From f4dce5ee5312f6e7146fb25257dd1e8b6c5bedf8 Mon Sep 17 00:00:00 2001
From: ls <1793460677@qq.com>
Date: Mon, 9 Jun 2025 10:29:26 +0800
Subject: [PATCH] =?UTF-8?q?add=EF=BC=9A=20=E5=8A=9F=E8=83=BD=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../agv/ndctwo/AgvNdcTwoDeviceDriver.java          |  4 ++--
 .../mps/service/impl/SlitterPdaServiceImpl.java    |  7 +++++++
 .../sch/point/service/ISchBasePointService.java    |  2 ++
 .../service/dao/mapper/SchBasePointMapper.java     |  3 +++
 .../service/dao/mapper/SchBasePointMapper.xml      | 14 ++++++++++++++
 .../service/impl/SchBasePointServiceImpl.java      |  5 +++++
 .../wms/sch/task/service/ISchBaseTaskService.java  |  7 +++++++
 .../task/service/impl/SchBaseTaskServiceImpl.java  | 12 ++++++++++++
 .../tasks/hot/InHotDockingTrussTask.java           |  2 +-
 .../tasks/hot/OutHotToDockingTrussTask.java        |  2 +-
 .../tasks/slitter/SlitterUpAGVTask.java            |  6 ++++++
 .../tasks/slitter/SlitterUpTrussTask.java          |  2 +-
 12 files changed, 61 insertions(+), 5 deletions(-)

diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/agv/ndctwo/AgvNdcTwoDeviceDriver.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/agv/ndctwo/AgvNdcTwoDeviceDriver.java
index 1bd6c5cda..8b2ab1a63 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/agv/ndctwo/AgvNdcTwoDeviceDriver.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/agv/ndctwo/AgvNdcTwoDeviceDriver.java
@@ -1067,7 +1067,7 @@ public class AgvNdcTwoDeviceDriver extends AbstractDeviceDriver implements Devic
                             //收卷锟行架
                             if (linkDevice.getDeviceDriver() instanceof RollUpRollerManipulatorDeviceDriver) {
                                 rollUpRollerManipulatorDeviceDriver = (RollUpRollerManipulatorDeviceDriver) linkDevice.getDeviceDriver();
-                                if ((manipulatorAgvStationDeviceDriver.getAction() == 6 && manipulatorAgvStationDeviceDriver.getMove() == 1 && rollUpRollerManipulatorDeviceDriver.getMode() != 3 && rollUpRollerManipulatorDeviceDriver.getError() == 0 && rollUpRollerManipulatorDeviceDriver.getError2()
+                                if ((manipulatorAgvStationDeviceDriver.getAction() == 6 && manipulatorAgvStationDeviceDriver.getMove() == 1  && rollUpRollerManipulatorDeviceDriver.getError() == 0 && rollUpRollerManipulatorDeviceDriver.getError2()
                                         == 0)) {
                                     data = ndcAgvService.sendAgvTwoModeInst(phase, index, 0, 0, 0);
                                     LuceneLogDto logDto = LuceneLogDto.builder()
@@ -1150,7 +1150,7 @@ public class AgvNdcTwoDeviceDriver extends AbstractDeviceDriver implements Devic
                             //收卷锟行架
                             if (linkDevice.getDeviceDriver() instanceof RollUpRollerManipulatorDeviceDriver) {
                                 rollUpRollerManipulatorDeviceDriver = (RollUpRollerManipulatorDeviceDriver) linkDevice.getDeviceDriver();
-                                if ((manipulatorAgvStationDeviceDriver.getAction() == 6 && rollUpRollerManipulatorDeviceDriver.getMode() != 3 && rollUpRollerManipulatorDeviceDriver.getError() == 0 && rollUpRollerManipulatorDeviceDriver.getTask() == 0 && rollUpRollerManipulatorDeviceDriver.getError2() == 0 && manipulatorAgvStationDeviceDriver.getMove() == 0)) {
+                                if ((manipulatorAgvStationDeviceDriver.getAction() == 6 && rollUpRollerManipulatorDeviceDriver.getError() == 0  && rollUpRollerManipulatorDeviceDriver.getError2() == 0 && manipulatorAgvStationDeviceDriver.getMove() == 0)) {
                                     // 查询缓存架点位状态
                                     JSONObject param = new JSONObject();
                                     param.put("device_code", device_code);
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/service/impl/SlitterPdaServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/service/impl/SlitterPdaServiceImpl.java
index ab8eb210d..47b3cfb02 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/service/impl/SlitterPdaServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/service/impl/SlitterPdaServiceImpl.java
@@ -119,6 +119,13 @@ public class SlitterPdaServiceImpl implements SlitterPdaService {
         if (isTask) {
             throw new BadRequestException("点位[" + pointCode + "、" + zcPoint + "]已经创建过任务！");
         }
+        //校验分切上料任务数
+        Boolean isTask2 = taskService.checkHaveTaskByPointsType();
+        // 判断是否呼叫过任务
+        if (isTask2) {
+            throw new BadRequestException("分切上料最大任务数为2条");
+        }
+
 
         SchBasePoint zcPointObj = pointService.getById(zcPoint);
         StIvtHotpointivt hotpointivt = hotpointivtService.getPointByCode(zcPoint, false);
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/ISchBasePointService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/ISchBasePointService.java
index 73637cecc..3c9dfa5a8 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/ISchBasePointService.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/ISchBasePointService.java
@@ -99,6 +99,8 @@ public interface ISchBasePointService extends IService<SchBasePoint> {
      */
     List<SchBasePoint> getHotNotTaskPoint(String area, String region, String pointType, String pointStatus);
 
+    List<SchBasePoint> getHotNotTaskPoint2(String area, String region, String pointType, String pointStatus);
+
     /**
      * 从点位查找以下条件可用的没任务点位
      * @param area 生产区域
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java
index dab0eaba0..9297675fc 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.java
@@ -35,6 +35,9 @@ public interface SchBasePointMapper extends BaseMapper<SchBasePoint> {
      */
     List<SchBasePoint> getHotNotTaskPoint(String area, String region, String pointType, String pointStatus);
 
+    List<SchBasePoint> getHotNotTaskPoint2(String area, String region, String pointType, String pointStatus);
+
+
     List<SchBasePoint> getAllBusinessNotTaskPoint(String area, String region, String pointType, String pointStatus,
                                                   String vehicleType, String vehicleCode);
 
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml
index 7c83649fe..764e539a3 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/dao/mapper/SchBasePointMapper.xml
@@ -39,6 +39,20 @@
           AND 0 = (SELECT COUNT(*) FROM sch_base_task t WHERE t.task_status <![CDATA[<]]> '07'
           AND (t.point_code1 = p.point_code OR t.point_code2 = p.point_code OR t.point_code4 = p.point_code))
     </select>
+    <select id="getHotNotTaskPoint2" resultType="org.nl.wms.sch.point.service.dao.SchBasePoint">
+        SELECT p.*
+        FROM sch_base_point p
+        WHERE p.product_area = #{area}
+        AND p.region_code = #{region}
+        <if test="pointType != null">
+            AND p.point_type = #{pointType}
+        </if>
+        AND p.point_status = #{pointStatus}
+        AND p.is_used = TRUE
+        AND 0 = (SELECT COUNT(*) FROM sch_base_task t WHERE  t.task_status <![CDATA[<]]> '071' and t.task_status <![CDATA[<>]]> '07'
+        AND (t.point_code1 = p.point_code OR t.point_code2 = p.point_code OR t.point_code4 = p.point_code))
+    </select>
+
     <select id="getAllBusinessNotTaskPoint" resultType="org.nl.wms.sch.point.service.dao.SchBasePoint">
         SELECT p.*
         FROM sch_base_point p
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java
index 62650acb9..23c88c627 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/point/service/impl/SchBasePointServiceImpl.java
@@ -229,6 +229,11 @@ public class SchBasePointServiceImpl extends ServiceImpl<SchBasePointMapper, Sch
         return pointMapper.getHotNotTaskPoint(area, region, pointType, pointStatus);
     }
 
+    @Override
+    public List<SchBasePoint> getHotNotTaskPoint2(String area, String region, String pointType, String pointStatus) {
+        return pointMapper.getHotNotTaskPoint2(area, region, pointType, pointStatus);
+    }
+
     @Override
     public List<SchBasePoint> getAllBusinessNotTaskPoint(String area, String region, String pointType,
                                                          String pointStatus, String vehicleType, String vehicleCode) {
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java
index d3b9260c0..35991eda3 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/ISchBaseTaskService.java
@@ -162,6 +162,13 @@ public interface ISchBaseTaskService extends IService<SchBaseTask> {
      */
     Boolean checkHaveTaskByPoints(List<String> collect);
 
+    /**
+     * 判断是否存在任务
+     *
+     * @return /
+     */
+    Boolean checkHaveTaskByPointsType();
+
     /**
      * 获取同配置、状态的任务
      * @param configCode 配置
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java
index f94370d7c..3fc83c5ec 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task/service/impl/SchBaseTaskServiceImpl.java
@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.lang.Assert;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -287,6 +288,17 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa
         return list.size() > 0;
     }
 
+    @Override
+    public Boolean checkHaveTaskByPointsType() {
+
+        LambdaQueryWrapper<SchBaseTask> lam = new QueryWrapper<SchBaseTask>().lambda();
+        lam.eq(SchBaseTask::getIs_delete, "0")
+                .lt(SchBaseTask::getTask_status, TaskStatus.FINISHED.getCode())
+                .eq(SchBaseTask::getConfig_code,"SlitterUpTrussTask");
+        List<SchBaseTask> list = list(lam);
+        return list.size() >= 2;
+    }
+
     @Override
     public List<SchBaseTask> getTaskByConfigAndStatus(String configCode, String status) {
         LambdaQueryWrapper<SchBaseTask> lam = new QueryWrapper<SchBaseTask>().lambda();
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/InHotDockingTrussTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/InHotDockingTrussTask.java
index 65a52732d..ba0b522f5 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/InHotDockingTrussTask.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/InHotDockingTrussTask.java
@@ -50,7 +50,7 @@ public class InHotDockingTrussTask extends AbstractTask {
     public void createCompletion(SchBaseTask task) {
         TaskUtils.taskLock(RegionConstant.REGION_A1_HXZC + "5", () -> {
             // 找个对接位（状态是空的，没有任务的）
-            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint(RegionConstant.A1, RegionConstant.REGION_A1_HXZC,
+            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint2(RegionConstant.A1, RegionConstant.REGION_A1_HXZC,
                     POINT_TYPE_HOT_DOCKING, POINT_STATUS_EMPTY);
             if (endPoints.size() == 0) {
                 throw new BadRequestException("没有可用的烘箱对接位！");
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/OutHotToDockingTrussTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/OutHotToDockingTrussTask.java
index 7d205dff9..3c0b16dcc 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/OutHotToDockingTrussTask.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/hot/OutHotToDockingTrussTask.java
@@ -55,7 +55,7 @@ public class OutHotToDockingTrussTask extends AbstractTask {
     public void createCompletion(SchBaseTask task) {
         TaskUtils.taskLock(REGION_A1_HXZC + "5", () -> {
             // 从烘箱对接位中找一个空位
-            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint(RegionConstant.A1, RegionConstant.REGION_A1_HXZC,
+            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint2(RegionConstant.A1, RegionConstant.REGION_A1_HXZC,
                     POINT_TYPE_HOT_DOCKING, POINT_STATUS_EMPTY);
             if (endPoints.size() == 0) {
                 throw new BadRequestException("没有可用的烘箱对接位！");
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpAGVTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpAGVTask.java
index a1ffbc32f..23b9d9868 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpAGVTask.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpAGVTask.java
@@ -165,6 +165,12 @@ public class SlitterUpAGVTask extends AbstractTask {
                 .set(SchBaseTask::getUpdate_time, DateUtil.now())
                 .eq(SchBaseTask::getTask_code, task.getTask_code());
         boolean update = taskService.update(lam);
+        String pointCode1 = task.getPoint_code1();
+        SchBasePoint point1 = pointService.query().eq("point_code", pointCode1).one();
+        point1.setPoint_status("1");
+        pointService.updateById(point1);
+
+
         log.info("任务[{}]取货完成执行{}", task.getTask_code(), update);
     }
 }
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpTrussTask.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpTrussTask.java
index abe13942c..c0a679798 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpTrussTask.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch/task_manage/tasks/slitter/SlitterUpTrussTask.java
@@ -67,7 +67,7 @@ public class SlitterUpTrussTask extends AbstractTask {
             JSONObject requestObj = JSONObject.parseObject(requestParam);
             String pointCode = requestObj.getString("zc_point");
             // 终点为出口
-            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint("A1", HX_REGION,
+            List<SchBasePoint> endPoints = pointService.getHotNotTaskPoint2("A1", HX_REGION,
                     "5", "1");
             if (endPoints.size() == 0) {
                 throw new BadRequestException("烘箱没有可以用的对接位！");