From d147093e6b1e0d4f0d6aed1732843e6779ae696e Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期五, 27 二月 2026 09:45:57 +0800
Subject: [PATCH] 出库任务限制发给ctu过多
---
src/main/java/com/zy/asrs/task/JlerScheduler.java | 20 +++++++++++++++++---
1 files changed, 17 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/JlerScheduler.java b/src/main/java/com/zy/asrs/task/JlerScheduler.java
index b6c640d..70aabab 100644
--- a/src/main/java/com/zy/asrs/task/JlerScheduler.java
+++ b/src/main/java/com/zy/asrs/task/JlerScheduler.java
@@ -1,8 +1,10 @@
package com.zy.asrs.task;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.OrderPakout;
import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.service.BasDevpService;
import com.zy.asrs.service.DigitalTwinService;
import com.zy.asrs.service.OrderPakoutService;
import com.zy.asrs.service.WrkMastService;
@@ -56,14 +58,26 @@
jlerHandler.autoGenerateOutTask(orderPakout);
}
+ @Resource
+ private BasDevpService basDevpService;
+
/**
* 鏍规嵁鍑哄簱浠诲姟鑷姩鍛煎彨鏂欑鏈哄櫒浜烘惉杩�
*/
@Scheduled(cron = "0/10 * * * * ? ")
private void outboundCallBinRobot() {
- // 姣忔鍙�3鏉�
- List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<WrkMast>().setSqlSelect("TOP 3 *").eq("source_sta_no", 101).eq("wrk_sts", 11).orderBy("io_type"));
- for(WrkMast wrkMast:wrkMastList) {
+ // 鍒ゆ柇杈撻�佺嚎鏈夊灏戣揣
+ int loadingCount = basDevpService.selectCount(new EntityWrapper<BasDevp>().eq("loading", "Y"));
+
+ // 鍒ゆ柇鏈夊灏戝嚭搴撲换鍔″湪鎵ц
+ int execCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("wrk_sts", 12));
+ // 鍒ゆ柇杩樿兘鍙戝嚑涓嚭搴撲换鍔�
+ int count = 6 - loadingCount - execCount;
+ if (count <= 0) {
+ return;
+ }
+ List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<WrkMast>().setSqlSelect("TOP " + count + " *").eq("source_sta_no", 101).eq("wrk_sts", 11).orderBy("io_type"));
+ for (WrkMast wrkMast : wrkMastList) {
jlerHandler.outboundCallBinRobot(wrkMast);
}
}
--
Gitblit v1.9.1