XW-AIOT/aiot-platform-cloud
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(ops): 添加事件发布和设备状态监听器日志便于排查
Some checks failed
Java CI with Maven / build (11) (push) Has been cancelled
Details
Java CI with Maven / build (17) (push) Has been cancelled
Details
Java CI with Maven / build (8) (push) Has been cancelled
Details

Browse Source 
1. OrderEventPublisherImpl 状态变更事件发布日志改为 info 级别
2. BadgeDeviceStatusEventListener 状态变更日志改为 info 级别
3. 优化日志格式，输出 orderType 便于排查事件接收问题

Co-Authored-By: Claude (MiniMax-M2.1) <noreply@anthropic.com>
This commit is contained in:
lzh
2026-01-29 22:17:03 +08:00
parent 20ea25cf55
commit 9d2bbabf1c
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/listener/BadgeDeviceStatusEventListener.java
View File

@@ -71,19 +71,20 @@ public class BadgeDeviceStatusEventListener {
WorkOrderStatusEnum newStatus = event.getNewStatus(); WorkOrderStatusEnum newStatus = event.getNewStatus();
Long orderId = event.getOrderId(); Long orderId = event.getOrderId();
log.debug("[BadgeDeviceStatusEventListener] 状态变更: orderId={}, status={}", orderId, newStatus); log.info("[BadgeDeviceStatusEventListener] 状态变更: orderId={}, status={}, orderType={}",
orderId, newStatus, event.getOrderType());
// 查询工单获取设备ID // 查询工单获取设备ID
OpsOrderDO order = opsOrderMapper.selectById(orderId); OpsOrderDO order = opsOrderMapper.selectById(orderId);
if (order == null) { if (order == null) {
log.debug("[BadgeDeviceStatusEventListener] 工单不存在，跳过处理: orderId={}", orderId); log.warn("[BadgeDeviceStatusEventListener] 工单不存在，跳过处理: orderId={}", orderId);
return; return;
} }
// assigneeId 存储的是工牌设备ID // assigneeId 存储的是工牌设备ID
Long deviceId = order.getAssigneeId(); Long deviceId = order.getAssigneeId();
if (deviceId == null) { if (deviceId == null) {
log.debug("[BadgeDeviceStatusEventListener] 工单未关联设备，跳过处理: orderId={}", orderId); log.warn("[BadgeDeviceStatusEventListener] 工单未关联设备，跳过处理: orderId={}", orderId);
return; return;
} }

2
viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/service/badge/BadgeDeviceStatusServiceImpl.java
View File

@@ -264,7 +264,7 @@ public class BadgeDeviceStatusServiceImpl implements BadgeDeviceStatusService, I
if (areaId != null) { if (areaId != null) {
statusMap.put("currentAreaId", areaId); statusMap.put("currentAreaId", areaId);
// 同时更新区域设备索引缓存 // 同时更新区域设备索引缓存
addToAreaIndex(deviceId, areaId); // addToAreaIndex(deviceId, areaId);
} else { } else {
// 保持现有实时物理区域信息 // 保持现有实时物理区域信息
Object existingAreaId = currentMap.get("currentAreaId"); Object existingAreaId = currentMap.get("currentAreaId");

4
viewsh-module-ops/viewsh-module-ops-biz/src/main/java/com/viewsh/module/ops/core/event/OrderEventPublisherImpl.java
View File

@@ -39,8 +39,8 @@ public class OrderEventPublisherImpl implements OrderEventPublisher {
public void publishStateChanged(OrderStateChangedEvent event) { public void publishStateChanged(OrderStateChangedEvent event) {
try { try {
applicationEventPublisher.publishEvent(event); applicationEventPublisher.publishEvent(event);
log.debug("状态变更事件已发布: orderId={}, {} -> {}", log.info("状态变更事件已发布: orderId={}, {} -> {}, orderType={}",
event.getOrderId(), event.getOldStatus(), event.getNewStatus()); event.getOrderId(), event.getOldStatus(), event.getNewStatus(), event.getOrderType());
} catch (Exception e) { } catch (Exception e) {
// 事件发布失败不应影响主流程 // 事件发布失败不应影响主流程
log.error("发布状态变更事件失败: orderId={}", event.getOrderId(), e); log.error("发布状态变更事件失败: orderId={}", event.getOrderId(), e);