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