kaiyu
2021-08-06 b41e39cab33da257f1b2cf33123c1958102fa0e9
screen-api
取消测试时间戳
1 files modified
11 ■■■■ changed files
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java 11 ●●●● patch | view | raw | blame | history
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -89,11 +89,12 @@
                    resultMessgae.put(sensor.getCode(), sourceData);
                }
            }
            resultMessgae.put("DataTime", message.get("DataTime"));
            resultMessgae.put("time", message.get("time"));
            resultMessgae.put("time1", message.get("time1"));
            resultMessgae.put("serverTime", System.currentTimeMillis());
            resultMessgae.put("serverStartTime", serverStartTime);
            //测试时间延迟使用的属性
            //resultMessgae.put("DataTime", message.get("DataTime"));
            //resultMessgae.put("time", message.get("time"));
            //resultMessgae.put("time1", message.get("time1"));
            //resultMessgae.put("serverTime", System.currentTimeMillis());
            //resultMessgae.put("serverStartTime", serverStartTime);
            socket.sendMessage(JSON.toJSONString(resultMessgae));
        }
    }