opt:修改线程影响的任务锁

lms/nladmin-system/src/main/java/org/nl/b_lms/pdm/subpackagerelation/service/impl/PdmBiSubpackagerelationServiceImpl.java

@@ -360,11 +360,11 @@ public class PdmBiSubpackagerelationServiceImpl extends ServiceImpl<PdmBiSubpack
         boxInfo.put("device_code", deviceCode);
         boxInfo.put("material_code", boxType);
         boxInfo.put("num", workIdList.size());
-        //String boxSn = outBoxManageService.outBox(boxInfo);
+        String boxSn = outBoxManageService.outBox(boxInfo);
         stopWatch.stop();
         System.out.println("木箱出库代码执行花费时间------------------------------------------------------------------------------------------*************************************************************************************************= totalTime = " + stopWatch.getTotalTimeMillis());
         log.info("木箱出库代码执行花费时间------------------------------------------------------------------------------------------*************************************************************************************************= totalTime = " + stopWatch.getTotalTimeMillis());
-        String boxSn = "MX230118000013";
+        //String boxSn = "MX230118000013";
         StopWatch stopWatch1 = new StopWatch();
         stopWatch1.start();
         //更新及子卷包装状态已分配规格及木箱规格组
@@ -866,7 +866,8 @@ public class PdmBiSubpackagerelationServiceImpl extends ServiceImpl<PdmBiSubpack
         stopWatch.stop();
         System.out.println("木箱出库代码执行花费时间------------------------------------------------------------------------------------------*************************************************************************************************= totalTime = " + stopWatch.getTotalTimeMillis());
         log.info("木箱出库代码执行花费时间------------------------------------------------------------------------------------------*************************************************************************************************= totalTime = " + stopWatch.getTotalTimeMillis());
-        //String boxSn = "MX240703000118";
+        //空木箱出库测试
+        //String boxSn = "33333";
         StopWatch stopWatch1 = new StopWatch();
         stopWatch1.start();
         //更新及子卷包装状态已分配规格及木箱规格组

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoExecuteWaitTask.java

@@ -3,6 +3,7 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
@@ -15,19 +16,25 @@ import org.nl.b_lms.storage_manage.ios.enums.IOSEnum;
 import org.nl.common.enums.PackageInfoIvtEnum;
 import org.nl.modules.common.exception.BadRequestException;
 import org.nl.wms.sch.manage.TaskStatusEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 
 @Slf4j
 @Component
 @RequiredArgsConstructor
 public class AutoExecuteWaitTask {
+    private final String THIS_CLASS = AutoExecuteWaitTask.class.getName();
 
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private MzhcwTask mzhcwTask;
 
@@ -47,13 +54,18 @@ public class AutoExecuteWaitTask {
     /**
      * 放满与取空桁架任务
      */
-    void executeWaitTask() {
+    @SneakyThrows
+    public void executeWaitTask() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
+        try {
+            if (tryLock) {
                 List<SchBaseTask> taskList = taskService.list(
                         new LambdaQueryWrapper<SchBaseTask>()
                                 .or(r -> r.eq(SchBaseTask::getTask_status, TaskStatusEnum.SURE_END.getCode())
-                                .and(w -> w.eq(SchBaseTask::getTask_type, PackageInfoIvtEnum.TASK_TYPE.code("放空(空载具缓存位->输送线)"))))
+                                        .and(w -> w.eq(SchBaseTask::getTask_type, PackageInfoIvtEnum.TASK_TYPE.code("放空(空载具缓存位->输送线)")).eq(SchBaseTask::getIs_delete, IOSEnum.IS_NOTANDYES.code("否"))))
                                 .or(r -> r.eq(SchBaseTask::getTask_status, TaskStatusEnum.SURE_START.getCode())
-                                .and(w -> w.eq(SchBaseTask::getTask_type, PackageInfoIvtEnum.TASK_TYPE.code("输送线->满轴缓存位"))))
+                                        .and(w -> w.eq(SchBaseTask::getTask_type, PackageInfoIvtEnum.TASK_TYPE.code("输送线->满轴缓存位")).eq(SchBaseTask::getIs_delete, IOSEnum.IS_NOTANDYES.code("否"))))
                 );
                 for (SchBaseTask task : taskList) {
                     if (task != null) {
@@ -99,6 +111,14 @@ public class AutoExecuteWaitTask {
                         }
                     }
                 }
+            } else {
+                log.info("放满与取空桁架任务正在创建被锁住。");
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
+        }
     }
 
     //校验相同子卷号的任务

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoSendDjqToGzq.java

@@ -2,16 +2,20 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
 import org.nl.b_lms.sch.point.service.IbstIvtPackageinfoivtService;
 import org.nl.b_lms.sch.tasks.first_floor_area.GzqTask;
 import org.nl.common.enums.PackageInfoIvtEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -20,6 +24,9 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class AutoSendDjqToGzq {
 
+    private final String THIS_CLASS = AutoSendDjqToGzq.class.getName();
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private GzqTask gzqTask;
 
@@ -35,7 +42,12 @@ public class AutoSendDjqToGzq {
     /**
      * 普通任务
      */
-    void sendDjqToGzq() {
+    @SneakyThrows
+    public void sendDjqToGzq() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
+        try {
+            if (tryLock) {
                 //待检区有管制品且过滤未完成任务
                 List<BstIvtPackageinfoivt> djqPackageinfoivtList = packageinfoivtService.checkEndPointTask(PackageInfoIvtEnum.POINT_STATUS.code("待检区"), PackageInfoIvtEnum.IVT_STATUS.code("管制品"), PackageInfoIvtEnum.TASK_POINT_TYPE.code("取货任务"), PackageInfoIvtEnum.SORT_TYPE.code("升序"), "");
                 if (CollectionUtils.isEmpty(djqPackageinfoivtList)) {
@@ -52,6 +64,14 @@ public class AutoSendDjqToGzq {
                 task.put("point_code1", djqPackageinfoivtList.get(0).getPoint_code());
                 task.put("point_code2", gzqPackageinfoivtList.get(0).getPoint_code());
                 gzqTask.createTask(task);
+            } else {
+                log.info("放满与取空桁架任务正在创建被锁住。");
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
+        }
     }
 
 

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoSendGzqToDjq.java

@@ -2,16 +2,20 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
 import org.nl.b_lms.sch.point.service.IbstIvtPackageinfoivtService;
 import org.nl.b_lms.sch.tasks.first_floor_area.DjqTask;
 import org.nl.common.enums.PackageInfoIvtEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -20,6 +24,9 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class AutoSendGzqToDjq {
 
+    private final String THIS_CLASS = AutoSendGzqToDjq.class.getName();
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private DjqTask djqTask;
 
@@ -35,8 +42,12 @@ public class AutoSendGzqToDjq {
     /**
      * 普通任务
      */
-
+    @SneakyThrows
-    void sendGzqToDjq() {
+    public void sendGzqToDjq() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
+        try {
+            if (tryLock) {
                 //管制区有合格品且过滤未完成任务
                 List<BstIvtPackageinfoivt> gzqPackageinfoivtList = packageinfoivtService.checkEndPointTask(PackageInfoIvtEnum.POINT_STATUS.code("管制区"), PackageInfoIvtEnum.IVT_STATUS.code("合格品"), PackageInfoIvtEnum.TASK_POINT_TYPE.code("取货任务"), PackageInfoIvtEnum.SORT_TYPE.code("降序"), "");
                 if (CollectionUtils.isEmpty(gzqPackageinfoivtList)) {
@@ -53,6 +64,14 @@ public class AutoSendGzqToDjq {
                 task.put("point_code1", gzqPackageinfoivtList.get(0).getPoint_code());
                 task.put("point_code2", djqPackageinfoivtList.get(0).getPoint_code());
                 djqTask.createTask(task);
+            } else {
+                log.info("放满与取空桁架任务正在创建被锁住。");
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
+        }
     }
 
 

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoSendMzToDjq.java

@@ -2,16 +2,20 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
 import org.nl.b_lms.sch.point.service.IbstIvtPackageinfoivtService;
 import org.nl.b_lms.sch.tasks.first_floor_area.DjqTask;
 import org.nl.common.enums.PackageInfoIvtEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -20,6 +24,9 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class AutoSendMzToDjq {
 
+    private final String THIS_CLASS = AutoSendMzToDjq.class.getName();
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private DjqTask djqTask;
 
@@ -52,8 +59,13 @@ public class AutoSendMzToDjq {
         djqTask.createTask(toDjqTask);
 
     }
-    void sendMzqToDjq2() {
+
+    @SneakyThrows
+    public void sendMzqToDjq2() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
         try {
+            if (tryLock) {
                 String pointCode2 = null;
                 JSONObject task = new JSONObject();
                 //满轴有子卷且过滤未完成任务
@@ -74,9 +86,13 @@ public class AutoSendMzToDjq {
                 task.put("point_code3", mzqPackageinfoivtList.get(0).getPoint_code());
                 task.put("point_code2", pointCode2);
                 djqTask.createTask(task);
-
+            } else {
-        } catch (Exception ex) {
+                log.info("满轴->待检区agv自动搬运任务正在创建被锁住。");
-            log.error("sendMzqToDjq1 error:{}", ex.getMessage());
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
         }
 
     }

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoSendVehicleToDjq.java

@@ -2,19 +2,21 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
 import org.nl.b_lms.sch.point.service.IbstIvtPackageinfoivtService;
-import org.nl.b_lms.sch.tasks.first_floor_area.DjqToKzjhcwTask;
-import org.nl.b_lms.sch.tasks.first_floor_area.GzqToKzjhcwTask;
 import org.nl.b_lms.sch.tasks.first_floor_area.SendDjqKzjTask;
 import org.nl.b_lms.sch.tasks.first_floor_area.SendGzqKzjTask;
 import org.nl.common.enums.PackageInfoIvtEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -22,7 +24,9 @@ import java.util.stream.Collectors;
 @Component
 @RequiredArgsConstructor
 public class AutoSendVehicleToDjq {
-
+    private final String THIS_CLASS = AutoSendVehicleToDjq.class.getName();
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private SendDjqKzjTask sendDjqKzjTask;
     @Resource
@@ -37,8 +41,12 @@ public class AutoSendVehicleToDjq {
         this.sendVehicleToDjqOrGzq1();
     }
 
-
+    @SneakyThrows
     public void sendVehicleToDjqOrGzq1() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
+        try {
+            if (tryLock) {
                 //存在装箱区有空载具的点位
                 String pointCode2 = null;
                 JSONObject task = new JSONObject();
@@ -71,6 +79,14 @@ public class AutoSendVehicleToDjq {
                         sendGzqKzjTask.createTask(task);
                     }
                 }
+            } else {
+                log.info("装箱区->待检区或管制区补空载具任务正在创建被锁住。");
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
+        }
     }
 
 

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/AutoSendVehicleToKzj.java

@@ -2,6 +2,7 @@ package org.nl.b_lms.sch.tasks.first_floor_area.auto;
 
 import com.alibaba.fastjson.JSONObject;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.nl.b_lms.sch.point.dao.BstIvtPackageinfoivt;
@@ -9,14 +10,15 @@ import org.nl.b_lms.sch.point.service.IbstIvtPackageinfoivtService;
 import org.nl.b_lms.sch.tasks.first_floor_area.DjqToKzjhcwTask;
 import org.nl.b_lms.sch.tasks.first_floor_area.GzqToKzjhcwTask;
 import org.nl.common.enums.PackageInfoIvtEnum;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -25,6 +27,9 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class AutoSendVehicleToKzj {
 
+    private final String THIS_CLASS = AutoSendVehicleToKzj.class.getName();
+    @Resource
+    private RedissonClient redissonClient;
     @Resource
     private DjqToKzjhcwTask djqToKzjhcwTask;
     @Resource
@@ -39,6 +44,7 @@ public class AutoSendVehicleToKzj {
     }
 
 
+    @SneakyThrows
     public void toKzjHcw() {
         //存在空载具缓存位无空载具的点位
         List<BstIvtPackageinfoivt> kzjIvtList = packageinfoivtService.checkEndPointTask(PackageInfoIvtEnum.POINT_STATUS.code("空载具缓存位"), PackageInfoIvtEnum.IVT_STATUS.code("空"), PackageInfoIvtEnum.TASK_POINT_TYPE.code("放货任务"), PackageInfoIvtEnum.SORT_TYPE.code("降序"), "");
@@ -72,7 +78,12 @@ public class AutoSendVehicleToKzj {
     /**
      * 二次分配任务
      */
+    @SneakyThrows
     public void toKzjHcw2() {
+        RLock lock = redissonClient.getLock(THIS_CLASS);
+        boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
+        try {
+            if (tryLock) {
                 //存在空载具缓存位无空载具的点位
                 String pointCode1 = null;
                 JSONObject task = new JSONObject();
@@ -121,6 +132,14 @@ public class AutoSendVehicleToKzj {
                         gzqToKzjhcwTask.createTask(task);
                     }
                 }
+            } else {
+                log.info("待检区或管制区->空载具缓存位补空任务正在创建被锁住。");
+            }
+        } finally {
+            if (tryLock) {
+                lock.unlock();
+            }
+        }
     }
 
     /**

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/ManualSendToZxq.java

@@ -33,7 +33,7 @@ public class ManualSendToZxq {
     /**
      * 普通任务
      */
-    void sendDjqToZxq() {
+    public  void sendDjqToZxq() {
         JSONObject toDjqTask = new JSONObject();
         //待检区有子卷且过滤未完成任务
         List<BstIvtPackageinfoivt> djqPackageinfoivtList = packageinfoivtService.checkEndPointTask(PackageInfoIvtEnum.POINT_STATUS.code("待检区"), PackageInfoIvtEnum.IVT_STATUS.code("合格品"), PackageInfoIvtEnum.TASK_POINT_TYPE.code("取货任务"), "", "");

lms/nladmin-system/src/main/java/org/nl/b_lms/sch/tasks/first_floor_area/auto/TaskQueue.java

@@ -8,6 +8,7 @@ import org.nl.b_lms.pdm.subpackagerelation.dao.mapper.PdmBiSubpackagerelationMap
 import org.nl.b_lms.sch.task.dao.SchBaseTask;
 import org.nl.b_lms.sch.task.service.IschBaseTaskService;
 import org.nl.b_lms.sch.tasks.first_floor_area.ZxqTask;
+import org.nl.b_lms.storage_manage.ios.enums.IOSEnum;
 import org.nl.modules.common.utils.RedisUtils;
 import org.nl.wms.sch.manage.TaskStatusEnum;
 import org.springframework.stereotype.Service;
@@ -61,10 +62,15 @@ public class TaskQueue {
 
     private void executeTask(SchBaseTask task, String pointCode) {
         if (task != null) {
+            List<SchBaseTask> taskList = taskService.list(new LambdaQueryWrapper<SchBaseTask>().eq(SchBaseTask::getTask_id, task.getTask_id())
+                    .eq(SchBaseTask::getIs_delete, IOSEnum.IS_NOTANDYES.code("否")).lt(SchBaseTask::getTask_status, TaskStatusEnum.FINISHED.getCode()));
+            //被取消或删除的任务不再执行
+            //if (CollectionUtils.isEmpty(taskList)) {
             task.setPoint_code2(pointCode);
             task.setTask_status(TaskStatusEnum.START_AND_POINT.getCode());
             taskService.updateById(task);
             zxqTask.immediateNotifyAcs(null);
+            //}
             //同步删除子卷包装关系
             LambdaQueryWrapper<PdmBiSubpackagerelation> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.eq(PdmBiSubpackagerelation::getContainer_name, task.getVehicle_code());