From d2ff39c5136f101ce372e4702a5e27357b3b6977 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期四, 12 十月 2023 09:54:55 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/controller/OpenController.java | 196 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 193 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 6024d65..18c87c4 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -1,12 +1,18 @@
package com.zy.asrs.controller;
import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.core.exception.CoolException;
+import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.CommandInfo;
+import com.zy.asrs.entity.TaskWrk;
+import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
import com.zy.asrs.entity.param.taskCreateParam;
-import com.zy.asrs.service.OpenService;
+import com.zy.asrs.service.*;
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -14,6 +20,7 @@
import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
+import java.util.List;
@Slf4j
@RestController
@@ -22,6 +29,14 @@
@Autowired
private OpenService openService;
+ @Autowired
+ private TaskWrkService taskWrkService;
+ @Autowired
+ private CommandInfoService commandInfoService;
+ @Autowired
+ private TaskWrkController taskWrkController;
+ @Autowired
+ private BasDevpService basDevpService;
public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
add("ea1f0459efc02a79f046f982767939ae");
@@ -29,8 +44,8 @@
//鍒涘缓浠诲姟
@PostMapping("/taskCreate")
- public R taskCreate(@RequestHeader(required = false) String appkey,
- @RequestBody(required = false) taskCreateParam param,
+ public R taskCreate(@RequestHeader String appkey,
+ @RequestBody taskCreateParam param,
HttpServletRequest request) {
auth(appkey, param, request);
if (Cools.isEmpty(param)) {
@@ -49,6 +64,34 @@
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("浠诲姟涓嶅瓨鍦�");
+ }
+ return R.ok().add(taskWrk);
+ }
+
+ //鏌ヨ浠诲姟鎸囦护闆嗗悎
+ @GetMapping("/queryTaskCommand")
+ public R queryTaskCommand(@RequestHeader String appkey,
+ @RequestParam String taskNo,
+ HttpServletRequest request) {
+ auth(appkey, taskNo, request);
+ TaskWrk taskWrk = taskWrkService.selectByTaskNo(taskNo);
+ if (taskWrk == null) {
+ return R.error("浠诲姟涓嶅瓨鍦�");
+ }
+
+ List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskNo);
+ 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);
@@ -60,4 +103,151 @@
}
}
+ //AGV璇锋眰鍏ュ簱鐮佸ご鎺ュ彛
+ @PostMapping("/targetWharfApply")
+ public R targetWharfApply(@RequestHeader String appkey,
+ @RequestBody WMSAndAGVInterfaceParam param,
+ HttpServletRequest request) {
+ if (Cools.isEmpty(param)){
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getTaskNo())){
+ return R.error("宸ヤ綔鍙蜂负绌猴紒");
+ } else if (Cools.isEmpty(param.getContainerCode())){
+ return R.error("鎵樼洏缂栫爜涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getWharfSource())){
+ return R.error("婧愮爜澶翠负绌猴紒");
+ } else if (Cools.isEmpty(param.getFreeWharfs()) || param.getFreeWharfs().size()==0){
+ return R.error("绌洪棽鐨勫叆搴撶爜澶达紙AGV锛変负绌猴紒");
+ }
+ TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
+
+ return R.ok(taskWrk.getStartPoint());
+ }
+
+ //AGV璇锋眰鍔ㄤ綔鎺ュ彛
+ @PostMapping("/agvTaskRequest")
+ public R agvTaskRequest(@RequestHeader String appkey,
+ @RequestBody WMSAndAGVInterfaceParam param,
+ HttpServletRequest request) {
+ if (Cools.isEmpty(param)){
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getRequestType())){
+ return R.error("璇锋眰绫诲瀷涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getWharfCode())){
+ return R.error("鐮佸ご缂栧彿涓虹┖锛�");
+ }
+ BasDevp basDevp = basDevpService.selectById(param.getWharfCode());
+ if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N")){
+ return R.ok();
+ }else {
+ return R.error();
+ }
+ }
+
+ //浠诲姟涓嬪彂鎺ュ彛
+ @PostMapping("/outboundTaskSend")
+ public R outboundTaskSend(@RequestHeader String appkey,
+ @RequestBody WMSAndAGVInterfaceParam param,
+ HttpServletRequest request) {
+ try {
+ if (Cools.isEmpty(param)){
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getTaskNo())){
+ return R.error("浠诲姟鍙蜂负绌猴紒");
+ } else if (Cools.isEmpty(param.getTaskType())){
+ return R.error("浠诲姟绫诲瀷涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getWarehouseId())){
+ return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
+ }
+ if (Cools.isEmpty(param.getTaskPriority())){
+ param.setTaskPriority(1);
+ }
+ if (Cools.isEmpty(param.getContainerCode())){
+ return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
+ }
+ if (Cools.isEmpty(param.getEmptyContainer())){
+ return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
+ }
+// if (Cools.isEmpty(param.getTaskTunnel())){
+// return R.error("浠诲姟宸烽亾涓虹┖锛�");
+// }
+// if (Cools.isEmpty(param.getGroupNo())){
+// return R.error("浠诲姟缁勪负绌猴紒");
+// }
+// if (Cools.isEmpty(param.getTaskSerialNo())){
+// return R.error("浠诲姟鎵ц椤哄簭涓虹┖锛�");
+// }
+ if (Cools.isEmpty(param.getTargetWharf())){
+ return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+ }
+
+ openService.taskCreate(new taskCreateParam(param));
+
+ return R.ok(param);
+ }catch (Exception e){
+ String errorMsg = Cools.isEmpty(e.getLocalizedMessage()) ? "" : e.getLocalizedMessage();
+ return R.ok("鐢熸垚浠诲姟澶辫触锛岃鑱旂郴绠＄悊鍛�!"+ errorMsg);
+ }
+ }
+
+ //浠诲姟鍙栨秷鎺ュ彛
+ @PostMapping("/taskCancel")
+ public R taskCancel(@RequestHeader String appkey,
+ @RequestBody WMSAndAGVInterfaceParam param,
+ HttpServletRequest request) {
+ if (Cools.isEmpty(param)){
+ return R.error("鍙傛暟涓虹┖锛�");
+ } else if (Cools.isEmpty(param.getTaskNo())){
+ return R.error("宸ヤ綔鍙蜂负绌猴紒");
+ } else if (Cools.isEmpty(param.getTaskStatus())){
+ return R.error("鎿嶄綔绫诲瀷涓虹┖锛�");
+ }
+// else if (Cools.isEmpty(param.getWarehouseId())){
+// return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
+// }
+
+ TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("task_no", param.getTaskNo()));
+ if (Cools.isEmpty(taskWrk)){
+ return R.error("鏈煡鍒板綋鍓嶄换鍔�");
+ }
+ boolean sign =false;
+ switch (param.getTaskStatus()){
+ case "1"://姝ｅ父鍙栨秷
+ if (taskWrk.getWrkSts()>1){
+ return R.error("浠诲姟宸插紑濮嬫墽琛�");
+ }
+ case "2"://寮哄埗鍙栨秷
+ if (taskWrk.getWrkSts()>3){
+ return R.error("浠诲姟宸叉墽琛屽畬鎴�");
+ }
+ break;
+ case "3"://姝ｅ父瀹屾垚
+ if (taskWrk.getWrkSts()>11){
+ return R.error("浠诲姟宸插紑濮嬫墽琛�");
+ }
+ case "4"://寮哄埗瀹屾垚
+ if (taskWrk.getWrkSts()>14){
+ 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();
+ }
+ }
+
}
--
Gitblit v1.9.1