| | |
|---|
| | | import com.ruoyi.system.api.feignClient.SysUserRoleClient; |
|---|
| | | import com.ruoyi.system.api.model.GetSysRoleByIds; |
|---|
| | | import com.ruoyi.system.api.model.SysUserRoleVo; |
|---|
| | | import io.seata.core.exception.TransactionException; |
|---|
| | | import io.seata.spring.annotation.GlobalTransactional; |
|---|
| | | import io.seata.tm.api.GlobalTransactionContext; |
|---|
| | | import org.springframework.http.HttpStatus; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | |
|---|
| | | user.setRoleId(partner.getRoleId().longValue()); |
|---|
| | | user.setRoleType(2); |
|---|
| | | user.setObjectId(partner.getId()); |
|---|
| | | sysUserClient.addSysUser(user); |
|---|
| | | R r = sysUserClient.addSysUser(user); |
|---|
| | | if(r.getCode() != 200){ |
|---|
| | | // 手动进行全局事务回滚 |
|---|
| | | try { |
|---|
| | | GlobalTransactionContext.getCurrent().rollback(); |
|---|
| | | } catch (TransactionException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return AjaxResult.success(); |
|---|
| | | } |
|---|
| | | |
|---|
