From 361ec0dcb6791e2b23aa95abd7b9e4d1719a905f Mon Sep 17 00:00:00 2001
From: lsymicc <e003914@163.com>
Date: Tue, 2 Jun 2026 16:28:23 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../job/service/impl/MydoJobServiceImpl.java  | 29 +++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/job/service/impl/MydoJobServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/job/service/impl/MydoJobServiceImpl.java
index b9cc228..da558cf 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/job/service/impl/MydoJobServiceImpl.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/job/service/impl/MydoJobServiceImpl.java
@@ -4,12 +4,16 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 
+import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.lang.UUID;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.job.domain.JobCallBack;
 import com.ruoyi.job.service.IJobCallBackService;
+import com.ruoyi.queue.ddj.domain.DdjDeviceExecutionQueue;
+import com.ruoyi.queue.ddj.domain.DdjDeviceExecutionQueueFinish;
+import com.ruoyi.queue.ddj.service.IDdjDeviceExecutionQueueFinishService;
 import com.ruoyi.queue.ddj.service.IDdjDeviceExecutionQueueService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -37,6 +41,8 @@ public class MydoJobServiceImpl implements IMydoJobService
     private IJobCallBackService jobCallBackService;
     @Autowired
     private IDdjDeviceExecutionQueueService ddjDeviceExecutionQueueService;
+    @Autowired
+    private IDdjDeviceExecutionQueueFinishService ddjDeviceExecutionQueueServiceFinishService;
 
     /**
      * 查询作业信息
@@ -170,6 +176,9 @@ public class MydoJobServiceImpl implements IMydoJobService
         map.put("v_rwh", rwh);
         map.put("v_ddj_id", id);
         mydoJobMapper.InvalidMydoJob(map);
+
+        log.info("【人工操作】手动作废wcs任务并移除执行中的堆垛机队列，wcs任务号:{}", rwh);
+
         if (Convert.toInt(map.get("v_result")) == 10){
             return true;
         }else {
@@ -237,6 +246,26 @@ public class MydoJobServiceImpl implements IMydoJobService
 
             //移除实时任务
             mydoJobMapper.deleteMydoJobByJobId(jobId);
+
+            log.info("【人工操作】手动完成wcs任务，wcs任务号:{}，wms任务号:{}", mydoJob.getTaskNo(), mydoJob.getWmsTaskNo());
+
+            DdjDeviceExecutionQueue queue = ddjDeviceExecutionQueueService.selectDdjDeviceExecutionQueueByTaskNo(mydoJob.getTaskNo());
+
+            try {
+                if (queue != null)
+                {
+                    DdjDeviceExecutionQueueFinish queueFinish = BeanUtil.copyProperties(queue, DdjDeviceExecutionQueueFinish.class);
+
+                    ddjDeviceExecutionQueueServiceFinishService.insertDdjDeviceExecutionQueueFinish(queueFinish);
+
+                    ddjDeviceExecutionQueueService.deleteDdjDeviceExecutionQueueByTaskNo(mydoJob.getTaskNo());
+
+                    log.info("【人工操作】移除堆垛机队列，wcs任务号:{}", mydoJob.getTaskNo());
+                }
+            } catch (Exception e) {
+
+            }
+
         }
 
         return AjaxResult.success("操作成功");