Browse Source

feat:增加数据接收时间字段

hph_优化版本
lizhongkang@qniao.cn 3 years ago
parent
commit
e4e75415f7
1 changed files with 2 additions and 1 deletions
  1. 3
      root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java

3
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;
}

Loading…
Cancel
Save