kaiyu
2021-08-05 d524949baa3b1c64da27f9b5592a1d94845849c6
screen-api
实时界面对数据进行保留小数位并且取整
1 files modified
9 ■■■■ changed files
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java 9 ●●●● patch | view | raw | blame | history
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -17,6 +17,7 @@
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -39,7 +40,7 @@
        long serverStartTime = System.currentTimeMillis();
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {
            //判断消息书否数据该socket
            //判断消息是否数据该socket
            String messageMac = (String) message.get("mac");
            String mac = socket.getMac();
            if (!mac.equalsIgnoreCase(messageMac))
@@ -57,7 +58,11 @@
                String showUnitKey = sensor.getShowUnitKey();
                String unitKey = sensor.getUnitKey();
                String unit = sensor.getUnit();
                String sourceData = String.valueOf(message.get(code));
                //对数据保留两位小数,并且向下取整
                Double sourceDataD = Double.valueOf(String.valueOf(message.get(code)));
                BigDecimal bg = new BigDecimal(sourceDataD);
                bg = bg.setScale(2,BigDecimal.ROUND_FLOOR);
                String sourceData = bg.toString();
                //数据补偿
                //单位转换
                if (!unitKey.equals(showUnitKey)) {//如果源单位和显示单位不同,则进行单位转换