SysUserSearchServiceImpl.java

    1. public boolean syncUserAttentionData() {
    2.     List<UserAttentionRecord> attentionRecord = getAttentionRecord();
    3.     if (CollectionUtil.isNotEmpty(attentionRecord)) {
    4.         //关注列表
    5.         Map<Long, List<Long>> attentionList = attentionRecord.stream().collect(
    6.             Collectors.groupingBy(UserAttentionRecord::getFromUid,   
    7.             Collectors.mapping(UserAttentionRecord::getToUid, Collectors.toList())));
    8.         //粉丝列表
    9.         Map<Long, List<Long>> followList = attentionRecord.stream().collect(
    10.             Collectors.groupingBy(UserAttentionRecord::getToUid,
    11.             Collectors.mapping(UserAttentionRecord::getFromUid, Collectors.toList())));
    12.     }
    13.     return false;
    14. }
    16. private Map<Integer, Set<String>> getWorkDayCache() {
    17.     List<WorkDay> workDays = workDayDao.listWorkDay();
    18.     if (CollectionUtils.isEmpty(workDays)) {
    19.         return Collections.emptyMap();
    20.     }
    21.     return workDays.stream()
    22.         .collect(Collectors.groupingBy(WorkDay::getWorkDayType,
    23.            Collectors.mapping(WorkDay::getWorkDay, Collectors.toSet())))
    24. }
    26. # toMap
    27. Map<String, Map<String, LadderEarningsRateBO>> rateMap = earningsRates.stream().collect(
    28. Collectors.groupingBy(e -> e.getProdCode() + e.getProdType(),
    29.       Collectors.toMap(FundEarningsRate::getEarningsRateType, FundEarningsRate::toLadderEarningsRateBO)
    30. ));
    32. Map<Integer, List<String>> prodMap = prodList.stream().collect(
    33.     Collectors.groupingBy(ProdBO::getProdType,
    34.                           Collectors.mapping(ProdBO::getProdCode, Collectors.toList())));