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 |  296 ++++++++++++++++++++++++++++++++++++++---------------------
 1 files changed, 190 insertions(+), 106 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 e3743a4..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,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,6 +3100,10 @@
             if (wrkMast == null) {
                 continue;
             }
+//            if (wrkMast.getStaNoSign().equals(signBigTurn)){
+//                continue;
+//            }
+
 
             crnStation = crnStation1;
 
@@ -3112,12 +3118,30 @@
                 continue;
             }
 
-            if (wrkMast.getStaNo()>300){
-                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
-                StaProtocol staProtocolEnt = devpThread.getStation().get(212);
-                if (staProtocolEnt.isLoading() || staProtocolEnt.getWorkNo()!=0){
+            if (wrkMast.booleanStaNoSign()){
+                RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign("LineUp"+wrkMast.getStaNo());
+                if (Cools.isEmpty(rgvOneSign)){
                     continue;
                 }
+                if (rgvOneSign.getRgvOneSign()>=2){
+                    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姸鎬佸垽鏂�
@@ -3338,6 +3362,10 @@
 //                }
             }
         }
+//        signBigTurn++;
+//        if (signBigTurn > 2){
+//            signBigTurn = 0;
+//        }
 
     }
 
@@ -5116,16 +5144,17 @@
                                 break;
                             }
                             BasJar basJar = basJarMapper.selectById(jarSlave.getId());
+                            BasJar basJarOther = basJarMapper.selectById(jarSlave.getJarOtherId());
                             jarMaxLoc = basJar.getJarCount();
-                            if (jarMaxLoc == 0) {
+                            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;
                             }
                             if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),3)!=0){
-                                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 3).equals(jarMaxLoc)){
+                                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 3).equals(basJarOther.getJarCount())){
                                     JarThread jarOtherThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getJarOtherId());
                                     JarProtocol jarOtherProtocol = jarOtherThread.getJarProtocol();
                                     if (jarOtherProtocol == null) {
@@ -5211,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;
             }
@@ -5241,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);//鍏ョ~鍖栫綈绔欑偣
@@ -5329,11 +5358,11 @@
                 case 3:
                 case 4:
                     signExecute = jarWrkMastExecuteGenerateJar(signExecute,sign);//纭寲缃愪换鍔�
-//                case 5:
-//                    signExecute = jarWrkMastExecuteGenerateBurial(signExecute, sign);//鍐峰嵈妲藉彇杈撻�佺嚎
-                default:
-//                    jarWrkMastExecuteGenerateSte(signExecute,sign);//灏忚溅绉诲姩
+                case 5:
                     signExecute = jarWrkMastExecuteGenerateBurial(signExecute, sign);//鍐峰嵈妲藉彇杈撻�佺嚎
+                default:
+                    jarWrkMastExecuteGenerateSte(signExecute,sign);//灏忚溅绉诲姩
+//                    signExecute = jarWrkMastExecuteGenerateBurial(signExecute, sign);//鍐峰嵈妲藉彇杈撻�佺嚎
 
             }
             if (!signExecute[0] && !signExecute[1]){
@@ -5458,13 +5487,13 @@
                 }
                 //闂ㄤ綔涓�  鏃�
                 //鑷姩銆佺┖闂层�佸彸闂ㄥ叧闂��   Other宸﹂棬鍏抽棴
-                if (jarProtocol.isAutoing() && jarProtocol.jarErr==0
-                        && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
+                if (jarProtocol.isAutoing() && jarProtocol.jarErr==0){
                     if (jarWrkMastExecuteGenerate5(jarSlave,sign)){
                         signExecute[jarSlave.getId()-5] = true;
                         return signExecute;
                         //鍐峰嵈瀹屾垚涓婅緭閫佺嚎
                     }
+                    continue;
                 }
             } catch (Exception e){
                 log.error("{}鍙风~鍖栫綈JarWrkMastExecute浠诲姟鍒涘缓寮傚父,寮傚父鍘熷洜={}",jarSlave.getId(),e.getMessage());
@@ -5473,65 +5502,65 @@
         return signExecute;
     }
 
-//    public synchronized boolean[] jarWrkMastExecuteGenerateSte(boolean[] signExecute,Integer sign) {
-//        for (JarSlave jarSlave : slaveProperties.getJar()) {
-//            if (jarSlave.getId()<5){
-//                continue;
-//            }
-//            try{
-//                if (signExecute[jarSlave.getId()-5]){
-//                    continue;
-//                }
-//                if (wrkMastExecuteService.getWrkMastExecuteByJarIdCount(jarSlave.getId())!=0){
-//                    continue;
-//                }
-//
-//                // 鑾峰彇纭寲缃愪俊鎭�
-//                JarThread jarThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getId());
-//                JarProtocol jarProtocol = jarThread.getJarProtocol();
-//                if (jarProtocol == null) {
-//                    continue;
-//                }
-//                if (jarProtocol.modeType != JarModeType.AUTO){
-//                    continue;
-//                }
-//                if (jarProtocol.getJarTemperature()>jarTemperature){
-//                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-//                    continue;
-//                }
-//
-//                JarThread jarOtherThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getJarOtherId());
-//                JarProtocol jarOtherProtocol = jarOtherThread.getJarProtocol();
-//                if (jarOtherProtocol == null) {
-//                    continue;
-//                }
-////                    if (jarOtherProtocol.modeType != JarModeType.AUTO){
-////                        continue;
-////                    }
-//
-//                BasJar basJar = basJarMapper.selectById(jarProtocol.getJarNo());
-//                if (Cools.isEmpty(basJar)){
-//                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarProtocol.getJarNo());
-//                    continue;
-//                }
-//                //闂ㄤ綔涓�  鏃�
-//                //鑷姩銆佺┖闂层�佸彸闂ㄥ叧闂��   Other宸﹂棬鍏抽棴
-//                if (jarProtocol.isAutoing() && jarProtocol.jarErr==0
-//                        && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
-//                    switch (sign){
-//                        case 5:
-//                            if (jarWrkMastExecuteGenerate5(jarSlave,sign)){
-//                                signExecute[jarSlave.getId()-5] = true;
-//                                break;
-//                            }
+    public synchronized boolean[] jarWrkMastExecuteGenerateSte(boolean[] signExecute,Integer sign) {
+        for (JarSlave jarSlave : slaveProperties.getJar()) {
+            if (jarSlave.getId()<5){
+                continue;
+            }
+            try{
+                if (signExecute[jarSlave.getId()-5]){
+                    continue;
+                }
+                if (wrkMastExecuteService.getWrkMastExecuteByJarIdCount(jarSlave.getId())!=0){
+                    continue;
+                }
+
+                // 鑾峰彇纭寲缃愪俊鎭�
+                JarThread jarThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getId());
+                JarProtocol jarProtocol = jarThread.getJarProtocol();
+                if (jarProtocol == null) {
+                    continue;
+                }
+                if (jarProtocol.modeType != JarModeType.AUTO){
+                    continue;
+                }
+                if (jarProtocol.getJarTemperature()>jarTemperature){
+                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+                    continue;
+                }
+
+                JarThread jarOtherThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getJarOtherId());
+                JarProtocol jarOtherProtocol = jarOtherThread.getJarProtocol();
+                if (jarOtherProtocol == null) {
+                    continue;
+                }
+//                    if (jarOtherProtocol.modeType != JarModeType.AUTO){
+//                        continue;
 //                    }
-//                }
-//            } catch (Exception e){
-//                log.error("{}鍙风~鍖栫綈JarWrkMastExecute浠诲姟鍒涘缓寮傚父,寮傚父鍘熷洜={}",jarSlave.getId(),e.getMessage());
-//            }
-//        }
-//        return signExecute;
-//    }
+
+                BasJar basJar = basJarMapper.selectById(jarProtocol.getJarNo());
+                if (Cools.isEmpty(basJar)){
+                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarProtocol.getJarNo());
+                    continue;
+                }
+                //闂ㄤ綔涓�  鏃�
+                //鑷姩銆佺┖闂层�佸彸闂ㄥ叧闂��   Other宸﹂棬鍏抽棴
+                if (jarProtocol.isAutoing() && jarProtocol.jarErr==0
+                        && jarProtocol.leftDoorOpen==0  && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0  && jarProtocol.rightDoorClose==0){
+                    switch (sign){
+                        case 5:
+                            if (jarWrkMastExecuteGenerate5(jarSlave,sign)){
+                                signExecute[jarSlave.getId()-5] = true;
+                                break;//鍑虹~鍖栫綈 ===銆� 鍏ュ喎鍗存Ы
+                            }
+                    }
+                }
+            } catch (Exception e){
+                log.error("{}鍙风~鍖栫綈JarWrkMastExecute浠诲姟鍒涘缓寮傚父,寮傚父鍘熷洜={}",jarSlave.getId(),e.getMessage());
+            }
+        }
+        return signExecute;
+    }
 
     /**
      *  JarWrkMastExecute浠诲姟鍒涘缓   //瀹屾垚
@@ -5590,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){
@@ -5698,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;
                 }
@@ -5724,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){
                     //鍏宠繘鏂欓棬
@@ -5756,11 +5785,6 @@
             List<BasJarMast> basJarMastList = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getId(), new ArrayList<Integer>() {{
                 add(6);
             }});
-//            if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=0
-//                    && basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=jarMaxLoc
-//                    && basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=jarMaxLoc*2){
-//                return false;
-//            }
             if (basJarMastList.isEmpty()){
                 return false;
             }
@@ -5792,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;
                 }
@@ -5822,6 +5846,15 @@
                         log.error("JarWrkMastExecute浠诲姟鍒涘缓===>鎵ц寮傚父===銆嬪紓甯告暟鎹細BasJar:"+ JSON.toJSONString(basJar)+";BasJarMast:"+JSON.toJSONString(basJarMastSign));
                     }
                     return true;
+                } 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){
+                        Integer integer = basJarMastService.updateStatus(jarProtocol.getJarNo(), 6, 8);
+                        if (basJarMastList.size()!=integer){
+                            log.error("{}鍙风~鍖栫綈纭寲瀹屾垚鍚庡紑闂ㄥ畬鎴愪慨鏀圭~鍖栨。妗堢姸鎬佺粨鏋滄暟閲忎笉涓�鑷达紒锛侊紒鏌ヨ璧勬枡鏁伴噺={}锛屾洿鏂拌繑鍥炴暟閲�={}",jarProtocol.getJarNo(),basJarMastList.size(),integer);
+                        }
+                        return true;
                 }
                 return false;
             } else {
@@ -5890,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;
                 }
@@ -5908,7 +5941,24 @@
                 if (basJarMastList10.size()==jarMaxLoc){
                     return false;
                 }
-                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),4)!=0 && !basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 4).equals(jarMaxLoc)){
+
+                BasJar basJarOther = basJarMapper.selectById(jarSlave.getJarOtherId());
+                if (Cools.isEmpty(basJarOther)){
+                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarSlave.getJarOtherId());
+                    return false;
+                }
+
+                if (basJarOther.getJarCount() == 0) {
+                    return false;
+                }
+
+                List<BasJarMast> basJarMastListOther = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getJarOtherId(), new ArrayList<Integer>() {{
+                    add(8);
+                }});
+                if (!basJarMastListOther.isEmpty() && basJarMastListOther.size() < basJarOther.getJarCount()){
+                    return false;
+                }
+                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),4)!=0 && !basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 4).equals(basJarOther.getJarCount() )){
                     return false;
                 }
 
@@ -6441,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;
             }
@@ -6569,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;
             }
@@ -6697,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;
             }
@@ -6813,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;
             }
@@ -6929,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;
             }
@@ -7065,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;
             }
@@ -7537,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;
             }
@@ -7589,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;
                 }
@@ -7867,26 +7917,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;
                     }
@@ -8099,7 +8141,7 @@
                         && (jarProtocol.leftDoorClose==2  || jarProtocol.rightDoorClose==2)){
                     if (jarProtocol.getJarTemperature()>jarTemperature){
                         log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-                        return false;
+                        continue;
                     }
                     WrkMastExecute wrkMastExecuteSou = new WrkMastExecute();
                     wrkMastExecuteSou.setWrkSts(3);
@@ -8429,6 +8471,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(!basJarMastList.isEmpty()){
                         continue;
@@ -8479,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){
@@ -8543,6 +8588,9 @@
                         add(5);
                         add(11);
                         add(17);
+                        add(99);
+                        add(100);
+                        add(999);
                     }});
                     if(basJarMastList.isEmpty()){
                         if (wrkMastExecuteService.selectNoStartCharge(steSlave.getId())==0){
@@ -8567,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){
@@ -8611,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);
@@ -8670,13 +8723,44 @@
             }
         }
 
+        try{
+            for (int idi = 1;idi<5;idi++){
+                LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, idi);
+
+                if (ledThread != null) {
+                    ErrMsg errMsg1 = new ErrMsg();
+                    errMsg1.setErrMsg("娴嬭瘯锛�"+idi);
+                    errMsg1.setArea("1");
+                    MessageQueue.offer(SlaveType.Led, idi, new Task(5, errMsg1));
+                } try {
+                    Thread.sleep(500);
+                } catch (Exception e){
+
+                }
+            }
+            LedThread ledThread3 = (LedThread) SlaveConnection.get(SlaveType.Led, 3);
+
+            if (ledThread3 != null) {
+                ErrMsg errMsg1 = new ErrMsg();
+                errMsg1.setErrMsg("娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯娴嬭瘯锛�"+3);
+                errMsg1.setArea("1");
+                MessageQueue.offer(SlaveType.Led, 3, new Task(5, errMsg1));
+            } try {
+                Thread.sleep(500);
+            } catch (Exception e){
+
+            }
+        } catch (Exception e){
+
+        }
+
 
     }
     public synchronized Integer jarGetStartStaNo(Integer staNo) {
         try {
             int[] jarNos=new int[]{3,1,4,2};//(607鍒嗛厤纭寲缃�)
             ArrayList<Integer> staNos = new ArrayList<Integer>() {{
-                add(607);add(608);add(609);add(610);add(611);add(612);
+                add(608);add(609);add(610);add(611);add(612);
                 add(613);add(614);add(615);add(616);add(617);add(618);
                 add(619);add(620);add(621);add(622);
             }};
@@ -8753,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){
@@ -8784,7 +8868,7 @@
                     DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 2);
                     StaProtocol staProtocolEnt = devpThread.getStation().get(staNoEnt);
                     if (staProtocolEnt == null || (staProtocolEnt.isLoading() && staProtocolEnt.getWorkNo()==0)){
-                        log.error("绔欑偣寮傚父,璁℃暟鍔犱竴锛岀珯鐐瑰彿锛�"+staNoEnt);
+//                        log.error("绔欑偣寮傚父,璁℃暟鍔犱竴锛岀珯鐐瑰彿锛�"+staNoEnt);
                         count++;
                     } else if (staProtocolEnt != null && staProtocolEnt.getWorkNo()!=0 && !wrkNoList.contains(staProtocolEnt.getWorkNo())){
                         if (staProtocolEnt.getStaNo().equals(basJar.getEntStaNo$())){

--
Gitblit v1.9.1