소스 검색

优化mqtt服务实时巡检事件逻辑,增加channel赋值默认0查询

james 6 일 전
부모
커밋
82c21133fc
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      service-sas/service-sas-biz/src/main/java/com/usky/sas/mqtt/MqttService.java

+ 1 - 1
service-sas/service-sas-biz/src/main/java/com/usky/sas/mqtt/MqttService.java

@@ -800,7 +800,7 @@ public class MqttService {
                 PatrolEventMessage message = mapper.readValue(payload, PatrolEventMessage.class);
 
                 // 1. 检查设备是否存在
-                SasDevice device = findDevice(message.getDeviceId(), message.getChannel(), SystemTypeCodeEnum.patrol.getCode());
+                SasDevice device = findDevice(message.getDeviceId(), 0, SystemTypeCodeEnum.patrol.getCode());
                 if (device == null) {
                     log.warn("设备不存在,丢弃巡检事件: deviceId={}, channel={}", message.getDeviceId(), message.getChannel());
                     return;