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
2025-10-28 14:51:09 +08:00
parent 0ef7e2643e
commit e2103d4d0d
3 changed files with 38 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
View File

@@ -263,31 +263,50 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
this.updateById(newDistributionUser);
}
@Override
public void costUpgradeLevelBefore(Long userId, Long shopId) {
ShopUser shopUser = shopUserService.getShopUserInfo(shopId, userId);
costUpgradeLevel(shopUser.getId(), shopId);
if (shopUser.getDistributionUserId() != null) {
costUpgradeLevel(shopUser.getDistributionUserParentId(), shopId);
}
}
/**
* 按消费金额升级等级
*
* @param distributionUserId 分销员Id
* 分销员：按消费金额升级等级
*/
public void costUpgradeLevel(Long distributionUserId) {
MkDistributionUser distributionUser = getById(distributionUserId);
public void costUpgradeLevel(Long shopUserId, Long shopId) {
MkDistributionUser distributionUser = getById(shopUserId);
if (distributionUser == null) {
return;
}
MkDistributionConfig mkDistributionConfig = mkDistributionConfigService.getOne(QueryWrapper.create()
.eq(MkDistributionConfig::getShopId, distributionUser.getShopId()));
AssertUtil.isNull(mkDistributionConfig, "升级失败,店铺未配置分销");
AssertUtil.isNotEqual(mkDistributionConfig.getUpgradeType(), "cost", "升级失败");
if (mkDistributionConfig == null || !"cost".equals(mkDistributionConfig.getUpgradeType())) {
return;
}
List<Long> userIds = shopUserService.listAs(QueryWrapper.create()
.select(ShopUser::getUserId)
.eq(ShopUser::getDistributionUserId, shopUserId), Long.class);
BigDecimal totalAmount = orderInfoService.getOneAs(QueryWrapper.create()
.select("sum(pay_amount)")
.eq(OrderInfo::getShopId, shopId)
.eq(OrderInfo::getStatus, OrderStatusEnums.DONE.getCode())
.in(OrderInfo::getUserId, userIds), BigDecimal.class);
MkDistributionLevelConfig levelConfig = levelConfigService.getOne(QueryWrapper.create()
.eq(MkDistributionLevelConfig::getShopId, distributionUser.getShopId())
.le(MkDistributionLevelConfig::getInviteCount, distributionUser.getInviteCount())
.gt(MkDistributionLevelConfig::getId, distributionUser.getDistributionLevelId())
.orderBy(MkDistributionLevelConfig::getLevel).desc().limit(1));
if (levelConfig != null) {
distributionUser.setDistributionLevelId(levelConfig.getId());
distributionUser.setDistributionLevelName(levelConfig.getName());
if (totalAmount.compareTo(levelConfig.getCostAmount()) >= 0) {
MkDistributionUser newDistributionUser = new MkDistributionUser();
newDistributionUser.setId(shopUserId);
newDistributionUser.setDistributionLevelId(levelConfig.getId());
newDistributionUser.setDistributionLevelName(levelConfig.getName());
updateById(newDistributionUser);
}
}
}
@@ -332,8 +351,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
public Page<InviteUserVO> getInviteUser(Long id, Integer page, Integer size) {
return pageAs(new Page<>(page, size), QueryWrapper.create()
.select("head_img as headImg,nick_name as shopUserName,phone as shopUserPhone,one_income as oneIncome")
.eq(MkDistributionUser::getShopId, id)
.eq(MkDistributionUser::getParentId, id)
.eq(ShopUser::getDistributionUserId, id)
.orderBy(MkDistributionUser::getCreateTime).desc(), InviteUserVO.class);
}