From 36078d6f6d6e3d793d97b030182b7592bec7be62 Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期一, 22 七月 2024 09:57:02 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java      |   74 +++++++++++++++++++++----------------
 src/main/java/com/zy/asrs/task/JarBurialEscalationScheduler.java |    2 
 src/main/resources/application.yml                               |    4 +-
 3 files changed, 45 insertions(+), 35 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 6bea44b..57292f5 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -60,6 +60,7 @@
     private static final int[][] execute = new int[][]{{1,4},{2,4},{3,4},{4,4},{5,6},{6,6},{7,4},{8,4},{9,3},{10,4},{11,4}};
 
     private static final Integer jarMaxLoc = 6;
+    private static final Float jarTemperature = 50F;
     @Autowired
     private CommonService commonService;
     @Autowired
@@ -4889,7 +4890,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -5034,10 +5035,7 @@
                 if (jarProtocol.modeType != JarModeType.AUTO){
                     continue;
                 }
-                if (jarProtocol.getJarTemperature()>50){
-                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-                    continue;
-                }
+
 
                 JarThread jarOtherThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getJarOtherId());
                 JarProtocol jarOtherProtocol = jarOtherThread.getJarProtocol();
@@ -5065,6 +5063,10 @@
                                 break;//寮�闂ㄤ换鍔�   鐢熸垚鍏ョ~鍖栫綈浠诲姟
                             }
                         case 2:
+                            if (jarProtocol.getJarTemperature()>jarTemperature){
+                                log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+                                continue;
+                            }
                             if (jarWrkMastExecuteGenerate2(jarSlave,sign)){
                                 signExecute[i] = true;
                                 break;//鍏宠繘鏂欓棬
@@ -5075,6 +5077,10 @@
                                 break;//寮�鍑烘枡闂�
                             }
                         case 4:
+                            if (jarProtocol.getJarTemperature()>jarTemperature){
+                                log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+                                continue;
+                            }
                             if (jarWrkMastExecuteGenerate4(jarSlave,sign)){
                                 signExecute[i] = true;
                                 break;//鍑虹~鍖栫綈 ===銆� 鍏ュ喎鍗存Ы
@@ -5113,7 +5119,7 @@
                     signExecute[jarSlave.getId()-5] = true;
                     continue;
                 }
-                if (jarProtocol.getJarTemperature()>50){
+                if (jarProtocol.getJarTemperature()>jarTemperature){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                     continue;
                 }
@@ -5162,7 +5168,7 @@
                 if (jarProtocol.modeType != JarModeType.AUTO){
                     continue;
                 }
-                if (jarProtocol.getJarTemperature()>50){
+                if (jarProtocol.getJarTemperature()>jarTemperature){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                     continue;
                 }
@@ -5260,7 +5266,7 @@
                         if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){
                             return false;
                         }
-                        if (jarProtocol.getJarTemperature()>50){
+                        if (jarProtocol.getJarTemperature()>jarTemperature){
                             log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                             continue;
                         }
@@ -5364,7 +5370,7 @@
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
-                if (jarProtocol.getJarTemperature()>50){
+                if (jarProtocol.getJarTemperature()>jarTemperature){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
@@ -5449,10 +5455,10 @@
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
-                if (jarProtocol.getJarTemperature()>50){
-                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-                    return false;
-                }
+//                if (jarProtocol.getJarTemperature()>jarTemperature){
+//                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+//                    return false;
+//                }
                 BasJar basJar = basJarMapper.selectById(jarProtocol.getJarNo());
                 if (Cools.isEmpty(basJar)){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarProtocol.getJarNo());
@@ -5621,7 +5627,7 @@
                 if (jarProtocol.modeType != JarModeType.AUTO){
                     return false;
                 }
-                if (jarProtocol.getJarTemperature()>50){
+                if (jarProtocol.getJarTemperature()>jarTemperature){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                     return false;
                 }
@@ -6064,10 +6070,10 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
-                log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-                return false;
-            }
+//            if (jarProtocol.getJarTemperature()>jarTemperature){
+//                log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+//                return false;
+//            }
             BasJar basJar = basJarMapper.selectById(jarProtocol.getJarNo());
             if (Cools.isEmpty(basJar)){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarProtocol.getJarNo());
@@ -6192,7 +6198,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6320,7 +6326,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6436,7 +6442,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6552,7 +6558,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6688,7 +6694,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6820,7 +6826,7 @@
             if (jarProtocol.modeType != JarModeType.AUTO){
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -6984,7 +6990,7 @@
 //            if (jarProtocol.modeType != JarModeType.AUTO){
 //                return false;
 //            }
-//            if (jarProtocol.getJarTemperature()>50){
+//            if (jarProtocol.getJarTemperature()>jarTemperature){
 //                log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
 //                return false;
 //            }
@@ -7160,7 +7166,7 @@
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
-            if (jarProtocol.getJarTemperature()>50){
+            if (jarProtocol.getJarTemperature()>jarTemperature){
                 log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                 return false;
             }
@@ -7618,10 +7624,6 @@
                 if (jarProtocol.modeType != JarModeType.AUTO){
                     continue;
                 }
-                if (jarProtocol.getJarTemperature()>50){
-                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
-                    return false;
-                }
                 BasJar basJar = basJarMapper.selectById(jarProtocol.getJarNo());
                 if (Cools.isEmpty(basJar)){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarProtocol.getJarNo());
@@ -7647,6 +7649,10 @@
                         && jarProtocol.leftDoorOpen!=1 && jarProtocol.leftDoorOpen!=3
                         && jarProtocol.rightDoorOpen!=1 && jarProtocol.rightDoorOpen!=3
                         && (jarProtocol.leftDoorOpen==2  || jarProtocol.rightDoorOpen==2)){
+                    if (jarProtocol.getJarTemperature()>jarTemperature){
+                        log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+                        return false;
+                    }
                     WrkMastExecute wrkMastExecuteSou = new WrkMastExecute();
                     wrkMastExecuteSou.setWrkSts(3);
                     List<WrkMastExecute> wrkMastExecuteList = wrkMastExecuteService.selectWrkMastExecuteByWrk(wrkMastExecuteSou);
@@ -7681,6 +7687,10 @@
                         && jarProtocol.leftDoorClose!=1 && jarProtocol.leftDoorClose!=3
                         && jarProtocol.rightDoorClose!=1 && jarProtocol.rightDoorClose!=3
                         && (jarProtocol.leftDoorClose==2  || jarProtocol.rightDoorClose==2)){
+                    if (jarProtocol.getJarTemperature()>jarTemperature){
+                        log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
+                        return false;
+                    }
                     WrkMastExecute wrkMastExecuteSou = new WrkMastExecute();
                     wrkMastExecuteSou.setWrkSts(3);
                     List<WrkMastExecute> wrkMastExecuteList = wrkMastExecuteService.selectWrkMastExecuteByWrk(wrkMastExecuteSou);
@@ -8055,7 +8065,7 @@
                             if (jarProtocol.statusType .equals(JarStatusType.SOS)){
                                 continue;
                             }
-                            if (jarProtocol.getJarTemperature()>50){
+                            if (jarProtocol.getJarTemperature()>jarTemperature){
                                 continue;
                             }
                             if (jarProtocol.leftDoorOpen != 0 || jarProtocol.rightDoorOpen != 0){
@@ -8251,7 +8261,7 @@
                 if (jarProtocol.statusType .equals(JarStatusType.SOS)){
                     continue;
                 }
-                if (jarProtocol.getJarTemperature()>50){
+                if (jarProtocol.getJarTemperature()>jarTemperature){
                     log.error("{}鍙风~鍖栫綈鏌ヨ璁惧娓╁害杩囬珮锛岀瓑寰呴檷娓�....锛侊紒锛�",jarProtocol.getJarNo());
                     continue;
                 }
diff --git a/src/main/java/com/zy/asrs/task/JarBurialEscalationScheduler.java b/src/main/java/com/zy/asrs/task/JarBurialEscalationScheduler.java
index 0ac9f54..bf94419 100644
--- a/src/main/java/com/zy/asrs/task/JarBurialEscalationScheduler.java
+++ b/src/main/java/com/zy/asrs/task/JarBurialEscalationScheduler.java
@@ -34,7 +34,7 @@
         }
     }
 
-    @Scheduled(cron = "0/3 * * * * ? ")
+//    @Scheduled(cron = "0/3 * * * * ? ")
     private void execute2(){//涓婁紶寮�寮忓喎鍗翠俊鍙�
         int[] jarList =new int[]{1,2,3,4,5,6};
         for (int jarNo : jarList){
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 4e5c801..a4be9ff 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -676,13 +676,13 @@
     # 纾呯Г
   scale[0]:
     id: 1
-    ip: 10.10.10.206
+    ip: 10.10.10.208
     port: 5005
     staNo: 281
   # 纾呯Г
   scale[1]:
     id: 2
-    ip: 10.10.10.207
+    ip: 10.10.10.209
     port: 5005
     staNo: 292
   # 纾呯Г

--
Gitblit v1.9.1