Map常用方式
public Map<Long, String> getIdNameMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getId, Account::getUsername)); }
收集成实体本身map
public Map<Long, Account> getIdAccountMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getId, account -> account)); }
//key由多个属性组成
Map<String, SalesPurchaseDailyStatistics> existStatisticsMap = existStatisticsList.stream().collect(Collectors.toMap(item -> item.getStatisticsDay() + "_" + item.getUserName(), Function.identity()));
Key作类型转换
Map<String, TOwpAmazon> tOwpAmazonMap = tOwpAmazonList.stream().collect(Collectors.toMap(item -> item.getId().toString(), Function.identity()));
account -> account是一个返回本身的lambda表达式,其实还可以使用Function接口中的一个默认方法代替,使整个方法更简洁优雅:
public Map<Long, Account> getIdAccountMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getId, Function.identity())); }
重复key的情况
public Map<String, Account> getNameAccountMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getUsername, Function.identity())); }
这个方法可能报错(java.lang.IllegalStateException: Duplicate key),因为name是有可能重复的。toMap有个重载方法,可以传入一个合并的函数来解决key冲突问题:
public Map<String, Account> getNameAccountMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getUsername, Function.identity(), (key1, key2) -> key2)); }
这里只是简单的使用后者覆盖前者来解决key重复问题。还有一种分组的方法:
Map<Long, List<ActivityUserMissionDO>> map = activityUserMissionDos.stream().collect(Collectors.groupingBy(ActivityUserMissionDO::getParentModuleId));
指定具体收集的map
toMap还有另一个重载方法,可以指定一个Map的具体实现,来收集数据:
public Map<String, Account> getNameAccountMap(List<Account> accounts) { return accounts.stream().collect(Collectors.toMap(Account::getUsername, Function.identity(), (key1, key2) -> key2, LinkedHashMap::new)); }
分组
Map<Integer, List<PyTradeOrderDt>> orderMap = pyTradeOrderDts.stream().collect(Collectors.groupingBy(PyTradeOrderDt::getTradeNid)); orderMap.forEach((k, v) -> { Set<String> collect = v.stream().map(PyTradeOrderDt::getSku).collect(Collectors.toSet()); skuSet.addAll(collect); });
//按多个属性分组
Map<String, List<JsonObject>> menuGroupMap = list.stream().collect(Collectors.groupingBy(goods -> goods.getInteger("menu_id")+"_"+goods.getString("menu_name")));
List常用方式
List<String> nidList = resultList.stream().map(TrackNoOverTimeDto::getNid).collect(Collectors.toist());
//String类型转Int
List<Integer> nidIntList = nidList.stream().map(Integer::parseInt).collect(Collectors.toList());
List排序
List<TrackNoOverTimeDto> resultList = new ArrayList<>(); resultList.forEach(item ->{ List<PyTradeLogs> pyTradeLogs = collect.get(item.getNid()); //取出日志ID最大的记录 PyTradeLogs tradeLogs = pyTradeLogs.stream().sorted((s1, s2) -> { if (s1.getOpDate() != null && s2.getOpDate() != null) { //如果日期都有值,按日期排序 return -s1.getOpDate().compareTo(s2.getOpDate()); } else if (s1.getOpDate() == null && s2.getOpDate() == null) { //如果日期都没有值,按主键ID排序 return -s1.getNID().compareTo(s2.getNID()); } else if (s1.getOpDate() == null && s2.getOpDate() != null) { //opDate为null的放在最后 return 1; } else if (s1.getOpDate() != null && s2.getOpDate() == null) { //opDate为null的放在最后 return -1; } return -s1.getNID().compareTo(s2.getNID()); }).findFirst().get(); });