From 23b4e7942a8524ed1e89d93c55a470f0dc263d5a Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期五, 06 六月 2025 13:54:01 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 24 +++++++++++++++++++----- 1 files changed, 19 insertions(+), 5 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 27e2d7b..9841de2 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -234,7 +234,7 @@ return; } long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(wrkMasts.get(0).getModiTime(), new Date()); - if (differenceInSeconds <= 100) { + if (differenceInSeconds <= 1000) { return; } @@ -270,6 +270,8 @@ try { List<WrkMast> wrkMastlistA = new ArrayList<>(); List<WrkMast> wrkMastlistB = new ArrayList<>(); + List<WrkMast> wrkMastlistC = new ArrayList<>(); + List<WrkMast> wrkMastlistD = new ArrayList<>(); for (BasDevpPosition basDevpPosition : basDevpPositionsListUN) { List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("sta_no", basDevpPosition.getDevNo()).eq("wrk_sts", 1L).orderBy("modi_time", true)); for (WrkMast wrkMast : wrkMastList) { @@ -283,12 +285,22 @@ } else { continue; } + long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(wrkMast.getModiTime(), new Date()); + if (SortTheExecutionOfTheCarUtil.devpNoSortbj(basDevpPositionsListUN, wrkMast.getSourceStaNo(), wrkMast.getStaNo())) { sourceStaNoList.add(wrkMast.getSourceStaNo()); - wrkMastlistA.add(wrkMast); + if (differenceInSeconds>600000){ + wrkMastlistA.add(wrkMast); + } else { + wrkMastlistC.add(wrkMast); + } } else { sourceStaNoList.add(wrkMast.getSourceStaNo()); - wrkMastlistB.add(wrkMast); + if (differenceInSeconds>600000){ + wrkMastlistB.add(wrkMast); + } else { + wrkMastlistD.add(wrkMast); + } } } } @@ -296,6 +308,8 @@ } wrkMastLists.add(wrkMastlistA); wrkMastLists.add(wrkMastlistB); + wrkMastLists.add(wrkMastlistC); + wrkMastLists.add(wrkMastlistD); // return wrkMastLists; wrkMastListAll.add(wrkMastLists); } catch (Exception e) { @@ -602,7 +616,7 @@ && rgvProtocol.getStatusType() == RgvStatusType.IDLE && rgvProtocol.getTaskNo1() == 0 && rgvProtocol.getAlarm() == 0) { - if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(4,devperimeter))) { + if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(5,devperimeter))) { log.error("RGV婕父鍚姩鍛戒护涓嬪彂澶辫触锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvNo, "婕父鎸囦护"); break; } @@ -661,7 +675,7 @@ wrkMastService.updateById(wrkMast); continue; }else { - log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触"); + log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触1"); } } else { //娴嬭瘯鐢� -- Gitblit v1.9.1