diff --git a/youchain-system/src/main/java/com/youchain/modules/quartz/task/fxTask.java b/youchain-system/src/main/java/com/youchain/modules/quartz/task/fxTask.java new file mode 100644 index 0000000..7afa7f2 --- /dev/null +++ b/youchain-system/src/main/java/com/youchain/modules/quartz/task/fxTask.java @@ -0,0 +1,55 @@ +package com.youchain.modules.quartz.task; + +import com.youchain.basicdata.service.StockService; +import com.youchain.businessdata.domain.AgvTask; +import com.youchain.businessdata.service.AgvTaskService; +import com.youchain.businessdata.service.KMReService; +import com.youchain.businessdata.service.PickService; +import com.youchain.businessdata.service.TaskService; +import com.youchain.exception.BadRequestException; +import com.youchain.utils.BizStatus; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * 返修下线任务 + */ +@Slf4j +@Service +public class fxTask { + + @Autowired + public AgvTaskService agvTaskService; + + @Autowired + public KMReService kmReService; + + // 定义异常信息常量 + private static final String NO_EMPTY_SHELVES_ERROR_MSG = "没有返修下线任务!"; + + // 定义一个对象作为锁 + private final Object lock = new Object(); + + /** + * 轮询下发返修下线任务 + */ + public void sendAgvFx() { + List agvTaskList = agvTaskService.findOpenByAgvTask(BizStatus.Fx_Off_Line); + if (agvTaskList.isEmpty()) { + throw new BadRequestException(NO_EMPTY_SHELVES_ERROR_MSG); + } + synchronized (lock) { + for (AgvTask agvTask : agvTaskList) { + processAgvTask(agvTask); + } + } + + } + + private void processAgvTask(AgvTask agvTask) { + kmReService.sendAgvTask(agvTask, kmReService.sendAgvTaskGtJson(agvTask)); + } +} diff --git a/youchain-system/src/main/java/com/youchain/utils/GtLineMap.java b/youchain-system/src/main/java/com/youchain/utils/GtLineMap.java index 54eff62..20563a8 100644 --- a/youchain-system/src/main/java/com/youchain/utils/GtLineMap.java +++ b/youchain-system/src/main/java/com/youchain/utils/GtLineMap.java @@ -8,8 +8,8 @@ import java.util.stream.Collectors; /** * 滚筒任务路线 - * 下线:下线点 BYDGTO06、BYDGT007、BVDGTO01、BXDGT003、BYDGT005 - * 上线:上线点 BYDGTO02、BYDGTO04、BYDGTO08 + * 下线:下线点 BYDGT006、BYDGT007、BVDGT001、BXDGT003、BYDGT005 + * 上线:上线点 BYDGT002、BYDGT004、BYDGT008 */ @Component public class GtLineMap {