| | |
| | | switch (topic){ |
| | | case "/ztt/v3/2455220/publish": |
| | | //耐丝:直流电阻数据解析 |
| | | mqCallback.collectBridgeService.addBridgeValueByNS(parse); |
| | | mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse); |
| | | break; |
| | | case "/ztt/v3/2455221/publish": |
| | | //耐丝:伸长率数据解析 |
| | | mqCallback.collectBridgeService.addBridgeValueByNSD(parse); |
| | | // log.info("伸长率消息体:{}",parse); |
| | | mqCallback.collectBridgeService.elongationDataAnalysis(parse); |
| | | break; |
| | | } |
| | | // 填充采集数据 |
| | | // JSONObject jsonObject = JSONObject.parseObject(parse); |
| | | // mqCallback.collectBridgeService.addBridgeValue(jsonObject); |
| | | |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.info("============》》接收消息主题异常 : " + e.getMessage()); |