From 44b8c0327db0e99895a4d33e316f327ce1a197e0 Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Thu, 15 Sep 2022 11:05:27 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/generator/job/IotMachineEventGeneratorJob.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 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 cd477c5..395d300 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
@@ -238,16 +238,15 @@ public class IotMachineEventGeneratorJob {
                                         }
                                     }
                                 }
-                                if ((event.getCurrJobCount() != 0 && event.getCurrJobDuration() != 0)
-                                        || (event.getCurrJobCount() == 0 && event.getCurrJobDuration() == 0)) {
+                                if(!(workingSta == 1 && event.getCurrJobCount() == 0)) {
                                     MachineIotDataReceivedEvent receivedEvent = collDeviceStatusChange(out, deviceState, lastDataReceivedEvent, event);
                                     if (receivedEvent != null) {
                                         ctx.output(machineIotDataReceivedEventOutput, event);
                                     }
-                                    lastDataReceivedEventState.update(event);
                                 }
                             }
                         }
+                        lastDataReceivedEventState.update(event);
                     }
                 }).name("keyBy stream");