From bc48a855d98e360042a7e2fff5594a91a82578c6 Mon Sep 17 00:00:00 2001
From: taisheng <taisheng@qq.com>
Date: 星期四, 24 七月 2025 16:16:33 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/controller/OpenController.java | 45 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 45 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 a2632f0..d41633b 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -12,9 +12,11 @@
import com.zy.asrs.entity.param.*;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.Utils;
+import com.zy.common.utils.HttpHandler;
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
@@ -48,6 +50,11 @@
@Autowired
private BasCrnErrorService basCrnErrorService;
+ @Value("${agv.url}")
+ private String agvUrl;
+ @Value("${agv.bindPodAndBerth}")
+ private String bindPodAndBerth;
+
private static final boolean auth = true;
public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
@@ -65,8 +72,46 @@
return R.error("浠诲姟涓嶅瓨鍦�");
}
+ if (taskWrk.getTargetPoint().equals("0900601")) {
+ HashMap<String, Object> requestParam = new HashMap<>();
+
+ int nextInt = new Random().nextInt(100);
+ requestParam.put("reqCode", taskWrk.getTaskNo() + "-" + nextInt);
+ requestParam.put("podCode", param.get("podCode"));
+ requestParam.put("positionCode", taskWrk.getTargetPoint());
+ requestParam.put("indBind", 0);
+
+ String response = null;
+ boolean requestStatus = false;
+ try {
+ log.info("WCS瑙ｇ粦AGV璐ф灦={}", taskWrk);
+ response = new HttpHandler.Builder()
+ .setUri(agvUrl)
+ .setPath(bindPodAndBerth)
+ .setJson(JSON.toJSONString(requestParam))
+ .build()
+ .doPost();
+ JSONObject jsonObject = JSON.parseObject(response);
+ if (jsonObject.get("code").equals("0")) {
+ requestStatus = true;
+ }
+ } catch (Exception e) {
+ log.error("WCS娲惧彂浠诲姟缁橝GV澶辫触{},杩斿洖鍊�={}", taskWrk, response);
+ } finally {
+ apiLogService.save("WCS娲惧彂浠诲姟缁橝GV"
+ , agvUrl + bindPodAndBerth
+ , null
+ , "127.0.0.1"
+ , JSON.toJSONString(requestParam)
+ , response
+ , requestStatus
+ );
+ }
+ }
+
taskWrk.setStatus(TaskStatusType.COMPLETE.id);
taskWrk.setModiTime(new Date());
+ taskWrk.setBarcode(param.get("podCode").toString());
taskWrkService.updateById(taskWrk);
return R.ok();
}
--
Gitblit v1.9.1