From a0b6faef7b25572ef6f5c19aaacc8e0474ae7b3b Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期二, 04 三月 2025 10:49:46 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java |   35 ++++++++++++++++++++++++-----------
 1 files changed, 24 insertions(+), 11 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
index 5f12d21..97f4364 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/OPCPlcSlicecage.java
@@ -4,10 +4,13 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.kangaroohy.milo.model.ReadWriteEntity;
 import com.kangaroohy.milo.service.MiloService;
+import com.mes.bigstorage.entity.BigStorageCageDetails;
 import com.mes.bigstorage.service.BigStorageCageDetailsService;
 import com.mes.bigstorage.service.BigStorageCageService;
 import com.mes.bigstoragecagetask.entity.BigStorageCageTask;
+import com.mes.bigstoragecagetask.entity.BigStorageTaskVO;
 import com.mes.bigstoragecagetask.service.BigStorageCageTaskService;
+import com.mes.common.config.Const;
 import com.mes.glassinfo.service.GlassInfoService;
 import com.mes.temperingglass.entity.TemperingGlassInfo;
 import com.mes.temperingglass.service.TemperingGlassInfoService;
@@ -54,19 +57,26 @@
         carPostion.add(0.5);
         jsonObject.append("carPostion", carPostion);
         //鐣岄潰灞曠ず绗煎瓙淇℃伅
-      jsonObject.append("bigStorageCageInfos", bigStorageCageDetailsService.querybigStorageCageDetail());
+        jsonObject.append("bigStorageCageInfos", bigStorageCageDetailsService.querybigStorageCageDetail());
 
-        try{
+        try {
             //杩涚墖浠诲姟鏁版嵁
-            List<BigStorageCageTask> inTaskList = new ArrayList();
+            List<BigStorageTaskVO> inTaskList = new ArrayList();
             ReadWriteEntity fromOpcUa = miloService.readFromOpcUa("DLP1A.DLP1A.FROM1");
             for (int i = 1; i <= 6; i++) {
                 ReadWriteEntity requestWord = miloService.readFromOpcUa("DLP1A.DLP1A.DI" + i);
                 ReadWriteEntity targetSlotWord = miloService.readFromOpcUa("DLP1A.DLP1A.TO" + i);
                 ReadWriteEntity stateWord = miloService.readFromOpcUa("DLP1A.DLP1A.STATE" + i);
                 if (null != requestWord.getValue()) {
-                    BigStorageCageTask task = new BigStorageCageTask();
+                    BigStorageTaskVO task = new BigStorageTaskVO();
                     task.setGlassId(requestWord.getValue() + "");
+                    int isExistCount = bigStorageCageDetailsService.count(new LambdaQueryWrapper<BigStorageCageDetails>().in(BigStorageCageDetails::getGlassId, task.getGlassId())
+                            .in(BigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL_ZERO));
+                    if (isExistCount > 0) {
+                        task.setIsSame(1);
+                    } else {
+                        task.setIsSame(0);
+                    }
                     task.setStartSlot(Integer.parseInt(fromOpcUa.getValue() + ""));
                     task.setTargetSlot(Integer.parseInt(targetSlotWord.getValue() + ""));
                     task.setTaskState(Integer.parseInt(stateWord.getValue() + ""));
@@ -75,7 +85,10 @@
                 }
             }
             jsonObject.append("bigStorageCageDetailsFeedTask", inTaskList);
-
+        } catch (Exception e) {
+            //todo:涓嶅仛浠诲姟澶勭悊
+        }
+        try {
             //杩涚墖鑱旀満
             ReadWriteEntity inkageEntity = miloService.readFromOpcUa("DLP1A.DLP1A.mesControl");
             jsonObject.append("inkageEntity", inkageEntity.getValue());
@@ -91,14 +104,14 @@
             //鍑虹墖璇锋眰
             ReadWriteEntity outRequestEntity = miloService.readFromOpcUa("DLP1B.DLP1B.RequestMes");
             jsonObject.append("outRequestEntity", outRequestEntity.getValue());
-        }catch(Exception e){
+
+
+            //鍑虹墖浠诲姟鏁版嵁
+            List<BigStorageCageTask> outTaskList = bigStorageCageTaskService.queryTaskMessage("big_storage_cage_out_one_task");
+            jsonObject.append("bigStorageCageDetailsOutTask", outTaskList);
+        } catch (Exception e) {
             //todo:涓嶅仛浠诲姟澶勭悊
         }
-
-        //鍑虹墖浠诲姟鏁版嵁
-        List<BigStorageCageTask> outTaskList = bigStorageCageTaskService.queryTaskMessage("big_storage_cage_out_one_task");
-        jsonObject.append("bigStorageCageDetailsOutTask", outTaskList);
-
 
         //閽㈠寲寮�鍏�
         boolean temperingSwitch = false;

--
Gitblit v1.8.0