From 3c0c0a2532296ceb258ffb811054515d0bf8f2c8 Mon Sep 17 00:00:00 2001 From: "1049970895@qniao.cn" <1049970895> Date: Tue, 13 Sep 2022 13:50:23 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:=E8=BF=87=E6=BB=A4=E5=B7=A5=E4=BD=9C?= =?UTF-8?q?=E7=8A=B6=E6=80=81=E4=B8=AD=E4=BA=A7=E8=83=BD=E4=B8=BA0?= =?UTF-8?q?=E7=9A=84=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../generator/job/IotMachineEventGeneratorJob.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 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 d9a5df6..c7ad49e 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 @@ -135,14 +135,9 @@ public class IotMachineEventGeneratorJob { @Override public boolean filter(MachineIotDataReceivedEvent value) { - Integer dataSource = value.getDataSource(); - boolean bool = true; - if (DataSource.TACT_CLOUD.equals(dataSource)) { - // 机智云(树根的校验不了) - Long currCount = value.getCurrJobCount(); - Integer machineWorkingStat = value.getMachineWorkingStat(); - bool = !(machineWorkingStat == 2 && currCount == 0); - } + Long currCount = value.getCurrJobCount(); + Integer machineWorkingStat = value.getMachineWorkingStat(); + boolean bool = !(machineWorkingStat == 2 && currCount == 0); if (bool && value.getMachinePwrStat() != null && value.getMachineIotMac() != null && value.getMachineWorkingStat() != null && value.getReportTime() != null) {