fix(mqtt): 解决设备在线状态检查和数据处理逻辑问题

- 注释掉MQTT客户端在线状态检查逻辑以避免设备访问阻塞
- 修复日志消息中APF模块信息显示错误的问题
- 添加PQ-COM设备特殊处理逻辑以正确查询设备注册信息
- 优化实时数据服务中的设备注册查询条件判断

iot-analysis/analysis-rt/rt-boot/src/main/java/com/njcn/rt/service/impl/RtServiceImpl.java

@@ -148,7 +148,13 @@ public class RtServiceImpl implements IRtService {
         List<CsDataArray> dataArrayList;
         //监测点id
         String lineId;
-        CsDeviceRegistry csDeviceRegistry = csDeviceRegistryFeignClient.queryByCurrentNdidAndClDid(appAutoDataMessage.getId(),appAutoDataMessage.getMsg().getClDid()).getData();
+        CsDeviceRegistry csDeviceRegistry;
+        //PQ-COM
+        if (appAutoDataMessage.getDid() == 1) {
+            csDeviceRegistry = csDeviceRegistryFeignClient.queryByCurrentNdidAndClDid(appAutoDataMessage.getId(),0).getData();
+        } else {
+            csDeviceRegistry = csDeviceRegistryFeignClient.queryByCurrentNdidAndClDid(appAutoDataMessage.getId(),appAutoDataMessage.getMsg().getClDid()).getData();
+        }
         if (Objects.isNull(csDeviceRegistry)) {
             if (appAutoDataMessage.getDid() == 1){
                 lineId = appAutoDataMessage.getId() + "0";