|
|
@ -84,6 +84,7 @@ public class TtDataCollectTask implements SchedulingConfigurer {
|
|
|
|
TtPouringEquip ttPouringEquip = new TtPouringEquip();
|
|
|
|
TtPouringEquip ttPouringEquip = new TtPouringEquip();
|
|
|
|
ttPouringEquip.setTemperature(new BigDecimal(temp));
|
|
|
|
ttPouringEquip.setTemperature(new BigDecimal(temp));
|
|
|
|
ttPouringEquip.setCreateTime(new Date());
|
|
|
|
ttPouringEquip.setCreateTime(new Date());
|
|
|
|
|
|
|
|
ttPouringEquip.setCreateBy("system");
|
|
|
|
ttPouringEquip.setType(type);
|
|
|
|
ttPouringEquip.setType(type);
|
|
|
|
ttPouringEquip.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttPouringEquip.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttPouringEquip.setEqtIp(eqtIp);
|
|
|
|
ttPouringEquip.setEqtIp(eqtIp);
|
|
|
@ -107,6 +108,7 @@ public class TtDataCollectTask implements SchedulingConfigurer {
|
|
|
|
TtFeedingEquip ttFeedingEquip = new TtFeedingEquip();
|
|
|
|
TtFeedingEquip ttFeedingEquip = new TtFeedingEquip();
|
|
|
|
ttFeedingEquip.setTemperature(new BigDecimal(temp));
|
|
|
|
ttFeedingEquip.setTemperature(new BigDecimal(temp));
|
|
|
|
ttFeedingEquip.setCreateTime(new Date());
|
|
|
|
ttFeedingEquip.setCreateTime(new Date());
|
|
|
|
|
|
|
|
ttFeedingEquip.setCreateBy("system");
|
|
|
|
ttFeedingEquip.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttFeedingEquip.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttFeedingEquip.setEqtIp(eqtIp);
|
|
|
|
ttFeedingEquip.setEqtIp(eqtIp);
|
|
|
|
feedingEquipService.save(ttFeedingEquip);
|
|
|
|
feedingEquipService.save(ttFeedingEquip);
|
|
|
@ -116,8 +118,8 @@ public class TtDataCollectTask implements SchedulingConfigurer {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// String cron2 = "0 0 8 * * ?";
|
|
|
|
String cron2 = "0 0 8 * * ?";
|
|
|
|
String cron2 = "0/5 * * * * ?";
|
|
|
|
// String cron2 = "0 0/5 * * * ?";
|
|
|
|
// 创建数字电表定时任务
|
|
|
|
// 创建数字电表定时任务
|
|
|
|
for(Map.Entry<DEVICE_TYPE, RS485Handler> entry : meterHandlerMap.entrySet()) {
|
|
|
|
for(Map.Entry<DEVICE_TYPE, RS485Handler> entry : meterHandlerMap.entrySet()) {
|
|
|
|
RS485Handler handler = entry.getValue();
|
|
|
|
RS485Handler handler = entry.getValue();
|
|
|
@ -134,6 +136,7 @@ public class TtDataCollectTask implements SchedulingConfigurer {
|
|
|
|
TtElectricMeter ttElectricMeter = new TtElectricMeter();
|
|
|
|
TtElectricMeter ttElectricMeter = new TtElectricMeter();
|
|
|
|
ttElectricMeter.setTotalPower(totalPower);
|
|
|
|
ttElectricMeter.setTotalPower(totalPower);
|
|
|
|
ttElectricMeter.setCreateTime(new Date());
|
|
|
|
ttElectricMeter.setCreateTime(new Date());
|
|
|
|
|
|
|
|
ttElectricMeter.setCreateBy("system");
|
|
|
|
ttElectricMeter.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttElectricMeter.setEqtNo(Optional.ofNullable(eqtNoIpMap.get(eqtIp)).orElse("0"));
|
|
|
|
ttElectricMeter.setEqtIp(eqtIp);
|
|
|
|
ttElectricMeter.setEqtIp(eqtIp);
|
|
|
|
// 获取昨日用电量
|
|
|
|
// 获取昨日用电量
|
|
|
|