Browse Source

更新

hph_优化版本
hupenghui@qniao.cn 3 years ago
parent
commit
7187b11205
1 changed files with 5 additions and 3 deletions
  1. 8
      root-cloud-statistics/src/main/java/com/qniao/iot/rc/RootCloudIotDataFormatterJob.java

8
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());
}

Loading…
Cancel
Save