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<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;
     }