src/main/java/com/zhitan/handler/MqttMessageHandler.java
@@ -1,13 +1,19 @@
package com.zhitan.handler;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.zhitan.model.entity.DeviceData;
import com.zhitan.model.entity.ElectricPower;
import com.zhitan.model.entity.PowerEntity;
import com.zhitan.service.IDataService;
import com.zhitan.util.PowerDataMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;
import java.util.ArrayList;
import java.util.List;
/**
 * mqtt 消息处理类
@@ -31,8 +37,13 @@
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            // 将 JSON 字符串转换为 SensorData 对象
            ElectricPower electricPower = objectMapper.readValue(payload, ElectricPower.class);
            dataService.writeTimeSeriesData(electricPower);
            //ElectricPower electricPower = objectMapper.readValue(payload, ElectricPower.class);
            DeviceData data = objectMapper.readValue(payload, DeviceData.class);
            List<PowerEntity> powerMeters = PowerDataMapper.mapToEntities(data);
            for (PowerEntity powerMeter : powerMeters) {
                dataService.writeTimeSeriesData(powerMeter);
            }
            // dataService.writeTimeSeriesData(electricPower)
        } catch (Exception e) {
            log.error(e.getMessage());
        }