消费金额

This commit is contained in:
wangw 2025-10-29 15:07:39 +08:00
parent 4285cc7bbd
commit 98db120f1f
3 changed files with 13 additions and 2 deletions

View File

@ -84,6 +84,10 @@ public class MkDistributionUserDTO extends TimeQueryParam implements Serializabl
* 邀请人数 * 邀请人数
*/ */
private Integer inviteCount; private Integer inviteCount;
/**
* 已消费金额
*/
private BigDecimal consumeAmount;
/** /**
* 自主申请付费开通手动添加 * 自主申请付费开通手动添加

View File

@ -89,6 +89,11 @@ public class MkDistributionUser implements Serializable {
*/ */
private Integer inviteCount; private Integer inviteCount;
/**
* 已消费金额
*/
private BigDecimal consumeAmount;
/** /**
* 自主申请付费开通手动添加 * 自主申请付费开通手动添加
*/ */

View File

@ -332,15 +332,17 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
.le(MkDistributionLevelConfig::getCostAmount, totalAmount) .le(MkDistributionLevelConfig::getCostAmount, totalAmount)
.gt(MkDistributionLevelConfig::getId, distributionUser.getDistributionLevelId()) .gt(MkDistributionLevelConfig::getId, distributionUser.getDistributionLevelId())
.orderBy(MkDistributionLevelConfig::getId).asc().limit(1)); .orderBy(MkDistributionLevelConfig::getId).asc().limit(1));
MkDistributionUser newDistributionUser = new MkDistributionUser();
newDistributionUser.setId(shopUserId);
newDistributionUser.setConsumeAmount(totalAmount);
if (levelConfig != null) { if (levelConfig != null) {
if (totalAmount.compareTo(levelConfig.getCostAmount()) >= 0) { if (totalAmount.compareTo(levelConfig.getCostAmount()) >= 0) {
MkDistributionUser newDistributionUser = new MkDistributionUser();
newDistributionUser.setId(shopUserId); newDistributionUser.setId(shopUserId);
newDistributionUser.setDistributionLevelId(levelConfig.getId()); newDistributionUser.setDistributionLevelId(levelConfig.getId());
newDistributionUser.setDistributionLevelName(levelConfig.getName()); newDistributionUser.setDistributionLevelName(levelConfig.getName());
updateById(newDistributionUser);
} }
} }
updateById(newDistributionUser);
} }