diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/DsTaskingMapper.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/DsTaskingMapper.java index 9f9b9f27..8638fd9c 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/DsTaskingMapper.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/DsTaskingMapper.java @@ -132,5 +132,5 @@ public interface DsTaskingMapper extends BaseMapper { List getOldMesAllPart(@Param("startTime") String startTime, @Param("endTime") String endTime, - @Param("partCode") String partCode); + @Param("partCodeList") List partCodeList); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/TaskingMapper.xml b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/TaskingMapper.xml index 57c1632b..cfbc25f8 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/TaskingMapper.xml +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/TaskingMapper.xml @@ -144,9 +144,12 @@ AND UPDATE_TIME BETWEEN to_date(#{startTime}, 'YYYY-MM-DD HH24:MI:SS') AND to_date(#{endTime}, 'YYYY-MM-DD HH24:MI:SS') - - AND part_code = #{partCode} - + + and part_code in + + #{partCode} + + diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java index 41233778..d80613a8 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java @@ -1572,10 +1572,10 @@ public class DsTaskingServiceImpl extends BaseServiceImpl codeList = Arrays.asList(partCode.split(",")); //查询所有老mes零件 - List dsPartEntityList = taskingMapper.getOldMesAllPart(startTime,endTime,partCode); + List dsPartEntityList = taskingMapper.getOldMesAllPart(startTime,endTime,codeList); for (DsPartEntity partEntity : dsPartEntityList) { - // 2. 递归处理零件及其子件 DsPartEntity newPart = processPartRecursively(partEntity); if (newPart == null) { diff --git a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/SameTroughMapper.xml b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/SameTroughMapper.xml index ca2583e8..9e8b2cd8 100644 --- a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/SameTroughMapper.xml +++ b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/SameTroughMapper.xml @@ -55,6 +55,7 @@ FROM MES_YIELD_ORDER a LEFT JOIN DS_PART b ON a.PART_CODE = b.PART_CODE + LEFT JOIN DS_PART_VERSION d ON b.ID = d.PART_ID AND a.PART_VERSION = d.PART_VERSION AND a.PART_CODE = d.PART_CODE LEFT JOIN MES_YIELD_ORDER_CRAFT c ON a.id = c.yo_id a.is_deleted = 0 AND c.WORK_CENTER_ID IS NOT NULL diff --git a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/WorkOrderMapper.xml b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/WorkOrderMapper.xml index 93f456ae..9c01a6eb 100644 --- a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/WorkOrderMapper.xml +++ b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/mapper/WorkOrderMapper.xml @@ -129,9 +129,9 @@ and a.wo_code = #{woCode} - + and b.equip_name = #{equipName} diff --git a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/service/impl/WorkOrderServiceImpl.java b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/service/impl/WorkOrderServiceImpl.java index 552a0a97..036234bd 100644 --- a/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/service/impl/WorkOrderServiceImpl.java +++ b/blade-service/blade-scheduling/src/main/java/org/springblade/scheduling/scheduling/service/impl/WorkOrderServiceImpl.java @@ -282,6 +282,20 @@ public class WorkOrderServiceImpl extends BaseServiceImpl { + return entry.getValue().stream() + .anyMatch(dto -> workOrder.getTeamName().equals(dto.getTeamName())); + }) + .collect(Collectors.toMap( + Map.Entry::getKey, + Map.Entry::getValue, + (oldValue, newValue) -> oldValue, + LinkedHashMap::new + )); + } List resultList = new ArrayList<>(); for (Map.Entry> entry : woCodeGroup.entrySet()) { //根据工序名称过滤订单 @@ -413,9 +427,10 @@ public class WorkOrderServiceImpl extends BaseServiceImpl craftAbilityMap) { List glassCakeOutList = new ArrayList<>(); List workOrderList = new ArrayList<>(); - list = mergeYieldOrderList(list); + //list = mergeYieldOrderList(list); LocalDateTime localDateTime = LocalDateTime.now(); for (YieldOrderEntity order : list) { + log.info("当前订单id是:" + order.getId()); try { DsPartVersionEntity partVersion = partVersionService.getOne(Wrappers.lambdaQuery().eq(DsPartVersionEntity::getPartCode,order.getPartCode()).eq(DsPartVersionEntity::getPartVersion,order.getPartVersion())); if(partVersion == null){ @@ -463,6 +478,7 @@ public class WorkOrderServiceImpl extends BaseServiceImpllambdaQuery().eq(OutsourceProcessEntity::getProcessId, craft.getPpsId())); @@ -891,7 +907,7 @@ public class WorkOrderServiceImpl extends BaseServiceImpl> dealCommonCraftOrders() { + log.info("处理前置公共工序开始!"); List commonCraftOrderList = yieldOrderService.selectCommonCraftOrderList(); Map> planMap = new HashMap<>(); if (CollectionUtils.isNotEmpty(commonCraftOrderList)) { @@ -1295,6 +1312,7 @@ public class WorkOrderServiceImpl extends BaseServiceImpl sintList = sintMap.get(craft.getPpsId()); List> sintMaterialList = new ArrayList<>(); - sintList.stream().map(SintTempCurveEntity::getGlassCode).collect(Collectors.toList()).forEach(item -> sintMaterialList.add(Arrays.asList(item.split(",")))); + sintList.stream().map(SintTempCurveEntity::getGlassCode).collect(Collectors.toList()).forEach(item -> sintMaterialList.add(Arrays.asList(item.split(" ")))); //根据零件号获取子件信息 List partRelationList = partRelationService.list(Wrappers.lambdaQuery().eq(PartRelationEntity::getPartId,part.getId()));