From a543291c5c4985c80e58a3ef0e79eafa063d72b9 Mon Sep 17 00:00:00 2001
From: zj <zhangjun@fortucky.cn>
Date: Thu, 22 Jan 2026 17:32:38 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=B7=E6=B1=82=E5=8F=96=E6=B6=88AGV?=
 =?UTF-8?q?=E4=BD=9C=E4=B8=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/api/service/IToWcsService.java  |  2 ++
 .../api/service/impl/ToWcsServiceImpl.java    | 21 +++++++++++++++++++
 .../service/impl/MydoJobServiceImpl.java      | 10 +++++++++
 3 files changed, 33 insertions(+)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/api/service/IToWcsService.java b/ruoyi-admin/src/main/java/com/ruoyi/api/service/IToWcsService.java
index ffb310e..a33eaed 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/api/service/IToWcsService.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/api/service/IToWcsService.java
@@ -40,6 +40,8 @@ public interface IToWcsService {
      */
     AjaxResult cancelTaskByTaskNo(String taskNo);
 
+    AjaxResult cancelRcsTaskBytaskCode(String taskCode);
+
 
     AjaxResult selectWcsPort();
 
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/api/service/impl/ToWcsServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/api/service/impl/ToWcsServiceImpl.java
index e74dffd..47bf194 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/api/service/impl/ToWcsServiceImpl.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/api/service/impl/ToWcsServiceImpl.java
@@ -42,6 +42,9 @@ public class ToWcsServiceImpl implements IToWcsService {
     public static final String SELECT_WCS_PORT = wcsUrl + "/wcs2Wms/api/selectWcsPort";
     public static final String UPDATE_WCS_PORT = wcsUrl + "/wcs2Wms/api/updateWcsPort";
 
+    //@@@
+    public static final String CANCEL_AGV_TASK = wcsUrl + "/agv/api/cancelTask";
+
 
     @Override
     @Scheduled(fixedDelay=1500)
@@ -125,6 +128,24 @@ public class ToWcsServiceImpl implements IToWcsService {
         Map<String,String> map = new HashMap<>();
         map.put("taskNo", taskNo);
         RequestLog requestLog = requestLogService.getRequestLog(CANCEL_MYDOJOB, JSONUtil.toJsonStr(map), "取消任务","wms","wcs");
+
+        //@@@
+        RequestLog requestLog1 = requestLogService.getRequestLog(CANCEL_AGV_TASK, JSONUtil.toJsonStr(map), "取消任务","wms","wcs");
+
+        if ("1".equals(requestLog.getIsSuccessful())){
+            return AjaxResult.success();
+        }
+        return AjaxResult.error(requestLog.getErrorDetails());
+    }
+
+    @Override
+    public AjaxResult cancelRcsTaskBytaskCode(String taskCode) {
+        Map<String,String> map = new HashMap<>();
+        map.put("taskCode", taskCode);
+
+        //@@@
+        RequestLog requestLog = requestLogService.getRequestLog(CANCEL_AGV_TASK, JSONUtil.toJsonStr(map), "取消任务","wms","wcs");
+
         if ("1".equals(requestLog.getIsSuccessful())){
             return AjaxResult.success();
         }
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/job/mydojob/service/impl/MydoJobServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/job/mydojob/service/impl/MydoJobServiceImpl.java
index a3d4fd0..49ff5cf 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/job/mydojob/service/impl/MydoJobServiceImpl.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/job/mydojob/service/impl/MydoJobServiceImpl.java
@@ -199,9 +199,14 @@ public class MydoJobServiceImpl implements IMydoJobService {
             BasCargoSpace basCargoSpace = basCargoSpaceService.selectBasCargoSpaceByCargoSpaceId(job.getCargoSpaceId());
             basCargoSpace.setStatus("1");
             basCargoSpaceService.updateBasCargoSpace(basCargoSpace);
+
+            //@@@
+            iToWcsService.cancelRcsTaskBytaskCode(mydoJob.getJobId());
+
             //插入历史表
             insertHistory(mydoJob.getJobId());
 
+
         } else if ("2".equals(job.getInOrOut())|| "3".equals(job.getInOrOut()) || "5".equals(job.getInOrOut())) {
             MydoJobDetail param = new MydoJobDetail();
             param.setJobId(jobId);
@@ -224,6 +229,10 @@ public class MydoJobServiceImpl implements IMydoJobService {
             mydoJob.setStatus("5");
             mydoJob.setFinishTime(DateUtil.formatDateTime(new Date()));
             updateMydoJob(mydoJob);
+
+            //@@@
+            iToWcsService.cancelRcsTaskBytaskCode(mydoJob.getJobId());
+
             //插入历史表
             insertHistory(mydoJob.getJobId());
         }
@@ -357,6 +366,7 @@ public class MydoJobServiceImpl implements IMydoJobService {
                 transferBillCallback.setSpare3(mydoJobDetails.get(0).getSpec());
                 transferBillCallback.setTrayCode(mydoJob.getTrayCode());
                 transferBillCallbackService.insertTransferBillCallback(transferBillCallback);
+
                 return AjaxResult.success();
             } else {
                 return AjaxResult.warn("不存在子作业");