Browse Source

更新

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

4
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) { private static MachineIotDataReceivedEvent transform(RootCloudIotDataReceiptedEvent event) {
MachineIotDataReceivedEvent machineIotDataReceivedEvent = new MachineIotDataReceivedEvent(); MachineIotDataReceivedEvent machineIotDataReceivedEvent = new MachineIotDataReceivedEvent();
machineIotDataReceivedEvent.setCurrCount(0L);
machineIotDataReceivedEvent.setCurrDuration(0L);
machineIotDataReceivedEvent.setDurationOfThePeriod(0L);
machineIotDataReceivedEvent.setCountOfThePeriod(0L);
machineIotDataReceivedEvent.setId(snowflake.nextId()); machineIotDataReceivedEvent.setId(snowflake.nextId());
machineIotDataReceivedEvent.setMachineIotMac(Long.valueOf(event.get__assetId__())); machineIotDataReceivedEvent.setMachineIotMac(Long.valueOf(event.get__assetId__()));
machineIotDataReceivedEvent.setDataSource(DataSource.ROOT_CLOUD); machineIotDataReceivedEvent.setDataSource(DataSource.ROOT_CLOUD);

Loading…
Cancel
Save