|
|
@ -254,24 +254,9 @@ public class UserBadgeServiceImpl implements UserBadgeService { |
|
|
|
@Override |
|
|
|
public void reloadCustomerBadge(String customerId){ |
|
|
|
userBadgeRedis.delCustomerBadge(customerId); |
|
|
|
List<UserBadgeListResultDTO> resultUserBadge = new ArrayList<>(); |
|
|
|
List<UserBadgeListResultDTO> userBadgeListResultDTOS = userBadgeDao.selectAllBadge(customerId); |
|
|
|
if (!CollectionUtils.isEmpty(userBadgeListResultDTOS)){ |
|
|
|
Map<String, List<UserBadgeListResultDTO>> groupByCustomer = userBadgeListResultDTOS.stream().collect(Collectors.groupingBy(UserBadgeListResultDTO::getCustomerId)); |
|
|
|
resultUserBadge.addAll(groupByCustomer.get(BadgeConstant.DEFAULT_CUSTOMER)); |
|
|
|
List<UserBadgeListResultDTO> badgeByCustomer = groupByCustomer.get(customerId); |
|
|
|
if (!CollectionUtils.isEmpty(badgeByCustomer)) { |
|
|
|
resultUserBadge.forEach(r -> { |
|
|
|
for (int i = NumConstant.ZERO; i < badgeByCustomer.size(); i++) { |
|
|
|
if (r.getBadgeId().equals(badgeByCustomer.get(i).getBadgeId())) { |
|
|
|
BeanUtils.copyProperties(badgeByCustomer.get(i), r); |
|
|
|
badgeByCustomer.remove(badgeByCustomer.get(i)); |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
resultUserBadge.addAll(badgeByCustomer); |
|
|
|
} |
|
|
|
userBadgeRedis.setCustomerBadge(resultUserBadge, customerId); |
|
|
|
if (CollectionUtils.isEmpty(userBadgeListResultDTOS)){ |
|
|
|
throw new RenException("客户徽章缓存初始化未查到数据"); |
|
|
|
} |
|
|
|
userBadgeRedis.setCustomerBadge(userBadgeListResultDTOS, customerId); |
|
|
|
} |
|
|
|