From 7fa44c95eb33fee61cad4065669ccb30d9bbe27b Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期四, 07 十一月 2024 13:46:14 +0800
Subject: [PATCH] 入库过滤出库状态为15的任务

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   58 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 57 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index 6981160..18b2d7f 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -11,6 +11,7 @@
 import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.MatUtils;
+import com.zy.common.constant.AgvSiteConstant;
 import com.zy.common.constant.ApiInterfaceConstant;
 import com.zy.common.constant.MesConstant;
 import com.zy.common.entity.Parameter;
@@ -76,10 +77,16 @@
     @Override
     public R inLocCallAgv(String sta, String inSta) {
         // 鍒ゆ柇鍏ュ簱绔欑偣鏈夋棤鍑哄簱浠诲姟
-        int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", inSta));
+        int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("sta_no", inSta).ne("wrk_sts",15));
         if (count > 0) {
             return R.parse(inSta + "绔欑偣瀛樺湪鍑哄簱浠诲姟");
         }
+
+        // 鍏堢粦瀹�
+//        boolean flag = bindPodAndBerth(sta);
+//        if (!flag) {
+//            return R.parse(inSta + "缁戝畾澶辫触");
+//        }
 
         ForwardAGVTaskParam forwardAGVTaskParam = new ForwardAGVTaskParam();
         forwardAGVTaskParam.setReqCode(UUID.randomUUID().toString().replace("-", ""));
@@ -131,6 +138,55 @@
         return success ? R.ok("鍛煎彨agv鎴愬姛") : R.parse(message);
     }
 
+    private boolean bindPodAndBerth(String sta) {
+        String staMap = AgvSiteConstant.SiteMap.get(sta);
+        if (staMap == null) {
+            log.error("娌℃湁鎵惧埌璇ョ珯鐐圭殑鍏ュ簱鏄犲皠:{}",sta);
+            return false;
+        }
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("reqCode",UUID.randomUUID().toString().replace("-", "")); // 璇锋眰鍞竴鍊�
+        jsonObject.put("crnType","2"); // 瀹瑰櫒绫诲瀷2
+        jsonObject.put("stgBinCode",staMap); // 浠撲綅缂栧彿锛屾牴鎹浠撶紪鍙疯浆鎹�
+        jsonObject.put("indBind","1"); // 1缁戝畾锛�0瑙g粦
+
+        String body = jsonObject.toJSONString();
+        String response = "";
+        boolean success = false;
+        try {
+            response = new HttpHandler.Builder()
+                    .setUri(ApiInterfaceConstant.AGV_IP)
+                    .setPath(ApiInterfaceConstant.AGV_BIND_PATH)
+                    .setJson(body)
+                    .build()
+                    .doPost();
+            JSONObject res = JSON.parseObject(response);
+            if (res.getInteger("code").equals(0)) {
+                success = true;
+            } else {
+                log.error("璋冪敤agv缁戝畾浠撲綅澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_BIND_PATH, body, response);
+            }
+        } catch (Exception e) {
+            log.error("璋冪敤agv缁戝畾浠撲綅寮傚父", e);
+        } finally {
+            try {
+                // 淇濆瓨鎺ュ彛鏃ュ織
+                apiLogService.save(
+                        "璋冪敤agv缁戝畾浠撲綅",
+                        ApiInterfaceConstant.AGV_IP + ApiInterfaceConstant.AGV_BIND_PATH,
+                        null,
+                        "127.0.0.1",
+                        body,
+                        response,
+                        success
+                );
+            } catch (Exception e) {
+                log.error("", e);
+            }
+        }
+        return success;
+    }
+
     @Override
     @Transactional
     public void comb(CombParam param, Long userId) {

--
Gitblit v1.9.1