From b38dda81d26f119dd5d7c53ab07a792751da4a56 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 29 十月 2024 14:39:34 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 76 ++++++++++++++++++++++++-------------
1 files changed, 49 insertions(+), 27 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..1e752b6 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
@@ -67,6 +67,8 @@
@Autowired
private ValidService validService;
@Autowired
+ private AllocateService allocateService;
+ @Autowired
private CodeService codeService;
@Autowired
private MapService mapService;
@@ -88,8 +90,7 @@
private TrafficService trafficService;
@Autowired
private AgvModelService agvModelService;
- @Autowired
- private MissionAssignService missionAssignService;
+
@SuppressWarnings("all")
@Transactional
@@ -194,7 +195,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>()
@@ -211,17 +212,14 @@
}
return;
}
- List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
- Map<String, List<Long>> taskAllot = new HashMap<>();
+ List<Long> taskIds = taskList.stream().map(Task::getId).distinct().collect(Collectors.toList());
for (Task task : taskList) {
- Agv agv = missionAssignService.execute(task, taskAllot, taskIds);
+ Agv agv = allocateService.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);
@@ -229,17 +227,35 @@
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()));
- }
}
-// bus.setUpdateTime(now);
-// if (!busService.updateById(bus)) {
-// throw new BusinessException(bus.getSeqNum() + "鎬荤嚎鏇存柊澶辫触");
+
+ // ------------------------------------------
+
+
+//
+// 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);
@@ -261,7 +277,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))) {
@@ -274,7 +290,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);
@@ -483,16 +499,22 @@
switch (taskType) {
case TO_CHARGE:
case TO_STANDBY:
- List<FuncSta> funcStaList = funcStaService.list(new LambdaQueryWrapper<FuncSta>()
- .eq(FuncSta::getType, FuncStaType.query(taskType).toString())
- .eq(FuncSta::getAgvId, agv.getId())
- .eq(FuncSta::getState, FuncStaStateType.IDLE.toString())
- .eq(FuncSta::getStatus, StatusType.ENABLE.val)
- );
- if (!Cools.isEmpty(funcStaList)) {
- FuncSta funcSta = funcStaList.get(0);
+ List<FuncSta> idleFunStaList = funcStaService.findInIdleStatus(FuncStaType.query(taskType), agv.getId());
+ if (!Cools.isEmpty(idleFunStaList)) {
+ FuncSta funcSta = funcStaService.checkoutClosestFunSta(agvDetail.getRecentCode(), idleFunStaList);
endCode = codeService.getById(funcSta.getCode());
}
+
+// List<FuncSta> funcStaList = funcStaService.list(new LambdaQueryWrapper<FuncSta>()
+// .eq(FuncSta::getType, FuncStaType.query(taskType).toString())
+// .eq(FuncSta::getAgvId, agv.getId())
+// .eq(FuncSta::getState, FuncStaStateType.IDLE.toString())
+// .eq(FuncSta::getStatus, StatusType.ENABLE.val)
+// );
+// if (!Cools.isEmpty(funcStaList)) {
+// FuncSta funcSta = funcStaList.get(0);
+// endCode = codeService.getById(funcSta.getCode());
+// }
break;
case MOVE:
endCode = codeService.selectByData(destination);
--
Gitblit v1.9.1