jieyuu/xdclass
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

分布式事务异常判断

Browse Source
This commit is contained in:
jieyuu 2024-08-26 15:05:06 +08:00
parent e65a801a62
commit 8b16ce48de
3 changed files with 30 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
xdclass-common/src/main/java/net/jieyuu/exception/CustomExceptionHandle.java
View File

@ -1,28 +1,28 @@
package net.jieyuu.exception; package net.jieyuu.exception;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import net.jieyuu.utils.JsonData; import net.jieyuu.utils.JsonData;
//import org.springframework.web.bind.annotation.ControllerAdvice; import org.springframework.web.bind.annotation.ControllerAdvice;
//import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.ExceptionHandler;
//import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseBody;
//
//@ControllerAdvice @ControllerAdvice
//@Slf4j @Slf4j
//public class CustomExceptionHandle { public class CustomExceptionHandle {
//
// @ExceptionHandler(value = Exception.class) @ExceptionHandler(value = Exception.class)
// @ResponseBody @ResponseBody
// public JsonData Handle(Exception e) { public JsonData Handle(Exception e) {
//
// if (e instanceof BizException) { if (e instanceof BizException) {
// BizException bizException = (BizException) e; BizException bizException = (BizException) e;
// log.info("[业务异常]{}", e); log.info("[业务异常]{}", e);
// return JsonData.buildCodeAndMsg(bizException.getCode(), bizException.getMsg()); return JsonData.buildCodeAndMsg(bizException.getCode(), bizException.getMsg());
//
// } else { } else {
// log.info("[系统异常]{}", e); log.info("[系统异常]{}", e);
// return JsonData.buildError("全局异常，未知错误"); return JsonData.buildError("全局异常，未知错误");
// } }
//
// } }
//} }

2
xdclass-user-service/src/main/java/net/jieyuu/UserServiceApplication.java
View File

@ -7,7 +7,7 @@ import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.transaction.annotation.EnableTransactionManagement; import org.springframework.transaction.annotation.EnableTransactionManagement;
@EnableFeignClients @EnableFeignClients
@EnableDiscoveryClient @EnableDiscoveryClient
@SpringBootApplication @SpringBootApplication
@EnableTransactionManagement @EnableTransactionManagement

3
xdclass-user-service/src/main/java/net/jieyuu/service/impl/UserServiceImpl.java
View File

@ -140,6 +140,9 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, UserDO> implements
request.setName(userDO.getName()); request.setName(userDO.getName());
request.setUserId(userDO.getId()); request.setUserId(userDO.getId());
JsonData jsonData = couponFeignService.addNewUserCoupon(request); JsonData jsonData = couponFeignService.addNewUserCoupon(request);
if (jsonData.getCode() != 0) {
throw new RuntimeException("发放优惠券异常");
}
log.info("发放新用户注册优惠券: {},结果:{}", request.toString(), jsonData.toString()); log.info("发放新用户注册优惠券: {},结果:{}", request.toString(), jsonData.toString());
} }