仿真环境启动

servo/src/main/java/com/galaxis/rcs/common/enums/BizTaskType.java

@@ -3,7 +3,9 @@ package com.galaxis.rcs.common.enums;
 public enum BizTaskType {
     MOVE,     // 移动任务
     CHARGE,     // 充电任务
-    CARRY;      // 搬运任务
+    CARRY,      // 搬运任务
+    LOAD,       // 装载任务
+    UNLOAD;     // 卸载任务
 
     public static BizTaskType fromString(String value) {
         if (value == null)

servo/src/main/java/com/galaxis/rcs/common/enums/PlanTaskType.java

@@ -11,5 +11,4 @@ public enum PlanTaskType {
     UNLOAD, // 装载任务
     CHARGE,       // 充电任务
     FINISH       // 完成任务
-
 }

servo/src/main/java/com/yvan/workbench/controller/EnvController.java

@@ -1,8 +1,10 @@
 package com.yvan.workbench.controller;
 
 import com.galaxis.rcs.RCSService;
+import com.google.common.base.Strings;
 import com.yvan.workbench.model.entity.Model;
 import org.clever.core.Conv;
+import org.clever.core.model.response.R;
 import org.clever.data.jdbc.DaoFactory;
 import org.clever.data.jdbc.QueryDSL;
 import org.clever.data.jdbc.querydsl.utils.QueryDslUtils;
@@ -12,7 +14,11 @@ import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 
+import static com.galaxis.rcs.common.query.QLccBasContainer.lccBasContainer;
+import static com.galaxis.rcs.common.query.QLccBasExecutor.lccBasExecutor;
+import static com.galaxis.rcs.common.query.QLccBasLocation.lccBasLocation;
 import static com.galaxis.rcs.common.query.QLccEnvInfo.lccEnvInfo;
+import static com.galaxis.rcs.common.query.QLccInvLpn.lccInvLpn;
 
 public class EnvController {
     static final QueryDSL queryDSL = DaoFactory.getQueryDSL();
@@ -25,4 +31,67 @@ public class EnvController {
 
         return Model.newSuccess(list);
     }
+
+    public static R<?> getAllInv(@RequestBody Map<String, Object> params) {
+        String catalogCode = Conv.asString(params.get("catalogCode"));
+        Long envId = Conv.asLong(params.get("envId"));
+
+        if (Strings.isNullOrEmpty(catalogCode)) {
+            return R.fail("catalogCode  must not be null");
+        }
+        if (envId == null) {
+            return R.fail("envId must not be null");
+        }
+
+        var list = queryDSL.select(QueryDslUtils.linkedMap(
+                lccBasContainer.containerType,
+                lccInvLpn.lpn,
+                lccInvLpn.locCode,
+                lccBasLocation.rack,
+                lccBasLocation.bay,
+                lccBasLocation.level,
+                lccBasLocation.cell
+            ))
+            .from(lccInvLpn)
+            .innerJoin(lccBasLocation).on(
+                lccInvLpn.locCode.eq(lccBasLocation.locCode).and(
+                    lccBasLocation.envId.eq(lccBasLocation.envId)
+                )
+            )
+            .innerJoin(lccBasContainer).on(
+                lccInvLpn.lpn.eq(lccInvLpn.lpn).and(
+                    lccBasContainer.envId.eq(lccInvLpn.envId)
+                )
+            )
+            .where(lccInvLpn.envId.eq(envId))
+            .where(lccBasLocation.catalogCode.eq(catalogCode))
+            .fetch();
+
+        return R.success(list);
+    }
+
+    public static R<?> getAllExecutor(@RequestBody Map<String, Object> params) {
+        String catalogCode = Conv.asString(params.get("catalogCode"));
+        Long envId = Conv.asLong(params.get("envId"));
+
+        if (Strings.isNullOrEmpty(catalogCode)) {
+            return R.fail("catalogCode  must not be null");
+        }
+        if (envId == null) {
+            return R.fail("envId must not be null");
+        }
+
+        var list = queryDSL.select(QueryDslUtils.linkedMap(
+                lccBasExecutor.executorId,
+                lccBasExecutor.virtualLocationAt,
+                lccBasExecutor.virtualExecutorPayload
+            ))
+            .from(lccBasExecutor)
+            .where(lccBasExecutor.envId.eq(envId))
+            .where(lccBasExecutor.isActive.eq(true))
+            .where(lccBasExecutor.virtualFloorCode.eq(catalogCode))
+            .fetch();
+
+        return R.success(list);
+    }
 }