Browse Source

更新

feature_hph_新增rabbitmq_sink
1049970895@qniao.cn 3 years ago
parent
commit
986ec1895c
1 changed files with 2 additions and 2 deletions
  1. 4
      src/main/java/com/qniao/iot/IotMonitoringDataJob.java

4
src/main/java/com/qniao/iot/IotMonitoringDataJob.java

@ -211,7 +211,7 @@ public class IotMonitoringDataJob {
nowDeviceState.setJobTotal(onData.getJobTotal() + receivedEvent.getCurrJobCount());
} else {
// 机智云
nowDeviceState.setTheDayJobCount(lastedDeviceState.getTheDayJobCount() + accJobCount);
nowDeviceState.setTheDayJobCount(lastedDeviceState.getTheDayJobCount() + receivedEvent.getCurrJobCount());
nowDeviceState.setJobTotal(lastedDeviceState.getJobTotal() + receivedEvent.getCurrJobCount());
}
}
@ -233,7 +233,7 @@ public class IotMonitoringDataJob {
nowDeviceState.setJobTotal(onData.getJobTotal() + receivedEvent.getCurrJobCount());
} else {
// 机智云
nowDeviceState.setTheDayJobCount(lastedDeviceState.getTheDayJobCount() + accJobCount);
nowDeviceState.setTheDayJobCount(lastedDeviceState.getTheDayJobCount() + receivedEvent.getCurrJobCount());
nowDeviceState.setJobTotal(lastedDeviceState.getJobTotal() + receivedEvent.getCurrJobCount());
}
nowDeviceState.setCurrLocalDate(localDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));

Loading…
Cancel
Save