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 16:03:59 +08:00
parent 8b16ce48de
commit dfc3941cb0
4 changed files with 34 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
xdclass-common/pom.xml
View File

@ -120,21 +120,21 @@
</dependency> </dependency>
<!--alibaba微服务整合分布式事务seata--> <!--alibaba微服务整合分布式事务seata-->
<dependency> <!-- <dependency>-->
<groupId>com.alibaba.cloud</groupId> <!-- <groupId>com.alibaba.cloud</groupId>-->
<artifactId>spring-cloud-starter-alibaba-seata</artifactId> <!-- <artifactId>spring-cloud-starter-alibaba-seata</artifactId>-->
<exclusions> <!-- <exclusions>-->
<exclusion> <!-- <exclusion>-->
<groupId>io.seata</groupId> <!-- <groupId>io.seata</groupId>-->
<artifactId>seata-spring-boot-starter</artifactId> <!-- <artifactId>seata-spring-boot-starter</artifactId>-->
</exclusion> <!-- </exclusion>-->
</exclusions> <!-- </exclusions>-->
</dependency> <!-- </dependency>-->
<dependency> <!-- <dependency>-->
<groupId>io.seata</groupId> <!-- <groupId>io.seata</groupId>-->
<artifactId>seata-spring-boot-starter</artifactId> <!-- <artifactId>seata-spring-boot-starter</artifactId>-->
<version>1.3.0</version> <!-- <version>1.3.0</version>-->
</dependency> <!-- </dependency>-->
</dependencies> </dependencies>

14
xdclass-coupon-service/src/main/resources/application.yml
View File

@ -34,10 +34,10 @@ logging:
#seata配置 #seata配置
seata: #seata:
tx-service-group: ${spring.application.name}-group # tx-service-group: ${spring.application.name}-group
service: # service:
grouplist: # grouplist:
xdclass: 134.175.219.253:8091 # xdclass: 134.175.219.253:8091
vgroup-mapping: # vgroup-mapping:
xdclass-coupon-service-group: xdclass # xdclass-coupon-service-group: xdclass

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

@ -1,9 +1,6 @@
package net.jieyuu.service.impl; package net.jieyuu.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import io.seata.spring.annotation.GlobalTransactional;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import net.jieyuu.enums.BizCodeEnum; import net.jieyuu.enums.BizCodeEnum;
import net.jieyuu.enums.SendCodeEnum; import net.jieyuu.enums.SendCodeEnum;
@ -69,7 +66,8 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, UserDO> implements
* @return * @return
*/ */
@Override @Override
@GlobalTransactional // @GlobalTransactional
@Transactional(rollbackFor = RuntimeException.class, propagation = Propagation.REQUIRED)
public JsonData register(UserRegisterRequest registerRequest) { public JsonData register(UserRegisterRequest registerRequest) {
boolean checkCode = false; boolean checkCode = false;
@ -140,9 +138,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) { // if (jsonData.getCode() != 0) {
throw new RuntimeException("发放优惠券异常"); // throw new RuntimeException("发放优惠券异常");
} // }
log.info("发放新用户注册优惠券: {},结果:{}", request.toString(), jsonData.toString()); log.info("发放新用户注册优惠券: {},结果:{}", request.toString(), jsonData.toString());
} }

14
xdclass-user-service/src/main/resources/application.yml
View File

@ -52,10 +52,10 @@ minio:
#seata配置 #seata配置
seata: #seata:
tx-service-group: ${spring.application.name}-group # tx-service-group: ${spring.application.name}-group
service: # service:
grouplist: # grouplist:
xdclass: 134.175.219.253:8091 # xdclass: 134.175.219.253:8091
vgroup-mapping: # vgroup-mapping:
xdclass-user-service-group: xdclass # xdclass-user-service-group: xdclass