package com.zy.asrs.task; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.zy.asrs.entity.CommandInfo; import com.zy.asrs.entity.TaskWrk; import com.zy.asrs.entity.WaitPakin; import com.zy.asrs.service.CommandInfoService; import com.zy.asrs.service.TaskWrkService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** * 定时将任务(完成、取消)转成日志 */ @Slf4j @Component public class TaskLogScheduler { @Autowired private TaskWrkService taskWrkService; @Autowired private CommandInfoService commandInfoService; @Scheduled(cron = "0/3 * * * * ? ") public void execute() { for (TaskWrk taskWrk : taskWrkService.selectToBeHistoryData()) { if (taskWrkService.saveToHistory(taskWrk.getTaskNo()) > 0) { //任务已经转日志,将该任务下面的指令转日志 commandInfoService.saveToHistory(taskWrk.getTaskNo()); //删除任务 taskWrkService.delete(new EntityWrapper().eq("task_no", taskWrk.getTaskNo())); //删除指令 commandInfoService.delete(new EntityWrapper().eq("task_no", taskWrk.getTaskNo())); } } } }