【代码优化】商城:分销用户的创建

This commit is contained in:
YunaiV 2024-12-01 15:00:50 +08:00
parent 844f573bd2
commit 1be6359603
3 changed files with 8 additions and 20 deletions

View File

@ -15,16 +15,4 @@ public class BrokerageUserCreateReqVO {
@Schema(description = "推广员编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "4587") @Schema(description = "推广员编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "4587")
private Long bindUserId; private Long bindUserId;
@Schema(description = "推广资格", requiredMode = Schema.RequiredMode.REQUIRED)
@NotNull(message = "推广资格不能为空")
private Boolean brokerageEnabled;
@Schema(description = "可用佣金", requiredMode = Schema.RequiredMode.REQUIRED, example = "11089")
@NotNull(message = "可用佣金不能为空")
private Integer price;
@Schema(description = "冻结佣金", requiredMode = Schema.RequiredMode.REQUIRED, example = "30916")
@NotNull(message = "冻结佣金不能为空")
private Integer frozenPrice;
} }

View File

@ -110,7 +110,8 @@ public interface BrokerageUserService {
boolean bindBrokerageUser(@NotNull Long userId, @NotNull Long bindUserId); boolean bindBrokerageUser(@NotNull Long userId, @NotNull Long bindUserId);
/** /**
* 创建分销用户 * 管理员创建分销用户
*
* @param createReqVO 请求 * @param createReqVO 请求
* @return 编号 * @return 编号
*/ */

View File

@ -113,7 +113,6 @@ public class BrokerageUserServiceImpl implements BrokerageUserService {
if (brokerageUserDO == null) { if (brokerageUserDO == null) {
throw exception(BROKERAGE_USER_NOT_EXISTS); throw exception(BROKERAGE_USER_NOT_EXISTS);
} }
return brokerageUserDO; return brokerageUserDO;
} }
@ -208,18 +207,18 @@ public class BrokerageUserServiceImpl implements BrokerageUserService {
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Long createBrokerageUser(BrokerageUserCreateReqVO createReqVO) { public Long createBrokerageUser(BrokerageUserCreateReqVO createReqVO) {
// 1. 校验分销用户是否已存在 // 1.1 校验分销用户是否已存在
BrokerageUserDO brokerageUser = brokerageUserMapper.selectById(createReqVO.getUserId()); BrokerageUserDO brokerageUser = brokerageUserMapper.selectById(createReqVO.getUserId());
if (brokerageUser != null) { if (brokerageUser != null) {
throw exception(BROKERAGE_CREATE_USER_EXISTS); throw exception(BROKERAGE_CREATE_USER_EXISTS);
} }
// 1.2 校验是否能绑定用户
// 2.1 创建分销人
brokerageUser = BeanUtils.toBean(createReqVO, BrokerageUserDO.class).setId(createReqVO.getUserId()) brokerageUser = BeanUtils.toBean(createReqVO, BrokerageUserDO.class).setId(createReqVO.getUserId())
.setBrokerageTime(LocalDateTime.now()).setBindUserId(null); .setBrokerageTime(LocalDateTime.now());
validateCanBindUser(brokerageUser, createReqVO.getBindUserId());
// 2. 创建分销人
brokerageUserMapper.insert(brokerageUser); brokerageUserMapper.insert(brokerageUser);
// 2.2 绑定推广员
updateBrokerageUserId(brokerageUser.getId(), createReqVO.getBindUserId());
return brokerageUser.getId(); return brokerageUser.getId();
} }