From 252ea6078917a0b035dcc27f1d90d12699d0397d Mon Sep 17 00:00:00 2001
From: liweidong-hj <liweidong-hj@huafang.com>
Date: Wed, 1 Apr 2026 17:20:15 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BB=88=E7=82=B9=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/constant/LauncherConstant.java     |  4 +--
 .../impl/TaskExecuteRecordServiceImpl.java    | 29 ++++++++++++++-----
 2 files changed, 23 insertions(+), 10 deletions(-)

diff --git a/blade-common/src/main/java/org/springblade/common/constant/LauncherConstant.java b/blade-common/src/main/java/org/springblade/common/constant/LauncherConstant.java
index 4dec1f26..bc322eab 100644
--- a/blade-common/src/main/java/org/springblade/common/constant/LauncherConstant.java
+++ b/blade-common/src/main/java/org/springblade/common/constant/LauncherConstant.java
@@ -31,8 +31,8 @@ public interface LauncherConstant {
     /**
      * nacos dev 地址
      */
-//    String NACOS_DEV_ADDR = "192.168.249.27:8848";
-    String NACOS_DEV_ADDR = "127.0.0.1:8848";
+    String NACOS_DEV_ADDR = "192.168.249.27:8848";
+//    String NACOS_DEV_ADDR = "127.0.0.1:8848";
 
     /**R
      * nacos prod 地址
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
index 2c217bb9..b08eec8a 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskExecuteRecordServiceImpl.java
@@ -412,7 +412,7 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
                 return false;
             }
 
-            Station station = stationService.getByStationCode(taskExecuteRecord.getEndPos());
+            Station endStation = stationService.getByStationCode(taskExecuteRecord.getEndPos());
 
             /**
              * 3. 检查是否需要送到库位
@@ -420,20 +420,33 @@ public class TaskExecuteRecordServiceImpl extends BaseServiceImpl<TaskExecuteRec
              * 3.2 执行记录的终点是 站点
              * 3.3 执行记录的终点是 输送线终点
              */
-            if (null == task.getLocationId() || null != station || DROPOFF_CONVEYOR_LINE.equals(taskExecuteRecord.getEndPos())) {
+            if (null == task.getLocationId() || null != endStation || DROPOFF_CONVEYOR_LINE.equals(taskExecuteRecord.getEndPos())) {
                 log.info("任务{}不需要送到库位，直接完成", taskCode);
                 log.info("终点位置为站点信息:{}，直接完成", taskExecuteRecord.getEndPos());
 
-                Station station1 = stationService.getByStationCode(taskExecuteRecord.getStartPos());
+                Station startStation = stationService.getByStationCode(taskExecuteRecord.getStartPos());
                 // 起点位置为站点 将站点状态改为空闲
-                if(null != station1){
-                    station1.setStationStatus(Station.STATUS_FREE);
-                    boolean update = stationService.updateById(station1);
+                if(null != startStation){
+                    startStation.setStationStatus(Station.STATUS_FREE);
+                    boolean update = stationService.updateById(startStation);
                     if (update) {
-                        log.info("站点释放成功：{}", station1.getStationCode());
+                        log.info("站点释放成功：{}", startStation.getStationCode());
                         return true;
                     } else {
-                        log.error("站点释放失败：{}", station1.getStationCode());
+                        log.error("站点释放失败：{}", startStation.getStationCode());
+                        return false;
+                    }
+                }
+
+                // 终点位置为站点将状态修改为占用
+                if(null != endStation){
+                    endStation.setStationStatus(Station.STATUS_OCCUPIED);
+                    boolean update = stationService.updateById(endStation);
+                    if (update) {
+                        log.info("站点释放成功：{}", endStation.getStationCode());
+                        return true;
+                    } else {
+                        log.error("站点释放失败：{}", endStation.getStationCode());
                         return false;
                     }
                 }