更新

root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java

@@ -205,7 +205,8 @@ public class RootCloudIotDataFormatterJob {
         machineIotDataReceivedEvent.setCurrCount(0L);
         machineIotDataReceivedEvent.setCurrDuration(0L);
         machineIotDataReceivedEvent.setDurationOfThePeriod(0L);
-        machineIotDataReceivedEvent.setCountOfThePeriod(0L);
+        // 树根的getACC_count每次关机就会清0，所以应该是一个周期的产量
+        machineIotDataReceivedEvent.setCountOfThePeriod(event.getACC_count());
         machineIotDataReceivedEvent.setId(snowflake.nextId());
         machineIotDataReceivedEvent.setMachineIotMac(Long.valueOf(event.get__assetId__()));
         machineIotDataReceivedEvent.setDataSource(DataSource.ROOT_CLOUD);
@@ -214,13 +215,13 @@ public class RootCloudIotDataFormatterJob {
         machineIotDataReceivedEvent.setIgStat(event.getIG_sta());
         machineIotDataReceivedEvent.setAccJobCount(event.getACC_count_total());
         // 当天的工作产能
-        machineIotDataReceivedEvent.setJobCountOfTheDay(event.getACC_count());
+        machineIotDataReceivedEvent.setJobCountOfTheDay(0L);
         // 当天的工作时长
         machineIotDataReceivedEvent
                 .setJobDurationOfTheDay(event.getRunning_duration() == null ? 0L : event.getRunning_duration().longValue());
         String stopDuration = event.getStoping_duration();
         if (stopDuration != null) {
-            machineIotDataReceivedEvent.setCurrStoppingDuration(Long.parseLong(stopDuration));
+            machineIotDataReceivedEvent.setCurrStoppingDuration(Long.parseLong(stopDuration.split("\\.")[0]));
         }
         machineIotDataReceivedEvent
                 .setCurrWaitingDuration(event.getWaiting_duration() == null ? 0L : event.getWaiting_duration().longValue());