From f3de21a928fd73a1c9f66a7fe4d24afb1c9916af Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期日, 24 十一月 2024 10:25:48 +0800
Subject: [PATCH] #cs1

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  102 ++++++++++++++++++++++++++++++--------------------
 1 files changed, 61 insertions(+), 41 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 91070bf..b58a285 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -61,8 +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  Integer signBigTurn = 0;
+//    private static  Integer signSmallTurn = 0;
     private static final Float jarTemperature = 50F;
     @Autowired
     private CommonService commonService;
@@ -3100,9 +3100,11 @@
             if (wrkMast == null) {
                 continue;
             }
-            if (wrkMast.getStaNoSign().equals(signBigTurn)){
-                continue;
-            }
+//            if (wrkMast.getStaNoSign().equals(signBigTurn)){
+//                continue;
+//            }
+
+
             crnStation = crnStation1;
 
             CrnSlave.CrnStn crnStn = null;
@@ -3116,23 +3118,30 @@
                 continue;
             }
 
-            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){
+            if (wrkMast.booleanStaNoSign()){
+                RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign("LineUp"+wrkMast.getStaNo());
+                if (Cools.isEmpty(rgvOneSign)){
                     continue;
                 }
-                RgvOneSign bigTurn = rgvOneSignMapper.selectOneSign("bigTurn");
-                if (Cools.isEmpty(bigTurn)){
+                if (rgvOneSign.getRgvOneSign()>=2){
                     continue;
                 }
-                if (bigTurn.getRgvOneSign()>13){
-                    continue;
-                }
-                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
-                StaProtocol staProtocolEnt = devpThread.getStation().get(212);
-                if (staProtocolEnt.isLoading() || staProtocolEnt.getWorkNo()!=0){
-                    continue;
-                }
+//                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);
+//                StaProtocol staProtocolEnt = devpThread.getStation().get(wrkMast.getStaNoBying());
+//                if (staProtocolEnt.isLoading() || staProtocolEnt.getWorkNo()!=0){
+//                    continue;
+//                }
             }
 
             // 宸ヤ綔妗g姸鎬佸垽鏂�
@@ -3353,10 +3362,10 @@
 //                }
             }
         }
-        signBigTurn++;
-        if (signBigTurn > 2){
-            signBigTurn = 0;
-        }
+//        signBigTurn++;
+//        if (signBigTurn > 2){
+//            signBigTurn = 0;
+//        }
 
     }
 
@@ -5231,7 +5240,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;
             }
@@ -5261,7 +5270,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);//鍏ョ~鍖栫綈绔欑偣
@@ -5610,7 +5619,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){
@@ -5718,7 +5727,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;
                 }
@@ -5744,7 +5753,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){
                     //鍏宠繘鏂欓棬
@@ -5807,7 +5816,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;
                 }
@@ -5837,7 +5846,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){
@@ -5914,7 +5923,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;
                 }
@@ -6482,7 +6491,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;
             }
@@ -6610,7 +6619,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;
             }
@@ -6738,7 +6747,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;
             }
@@ -6854,7 +6863,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;
             }
@@ -6970,7 +6979,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;
             }
@@ -7106,7 +7115,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;
             }
@@ -7578,7 +7587,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;
             }
@@ -7630,7 +7639,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;
                 }
@@ -8462,6 +8471,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(!basJarMastList.isEmpty()){
                         continue;
@@ -8512,7 +8524,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){
@@ -8576,6 +8588,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(basJarMastList.isEmpty()){
                         if (wrkMastExecuteService.selectNoStartCharge(steSlave.getId())==0){
@@ -8600,7 +8615,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){
@@ -8644,6 +8659,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);
@@ -8817,7 +8837,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