Freight-Settlement-Backend/src/main/java/com/sckw/freight/job/FreightTask.java

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