From b8f320c817c486c33613ca196ceab7c8fd354bae Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期三, 29 五月 2024 16:24:47 +0800 Subject: [PATCH] # 操作日志 --- src/main/java/com/zy/asrs/task/AutoMoveScheduler.java | 90 ++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 89 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java index c1d9027..47690fc 100644 --- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java +++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java @@ -3,7 +3,9 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.zy.asrs.entity.AgvLocMast; +import com.zy.asrs.entity.AgvWrkMast; import com.zy.asrs.service.AgvLocMastService; +import com.zy.asrs.service.AgvWrkMastService; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.AutoMoveHandler; import org.springframework.beans.factory.annotation.Autowired; @@ -21,6 +23,8 @@ private AgvLocMastService agvLocMastService; @Autowired private AutoMoveHandler autoMoveHandler; + @Autowired + private AgvWrkMastService agvWrkMastService; // 璋冩嫧鍑哄簱 @Scheduled(cron = "0/2 * * * * ? ") @@ -40,8 +44,59 @@ } - // 绌烘澘鑷姩鍥炲簱 + // 璋冩嫧鍑哄簱 @Scheduled(cron = "0/2 * * * * ? ") + private void execute2(){ + List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() + .eq("wrk_sts", 22) + .andNew().eq("io_type",108) + .eq("crn_no",2) + .orderBy("appe_time",true) + ); + if (agvWrkMastList.isEmpty()) { + return; + } + for (AgvWrkMast agvWrkMast : agvWrkMastList) { + ReturnT<String> returnT = autoMoveHandler.start2(agvWrkMast); + } + + } + + @Scheduled(cron = "0/2 * * * * ? ") + private void execute5(){ + List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() + .eq("wrk_sts", 22) + .andNew().eq("io_type",108) + .eq("crn_no",3) + .orderBy("appe_time",true) + ); + if (agvWrkMastList.isEmpty()) { + return; + } + for (AgvWrkMast agvWrkMast : agvWrkMastList) { + ReturnT<String> returnT = autoMoveHandler.start2(agvWrkMast); + } + + } + + // 璋冩嫧鍑哄簱 + @Scheduled(cron = "0/2 * * * * ? ") + private void execute3(){ + List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() + .eq("wrk_sts", 22) + .andNew().eq("io_type",111) + ); + if (agvWrkMastList.isEmpty()) { + return; + } + for (AgvWrkMast agvWrkMast : agvWrkMastList) { + ReturnT<String> returnT = autoMoveHandler.start3(agvWrkMast); + } + + } + + // 绌烘澘鑷姩鍥炲簱 搴撲綅-鎺ラ┏鐐� + //@Scheduled(cron = "0/2 * * * * ? ") private void autoEmptyBack(){ // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋� List<AgvLocMast> agvLocMasts = agvLocMastService.selectList( @@ -55,6 +110,39 @@ for (AgvLocMast agvLocMast : agvLocMasts) { ReturnT<String> returnT = autoMoveHandler.autoEmptyBack(agvLocMast); } + } + // 绌烘澘鑷姩鍥炲簱 鎺ラ┏鐐� - 1妤煎簱浣� + //@Scheduled(cron = "0/2 * * * * ? ") + private void autoEmptyBack3(){ + // 宸ヤ綔妗d负201 涓� 鍏ュ嚭搴撶被鍨嬩负109 + List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>() + .eq("wrk_sts", 201) + .eq("loc_no","") + .eq("io_type",109) + .or().eq("io_type",112)); + if (agvWrkMastList.isEmpty()) { + return; + } + for (AgvWrkMast agvWrkMast : agvWrkMastList) { + ReturnT<String> returnT = autoMoveHandler.autoEmptyBack3(agvWrkMast); + } + } + + // 绌烘澘鑷姩鍥炲簱 + @Scheduled(cron = "0/2 * * * * ? ") + private void autoEmptyBack2(){ + // 鏌ヨ 涓嶄负1妤肩殑绌鸿揣鏋� + List<AgvLocMast> agvLocMasts = agvLocMastService.selectList( + new EntityWrapper<AgvLocMast>() + .ne("floor", 1) + .eq("loc_sts","D") + .eq("loc_type1",3)); + if (agvLocMasts.isEmpty()) { + return; + } + for (AgvLocMast agvLocMast : agvLocMasts) { + ReturnT<String> returnT = autoMoveHandler.autoEmptyBack2(agvLocMast); + } } } -- Gitblit v1.9.1