From 561728125973f6ea4f022fbfae3b747f7650a704 Mon Sep 17 00:00:00 2001
From: skyouc <creaycat@gmail.com>
Date: 星期四, 20 十一月 2025 21:47:54 +0800
Subject: [PATCH] Merge branch 'devlop_whxrwms' of http://47.97.1.152:5880/r/wms-master into devlop_whxrwms

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java |   24 ++++++++----------------
 1 files changed, 8 insertions(+), 16 deletions(-)

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 dc5854c..a68b334 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
@@ -578,19 +578,7 @@
                 throw new CoolException("浠诲姟鍘嗗彶妗d繚瀛樺け璐ワ紒锛�");
             }
             List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
-            //鍏ュ簱鍗曟嵁鏄庣粏涓婃姤
-//            if (order.getType().equals(OrderType.ORDER_OUT.type)) {
-//                try {
-//                    //涓婃姤宸插畬鎴愯鍗曡嚦ERP銆丮ES绛変笁鏂圭郴缁�
-//                    reportMsgService.reportOrders(order);
-//                    order.setReportOnce(order.getReportOnce() + 1);
-//                    if (!asnOrderService.updateById(order)) {
-//                        log.error(order.getCode() + "锛屽崟鎹笂浼犳鏁颁慨鏀瑰け璐ワ紒锛�");
-//                    }
-//                } catch (Exception e) {
-//                    log.error(e.getMessage());
-//                }
-//            }
+
             if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) {
                 for (TaskItem taskItem : taskItems) {
                     if (Objects.isNull(taskItem.getOrderId())) {
@@ -610,8 +598,8 @@
                     /**鍏ュ簱鍗曟槑缁嗕笂鎶�*/
                     reportMsgService.reportOrderItem(wkOrderItem);
                 }
-            } else if (task.getTaskType() >= TaskType.TASK_TYPE_OUT.type && task.getTaskType() <= TaskType.TASK_TYPE_EMPITY_OUT.type) {
-
+            } else if ((task.getTaskType() >= TaskType.TASK_TYPE_OUT.type && task.getTaskType() <= TaskType.TASK_TYPE_EMPITY_OUT.type)
+                    || task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type)) {
                 /**鍒ゆ柇鍗曟嵁鏄惁瀹屾垚**/
                 Set<Long> longSet = taskItems.stream().map(TaskItem::getSourceId).collect(Collectors.toSet());
                 List<WaveOrderRela> waveOrderRelas = waveOrderRelaService.list(new LambdaQueryWrapper<WaveOrderRela>()
@@ -628,12 +616,16 @@
                     //妫�鏌ュ崟鎹槸鍚﹀畬鎴�
                     if (order.getAnfme().compareTo(order.getQty()) == 0) {
                         order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
+//                        if (order.getType().equals(OrderType.ORDER_IN)) {
+//                            order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val);
+//                        } else {
+//                            order.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val);
+//                        }
                         if (!asnOrderService.updateById(order)) {
                             throw new CoolException("鍑哄簱鍗曟洿鏂扮姸鎬佸け璐�");
                         }
                     }
                 });
-
                 //鍑哄簱鍗曚笂鎶CS淇敼搴撲綅鐘舵��
                 try {
                     reportStationStatus(task);

--
Gitblit v1.9.1