MyCoinJobs.java 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. package top.lvzhiqiang.config;
  2. import lombok.extern.slf4j.Slf4j;
  3. import org.springframework.scheduling.annotation.Scheduled;
  4. import org.springframework.stereotype.Component;
  5. import top.lvzhiqiang.service.CoinService;
  6. import top.lvzhiqiang.util.DateUtils;
  7. import javax.annotation.Resource;
  8. import java.time.LocalDateTime;
  9. /**
  10. * Coin定时任务
  11. *
  12. * @author lvzhiqiang
  13. * 2023/9/10 13:58
  14. */
  15. @Component
  16. @Slf4j
  17. public class MyCoinJobs {
  18. @Resource
  19. private CoinService coinService;
  20. private static final String SCHEDULED_ZONE = "Asia/Shanghai";
  21. /**
  22. * 每小时执行一次
  23. */
  24. @Scheduled(cron = "0 0 */1 * * ?", zone = SCHEDULED_ZONE)
  25. public void syncData() {
  26. String startTime = String.valueOf(DateUtils.localDateTimeToMilliseconds(LocalDateTime.now().minusDays(1)));
  27. String endTime = String.valueOf(System.currentTimeMillis());
  28. String pageSize = "100";
  29. coinService.syncData(startTime, endTime, pageSize);
  30. }
  31. /**
  32. * 同步交易员列表
  33. */
  34. @Scheduled(cron = "0 0 5 * * ?", zone = SCHEDULED_ZONE)
  35. public void syncData4TraderList() {
  36. coinService.syncData4TraderList();
  37. }
  38. }