Merge remote-tracking branch 'origin/test' into test

This commit is contained in:
2025-11-14 10:07:50 +08:00
5 changed files with 30 additions and 6 deletions

View File

@@ -152,6 +152,8 @@ public class ShopUser implements Serializable {
private LocalDateTime nextDeliverTime; private LocalDateTime nextDeliverTime;
// 是否分销员 // 是否分销员
private String distributionShops; private String distributionShops;
private String memberCircleName;
private Integer memberCircleReward;
@Column(ignore = true) @Column(ignore = true)
private String memberName; private String memberName;

View File

@@ -34,4 +34,6 @@ public class MemberDetailVO implements Serializable {
private LocalDateTime endTime; private LocalDateTime endTime;
private String memberName; private String memberName;
private String memberCircleName;
private Integer memberCircleReward;
} }

View File

@@ -99,6 +99,7 @@ public class AShopUserServiceImpl implements AShopUserService {
PageInfo<ShopUserDTO> shopUserDTOPageInfo = new PageInfo<>(shopUserMapper.selectPageByKeyAndIsVip(mainIdByShopId, isVip, key, amount)); PageInfo<ShopUserDTO> shopUserDTOPageInfo = new PageInfo<>(shopUserMapper.selectPageByKeyAndIsVip(mainIdByShopId, isVip, key, amount));
shopUserDTOPageInfo.getList().forEach(item -> { shopUserDTOPageInfo.getList().forEach(item -> {
item.setNew(consumeDiscountService.isNewUser(item, StpKit.USER.getShopId())); item.setNew(consumeDiscountService.isNewUser(item, StpKit.USER.getShopId()));
setUserDiscount(item);
}); });
return PageUtil.convert(shopUserDTOPageInfo); return PageUtil.convert(shopUserDTOPageInfo);
} }
@@ -182,6 +183,16 @@ public class AShopUserServiceImpl implements AShopUserService {
return shopUserService.save(shopUser); return shopUserService.save(shopUser);
} }
private void setUserDiscount(ShopUserDTO shopUserDTO) {
if (shopUserDTO.getMemberLevelId() != null) {
MemberLevelConfig memberLevelConfig = memberLevelConfigService.getById(shopUserDTO.getMemberLevelId());
shopUserDTO.setMemberLevelName(memberLevelConfig == null ? null : memberLevelConfig.getName());
if (memberLevelConfig != null) {
shopUserDTO.setDiscount(memberLevelConfig.getDiscount());
}
}
}
@Override @Override
public ShopUser getDetail(Integer id, Integer userId) { public ShopUser getDetail(Integer id, Integer userId) {
Long mainId = shopInfoService.getMainIdByShopId(StpKit.USER.getShopId()); Long mainId = shopInfoService.getMainIdByShopId(StpKit.USER.getShopId());

View File

@@ -331,7 +331,9 @@ public class TbMemberConfigServiceImpl extends ServiceImpl<TbMemberConfigMapper,
if (levelVO.getIsCostRewardPoints() == 1 && levelVO.getCostRewardPoints() != null) { if (levelVO.getIsCostRewardPoints() == 1 && levelVO.getCostRewardPoints() != null) {
int points = (int) (money.floatValue() / levelVO.getCostRewardPoints()); int points = (int) (money.floatValue() / levelVO.getCostRewardPoints());
log.info("消费送积分: {}", points); log.info("消费送积分: {}", points);
memberPointsService.addPoints(shopUser.getId(), points, "会员消费送积分", null); if (points > 0) {
memberPointsService.addPoints(shopUser.getId(), points, "会员消费送积分", null);
}
} }
} }
case RECHARGE -> { case RECHARGE -> {
@@ -441,7 +443,7 @@ public class TbMemberConfigServiceImpl extends ServiceImpl<TbMemberConfigMapper,
} }
@Override @Override
@Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED) @Transactional(rollbackFor = Exception.class)
public boolean joinMember(Long shopId, Long userId, Long memberOrderId) { public boolean joinMember(Long shopId, Long userId, Long memberOrderId) {
MemberConfigVO memberConfigVO = detail(shopId); MemberConfigVO memberConfigVO = detail(shopId);
ShopUser shopUser = shopUserService.getShopUserInfo(shopId, userId); ShopUser shopUser = shopUserService.getShopUserInfo(shopId, userId);
@@ -515,14 +517,17 @@ public class TbMemberConfigServiceImpl extends ServiceImpl<TbMemberConfigMapper,
memberOrder.setPayAmount(memberOrder.getAmount()); memberOrder.setPayAmount(memberOrder.getAmount());
memberOrder.setStatus(OrderStatusEnums.DONE.getCode()); memberOrder.setStatus(OrderStatusEnums.DONE.getCode());
memberOrderService.updateById(memberOrder); memberOrderService.updateById(memberOrder);
if (memberOrder.getReward() != null) {
deliver(shopUser, TableValueConstant.MemberExpFlow.Type.PAY, memberOrder.getAmount(), memberOrder.getReward(), memberOrderId);
}
if (shopUser.getMemberLevelId() == null || shopUser.getMemberLevelId() == 0) { if (shopUser.getMemberLevelId() == null || shopUser.getMemberLevelId() == 0) {
shopUser.setMemberLevelId(levelConfig.getId()); shopUser.setMemberLevelId(levelConfig.getId());
} }
shopUser.setMemberCircleName(memberOrder.getName());
shopUser.setMemberCircleReward(memberOrder.getReward());
shopUser.setIsVip(1); shopUser.setIsVip(1);
shopUser.setOpenType("PAY"); shopUser.setOpenType("PAY");
if (memberOrder.getReward() != null) {
deliver(shopUser, TableValueConstant.MemberExpFlow.Type.PAY, memberOrder.getAmount(), memberOrder.getReward(), memberOrderId);
}
return shopUserService.updateInfo(shopUser); return shopUserService.updateInfo(shopUser);
} }
@@ -568,6 +573,8 @@ public class TbMemberConfigServiceImpl extends ServiceImpl<TbMemberConfigMapper,
MemberLevelConfig nextLevel = levelConfigService.getOne(new QueryWrapper().eq(MemberLevelConfig::getShopId, shopId).ge(MemberLevelConfig::getExperienceValue, shopUser.getExperience()) MemberLevelConfig nextLevel = levelConfigService.getOne(new QueryWrapper().eq(MemberLevelConfig::getShopId, shopId).ge(MemberLevelConfig::getExperienceValue, shopUser.getExperience())
.ne(MemberLevelConfig::getId, shopUser.getMemberLevelId()).orderBy(MemberLevelConfig::getExperienceValue, true)); .ne(MemberLevelConfig::getId, shopUser.getMemberLevelId()).orderBy(MemberLevelConfig::getExperienceValue, true));
return new MemberDetailVO() return new MemberDetailVO()
.setMemberCircleName(shopUser.getMemberCircleName())
.setMemberCircleReward(shopUser.getMemberCircleReward())
.setMemberName(shopUser.getMemberName()) .setMemberName(shopUser.getMemberName())
.setShopInfo(shopInfo) .setShopInfo(shopInfo)
.setMemberLevel(levelVO) .setMemberLevel(levelVO)

View File

@@ -1130,10 +1130,12 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
.setBizEnum(ShopUserFlowBizEnum.ORDER_PAY) .setBizEnum(ShopUserFlowBizEnum.ORDER_PAY)
.setRelationId(orderInfo.getId()) .setRelationId(orderInfo.getId())
.setMoney(orderInfo.getOrderAmount()); .setMoney(orderInfo.getOrderAmount());
shopUserService.updateMoney(shopUserMoneyEditDTO); shopUserService.updateMoney(shopUserMoneyEditDTO);
redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId()); redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId());
// 发放成长值 // 发放成长值
// 会员消费赠送成长值 shopUser = shopUserService.getById(shopUser);
memberConfigService.deliver(shopUser, memberConfigService.deliver(shopUser,
TableValueConstant.MemberExpFlow.Type.RECHARGE, TableValueConstant.MemberExpFlow.Type.RECHARGE,
BigDecimal.valueOf(czgCallBackDto.getAmount()).divide(BigDecimal.valueOf(100), 2, RoundingMode.DOWN), null, orderInfo.getId()); BigDecimal.valueOf(czgCallBackDto.getAmount()).divide(BigDecimal.valueOf(100), 2, RoundingMode.DOWN), null, orderInfo.getId());