diff --git a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java index 0bc211f..78185ff 100644 --- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java +++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java @@ -128,7 +128,8 @@ public class RootCloudIotDataFormatterJob { machineIotDataReceivedEvent.setCurrStoppingDuration(stoppingDuration.longValue()); } machineIotDataReceivedEvent.setCurrWaitingDuration(Objects.isNull(event.getWaiting_duration()) ? null : event.getWaiting_duration().longValue()); - machineIotDataReceivedEvent.setReportTime(System.currentTimeMillis()); + machineIotDataReceivedEvent.setReceivedTime(System.currentTimeMillis()); + machineIotDataReceivedEvent.setReportTime(event.get__timestamp__()); } return machineIotDataReceivedEvent; }