直流电阻：解析mqtt订阅的数据保存到redis

zouyu

3 天以前 b02ace7aa9a5e046d533cf80afa8ec14c40fe133

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

@@ -1,9 +1,15 @@
package com.ruoyi.device.mqtt;

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.ruoyi.device.constant.DCResistanceMqttConstants;
import com.ruoyi.device.service.CollectBridgeService;
import com.ruoyi.device.vo.DCResistanceMqttVO;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
@@ -11,6 +17,9 @@

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import java.util.Objects;

@Component
@Slf4j
@@ -71,9 +80,11 @@
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        try {
            String parse = new String(message.getPayload());
            JSONObject jsonObject = JSONObject.parseObject(parse);
//            JSONObject jsonObject = JSONObject.parseObject(parse);
            // 填充采集数据
            mqCallback.collectBridgeService.addBridgeValue(jsonObject);
//            mqCallback.collectBridgeService.addBridgeValue(jsonObject);
            //耐丝：直流电阻数据解析
            mqCallback.collectBridgeService.addBridgeValueByNS(parse);

        } catch (Exception e) {
            e.printStackTrace();