zouyu
9 小时以前 c17a0d27b6a2e9e0ebda4ee584b6b2fdf4e323ca
cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java
@@ -71,19 +71,14 @@
            String parse = new String(message.getPayload());
            switch (topic){
                case "/ztt/v3/2455220/publish":
                    //耐丝:直流电阻数据解析
                    mqCallback.collectBridgeService.addBridgeValueByNS(parse);
                    //耐丝:直流电阻数据解析NS-ER02001
                    mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse);
                    break;
                case "/ztt/v3/2455221/publish":
                    //耐丝:伸长率数据解析
                    mqCallback.collectBridgeService.addBridgeValueByNSD(parse);
//                    log.info("伸长率消息体:{}",parse);
                    //耐丝:伸长率数据解析NS-FM05003
                    mqCallback.collectBridgeService.elongationDataAnalysis(parse);
                    break;
            }
            // 填充采集数据
//            JSONObject jsonObject = JSONObject.parseObject(parse);
//            mqCallback.collectBridgeService.addBridgeValue(jsonObject);
        } catch (Exception e) {
            e.printStackTrace();
            log.info("============》》接收消息主题异常 : " + e.getMessage());