智能电表水表定时更新接口

This commit is contained in:
曹磊 2025-06-16 18:46:29 +08:00
parent 7a7284e5ac
commit eff9b39f10
4 changed files with 21 additions and 1 deletions

View File

@ -8,7 +8,7 @@ import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
/** /**
* 表设备状态信息同步 * 采集器状态信息同步
*/ */
@Slf4j @Slf4j
public class CollectorDataJob implements Job { public class CollectorDataJob implements Job {
@ -16,6 +16,11 @@ public class CollectorDataJob implements Job {
@Autowired @Autowired
ITqDeviceInfoService service; ITqDeviceInfoService service;
/**
* 5分钟一次
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
service.getAllCollector(true); service.getAllCollector(true);

View File

@ -16,6 +16,11 @@ public class MeterStatusJob implements Job {
@Autowired @Autowired
ITqDeviceInfoService service; ITqDeviceInfoService service;
/**
* 5分钟一次
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
service.getAllMeter(true); service.getAllMeter(true);

View File

@ -20,6 +20,11 @@ public class ElectricityReadJob implements Job {
@Autowired @Autowired
IElectricityMeterService service; IElectricityMeterService service;
/**
* 1小时一次
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
List<ElectricityMeter> electricityList = service.findAllList(); List<ElectricityMeter> electricityList = service.findAllList();

View File

@ -21,6 +21,11 @@ public class WaterReadJob implements Job {
@Autowired @Autowired
IWaterMeterService service; IWaterMeterService service;
/**
* 1小时一次
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
List<WaterMeter> waterList = service.findAllList(); List<WaterMeter> waterList = service.findAllList();