From d5c7b413380e3d722d97c9d33d4569b0dad1551e Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期一, 05 八月 2024 12:00:51 +0800
Subject: [PATCH] Merge branch 'master' of http://bore.pub:10439/r/HangZhouMes

---
 hangzhoumesParent/moduleService/CacheGlassModule/src/test/java/com/mes/CacheGlassModuleApplicationTest.java                              |    6 ++++++
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java                                           |   14 ++++++++++++--
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/edgstoragecage/service/impl/EdgStorageCageDetailsServiceImpl.java |   27 +++++++++++++++++++++++++--
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/controller/TaskCacheController.java                     |    3 +++
 4 files changed, 46 insertions(+), 4 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 b4c28b8..fd28610 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
@@ -31,6 +31,7 @@
 
 import javax.print.attribute.standard.MediaSize;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -183,8 +184,10 @@
      */
     @Override
     public List<Map<String, Object>> selectCurrentCutTerritory(String current) {
-
-        return optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class)
+        //鏈�缁堣繑鍥炵粨鏋�
+        List<Map<String, Object>> ResultcutTerritorys=new ArrayList<>();
+        //姝ゅ伐绋嬬殑鎵�鏈変紭鍖栨暟鎹�
+        List<Map<String, Object>> cutTerritorys=optimizeDetailMapper.selectJoinMaps(JoinWrappers.lambda(OptimizeDetail.class)
                 .selectAll(OptimizeDetail.class)
                 .selectAs(OptimizeLayout::getWidth, "olWidth")
                 .selectAs(OptimizeLayout::getWidth, "olHeight")
@@ -193,6 +196,26 @@
                         .eq(OptimizeLayout::getStockId, OptimizeDetail::getStockId))
                 .eq(OptimizeDetail::getProjectNo, current)
         );
+
+        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);
+                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);
+        }
+        return ResultcutTerritorys;
 //Sql鐗堟湰
 //        return optimizeDetailMapper.selectJoinMaps(new MPJQueryWrapper<OptimizeDetail>().selectAll(OptimizeDetail.class)
 //                .select("ol.width as olwidth","ol.height as olheight")
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
index ddbc9a9..0dd3ec0 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java
@@ -87,6 +87,8 @@
     @Value("${mes.min.two.secondLength}")
     private String minTwoSecondLength;
 
+    public static String engineerId="";
+
     @Scheduled(fixedDelay = 1000)
     public void plcHomeEdgTask() {
         Date startDate = new Date();
@@ -696,9 +698,17 @@
     @Scheduled(fixedDelay = 1000)
     public void CacheGlassTasks() {
         JSONObject jsonObject = new JSONObject();
-        //璇嗗埆鎽嗙墖
-        List<Map<String, Object>> currentCutTerritorys = edgStorageCageDetailsService.selectCutTerritory();
+        List<Map<String, Object>> currentCutTerritorys= edgStorageCageDetailsService.selectCutTerritory();
+//        List<Map<String, Object>> currentCutTerritorys=new ArrayList<>();
+//        if(engineerId==null||engineerId.isEmpty()){
+//            //璇嗗埆鎽嗙墖 褰撳墠鐗堝浘鏁版嵁
+//            currentCutTerritorys = edgStorageCageDetailsService.selectCutTerritory();
+//        }else{
+//            //璇嗗埆鎽嗙墖 姝ngineerId 宸ョ▼鐗堝浘鏁版嵁
+//            currentCutTerritorys = edgStorageCageDetailsService.selectCurrentCutTerritory(engineerId);
+//        }
         jsonObject.append("currentCutTerritory", currentCutTerritorys);
+        //log.info("鏈璇嗗埆鐗堝浘{},++++{}",engineerId,currentCutTerritorys);
         //纾ㄨ竟淇℃伅
         List<Map<String, Object>> EdgTasks1 = taskCacheService.selectEdgInfo("2001");
         List<Map<String, Object>> EdgTasks2 = taskCacheService.selectEdgInfo("2002");
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/controller/TaskCacheController.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/controller/TaskCacheController.java
index 6f09fea..8122b36 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/controller/TaskCacheController.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/taskcache/controller/TaskCacheController.java
@@ -13,6 +13,8 @@
 import java.util.List;
 import java.util.Map;
 
+import static com.mes.job.CacheGlassTask.engineerId;
+
 /**
  * <p>
  *  鍓嶇鎺у埗鍣�
@@ -38,6 +40,7 @@
     @PostMapping("/cutTerritory")
     @ResponseBody
     public Result cutTerritory(String current) {
+        //engineerId=current;
         List<Map<String, Object>> h = edgStorageCageDetailsService.selectCurrentCutTerritory(current);
         return Result.build(200,"鎴愬姛",h);
     }
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/test/java/com/mes/CacheGlassModuleApplicationTest.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/test/java/com/mes/CacheGlassModuleApplicationTest.java
index 19a87ce..8264682 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/test/java/com/mes/CacheGlassModuleApplicationTest.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/test/java/com/mes/CacheGlassModuleApplicationTest.java
@@ -137,6 +137,12 @@
     }
 
     @Test
+    public void testEngineerCutTerritory() {
+        List<Map<String, Object>> map = edgStorageCageDetailsService.selectCurrentCutTerritory("P24051806");
+        log.info("鍒囧壊宸ョ▼鐗堝浘淇℃伅锛歿}", Arrays.asList(map));
+    }
+
+    @Test
     public void testidentWorn() {
         Map<String, String> arguments=new HashMap<>();
         arguments.put("glassId","P24060403|3|6");//鐜荤拑ID

--
Gitblit v1.8.0