diff --git a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
index b009317..3ab10c7 100644
--- a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
+++ b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
@@ -209,13 +209,16 @@ public class IotMachineEventGeneratorJob {
                                             // 树根的需要计算
                                             event.setCurrJobCount(accCount - lastAccJobCount);
                                             // 单位是秒
-                                            event.setCurrJobDuration((reportTime - lastReportTime) / 3600);
+                                            event.setCurrJobDuration((reportTime - lastReportTime) / 1000);
                                         }
                                     }
                                 }
-                                ctx.output(machineIotDataReceivedEventOutput, event);
-                                collDeviceStatusChange(out, deviceState, lastDataReceivedEvent, event);
-                                lastDataReceivedEventState.update(event);
+                                if((event.getCurrJobCount() != 0 && event.getCurrJobDuration() != 0)
+                                        || (event.getCurrJobCount() == 0 && event.getCurrJobDuration() == 0)) {
+                                    ctx.output(machineIotDataReceivedEventOutput, event);
+                                    collDeviceStatusChange(out, deviceState, lastDataReceivedEvent, event);
+                                    lastDataReceivedEventState.update(event);
+                                }
                             }
                         }
                     }