czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

事务结束后

Browse Source
This commit is contained in:
wangw
2026-01-22 17:56:45 +08:00
parent f2ab7bdcd5
commit 5cb95a31f1
1 changed files with 1 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
cash-api/market-server/src/main/java/com/czg/controller/user/UDistributionController.java
View File

@@ -13,12 +13,9 @@ import com.czg.resp.CzgResult;
import com.czg.sa.StpKit; import com.czg.sa.StpKit;
import com.czg.task.DistributionTask; import com.czg.task.DistributionTask;
import com.czg.utils.AssertUtil; import com.czg.utils.AssertUtil;
import com.czg.utils.FunUtils;
import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.paginate.Page;
import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.core.query.QueryWrapper;
import io.seata.core.exception.TransactionException; import io.seata.core.exception.TransactionException;
import io.seata.tm.api.GlobalTransaction;
import io.seata.tm.api.GlobalTransactionContext;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.core.NestedExceptionUtils; import org.springframework.core.NestedExceptionUtils;
@@ -153,19 +150,12 @@ public class UDistributionController {
*/ */
@PostMapping("/autoBindInviteUser") @PostMapping("/autoBindInviteUser")
public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) throws TransactionException { public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) throws TransactionException {
GlobalTransaction tx = GlobalTransactionContext.getCurrentOrCreate();
try { try {
tx.begin();
bindInviteUser(param); bindInviteUser(param);
tx.commit(); // 手动提交
return CzgResult.success();
} catch (Exception e) { } catch (Exception e) {
tx.rollback(); // 手动回滚
log.error("无感绑定邀请人失败：{}", param, e); log.error("无感绑定邀请人失败：{}", param, e);
return CzgResult.success();
} }
return CzgResult.success();
} }