From 364b9ccc44bc6863280c5cc00aa8512cfff548d4 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期五, 25 四月 2025 15:27:18 +0800
Subject: [PATCH] 123
---
src/main/java/com/zy/asrs/controller/OpenController.java | 380 +++++++++++++++++++++++++++---------------------------
1 files changed, 190 insertions(+), 190 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 1cdf7c3..a508bdb 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -1,7 +1,6 @@
package com.zy.asrs.controller;
import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.annotations.AppAuth;
import com.core.common.BaseRes;
@@ -9,18 +8,18 @@
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.asrs.entity.*;
-import com.zy.asrs.entity.param.*;
+import com.zy.asrs.entity.param.CrnStatusParam;
+import com.zy.asrs.entity.param.TaskCreateParam;
+import com.zy.asrs.entity.param.TaskOverParam;
+import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
import com.zy.asrs.service.*;
-import com.zy.asrs.utils.Utils;
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.*;
import javax.servlet.http.HttpServletRequest;
-import java.io.IOException;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.HashMap;
@@ -105,25 +104,6 @@
}
}
- //agv浠诲姟瀹屾垚
- @PostMapping("/toAgvTaskOver")
- @AppAuth(memo = "agv浠诲姟瀹屾垚鎺ュ彛")
- public R getAgvTaskOver(@RequestHeader String appkey,
- @RequestBody TaskOverParam param,
- HttpServletRequest request) {
- auth(appkey, param, request);
- if (Cools.isEmpty(param)) {
- return R.parse(BaseRes.PARAM);
- }
- if (Cools.isEmpty(param.getStartPoint())) {
- return R.error("鐮佸ご[wharfCode]涓嶈兘涓虹┖");
- }
- if (Cools.isEmpty(param.getStatus())) {
- return R.error("瀹屾垚鏍囪[status]涓嶈兘涓虹┖");
- }
- openService.getAgvTaskOver(param);
- return R.ok();
- }
//鍒涘缓浠诲姟
@PostMapping("/taskCreate")
@@ -189,17 +169,82 @@
return R.ok();
}
- //鏌ヨ浠诲姟璇︽儏
- @GetMapping("/queryTask")
- public R queryTask(@RequestHeader String appkey,
- @RequestParam String taskNo,
- HttpServletRequest request) {
- auth(appkey, taskNo, request);
- TaskWrk taskWrk = taskWrkService.selectByTaskNo(taskNo);
- if (taskWrk == null) {
- return R.error("浠诲姟涓嶅瓨鍦�");
+
+ //浠诲姟鍙栨秷鎺ュ彛
+ @PostMapping("/taskCancel")
+ public R taskCancel(@RequestHeader String appkey,
+ @RequestBody WMSAndAGVInterfaceParam param,
+ HttpServletRequest request) {
+ auth(appkey, param, request);
+ if (Cools.isEmpty(param)) {
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getTaskNo())) {
+ return R.error("宸ヤ綔鍙蜂负绌猴紒");
+ } else if (Cools.isEmpty(param.getIoType())) {
+ return R.error("鎿嶄綔绫诲瀷涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getBarcode())) {
+ return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒");
}
- return R.ok().add(taskWrk);
+
+ TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>()
+ .eq("task_no", param.getTaskNo())
+ .eq("io_type", param.getIoType())
+ .eq("barcode", param.getBarcode()));
+ if (Cools.isEmpty(taskWrk)) {
+ return R.error("鏈煡鍒板綋鍓嶄换鍔�---" + param);
+ }
+ boolean sign = false;
+ switch (param.getTaskStatus()) {
+ case 1://姝ｅ父鍙栨秷
+ if (taskWrk.getStatus() > 1) {
+ return R.error("浠诲姟宸插紑濮嬫墽琛�");
+ }
+ break;
+ case 2://姝ｅ父瀹屾垚
+ if (taskWrk.getStatus() > 1) {
+ return R.error("浠诲姟宸插紑濮嬫墽琛�");
+ }
+ sign = true;
+ break;
+ default:
+ return R.error("鏈煡鎿嶄綔");
+ }
+ return taskWrkOperate(taskWrk, sign);
+ }
+
+ //浠诲姟鎿嶄綔
+ private R taskWrkOperate(TaskWrk taskWrk, boolean sign) {
+ try {
+ if (sign) {//瀹屾垚
+ return taskWrkController.complete(taskWrk.getTaskNo());
+ } else {//鍙栨秷
+ return taskWrkController.cancel(taskWrk.getTaskNo());
+ }
+ } catch (Exception e) {
+ return R.error();
+ }
+ }
+
+ //璁惧鐘舵�佹煡璇㈡帴鍙�
+ @GetMapping("/deviceStatus")
+ @Transactional
+ public R deviceStatus() {
+ List<CrnStatusParam> crnStatusParams = new ArrayList<>();
+ List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
+ for (BasCrnp basCrnp : basCrnps) {
+ CrnStatusParam crnStatusParam = new CrnStatusParam();
+ crnStatusParam.setCrnNo(basCrnp.getCrnNo());
+ crnStatusParam.setCrnSts(basCrnp.getCrnSts());
+ crnStatusParam.setErrorCode(basCrnp.getCrnErr());
+ BasCrnError error = basCrnErrorService.selectOne(new EntityWrapper<BasCrnError>().eq("error_code", basCrnp.getCrnErr()));
+ if (Cools.isEmpty(error)) {
+ crnStatusParam.setErrorMsg("");
+ } else {
+ crnStatusParam.setErrorMsg(error.getErrName());
+ }
+ crnStatusParams.add(crnStatusParam);
+ }
+ return R.ok(crnStatusParams);
}
//鍙栨斁璐х敵璇�
@@ -240,6 +285,31 @@
return openService.getAgvPickAndPlaceV2(param);
}
+
+ private void auth(String appkey, Object obj, HttpServletRequest request) {
+ log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", request.getServletPath(), appkey, JSON.toJSONString(obj));
+ request.setAttribute("cache", obj);
+ if (Cools.isEmpty(appkey)) {
+ throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+ }
+ if (!APP_KEY_LIST.contains(appkey)) {
+ throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+ }
+ }
+
+ //鏌ヨ浠诲姟璇︽儏
+ @GetMapping("/queryTask")
+ public R queryTask(@RequestHeader String appkey,
+ @RequestParam String taskNo,
+ HttpServletRequest request) {
+ auth(appkey, taskNo, request);
+ TaskWrk taskWrk = taskWrkService.selectByTaskNo(taskNo);
+ if (taskWrk == null) {
+ return R.error("浠诲姟涓嶅瓨鍦�");
+ }
+ return R.ok().add(taskWrk);
+ }
+
//鏌ヨ浠诲姟鎸囦护闆嗗悎
@GetMapping("/queryTaskCommand")
public R queryTaskCommand(@RequestHeader String appkey,
@@ -255,16 +325,74 @@
return R.ok().add(commandInfos);
}
- private void auth(String appkey, Object obj, HttpServletRequest request) {
- log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", request.getServletPath(), appkey, JSON.toJSONString(obj));
- request.setAttribute("cache", obj);
- if (Cools.isEmpty(appkey)) {
- throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
- }
- if (!APP_KEY_LIST.contains(appkey)) {
- throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
- }
- }
+
+ //浠诲姟涓嬪彂鎺ュ彛
+// @PostMapping("/outboundTaskSend")
+// @Transactional
+// public HashMap<String, Object> outboundTaskSend(@RequestBody List<CarryParam> params) {
+// HashMap<String, Object> map = new HashMap<>();
+// for (CarryParam param : params) {
+// if (Cools.isEmpty(param)) {
+// map.put("Code", "0");
+// map.put("Msg", "鍙傛暟涓虹┖锛�");
+// return map;
+// } else if (Cools.isEmpty(param.getTaskNo())) {
+// map.put("Code", "0");
+// map.put("Msg", "浠诲姟鍙蜂负绌猴紒");
+// return map;
+// } else if (Cools.isEmpty(param.getStereoscopicTaskType())) {
+// map.put("Code", "0");
+// map.put("Msg", "浠诲姟绫诲瀷涓虹┖锛�");
+// return map;
+// }
+// String fusion = Utils.Fusion(param.getOriginalRowNo(), param.getOriginalFloorNo(), param.getOriginalColumnNo());
+// param.setStartPoint(fusion);
+// LocMast locMast = locMastService.selectByLocNo(param.getStartPoint());
+// if (Cools.isEmpty(locMast)) {
+// map.put("Code", "0");
+// map.put("Msg", "鍒濆搴撲綅鏃犳硶鎵惧埌锛�");
+// return map;
+// }
+//
+// HashMap<String, Object> r = new HashMap<>();
+//
+// if (param.getStereoscopicTaskType() == 2) {
+// //鍑哄簱浠诲姟鍒涘缓
+// StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+// .eq("type_no", 2)
+// .eq("crn_no", locMast.getCrnNo())
+// .eq("stn_no", param.getTerminalNo()));
+// if (Cools.isEmpty(staDesc)) {
+// map.put("Code", "0");
+// map.put("Msg", "鍑哄簱璺緞涓嶅瓨鍦紒");
+// return map;
+// }
+// r = openService.taskCreate(new TaskCreateParam(param, staDesc.getCrnNo()));
+// if (r.get("Code").equals("0")) {
+// return r;
+// }
+// } else if (param.getStereoscopicTaskType() == 3) {
+// String fusion1 = Utils.Fusion(param.getGoalRowNo(), param.getGoalFloorNo(), param.getGoalColumnNo());
+// param.setTerminalNo(fusion1);
+// //绉诲簱浠诲姟鍒涘缓
+// r = openService.taskCreate(new TaskCreateParam(param, locMast.getCrnNo()));
+// if (r.get("Code").equals("0")) {
+// return r;
+// }
+// }
+// apiLogService.save("Wms浠诲姟涓嬪彂鎺ュ彛"
+// , request.getRemoteAddr() + request.getRequestURI()
+// , ""
+// , request.getRemoteAddr()
+// , JSON.toJSONString(param)
+// , r.toString()
+// , true
+// );
+// }
+// map.put("Code", "1");
+// map.put("Msg", "ok");
+// return map;
+// }
//AGV璇锋眰鍏ュ簱鐮佸ご鎺ュ彛
// @PostMapping("/targetWharfApply")
@@ -363,150 +491,22 @@
//
//
// }
-
- //浠诲姟涓嬪彂鎺ュ彛
- @PostMapping("/outboundTaskSend")
- @Transactional
- public HashMap<String, Object> outboundTaskSend(@RequestBody List<CarryParam> params) {
- HashMap<String, Object> map = new HashMap<>();
- for (CarryParam param : params) {
- if (Cools.isEmpty(param)) {
- map.put("Code", "0");
- map.put("Msg", "鍙傛暟涓虹┖锛�");
- return map;
- } else if (Cools.isEmpty(param.getTaskNo())) {
- map.put("Code", "0");
- map.put("Msg", "浠诲姟鍙蜂负绌猴紒");
- return map;
- } else if (Cools.isEmpty(param.getStereoscopicTaskType())) {
- map.put("Code", "0");
- map.put("Msg", "浠诲姟绫诲瀷涓虹┖锛�");
- return map;
- }
- String fusion = Utils.Fusion(param.getOriginalRowNo(), param.getOriginalFloorNo(), param.getOriginalColumnNo());
- param.setStartPoint(fusion);
- LocMast locMast = locMastService.selectByLocNo(param.getStartPoint());
- if (Cools.isEmpty(locMast)) {
- map.put("Code", "0");
- map.put("Msg", "鍒濆搴撲綅鏃犳硶鎵惧埌锛�");
- return map;
- }
-
- HashMap<String, Object> r = new HashMap<>();
-
- if (param.getStereoscopicTaskType() == 2) {
- //鍑哄簱浠诲姟鍒涘缓
- StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
- .eq("type_no", 2)
- .eq("crn_no", locMast.getCrnNo())
- .eq("stn_no", param.getTerminalNo()));
- if (Cools.isEmpty(staDesc)) {
- map.put("Code", "0");
- map.put("Msg", "鍑哄簱璺姴涓嶅瓨鍦紒");
- return map;
- }
- r = openService.taskCreate(new TaskCreateParam(param, staDesc.getCrnNo()));
- if (r.get("Code").equals("0")) {
- return r;
- }
- } else if (param.getStereoscopicTaskType() == 3) {
- String fusion1 = Utils.Fusion(param.getGoalRowNo(), param.getGoalFloorNo(), param.getGoalColumnNo());
- param.setTerminalNo(fusion1);
- //绉诲簱浠诲姟鍒涘缓
- r = openService.taskCreate(new TaskCreateParam(param, locMast.getCrnNo()));
- if (r.get("Code").equals("0")) {
- return r;
- }
- }
- apiLogService.save("Wms浠诲姟涓嬪彂鎺ュ彛"
- , request.getRemoteAddr() + request.getRequestURI()
- , ""
- , request.getRemoteAddr()
- , JSON.toJSONString(param)
- , r.toString()
- , true
- );
- }
- map.put("Code", "1");
- map.put("Msg", "ok");
- return map;
- }
-
- //浠诲姟鍙栨秷鎺ュ彛
- @PostMapping("/taskCancel")
- public R taskCancel(@RequestHeader String appkey,
- @RequestBody WMSAndAGVInterfaceParam param,
- HttpServletRequest request) {
- auth(appkey, param, request);
- if (Cools.isEmpty(param)) {
- return R.error("鍙傛暟涓虹┖锛�");
- } else if (Cools.isEmpty(param.getTaskNo())) {
- return R.error("宸ヤ綔鍙蜂负绌猴紒");
- } else if (Cools.isEmpty(param.getIoType())) {
- return R.error("鎿嶄綔绫诲瀷涓虹┖锛�");
- } else if (Cools.isEmpty(param.getBarcode())) {
- return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒");
- }
-
- TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>()
- .eq("task_no", param.getTaskNo())
- .eq("io_type", param.getIoType())
- .eq("barcode", param.getBarcode()));
- if (Cools.isEmpty(taskWrk)) {
- return R.error("鏈煡鍒板綋鍓嶄换鍔�---" + param);
- }
- boolean sign = false;
- switch (param.getTaskStatus()) {
- case 1://姝ｅ父鍙栨秷
- if (taskWrk.getStatus() > 1) {
- return R.error("浠诲姟宸插紑濮嬫墽琛�");
- }
- break;
- case 2://姝ｅ父瀹屾垚
- if (taskWrk.getStatus() > 1) {
- return R.error("浠诲姟宸插紑濮嬫墽琛�");
- }
- sign = true;
- break;
- default:
- return R.error("鏈煡鎿嶄綔");
- }
- return taskWrkOperate(taskWrk, sign);
- }
-
- //浠诲姟鎿嶄綔
- private R taskWrkOperate(TaskWrk taskWrk, boolean sign) {
- try {
- if (sign) {//瀹屾垚
- return taskWrkController.complete(taskWrk.getTaskNo());
- } else {//鍙栨秷
- return taskWrkController.cancel(taskWrk.getTaskNo());
- }
- } catch (Exception e) {
- return R.error();
- }
- }
-
- //璁惧鐘舵�佹煡璇㈡帴鍙�
- @GetMapping("/deviceStatus")
- @Transactional
- public R deviceStatus() {
- List<CrnStatusParam> crnStatusParams = new ArrayList<>();
- List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
- for (BasCrnp basCrnp : basCrnps) {
- CrnStatusParam crnStatusParam = new CrnStatusParam();
- crnStatusParam.setCrnNo(basCrnp.getCrnNo());
- crnStatusParam.setCrnSts(basCrnp.getCrnSts());
- crnStatusParam.setErrorCode(basCrnp.getCrnErr());
- BasCrnError error = basCrnErrorService.selectOne(new EntityWrapper<BasCrnError>().eq("error_code", basCrnp.getCrnErr()));
- if (Cools.isEmpty(error)) {
- crnStatusParam.setErrorMsg("");
- } else {
- crnStatusParam.setErrorMsg(error.getErrName());
- }
- crnStatusParams.add(crnStatusParam);
- }
- return R.ok(crnStatusParams);
- }
-
+// @PostMapping("/toAgvTaskOver")
+// @AppAuth(memo = "agv浠诲姟瀹屾垚鎺ュ彛")
+// public R getAgvTaskOver(@RequestHeader String appkey,
+// @RequestBody TaskOverParam param,
+// HttpServletRequest request) {
+// auth(appkey, param, request);
+// if (Cools.isEmpty(param)) {
+// return R.parse(BaseRes.PARAM);
+// }
+// if (Cools.isEmpty(param.getStartPoint())) {
+// return R.error("鐮佸ご[wharfCode]涓嶈兘涓虹┖");
+// }
+// if (Cools.isEmpty(param.getStatus())) {
+// return R.error("瀹屾垚鏍囪[status]涓嶈兘涓虹┖");
+// }
+// openService.getAgvTaskOver(param);
+// return R.ok();
+// }
}
--
Gitblit v1.9.1