From e7261ae10e64dfbd827eef23737fa74309c202e8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B8=B8=E7=86=9F=E5=90=B4=E5=BD=A6=E7=A5=96?= Date: Mon, 26 Jan 2026 15:20:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=84=E7=A7=8D=E5=BC=82=E5=B8=B8=E4=BF=9D?= =?UTF-8?q?=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/KitTransportServiceImpl.java | 3 +++ .../automatedWarehouse/task/AgvTaskScheduler.java | 3 +++ .../automatedWarehouse/task/AutoTaskScheduler.java | 9 ++++++++- .../automatedWarehouse/task/DataArchiveScheduler.java | 1 + .../automatedWarehouse/task/WcsTaskScheduler.java | 5 +++++ 5 files changed, 20 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/service/impl/KitTransportServiceImpl.java b/src/main/java/com/gaotao/modules/automatedWarehouse/service/impl/KitTransportServiceImpl.java index df4d5f9..da928cf 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/service/impl/KitTransportServiceImpl.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/service/impl/KitTransportServiceImpl.java @@ -1,5 +1,6 @@ package com.gaotao.modules.automatedWarehouse.service.impl; +import com.gaotao.common.utils.ErrorLogUtils; import com.gaotao.modules.automatedWarehouse.entity.KitTransportOrderResult; import com.gaotao.modules.automatedWarehouse.mapper.KitTransportMapper; import com.gaotao.modules.automatedWarehouse.service.KitTransportService; @@ -90,6 +91,8 @@ public class KitTransportServiceImpl implements KitTransportService { processedCount++; } catch (Exception e) { + ErrorLogUtils.logException(order.getSite(), "订单齐套", "处理订单齐套",notifyNo+"-"+itemNo, e); + failedCount++; log.error("处理生产订单失败 - rqrq：notifyNo={}, itemNo={}, error={}", notifyNo, itemNo, e.getMessage(), e); diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/task/AgvTaskScheduler.java b/src/main/java/com/gaotao/modules/automatedWarehouse/task/AgvTaskScheduler.java index 08a7134..a6605f7 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/task/AgvTaskScheduler.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/task/AgvTaskScheduler.java @@ -1,5 +1,6 @@ package com.gaotao.modules.automatedWarehouse.task; +import com.gaotao.common.utils.ErrorLogUtils; import com.gaotao.modules.automatedWarehouse.entity.WmsTransportTask; import com.gaotao.modules.automatedWarehouse.entity.WmsTransportTaskDetail; import com.gaotao.modules.automatedWarehouse.service.AgvTaskService; @@ -91,6 +92,7 @@ public class AgvTaskScheduler { log.info("任务下发成功：taskNo={}", task.getTaskNo()); } catch (Exception e) { + ErrorLogUtils.logException(task.getSite(), "立库自动化", "AGV下发任务", task.getTaskNo(), e); log.error("任务下发失败：taskNo={}, error={}", task.getTaskNo(), e.getMessage()); // 继续下发其他任务，不中断整个流程 } @@ -128,6 +130,7 @@ public class AgvTaskScheduler { // 委托给业务服务处理 agvTaskService.processAgvFeedbackTask(taskDetail); } catch (Exception e) { + ErrorLogUtils.logException(taskDetail.getSite(), "立库自动化", "处理AGV回调信息："+taskDetail.getActionType(), taskDetail.getTaskNo(), e); log.error("处理AGV回调数据失败：taskNo={}, error={}", taskDetail.getTaskNo(), e.getMessage()); // 继续处理下一个数据 } diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/task/AutoTaskScheduler.java b/src/main/java/com/gaotao/modules/automatedWarehouse/task/AutoTaskScheduler.java index e00e0eb..b0ef573 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/task/AutoTaskScheduler.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/task/AutoTaskScheduler.java @@ -1,5 +1,6 @@ package com.gaotao.modules.automatedWarehouse.task; +import com.gaotao.common.utils.ErrorLogUtils; import com.gaotao.modules.api.entity.NeedPalletTask; import com.gaotao.modules.automatedWarehouse.entity.AgvStation; import com.gaotao.modules.automatedWarehouse.entity.WcsCallbackTask; @@ -60,6 +61,8 @@ public class AutoTaskScheduler { autoTaskService.processNeedPalletTask(wmsTransportTask); successCount++; } catch (Exception e) { + ErrorLogUtils.logException(wmsTransportTask.getSite(), "立库自动化", "处理获取栈板任务："+wmsTransportTask.getSourceType(), wmsTransportTask.getTaskNo(), e); + log.error("处理预约获取托盘任务失败：TaskNo={}, error={}", wmsTransportTask.getTaskNo(), e.getMessage()); failCount++; // 继续处理下一个数据 @@ -104,6 +107,8 @@ public class AutoTaskScheduler { autoTaskService.processScheduledTransportPalletTask(wmsTransportTask); successCount++; } catch (Exception e) { + ErrorLogUtils.logException(wmsTransportTask.getSite(), "立库自动化", "处理运输栈板任务："+wmsTransportTask.getSourceType(), wmsTransportTask.getTaskNo(), e); + log.error("处理预约运输栈板任务失败 - rqrq：TaskNo={}, error={}", wmsTransportTask.getTaskNo(), e.getMessage(), e); failCount++; @@ -145,6 +150,7 @@ public class AutoTaskScheduler { for (AgvStation station : stations) { + NeedPalletTask needPalletTask=new NeedPalletTask(); try { log.info("开始为站点 {} 自动调用空托盘 - rqrq，站点编码={}, 托盘类型={}, 等待站点={}", station.getStationName(), @@ -153,7 +159,6 @@ public class AutoTaskScheduler { station.getWaitStationCode()); // 构建NeedPalletTask参数 - rqrq - NeedPalletTask needPalletTask = new NeedPalletTask(); needPalletTask.setSite("55"); // 固定站点为55 - rqrq needPalletTask.setStationCode(station.getStationCode()); // 使用wait_station_code作为目标站点 - rqrq needPalletTask.setPalletType(station.getAutoCallBlankPalletType()); // 使用auto_call_blank_pallet_type作为栈板类型 - rqrq @@ -168,6 +173,8 @@ public class AutoTaskScheduler { log.info("站点 {} 自动续盘成功 - rqrq", station.getStationCode()); } catch (Exception e) { + ErrorLogUtils.logException(needPalletTask.getSite(), "立库自动化", "站点自动续盘", needPalletTask.getStationCode(), e); + failCount++; log.error("站点 {} 自动续盘失败 - rqrq：stationCode={}, error={}", station.getStationName(), diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/task/DataArchiveScheduler.java b/src/main/java/com/gaotao/modules/automatedWarehouse/task/DataArchiveScheduler.java index 392427c..6bfa08c 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/task/DataArchiveScheduler.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/task/DataArchiveScheduler.java @@ -1,5 +1,6 @@ package com.gaotao.modules.automatedWarehouse.task; +import com.gaotao.common.utils.ErrorLogUtils; import com.gaotao.modules.automatedWarehouse.service.DataArchiveService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java b/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java index b31f674..effaf66 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java @@ -1,5 +1,6 @@ package com.gaotao.modules.automatedWarehouse.task; +import com.gaotao.common.utils.ErrorLogUtils; import com.gaotao.modules.automatedWarehouse.entity.WcsCallbackTask; import com.gaotao.modules.automatedWarehouse.entity.WmsOrderTask; import com.gaotao.modules.automatedWarehouse.entity.WcsCallbackPalletScan; @@ -82,6 +83,8 @@ public class WcsTaskScheduler { wcsTaskService.processWcsCallbackTask(callbackTask); successCount++; } catch (Exception e) { + ErrorLogUtils.logException(callbackTask.getSite(), "立库自动化", "处理WCS回调："+callbackTask.getTransTypeDesc(), callbackTask.getPalletId(), e); + log.error("处理WCS回调任务失败：palletId={}, error={}", callbackTask.getPalletId(), e.getMessage()); failCount++; // 继续处理下一个数据 @@ -170,6 +173,8 @@ public class WcsTaskScheduler { } successCount++; } catch (Exception e) { + ErrorLogUtils.logException(callback.getSite(), "立库自动化", "处理WCS栈板分拣："+callback.getActionType(), callback.getPalletId(), e); + log.error("处理WCS栈板分拣失败 - rqrq：palletId={}, error={}", callback.getPalletId(), e.getMessage()); failCount++;