package com.ruoyi.web.modules.industryservice.task;

import com.alibaba.fastjson2.JSON;
import com.ruoyi.web.modules.industryservice.domain.vo.IotDataIncrementalSyncResultVo;
import com.ruoyi.web.modules.industryservice.service.IotDataIncrementalSyncService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * IoT 数据增量同步定时任务（Quartz 调用：{@code iotDataIncrementalSyncTask.syncIncremental}）。
 * <p>
 * 建议 cron：{@code 0 0 1 * * ?}（每天凌晨 1:00）。
 * 同步牛只称重、耳标温度步数、定位项圈、环境监测四类数据。
 * </p>
 */
@Component("iotDataIncrementalSyncTask")
public class IotDataIncrementalSyncTask
{
    private static final Logger LOGGER = LoggerFactory.getLogger(IotDataIncrementalSyncTask.class);

    @Autowired
    private IotDataIncrementalSyncService iotDataIncrementalSyncService;

    public void syncIncremental()
    {
        LOGGER.info("IotDataIncrementalSyncTask start");
        IotDataIncrementalSyncResultVo iotDataIncrementalSyncResultVo = iotDataIncrementalSyncService.syncIncremental();
        LOGGER.info("IotDataIncrementalSyncTask done, result={}", JSON.toJSONString(iotDataIncrementalSyncResultVo));
    }
}
