blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-10-10 f0837ee21f7650d4413830d4ee90da02bcdd6d36 
 screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java


@@ -1,3 +1,4 @@




package com.moral.api.exception.consumer;




import com.moral.api.utils.AdjustDataUtils;


@@ -27,10 +28,15 @@




/*


 * 走航车数据消费者


 * */


 **/












@Component


@Slf4j


public class CruiserDataConsumer implements ConsumerSeekAware {


public class CruiserDataConsumer  implements ConsumerSeekAware {




    @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "cruiserDataListenerFactory")


    public void listenSecondSpecial(ConsumerRecord<String, String> record) throws Exception {


@@ -64,8 +70,10 @@


                    continue;


                }


                Double sourceDataD = Double.valueOf(String.valueOf(data.get(code)));


                /*BigDecimal bg = new BigDecimal(sourceDataD);


                bg = bg.setScale(2, BigDecimal.ROUND_FLOOR);*/




                 BigDecimal bg = new BigDecimal(sourceDataD);


                bg = bg.setScale(2, BigDecimal.ROUND_FLOOR);




                String sourceData = String.valueOf(sourceDataD);


                //数据补偿


                //单位转换


@@ -112,3 +120,4 @@




    }


}