From 0a8b8decb5b70e1345a2cb5d6ce37285d267f738 Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期五, 30 一月 2026 09:31:36 +0800
Subject: [PATCH] 移库任务功能优化

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 51 insertions(+), 4 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 21e625e..eb258b4 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -2585,11 +2585,58 @@
      * @return
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public R taskMove(CompleteParam combParam, long userId) {
-//        /openapi/createLocMoveTask
-
-
-
+        if (Objects.isNull(combParam.getWorkNo())) {
+            return R.error("浠诲姟鍙蜂笉鑳戒负绌�");
+        }
+        if (Objects.isNull(combParam.getSourceLocNo())) {
+            return R.error("婧愬簱浣嶄笉鑳戒负绌猴紒锛�");
+        }
+        if (Objects.isNull(combParam.getLocNo())) {
+            return R.error("鐩爣搴撲綅涓嶈兘涓虹┖锛�");
+        }
+        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", combParam.getWorkNo()));
+        if (Objects.isNull(wrkMast)) {
+            return R.error("浠诲姟妗d笉瀛樺湪锛侊紒");
+        }
+        String body = JSON.toJSONString(combParam);
+        boolean success = false;
+        String response = "";
+        try {
+            response = new HttpHandler.Builder()
+                    .setUri(HIKApiConstant.AGV_IP)
+                    .setPath(MesConstant.MOVE_LOC_TASK)
+                    .setJson(body)
+                    .build()
+                    .doPost();
+            JSONObject jsonObject = JSON.parseObject(response);
+            if (jsonObject.getInteger("code").equals(200)) {
+                wrkMast.setWrkSts(12L);
+                if (!wrkMastService.updateById(wrkMast)) {
+                    throw new CoolException("浠诲姟鐘舵�佹洿鏂板け璐ワ紒锛�");
+                }
+                success = true;
+            } else {
+                log.error("鍙戦�乤gv浠诲姟澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.WCS_URL + MesConstant.MOVE_LOC_TASK, body, response);
+            }
+        } catch (Exception e) {
+            log.error("鍙戦�乤gv浠诲姟寮傚父", e);
+        } finally {
+            try {
+                // 淇濆瓨鎺ュ彛鏃ュ織
+                apiLogService.save(
+                        "鍙戦�乤gv浠诲姟",
+                        MesConstant.WCS_URL + MesConstant.MOVE_LOC_TASK,
+                        null,
+                        "127.0.0.1",
+                        body,
+                        response,
+                        success);
+            } catch (Exception e) {
+                log.error("", e);
+            }
+        }
 
         return null;
     }

--
Gitblit v1.9.1