From 9d2bbabf1cd902bb26b0aec1ace5da87b5c926b1 Mon Sep 17 00:00:00 2001 From: lzh Date: Thu, 29 Jan 2026 22:17:03 +0800 Subject: [PATCH] =?UTF-8?q?feat(ops):=20=E6=B7=BB=E5=8A=A0=E4=BA=8B?= =?UTF-8?q?=E4=BB=B6=E5=8F=91=E5=B8=83=E5=92=8C=E8=AE=BE=E5=A4=87=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E7=9B=91=E5=90=AC=E5=99=A8=E6=97=A5=E5=BF=97=E4=BE=BF?= =?UTF-8?q?=E4=BA=8E=E6=8E=92=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. OrderEventPublisherImpl 状态变更事件发布日志改为 info 级别 2. BadgeDeviceStatusEventListener 状态变更日志改为 info 级别 3. 优化日志格式，输出 orderType 便于排查事件接收问题 Co-Authored-By: Claude (MiniMax-M2.1) --- .../listener/BadgeDeviceStatusEventListener.java | 7 ++++--- .../service/badge/BadgeDeviceStatusServiceImpl.java | 2 +- .../module/ops/core/event/OrderEventPublisherImpl.java | 4 ++-- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/listener/BadgeDeviceStatusEventListener.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/listener/BadgeDeviceStatusEventListener.java index 1d2bce4..753bfe8 100644 --- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/listener/BadgeDeviceStatusEventListener.java +++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/listener/BadgeDeviceStatusEventListener.java @@ -71,19 +71,20 @@ public class BadgeDeviceStatusEventListener { WorkOrderStatusEnum newStatus = event.getNewStatus(); Long orderId = event.getOrderId(); - log.debug("[BadgeDeviceStatusEventListener] 状态变更: orderId={}, status={}", orderId, newStatus); + log.info("[BadgeDeviceStatusEventListener] 状态变更: orderId={}, status={}, orderType={}", + orderId, newStatus, event.getOrderType()); // 查询工单获取设备ID OpsOrderDO order = opsOrderMapper.selectById(orderId); if (order == null) { - log.debug("[BadgeDeviceStatusEventListener] 工单不存在，跳过处理: orderId={}", orderId); + log.warn("[BadgeDeviceStatusEventListener] 工单不存在，跳过处理: orderId={}", orderId); return; } // assigneeId 存储的是工牌设备ID Long deviceId = order.getAssigneeId(); if (deviceId == null) { - log.debug("[BadgeDeviceStatusEventListener] 工单未关联设备，跳过处理: orderId={}", orderId); + log.warn("[BadgeDeviceStatusEventListener] 工单未关联设备，跳过处理: orderId={}", orderId); return; } diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/badge/BadgeDeviceStatusServiceImpl.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/badge/BadgeDeviceStatusServiceImpl.java index 70b6096..3af4fcf 100644 --- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/badge/BadgeDeviceStatusServiceImpl.java +++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/badge/BadgeDeviceStatusServiceImpl.java @@ -264,7 +264,7 @@ public class BadgeDeviceStatusServiceImpl implements BadgeDeviceStatusService, I if (areaId != null) { statusMap.put("currentAreaId", areaId); // 同时更新区域设备索引缓存 - addToAreaIndex(deviceId, areaId); +// addToAreaIndex(deviceId, areaId); } else { // 保持现有实时物理区域信息 Object existingAreaId = currentMap.get("currentAreaId"); diff --git a/viewsh-module-ops/viewsh-module-ops-biz/src/main/java/com/viewsh/module/ops/core/event/OrderEventPublisherImpl.java b/viewsh-module-ops/viewsh-module-ops-biz/src/main/java/com/viewsh/module/ops/core/event/OrderEventPublisherImpl.java index eac8a90..09247c1 100644 --- a/viewsh-module-ops/viewsh-module-ops-biz/src/main/java/com/viewsh/module/ops/core/event/OrderEventPublisherImpl.java +++ b/viewsh-module-ops/viewsh-module-ops-biz/src/main/java/com/viewsh/module/ops/core/event/OrderEventPublisherImpl.java @@ -39,8 +39,8 @@ public class OrderEventPublisherImpl implements OrderEventPublisher { public void publishStateChanged(OrderStateChangedEvent event) { try { applicationEventPublisher.publishEvent(event); - log.debug("状态变更事件已发布: orderId={}, {} -> {}", - event.getOrderId(), event.getOldStatus(), event.getNewStatus()); + log.info("状态变更事件已发布: orderId={}, {} -> {}, orderType={}", + event.getOrderId(), event.getOldStatus(), event.getNewStatus(), event.getOrderType()); } catch (Exception e) { // 事件发布失败不应影响主流程 log.error("发布状态变更事件失败: orderId={}", event.getOrderId(), e);