From 30c64524c2253a397cc787c1daeae9b491259240 Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期三, 31 十二月 2025 15:17:17 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 91 ++++++++++++++++++++++++++++++++++++++-------
1 files changed, 77 insertions(+), 14 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 33d4e20..849bdcd 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
@@ -2,6 +2,7 @@
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.zy.acs.common.constant.RedisConstant;
import com.zy.acs.common.domain.AgvAction;
import com.zy.acs.common.domain.AgvActionItem;
@@ -267,9 +268,53 @@
);
// load segment
Segment currSeg = segmentService.getRollerWaiting(agvId, sta.getCode(), TaskPosDto.PosType.ORI_STA);
+ currSeg.setState(SegmentStateType.INIT.toString());
+ currSeg.setUpdateTime(now);
+ if (!segmentService.updateById(currSeg)) {
+ log.error("Segment [{}] failed to update 锛侊紒锛�", currSeg.getGroupId() + " - " + currSeg.getSerial());
+ }
+
+ // new oriSta seg
+ Segment loadSeg = new Segment();
+ loadSeg.setUuid(String.valueOf(snowflakeIdWorker.nextId()).substring(3));
+ loadSeg.setTravelId(currSeg.getTravelId());
+ loadSeg.setAgvId(agvId);
+ loadSeg.setTaskId(task.getId());
+ loadSeg.setSerial(currSeg.getSerial() - 1);
+ loadSeg.setEndNode(sta.getCode());
+ loadSeg.setPosType(TaskPosDto.PosType.ORI_STA.toString());
+ loadSeg.setState(SegmentStateType.WAITING.toString());
+ if (!segmentService.save(loadSeg)) {
+ log.error("Segment [{}] failed to save 锛侊紒锛�", loadSeg.getTravelId() + " - " + loadSeg.getSerial());
+ }
// place segment
+ TaskTypeType taskType = Objects.requireNonNull(TaskTypeType.get(task.getTaskTypeEl()));
+ TaskPosDto.PosType posType = null;
+ switch (taskType) {
+ case STA_TO_LOC:
+ posType = TaskPosDto.PosType.DEST_LOC;
+ break;
+ case STA_TO_STA:
+ posType = TaskPosDto.PosType.DEST_STA;
+ break;
+ default:
+ throw new BusinessException("[Agv: " + agvNo + "]allocate inbound failed to find travel");
+ }
+
+ Segment placeSeg = new Segment();
+ placeSeg.setUuid(String.valueOf(snowflakeIdWorker.nextId()).substring(3));
+ placeSeg.setTravelId(currSeg.getTravelId());
+ placeSeg.setAgvId(agvId);
+ placeSeg.setTaskId(task.getId());
+ placeSeg.setSerial(currSeg.getSerial() - 1);
+ placeSeg.setEndNode(sta.getCode());
+ placeSeg.setPosType(posType.toString());
+ placeSeg.setState(SegmentStateType.INIT.toString());
+ if (!segmentService.save(placeSeg)) {
+ log.error("Segment [{}] failed to save 锛侊紒锛�", placeSeg.getTravelId() + " - " + placeSeg.getSerial());
+ }
task.setAgvId(agvId);
task.setTaskSts(TaskStsType.ASSIGN.val());
@@ -1208,6 +1253,38 @@
List<Action> newActionList = actionSorter.optimizeSort(actionList);
String groupId = String.valueOf(snowflakeIdWorker.nextId()).substring(3);
+ // update segment
+ for (Segment item : segmentList) {
+ LambdaUpdateWrapper<Segment> uw = new LambdaUpdateWrapper<Segment>()
+ .eq(Segment::getId, item.getId())
+ .eq(Segment::getState, item.getState())
+ .set(Segment::getGroupId, groupId)
+ .set(Segment::getState, SegmentStateType.RUNNING.toString())
+ .set(Segment::getStartTime, now)
+ .set(Segment::getUpdateTime, now);
+ if (algoStartTime != null) {
+ uw.set(Segment::getAlgoTime, (int) (now.getTime() - algoStartTime.getTime()));
+ }
+ if (!segmentService.update(uw)) {
+ // segment 鍘熷瓙鎬т繚璇�
+ throw new CoolException("鏇存柊Segment澶辫触: segmentId=" + item.getId() + " state not WAITING");
+ }
+ }
+
+ // update segment
+// for (Segment item : segmentList) {
+// item.setGroupId(groupId);
+// item.setState(SegmentStateType.RUNNING.toString());
+// item.setStartTime(now);
+// item.setUpdateTime(now);
+// if (null != algoStartTime) {
+// item.setAlgoTime((int) (now.getTime() - algoStartTime.getTime()));
+// }
+// if (!segmentService.updateById(item)) {
+// throw new CoolException("鏇存柊Segment澶辫触");
+// }
+// }
+
// save action
int i = newActionList.size();
for (Action action : newActionList) {
@@ -1218,20 +1295,6 @@
}
if (!actionService.saveBatch(newActionList)) {
throw new BusinessException("group[" + groupId + "] 鍔ㄤ綔淇濆瓨澶辫触");
- }
-
- // update segment
- for (Segment item : segmentList) {
- item.setGroupId(groupId);
- item.setState(SegmentStateType.RUNNING.toString());
- item.setStartTime(now);
- item.setUpdateTime(now);
- if (null != algoStartTime) {
- item.setAlgoTime((int) (now.getTime() - algoStartTime.getTime()));
- }
- if (!segmentService.updateById(item)) {
- throw new CoolException("鏇存柊Segment澶辫触");
- }
}
log.info("{}鍙稟gv鍔ㄤ綔缁勮瀹屾垚锛屾寚浠ゆ暟閲忥細{}", agvNo, newActionList.size());
--
Gitblit v1.9.1