From 33308e16bbb153d9aac76fd703ec0f38ea7e344a Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期三, 09 十月 2024 15:47:59 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java | 229 ++++++++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 179 insertions(+), 50 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java index e214749..67232f0 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java @@ -10,6 +10,7 @@ import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.mes.common.config.Const; import com.mes.damage.entity.Damage; +import com.mes.damage.mapper.DamageMapper; import com.mes.damage.service.DamageService; import com.mes.edgglasstask.entity.EdgGlassTaskInfo; import com.mes.edgglasstask.entity.request.IdentWornRequest; @@ -19,6 +20,9 @@ import com.mes.edgstoragecage.mapper.EdgStorageCageDetailsMapper; import com.mes.edgstoragecage.mapper.EdgStorageCageMapper; import com.mes.edgstoragecage.service.EdgStorageCageDetailsService; +import com.mes.engineering.entity.Engineering; +import com.mes.engineering.mapper.EngineeringMapper; +import com.mes.glassinfo.entity.GlassInfo; import com.mes.glassinfo.mapper.GlassInfoMapper; import com.mes.pp.entity.OptimizeDetail; import com.mes.pp.entity.OptimizeLayout; @@ -54,6 +58,9 @@ UpPattenUsageMapper upPattenUsageMapper; @Autowired + EngineeringMapper engineeringMapper; + + @Autowired OptimizeDetailMapper optimizeDetailMapper; @Autowired @@ -65,11 +72,48 @@ TaskCacheService taskCacheService; @Autowired + DamageMapper damageMapper; + + @Autowired DamageService damageService; @Autowired EdgGlassTaskInfoService edgGlassTaskInfoService; - +// +// @Override +// public boolean identWorn(Map<String, Object> arguments) { +// String glassId=arguments.get("glassId").toString(); +// int state=arguments.get("state").toString().isEmpty()?0:Integer.parseInt(arguments.get("state").toString()); +// int line=arguments.get("line").toString().isEmpty()?0:Integer.parseInt(arguments.get("line").toString()); +// String workingProcedure=arguments.get("workingProcedure").toString(); +// if(state==0||line==0||workingProcedure==null||glassId==null||glassId.isEmpty()){ +// log.info("鍓嶇浼犻�掓暟鎹笉鍏�:{}",arguments); +// return false; +// } +// List<GlassInfo> GlassInfos = glassInfoMapper.selectList(new MPJLambdaQueryWrapper<GlassInfo>() +// .selectAll(GlassInfo.class) +// .eq(GlassInfo::getGlassId, glassId)); +// if (GlassInfos.size() == 1) { +// Damage damage =new Damage(); +// damage.setGlassId(glassId); +// damage.setLine(line); +// damage.setWorkingProcedure(workingProcedure); +// damage.setRemark(""); +// damage.setStatus(state);//8鐮存崯锛�9鎷胯蛋 +// damageService.insertDamage(damage); +// }else{ +// return false; +// } +// List<EdgStorageCageDetails> edgStorageCageDetails = baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() +// .selectAll(EdgStorageCageDetails.class) +// .eq(EdgStorageCageDetails::getGlassId, glassId)); +// if (edgStorageCageDetails.size() == 1) { +// EdgStorageCageDetails item = edgStorageCageDetails.get(0); +// item.setState(state); +// baseMapper.update(item, new MPJLambdaWrapper<EdgStorageCageDetails>().selectAll(EdgStorageCageDetails.class).eq(EdgStorageCageDetails::getGlassId, glassId)); +// } +// return true; +// } /** * 鑾峰彇 鍒囧壊褰撳墠鐗堝浘 * @@ -77,13 +121,67 @@ */ @Override public List<Map<String, Object>> selectCutTerritory() { - List<UpPattenUsage> upPattenUsage = upPattenUsageMapper.selectList(new MPJLambdaWrapper<UpPattenUsage>() + //鏌ヨEdgStorageCageDetails鏈�鍚庝竴寮犵幓鐠冩墍灞炵増鍥� + List<UpPattenUsage> upPattenUsage=upPattenUsageMapper.selectJoinList(UpPattenUsage.class, new MPJLambdaWrapper<UpPattenUsage>() .selectAll(UpPattenUsage.class) - .orderByDesc(UpPattenUsage::getState) - .orderByDesc(UpPattenUsage::getId)); + .distinct() + .innerJoin(Engineering.class, on -> on + .eq(Engineering::getEngineerId, UpPattenUsage::getEngineeringId)) + .innerJoin(GlassInfo.class, on -> on + .eq(GlassInfo::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(GlassInfo::getPatternSequence,UpPattenUsage::getLayoutSequence)) + .leftJoin(EdgStorageCageDetails.class, on -> on + .eq(EdgStorageCageDetails::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(EdgStorageCageDetails::getGlassId,GlassInfo::getGlassId)) + .leftJoin(Damage.class, on -> on + .eq(Damage::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(Damage::getGlassId,GlassInfo::getGlassId)) + .eq(Engineering::getState,1) + .and(wrapper->wrapper.isNotNull(EdgStorageCageDetails::getId).or().isNotNull(Damage::getId)) + .orderByDesc(UpPattenUsage::getLayoutSequence) + .orderByDesc(GlassInfo::getId) + ); if (!upPattenUsage.isEmpty()) { + //褰撳墠鐗� UpPattenUsage upPattenUsage1 = upPattenUsage.get(0); - List<Map<String, Object>> cutTerritorys = optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) + //鏌ョ湅褰撳墠鐗堟槸鍚﹀瓨鍦ㄦ湭杩涚瀛愭垨鐮存崯鐨勭幓鐠� + List<UpPattenUsage> upPattenUsage2=upPattenUsageMapper.selectJoinList(UpPattenUsage.class, new MPJLambdaWrapper<UpPattenUsage>() + .selectAll(UpPattenUsage.class) + .distinct() + .innerJoin(GlassInfo.class, on -> on + .eq(GlassInfo::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(GlassInfo::getPatternSequence,UpPattenUsage::getLayoutSequence)) + .leftJoin(EdgStorageCageDetails.class, on -> on + .eq(EdgStorageCageDetails::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(EdgStorageCageDetails::getGlassId,GlassInfo::getGlassId)) + .leftJoin(Damage.class, on -> on + .eq(Damage::getEngineerId, UpPattenUsage::getEngineeringId) + .eq(Damage::getGlassId,GlassInfo::getGlassId)) + .eq(UpPattenUsage::getEngineeringId,upPattenUsage.get(0).getEngineeringId()) + .eq(UpPattenUsage::getLayoutSequence,upPattenUsage.get(0).getLayoutSequence()) + .and(wrapper->wrapper.isNull(EdgStorageCageDetails::getId).or().isNull(Damage::getId)) + .orderByDesc(UpPattenUsage::getLayoutSequence) + .orderByDesc(GlassInfo::getId) + ); + //鏄剧ず涓嬩竴鐗� 鍚﹀垯鏄剧ず褰撳墠鐗堝浘 + if(upPattenUsage2.isEmpty()){ + //鍓╀綑鐗堝浘 + List<UpPattenUsage> upPattenUsage3=upPattenUsageMapper.selectJoinList(UpPattenUsage.class, new MPJLambdaWrapper<UpPattenUsage>() + .selectAll(UpPattenUsage.class) + .distinct() + .innerJoin(Engineering.class, on -> on + .eq(Engineering::getEngineerId, UpPattenUsage::getEngineeringId)) + .eq(Engineering::getState,1) + .gt(UpPattenUsage::getLayoutSequence,upPattenUsage1.getLayoutSequence()) + .orderByAsc(UpPattenUsage::getLayoutSequence) + ); + if(!upPattenUsage3.isEmpty()){ + //鍒囨崲鎴愪笅涓�鐗堝浘 + upPattenUsage1=upPattenUsage3.get(0); + } + } + + List<Map<String, Object>> cutTerritorys=optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) .selectAll(OptimizeDetail.class) .selectAs(OptimizeLayout::getWidth, "olWidth") .selectAs(OptimizeLayout::getHeight, "olHeight") @@ -93,29 +191,36 @@ .eq(OptimizeDetail::getProjectNo, upPattenUsage1.getEngineeringId()) .eq(OptimizeDetail::getStockId, upPattenUsage1.getLayoutSequence()) ); - List<Map<String, Object>> ResultcutTerritorys = new ArrayList<>(); - for (Map<String, Object> cutTerritory : cutTerritorys) { - EdgStorageCageDetails edgStorageCageDetails = baseMapper.selectOne(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() - .selectAll(EdgStorageCageDetails.class) - .eq(EdgStorageCageDetails::getGlassId, cutTerritory.get("glass_id")) - .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)); -// log.info("鍐呭锛歿}-------{}",cutTerritory,edgStorageCageDetails); - if (edgStorageCageDetails != null) { - cutTerritory.put("glass_state", edgStorageCageDetails.getState()); - } else { - cutTerritory.put("glass_state", 0); - } - ResultcutTerritorys.add(cutTerritory); - } - return ResultcutTerritorys; + Map<String, EdgStorageCageDetails> edgMaps=baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() + .selectAll(EdgStorageCageDetails.class) + .eq(EdgStorageCageDetails::getEngineerId,upPattenUsage1.getEngineeringId()) + ).stream().collect(Collectors.toMap(EdgStorageCageDetails::getGlassId,EdgStorageCageDetails->EdgStorageCageDetails)); -// Sql鐗堟湰 -// return optimizeDetailMapper.selectJoinMaps(new MPJQueryWrapper<OptimizeDetail>().selectAll(OptimizeDetail.class) -// .select("ol.width as olwidth","ol.height as olheight") -// .leftJoin("optimize_layout ol on t.project_no=ol.project_no and t.stock_id=ol.stock_id") -// .eq("t.project_no", upPattenUsage1.getEngineeringId()) -// .eq("t.stock_id",upPattenUsage1.getLayoutSequence()) -// ); + Map<String, Damage> damageMaps=damageMapper.selectList(new MPJLambdaQueryWrapper<Damage>() + .selectAll(Damage.class) + .eq(Damage::getEngineerId,upPattenUsage1.getEngineeringId()) + .and(wrapper->wrapper.eq(Damage::getType,8) + .or() + .eq(Damage::getType,9)) + ).stream().collect(Collectors.toMap(Damage::getGlassId,Damage->Damage,(V1,V2)->V2)); + + List<Map<String, Object>> resultCutTerritory=new ArrayList<>(); + for (Map<String, Object> cutTerritory : cutTerritorys) { +// log.info("鍐呭锛歿}-------{}",cutTerritory,edgStorageCageDetails); + if(cutTerritory.get("glass_id")==null||"".equals(cutTerritory.get("glass_id"))){ + log.info("浼樺寲鏁版嵁涓璯lassId瀛樺湪绌哄��-----鍐呭锛歿}",cutTerritorys); + return new ArrayList<>(); + }else if(damageMaps.get(cutTerritory.get("glass_id"))!=null){ + //log.info("鐜荤拑宸茬牬鎹�/鎷胯蛋-----鍐呭锛歿}",damageMaps.get(item.get("glass_id"))); + cutTerritory.put("glass_state",damageMaps.get(cutTerritory.get("glass_id")).getType()); + }else if(edgMaps.get(cutTerritory.get("glass_id"))!=null){ + cutTerritory.put("glass_state",edgMaps.get(cutTerritory.get("glass_id")).getState()); + }else{ + cutTerritory.put("glass_state",0); + } + resultCutTerritory.add(cutTerritory); + } + return resultCutTerritory; } return null; } @@ -128,10 +233,19 @@ */ @Override public List<List<Map<String, Object>>> selectCurrentCutTerritory(String current) { + + List<Engineering> engineering=engineeringMapper.selectJoinList(Engineering.class, new MPJLambdaWrapper<Engineering>() + .selectAll(Engineering.class) + .eq(Engineering::getEngineerId,current) + ); + if(engineering.size()==0){ + log.info("褰撳墠宸ョ▼鍙锋湭棰嗗彇杩�:{}",current); + return new ArrayList<>(); + } //缁撴灉 - List<Map<String, Object>> ResultcutTerritorys = new ArrayList<>(); + List<Map<String, Object>> resultCutTerritory=new ArrayList<>(); //姝ゅ伐绋嬬殑鎵�鏈変紭鍖栨暟鎹� - List<Map<String, Object>> cutTerritorys = optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) + List<Map<String, Object>> cutTerritory=optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class) .selectAll(OptimizeDetail.class) .selectAs(OptimizeLayout::getWidth, "olWidth") .selectAs(OptimizeLayout::getHeight, "olHeight") @@ -141,32 +255,47 @@ .eq(OptimizeDetail::getProjectNo, current) ); - Map<String, EdgStorageCageDetails> edgMaps = baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() + Map<String, EdgStorageCageDetails> edgMaps=baseMapper.selectList(new MPJLambdaQueryWrapper<EdgStorageCageDetails>() .selectAll(EdgStorageCageDetails.class) - .eq(EdgStorageCageDetails::getEngineerId, current) - .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN) - ).stream().collect(Collectors.toMap(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails -> EdgStorageCageDetails)); - for (Map<String, Object> cutTerritory : cutTerritorys) { -// log.info("鍐呭锛歿}-------{}",cutTerritory,edgStorageCageDetails); - if (cutTerritory.get("glass_id") == null || "".equals(cutTerritory.get("glass_id"))) { - log.info("浼樺寲鏁版嵁涓璯lassId瀛樺湪绌哄��-----鍐呭锛歿}", cutTerritorys); + .eq(EdgStorageCageDetails::getEngineerId,current) + ).stream().collect(Collectors.toMap(EdgStorageCageDetails::getGlassId,EdgStorageCageDetails->EdgStorageCageDetails,(V1,V2)->V2)); + + Map<String, Damage> damageMaps=damageMapper.selectList(new MPJLambdaQueryWrapper<Damage>() + .selectAll(Damage.class) + .eq(Damage::getEngineerId,current) + .and(wrapper->wrapper.eq(Damage::getType,8) + .or() + .eq(Damage::getType,9)) + ).stream().collect(Collectors.toMap(Damage::getGlassId,Damage->Damage,(V1,V2)->V2)); + + for (Map<String, Object> item : cutTerritory) { +// log.info("鍐呭锛歿}-------{}",cutTerritory,edgStorageCageDetails); + if(item.get("glass_id")==null||"".equals(item.get("glass_id"))){ + log.info("浼樺寲鏁版嵁涓璯lassId瀛樺湪绌哄��-----鍐呭锛歿}",cutTerritory); return new ArrayList<>(); - } else if (edgMaps.get(cutTerritory.get("glass_id")) != null) { - cutTerritory.put("glass_state", edgMaps.get(cutTerritory.get("glass_id")).getState()); - } else { - cutTerritory.put("glass_state", 0); } - ResultcutTerritorys.add(cutTerritory); + if(damageMaps.get(item.get("glass_id"))!=null){ + //log.info("鐜荤拑宸茬牬鎹�/鎷胯蛋-----鍐呭锛歿}",damageMaps.get(item.get("glass_id"))); + item.put("glass_state",damageMaps.get(item.get("glass_id")).getType()); + }else if(edgMaps.get(item.get("glass_id"))!=null){ + item.put("glass_state",edgMaps.get(item.get("glass_id")).getState()); + }else{ + item.put("glass_state",0); + } + resultCutTerritory.add(item); } - Map<String, List<Map<String, Object>>> groupBy = ResultcutTerritorys.stream().collect(Collectors.groupingBy(item -> item.get("stock_id").toString())); + Map<String, List<Map<String, Object>>> groupBy=resultCutTerritory.stream().collect(Collectors.groupingBy(item->item.get("stock_id").toString())); // List<List<Map<String, Object>>> Result=groupBy.values().stream().collect(Collectors.toList()); - return new ArrayList<>(groupBy.values()); -//Sql鐗堟湰 -// return optimizeDetailMapper.selectJoinMaps(new MPJQueryWrapper<OptimizeDetail>().selectAll(OptimizeDetail.class) -// .select("ol.width as olwidth","ol.height as olheight") -// .leftJoin("optimize_layout ol on t.project_no=ol.project_no and t.stock_id=ol.stock_id") -// .eq("t.project_no",current) -// ); + int count=1; + List<List<Map<String, Object>>> result=new ArrayList<>(); + for (String item : groupBy.keySet()) { + String key=count+""; + if(key!=null){ + result.add(groupBy.get(key)); + } + count++; + } + return result; } /** -- Gitblit v1.8.0