package com.vincent.rsf.server.manager.schedules; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.vincent.rsf.framework.common.Cools; import com.vincent.rsf.server.manager.controller.params.LocToTaskParams; import com.vincent.rsf.server.manager.entity.BasContainer; import com.vincent.rsf.server.manager.entity.Loc; import com.vincent.rsf.server.manager.entity.WarehouseAreas; import com.vincent.rsf.server.manager.enums.LocStsType; import com.vincent.rsf.server.manager.service.LocItemService; import com.vincent.rsf.server.manager.service.LocService; import com.vincent.rsf.server.manager.service.TaskService; import com.vincent.rsf.server.manager.service.impl.BasContainerServiceImpl; import com.vincent.rsf.server.manager.service.impl.WarehouseAreasServiceImpl; import com.vincent.rsf.server.system.constant.GlobalConfigCode; import com.vincent.rsf.server.system.entity.Config; import com.vincent.rsf.server.system.service.ConfigService; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.List; import java.util.Objects; /** * @author Munch D. Luffy * @date 2026/01/29 * 缓存区域任务自动触发 */ @Slf4j @Component public class TaskMissionSchedules { public static Logger logger = LoggerFactory.getLogger(TaskMissionSchedules.class); @Autowired private TaskService taskService; @Autowired private ConfigService configService; @Autowired private WarehouseAreasServiceImpl warehouseAreasService; @Autowired private LocService locService; @Autowired private LocItemService locItemService; @Autowired private BasContainerServiceImpl basContainerService; /** * @author Munch D. Luffy * @date 2026/01/15 * @description: 初始任务规划路径 * @version 1.0 */ @Scheduled(cron = "0/2 * * * * ?") @Transactional(rollbackFor = Exception.class) public void missionTemplate() throws Exception { Config config = configService.getOne(new LambdaQueryWrapper().eq(Config::getFlag, GlobalConfigCode.AUTO_TEMPLATE_PLANNING_STEP_FLOW)); if (!Boolean.parseBoolean(config.getVal())) { return; } } }