forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-04-12 fc8fe626f222e024c1c4b45759ef0102174e5b9c 
 screen-api/src/main/java/com/moral/api/kafka/consumer/CruiserDataConsumer.java


@@ -1,5 +1,7 @@


package com.moral.api.kafka.consumer;




import com.moral.api.utils.AdjustDataUtils;


import com.moral.api.utils.UnitConvertUtils;


import lombok.extern.slf4j.Slf4j;


import org.apache.kafka.clients.consumer.ConsumerRecord;


import org.apache.kafka.common.TopicPartition;


@@ -22,7 +24,6 @@


import com.moral.api.entity.UnitConversion;


import com.moral.api.websocket.CruiserWebSocketServer;


import com.moral.constant.KafkaConstants;


import com.moral.util.UnitConvertUtils;




/*


 * 走航车数据消费者


@@ -43,6 +44,10 @@


                continue;


            //取出基本信息


            SpecialDevice specialDevice = socket.getSpecialDevice();


            Map<String, Object> adjustFormula = socket.getAdjustFormula();


            Map<String, Object> regionAqi = socket.getRegionAqi();


            if(adjustFormula!=null)


                data = AdjustDataUtils.adjust(data,adjustFormula,regionAqi);


            //创建最终消息对象


            Map<String, Object> result = new HashMap<>();


            result.put("time",data.get("time"));