From fff2e8aa532540036088744c76efe5bffc7733a3 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期五, 25 十月 2024 15:24:00 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 26 ++++++++++++++++++++------
1 files changed, 20 insertions(+), 6 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 763aee2..9b3a1d8 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
@@ -211,6 +211,25 @@
}
return;
}
+
+ for (Task task : taskList) {
+ Agv agv = missionAssignService.execute(task);
+ if (null == agv) {
+ log.warn("Task[{}] has an issue锛� because it failed to checkout agv which is idle...", task.getSeqNum());
+ continue;
+ }
+ task.setAgvId(agv.getId());
+ task.setTaskSts(TaskStsType.WAITING.val());
+ task.setIoTime(now);
+ task.setUpdateTime(now);
+ if (!taskService.updateById(task)) {
+ throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update");
+ }
+ }
+
+
+ // ------------------------------------------
+
List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
Map<String, List<Long>> taskAllot = new HashMap<>();
@@ -236,11 +255,6 @@
taskAllot.put(agv.getUuid(), Utils.singletonList(task.getId()));
}
}
-
-// bus.setUpdateTime(now);
-// if (!busService.updateById(bus)) {
-// throw new BusinessException(bus.getSeqNum() + "鎬荤嚎鏇存柊澶辫触");
-// }
} catch (Exception e) {
log.error("mainService.infuseAgvForTask", e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -274,7 +288,7 @@
taskList.sort(new Comparator<Task>() {
@Override
public int compare(Task o1, Task o2) {
- return 0;
+ return o1.getPriority() - o2.getPriority();
}
});
Integer backpack = agvService.getBackpack(agv);
--
Gitblit v1.9.1