feat(mqtt): 增加对空调设备数据的处理

baoshiwei

2025-06-19 be00ddc83f86599916eb8d0f581f448aa74c9d51

 src/main/java/com/zhitan/handler/MqttMessageHandler.java

@@ -1,10 +1,13 @@
package com.zhitan.handler;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.zhitan.config.mqtt.MqttTopic;
import com.zhitan.model.entity.DeviceData;
import com.zhitan.model.entity.ElectricPower;
import com.zhitan.model.entity.KtDataEntity;
import com.zhitan.model.entity.PowerEntity;
import com.zhitan.service.IDataService;
import com.zhitan.util.KtDataMapper;
import com.zhitan.util.PowerDataMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.integration.mqtt.support.MqttHeaders;
@@ -31,14 +34,44 @@
        String topic = (String) message.getHeaders().get(MqttHeaders.RECEIVED_TOPIC);
        String payload = (String) message.getPayload();
        System.out.println("Received message from topic " + topic + ": " + payload);

//        dataService.writeTimeSeriesData(payload);
//
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            // 将 JSON 字符串转换为 SensorData 对象
            //ElectricPower electricPower = objectMapper.readValue(payload, ElectricPower.class);
            DeviceData data = objectMapper.readValue(payload, DeviceData.class);
            if (topic != null) {
                switch ( topic) {
                    case MqttTopic.DEFAULT_TOPIC:
                        handleDeviceUpMessage(data);
                        break;
                    case MqttTopic.DEVICE_KT_UP:
                        handleDeviceKtUpMessage(data);
                        break;
                    default:
                        log.error("Invalid topic: " + topic);
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage());
        }



    }

    private void handleDeviceKtUpMessage(DeviceData data) {
        try {
            KtDataEntity ktDataEntity = KtDataMapper.mapToEntity(data);
            dataService.writeTimeSeriesData(ktDataEntity);
            // dataService.writeTimeSeriesData(electricPower)
        } catch (Exception e) {
            log.error(e.getMessage());
        }

    }

    private void handleDeviceUpMessage(DeviceData data) {
        try {
            List<PowerEntity> powerMeters = PowerDataMapper.mapToEntities(data);
            for (PowerEntity powerMeter : powerMeters) {
                dataService.writeTimeSeriesData(powerMeter);