From ce47d94ceb8b3d8e7a85d429ce59e6af77b9c794 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期四, 07 十一月 2024 13:36:02 +0800
Subject: [PATCH] 修改卧式理片逻辑,大理片进片逻辑

---
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java |   76 ++++++++++++++++++++++++++------------
 1 files changed, 52 insertions(+), 24 deletions(-)

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 8e0191c..3d20506 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
@@ -100,7 +100,7 @@
 
     public static String engineerId = "";
 
-    @Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 500)
     public void plcHomeEdgTask() {
         Date startDate = new Date();
         log.info("鏈浠诲姟寮�濮嬫墽琛屾椂闂达細{}", startDate);
@@ -110,16 +110,22 @@
         String confirmationWrodValue = plcParameterObject.getPlcParameter("MES_confirmation_word").getValue();
         //A08  A09琛ㄧず绾胯矾鐩稿悓  鍙仛绛変环  鏃犳暟鎹浆int寮傚父
         String out08Glassstate = plcParameterObject.getPlcParameter("A08_glass_status").getValue();
+        String out09Glassstate = plcParameterObject.getPlcParameter("A09_glass_status").getValue();
         String out10Glassstate = plcParameterObject.getPlcParameter("A10_glass_status").getValue();
         String confirmationWrodAddress = plcParameterObject.getPlcParameter("MES_confirmation_word").getAddress();
         String currentSlot = plcParameterObject.getPlcParameter("Current_slot").getValue();
 
-//        taskRequestTypeValue = "2";
+        if ("1".equals(out09Glassstate)) {
+            log.info("A09绌洪棽");
+            out08Glassstate = "1";
+        }
+
+//        taskRequestTypeValue = "3";
 //        out08Glassstate = "1";
 //        out10Glassstate = "1";
-//        currentSlot = "5";
+//        currentSlot = "1";
 //        confirmationWrodValue = "0";
-//        glassIdeValue = "P24092706|15|5";
+//        glassIdeValue = "P24110201|17|1";
 
         log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛欰09:{}銆丄10:{},褰撳墠鏍煎瓙鍙蜂负锛歿}",
                 taskRequestTypeValue, glassIdeValue, confirmationWrodValue, out08Glassstate, out10Glassstate, currentSlot);
@@ -141,12 +147,12 @@
         if ("1".equals(taskRequestTypeValue) && result) {
             log.info("2銆佽繘鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�,鎵爜閲嶅ID楠岃瘉銆愭湁閲嶅=false,鏃犻噸澶�=true銆戯細{}", result);
             inTo(glassIdeValue, confirmationWrodAddress, currentSlot);
-        } else if ("2".equals(taskRequestTypeValue)) {
+        } else if ("2".equals(taskRequestTypeValue) && result) {
             //09绌洪棽 锛�1      10绌洪棽 锛�2        閮界┖闂诧細3    鍏朵粬0
             log.info("2銆佸嚭鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛屽嚭鐗囦换鍔�");
             outTo(Integer.parseInt(out08Glassstate),
                     Integer.parseInt(out10Glassstate), confirmationWrodAddress, "", Integer.parseInt(currentSlot));
-        } else if ("3".equals(taskRequestTypeValue)) {
+        } else if ("3".equals(taskRequestTypeValue) && result) {
             log.info("2銆佽繘鐗囧拰鍑虹墖閮界┖闂诧紝鎵ц鍑虹墖浠诲姟");
             //鍔犵瀛愰噷闈㈡槸鍚︽湁鐜荤拑锛屾湁鍏堝嚭锛屾棤鐜荤拑鍏堣繘
             boolean outFlase = outTo(Integer.parseInt(out08Glassstate),
@@ -161,7 +167,7 @@
     }
 
 
-    @Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 500)
     public void dealDamageTask() {
         Date startDate = new Date();
         log.info("鍗у紡鐞嗙墖鐮存崯鐜荤拑娓呴櫎浠诲姟寮�濮嬫墽琛屾椂闂达細{}", startDate);
@@ -346,15 +352,26 @@
 //        1.2.3銆佹寜鐓у嚭鐗囦俊鎭幓璇︽儏琛ㄦ煡璇㈡牸瀛愬湪绗煎瓙閲岄潰鍓╀綑鐩稿悓灏哄鐨勭幓鐠冩暟鎹笖浠ョ増鍥緄d銆佺増搴忓崌搴忔帓搴�  鍙栫涓�鍧楃幓鐠冨嚭鐗�
 //        2銆佸鏋滄病鏈夊巻鍙插嚭鐗囦换鍔�
 //        2.1銆佸嚭褰撳墠鐗堝浘id鏈�灏忕増搴忔渶灏忕殑鐜荤拑锛堥棶棰橈細涓ゆ潯绾块兘娌℃湁鍘嗗彶浠诲姟锛屽嚭鐗囨椂涓ゆ潯绾跨殑鐜荤拑灏哄鐩稿悓锛屾槸鍚︽壘灏哄涓嶅悓鐨勶級
-        if ((out08Glassstate == 2 && out10Glassstate == 2) || (out08Glassstate == 0 && out10Glassstate == 0)) {
+//        if ((out08Glassstate == 2 && out10Glassstate == 2) || (out08Glassstate == 0 && out10Glassstate == 0)) {
+//            log.info("A09銆丄10涓簕},{}闈炶嚜鍔ㄧ姸鎬侊紝鏃犳硶鍑虹墖", out08Glassstate, out10Glassstate);
+//            return Boolean.FALSE;
+//        }
+        if ((out08Glassstate == 2 && out10Glassstate == 2)) {
             log.info("A09銆丄10涓簕},{}闈炶嚜鍔ㄧ姸鎬侊紝鏃犳硶鍑虹墖", out08Glassstate, out10Glassstate);
             return Boolean.FALSE;
+        }
+        if ((out08Glassstate == 0 && out10Glassstate == 0)) {
+            out10Glassstate = 1;
         }
         log.info("0銆佸嚭鐗囦换鍔″嚭鐨勭姸鎬�:A09:銆恵}銆�;A10:銆恵}銆�)", out08Glassstate, out10Glassstate);
         //瀹氫箟鍑虹墖鐜荤拑淇℃伅
         int endcell = 0;
         EdgStorageCageDetails glassInfo = null;
-
+        //褰撶瀛愬凡婊℃椂锛屼笉鑰冭檻鍗у紡鐞嗙墖鍓嶇殑鐜荤拑
+        EdgStorageCage nearestEmpty = edgStorageCageService.selectNearestEmpty(currentSlot, Boolean.FALSE);
+        if (nearestEmpty == null) {
+            glassId = "";
+        }
 
         boolean flag = queryMaxMinDiff(threshold);
         log.info("1銆佽幏鍙栭挗鍖栫増鍥炬槸鍚﹁秴杩囬槇鍊�:{}", flag);
@@ -376,7 +393,7 @@
             if (out08Glassstate == 1 && out10Glassstate == 1) {
                 EdgStorageCageDetails a09EdgGlass = queryGlassByTaskCache(Const.A09_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT_ALL);
                 EdgStorageCageDetails a10EdgGlass = queryGlassByTaskCache(Const.A10_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT_ALL);
-                if (a09EdgGlass == null && a10EdgGlass == null) {
+                if (a09EdgGlass != null || a10EdgGlass != null) {
                     MPJQueryWrapper<EdgStorageCageDetails> wrapper = new MPJQueryWrapper<>();
                     wrapper.select("count(t.glass_id), t.width, t.height")
                             .eq("t.state", Const.GLASS_STATE_IN)
@@ -780,10 +797,10 @@
                         glassInfo = currentGlass;
                     }
                 }
-                //鐜荤拑淇℃伅鏇挎崲
-                String glassIdChange = queryAndChangeGlass(glassInfo.getGlassId());
-                //澶勭悊鍦ㄥ崸鐞嗗唴鐨勭幓鐠冧俊鎭細绗煎唴鐨勬暟鎹鐞�
-                queryEdgAndChangeGlass(glassInfo.getGlassId(), glassIdChange);
+//                //鐜荤拑淇℃伅鏇挎崲
+//                String glassIdChange = queryAndChangeGlass(glassInfo.getGlassId());
+//                //澶勭悊鍦ㄥ崸鐞嗗唴鐨勭幓鐠冧俊鎭細绗煎唴鐨勬暟鎹鐞�
+//                queryEdgAndChangeGlass(glassInfo.getGlassId(), glassIdChange);
                 LambdaUpdateWrapper<EdgStorageCageDetails> wrapper = new LambdaUpdateWrapper<>();
                 wrapper.eq(EdgStorageCageDetails::getGlassId, glassInfo.getGlassId()).set(EdgStorageCageDetails::getState, Const.GLASS_STATE_OUT);
                 edgStorageCageDetailsService.update(wrapper);
@@ -859,20 +876,31 @@
      * @return
      */
     private int computerLineByState(int out08Glassstate, int out10Glassstate) {
-        if (out08Glassstate == 0) {
-            if (out10Glassstate == 2) {
-                return Const.A09_OUT_TARGET_POSITION;
-            } else {
+//        if (out08Glassstate == 0) {
+//            if (out10Glassstate == 2) {
+//                return Const.A09_OUT_TARGET_POSITION;
+//            } else {
+//                return Const.A10_OUT_TARGET_POSITION;
+//            }
+//        } else if (out08Glassstate == 1) {
+//            return Const.A09_OUT_TARGET_POSITION;
+//        } else {
+//            return Const.A10_OUT_TARGET_POSITION;
+//        }
+        if (out10Glassstate == 0) {
+            if (out08Glassstate == 2) {
                 return Const.A10_OUT_TARGET_POSITION;
+            } else {
+                return Const.A09_OUT_TARGET_POSITION;
             }
-        } else if (out08Glassstate == 1) {
-            return Const.A09_OUT_TARGET_POSITION;
-        } else {
+        } else if (out10Glassstate == 1) {
             return Const.A10_OUT_TARGET_POSITION;
+        } else {
+            return Const.A09_OUT_TARGET_POSITION;
         }
     }
 
-    @Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 500)
     public void CacheGlassTasks() {
         JSONObject jsonObject = new JSONObject();
         List<Map<String, Object>> currentCutTerritorys = edgStorageCageDetailsService.selectCutTerritory();
@@ -899,7 +927,7 @@
         }
     }
 
-    @Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 500)
     public void cacheGlassIsRun() {
         JSONObject jsonObject = new JSONObject();
         //姝e湪杩涜鐨勪换鍔�
@@ -917,7 +945,7 @@
         }
     }
 
-    @Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 500)
     public void CacheGlassTaskss() {
         JSONObject jsonObject = new JSONObject();
         //log.info("鏈璇嗗埆鐗堝浘{},++++{}",engineerId,currentCutTerritorys);

--
Gitblit v1.8.0