From 323d014b95241cd42dfa01227dd4a15575f58a2b Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期二, 16 九月 2025 11:01:33 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java | 36 +++++++++++++++++++----------------- 1 files changed, 19 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java b/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java index 14544b6..60e7ec2 100644 --- a/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java +++ b/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.mapper.Wrapper; import com.baomidou.mybatisplus.plugins.Page; import com.core.common.Cools; +import com.core.common.DateUtils; import com.zy.asrs.entity.AgvBasDevp; import com.zy.asrs.entity.AgvWrkMast; import com.zy.asrs.service.AgvBasDevpService; @@ -18,6 +19,7 @@ import java.io.IOException; import java.util.ArrayList; +import java.util.Date; import java.util.List; /** @@ -44,10 +46,10 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负205.宸ヤ綔瀹屾垚 涓� 锛�1.鍏ュ簱 || 53锛屾嫞鏂欏叆搴� || 57.鐩樼偣鍏ュ簱 || 10.绌烘澘鍏ュ簱 || 11.鍗曞眰绉诲簱 || 12.璺ㄥ眰绉诲簱 || 108.鑷姩璋冩嫧 || 109.鎵嬪姩璋冩嫧)鐨勬暟鎹� */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 3000) public void excutePutwayWrk(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 205) + .eq("wrk_sts", 205L) .andNew().eq("io_type",53) .or().eq("io_type",1) .or().eq("io_type",57) @@ -78,10 +80,10 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206.鍑哄簱瀹屾垚 涓� (101.鍑哄簱 || 110.绌烘澘鍑哄簱) */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 3000) public void excuteCarryWrk(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 206) + .eq("wrk_sts", 206L) .andNew().eq("io_type",110) .or().eq("io_type",101)); if(!Cools.isEmpty(agvWrkMastList)){ @@ -101,10 +103,10 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206.鍑哄簱瀹屾垚 涓� (101.鍑哄簱 || 110.绌烘澘鍑哄簱) */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 3000) public void excuteCarryWrk2(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 208) + .eq("wrk_sts", 208L) .andNew().eq("io_type",110) .or().eq("io_type",101)); if(!Cools.isEmpty(agvWrkMastList)){ @@ -124,11 +126,11 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负201.鐢熸垚鍏ュ簱浠诲姟ID 涓�(鍑哄簱绫诲瀷涓� 53.鎷f枡鍐嶅叆搴� || 1.鍏ュ簱 || 10.绌烘澘鍏ュ簱鏍� || 57.鐩樼偣鍐嶅叆搴�)鐨勬暟鎹� */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) - public void startPutwayWrk(){ + @Scheduled(fixedDelay = 5000) + public synchronized void startPutwayWrk(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50) ,new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 201) + .eq("wrk_sts", 201L) .andNew().eq("io_type", 53) .or().eq("io_type", 1) .or().eq("io_type", 10) @@ -159,11 +161,11 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负201.鐢熸垚鍏ュ簱浠诲姟ID 涓�(鍑哄簱绫诲瀷涓� 53.鎷f枡鍐嶅叆搴� || 1.鍏ュ簱 || 10.绌烘澘鍏ュ簱鏍� || 57.鐩樼偣鍐嶅叆搴�)鐨勬暟鎹� */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 4000) public void startAllcationIn(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50) ,new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 211) + .eq("wrk_sts", 211L) .andNew().eq("io_type", 112)).getRecords(); if(!Cools.isEmpty(agvWrkMastList)){ @@ -182,11 +184,11 @@ 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负21.鐢熸垚鍑哄簱浠诲姟 涓�(鍑哄簱绫诲瀷涓� 101.鍑哄簱 || 103.鎷f枡鍑哄簱 || 11.搴撴牸绉绘牻 || 110.绌烘澘鍑哄簱 || 107.鐩樼偣鍑哄簱)鐨勬暟鎹� */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 4000) public void startCarryWrk(){ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50) ,new EntityWrapper<AgvWrkMast>() - .eq("wrk_sts", 21) + .eq("wrk_sts", 21L) //.like("loc_no","@") .andNew().eq("io_type", 101) .or().eq("io_type", 103) @@ -218,7 +220,7 @@ agvWrkMastWorking = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>() .eq("source_loc_no",agvWrkMast.getLocNo()) - .le("wrk_sts",204L)); + .lt("wrk_sts",204L)); if(!Cools.isEmpty(agvWrkMastWorking)){ return; @@ -250,7 +252,7 @@ 鑷姩鐢熸垚绌烘澘鍑哄簱浠诲姟 */ //@Scheduled(cron = "0/1 * * * * ? ") - @Scheduled(fixedDelay = 2000) + @Scheduled(fixedDelay = 3000) public void autoEmptyOut(){ boolean packageEmptyAutoOUt = Cools.eq("Y",Parameter.get().getPackageEmptyAutoOUt()); boolean mateEmptyAutoOut = Cools.eq("Y",Parameter.get().getMateEmptyAutoOut()); @@ -282,8 +284,8 @@ try { agvWrkMastHandler.autoEmptyOut(agvBasDevp); }catch (Exception e){ - log.error(e.getMessage()); - e.printStackTrace(); + //log.error(e.getMessage()); + //e.printStackTrace(); } } -- Gitblit v1.9.1