Skip to content
项目
群组
代码片段
帮助
正在加载...
帮助
提交反馈
为 GitLab 提交贡献
登录
切换导航
I
iBiz商业中心
项目
项目
详情
动态
版本
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
计划
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
iBiz商业套件
iBiz商业中心
提交
ff1ceb12
提交
ff1ceb12
编写于
10月 29, 2020
作者:
misaka
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
delete
上级
d92f3a7a
变更
1
隐藏空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
0 行增加
和
442 行删除
+0
-442
Purchase_requisitionServiceImpl.java
...urchase/service/impl/Purchase_requisitionServiceImpl.java
+0
-442
未找到文件。
businesscentral-core/src/main/java/cn/ibizlab/businesscentral/core/odoo_purchase/service/impl/Purchase_requisitionServiceImpl.java
已删除
100644 → 0
浏览文件 @
d92f3a7a
package
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
service
.
impl
;
import
java.io.Serializable
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.Set
;
import
java.util.Map
;
import
java.util.HashSet
;
import
java.util.HashMap
;
import
java.util.Collection
;
import
java.util.Objects
;
import
java.util.Optional
;
import
java.math.BigInteger
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.cglib.beans.BeanCopier
;
import
org.springframework.stereotype.Service
;
import
org.springframework.data.domain.Page
;
import
org.springframework.data.domain.PageImpl
;
import
org.springframework.data.domain.Pageable
;
import
org.springframework.util.ObjectUtils
;
import
org.springframework.beans.factory.annotation.Value
;
import
cn.ibizlab.businesscentral.util.errors.BadRequestAlertException
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.context.annotation.Lazy
;
import
cn.ibizlab.businesscentral.core.odoo_purchase.domain.Purchase_requisition
;
import
cn.ibizlab.businesscentral.core.odoo_purchase.filter.Purchase_requisitionSearchContext
;
import
cn.ibizlab.businesscentral.core.odoo_purchase.service.IPurchase_requisitionService
;
import
cn.ibizlab.businesscentral.util.helper.CachedBeanCopier
;
import
cn.ibizlab.businesscentral.util.helper.DEFieldCacheMap
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
cn.ibizlab.businesscentral.core.util.helper.EBSServiceImpl
;
import
cn.ibizlab.businesscentral.core.odoo_purchase.mapper.Purchase_requisitionMapper
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.baomidou.mybatisplus.core.conditions.Wrapper
;
import
com.alibaba.fastjson.JSONObject
;
import
org.springframework.util.StringUtils
;
/**
* 实体[采购申请] 服务对象接口实现
*/
@Slf4j
@Service
(
"Purchase_requisitionServiceImpl"
)
public
class
Purchase_requisitionServiceImpl
extends
EBSServiceImpl
<
Purchase_requisitionMapper
,
Purchase_requisition
>
implements
IPurchase_requisitionService
{
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
service
.
IPurchase_orderService
purchaseOrderService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
service
.
IPurchase_requisition_lineService
purchaseRequisitionLineService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
service
.
IPurchase_requisition_typeService
purchaseRequisitionTypeService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
service
.
IRes_companyService
resCompanyService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
service
.
IRes_currencyService
resCurrencyService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
service
.
IRes_supplierService
resSupplierService
;
@Autowired
@Lazy
protected
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
service
.
IRes_usersService
resUsersService
;
protected
int
batchSize
=
500
;
public
String
getIrModel
(){
return
"purchase.requisition"
;
}
@Override
@Transactional
public
boolean
create
(
Purchase_requisition
et
)
{
boolean
mail_create_nosubscribe
=
et
.
get
(
"mail_create_nosubscribe"
)
!=
null
;
boolean
mail_create_nolog
=
et
.
get
(
"mail_create_nolog"
)
!=
null
;
boolean
mail_notrack
=
et
.
get
(
"mail_notrack"
)
!=
null
;
fillParentData
(
et
);
if
(!
this
.
retBool
(
this
.
baseMapper
.
insert
(
et
)))
return
false
;
CachedBeanCopier
.
copy
(
get
(
et
.
getId
()),
et
);
if
(!
mail_create_nosubscribe
)
{
cn
.
ibizlab
.
businesscentral
.
util
.
security
.
SpringContextHolder
.
getBean
(
cn
.
ibizlab
.
businesscentral
.
core
.
extensions
.
service
.
Mail_followersExService
.
class
).
add_default_followers
(
this
,
et
);
}
if
(!
mail_create_nolog
)
{
cn
.
ibizlab
.
businesscentral
.
util
.
security
.
SpringContextHolder
.
getBean
(
cn
.
ibizlab
.
businesscentral
.
core
.
extensions
.
service
.
Mail_tracking_valueExService
.
class
).
add_default_create_message
(
this
,
et
);
}
if
(!
mail_notrack
)
{
}
return
true
;
}
@Override
@Transactional
public
void
createBatch
(
List
<
Purchase_requisition
>
list
)
{
list
.
forEach
(
item
->
fillParentData
(
item
));
this
.
saveBatch
(
list
,
batchSize
);
}
@Override
@Transactional
public
boolean
update
(
Purchase_requisition
et
)
{
Purchase_requisition
old
=
new
Purchase_requisition
()
;
CachedBeanCopier
.
copy
(
get
(
et
.
getId
()),
old
);
boolean
mail_notrack
=
et
.
get
(
"mail_notrack"
)
!=
null
;
fillParentData
(
et
);
if
(!
update
(
et
,(
Wrapper
)
et
.
getUpdateWrapper
(
true
).
eq
(
"id"
,
et
.
getId
())))
return
false
;
CachedBeanCopier
.
copy
(
get
(
et
.
getId
()),
et
);
if
(!
mail_notrack
)
{
cn
.
ibizlab
.
businesscentral
.
util
.
security
.
SpringContextHolder
.
getBean
(
cn
.
ibizlab
.
businesscentral
.
core
.
extensions
.
service
.
Mail_tracking_valueExService
.
class
).
message_track
(
this
,
old
,
et
);
}
return
true
;
}
@Override
@Transactional
public
void
updateBatch
(
List
<
Purchase_requisition
>
list
)
{
list
.
forEach
(
item
->
fillParentData
(
item
));
updateBatchById
(
list
,
batchSize
);
}
@Override
@Transactional
public
boolean
remove
(
Long
key
)
{
boolean
result
=
removeById
(
key
);
return
result
;
}
@Override
@Transactional
public
void
removeBatch
(
Collection
<
Long
>
idList
)
{
removeByIds
(
idList
);
}
@Override
@Transactional
public
Purchase_requisition
get
(
Long
key
)
{
Purchase_requisition
et
=
getById
(
key
);
if
(
et
==
null
){
et
=
new
Purchase_requisition
();
et
.
setId
(
key
);
}
else
{
}
return
et
;
}
@Override
public
Purchase_requisition
getDraft
(
Purchase_requisition
et
)
{
fillParentData
(
et
);
return
et
;
}
@Override
@Transactional
public
Purchase_requisition
action_cancel
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
Purchase_requisition
action_done
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
Purchase_requisition
action_draft
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
Purchase_requisition
action_in_progress
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
Purchase_requisition
action_open
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
public
boolean
checkKey
(
Purchase_requisition
et
)
{
return
(!
ObjectUtils
.
isEmpty
(
et
.
getId
()))&&(!
Objects
.
isNull
(
this
.
getById
(
et
.
getId
())));
}
@Override
@Transactional
public
Purchase_requisition
masterTabCount
(
Purchase_requisition
et
)
{
//自定义代码
return
et
;
}
@Override
@Transactional
public
boolean
save
(
Purchase_requisition
et
)
{
if
(!
saveOrUpdate
(
et
))
return
false
;
return
true
;
}
@Override
@Transactional
public
boolean
saveOrUpdate
(
Purchase_requisition
et
)
{
if
(
null
==
et
)
{
return
false
;
}
else
{
return
checkKey
(
et
)
?
this
.
update
(
et
)
:
this
.
create
(
et
);
}
}
@Override
@Transactional
public
boolean
saveBatch
(
Collection
<
Purchase_requisition
>
list
)
{
list
.
forEach
(
item
->
fillParentData
(
item
));
saveOrUpdateBatch
(
list
,
batchSize
);
return
true
;
}
@Override
@Transactional
public
void
saveBatch
(
List
<
Purchase_requisition
>
list
)
{
list
.
forEach
(
item
->
fillParentData
(
item
));
saveOrUpdateBatch
(
list
,
batchSize
);
}
@Override
public
List
<
Purchase_requisition
>
selectByTypeId
(
Long
id
)
{
return
baseMapper
.
selectByTypeId
(
id
);
}
@Override
public
void
removeByTypeId
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"type_id"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByCompanyId
(
Long
id
)
{
return
baseMapper
.
selectByCompanyId
(
id
);
}
@Override
public
void
removeByCompanyId
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"company_id"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByCurrencyId
(
Long
id
)
{
return
baseMapper
.
selectByCurrencyId
(
id
);
}
@Override
public
void
removeByCurrencyId
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"currency_id"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByVendorId
(
Long
id
)
{
return
baseMapper
.
selectByVendorId
(
id
);
}
@Override
public
void
removeByVendorId
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"vendor_id"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByCreateUid
(
Long
id
)
{
return
baseMapper
.
selectByCreateUid
(
id
);
}
@Override
public
void
removeByCreateUid
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"create_uid"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByUserId
(
Long
id
)
{
return
baseMapper
.
selectByUserId
(
id
);
}
@Override
public
void
removeByUserId
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"user_id"
,
id
));
}
@Override
public
List
<
Purchase_requisition
>
selectByWriteUid
(
Long
id
)
{
return
baseMapper
.
selectByWriteUid
(
id
);
}
@Override
public
void
removeByWriteUid
(
Long
id
)
{
this
.
remove
(
new
QueryWrapper
<
Purchase_requisition
>().
eq
(
"write_uid"
,
id
));
}
/**
* 查询集合 数据集
*/
@Override
public
Page
<
Purchase_requisition
>
searchDefault
(
Purchase_requisitionSearchContext
context
)
{
com
.
baomidou
.
mybatisplus
.
extension
.
plugins
.
pagination
.
Page
<
Purchase_requisition
>
pages
=
baseMapper
.
searchDefault
(
context
.
getPages
(),
context
,
context
.
getSelectCond
());
return
new
PageImpl
<
Purchase_requisition
>(
pages
.
getRecords
(),
context
.
getPageable
(),
pages
.
getTotal
());
}
/**
* 为当前实体填充父数据(外键值文本、外键值附加数据)
* @param et
*/
private
void
fillParentData
(
Purchase_requisition
et
){
//实体关系[DER1N_PURCHASE_REQUISITION_PURCHASE_REQUISITION_TYPE_TYPE_ID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getTypeId
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
domain
.
Purchase_requisition_type
odooType
=
et
.
getOdooType
();
if
(
ObjectUtils
.
isEmpty
(
odooType
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_purchase
.
domain
.
Purchase_requisition_type
majorEntity
=
purchaseRequisitionTypeService
.
get
(
et
.
getTypeId
());
et
.
setOdooType
(
majorEntity
);
odooType
=
majorEntity
;
}
et
.
setTypeIdText
(
odooType
.
getName
());
et
.
setQuantityCopy
(
odooType
.
getQuantityCopy
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_COMPANY_COMPANY_ID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getCompanyId
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_company
odooCompany
=
et
.
getOdooCompany
();
if
(
ObjectUtils
.
isEmpty
(
odooCompany
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_company
majorEntity
=
resCompanyService
.
get
(
et
.
getCompanyId
());
et
.
setOdooCompany
(
majorEntity
);
odooCompany
=
majorEntity
;
}
et
.
setCompanyName
(
odooCompany
.
getName
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_CURRENCY_CURRENCY_ID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getCurrencyId
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_currency
odooCurrency
=
et
.
getOdooCurrency
();
if
(
ObjectUtils
.
isEmpty
(
odooCurrency
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_currency
majorEntity
=
resCurrencyService
.
get
(
et
.
getCurrencyId
());
et
.
setOdooCurrency
(
majorEntity
);
odooCurrency
=
majorEntity
;
}
et
.
setCurrencyName
(
odooCurrency
.
getName
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_SUPPLIER_VENDOR_ID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getVendorId
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_supplier
odooVendor
=
et
.
getOdooVendor
();
if
(
ObjectUtils
.
isEmpty
(
odooVendor
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_supplier
majorEntity
=
resSupplierService
.
get
(
et
.
getVendorId
());
et
.
setOdooVendor
(
majorEntity
);
odooVendor
=
majorEntity
;
}
et
.
setVendorIdText
(
odooVendor
.
getName
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_USERS_CREATE_UID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getCreateUid
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
odooCreate
=
et
.
getOdooCreate
();
if
(
ObjectUtils
.
isEmpty
(
odooCreate
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
majorEntity
=
resUsersService
.
get
(
et
.
getCreateUid
());
et
.
setOdooCreate
(
majorEntity
);
odooCreate
=
majorEntity
;
}
et
.
setCreateUname
(
odooCreate
.
getName
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_USERS_USER_ID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getUserId
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
odooUser
=
et
.
getOdooUser
();
if
(
ObjectUtils
.
isEmpty
(
odooUser
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
majorEntity
=
resUsersService
.
get
(
et
.
getUserId
());
et
.
setOdooUser
(
majorEntity
);
odooUser
=
majorEntity
;
}
et
.
setUserName
(
odooUser
.
getName
());
}
//实体关系[DER1N_PURCHASE_REQUISITION_RES_USERS_WRITE_UID]
if
(!
ObjectUtils
.
isEmpty
(
et
.
getWriteUid
())){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
odooWrite
=
et
.
getOdooWrite
();
if
(
ObjectUtils
.
isEmpty
(
odooWrite
)){
cn
.
ibizlab
.
businesscentral
.
core
.
odoo_base
.
domain
.
Res_users
majorEntity
=
resUsersService
.
get
(
et
.
getWriteUid
());
et
.
setOdooWrite
(
majorEntity
);
odooWrite
=
majorEntity
;
}
et
.
setWriteUname
(
odooWrite
.
getName
());
}
}
@Override
public
List
<
JSONObject
>
select
(
String
sql
,
Map
param
){
return
this
.
baseMapper
.
selectBySQL
(
sql
,
param
);
}
@Override
@Transactional
public
boolean
execute
(
String
sql
,
Map
param
){
if
(
sql
==
null
||
sql
.
isEmpty
())
{
return
false
;
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"insert"
))
{
return
this
.
baseMapper
.
insertBySQL
(
sql
,
param
);
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"update"
))
{
return
this
.
baseMapper
.
updateBySQL
(
sql
,
param
);
}
if
(
sql
.
toLowerCase
().
trim
().
startsWith
(
"delete"
))
{
return
this
.
baseMapper
.
deleteBySQL
(
sql
,
param
);
}
log
.
warn
(
"暂未支持的SQL语法"
);
return
true
;
}
}
编辑
预览
Markdown
格式
0%
请重试
or
添加新附件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
先完成此消息的编辑!
取消
想要评论请
注册
或
登录