package cn.iocoder.yudao.module.mes.job.dv;
|
|
import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler;
|
import cn.iocoder.yudao.framework.tenant.core.job.TenantJob;
|
import cn.iocoder.yudao.module.mes.controller.admin.dv.telemetry.vo.MesDvTelemetryPullRespVO;
|
import cn.iocoder.yudao.module.mes.service.dv.telemetry.MesDvTelemetryService;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 设备数采数据定时拉取 Job
|
*
|
* 数采接口仅保留近 5 分钟数据，需定时拉取避免数据丢失。默认每 5 分钟执行一次。
|
*
|
* @author 超级管理员
|
*/
|
@Component
|
public class MesDvTelemetryPullJob implements JobHandler {
|
|
@Resource
|
private MesDvTelemetryService telemetryService;
|
|
@Override
|
@TenantJob
|
public String execute(String param) {
|
MesDvTelemetryPullRespVO resp = telemetryService.pullTelemetry();
|
return String.format("拉取数采数据成功，新增 %s 条，涉及设备 %s 台", resp.getRecordCount(), resp.getDeviceCount());
|
}
|
|
}
|
