事务结束后 响应
This commit is contained in:
@@ -13,6 +13,7 @@ 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 jakarta.annotation.Resource;
|
import jakarta.annotation.Resource;
|
||||||
@@ -149,15 +150,13 @@ public class UDistributionController {
|
|||||||
*/
|
*/
|
||||||
@PostMapping("/autoBindInviteUser")
|
@PostMapping("/autoBindInviteUser")
|
||||||
public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) {
|
public CzgResult<Map<String, Object>> autoBindInviteUser(@RequestBody MkDistributionUserDTO param) {
|
||||||
AssertUtil.isNull(param.getId(), "店铺用户ID不能为空");
|
|
||||||
AssertUtil.isNull(param.getShopId(), "店铺ID不能为空");
|
|
||||||
AssertUtil.isNull(param.getInviteCode(), "邀请码不能为空");
|
|
||||||
try {
|
try {
|
||||||
distributionUserService.bindInviteUser(param);
|
bindInviteUser(param);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("无感绑定邀请人失败:{}", param, e);
|
log.error("无感绑定邀请人失败:{}", param, e);
|
||||||
}
|
}
|
||||||
return CzgResult.success();
|
FunUtils.transactionSafeRun(CzgResult::success);
|
||||||
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -52,7 +52,6 @@ public class FunUtils {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* 在事务提交后执行方法
|
* 在事务提交后执行方法
|
||||||
* 异步 执行
|
|
||||||
*
|
*
|
||||||
* @param func 方法
|
* @param func 方法
|
||||||
*/
|
*/
|
||||||
|
|||||||
Reference in New Issue
Block a user