jinpengyong
2023-07-28 9f7685f3488b5582d48cf8778ee45feb99bd5eec
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;
@@ -25,10 +26,12 @@
import com.moral.api.websocket.CruiserWebSocketServer;
import com.moral.constant.KafkaConstants;
/*
 * 走航车数据消费者
 * */
@Component
//@Component
@Slf4j
public class CruiserDataConsumer implements ConsumerSeekAware {
@@ -64,8 +67,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 +117,4 @@
    }
}