package com.sckw.freight.job; import com.sckw.freight.service.JobService; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; /** * @BelongsProject: Freight-Settlement-Backend * @BelongsPackage: com.sckw.freight.job * @Author: xj * @CreateTime: 2025-01-14 15:33 * @Description: TODO * @Version: 1.0 */ @Component @Data @Slf4j public class FreightTask implements Runnable { @Value("${job.sleep}") private Integer sleep; @Value("${job.enable}") private Boolean enable; @Autowired private JobService jobService; @Override public void run() { if (!enable) return; new Thread(() -> { while (true) { try { log.info("轮循任务执行中..."); jobService.executeJob(); Thread.sleep(sleep * 1000l); log.info("轮循任务执行完成"); } catch (InterruptedException e) { log.error("轮循任务执行失败", e); } } }).start(); } }