From 9611dc686299be640ce5e5f5990c747765161ec7 Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期三, 21 一月 2026 10:59:38 +0800
Subject: [PATCH] agv逻辑调整2
---
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 100 +++++++++++++++++++++++++++++++++++++++----------
1 files changed, 79 insertions(+), 21 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 5f49418..b86ad49 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -12,6 +12,7 @@
import com.zy.asrs.entity.result.StockVo;
import com.zy.asrs.mapper.TagMapper;
import com.zy.asrs.service.*;
+import com.zy.asrs.task.handler.AgvHandler;
import com.zy.asrs.utils.MatUtils;
import com.zy.common.model.DetlDto;
import com.zy.common.utils.NodeUtils;
@@ -22,6 +23,7 @@
import javax.annotation.Resource;
import java.util.ArrayList;
+import java.util.Collections;
import java.util.Date;
import java.util.List;
@@ -58,6 +60,9 @@
@Resource
private TaskService taskService;
+ @Resource
+ private AgvHandler agvHandler;
+
@Override
@Transactional(rollbackFor = Exception.class)
public R agvCallback(AgvCallbackDto param) {
@@ -74,20 +79,48 @@
param.getKind());
// 鏍规嵁taskId鏌ヨ浠诲姟
+ // taskId鏍煎紡锛歍 + 宸ヤ綔鍙凤紙濡�"T5299"锛夋垨 T + 浠诲姟ID锛堝悜鍚庡吋瀹癸級
Task task = null;
try {
- // 澶勭悊"T"鍓嶇紑鏍煎紡锛堝"T130"锛夛紝杩欐槸AGV浠诲姟鍒涘缓鏃剁殑鏍煎紡
+ // 澶勭悊"T"鍓嶇紑鏍煎紡锛堝"T5299"鎴�"T130"锛�
String numericId = taskId;
if (taskId.startsWith("T") && taskId.length() > 1) {
numericId = taskId.substring(1);
- log.debug("妫�娴嬪埌T鍓嶇紑鏍煎紡鐨則askId锛屾彁鍙栨暟瀛桰D锛歿}", numericId);
+ log.debug("妫�娴嬪埌T鍓嶇紑鏍煎紡鐨則askId锛屾彁鍙栨暟瀛楋細{}", numericId);
}
- // 灏濊瘯灏唗askId瑙ｆ瀽涓篖ong绫诲瀷鐨刬d
- Long taskIdLong = Long.parseLong(numericId);
- task = taskService.selectById(taskIdLong);
- } catch (NumberFormatException e) {
- // 濡傛灉涓嶆槸鏁板瓧锛屽皾璇曢�氳繃鍏朵粬瀛楁鏌ヨ锛堝sheetNo绛夛級
- log.debug("taskId涓嶆槸鏁板瓧鏍煎紡锛屽皾璇曢�氳繃鍏朵粬瀛楁鏌ヨ锛宼askId锛歿}", taskId);
+
+ // 鍏堝皾璇曢�氳繃宸ヤ綔鍙凤紙wrk_no锛夋煡璇紙浼樺厛锛屽洜涓虹幇鍦ㄤ娇鐢ㄥ伐浣滃彿浣滀负taskId锛�
+ try {
+ Integer wrkNo = Integer.parseInt(numericId);
+ task = taskService.selectOne(
+ new EntityWrapper<Task>().eq("wrk_no", wrkNo)
+ );
+ if (task != null) {
+ log.debug("閫氳繃宸ヤ綔鍙凤紙wrk_no={}锛夋壘鍒颁换鍔★紝taskId锛歿}", wrkNo, task.getId());
+ }
+ } catch (NumberFormatException e) {
+ log.debug("鏃犳硶瑙ｆ瀽涓哄伐浣滃彿锛宼askId锛歿}", taskId);
+ }
+
+ // 濡傛灉閫氳繃宸ヤ綔鍙锋病鎵惧埌锛屽皾璇曢�氳繃浠诲姟ID鏌ヨ锛堝悜鍚庡吋瀹癸級
+ if (task == null) {
+ try {
+ Long taskIdLong = Long.parseLong(numericId);
+ task = taskService.selectById(taskIdLong);
+ if (task != null) {
+ log.debug("閫氳繃浠诲姟ID锛坕d={}锛夋壘鍒颁换鍔★紝taskId锛歿}", taskIdLong, taskId);
+ }
+ } catch (NumberFormatException e) {
+ log.debug("鏃犳硶瑙ｆ瀽涓轰换鍔D锛宼askId锛歿}", taskId);
+ }
+ }
+ } catch (Exception e) {
+ log.debug("瑙ｆ瀽taskId寮傚父锛宼askId锛歿}锛屽紓甯革細{}", taskId, e.getMessage());
+ }
+
+ // 濡傛灉杩樻槸娌℃壘鍒帮紝灏濊瘯閫氳繃鍏朵粬瀛楁鏌ヨ锛堝sheetNo绛夛紝鍚戝悗鍏煎锛�
+ if (task == null) {
+ log.debug("閫氳繃宸ヤ綔鍙峰拰浠诲姟ID閮芥病鎵惧埌锛屽皾璇曢�氳繃鍏朵粬瀛楁鏌ヨ锛宼askId锛歿}", taskId);
task = taskService.selectOne(
new EntityWrapper<Task>().eq("sheet_no", taskId)
);
@@ -114,6 +147,9 @@
task.setModiTime(new Date());
+ // 鏍囪浠诲姟鏄惁宸茬粡琚浆绉诲埌鍘嗗彶琛�
+ boolean taskMovedToHistory = false;
+
// 濡傛灉鏈塻tatus瀛楁锛屾寜鍘熸湁閫昏緫澶勭悊锛堝悜鍚庡吋瀹癸級
if (!Cools.isEmpty(param.getStatus())) {
switch (param.getStatus()) {
@@ -128,7 +164,29 @@
}
break;
case "Done":
- task.setWrkSts(9L);
+ // status="Done" 鎵嶇畻鎼繍瀹屾垚锛岀粨鏉熸帀AGV浠诲姟锛堥�傜敤浜庢墍鏈変换鍔＄被鍨嬶細鍏ュ簱銆佸嚭搴撱�佽浆绉伙級
+ if (task.getWrkSts() != null && task.getWrkSts() == 8L) {
+ task.setWrkSts(9L);
+ task.setModiTime(new Date());
+ String taskTypeName = "";
+ if (!Cools.isEmpty(param.getKind())) {
+ taskTypeName = param.getKind();
+ }
+ log.info("AGV鍥炶皟鎼繍瀹屾垚锛坰tatus=Done锛夛紝瀹岀粨AGV鍛煎彨鍗曪紝taskId锛歿}锛屼换鍔＄被鍨嬶細{}", taskId, taskTypeName);
+ // 淇濆瓨浠诲姟鏇存柊鍚庯紝杞Щ鍒板巻鍙茶〃
+ if (taskService.updateById(task)) {
+ try {
+ agvHandler.moveTaskToHistory(Collections.singletonList(task));
+ taskMovedToHistory = true;
+ log.info("AGV鍥炶皟鎼繍瀹屾垚锛屽凡灏嗕换鍔¤浆绉诲埌鍘嗗彶琛紝taskId锛歿}", taskId);
+ } catch (Exception e) {
+ log.error("AGV鍥炶皟鎼繍瀹屾垚锛岃浆绉讳换鍔″埌鍘嗗彶琛ㄥけ璐ワ紝taskId锛歿}", taskId, e);
+ }
+ }
+ } else {
+ log.debug("AGV鍥炶皟status=Done锛屼絾浠诲姟鐘舵�佷笉鏄�8锛堝綋鍓嶇姸鎬侊細{}锛夛紝涓嶇粨鏉熶换鍔★紝taskId锛歿}",
+ task.getWrkSts(), taskId);
+ }
break;
case "Failed":
case "Cancelled":
@@ -137,26 +195,26 @@
}
}
- // 鏍规嵁浠诲姟绫诲瀷杩涜鐩稿簲澶勭悊
+ // 鏍规嵁浠诲姟绫诲瀷杩涜鐩稿簲澶勭悊锛堣褰曟棩蹇楋紝浣嗕笉鍦ㄦ澶勭粨鏉熶换鍔★紝浠诲姟缁撴潫缁熶竴鐢眘tatus="Done"澶勭悊锛�
if (!Cools.isEmpty(param.getKind())) {
String kind = param.getKind();
if ("璐х墿杞繍".equals(kind)) {
- log.info("澶勭悊璐х墿杞繍浠诲姟锛宼askId锛歿}", taskId);
+ log.info("澶勭悊璐х墿杞繍浠诲姟锛宼askId锛歿}锛宻tatus锛歿}", taskId, param.getStatus());
} else if ("瀹炴墭鍏ュ簱".equals(kind) || "绌烘墭鍏ュ簱".equals(kind)) {
- log.info("澶勭悊鍏ュ簱浠诲姟锛宼askId锛歿}", taskId);
- // 鍏ュ簱浠诲姟锛氬鏋滄敹鍒扮‘璁ゅ彇璐у洖璋冿紙loaded=true锛夛紝瀹岀粨AGV鍛煎彨鍗�
- if (Boolean.TRUE.equals(param.getLoaded())) {
- // 濡傛灉浠诲姟鐘舵�佹槸8锛堝凡鍛煎彨AGV锛夛紝鏇存柊涓�9锛堜换鍔″畬鎴愶級
- if (task.getWrkSts() != null && task.getWrkSts() == 8L) {
- task.setWrkSts(9L);
- log.info("鍏ュ簱浠诲姟鏀跺埌纭鍙栬揣鍥炶皟锛屽畬缁揂GV鍛煎彨鍗曪紝taskId锛歿}", taskId);
- }
- }
+ log.info("澶勭悊鍏ュ簱浠诲姟锛宼askId锛歿}锛宻tatus锛歿}", taskId, param.getStatus());
+ // 娉ㄦ剰锛氫换鍔＄粨鏉熺粺涓�鐢� status="Done" 澶勭悊锛屾澶勪笉鍐嶉噸澶嶅鐞�
} else if ("瀹炴墭鍑哄簱".equals(kind)) {
- log.info("澶勭悊瀹炴墭鍑哄簱浠诲姟锛宼askId锛歿}", taskId);
+ log.info("澶勭悊瀹炴墭鍑哄簱浠诲姟锛宼askId锛歿}锛宻tatus锛歿}", taskId, param.getStatus());
+ // 娉ㄦ剰锛氫换鍔＄粨鏉熺粺涓�鐢� status="Done" 澶勭悊锛屾澶勪笉鍐嶉噸澶嶅鐞�
}
}
+ // 濡傛灉浠诲姟宸茬粡琚浆绉诲埌鍘嗗彶琛紝鐩存帴杩斿洖鎴愬姛
+ if (taskMovedToHistory) {
+ log.info("AGV浠诲姟鍥炶皟澶勭悊鎴愬姛锛屼换鍔″凡杞Щ鍒板巻鍙茶〃锛宼askId锛歿}", taskId);
+ return R.ok();
+ }
+
// 淇濆瓨浠诲姟鏇存柊
if (!taskService.updateById(task)) {
log.error("鏇存柊浠诲姟澶辫触锛宼askId锛歿}", taskId);
--
Gitblit v1.9.1