From 863b5cfdd2e8fa0f8da1c3c8e06c4e9d5b1ee337 Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Tue, 6 Sep 2022 16:15:22 +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 --- .../generator/job/IotMachineEventGeneratorJob.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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); + } } } }