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 9911716..6b2ca94 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 @@ -363,6 +363,10 @@ public class RootCloudIotDataFormatterJob { private static MachineIotDataReceivedEvent transform(RootCloudIotDataReceiptedEvent event) { MachineIotDataReceivedEvent machineIotDataReceivedEvent = new MachineIotDataReceivedEvent(); + machineIotDataReceivedEvent.setCurrCount(0L); + machineIotDataReceivedEvent.setCurrDuration(0L); + machineIotDataReceivedEvent.setDurationOfThePeriod(0L); + machineIotDataReceivedEvent.setCountOfThePeriod(0L); machineIotDataReceivedEvent.setId(snowflake.nextId()); machineIotDataReceivedEvent.setMachineIotMac(Long.valueOf(event.get__assetId__())); machineIotDataReceivedEvent.setDataSource(DataSource.ROOT_CLOUD);