From 61eb8dfa4ff44b539d9dd03205705270ba6e1fa7 Mon Sep 17 00:00:00 2001
From: skyouc <creaycat@gmail.com>
Date: 星期六, 10 一月 2026 14:38:00 +0800
Subject: [PATCH] 库位锁定或释放 添加任务自动下发功能

---
 src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java |   45 +++++++++++++++++++++++++++++++++++++++------
 1 files changed, 39 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java b/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
index 0186fd0..ede488a 100644
--- a/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
+++ b/src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java
@@ -61,7 +61,7 @@
         }
         Set<String> locs = binds.stream().map(LocAroundBind::getBLocNo).collect(Collectors.toSet());
 
-        reportLockLocs(locs);
+        reportLockLocs(locs, "lock");
 
         return R.ok("涓婃姤鎴愬姛锛侊紒");
     }
@@ -109,26 +109,59 @@
      */
     @Override
     public R pubWrkToWcs(WorkTaskParams params) {
+        if (Objects.isNull(params.getTaskNo())) {
+            return R.error("浠诲姟鍙蜂笉鑳戒负绌猴紒锛�");
+        }
+        if (Objects.isNull(params.getBarcode())) {
+            return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒锛�");
+        }
+        if (Objects.isNull(params.getLocNo())) {
+            return R.error("鐩爣搴撲綅涓嶈兘涓虹┖锛侊紒");
+        }
+        String url = MesConstant.PUB_TASK_IN;
+        if (Objects.isNull(params.getType()) && params.getType().equals("out")) {
+            url = MesConstant.PUB_TASK_OUT;
+        }
+        String response;
+        try {
+            response =  new HttpHandler.Builder()
+                    .setUri(MesConstant.URL)
+                    .setPath(url)
+                    .setJson(JSON.toJSONString(params))
+                    .build()
+                    .doPost();
+            R result = JSON.parseObject(response, R.class);
 
-
-
+            if (result.get("code").equals("200")) {
+                //TODO 涓婃姤鏄惁鎴愬姛
+            }
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
         return null;
     }
 
 
     /**
-     * 涓婃姤閿佸畾搴撲綅淇℃伅
+     * 涓婃姤閿佸畾/閲婃斁搴撲綅淇℃伅
      * @author Ryan
      * @date 2026/1/10 12:50
      * @param locs
      */
+    @Override
     @Transactional(rollbackFor = Exception.class)
-    public void reportLockLocs(Set<String> locs) {
+    public void reportLockLocs(Set<String> locs, String type) {
+        String url = MesConstant.LOCK_LOCS_URL;
+        if (!Objects.isNull(type)) {
+            if (type.equals("release")) {
+                url = MesConstant.RELEASE_LOCS_URL;
+            }
+        }
         String response;
         try {
           response =  new HttpHandler.Builder()
             .setUri(MesConstant.URL)
-            .setPath(MesConstant.LOCK_LOCS_URL)
+            .setPath(url)
             .setJson(JSON.toJSONString(locs))
             .build()
             .doPost();

--
Gitblit v1.9.1