From 510a21954afdf40479bdf293568cc7979e6043ad Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期三, 07 一月 2026 16:15:53 +0800
Subject: [PATCH] 1
---
src/main/java/com/zy/asrs/controller/OpenController.java | 31 ++++++++++++++++++++-----------
1 files changed, 20 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index fc003ee..62d7ce9 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -3,8 +3,7 @@
import com.core.common.R;
import com.zy.asrs.domain.param.AskStaParam;
import com.zy.asrs.domain.param.TaskReportParam;
-import com.zy.asrs.service.LocMastService;
-import com.zy.asrs.service.impl.CtuMainServiceImpl;
+import com.zy.asrs.service.CtuMainService;
import com.zy.common.web.BaseController;
import com.zy.core.DevpThread;
import com.zy.core.cache.MessageQueue;
@@ -34,11 +33,7 @@
@Autowired
- private LocMastService locMastService;
-
-
- @Autowired
- private CtuMainServiceImpl ctuMainService;
+ private CtuMainService ctuMainService;
@Value("${ctu.url}")
@@ -81,10 +76,10 @@
*/
@RequestMapping("/task/sync/v1")
public R taskSync(@RequestBody TaskReportParam param) {
- if (param == null || param.getSeqNum() == null || param.getQrCode() == null) {
+ if (param == null || param.getSeqNum() == null) {
return R.error("鍙傛暟涓虹┖");
}
- if ((param.getQrCode().equals("00001547") || param.getQrCode().equals("1001")) && param.getTaskSts() == 10) {
+ if (param.getTaskSts() == 15 && (param.getQrCode().equals("00001547") || param.getQrCode().equals("1001"))) {
log.info("1001浠诲姟鐘舵�佷笂鎶ユ帴鏀讹細{}", param);
DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
Map<Integer, StaProtocol> station = devpThread.getStation();
@@ -94,6 +89,9 @@
} else {
staProtocol = staProtocol.clone();
}
+ if (!staProtocol.isLoading()) {
+ return R.error("绔欑偣鏃犵墿");
+ }
Random rand = new Random();
staProtocol.setWorkNo(rand.nextInt(1000));
staProtocol.setStaNo((short) 1004);
@@ -101,9 +99,20 @@
if (result) {
log.info("涓嬪彂鎴愬姛锛歿},{}", staProtocol.getWorkNo(), 1004);
}
- } else if (param.getQrCode().equals("00001612") && param.getTaskSts() == 5) {
+ } else if (param.getTaskSts() == 5) {
log.info("1007浠诲姟鐘舵�佷笂鎶ユ帴鏀讹細{}", param);
-
+ DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
+ Map<Integer, StaProtocol> station = devpThread.getStation();
+ StaProtocol staProtocol = station.get(1007);
+ if (staProtocol == null) {
+ return R.error("鏈壘鍒扮珯鐐�");
+ } else {
+ staProtocol = staProtocol.clone();
+ }
+ boolean result = MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol));
+ if (result) {
+ log.info("涓嬪彂鎴愬姛锛歿},{}", staProtocol.getWorkNo(), 1007);
+ }
}
return R.ok();
}
--
Gitblit v1.9.1