添加事务回滚

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/callEmpty/FjCallEmptyVehicleTask.java

@@ -21,6 +21,7 @@ import org.nl.wms.sch.tasks.PointUpdateUtil;
 import org.nl.wms.util.IdUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -78,7 +79,8 @@ public class FjCallEmptyVehicleTask extends AbstractAcsTask {
      * @created 2019年4月17日 下午8:51:50
      */
     @Override
-        public void updateTaskStatus(JSONObject task, String status) {
+    @Transactional(rollbackFor = Exception.class)
+    public void updateTaskStatus(JSONObject task, String status) {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");
         WQLObject pointTab = WQLObject.getWQLObject("sch_base_point");
         WQLObject regionIoTab = WQLObject.getWQLObject("st_ivt_regionIO");
@@ -161,6 +163,7 @@ public class FjCallEmptyVehicleTask extends AbstractAcsTask {
      * @return 返回任务标识
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String createTask(JSONObject form) {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task"); // 任务表
         WQLObject workOrderTab = WQLObject.getWQLObject("PDM_BD_WorkOrder"); // 生产工单表
@@ -206,6 +209,7 @@ public class FjCallEmptyVehicleTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:30
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findStartPoint() {
         // 先找包装暂存区是否有半满托的，没有就呼叫空的木托盘
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task"); // 任务表

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/callEmpty/YzjCallEmptyVehicleTask.java

@@ -164,6 +164,7 @@ public class YzjCallEmptyVehicleTask extends AbstractAcsTask {
      * @return 返回任务标识
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String createTask(JSONObject form) {
         /*
          * 1.先生成确定终点的任务
@@ -215,6 +216,7 @@ public class YzjCallEmptyVehicleTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:30
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findStartPoint() {
         // 找托盘：先找库存上是否有半满托盘，如果没有就到KGTDDW05找空钢托盘
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task"); // 任务表

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/sendEmpty/FjSendEmpVehicleTask.java

@@ -21,6 +21,7 @@ import org.nl.wms.sch.manage.TaskStatusEnum;
 import org.nl.wms.sch.manage.UpdateTaskStatusEnum;
 import org.nl.wms.sch.tasks.AcsTaskDto;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -75,6 +76,7 @@ public class FjSendEmpVehicleTask extends AbstractAcsTask {
      * @created 2019年4月17日 下午8:51:50
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateTaskStatus(JSONObject task, String status) {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");
         WQLObject pointTab = WQLObject.getWQLObject("sch_base_point");
@@ -128,6 +130,7 @@ public class FjSendEmpVehicleTask extends AbstractAcsTask {
      * @return 返回任务标识
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String createTask(JSONObject form) {
         // 送到叠盘区：KGTDTW01
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task"); // 任务表
@@ -162,6 +165,7 @@ public class FjSendEmpVehicleTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:06
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findNextPoint() {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");
         WQLObject pointTab = WQLObject.getWQLObject("sch_base_point");

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/sendEmpty/YzjSendEmpVehicleTask.java

@@ -22,6 +22,7 @@ import org.nl.wms.sch.manage.UpdateTaskStatusEnum;
 import org.nl.wms.sch.tasks.AcsTaskDto;
 import org.nl.wms.sch.tasks.PointUpdateUtil;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -76,6 +77,7 @@ public class YzjSendEmpVehicleTask extends AbstractAcsTask {
      * @created 2019年4月17日 下午8:51:50
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateTaskStatus(JSONObject taskObj, String status) {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");
         WQLObject pointTab = WQLObject.getWQLObject("sch_base_point");
@@ -131,6 +133,7 @@ public class YzjSendEmpVehicleTask extends AbstractAcsTask {
      * @return 返回任务标识
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String createTask(JSONObject form) {
         /*
          * 1.先生成确定起点的任务
@@ -165,6 +168,7 @@ public class YzjSendEmpVehicleTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:06
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findNextPoint() {
         /*
          * 根据业务找对应的终点

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/sendMaterial/HnSendMaterialTask.java

@@ -75,6 +75,7 @@ public class HnSendMaterialTask extends AbstractAcsTask {
      * @created 2019年4月17日 下午8:51:50
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateTaskStatus(JSONObject task, String status) {
         /**
          * 工单没有载具类型，混碾下料根据工单新旧物料区分。
@@ -235,6 +236,7 @@ public class HnSendMaterialTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:06
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findNextPoint() {
         /**
          * 根据业务找到相应的终点

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/sendMaterial/SzSendMaterialTask.java

@@ -169,6 +169,7 @@ public class SzSendMaterialTask extends AbstractAcsTask {
      * 压制机送料入窑缓存货架
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String createTask(JSONObject form) {
         String point_code1 = form.getString("point_code1");
         String vehicle_code = form.getString("vehicle_code");
@@ -213,6 +214,7 @@ public class SzSendMaterialTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:06
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findNextPoint() {
         // 查找出窑缓存货架
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");

lms/nladmin-system/src/main/java/org/nl/wms/sch/tasks/sendMaterial/YzjSendMaterialTask.java

@@ -73,6 +73,7 @@ public class YzjSendMaterialTask extends AbstractAcsTask {
      * @created 2019年4月17日 下午8:51:50
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateTaskStatus(JSONObject task, String status) {
         WQLObject taskTab = WQLObject.getWQLObject("SCH_BASE_Task");
         WQLObject pointTab = WQLObject.getWQLObject("sch_base_point");
@@ -227,6 +228,7 @@ public class YzjSendMaterialTask extends AbstractAcsTask {
      * @created 2020年6月12日 下午6:01:06
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void findNextPoint() {
         /**
          * 根据业务找到相应的终点