From 5858cc2564a42479c65e14e21f8d554959c1827f Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期二, 24 九月 2024 16:13:15 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java | 12 ++++++++++++
1 files changed, 12 insertions(+), 0 deletions(-)
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java
index f0ccf51..2d670de 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java
@@ -5,10 +5,13 @@
import com.zy.asrs.framework.exception.CoolException;
import com.zy.asrs.wcs.core.domain.param.CreateWcsTaskParam;
import com.zy.asrs.wcs.core.entity.BasConveyorSta;
+import com.zy.asrs.wcs.core.entity.Task;
import com.zy.asrs.wcs.core.entity.TaskCache;
+import com.zy.asrs.wcs.core.model.enums.TaskStsType;
import com.zy.asrs.wcs.core.service.BasConveyorStaService;
import com.zy.asrs.wcs.core.service.OpenService;
import com.zy.asrs.wcs.core.service.TaskCacheService;
+import com.zy.asrs.wcs.core.service.TaskService;
import com.zy.asrs.wcs.rcs.model.enums.WorkModeType;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,6 +27,8 @@
public class TaskCacheTimer {
@Autowired
+ private TaskService taskService;
+ @Autowired
private TaskCacheService taskCacheService;
@Autowired
private BasConveyorStaService basConveyorStaService;
@@ -40,6 +45,13 @@
return;
}
+ int count = taskService.count(new LambdaQueryWrapper<Task>()
+ .in(Task::getTaskSts, TaskStsType.NEW_INBOUND.sts, TaskStsType.ANALYZE_INBOUND.sts, TaskStsType.EXECUTE_INBOUND.sts, TaskStsType.COMPLETE_INBOUND.sts
+ , TaskStsType.NEW_OUTBOUND.sts, TaskStsType.ANALYZE_OUTBOUND.sts, TaskStsType.EXECUTE_OUTBOUND.sts, TaskStsType.COMPLETE_OUTBOUND.sts));
+ if (count > 0) {
+ return;//瀛樺湪浠诲姟姝ｅ湪鎵ц锛岀瓑寰呮墽琛屽畬鎴愬悗鍐嶈В鏋愰槦鍒�
+ }
+
List<TaskCache> taskInCaches = taskCacheService.list(new LambdaQueryWrapper<TaskCache>().eq(TaskCache::getTaskType, 1));//鍏ュ簱缂撳瓨
List<TaskCache> taskOutCaches = taskCacheService.list(new LambdaQueryWrapper<TaskCache>().eq(TaskCache::getTaskType, 2));//鍑哄簱缂撳瓨
--
Gitblit v1.9.1