From 3a6155c8c3464152e0bc6267059a045c0d102c49 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 15 十二月 2025 08:55:56 +0800
Subject: [PATCH] 1
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 90 +++++++++++++++++++++++++++++----------------
1 files changed, 58 insertions(+), 32 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 1a2bf2a..edcc01f 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
@@ -780,6 +780,7 @@
continue;
}
+
String next = pathListPart.get(i);
Code nextCode = codeService.getCacheByData(next);
@@ -853,6 +854,23 @@
lastDirection = nextDirection;
}
+
+ actionList.add(new Action(
+ null, // 缂栧彿
+ task.getBusId(), // 鎬荤嚎
+ task.getId(), // 浠诲姟
+ null, // 鍔ㄤ綔鍙�
+ null, // 浼樺厛绾�
+ ActionTypeType.RunToWaitHeight.desc, // 鍚嶇О
+ 1D, // 灞炴�ш皰
+ lastCode.getData(), // 鍦伴潰鐮�
+ "350", // 鍔ㄤ綔鍙傛暟
+ ActionTypeType.RunToWaitHeight.val(), // 鍔ㄤ綔绫诲瀷
+ actionPrepareSts, // 鍔ㄤ綔杩涘害
+ agvId, // AGV
+ now // 宸ヤ綔鏃堕棿
+ ));
+
// run
ActionTypeType actionType = ActionTypeType.StraightAheadTurnable;
@@ -1502,11 +1520,11 @@
// }
// }
- List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
- for (Long taskId : taskIds) {
- Task task = taskService.getById(taskId);
- report(task, agv_11_up.getQrCode(), TaskReportStsType.END);
- }
+// List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
+// for (Long taskId : taskIds) {
+// Task task = taskService.getById(taskId);
+// report(task, agv_11_up.getQrCode(), TaskReportStsType.END);
+// }
}
// 鍑哄簱鍙栬揣
@@ -1540,31 +1558,31 @@
// }
// }
// }
- List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
- for (Long taskId : taskIds) {
- Task task = taskService.getById(taskId);
- report(task, agv_11_up.getQrCode(), TaskReportStsType.OTBIN);
- }
+// List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
+// for (Long taskId : taskIds) {
+// Task task = taskService.getById(taskId);
+// report(task, agv_11_up.getQrCode(), TaskReportStsType.OTBIN);
+// }
}
//浠庤緭閫佺嚎鍙栬揣瀹屾垚
- if (agv_11_up.getCompleteType().equals(AgvCompleteType.TAKE_FROM_STA_COMPLETE)) {
- WebsocketServiceImpl.taskShelfBarcode = agv_11_up.getLocCode();
- List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
- for (Long taskId : taskIds) {
- Task task = taskService.getById(taskId);
- report(task, agv_11_up.getQrCode(), TaskReportStsType.OTBIN);
- }
- }
+// if (agv_11_up.getCompleteType().equals(AgvCompleteType.TAKE_FROM_STA_COMPLETE)) {
+// WebsocketServiceImpl.taskShelfBarcode = agv_11_up.getLocCode();
+// List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
+// for (Long taskId : taskIds) {
+// Task task = taskService.getById(taskId);
+// report(task, agv_11_up.getQrCode(), TaskReportStsType.OTBIN);
+// }
+// }
//寰�杈撻�佺嚎鏀捐揣瀹屾垚
- if (agv_11_up.getCompleteType().equals(AgvCompleteType.RELEASE_FROM_STA_COMPLETE)) {
- WebsocketServiceImpl.taskShelfBarcode = agv_11_up.getLocCode();
- List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
- for (Long taskId : taskIds) {
- Task task = taskService.getById(taskId);
- report(task, agv_11_up.getQrCode(), TaskReportStsType.END);
- }
- }
+// if (agv_11_up.getCompleteType().equals(AgvCompleteType.RELEASE_FROM_STA_COMPLETE)) {
+// WebsocketServiceImpl.taskShelfBarcode = agv_11_up.getLocCode();
+// List<Long> taskIds = actionService.selectTaskIdsByGroupId(serialNo);
+// for (Long taskId : taskIds) {
+// Task task = taskService.getById(taskId);
+// report(task, agv_11_up.getQrCode(), TaskReportStsType.END);
+// }
+// }
// 璺緞瀹屾垚 || 鍏呯數瀹屾垚
if (agv_11_up.getCompleteType().equals(AgvCompleteType.ENTIRE_PATH_COMPLETE)
@@ -1604,6 +1622,8 @@
// task
for (Segment segment : segmentList) {
boolean taskComplete = false;
+ boolean otbin = false;
+
Task task = taskService.getById(segment.getTaskId());
assert null != task;
@@ -1614,6 +1634,7 @@
switch (Objects.requireNonNull(posType)) {
case ORI_STA:
case ORI_LOC:
+ otbin = true;
break;
case DEST_STA:
case DEST_LOC:
@@ -1634,19 +1655,24 @@
break;
}
+ if (otbin) {
+ locService.taskCallBackOtbin(task);
+ report(task, null, TaskReportStsType.OTBIN);
+ }
+
+
if (taskComplete) {
- locService.taskCallBack(task);
+ locService.taskCallBackEnd(task);
task.setTaskSts(TaskStsType.COMPLETE.val());
task.setEndTime(now);
task.setUpdateTime(now);
if (!taskService.updateById(task)) {
log.error("Task [{}] 鏇存柊澶辫触 锛侊紒锛�", task.getSeqNum());
- } else {
- report(task, null, TaskReportStsType.END);
- if (task.getSeqNum() != null && task.getSeqNum().contains("SSX-CK")) {
- report(task, "1001", TaskReportStsType.COMPLETED);
- }
+ }
+ report(task, null, TaskReportStsType.END);
+ if (task.getSeqNum() != null && task.getSeqNum().contains("SSX-CK")) {
+ report(task, "1001", TaskReportStsType.COMPLETED);
}
}
}
--
Gitblit v1.9.1