From d8d69911bfc7cbc1b86834aa6fb5ddbba2801b2b Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 08 七月 2020 12:26:29 +0800
Subject: [PATCH] 优化事务处理完成
---
java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java | 22 ++++++++++++----------
1 files changed, 12 insertions(+), 10 deletions(-)
diff --git a/java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java b/java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java
index 1e583e9..46f1c1e 100644
--- a/java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java
+++ b/java110-core/src/main/java/com/java110/core/aop/Java110TransactionalAop.java
@@ -1,14 +1,14 @@
package com.java110.core.aop;
import com.java110.core.factory.Java110TransactionalFactory;
+import com.java110.dto.BusinessDto;
import com.java110.dto.order.OrderDto;
+import com.java110.utils.constant.CommonConstant;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
@@ -51,19 +51,19 @@
while (headerNames.hasMoreElements()) {
String key = (String) headerNames.nextElement();
String value = request.getHeader(key);
- if (OrderDto.APP_ID.equals(key.toUpperCase())) {
+ if (CommonConstant.APP_ID.equals(key)) {
orderDto.setAppId(value);
}
- if (OrderDto.TRANSACTION_ID.equals(key.toUpperCase())) {
+ if (CommonConstant.TRANSACTION_ID.equals(key)) {
orderDto.setExtTransactionId(value);
}
- if (OrderDto.REQUEST_TIME.equals(key.toUpperCase())) {
+ if (CommonConstant.REQUEST_TIME.equals(key)) {
orderDto.setRequestTime(value);
}
- if (OrderDto.O_ID.equals(key.toUpperCase())) {
+ if (OrderDto.O_ID.equals(key)) {
orderDto.setoId(value);
}
- if (OrderDto.USER_ID.equals(key.toUpperCase())) {
+ if (CommonConstant.USER_ID.equals(key)) {
orderDto.setUserId(value);
}
}
@@ -95,9 +95,10 @@
//鐜粫閫氱煡,鐜粫澧炲己锛岀浉褰撲簬MethodInterceptor
@Around("dataProcess()")
- public Object around(ProceedingJoinPoint pjp) {
+ public Object around(ProceedingJoinPoint pjp) throws Throwable {
+ Object o = null;
try {
- Object o = pjp.proceed();
+ o = pjp.proceed();
//瑙傚療鑰呬笉鍋氬鐞�
if (Java110TransactionalFactory.ROLE_OBSERVER.equals(Java110TransactionalFactory.getServiceRole())) {
return o;
@@ -109,7 +110,8 @@
logger.error("鎵ц鏂规硶寮傚父", e);
//鍥為��浜嬪姟
Java110TransactionalFactory.fallbackOId();
- return new ResponseEntity("鍐呴儴寮傚父" + e.getLocalizedMessage(), HttpStatus.BAD_REQUEST);
+ //return new BusinessDto(BusinessDto.CODE_ERROR, "鍐呴儴寮傚父" + e.getLocalizedMessage());
+ throw e;
}
}
}
--
Gitblit v1.8.0