From 19feb4af89f6e5e67c3dc97cbbcf6cfc40350781 Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期六, 07 二月 2026 15:02:55 +0800
Subject: [PATCH] no message
---
src/main/java/com/zy/asrs/task/WorkMastScheduler.java | 25 +++++++++++++++----------
1 files changed, 15 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
index 1a73349..e14d6bc 100644
--- a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
@@ -5,6 +5,8 @@
import com.zy.api.service.WcsApiService;
import com.zy.asrs.entity.Task;
import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.entity.param.CompleteParam;
+import com.zy.asrs.service.MobileService;
import com.zy.asrs.service.TaskService;
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.task.core.ReturnT;
@@ -34,6 +36,8 @@
private WorkMastHandler workMastHandler;
@Autowired
private WcsApiService wcsApiService;
+ @Autowired
+ private MobileService mobileService;
@Autowired
private TaskService taskService;
@@ -82,22 +86,23 @@
* @author Ryan
* @date 2026/1/10 14:42
*/
- @Scheduled(cron = "0/15 * * * * ? ")
+ @Scheduled(cron = "0/5 * * * * ? ")
private void autoPubTasks() {
- List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", Arrays.asList(11L)));
+ List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", Arrays.asList(11L, 1L)));
if (wrkMasts.isEmpty()) {
return;
}
Collections.shuffle(wrkMasts);
wrkMasts.forEach(wrkMast -> {
WorkTaskParams params = new WorkTaskParams();
-// if (wrkMast.getIoType().equals(1)) {
-// params.setType("in");
-// params.setTaskNo(wrkMast.getWrkNo() + "")
-// .setLocNo(wrkMast.getLocNo())
-// .setBarcode(wrkMast.getBarcode())
-// .setTaskPri(wrkMast.getIoPri().intValue());
-// } else {
+ if (wrkMast.getIoType().equals(11)) {
+ CompleteParam param = new CompleteParam();
+ param.setTaskNo(wrkMast.getWrkNo() + "");
+ param.setSourceLocNo(wrkMast.getSourceLocNo());
+ param.setLocNo(wrkMast.getLocNo());
+// param.set
+ mobileService.taskMove(param, 9527L);
+ } else if (wrkMast.getIoType() > 100) {
params.setType("out")
.setTaskNo(wrkMast.getWrkNo() + "")
.setLocNo(wrkMast.getSourceLocNo())
@@ -105,7 +110,7 @@
.setStaNo(wrkMast.getStaNo())
.setTaskPri(wrkMast.getIoPri().intValue());
wcsApiService.pubWrkToWcs(params);
-// }
+ }
});
}
--
Gitblit v1.9.1