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