| | |
|---|
| | | |
|---|
| | | package com.moral.api.exception.consumer; |
|---|
| | | |
|---|
| | | import com.moral.api.utils.AdjustDataUtils; |
|---|
| | |
|---|
| | | import com.moral.api.websocket.CruiserWebSocketServer; |
|---|
| | | import com.moral.constant.KafkaConstants; |
|---|
| | | |
|---|
| | | |
|---|
| | | /* |
|---|
| | | * 走航车数据消费者 |
|---|
| | | * */ |
|---|
| | | @Component |
|---|
| | | * |
|---|
| | | */ |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | //@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 { |
|---|
| | |
|---|
| | | 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); |
|---|
| | | //数据补偿 |
|---|
| | | //单位转换 |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
