|
|
@ -87,6 +87,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);
|
|
|
@ -119,6 +120,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);
|
|
|
@ -128,8 +130,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();
|
|
|
@ -146,6 +148,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);
|
|
|
|
// 获取昨日用电量
|
|
|
|
// 获取昨日用电量
|
|
|
|