限制出入库

ruoyi-admin/src/main/java/com/ruoyi/common/TaskType.java

@@ -10,6 +10,16 @@ public class TaskType {
      */
     public static final int STACKER_TYPE_DEFAULT = 0;
 
+    /**
+     * 常规入库
+     */
+    public static final String STOCKIN = "1";
+
+    /**
+     * 常规出库
+     */
+    public static final String STOCKOUT = "2";
+
     /**
      * 1-二楼入出
      */

ruoyi-admin/src/main/java/com/ruoyi/job/domain/MydoJob.java

@@ -1,5 +1,6 @@
 package com.ruoyi.job.domain;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.*;
@@ -21,13 +22,14 @@ import java.util.List;
 @NoArgsConstructor
 @ToString
 @Builder
-//@TableName("mydo_job_wcs")
+@TableName("mydo_job_wcs")
 public class MydoJob extends BaseEntity
 {
+    @TableField(exist = false)
     private static final long serialVersionUID = 1L;
 
     /** 任务ID */
-//    @TableId
+    @TableId
     private String jobId;
 
     /** 任务状态 */

ruoyi-admin/src/main/java/com/ruoyi/schedule/scheduleTask/ssj/PortConvThread.java

@@ -32,6 +32,7 @@ import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
 import static com.ruoyi.common.TaskStatusCode.*;
+import static com.ruoyi.common.TaskType.STOCKOUT;
 import static com.ruoyi.common.WmsTaskTypeCode.WMS_TASK_TYPE_STOCKIN;
 import static com.ruoyi.schedule.plcRead.ssj.PlcSsjRead.writeToSsj;
 
@@ -165,17 +166,20 @@ public class PortConvThread implements Runnable {
         ).size();
 
         if (count > 0) {
-            //如果查到输送机有已经该条码的入库作业 - 把该作业更新为初始状态（未向入库输送机下发任务号的阶段）
+            log.warn("【警告】已经存在该托盘号的入库作业,无法继续执行该托盘的入库请求，请稍后重试");
-            // 省去入库输送机口的手动作废操作，自动更新任务至初始阶段
+            writeToSsj(inSsjDevice.getPlcDbWriteAddress(), "99", 2, 1);
-//            mydoJobService.updateMydoJob(
-//                    new MydoJob().builder()
-//                            .status("1")
-//                            .executionPhase("0")
-//                            .build()
-//            );
             return;
         }
 
+        int stockoutMydoJob = mydoJobService.selectInOrOutMydoJobList(
+                new MydoJob().builder().inOrOut(STOCKOUT).build()
+        ).size();
+
+        if (stockoutMydoJob > 0) {
+            log.warn("【警告】已经存在执行中的出库作业,无法执行入库请求，请稍后重试");
+            writeToSsj(inSsjDevice.getPlcDbWriteAddress(), "99", 2, 1);
+            return;
+        }
 
 
         String errorMessage = "";