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());
    }

}