From 5213d5c3bf7c4b60fbb308fdadfb84f6d999c38b Mon Sep 17 00:00:00 2001
From: zc <zyzc>
Date: 星期五, 14 十一月 2025 23:18:35 +0800
Subject: [PATCH] 出庫訂單完成上報功能優化

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java  |    6 
 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java       |   44 ++++----
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java |  232 ++++++++++++++++++++++++++++++++--------------
 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java |    7 
 rsf-server/src/main/java/com/vincent/rsf/server/manager/enums/LocStsType.java              |   10 +-
 5 files changed, 194 insertions(+), 105 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java
index f38ec84..c723680 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java
@@ -291,14 +291,15 @@
             if (!Objects.isNull(user)) {
                 nickName = user.getNickname();
             }
-            //鑾峰彇鍏ュ簱搴撲綅淇℃伅
+                 //鑾峰彇搴撳瓨搴撲綅淇℃伅
             if (order.getType().equals(OrderType.ORDER_IN.type)) {
+                //鑾峰彇鍏ュ簱搴撲綅淇℃伅
                 //绛涢�夊綋鍓嶅敮涓�瀛楁鎵�鏈夊嚭鍏ュ簱淇℃伅
                 List<StockItem> stockItems = stockItemService.list(new LambdaQueryWrapper<StockItem>()
                         .eq(StockItem::getFieldsIndex, orderItem.getFieldsIndex()));
                 //鑾峰彇搴撳瓨涓鍗曞簱浣�
                 Set<Long> longSet = stockItems.stream().map(StockItem::getStockId).collect(Collectors.toSet());
-                //鑾峰彇搴撳瓨搴撲綅淇℃伅
+
                 Stock stocks = stockService.getOne(new LambdaQueryWrapper<Stock>()
                         .in(Stock::getId, longSet)
                         .eq(Stock::getType, OrderType.ORDER_IN.type)
@@ -306,82 +307,173 @@
                 if (!Objects.isNull(stocks)) {
                     param.setZone(stocks.getLocCode());
                 }
-            }
-            //鑾峰彇绱㈠紩鍐呭
-            Map<String, String> fields = FieldsUtils.getFields(orderItem.getFieldsIndex());
+                //鑾峰彇绱㈠紩鍐呭
+                Map<String, String> fields = FieldsUtils.getFields(orderItem.getFieldsIndex());
+                //璁剧疆閫氱敤鍙傛暟
+                param.setWMSNO(order.getCode())
+                        .setPONO(order.getPoCode())
+                        .setOrderNO(order.getPoCode())
+                        .setOrderDate(order.getCreateTime())
+                        .setItemCode(orderItem.getMatnrCode())
+                        .setEditUser(nickName)
+                        .setEditDate(order.getUpdateTime())
+                        .setGoodsNO(fields.get("crushNo"))
+                        .setMemoDtl(order.getMemo());
 
-            //璁剧疆閫氱敤鍙傛暟
-            param.setWMSNO(order.getCode())
-                    .setPONO(order.getPoCode())
-                    .setOrderNO(order.getPoCode())
-                    .setOrderDate(order.getCreateTime())
-                    .setItemCode(orderItem.getMatnrCode())
-                    .setEditUser(nickName)
-                    .setEditDate(order.getUpdateTime())
-                    .setGoodsNO(fields.get("crushNo"))
-                    .setMemoDtl(order.getMemo());
+                if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_DONE_IN.type)) {
+                    //閲囪喘鍏ュ簱鍗�
+                    params.setOrderType("PO_Instock").setAction("Update");
+                    //鑾峰彇鎸囧畾鏌ヨ瀛楁CrushNo 绁ㄥ彿
+                    param.setInQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE_RETURN.type)) {
+                    //閲囪喘閫�璐�
+                    params.setOrderType("PR_Outstock").setAction("Update");
+                    param.setOutQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER_IN.type)) {
+                    //璋冩嫈鍏ュ簱鍗�
+                    params.setOrderType("Mv_Instock").setAction("Update");
 
-            if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_DONE_IN.type)) {
-                //閲囪喘鍏ュ簱鍗�
-                params.setOrderType("PO_Instock").setAction("Update");
-                //鑾峰彇鎸囧畾鏌ヨ瀛楁CrushNo 绁ㄥ彿
-                param.setInQty(orderItem.getQty());
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE_RETURN.type)) {
-                //閲囪喘閫�璐�
-                params.setOrderType("PR_Outstock").setAction("Update");
-                param.setOutQty(orderItem.getQty());
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER_IN.type)) {
-                //璋冩嫈鍏ュ簱鍗�
-                params.setOrderType("Mv_Instock").setAction("Update");
-
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD.type)) {
-                //鐢熶骇鍏ュ簱鍗�
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD.type)) {
+                    //鐢熶骇鍏ュ簱鍗�
 //                params.setOrderType("WO_Outstock").setAction("Update");
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE.type)) {
-                //鐢熶骇閫�鏂�
-                params.setOrderType("WR_Instock").setAction("Update");
-                param.setInQty(orderItem.getQty());
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_RETURN_ORDER.type)) {
-                //鐢熶骇棰嗘枡
-                params.setOrderType("WO_Outstock").setAction("Update");
-                param.setOutQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE.type)) {
+                    //鐢熶骇閫�鏂�
+                    params.setOrderType("WR_Instock").setAction("Update");
+                    param.setInQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_RETURN_ORDER.type)) {
+                    //鐢熶骇棰嗘枡
+                    params.setOrderType("WO_Outstock").setAction("Update");
+                    param.setOutQty(orderItem.getQty());
 
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD_ADDITION.type)) {
-                //鐢熶骇琛ユ枡
-                params.setOrderType("WR_Instock_BL").setAction("Update");
-                param.setOutQty(orderItem.getQty());
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_FIX_OUT.type)) {
-                params.setOrderType("WO_Outstock_WR").setAction("Update");
-                param.setOutQty(orderItem.getQty());
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)) {
-                //鍏跺畠鍏ュ簱鍗�/鎵嬪姩鍏ュ簱鍗�
-                params.setOrderType("In_Instock").setAction("Update");
-                param.setInQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD_ADDITION.type)) {
+                    //鐢熶骇琛ユ枡
+                    params.setOrderType("WR_Instock_BL").setAction("Update");
+                    param.setOutQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_FIX_OUT.type)) {
+                    params.setOrderType("WO_Outstock_WR").setAction("Update");
+                    param.setOutQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)) {
+                    //鍏跺畠鍏ュ簱鍗�/鎵嬪姩鍏ュ簱鍗�
+                    params.setOrderType("In_Instock").setAction("Update");
+                    param.setInQty(orderItem.getQty());
 
-            } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER.type)) {
-                //鍏跺畠鍑哄簱鍗�/鎵嬪姩鍑哄簱鍗�
-                params.setOrderType("Io_Outstock").setAction("Update");
-                param.setOutQty(orderItem.getQty());
+                } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER.type)) {
+                    //鍏跺畠鍑哄簱鍗�/鎵嬪姩鍑哄簱鍗�
+                    params.setOrderType("Io_Outstock").setAction("Update");
+                    param.setOutQty(orderItem.getQty());
+                }
+                reportData.add(param);
+
+
+                params.setData(reportData);
+                try {
+                    R reported = uploadReportOrders(params);
+                    if (Integer.valueOf(reported.get("code").toString()) == 200) {
+                        order.setNtyStatus(OrderReportStatus.ORDER_REPORT_STATUS_ALL.val);
+                        asnOrderService.updateById(order);
+                    }
+                } catch (Exception e) {
+                    log.error("<UNK>", e);
+                }
+                try {
+                    //浼戠湢3绉�
+                    Thread.sleep(3000);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
+            } else if (order.getType().equals(OrderType.ORDER_OUT.type)){
+                List<Stock> stocks = stockService.list(new LambdaQueryWrapper<Stock>().eq(Stock::getSourceCode, order.getCode()));
+                if (stocks.isEmpty()) {
+                    throw new CoolException("鍑哄韩姝峰彶涓嶅瓨鍦紒锛�");
+                }
+                String finalNickName = nickName;
+                stocks.forEach(stock -> {
+                    //绛涢�夊綋鍓嶅敮涓�瀛楁鎵�鏈夊嚭鍏ュ簱淇℃伅
+                    List<StockItem> stockItems = stockItemService.list(new LambdaQueryWrapper<StockItem>()
+                            .eq(StockItem::getStockId, stock.getId()));
+                    if (stockItems.isEmpty()) {
+                        throw new CoolException("鍑哄韩鍠槑绱颁笉瀛樺湪锛侊紒");
+                    }
+                    //鑾峰彇搴撳瓨涓鍗曞簱浣�
+//                Set<Long> longSet = stockItems.stream().map(StockItem::getStockId).collect(Collectors.toSet());
+                    stockItems.forEach(items -> {
+                        List<ReportDataParam> dataParams = new ArrayList<>();
+                        //鑾峰彇绱㈠紩鍐呭
+                        Map<String, String> fields = FieldsUtils.getFields(items.getFieldsIndex());
+                        //璁剧疆閫氱敤鍙傛暟
+                        param.setWMSNO(order.getCode())
+                                .setPONO(order.getPoCode())
+                                .setOrderNO(order.getPoCode())
+                                .setOrderDate(order.getCreateTime())
+                                .setItemCode(items.getMatnrCode())
+                                .setEditUser(finalNickName)
+                                .setEditDate(order.getUpdateTime())
+                                .setGoodsNO(fields.get("crushNo"))
+                                .setMemoDtl(order.getMemo());
+
+                        if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_DONE_IN.type)) {
+                            //閲囪喘鍏ュ簱鍗�
+                            params.setOrderType("PO_Instock").setAction("Update");
+                            //鑾峰彇鎸囧畾鏌ヨ瀛楁CrushNo 绁ㄥ彿
+                            param.setInQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE_RETURN.type)) {
+                            //閲囪喘閫�璐�
+                            params.setOrderType("PR_Outstock").setAction("Update");
+                            param.setOutQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER_IN.type)) {
+                            //璋冩嫈鍏ュ簱鍗�
+                            params.setOrderType("Mv_Instock").setAction("Update");
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD.type)) {
+                            //鐢熶骇鍏ュ簱鍗�
+//                      params.setOrderType("WO_Outstock").setAction("Update");
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PURCHASE.type)) {
+                            //鐢熶骇閫�鏂�
+                            params.setOrderType("WR_Instock").setAction("Update");
+                            param.setInQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_RETURN_ORDER.type)) {
+                            //鐢熶骇棰嗘枡
+                            params.setOrderType("WO_Outstock").setAction("Update");
+                            param.setOutQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_PROD_ADDITION.type)) {
+                            //鐢熶骇琛ユ枡
+                            params.setOrderType("WR_Instock_BL").setAction("Update");
+                            param.setOutQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_FIX_OUT.type)) {
+                            params.setOrderType("WO_Outstock_WR").setAction("Update");
+                            param.setOutQty(orderItem.getQty());
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type)) {
+                            //鍏跺畠鍏ュ簱鍗�/鎵嬪姩鍏ュ簱鍗�
+                            params.setOrderType("In_Instock").setAction("Update");
+                            param.setInQty(orderItem.getQty());
+
+                        } else if (order.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER.type)) {
+                            //鍏跺畠鍑哄簱鍗�/鎵嬪姩鍑哄簱鍗�
+                            params.setOrderType("Io_Outstock").setAction("Update");
+                            param.setOutQty(orderItem.getQty());
+                        }
+                        dataParams.add(param);
+
+                        params.setData(dataParams);
+                        try {
+                            R reported = uploadReportOrders(params);
+                            if (Integer.valueOf(reported.get("code").toString()) == 200) {
+                                order.setReportOnce(5);
+                                asnOrderService.updateById(order);
+                            }
+                        } catch (Exception e) {
+                            log.error("<UNK>", e);
+                        }
+                        try {
+                            //浼戠湢3绉�
+                            Thread.sleep(3000);
+                        } catch (InterruptedException e) {
+                            throw new RuntimeException(e);
+                        }
+                    });
+                });
             }
-            reportData.add(param);
         });
-        params.setData(reportData);
-        try {
-            R reported = uploadReportOrders(params);
-            if (Integer.valueOf(reported.get("code").toString()) == 200) {
-                order.setNtyStatus(OrderReportStatus.ORDER_REPORT_STATUS_ALL.val);
-                asnOrderService.updateById(order);
-            }
-        } catch (Exception e) {
-            log.error("<UNK>", e);
-        }
 
-        try {
-            //浼戠湢3绉�
-            Thread.sleep(3000);
-        } catch (InterruptedException e) {
-            throw new RuntimeException(e);
-        }
     }
 
     /**
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/enums/LocStsType.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/enums/LocStsType.java
index a9fc98b..d081a1a 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/enums/LocStsType.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/enums/LocStsType.java
@@ -65,15 +65,15 @@
      */
     public static String getRcsLocSts(String val) {
         if (val.equals(LocStsType.LOC_STS_TYPE_O.type)) {
-            return RcsLocStsType.LOC_STS_TYPE_D.type;
+            return RcsLocStsType.LOC_STS_TYPE_D.desc;
         } else if (val.equals(LocStsType.LOC_STS_TYPE_F.type)) {
-            return RcsLocStsType.LOC_STS_TYPE_F.type;
+            return RcsLocStsType.LOC_STS_TYPE_F.desc;
         } else if (val.equals(LocStsType.LOC_STS_TYPE_S.type)) {
-            return RcsLocStsType.LOC_STS_TYPE_S.type;
+            return RcsLocStsType.LOC_STS_TYPE_S.desc;
         } else if (val.equals(LocStsType.LOC_STS_TYPE_R.type)) {
-            return RcsLocStsType.LOC_STS_TYPE_R.type;
+            return RcsLocStsType.LOC_STS_TYPE_R.desc;
         } else if (val.equals(LocStsType.LOC_STS_TYPE_X.type)) {
-            return RcsLocStsType.LOC_STS_TYPE_X.type;
+            return RcsLocStsType.LOC_STS_TYPE_X.desc;
         }
         return null;
     }
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java
index a521c98..b986c84 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java
@@ -64,7 +64,7 @@
      * @description 鍒犻櫎宸插畬鎴愯鍗曞姞鍏og琛�
      * @time 2025/3/19 19:09
      */
-    @Scheduled(cron = "0/35 * * * * ?  ")
+    @Scheduled(cron = "0 0 2 1 * ?")
     @Transactional(rollbackFor = Exception.class)
     public void InStockToLog() {
         List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
@@ -89,7 +89,8 @@
      * @description 鍑哄簱鍗曞畬鎴愬悗锛岀姸鎬佷慨鏀�
      * @time 2025/6/16 08:35
      */
-    @Scheduled(cron = "0/30 * * * * ?  ")
+    @Scheduled(cron = "0/15 * * * * ?  ")
+//    @Scheduled(cron = "0 0 2 1 * ?")
     @Transactional(rollbackFor = Exception.class)
     public void outStockComplete() {
         List<WkOrder> wkOrders = asnOrderService.list(new LambdaQueryWrapper<WkOrder>()
@@ -141,7 +142,7 @@
                     log.error(e.getMessage());
                 }
             }
-            if (order.getNtyStatus().equals(OrderReportStatus.ORDER_REPORT_STATUS_ALL.val)) {
+            if (order.getType().equals(OrderType.ORDER_OUT.type) &&  order.getReportOnce() >= 4) {
                 AsnOrderLog one = asnOrderLogService.getOne(new LambdaQueryWrapper<AsnOrderLog>().eq(AsnOrderLog::getCode, order.getCode()), false);
                 if (Objects.isNull(one)) {
                     AsnOrderLog orderLog = new AsnOrderLog();
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java
index 582c8af..7037a5e 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java
@@ -558,27 +558,25 @@
             List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
             //鍏ュ簱鍗曟嵁鏄庣粏涓婃姤
 
-            for (TaskItem taskItem : taskItems) {
-                if (Objects.isNull(taskItem.getOrderId())) {
-                    continue;
+            if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) {
+                for (TaskItem taskItem : taskItems) {
+                    if (Objects.isNull(taskItem.getOrderId())) {
+                        continue;
+                    }
+                    WkOrder order = asnOrderService.getById(taskItem.getOrderId());
+                    if (Objects.isNull(order)) {
+                        continue;
+                    }
+                    //鍏ュ簱鍗曚换鍔℃槑缁嗕笂鎶�
+                    WkOrderItem wkOrderItem = asnOrderItemService.getOne(new LambdaQueryWrapper<WkOrderItem>()
+                            .eq(WkOrderItem::getOrderId, order.getId())
+                            .eq(WkOrderItem::getFieldsIndex, taskItem.getFieldsIndex()));
+                    if (Objects.isNull(wkOrderItem)) {
+                        throw new CoolException("鏁版嵁閿欒锛屽崟鎹槑缁嗕笉瀛樺湪鎴栧凡瀹屾垚锛侊紒");
+                    }
+                    /**鍏ュ簱鍗曟槑缁嗕笂鎶�*/
+                    reportMsgService.reportOrderItem(wkOrderItem);
                 }
-                WkOrder order = asnOrderService.getById(taskItem.getOrderId());
-                if (Objects.isNull(order)) {
-                    continue;
-                }
-                //鍏ュ簱鍗曚换鍔℃槑缁嗕笂鎶�
-                WkOrderItem wkOrderItem = asnOrderItemService.getOne(new LambdaQueryWrapper<WkOrderItem>()
-                        .eq(WkOrderItem::getOrderId, order.getId())
-                        .eq(WkOrderItem::getFieldsIndex, taskItem.getFieldsIndex()));
-                if (Objects.isNull(wkOrderItem)) {
-                    throw new CoolException("鏁版嵁閿欒锛屽崟鎹槑缁嗕笉瀛樺湪鎴栧凡瀹屾垚锛侊紒");
-                }
-                /**鍏ュ簱鍗曟槑缁嗕笂鎶�*/
-                reportMsgService.reportOrderItem(wkOrderItem);
-            }
-
-            if (task.getTaskType() <= TaskType.TASK_TYPE_CHECK_IN.type) {
-
             } else if (task.getTaskType() >= TaskType.TASK_TYPE_OUT.type && task.getTaskType() <= TaskType.TASK_TYPE_EMPITY_OUT.type) {
                 //鍑哄簱鍗曚笂鎶CS淇敼搴撲綅鐘舵��
                 try {
@@ -636,11 +634,9 @@
         }
 
         LocSiteParams locSiteParams = new LocSiteParams();
-        locSiteParams
-                .setStatus(LocStsType.getRcsLocSts(LocStsType.LOC_STS_TYPE_O.type))
+        locSiteParams.setStatus(LocStsType.getRcsLocSts(LocStsType.LOC_STS_TYPE_O.type))
                 .setType("site")
                 .setCode(station.getStationName());
-
         /**WMS鍩虹閰嶇疆閾炬帴*/
         String rcsUrl = rcsApi.getHost() + ":" + rcsApi.getPort() + RcsConstant.REPORT_SITE_STATUS;
         log.info("涓婃姤宸插畬鎴愯鍗曪細{}锛� 璇锋眰鍙傛暟锛� {}", rcsUrl, JSONObject.toJSONString(locSiteParams));
@@ -651,6 +647,7 @@
         HttpEntity httpEntity = new HttpEntity(locSiteParams, headers);
         ResponseEntity<String> exchange = restTemplate.exchange(rcsUrl, HttpMethod.POST, httpEntity, String.class);
         log.info("涓婃姤宸插畬鎴愯鍗曪紝杩斿洖缁撴灉锛� {}", exchange);
+
         if (Objects.isNull(exchange.getBody())) {
             throw new CoolException("淇敼澶辫触锛侊紒");
         } else {
@@ -663,7 +660,6 @@
                 throw new CoolException(e.getMessage());
             }
         }
-
     }
 
 }
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
index a0d4c53..53cc96e 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
@@ -683,9 +683,9 @@
         if (Objects.isNull(loc)) {
             throw new CoolException("搴撳瓨涓嶅瓨鍦紒锛�");
         }
-        if (!loc.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type)) {
-            throw new CoolException("褰撳墠搴撲綅鐘舵�佷笉澶勪簬S.鍏ュ簱棰勭害锛屼笉鍙墽琛屽叆搴撴搷浣滐紒");
-        }
+//        if (!loc.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type)) {
+//            throw new CoolException("褰撳墠搴撲綅鐘舵�佷笉澶勪簬S.鍏ュ簱棰勭害锛屼笉鍙墽琛屽叆搴撴搷浣滐紒");
+//        }
 
         loc.setUseStatus(LocStsType.LOC_STS_TYPE_F.type)
                 .setBarcode(task.getBarcode())

--
Gitblit v1.9.1