From 500f6ce071c0bc14d6720354ce148599ac3f35ee Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期五, 25 十月 2024 15:38:42 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 53 +++++++++++++++++++++++++++--------------------------
1 files changed, 27 insertions(+), 26 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 9b3a1d8..8da6ca8 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
@@ -194,7 +194,7 @@
* 浠诲姟鍒嗛厤缁欒溅杈� ( 杞﹁締姝ゆ椂鏄┖闂蹭笖闈欐鐨� )
*/
@Transactional
- public synchronized void infuseAgvForTask(Bus bus) {
+ public synchronized void allocateTask(Bus bus) {
try {
Date now = new Date();
List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>()
@@ -212,6 +212,7 @@
return;
}
+ List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
for (Task task : taskList) {
Agv agv = missionAssignService.execute(task);
if (null == agv) {
@@ -230,31 +231,31 @@
// ------------------------------------------
- List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
- Map<String, List<Long>> taskAllot = new HashMap<>();
- for (Task task : taskList) {
- Agv agv = missionAssignService.execute(task, taskAllot, taskIds);
- 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");
- }
-
- if (taskAllot.containsKey(agv.getUuid())) {
- taskAllot.get(agv.getUuid()).add(task.getId());
- } else {
- taskAllot.put(agv.getUuid(), Utils.singletonList(task.getId()));
- }
- }
+//
+// Map<String, List<Long>> taskAllot = new HashMap<>();
+// for (Task task : taskList) {
+// Agv agv = missionAssignService.execute(task, taskAllot, taskIds);
+// 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");
+// }
+//
+// if (taskAllot.containsKey(agv.getUuid())) {
+// taskAllot.get(agv.getUuid()).add(task.getId());
+// } else {
+// taskAllot.put(agv.getUuid(), Utils.singletonList(task.getId()));
+// }
+// }
} catch (Exception e) {
log.error("mainService.infuseAgvForTask", e);
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -275,7 +276,7 @@
// valid -----------------------------------------------
Agv agv = agvService.getById(agvId);
- if (!agvService.judgeEnable(agv.getId(), agvDetail -> agvDetail.getVol() > agv.getChargeLine())) {
+ if (!agvService.judgeEnable(agv.getId(), true)) {
throw new CoolException("AGV[" + agv.getUuid() + "]褰撳墠涓嶅彲鐢�...");
}
if (!Cools.isEmpty(taskService.selectInSts(agvId, TaskStsType.ASSIGN, TaskStsType.PROGRESS))) {
--
Gitblit v1.9.1