From f2ab7bdcd51a7a7357e0d862ba17958401d6ce79 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Thu, 22 Jan 2026 17:41:31 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BA=8B=E5=8A=A1=E7=BB=93=E6=9D=9F=E5=90=8E?= =?UTF-8?q?=20=E5=93=8D=E5=BA=942?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/user/UDistributionController.java | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/cash-api/market-server/src/main/java/com/czg/controller/user/UDistributionController.java b/cash-api/market-server/src/main/java/com/czg/controller/user/UDistributionController.java index c43af37b6..ce731c817 100644 --- a/cash-api/market-server/src/main/java/com/czg/controller/user/UDistributionController.java +++ b/cash-api/market-server/src/main/java/com/czg/controller/user/UDistributionController.java @@ -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> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) { + public CzgResult> 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; }