oa调整

zouyu

2025-11-21 ca7685886ae8a4a4bb6717d48a1c48cf3934faf3

 cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java

@@ -71,19 +71,22 @@
            String parse = new String(message.getPayload());
            switch (topic){
                case "/ztt/v3/2455220/publish":
                    //耐丝：直流电阻数据解析
                    mqCallback.collectBridgeService.addBridgeValueByNS(parse);
                    //耐丝：直流电阻数据解析NS-ER02001
                    mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse,"NS-ER02001");
                    break;
//                case "/aiot/8fac9fa0-c517-11f0-954c-255ce11213f1":
//                    //耐丝：直流电阻数据解析NS-ER02002
//                    mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse,"NS-ER02002");
//                    break;
                case "/ztt/v3/2455221/publish":
                    //耐丝：伸长率数据解析
                    mqCallback.collectBridgeService.addBridgeValueByNSD(parse);
//                    log.info("伸长率消息体：{}",parse);
                    //耐丝：伸长率数据解析NS-FM05003
                    mqCallback.collectBridgeService.elongationDataAnalysis(parse,"NS-FM05003");
//                    break;
//                case "/aiot/38568140-c697-11f0-8b13-c14e8310d70b":
//                    //耐丝：伸长率数据解析NS-FM05002
//                    mqCallback.collectBridgeService.elongationDataAnalysis(parse,"NS-FM05002");
                    break;
            }
            // 填充采集数据
//            JSONObject jsonObject = JSONObject.parseObject(parse);
//            mqCallback.collectBridgeService.addBridgeValue(jsonObject);

        } catch (Exception e) {
            e.printStackTrace();
            log.info("============》》接收消息主题异常 : " + e.getMessage());