From 180b27da2a0139ef45c7859edf450163439aa73c Mon Sep 17 00:00:00 2001
From: liuxy <lxy1605052545@163.com>
Date: Wed, 26 Nov 2025 16:42:03 +0800
Subject: [PATCH] =?UTF-8?q?rev=EF=BC=9A=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/SchBasePointServiceImpl.java          | 10 ++--------
 .../wms/sch_manage/service/util/tasks/KwzdInTask.java  | 10 ++++++++++
 2 files changed, 12 insertions(+), 8 deletions(-)

diff --git a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/impl/SchBasePointServiceImpl.java b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/impl/SchBasePointServiceImpl.java
index f59a142..65ceadc 100644
--- a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/impl/SchBasePointServiceImpl.java
+++ b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/impl/SchBasePointServiceImpl.java
@@ -240,10 +240,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
         jsonParam.put("task_type", IOSConstant.ONE);
         jsonParam.put("task_code", taskDao.getTask_code());
         jsonParam.put("point_code", taskDao.getPoint_code2());
-        AcsResponse acsResponse = wmsToAcsService.confirmAgv(jsonParam);
-        if (acsResponse.getStatus() != 200) {
-            throw new BadRequestException(acsResponse.getMessage());
-        }
+        wmsToAcsService.confirmAgv(jsonParam);
     }
 
     @Override
@@ -268,10 +265,7 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
         jsonParam.put("task_type", IOSConstant.TWO);
         jsonParam.put("task_code", taskDao.getTask_code());
         jsonParam.put("point_code", taskDao.getPoint_code1());
-        AcsResponse acsResponse = wmsToAcsService.confirmAgv(jsonParam);
-        if (acsResponse.getStatus() != 200) {
-            throw new BadRequestException(acsResponse.getMessage());
-        }
+        wmsToAcsService.confirmAgv(jsonParam);
     }
 
     @Override
diff --git a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/KwzdInTask.java b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/KwzdInTask.java
index 20876f4..a091f53 100644
--- a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/KwzdInTask.java
+++ b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/KwzdInTask.java
@@ -131,6 +131,7 @@ public class KwzdInTask extends AbstractTask {
         }
         // 根据传来的类型去对任务进行操作
         if (status.equals(TaskStatus.EXECUTING)) {
+            this.executing(taskObj);
             taskObj.setTask_status(TaskStatus.EXECUTING.getCode());
             taskObj.setRemark("执行中");
             taskService.updateById(taskObj);
@@ -238,4 +239,13 @@ public class KwzdInTask extends AbstractTask {
     public JSONObject resultWeigh(SchBaseTask taskObj) {
         return null;
     }
+
+    private void executing(SchBaseTask taskObj) {
+        // 更新起点
+        iSchBasePointService.update(
+                new UpdateWrapper<SchBasePoint>().lambda()
+                        .eq(SchBasePoint::getPoint_code, taskObj.getPoint_code1())
+                        .set(SchBasePoint::getIng_task_code, taskObj.getTask_id())
+        );
+    }
 }