From 73fd9aecc97d33f51ae7fe0350f3423cf8fd824f Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期一, 10 二月 2025 08:11:31 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 86 ++++++++++++++++++++++++++++++++++--------- 1 files changed, 68 insertions(+), 18 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 4451bad..2185eff 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -3096,6 +3096,13 @@ } Integer turnBigInt = 0; + if (wrkMast.booleanStaNoSign() && wrkMast.getIoPri()<99D){ + Date now = new Date(); + long differenceInSeconds = now.getTime() - wrkMast.getModiTime().getTime(); + if (differenceInSeconds<=2000){ + continue; + } + } // if (wrkMast.booleanStaNoSign()){ // RgvOneSign rgvOneSign = rgvOneSignMapper.selectOneSign("LineUp"+wrkMast.getStaNo()); // if (Cools.isEmpty(rgvOneSign)){ @@ -5904,6 +5911,42 @@ if (basJarMastList.isEmpty()){ return false; } + + StaProtocol staProtocolEnd = new StaProtocol(); + staProtocolEnd.setAutoing(false); + for (DevpSlave devp : slaveProperties.getDevp()) { + if (devp.getId() == 1){ + continue; + } + // 閬嶅巻鍏ュ簱鍙� + for (DevpSlave.Sta inSta : devp.getOutJarInSta()) { + if (jarSlave.getId() == 1 || jarSlave.getId() == 2){ + if (inSta.getStaNo() == 627){ + SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); + StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo()); + if (staProtocol == null) { + break; + } + staProtocolEnd = staProtocol; + break; + } + } else if (jarSlave.getId() == 3 || jarSlave.getId() == 4){ + if (inSta.getStaNo() == 628){ + SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); + StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo()); + if (staProtocol == null) { + break; + } + staProtocolEnd = staProtocol; + break; + } + } + + } + } + if (!staProtocolEnd.isAutoing() || staProtocolEnd.isLoading()){ + return false; + } List<BasJarMast> basJarMastList10 = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getId(), new ArrayList<Integer>() {{ add(10); }}); @@ -8047,6 +8090,7 @@ // // } List<WrkMastExecute> wrkMastExecuteByWrkNoList = wrkMastExecuteService.getWrkMastExecuteByWrkNoList(steProtocol.getTaskNo().longValue()); + steReturn: for (WrkMastExecute wrkMastExecute : wrkMastExecuteByWrkNoList){ if (!Cools.isEmpty(wrkMastExecute)){ switch (wrkMastExecute.getIoType()){ @@ -8063,12 +8107,14 @@ wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSON(steProtocol),sign); } // Thread.sleep(500); - return true; +// return true; + break steReturn; } } - log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", - wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSONString(steProtocol),sign); - return true; +// log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", +// wrkMastExecute.getSteId(), JSON.toJSONString(wrkMastExecute), JSON.toJSONString(steProtocol),sign); +// return true; + break steReturn; } case 5: if (wrkMastExecute.getWrkSts()==5){ @@ -8082,12 +8128,14 @@ log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); } - return true; +// return true; + break steReturn; } } - log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", - wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); - return true; +// log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", +// wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); +// return true; + break steReturn; } continue; case 7: @@ -8105,12 +8153,14 @@ log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); } - return true; +// return true; + break steReturn; } } - log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", - wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); - return true; +// log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", +// wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); +// return true; + break steReturn; } continue; case 9: @@ -8125,17 +8175,17 @@ log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>鏇存柊wrkMastExecute澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); } - return true; +// return true; + break steReturn; } } - log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", - wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); +// log.error("绌挎杞te鍛戒护涓嬪彂澶辫触===>涓嬪彂寮傚父锛宩ar鍙�={},浠诲姟鏁版嵁={},绌挎杞︽暟鎹�={},sign={}", +// wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(steProtocol),sign); continue; } default: continue; } } - } } } @@ -8272,7 +8322,7 @@ log.error("纭寲缃怞ar鍛戒护涓嬪彂澶辫触锛宩ar鍙�={},浠诲姟鏁版嵁={},纭寲缃愭暟鎹�={},sign={}", execute.getJarId(), JSON.toJSON(execute), JSON.toJSON(jarProtocol),sign); } - return true; + continue; } for (WrkMastExecute wrkMastExecute : wrkMastExecuteList){ if (wrkMastExecute.getIoType() == 2 || wrkMastExecute.getIoType() == 4){ @@ -8287,7 +8337,7 @@ wrkMastExecute.getSteId(), JSON.toJSON(wrkMastExecute), JSON.toJSON(jarProtocol),sign); return false; } - return true; + continue; } } } -- Gitblit v1.9.1