From 469d8ceb95ed82f09fd4c1bddbbe672689bc8d82 Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期三, 09 四月 2025 19:52:22 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/asrs/task/AutoMoveScheduler.java | 68 ++++++++++++++++++++++++++++------ 1 files changed, 56 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java index 0c9018b..e370d60 100644 --- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java +++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java @@ -66,7 +66,7 @@ * ioType 108.鑷姩璋冩嫧 * crnNo :2鐩爣妤煎眰 */ - @Scheduled(cron = "0/1 * * * * ? ") + @Scheduled(cron = "0/10 * * * * ? ") private synchronized void execute2() { List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("wrk_sts", 22).andNew().eq("io_type", 108).andNew().eq("crn_no", 2).or().eq("crn_no", 3).orderBy("io_pri", false).orderBy("appe_time", true)); if (agvWrkMastList.isEmpty()) { @@ -110,7 +110,7 @@ * wrkSts 22.璋冩嫧寰呭垎閰� * ioType 111.鎵嬪姩璋冩嫧 */ - @Scheduled(cron = "0/2 * * * * ? ") + @Scheduled(cron = "0/10 * * * * ? ") private void execute3() { List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("wrk_sts", 22).andNew().eq("io_type", 111).orderBy("io_pri", false).orderBy("appe_time", true)); if (agvWrkMastList.isEmpty()) { @@ -215,20 +215,48 @@ */ @Scheduled(cron = "0/30 * * * * ? ") private void autoEmptyBack4() { - // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋� List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>() // TODO 鍥涙湡 .eq("loc_sts", "D").eq("loc_type1", 3).andNew().ne("floor", 1).or().ne("lev1", 1)); if (agvLocMasts.isEmpty()) { return; } + + Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_3_TIME")); for (AgvLocMast agvLocMast : agvLocMasts) { - try { - autoMoveHandler.autoEmptyBack4(agvLocMast); - } catch (Exception e) { - log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐� 搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage()); + if (agvLocMast.getLocNo().contains("02F1")) { + boolean flag = false; + if (config != null && !Cools.isEmpty(config.getValue())) { + try { + + // 鍒ゆ柇鏄惁鍦ㄦ墽琛屾椂闂村唴 + ProcesTimeData procesTimeData = JSONObject.parseObject(config.getValue(), ProcesTimeData.class); + if (procesTimeData != null && config.getStatus() == 1 && TimeUtils.between(procesTimeData)) { + flag = true; + } + } catch (Exception e) { + log.error("6绫诲瀷绌鸿揣鏋惰繑鍥炵殑鎵ц鏃堕棿鐐硅В鏋愬紓甯革細===銆嬪紓甯稿師鍥狅細" + e.getMessage()); + flag = true; + } + } + if (flag) { + try { + autoMoveHandler.autoEmptyBack4(agvLocMast); + } catch (Exception e) { + //log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐� 搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage()); + } + } + } else { + try { + autoMoveHandler.autoEmptyBack4(agvLocMast); + } catch (Exception e) { + //log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐� 搴撲綅-鍚稿杞﹂棿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage()); + } } + } + + } @@ -238,6 +266,22 @@ // TODO 鍥涙湡 @Scheduled(cron = "0/30 * * * * ? ") private void autoEmptyBackSiqi() { + Config config2 = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_EMPTY")); + //鍏堝垽鏂┖搴撲綅鏁颁簡 + List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_type1", 6).eq("floor", 1).eq("lev1", 2).eq("loc_sts", "O")); + int size = 0; + if (agvLocMasts != null) { + size = agvLocMasts.size(); + } + if (config2 != null && config2.getStatus() == 1 && !Cools.isEmpty(config2.getValue())) { + if (size < Integer.parseInt(config2.getValue())) { + return; + } + } else { + if (size < 20) { + return; + } + } // 鏌ヨ6绫诲瀷绌鸿揣鏋惰繑鍥炵殑鎵ц鏃堕棿鐐� Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_TIME")); if (config != null && !Cools.isEmpty(config.getValue())) { @@ -264,7 +308,7 @@ private void executeLocType6() { // 鏌ヨ 浜屽巶鐨勭殑鍗婃垚鍝佺澹崇被鍨嬬殑绌鸿揣鏋� - List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_sts", "D").eq("loc_type1", 6).eq("floor", 2)); + List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(new EntityWrapper<AgvLocMast>().eq("loc_sts", "D").eq("loc_type1", 6).eq("floor", 2).orderBy("bay1",false)); if (agvLocMasts.isEmpty()) { return; } @@ -319,7 +363,7 @@ * 妫�娴�1妤兼帴椹崇偣 * 鎵嬪姩锛� 鐢熸垚 113 鎵嬪姩鍥炴祦 */ - @Scheduled(cron = "0/2 * * * * ? ") + @Scheduled(cron = "0/30 * * * * ? ") private void autoEmptyBack6() { List<AgvBasDevp> agvBasDevps = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>().eq("floor", 1).eq("loc_sts", "F").like("dev_no", "DB")); if (agvBasDevps.isEmpty()) { @@ -385,7 +429,7 @@ * 鎵撴爣璁扮殑搴撲綅杩涜鑷姩绉诲簱锛屽洓鏈� * 鍦ㄥ簱浣嶄笉澶熺殑鎯呭喌涓嬶紝绠卞3鍏ュ簱鍒殑妤煎眰搴撲綅鐨勬椂鍊欙紝鏅氫笂杩涜璺ㄥ眰绉诲簱 */ - @Scheduled(cron = "0/2 * * * * ? ") + @Scheduled(cron = "0/30 * * * * ? ") private void autoEmptyBack8() throws ParseException { Date now = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); @@ -418,13 +462,13 @@ return; } for (AgvLocMast agvLocMast : agvLocMasts) { - if (agvLocMast.getLev1() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("2")) { + if (agvLocMast.getLev1() == 1 && agvLocMast.getFloor() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("2")) { try { autoMoveHandler.autoTransfersV2(agvLocMast, maxTansk); } catch (Exception e) { log.error("搴撲綅鍙�" + agvLocMast.getLocNo() + "鍥涙湡瀹氭椂绉诲簱浠诲姟 鍚稿 --> 鍚稿,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細" + e.getMessage()); } - } else if (agvLocMast.getLev1() == 2 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("1")) { + } else if (agvLocMast.getLev1() == 2 && agvLocMast.getFloor() == 1 && !Cools.isEmpty(agvLocMast.getCtnNo()) && agvLocMast.getCtnNo().toString().equals("1")) { try { autoMoveHandler.autoTransfersV2(agvLocMast, maxTansk); } catch (Exception e) { -- Gitblit v1.9.1