From 8c75fbabe59e6d406e276736239afa3666ce4f0f Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期一, 14 十月 2024 10:56:51 +0800
Subject: [PATCH] #控制同时出库解析数量
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java | 18 ++++++++++++++++++
1 files changed, 18 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 5bbafcb..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;
@@ -38,6 +43,13 @@
.eq(BasConveyorSta::getSiteNo, 101));
if (basConveyorSta == null) {
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));//鍏ュ簱缂撳瓨
@@ -79,6 +91,12 @@
throw new CoolException("缂撳瓨鍒犻櫎澶辫触");
}
}
+
+ try {
+ Thread.sleep(10000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
}
}
--
Gitblit v1.9.1