diff --git a/ruoyi-admin/src/main/java/com/ruoyi/common/TaskType.java b/ruoyi-admin/src/main/java/com/ruoyi/common/TaskType.java index 84f0d71..80919f7 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/common/TaskType.java +++ b/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-二楼入出 */ diff --git a/ruoyi-admin/src/main/java/com/ruoyi/job/domain/MydoJob.java b/ruoyi-admin/src/main/java/com/ruoyi/job/domain/MydoJob.java index ca18d28..f056780 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/job/domain/MydoJob.java +++ b/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; /** 任务状态 */ diff --git a/ruoyi-admin/src/main/java/com/ruoyi/schedule/scheduleTask/ssj/PortConvThread.java b/ruoyi-admin/src/main/java/com/ruoyi/schedule/scheduleTask/ssj/PortConvThread.java index 849a4f1..34dd188 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/schedule/scheduleTask/ssj/PortConvThread.java +++ b/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) { - //如果查到输送机有已经该条码的入库作业 - 把该作业更新为初始状态(未向入库输送机下发任务号的阶段) - // 省去入库输送机口的手动作废操作,自动更新任务至初始阶段 -// mydoJobService.updateMydoJob( -// new MydoJob().builder() -// .status("1") -// .executionPhase("0") -// .build() -// ); + log.warn("【警告】已经存在该托盘号的入库作业,无法继续执行该托盘的入库请求,请稍后重试"); + writeToSsj(inSsjDevice.getPlcDbWriteAddress(), "99", 2, 1); 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 = "";