From 58d62142408b64ddd597aab2ed06138300b4a571 Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期三, 31 十二月 2025 10:42:20 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 20 +++++++++++++++++---
1 files changed, 17 insertions(+), 3 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
index de18b2a..8853796 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
@@ -247,12 +247,26 @@
List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
for (Task task : taskList) {
- Agv agv = allocateService.execute(task);
- if (null == agv) {
+ String agvNo = allocateService.execute(task, new AllocateSupport() {
+ @Override
+ public void success(Task task, String agvNo) {
+ if (Cools.isEmpty(agvNo)) {
+ return;
+ }
+ task.setAgvId(agvService.getAgvId(agvNo));
+ task.setTaskSts(TaskStsType.WAITING.val());
+ task.setIoTime(now);
+ task.setUpdateTime(now);
+ if (!taskService.updateById(task)) {
+ throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
+ }
+ }
+ });
+ if (Cools.isEmpty(agvNo)) {
// log.warn("Task[{}] has an issue锛� because it failed to check out agv which is idle...", task.getSeqNum());
continue;
}
- task.setAgvId(agv.getId());
+ task.setAgvId(agvService.getAgvId(agvNo));
task.setTaskSts(TaskStsType.WAITING.val());
task.setIoTime(now);
task.setUpdateTime(now);
--
Gitblit v1.9.1