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 | 28 +++++++++++++++++-----------
1 files changed, 17 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
index 33112bc..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;
@@ -77,30 +81,32 @@
/**
- * 浠诲姟鑷姩涓嬪彂
+ * 浠诲姟鑷姩涓嬪彂鍑哄簱浠诲姟
*
* @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(1L, 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.getLocNo())
+ .setLocNo(wrkMast.getSourceLocNo())
+ .setBarcode(wrkMast.getBarcode())
.setStaNo(wrkMast.getStaNo())
.setTaskPri(wrkMast.getIoPri().intValue());
wcsApiService.pubWrkToWcs(params);
--
Gitblit v1.9.1