Map<String,BusinessGroupPlaceOrder> map = result.stream().collect(Collectors.toMap(a->a.getBuId(),a->a,(k1,k2)->k1));这行代码的作用是什么

时间: 2024-04-27 08:23:17 浏览: 8
这行代码的作用是将一个 List 集合中的元素按照 BuId 字段进行分组,并将结果映射为 Map<String,BusinessGroupPlaceOrder> 类型。其中,BuId 字段作为 Map 的 key,对应的 BusinessGroupPlaceOrder 对象作为 value。如果有重复的 BuId,采用 k1 覆盖 k2 的方式进行去重,即保留第一个出现的元素。
相关问题

优化代码 public Map<String, String> getManagerCodeToMap(String... deptCodes) { List<DepartDO> departDOS = orgCenterService.selDepartList(deptCodes); Map<String, String> result = departDOS.stream().collect(Collectors.toMap(DepartDO::getDepartCode, DepartDO::getDepartManager)); return result; }

这段代码可以进一步优化,可以使用方法引用来简化代码,如下所示: public Map<String, String> getManagerCodeToMap(String... deptCodes) { List<DepartDO> departDOS = orgCenterService.selDepartList(deptCodes); return departDOS.stream().collect(Collectors.toMap(DepartDO::getDepartCode, DepartDO::getDepartManager)); } 另外,可以考虑使用并行流来提高性能,如下所示: public Map<String, String> getManagerCodeToMap(String... deptCodes) { List<DepartDO> departDOS = orgCenterService.selDepartList(deptCodes); return departDOS.parallelStream().collect(Collectors.toMap(DepartDO::getDepartCode, DepartDO::getDepartManager)); }

List<ZbcQsjdrzlbaTjQueryResult> queryResultList = zbglXtZbcjsjgMapper.queryjdrzlZzdw(zbcQsjdrzlbaTjQueryParam); Map<String, String> jdrzlRybmMap = queryResultList.stream().collect(Collectors.toMap(ZbcQsjdrzlbaTjQueryResult::getRybm , ZbcQsjdrzlbaTjQueryResult::getDwbm)); Map<String, String> jdrzlDwmcMap = queryResultList.stream().collect(Collectors.toMap(ZbcQsjdrzlbaTjQueryResult::getRybm , ZbcQsjdrzlbaTjQueryResult::getDwmc)); 优化一下代码

可以考虑将两个stream的操作合并为一个,避免重复遍历queryResultList。具体实现如下: ``` Map<String, String> jdrzlRybmMap = new HashMap<>(); Map<String, String> jdrzlDwmcMap = new HashMap<>(); queryResultList.forEach(result -> { jdrzlRybmMap.put(result.getRybm(), result.getDwbm()); jdrzlDwmcMap.put(result.getRybm(), result.getDwmc()); }); ``` 这样可以将查询结果只遍历一次,并且使用forEach代替了stream操作,提高了代码的性能和可读性。

相关推荐

优化代码:@Override public List projectCount(String beginTime, String endTime, Integer forceType, String projectId) { List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId); if(CollectionUtil.isEmpty(taskTaskList)){ return Collections.emptyList(); } List result = new ArrayList<>(); Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId)); for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) { String currentProjectId = projectTaskEntry.getKey(); ProjectCountVO projectCountVO = new ProjectCountVO(); projectCountVO.setId(currentProjectId); // 查询项目名称 ProjectCondition queryProjectDto = new ProjectCondition(); queryProjectDto.setCompanyId(companyId); queryProjectDto.setDesignStatusList(designStatusList); queryProjectDto.setPageSize(pageSize); queryProjectDto.setUserId(userId); ResultWrapper<QueryAllProject> queryAllProjectResult = applicationServicePlatformClient.listUserProject(bspToken, bspUserId, bspUserEnvId, bspUserTenant, queryProjectDto); QueryAllProject queryAllProject = queryAllProjectResult.getData(); projectCountVO.setName(queryAllProject.getProjectName()); List<TaskTask> taskList = projectTaskEntry.getValue(); projectCountVO.setTaskCount(taskList.size()); Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task-> Optional.ofNullable(task.getProblemNum()).orElse(0))); projectCountVO.setProblemCount(problemCount); result.add(projectCountVO); } return result; }

根据代码1“public List projectCount(String beginTime, String endTime, Integer forceType, String projectId) { // 查询任务列表 List<TaskTask> taskTaskList = this.listStatisticsTask(beginTime, endTime, forceType, projectId); if (CollectionUtil.isEmpty(taskTaskList)) { return Collections.emptyList(); } List result = new ArrayList<>(); // 将任务按照项目ID分组 Map<String, List<TaskTask>> projectTaskMap = taskTaskList.stream().collect(Collectors.groupingBy(TaskTask::getProjectId)); //查询项目名称 String bspToken = RequestHeaderHolder.getBspToken(); String bspUserId = RequestHeaderHolder.getUserId(); String bspUserEnvId = RequestHeaderHolder.getCompanyId(); String bspUserTenant = RequestHeaderHolder.getCompanyId(); String companyId = RequestHeaderHolder.getCompanyId(); ProjectCondition projectCondition = new ProjectCondition(); projectCondition.setAppId("23031408164321600"); projectCondition.setCompanyId(companyId); projectCondition.setDesignStatusList(Arrays.asList(2,3)); projectCondition.setPageSize(-1); projectCondition.setUserId(bspUserId); List<QueryAllProject> queryAllProject = applicationServicePlatformClientProxy.listUserProject(bspToken, bspUserId, bspUserEnvId, bspUserTenant, projectCondition);”修改代码2“// 遍历项目及对应的任务列表 for (Map.Entry<String, List<TaskTask>> projectTaskEntry : projectTaskMap.entrySet()) { projectId = projectTaskEntry.getKey(); ProjectCountVO projectCountVO = new ProjectCountVO(); projectCountVO.setId(projectId); String projectName = queryAllProject; projectCountVO.setName(projectName); List<TaskTask> taskList = projectTaskEntry.getValue(); projectCountVO.setTaskCount(taskList.size()); Integer problemCount = CollectionUtil.isEmpty(taskList) ? 0 : taskList.stream().collect(Collectors.summingInt(task -> Optional.ofNullable(task.getProblemNum()).orElse(0))); projectCountVO.setProblemCount(problemCount); result.add(projectCountVO); } return result;”,最终能够查到指定“projectname”

//1.获取最新两期日期 List<String> lastTwoDate = industryScoreInfoRepository.getLastTwoDate(); // List<String> lastTwoDate = new ArrayList<>(); // lastTwoDate.add("2023-02-28"); // lastTwoDate.add("2023-01-31"); log.info("当前观点较上期变化日期:"+new Gson().toJson(lastTwoDate)); //2.根据日期获取数据 List<IndustryScoreInfo> industryScoreInfoByDate = industryScoreInfoRepository.getIndustryLastScoreInfos(lastTwoDate); Map<String, List<IndustryScoreInfo>> groups = industryScoreInfoByDate.stream().collect(Collectors.groupingBy(IndustryScoreInfo::getTrackDate)); // 遍历groups中的每个List<IndustryScoreInfo> List<IndustryScoreResult> industryScoreResults = new ArrayList<>(); //获取当前最新日期综合得分 List<IndustryScoreInfo> industryScoreInfos = groups.get(lastTwoDate.get(0)); //获取上一日期综合得分 List<IndustryScoreInfo> last = groups.get(lastTwoDate.get(1)); for(IndustryScoreInfo industry: industryScoreInfos){ IndustryScoreResult result = new IndustryScoreResult(); result.setTrackDate(industry.getTrackDate()); result.setTrackName(industry.getTrackName()); //当前日期观点分数 result.setComprehensiveScore(industry.getComprehensiveScore()); //对上一日期遍历获取track_name相同时,的综合得分,赋值 如果上一日期不存在,则为空串("")返回 for(IndustryScoreInfo lastIndustryScoreInfo: last){ if(result.getTrackName().equals(lastIndustryScoreInfo.getTrackName())){ result.setLastComprehensiveScore(lastIndustryScoreInfo.getComprehensiveScore()); } } industryScoreResults.add(result); } 代码优化

for (BdFindOutPlanGroupDTO comDTO : result) { Result<FeignOrgDTO> feignOrgDTOResult = remoteIpmpOrgService.getInfoById(comDTO.getCompanyId().toString()); if (StringUtils.isNotNull(feignOrgDTOResult.getData())) { if (StringUtils.isNotNull(feignOrgDTOResult.getData())) { comDTO.setCompanyName(feignOrgDTOResult.getData().getOrgName()); } else { comDTO.setCompanyName(comDTO.getCompanyId().toString()); } } else { comDTO.setCompanyName(comDTO.getCompanyId().toString()); } BdFindOutPlanGroupDtlQueryDTO findOutPlanGroupDtlQueryDTO = new BdFindOutPlanGroupDtlQueryDTO(); findOutPlanGroupDtlQueryDTO.setFindOutPlanGroupId(Long.parseLong(comDTO.getFindOutPlanGroupId())); List<BdFindOutPlanGroupDtlDO> bdFindOutPlanGroupDtlDOS = findOutPlanGroupDtlMapper.selectList(findOutPlanGroupDtlQueryDTO); List<BdFindOutPlanGroupDtlDTO> dtoList = BeanUtils.copyToList(bdFindOutPlanGroupDtlDOS, BdFindOutPlanGroupDtlDTO.class); //获取项目id与项目名称对应关系 if (StringUtils.isNotEmpty(dtoList)) { List<Long> projectIdList = dtoList.stream().map(BdFindOutPlanGroupDtlDTO::getProjectId).collect(Collectors.toList()); ApiMdProjectDTO apiMdProjectDTO = new ApiMdProjectDTO(); apiMdProjectDTO.setProjectIds(projectIdList.stream().map(x -> x + "").collect(Collectors.toList())); Result> projectInfoList = remoteProjecctService.listProject(apiMdProjectDTO); Map<String, String> stringStringMap = CollectionUtils.toMap( projectInfoList.getData(), ApiMdProjectDTO::getProjectId, ApiMdProjectDTO::getProjectName ); //将从其他表获取的数值做填充 dtoList.forEach(d -> { //如果md_project表未查询到名称,则显示id d.setProjectName(Optional.ofNullable(stringStringMap.get(d.getProjectId().toString())).orElse(d.getProjectId().toString())); }); } comDTO.setFindOutPlanGroupDtlDTOS(dtoList); } 代码优化

最新推荐

recommend-type

Python源码-数学美之樱花.py

Python源码-数学美之樱花
recommend-type

蚁群算法(ACO)求解TSP问题,MATLAB源码,代码注释详细,可根据自身需求拓展应用

蚁群算法(ACO)求解TSP问题,MATLAB源码,代码注释详细,可根据自身需求拓展应用
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

用matlab绘制高斯色噪声情况下的频率估计CRLB,其中w(n)是零均值高斯色噪声,w(n)=0.8*w(n-1)+e(n),e(n)服从零均值方差为se的高斯分布

以下是用matlab绘制高斯色噪声情况下频率估计CRLB的代码: ```matlab % 参数设置 N = 100; % 信号长度 se = 0.5; % 噪声方差 w = zeros(N,1); % 高斯色噪声 w(1) = randn(1)*sqrt(se); for n = 2:N w(n) = 0.8*w(n-1) + randn(1)*sqrt(se); end % 计算频率估计CRLB fs = 1; % 采样频率 df = 0.01; % 频率分辨率 f = 0:df:fs/2; % 频率范围 M = length(f); CRLB = zeros(M,1); for
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。
recommend-type

"互动学习:行动中的多样性与论文攻读经历"

多样性她- 事实上SCI NCES你的时间表ECOLEDO C Tora SC和NCESPOUR l’Ingén学习互动,互动学习以行动为中心的强化学习学会互动,互动学习,以行动为中心的强化学习计算机科学博士论文于2021年9月28日在Villeneuve d'Asq公开支持马修·瑟林评审团主席法布里斯·勒菲弗尔阿维尼翁大学教授论文指导奥利维尔·皮耶昆谷歌研究教授:智囊团论文联合主任菲利普·普雷教授,大学。里尔/CRISTAL/因里亚报告员奥利维耶·西格德索邦大学报告员卢多维奇·德诺耶教授,Facebook /索邦大学审查员越南圣迈IMT Atlantic高级讲师邀请弗洛里安·斯特鲁布博士,Deepmind对于那些及时看到自己错误的人...3谢谢你首先,我要感谢我的两位博士生导师Olivier和Philippe。奥利维尔,"站在巨人的肩膀上"这句话对你来说完全有意义了。从科学上讲,你知道在这篇论文的(许多)错误中,你是我可以依
recommend-type

实现实时监控告警系统:Kafka与Grafana整合

![实现实时监控告警系统:Kafka与Grafana整合](https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9BVldpY3ladXVDbEZpY1pLWmw2bUVaWXFUcEdLT1VDdkxRSmQxZXB5R1lxaWNlUjA2c0hFek5Qc3FyRktudFF1VDMxQVl3QTRXV2lhSWFRMEFRc0I1cW1ZOGcvNjQw?x-oss-process=image/format,png) # 1.1 Kafka集群架构 Kafka集群由多个称为代理的服务器组成,这
recommend-type

python中从Excel中取的列没有了0

可能是因为Excel中的列被格式化为数字,而数字前导的0被省略了。可以在Excel中将列的格式更改为文本,这样就会保留数字前导的0。另外,在Python中读取Excel时,可以将列的数据类型指定为字符串,这样就可以保留数字前导的0。例如: ```python import pandas as pd # 读取Excel文件 df = pd.read_excel('data.xlsx', dtype={'列名': str}) # 输出列数据 print(df['列名']) ``` 其中,`dtype={'列名': str}`表示将列名为“列名”的列的数据类型指定为字符串。