From 27f59f44345d044967e2048f09dbd704f90ce3db Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期五, 25 四月 2025 17:51:20 +0800
Subject: [PATCH] #新增 1. 新增波次功能 2. 库区新增优化
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 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 1e857c8..aa19574 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
@@ -50,6 +50,10 @@
private StockService stockService;
@Autowired
private LocService locService;
+ @Autowired
+ private OrderService orderService;
+ @Autowired
+ private OrderItemService orderItemService;
/**
* @author Ryan
* @description 瀹屾垚鍏ュ簱锛屾洿鏂板簱瀛�
@@ -88,6 +92,7 @@
if (taskItems.isEmpty()) {
return;
}
+
List<TaskLog> taskLogs = new ArrayList<>();
tasks.forEach(task -> {
TaskLog taskLog = new TaskLog();
@@ -99,15 +104,18 @@
throw new CoolException("浠诲姟鍘嗗彶妗ｄ繚瀛樺け璐ワ紒锛�");
}
List<TaskItemLog >itemLogs = new ArrayList<>();
+
taskItems.forEach(item -> {
TaskItemLog itemLog = new TaskItemLog();
BeanUtils.copyProperties(item, itemLog);
itemLog.setId(null).setTaskItemId(item.getId());
itemLogs.add(itemLog);
});
+
if (!taskItemLogService.saveBatch(itemLogs)) {
throw new CoolException("浠诲姟鏄庣粏鍘嗗彶妗ｄ繚瀛樺け璐ワ紒锛�");
}
+
if (!taskService.removeByIds(list)) {
throw new CoolException("鍘熷浠诲姟鍒犻櫎澶辫触锛侊紒");
}
--
Gitblit v1.9.1