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 73fb8f6fd..c43af37b6 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 @@ -13,6 +13,7 @@ import com.czg.resp.CzgResult; import com.czg.sa.StpKit; import com.czg.task.DistributionTask; import com.czg.utils.AssertUtil; +import com.czg.utils.FunUtils; import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.query.QueryWrapper; import jakarta.annotation.Resource; @@ -149,15 +150,13 @@ public class UDistributionController { */ @PostMapping("/autoBindInviteUser") public CzgResult> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) { - AssertUtil.isNull(param.getId(), "店铺用户ID不能为空"); - AssertUtil.isNull(param.getShopId(), "店铺ID不能为空"); - AssertUtil.isNull(param.getInviteCode(), "邀请码不能为空"); try { - distributionUserService.bindInviteUser(param); + bindInviteUser(param); } catch (Exception e) { log.error("无感绑定邀请人失败:{}", param, e); } - return CzgResult.success(); + FunUtils.transactionSafeRun(CzgResult::success); + return null; } diff --git a/cash-common/cash-common-tools/src/main/java/com/czg/utils/FunUtils.java b/cash-common/cash-common-tools/src/main/java/com/czg/utils/FunUtils.java index 5e41792d4..f509611f3 100644 --- a/cash-common/cash-common-tools/src/main/java/com/czg/utils/FunUtils.java +++ b/cash-common/cash-common-tools/src/main/java/com/czg/utils/FunUtils.java @@ -52,7 +52,6 @@ public class FunUtils { /** * 在事务提交后执行方法 - * 异步 执行 * * @param func 方法 */