From 5e2db58fe16732b3a9d30f0476e9c4c0c8fcab02 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期二, 30 一月 2024 16:32:14 +0800
Subject: [PATCH] # 入库流程

---
 src/main/java/com/zy/asrs/controller/OpenController.java |  101 +++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 75 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index ada0552..eb2cd6c 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -23,10 +23,8 @@
 
 import javax.servlet.http.HttpServletRequest;
 import java.io.IOException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.sql.ResultSetMetaData;
+import java.util.*;
 
 @Slf4j
 @RestController
@@ -45,7 +43,8 @@
     private BasDevpService basDevpService;
     @Autowired
     private ApiLogService apiLogService;
-
+    @Autowired
+    private BasCrnpService basCrnpService;
     @Autowired
     private StaDescService staDescService;
 
@@ -185,22 +184,26 @@
         }
 
         Map<String,Integer> map = new HashMap<>();
-        map.put("J-1101",102);map.put("J-1102",101);
-        map.put("J-1103",106);map.put("J-1104",105);
-        map.put("J-1105",110);map.put("J-1106",109);
-        map.put("J-1107",114);map.put("J-1108",113);
-        map.put("J-1109",118);map.put("J-1110",117);
-        map.put("J-1111",122);map.put("J-1112",121);
+        map.put("J-1102",102);map.put("J-1101",101);
+        map.put("J-1103",105);map.put("J-1104",106);
+        map.put("J-1105",109);map.put("J-1106",110);
+        map.put("J-1107",113);map.put("J-1108",114);
+        map.put("J-1109",117);map.put("J-1110",118);
+        map.put("J-1111",121);map.put("J-1112",122);
         map.put("H-1102",300);map.put("H-1101",305);
-        StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
-                .eq("stn_desc", param.getWharfCode()));
-
-        if (Cools.isEmpty(staDesc)){
-            return R.error("绋嬪簭鎶ラ敊锛屾湭鏌ヨ鍒扮珯鐐�");
+        map.put("G-1102",400);map.put("G-1101",405);
+//        StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+//                .eq("stn_desc", param.getWharfCode()));
+//
+//        if (Cools.isEmpty(staDesc)){
+//            return R.error("绋嬪簭鎶ラ敊锛屾湭鏌ヨ鍒扮珯鐐�");
+//        }
+        if (Cools.isEmpty(map.get(param.getWharfCode()))){
+            return R.error("鏈煡璇㈠埌绔欑偣");
         }
-        //BasDevp basDevp = basDevpService.selectById(map.get(param.getWharfCode()));
-        BasDevp basDevp = basDevpService.selectById(staDesc.getStnNo());
-        if (basDevp.getAutoing().equals("Y")){
+        BasDevp basDevp = basDevpService.selectById(map.get(param.getWharfCode()));
+//        BasDevp basDevp = basDevpService.selectById(staDesc.getStnNo());
+        if (basDevp.getAutoing().equals("Y") && (basDevp.getInEnable().equals("Y") || basDevp.getOutEnable().equals("Y"))){
             apiLogService.save("AGV璇锋眰鍏ュ簱鐮佸ご鎺ュ彛"
                     ,request.getRemoteAddr()+request.getRequestURI()
                     ,appkey
@@ -209,7 +212,7 @@
                     ,R.ok().toString()
                     ,true
             );
-            return R.ok();
+            return R.ok("鍙叆");
         }else {
             apiLogService.save("AGV璇锋眰鍏ュ簱鐮佸ご鎺ュ彛"
                     ,request.getRemoteAddr()+request.getRequestURI()
@@ -256,16 +259,30 @@
                 if (Cools.isEmpty(param.getEmptyContainer())){
                     return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
                 }
-                if (Cools.isEmpty(param.getTargetWharf())){
-                    return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+                if (!param.getTaskType().equals("YK")){
+                    if (Cools.isEmpty(param.getTargetWharf())){
+                        return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+                    }
                 }
+
                 StaDesc staDesc = new StaDesc();
                 if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("J")){
                     staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
-                            .eq("crn_no", param.getTaskTunnel()).eq("type_no",2).lt("crn_stn", 200));
+                            .eq("crn_no",param.getTaskTunnel())
+                            .eq("type_no",2)
+                            .lt("stn_no",200));
+                }else if (param.getTaskType().equals("CK") && param.getTargetWharf().contains("H")){
+                    staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
+                            .eq("crn_no",param.getTaskTunnel())
+                            .eq("type_no",2)
+                            .lt("stn_no",400)
+                            .gt("stn_no",200));
                 }else {
                     staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
-                            .eq("crn_no", param.getTaskTunnel()).eq("type_no",2).ge("crn_stn", 200));
+                            .eq("crn_no",param.getTaskTunnel())
+                            .eq("type_no",2)
+                            .lt("stn_no",500)
+                            .ge("stn_no",400));
                 }
                 param.setTargetLocationCode(staDesc.getStnNo().toString());
 
@@ -280,11 +297,11 @@
                         ,r.toString()
                         ,true
                 );
-                return r;
+
 
         }
 
-        return null;
+        return R.ok();
     }
 
     //浠诲姟鍙栨秷鎺ュ彛
@@ -292,6 +309,7 @@
     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())){
@@ -347,6 +365,37 @@
         }
     }
 
+    //璁惧鐘舵�佹煡璇㈡帴鍙�
+    @PostMapping("/deviceStatus")
+    @Transactional
+    public R deviceStatus(@RequestHeader String appkey,
+                              HttpServletRequest request) {
+        auth(appkey, "璁惧鐘舵�佹煡璇㈡帴鍙�", request);
+        List<BasDevp> basDevps = basDevpService.selectList(new EntityWrapper<>());
+        List<Map<String, Object>> list = new ArrayList<>();
+        for (BasDevp basDevp:basDevps){
+            Map<String, Object> map = new HashMap<>();
+            map.put("devNo", basDevp.getDevNo());
+            map.put("devType", "杈撻�佺嚎");
+            map.put("devStatus", basDevp.getAutoing().equals("Y")? 1:0);
+            map.put("errorCode", 0);
+            map.put("errorMsg", "");
+            map.put("newDate",new Date());
+            list.add(map);
+        }
+        List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>());
+        for (BasCrnp basCrnp:basCrnps){
+            Map<String, Object> map = new HashMap<>();
+            map.put("devNo", basCrnp.getCrnNo());
+            map.put("devType", "鍫嗗灈鏈�");
+            map.put("devStatus", basCrnp.getCrnSts());
+            map.put("errorCode", 0);
+            map.put("errorMsg", "");
+            map.put("newDate",new Date());
+            list.add(map);
+        }
+        return R.ok(list);
+    }
 
 
 }

--
Gitblit v1.9.1