no message

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<AgvTask> 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));
+    }
+}

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 {