From 683c0e046f1d4363f87633104969a91ffe275da6 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期三, 29 五月 2024 16:28:36 +0800
Subject: [PATCH] # 订单出库同步锁
---
src/main/java/com/zy/asrs/task/AutoMoveScheduler.java | 95 ++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 92 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
index 35835aa..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,8 +23,10 @@
private AgvLocMastService agvLocMastService;
@Autowired
private AutoMoveHandler autoMoveHandler;
+ @Autowired
+ private AgvWrkMastService agvWrkMastService;
-
+ // 璋冩嫧鍑哄簱
@Scheduled(cron = "0/2 * * * * ? ")
private void execute(){
List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
@@ -40,19 +44,104 @@
}
+ // 璋冩嫧鍑哄簱
@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(
new EntityWrapper<AgvLocMast>()
- .ne("floor", 3)
+ .ne("floor", 1)
.eq("loc_sts","D")
.eq("loc_type1",3));
if (agvLocMasts.isEmpty()) {
return;
}
for (AgvLocMast agvLocMast : agvLocMasts) {
- ReturnT<String> returnT = autoMoveHandler.start(agvLocMast);
+ ReturnT<String> returnT = autoMoveHandler.autoEmptyBack(agvLocMast);
+ }
+ }
+ // 绌烘澘鑷姩鍥炲簱 鎺ラ┏鐐� - 1妤煎簱浣�
+ //@Scheduled(cron = "0/2 * * * * ? ")
+ private void autoEmptyBack3(){
+ // 宸ヤ綔妗ｄ负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