|
@@ -8,7 +8,6 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.fjhx.common.constant.SourceConstant;
|
|
|
-import com.fjhx.common.entity.contract.po.ContractTemplate;
|
|
|
import com.fjhx.common.enums.FlowStatusEnum1;
|
|
|
import com.fjhx.common.service.contract.ContractTemplateService;
|
|
|
import com.fjhx.common.service.corporation.CorporationService;
|
|
@@ -111,15 +110,6 @@ public class ContractProductServiceImpl extends ServiceImpl<ContractProductMappe
|
|
|
if (StringUtils.isNotEmpty(dto.getKeyword())) {
|
|
|
wrapper.keyword(dto.getKeyword(), new SqlField("t2.`code`"), new SqlField("t2.`user_name`"));
|
|
|
}
|
|
|
- //所属公司id过滤
|
|
|
- if (ObjectUtil.isNotEmpty(dto.getCorporationId())) {
|
|
|
- List<Long> ctIds = contractTemplateService.listObject(ContractTemplate::getId,
|
|
|
- q -> q.eq(ContractTemplate::getCorporationId, dto.getCorporationId()));
|
|
|
- if (ObjectUtil.isEmpty(ctIds)) {
|
|
|
- return new Page<>();
|
|
|
- }
|
|
|
- wrapper.in("t2.contract_template_id", ctIds);
|
|
|
- }
|
|
|
//是否到账过滤
|
|
|
if (ObjectUtil.isNotEmpty(dto.getIsReceived())) {
|
|
|
if (1 == dto.getIsReceived()) {
|
|
@@ -154,11 +144,6 @@ public class ContractProductServiceImpl extends ServiceImpl<ContractProductMappe
|
|
|
item.setProductCategory(productClassify.getName());
|
|
|
});
|
|
|
|
|
|
- // 赋值公司id
|
|
|
- contractTemplateService.attributeAssign(list, ContractProductVo::getContractTemplateId, (item, contractTemplate) -> {
|
|
|
- item.setCorporationId(contractTemplate.getCorporationId());
|
|
|
- });
|
|
|
-
|
|
|
// 赋值公司名称
|
|
|
corporationService.attributeAssign(list, ContractProductVo::getCorporationId, (item, corporation) -> {
|
|
|
item.setCorporationName(corporation.getName());
|
|
@@ -236,7 +221,7 @@ public class ContractProductServiceImpl extends ServiceImpl<ContractProductMappe
|
|
|
List<EhsdPurchaseProduct> purchaseProducts = ehsdPurchaseProductService.getPurchaseProductByContractProductIds(contractProductIds);
|
|
|
if (ObjectUtil.isNotEmpty(purchaseProducts)) {
|
|
|
Map<Long, List<EhsdPurchaseProduct>> collect = purchaseProducts.stream()
|
|
|
- .filter(item->ObjectUtil.isNotEmpty(item.getDataResourceId()))
|
|
|
+ .filter(item -> ObjectUtil.isNotEmpty(item.getDataResourceId()))
|
|
|
.collect(Collectors.groupingBy(EhsdPurchaseProduct::getDataResourceId));
|
|
|
for (ContractProduct contractProduct : list) {
|
|
|
List<EhsdPurchaseProduct> ehsdPurchaseProductList = collect.get(contractProduct.getId());
|
|
@@ -318,16 +303,16 @@ public class ContractProductServiceImpl extends ServiceImpl<ContractProductMappe
|
|
|
public Page<ContractProductVo> contractHandoverPage(ContractProductSelectDto dto) {
|
|
|
IWrapper<ContractProduct> wrapper = getWrapper();
|
|
|
wrapper.orderByDesc("t1.create_time");
|
|
|
- wrapper.eq("t2.is_delivery_file",1);
|
|
|
+ wrapper.eq("t2.is_delivery_file", 1);
|
|
|
if (StringUtils.isNotEmpty(dto.getKeyword())) {
|
|
|
DynamicDataSourceContextHolder.push(SourceConstant.BASE);
|
|
|
List<SysUser> list = userService.list(Wrappers.<SysUser>lambdaQuery().like(SysUser::getUserName, dto.getKeyword()));
|
|
|
DynamicDataSourceContextHolder.poll();
|
|
|
List<Long> userIds = list.stream().map(SysUser::getUserId).collect(Collectors.toList());
|
|
|
- wrapper.and(q->q
|
|
|
- .like("t2.`code`",dto.getKeyword())
|
|
|
- .or().like("t2.`user_name`",dto.getKeyword())
|
|
|
- .or().in("t2.create_user",userIds)
|
|
|
+ wrapper.and(q -> q
|
|
|
+ .like("t2.`code`", dto.getKeyword())
|
|
|
+ .or().like("t2.`user_name`", dto.getKeyword())
|
|
|
+ .or().in("t2.create_user", userIds)
|
|
|
);
|
|
|
}
|
|
|
wrapper.eq("t2.`status`", 30);
|
|
@@ -358,7 +343,7 @@ public class ContractProductServiceImpl extends ServiceImpl<ContractProductMappe
|
|
|
List<EhsdPurchaseProduct> purchaseProducts = ehsdPurchaseProductService.getPurchaseProductByContractProductIds(contractProductIds);
|
|
|
if (ObjectUtil.isNotEmpty(purchaseProducts)) {
|
|
|
Map<Long, List<EhsdPurchaseProduct>> collect = purchaseProducts.stream()
|
|
|
- .filter(item->ObjectUtil.isNotEmpty(item.getDataResourceId()))
|
|
|
+ .filter(item -> ObjectUtil.isNotEmpty(item.getDataResourceId()))
|
|
|
.collect(Collectors.groupingBy(EhsdPurchaseProduct::getDataResourceId));
|
|
|
for (ContractProduct contractProduct : list) {
|
|
|
List<EhsdPurchaseProduct> ehsdPurchaseProductList = collect.get(contractProduct.getId());
|