| | |
| | | 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 消息处理类 |
| | |
| | | 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()); |
| | | } |