From 9effb92a108f4cfcd7b67ef2f94c82af23f155da Mon Sep 17 00:00:00 2001 From: liweidong-hj Date: Thu, 12 Mar 2026 15:53:50 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BE=AA=E7=8E=AF=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logistics/service/impl/StorageMonitoringServiceImpl.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java index ce6586bb..33ed9fa1 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StorageMonitoringServiceImpl.java @@ -13,6 +13,7 @@ import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; +import java.util.ArrayList; import java.util.List; /** @@ -105,6 +106,7 @@ public class StorageMonitoringServiceImpl implements IStorageMonitoringService { log.warn("【仓储监控】定时任务执行 - 未查询到空闲站点，任务提前结束"); return; } + ArrayList taskIdList = new ArrayList<>(); // ========== 步骤2：遍历空闲站点处理关联任务 ========== int processedCount = 0; // 统计成功处理的站点数量 @@ -118,6 +120,7 @@ public class StorageMonitoringServiceImpl implements IStorageMonitoringService { new LambdaQueryWrapper() .eq(Task::getTaskStatus, Task.STATUS_TEMPORARY_STORAGE) // 任务状态：待库位 .eq(Task::getWcId, station.getWcId()) // 匹配当前站点的工位ID + .notIn(taskIdList!=null&&taskIdList.size()!=0,Task::getId,taskIdList) .orderByAsc(Task::getCreateTime) // 按创建时间升序，优先处理最早创建的任务 ); @@ -200,6 +203,7 @@ public class StorageMonitoringServiceImpl implements IStorageMonitoringService { if(null != ctuSchedulingTask && ctuSchedulingTask.getCode().equals("0")){ // 添加任务 boolean record = taskExecuteRecordService.inboundRecord(ctuSchedulingTask, firstTask,null); + taskIdList.add(firstTask.getId()); } processedCount++; // 成功处理计数+1