test/Raincat
1
0
Fork 0
mirror of https://gitee.com/dromara/Raincat.git synced 2024-11-29 18:38:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

try catch log

Browse Source
This commit is contained in:
Administrator 2018-08-24 10:46:16 +08:00
parent 1d86772916
commit 23725c3471
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
raincat-springcloud/src/main/java/com/raincat/springcloud/interceptor/SpringCloudTxTransactionInterceptor.java
View File

@ -19,12 +19,14 @@
package com.raincat.springcloud.interceptor;
import com.raincat.common.constant.CommonConstant;
import com.raincat.common.holder.LogUtil;
import com.raincat.core.concurrent.threadlocal.CompensationLocal;
import com.raincat.core.interceptor.TxTransactionInterceptor;
import com.raincat.core.service.AspectTransactionService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestAttributes;
@ -39,9 +41,10 @@ import javax.servlet.http.HttpServletRequest;
* @author xiaoyu
*/
@Component
@Slf4j
public class SpringCloudTxTransactionInterceptor implements TxTransactionInterceptor {
private static final Logger LOGGER = LoggerFactory.getLogger(SpringCloudTxTransactionInterceptor.class);
private final AspectTransactionService aspectTransactionService;
@Autowired
@ -57,10 +60,10 @@ public class SpringCloudTxTransactionInterceptor implements TxTransactionInterce
//如果不是本地反射调用补偿
try {
RequestAttributes requestAttributes = RequestContextHolder.currentRequestAttributes();
HttpServletRequest request = requestAttributes == null ? null : ((ServletRequestAttributes) requestAttributes).getRequest();
groupId = request == null ? null : request.getHeader(CommonConstant.TX_TRANSACTION_GROUP);
HttpServletRequest request = ((ServletRequestAttributes) requestAttributes).getRequest();
groupId = request.getHeader(CommonConstant.TX_TRANSACTION_GROUP);
} catch (IllegalStateException e) {
log.error("Not Http request ,can't get RequestContextHolder!", e);
LogUtil.error(LOGGER,"Not Http request ,can't get RequestContextHolder!", e::getMessage);
}
}
return aspectTransactionService.invoke(groupId, pjp);