From 6fb65f6e9fd0c9d5a5854a0d42476e2956c3713c Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Sat, 3 Sep 2022 02:22:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java | 4 ++++ 1 file changed, 4 insertions(+) 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);