From ff9b89307d063f29000857a8b8823bfd4b3de4a5 Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期六, 23 十一月 2024 17:19:45 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   76 +++++++++++++++++++++++--------------
 1 files changed, 47 insertions(+), 29 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 9679fdf..ae3c037 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -61,6 +61,8 @@
 
 //    private static final Integer jarMaxLoc1 = 7;
     private static  Integer jarMaxLoc = 0;
+    private static  Integer signBigTurn = 0;
+    private static  Integer signSmallTurn = 0;
     private static final Float jarTemperature = 50F;
     @Autowired
     private CommonService commonService;
@@ -3098,7 +3100,9 @@
             if (wrkMast == null) {
                 continue;
             }
-
+            if (wrkMast.getStaNoSign().equals(signBigTurn)){
+                continue;
+            }
             crnStation = crnStation1;
 
             CrnSlave.CrnStn crnStn = null;
@@ -3115,6 +3119,13 @@
             if (wrkMast.getStaNo()>309){
                 int wrkCount = wrkMastMapper.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 110).gt("sta_no", 309).lt("sta_no", 314).gt("wrk_sts",11L));
                 if (wrkCount>=12){
+                    continue;
+                }
+                RgvOneSign bigTurn = rgvOneSignMapper.selectOneSign("bigTurn");
+                if (Cools.isEmpty(bigTurn)){
+                    continue;
+                }
+                if (bigTurn.getRgvOneSign()>13){
                     continue;
                 }
                 DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
@@ -3341,6 +3352,10 @@
 //                    }
 //                }
             }
+        }
+        signBigTurn++;
+        if (signBigTurn > 2){
+            signBigTurn = 0;
         }
 
     }
@@ -5125,7 +5140,7 @@
                             if (jarMaxLoc == 0 || basJarOther.getJarCount() == 0) {
                                 break;
                             }
-                            int count = basJarMastService.selectCount(new EntityWrapper<BasJarMast>().eq("jar_regin", basJar.getRegion()).lt("status", 17).gt("status", 11));
+                            int count = basJarMastService.selectCount(new EntityWrapper<BasJarMast>().eq("jar_regin", basJar.getRegion()).lt("status", 17).gt("status", 6));
                             if (count>0){
                                 break;
                             }
@@ -5216,7 +5231,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -5246,7 +5261,7 @@
             //鑷姩銆佺┖闂层�佸彸闂ㄥ叧闂��   Other宸﹂棬鍏抽棴
             if (jarProtocol.isAutoing() && jarProtocol.jarErr==0
                     && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
-                if (jarProtocol.statusType != JarStatusType.SOS){
+                if (jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType != JarStatusType.SOS2){
                     log.error("Jar浠诲姟鍒涘缓===銆嬫墽琛�===>琛�={}",4537);
                     BasJarMast basJarMast = new BasJarMast(basJar, wrkMast, jarLocDigit);
                     basJarMast.setJarEnterStaNo(staNo);//鍏ョ~鍖栫綈绔欑偣
@@ -5595,7 +5610,7 @@
                         if (jarProtocol.modeType != JarModeType.AUTO){
                             return false;
                         }
-                        if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
+                        if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                             return false;
                         }
                         if (jarProtocol.getJarTemperature()>jarTemperature){
@@ -5703,7 +5718,7 @@
                     return false;
                 }
 
-                if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
+                if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
@@ -5729,7 +5744,7 @@
                 }
 
                 //闂ㄤ綔涓�  鏃�
-                if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.jarErr==0
+                if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType!= JarStatusType.SOS2 && jarProtocol.jarErr==0
                         && jarProtocol.isRightDoor() && jarProtocol.isLeftDoor()
                         && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
                     //鍏宠繘鏂欓棬
@@ -5792,7 +5807,7 @@
                     return false;
                 }
 
-                if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+                if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
@@ -5822,7 +5837,7 @@
                         log.error("JarWrkMastExecute浠诲姟鍒涘缓===>鎵ц寮傚父===銆嬪紓甯告暟鎹細BasJar:"+ JSON.toJSONString(basJar)+";BasJarMast:"+JSON.toJSONString(basJarMastSign));
                     }
                     return true;
-                } else if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS
+                } else if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType != JarStatusType.SOS2
                         && jarProtocol.statusType != JarStatusType.WAITING2 && jarProtocol.jarErr==0
                             && jarProtocol.isLeftDoor() && jarProtocol.isRightDoor()
                             && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
@@ -5899,7 +5914,7 @@
                     return false;
                 }
 
-                if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+                if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
@@ -6467,7 +6482,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6595,7 +6610,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6723,7 +6738,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6839,7 +6854,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6955,7 +6970,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -7091,7 +7106,7 @@
                 return false;
             }
 
-            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -7563,7 +7578,7 @@
                 return false;
             }
 
-            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -7615,7 +7630,7 @@
                     continue;
                 }
 
-                if (jarProtocolOther.statusType .equals(JarStatusType.SOS)){
+                if (jarProtocolOther.statusType .equals(JarStatusType.SOS)  || jarProtocol.statusType .equals(JarStatusType.SOS2)){
 //                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     continue;
                 }
@@ -7893,26 +7908,18 @@
         try{
             switch (sign){
                 case 1:
-                case 5:
-                case 9:
                     if (jarWrkMastExecuteGenerateSteComplete(sign)){
                         break;
                     }
                 case 2:
-                case 6:
-                case 10:
                     if (jarWrkMastExecuteGenerateJarComplete(sign)){
                         break;
                     }
                 case 3:
-                case 7:
-                case 11:
                     if (jarWrkMastExecuteGenerateRgvComplete1(sign)){
                         break;
                     }
                 case 4:
-                case 8:
-                case 12:
                     if (jarWrkMastExecuteGenerateRgvComplete2(sign)){
                         break;
                     }
@@ -8455,6 +8462,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(!basJarMastList.isEmpty()){
                         continue;
@@ -8505,7 +8515,7 @@
                             if (jarProtocol.modeType != JarModeType.AUTO){
                                 continue;
                             }
-                            if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+                            if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                                 continue;
                             }
                             if (jarProtocol.getJarTemperature()>jarTemperature){
@@ -8569,6 +8579,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(basJarMastList.isEmpty()){
                         if (wrkMastExecuteService.selectNoStartCharge(steSlave.getId())==0){
@@ -8593,7 +8606,7 @@
                                         if (jarProtocol.modeType != JarModeType.AUTO){
                                             continue;
                                         }
-                                        if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+                                        if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                                             continue;
                                         }
                                         if (jarProtocol.getJarTemperature()>jarTemperature){
@@ -8637,6 +8650,11 @@
                         if (!jarSteTake(wrkMastExecuteByCharge,SteLocaType.POINT20.id,SteLocaType.POINT20.id,SteTaskModeType.CLOSE_CHARGE,true,wrkMastExecuteByCharge.getJarId())){
                             log.error("绌挎鏉縎te鍛戒护涓嬪彂澶辫触锛宻te鍙�={},浠诲姟鏁版嵁={}",
                                     wrkMastExecuteByCharge.getSteId(), JSON.toJSONString(wrkMastExecuteByCharge));
+                        }
+                        try{
+                            Thread.sleep(1000);
+                        } catch (Exception e){
+
                         }
                         wrkMastExecuteByCharge.setWrkType(2);
                         wrkMastExecuteByCharge.setWrkSts(100);
@@ -8810,7 +8828,7 @@
                 if (jarProtocol.modeType != JarModeType.AUTO){
                     continue;
                 }
-                if (jarProtocol.statusType .equals(JarStatusType.SOS)){
+                if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){
                     continue;
                 }
                 if (jarProtocol.getJarTemperature()>jarTemperature){

--
Gitblit v1.9.1