From d8c49ec782f4f1341f22bc1ac918e59a054fc58d Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期二, 07 七月 2020 09:52:33 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java |   48 ++++++++++++++++++++++++++++--------------------
 1 files changed, 28 insertions(+), 20 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
index 6b8c21f..ec51266 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
@@ -11,12 +11,12 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 /**
  * Created by vincent on 2020/7/6
  */
 @Service
-@Transactional
 public class WorkLogHandler extends AbstractHandler {
 
     @Autowired
@@ -28,27 +28,35 @@
     @Autowired
     private WrkDetlLogService wrkDetlLogService;
 
+    @Transactional
     public void start() {
-        WrkMast wrkMast = wrkMastService.selectToBeHistoryData();
-        if (null == wrkMast) {
-            return;
+        try {
+            WrkMast wrkMast = wrkMastService.selectToBeHistoryData();
+            if (null == wrkMast) {
+                return;
+            }
+            // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
+            if (!wrkMastLogService.save(wrkMast.getWrkNo())) {
+                exceptionHandle(""); // todo
+            }
+            // 鍒犻櫎宸ヤ綔涓绘。
+            if (!wrkMastService.deleteById(wrkMast)) {
+                exceptionHandle(""); // todo
+            }
+            // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
+            if (!wrkDetlLogService.save(wrkMast.getWrkNo())) {
+                exceptionHandle(""); // todo
+            }
+            // 鍒犻櫎宸ヤ綔鏄庣粏妗�
+            if (!wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()))) {
+                exceptionHandle(""); // todo
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            // todo
         }
-        // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
-        if (!wrkMastLogService.save(wrkMast.getWrkNo())) {
-            exceptionHandle(""); // todo
-        }
-        // 鍒犻櫎宸ヤ綔涓绘。
-        if (!wrkMastService.deleteById(wrkMast)) {
-            exceptionHandle(""); // todo
-        }
-        // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
-        if (!wrkDetlLogService.save(wrkMast.getWrkNo())) {
-            exceptionHandle(""); // todo
-        }
-        // 鍒犻櫎宸ヤ綔鏄庣粏妗�
-        if (!wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()))) {
-            exceptionHandle(""); // todo
-        }
+
     }
 
 }

--
Gitblit v1.9.1