From d62951d7c0947303fc6eed23a664c162f2ea0010 Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期五, 05 十二月 2025 09:07:32 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/controller/OpenController.java | 31 +++++++++++++++++++++++++++++++
1 files changed, 31 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index a07109a..344b920 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -8,8 +8,15 @@
import com.core.exception.CoolException;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.param.ArmPrecomputeParam;
+import com.zy.asrs.entity.param.PdaWriteBarcodeParam;
import com.zy.asrs.service.OpenService;
import com.zy.common.web.BaseController;
+import com.zy.core.cache.MessageQueue;
+import com.zy.core.cache.SlaveConnection;
+import com.zy.core.enums.SlaveType;
+import com.zy.core.model.Task;
+import com.zy.core.model.protocol.StaProtocol;
+import com.zy.core.thread.SiemensDevpThread;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
@@ -65,6 +72,30 @@
return R.ok().add(param);
}
+ /**
+ * 娣诲姞鍑哄簱鍗�
+ */
+ @PostMapping("/task/cs/barcode/default/v1")
+ @AppAuth(memo = "PDA涓嬪彂鏉＄爜")
+ public synchronized R wcsBarcode(@RequestHeader(required = false) String appkey,
+ @RequestBody PdaWriteBarcodeParam param,
+ HttpServletRequest request) {
+ try{
+ auth(appkey, param, request);
+ } catch (Exception e){
+ return new R(403,e.getMessage());
+ }
+ if (Cools.isEmpty(param)) {
+ return R.parse(BaseRes.PARAM);
+ }
+ SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 2);
+ StaProtocol staProtocol = devpThread.getStation().get(param.getSiteId());
+ staProtocol.setBarcode(param.getBarcode());
+ MessageQueue.offer(SlaveType.Devp, 2, new Task(2, staProtocol));
+
+ return R.ok("涓嬪彂鎴愬姛璇风◢绛�");
+ }
+
private void auth(String appkey, Object obj, HttpServletRequest request) {
// log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
--
Gitblit v1.9.1