From e918d4fa4f5065b51be706f21da6793c378c9aaf Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期六, 16 八月 2025 17:05:05 +0800
Subject: [PATCH] 接口文档修改

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java |   35 ++++++++++++++++-------------------
 1 files changed, 16 insertions(+), 19 deletions(-)

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 1ae6e7d..414becc 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
@@ -3,7 +3,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.vincent.rsf.framework.common.Cools;
-import com.vincent.rsf.server.api.controller.params.TaskInParam;
+import com.vincent.rsf.server.api.controller.erp.params.TaskInParam;
 import com.vincent.rsf.server.api.entity.dto.InTaskMsgDto;
 import com.vincent.rsf.server.api.service.WcsService;
 import com.vincent.rsf.server.common.constant.Constants;
@@ -33,7 +33,6 @@
 
 import java.util.*;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 @Service("taskService")
 public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements TaskService {
@@ -411,18 +410,18 @@
     public void complateInTask(List<Task> tasks) throws Exception {
         Long loginUserId = SystemAuthUtils.getLoginUserId();
         for (Task task : tasks) {
-//            if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) {
-//
-//            } else if (task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)) {
-//                //53.鎷f枡鍐嶅叆搴�
-//                //57.鐩樼偣鍐嶅叆搴�
-//                pickComplateInStock(task, loginUserId);
-//            } else if (task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) {
-//                //绉诲簱
-//                moveInStock(task, loginUserId);
-//            }
-            //1.鍏ュ簱
-            complateInstock(task, loginUserId);
+            if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) {
+                //1.鍏ュ簱
+                complateInstock(task, loginUserId);
+            } else if (task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)) {
+                //53.鎷f枡鍐嶅叆搴�
+                //57.鐩樼偣鍐嶅叆搴�
+                pickComplateInStock(task, loginUserId);
+            } else if (task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) {
+                //绉诲簱
+                moveInStock(task, loginUserId);
+            }
+
         }
     }
 
@@ -707,9 +706,7 @@
         //淇濆瓨鍏ュ嚭搴撴祦姘�
         saveStockItems(taskItems, task, null, null, taskItem.getWkType(), taskItem.getOrderType(), loginUserId);
 
-        if (!locItemWorkingService.remove(new LambdaQueryWrapper<LocItemWorking>().eq(LocItemWorking::getTaskId, task.getId()))) {
-            throw new CoolException("浣滀笟涓簱瀛樺垹闄ゅけ璐ワ紒锛�");
-        }
+        locItemWorkingService.remove(new LambdaQueryWrapper<LocItemWorking>().eq(LocItemWorking::getTaskId, task.getId()));
 
         task.setTaskStatus(TaskStsType.UPDATED_IN.id).setUpdateTime(new Date()).setUpdateBy(loginUserId);
         if (!taskService.updateById(task)) {
@@ -1491,8 +1488,8 @@
 
         WkOrder order = asnOrderService.getOne(new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getCode, code));
         if (!Objects.isNull(order)) {
-            Double qty = Math.round((order.getQty() + sum) * 10000) / 10000.0;
-            order.setQty(qty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_EXCE.val);
+//            Double qty = Math.round((order.getQty() + sum) * 10000) / 10000.0;
+            order.setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_TASK_EXCE.val);
             if (!asnOrderService.updateById(order)) {
                 throw new CoolException("鍏ュ簱鍗曠姸鎬佷慨鏀瑰け璐ワ紒锛�");
             }

--
Gitblit v1.9.1