事务结束后 响应2
This commit is contained in:
@@ -16,6 +16,9 @@ import com.czg.utils.AssertUtil;
|
||||
import com.czg.utils.FunUtils;
|
||||
import com.mybatisflex.core.paginate.Page;
|
||||
import com.mybatisflex.core.query.QueryWrapper;
|
||||
import io.seata.core.exception.TransactionException;
|
||||
import io.seata.tm.api.GlobalTransaction;
|
||||
import io.seata.tm.api.GlobalTransactionContext;
|
||||
import jakarta.annotation.Resource;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.core.NestedExceptionUtils;
|
||||
@@ -149,14 +152,20 @@ public class UDistributionController {
|
||||
* 分销员中心-无感-绑定邀请人
|
||||
*/
|
||||
@PostMapping("/autoBindInviteUser")
|
||||
public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) {
|
||||
public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) throws TransactionException {
|
||||
|
||||
GlobalTransaction tx = GlobalTransactionContext.getCurrentOrCreate();
|
||||
try {
|
||||
tx.begin();
|
||||
bindInviteUser(param);
|
||||
tx.commit(); // 手动提交
|
||||
return CzgResult.success();
|
||||
} catch (Exception e) {
|
||||
tx.rollback(); // 手动回滚
|
||||
log.error("无感绑定邀请人失败:{}", param, e);
|
||||
|
||||
return CzgResult.success();
|
||||
}
|
||||
FunUtils.transactionSafeRun(CzgResult::success);
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user