package top.lvzhiqiang.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import top.lvzhiqiang.service.CoinService;
import top.lvzhiqiang.util.DateUtils;

import javax.annotation.Resource;
import java.time.LocalDateTime;

/**
 * Coin定时任务
 *
 * @author lvzhiqiang
 * 2023/9/10 13:58
 */
@Component
@Slf4j
public class MyCoinJobs {

    @Resource
    private CoinService coinService;

    private static final String SCHEDULED_ZONE = "Asia/Shanghai";

    /**
     * 每小时执行一次
     */
    @Scheduled(cron = "0 0 */1 * * ?", zone = SCHEDULED_ZONE)
    public void syncData() {
        String startTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(LocalDateTime.now().minusDays(1)));
        String endTime = String.valueOf(System.currentTimeMillis());
        String pageSize = "100";
        coinService.syncData(startTime, endTime, pageSize);
    }

    /**
     * 同步交易员列表
     */
    @Scheduled(cron = "0 0 5 * * ?", zone = SCHEDULED_ZONE)
    public void syncData4TraderList() {
        coinService.syncData4TraderList();
    }
}