From 6e05d25d44bd1fa1bab3806e5f2f33d9076664b5 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 31 五月 2024 11:17:42 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/OrderLogHandler.java |   86 ++++++++++++++++++++++++------------------
 1 files changed, 49 insertions(+), 37 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/OrderLogHandler.java b/src/main/java/com/zy/asrs/task/handler/OrderLogHandler.java
index 5abd9df..5f645b2 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderLogHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderLogHandler.java
@@ -1,48 +1,60 @@
 package com.zy.asrs.task.handler;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.zy.asrs.entity.Order;
+import com.zy.asrs.entity.OrderDetl;
+import com.zy.asrs.service.OrderDetlLogService;
+import com.zy.asrs.service.OrderDetlService;
+import com.zy.asrs.service.OrderLogService;
+import com.zy.asrs.service.OrderService;
 import com.zy.asrs.task.AbstractHandler;
+import com.zy.asrs.task.core.ReturnT;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 @Slf4j
 @Service
 public class OrderLogHandler extends AbstractHandler<String> {
-//    @Autowired
-//    private OrderService orderService;
-//    @Autowired
-//    private OrderDetlService orderDetlService;
-//    @Autowired
-//    private OrderLogService orderLogService;
-//    @Autowired
-//    private OrderDetlLogService orderDetlLogService;
-//
-//    @Transactional
-//    public ReturnT<String> start(Order order) {
-//        try {
-//            // 淇濆瓨鍗曟嵁涓绘。鍘嗗彶妗�
-//            if (!orderLogService.save(order.getOrderNo())) {
-//                exceptionHandle("淇濆瓨鍗曟嵁鍘嗗彶妗orderNo={0}]澶辫触", order.getOrderNo());
-//            }
-//            // 鍒犻櫎鍗曟嵁涓绘。
-//            if (!orderService.deleteById(order)) {
-//                exceptionHandle("鍒犻櫎鍗曟嵁涓绘。[orderNo={0}]澶辫触", order.getOrderNo());
-//            }
-//            // 淇濆瓨鍗曟嵁鏄庣粏妗e巻鍙叉。
-//            if (!orderDetlLogService.save(order.getOrderNo())) {
-//                exceptionHandle("淇濆瓨鍗曟嵁鏄庣粏鍘嗗彶妗orderNo={0}]澶辫触", order.getOrderNo());
-//            }
-//            // 鍒犻櫎宸ヤ綔鏄庣粏妗�
-//            if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo()))) {
-//                exceptionHandle("鍒犻櫎鍗曟嵁鏄庣粏妗orderNo={0}]澶辫触", order.getOrderNo());
-//            }
-//
-//        } catch (Exception e) {
-//            log.error("fail", e);
-//            e.printStackTrace();
-//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-//            return FAIL.setMsg(e.getMessage());
-//        }
-//        return SUCCESS;
-//    }
+    @Autowired
+    private OrderService orderService;
+    @Autowired
+    private OrderDetlService orderDetlService;
+    @Autowired
+    private OrderLogService orderLogService;
+    @Autowired
+    private OrderDetlLogService orderDetlLogService;
+
+    @Transactional
+    public ReturnT<String> start(Order order) {
+        try {
+            // 淇濆瓨鍗曟嵁涓绘。鍘嗗彶妗�
+            if (!orderLogService.save(order.getOrderNo())) {
+                exceptionHandle("淇濆瓨鍗曟嵁鍘嗗彶妗orderNo={0}]澶辫触", order.getOrderNo());
+            }
+            // 鍒犻櫎鍗曟嵁涓绘。
+            if (!orderService.deleteById(order)) {
+                exceptionHandle("鍒犻櫎鍗曟嵁涓绘。[orderNo={0}]澶辫触", order.getOrderNo());
+            }
+            // 淇濆瓨鍗曟嵁鏄庣粏妗e巻鍙叉。
+            if (!orderDetlLogService.save(order.getOrderNo())) {
+                exceptionHandle("淇濆瓨鍗曟嵁鏄庣粏鍘嗗彶妗orderNo={0}]澶辫触", order.getOrderNo());
+            }
+            // 鍒犻櫎宸ヤ綔鏄庣粏妗�
+            if (!orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo()))) {
+                exceptionHandle("鍒犻櫎鍗曟嵁鏄庣粏妗orderNo={0}]澶辫触", order.getOrderNo());
+            }
+
+        } catch (Exception e) {
+            log.error("fail", e);
+            e.printStackTrace();
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            return FAIL.setMsg(e.getMessage());
+        }
+        return SUCCESS;
+    }
 
 }
 

--
Gitblit v1.9.1