diff --git a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java index 89fe9c7..9bb805e 100644 --- a/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java +++ b/root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java @@ -194,13 +194,15 @@ public class RootCloudIotDataFormatterJob { machineIotDataReceivedEvent.setId(snowflake.nextId()); machineIotDataReceivedEvent.setMachineIotMac(Long.valueOf(event.get__assetId__())); machineIotDataReceivedEvent.setDataSource(DataSource.ROOT_CLOUD); - machineIotDataReceivedEvent.setMachinePwrStat(event.getPWR_sta()); + Integer pwrSta = event.getPWR_sta(); + machineIotDataReceivedEvent.setMachinePwrStat(pwrSta); machineIotDataReceivedEvent.setIgStat(event.getIG_sta()); machineIotDataReceivedEvent.setAccJobCount(event.getACC_count_total()); Long accCount = event.getACC_count(); machineIotDataReceivedEvent.setCurrJobCount(accCount); - if(accCount == 0) { - machineIotDataReceivedEvent.setMachineWorkingStat(event.getWorking_sta()); + if(pwrSta == 1 && accCount == 0) { + // 如果是开机状态并且没有产量就设置为待机 + machineIotDataReceivedEvent.setMachineWorkingStat(2); }else { machineIotDataReceivedEvent.setMachineWorkingStat(event.getWorking_sta()); }