java8 list map 聚合求和

news2024/11/7 15:08:35

目标:

统计地市的总的完成数量,并根据总数来排序。

要把下面的数据:

[
	{
		"city_name": "南京市",
		"carrier_id": "2",
		"carrier_name": "移动",
		"city_id": "0",
		"finish_num": 14
	},
	{
		"city_name": "南京市",
		"carrier_id": "5",
		"carrier_name": "移动转售企业",
		"city_id": "0",
		"finish_num": 1
	},
	{
		"city_name": "南京市",
		"carrier_id": "6",
		"carrier_name": "长城宽带",
		"city_id": "0",
		"finish_num": 1
	},
	{
		"city_name": "南京市",
		"carrier_id": "7",
		"carrier_name": "增值电信企业",
		"city_id": "0",
		"finish_num": 1
	},
	{
		"city_name": "无锡市",
		"carrier_id": "1",
		"carrier_name": "电信",
		"city_id": "1",
		"finish_num": 3
	},
	{
		"city_name": "镇江市",
		"carrier_id": "1",
		"carrier_name": "电信",
		"city_id": "10",
		"finish_num": 1
	}, 
	{
		"city_name": "常州市",
		"carrier_id": "2",
		"carrier_name": "移动",
		"city_id": "3",
		"finish_num": 1
	},
	{
		"city_name": "常州市",
		"carrier_id": "1",
		"carrier_name": "电信",
		"city_id": "3",
		"finish_num": 1
	},
	{
		"city_name": "常州市",
		"carrier_id": "5",
		"carrier_name": "移动转售企业",
		"city_id": "3",
		"finish_num": 1
	} 
]

目标格式:
 

[
	{
		"city_name": "南京市",
		"total": 17,
		"city_id": "0"
	},
	{
		"city_name": "常州市",
		"total": 5,
		"city_id": "3"
	},
	{
		"city_name": "无锡市",
		"total": 3,
		"city_id": "1"
	}
]

处理:

模拟数据:

public static List<Map<String, Object>> initData() {
        String data = "[\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"南京市\",\n" +
                "\t\t\"carrier_id\": \"2\",\n" +
                "\t\t\"carrier_name\": \"移动\",\n" +
                "\t\t\"city_id\": \"0\",\n" +
                "\t\t\"finish_num\": 14\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"南京市\",\n" +
                "\t\t\"carrier_id\": \"5\",\n" +
                "\t\t\"carrier_name\": \"移动转售企业\",\n" +
                "\t\t\"city_id\": \"0\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"南京市\",\n" +
                "\t\t\"carrier_id\": \"6\",\n" +
                "\t\t\"carrier_name\": \"长城宽带\",\n" +
                "\t\t\"city_id\": \"0\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"南京市\",\n" +
                "\t\t\"carrier_id\": \"7\",\n" +
                "\t\t\"carrier_name\": \"增值电信企业\",\n" +
                "\t\t\"city_id\": \"0\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"无锡市\",\n" +
                "\t\t\"carrier_id\": \"1\",\n" +
                "\t\t\"carrier_name\": \"电信\",\n" +
                "\t\t\"city_id\": \"1\",\n" +
                "\t\t\"finish_num\": 3\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"镇江市\",\n" +
                "\t\t\"carrier_id\": \"1\",\n" +
                "\t\t\"carrier_name\": \"电信\",\n" +
                "\t\t\"city_id\": \"10\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"宿迁市\",\n" +
                "\t\t\"carrier_id\": \"3\",\n" +
                "\t\t\"carrier_name\": \"联通\",\n" +
                "\t\t\"city_id\": \"12\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"外省\",\n" +
                "\t\t\"carrier_id\": \"1\",\n" +
                "\t\t\"carrier_name\": \"电信\",\n" +
                "\t\t\"city_id\": \"13\",\n" +
                "\t\t\"finish_num\": 3\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"徐州市\",\n" +
                "\t\t\"carrier_id\": \"3\",\n" +
                "\t\t\"carrier_name\": \"联通\",\n" +
                "\t\t\"city_id\": \"2\",\n" +
                "\t\t\"finish_num\": 2\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"常州市\",\n" +
                "\t\t\"carrier_id\": \"2\",\n" +
                "\t\t\"carrier_name\": \"移动\",\n" +
                "\t\t\"city_id\": \"3\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"常州市\",\n" +
                "\t\t\"carrier_id\": \"1\",\n" +
                "\t\t\"carrier_name\": \"电信\",\n" +
                "\t\t\"city_id\": \"3\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"常州市\",\n" +
                "\t\t\"carrier_id\": \"5\",\n" +
                "\t\t\"carrier_name\": \"移动转售企业\",\n" +
                "\t\t\"city_id\": \"3\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"常州市\",\n" +
                "\t\t\"carrier_id\": \"6\",\n" +
                "\t\t\"carrier_name\": \"长城宽带\",\n" +
                "\t\t\"city_id\": \"3\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t},\n" +
                "\t{\n" +
                "\t\t\"city_name\": \"常州市\",\n" +
                "\t\t\"carrier_id\": \"7\",\n" +
                "\t\t\"carrier_name\": \"增值电信企业\",\n" +
                "\t\t\"city_id\": \"3\",\n" +
                "\t\t\"finish_num\": 1\n" +
                "\t}\n" +
                "]";

        return changeFormat(data);

    }

    private static List<Map<String,Object>> changeFormat(String areaInfo){
        JSONArray areaArr = JSONArray.parseArray(areaInfo);
        return ListUtils.emptyIfNull(areaArr).stream().map(e -> (JSONObject) e)
                .map(e -> (Map<String, Object>)JSONObject.parseObject( e.toJSONString())).collect(Collectors.toList());
    }

方式一: 分布处理

先根据市进行聚合,再根据数量进行求和

  Map<String, List<Map<String, Object>>> cityGroup = ListUtils.emptyIfNull(cityCarrier).stream()
                .collect(Collectors.groupingBy(e -> e.get("city_id").toString()));

  Map<String, Integer> citySumMap = MapUtils.emptyIfNull(cityGroup).entrySet().stream()
.collect(Collectors.toMap(Map.Entry::getKey, t -> 
ListUtils.emptyIfNull(t.getValue()).stream().mapToInt(f -> 
MapUtils.getInteger(f, "finish_num")).sum()));
        System.out.println(citySumMap);

 能分步处理,说明可以聚合到一起处理

方式二:聚合处理

Map<String, IntSummaryStatistics> citySumMap2 = 
ListUtils.emptyIfNull(cityCarrier).stream()          
.collect(Collectors.groupingBy(e -> e.get("city_id").toString(),                  
Collectors.summarizingInt(f -> MapUtils.getInteger(f, "finish_num"))));

汇总:

public static void main(String[] args) {
        List<Map<String, Object>> cityCarrier = initData();
        Map<String, String> cityNameMap = ListUtils.emptyIfNull(cityCarrier).stream().collect(Collectors.toMap(e -> MapUtils.getString(e, "city_id"), f -> MapUtils.getString(f, "city_name"), (x, y) -> x));

        Map<String, IntSummaryStatistics> citySumMap2 = ListUtils.emptyIfNull(cityCarrier).stream()
                .collect(Collectors.groupingBy(e -> e.get("city_id").toString(),
                        Collectors.summarizingInt(f -> MapUtils.getInteger(f, "finish_num"))));
        List<Map<String, Object>> cityCountData = MapUtils.emptyIfNull(cityNameMap).entrySet().stream().map(e -> {
            String key = e.getKey();
            Map<String, Object> temp = new HashMap<>();
            temp.put("city_id", key);
            temp.put("city_name", e.getValue());
            temp.put("total", citySumMap2.get(key).getSum());
            return temp;
        }).collect(Collectors.toList());
        List<Map<String, Object>> result = ListUtils.emptyIfNull(cityCountData).stream().sorted((c1, c2) -> MapUtils.getDouble(c2, "total").compareTo(MapUtils.getDouble(c1, "total"))).collect(Collectors.toList());
        System.out.println(JSON.toJSONString(result));
    }

输出:

[
	{
		"city_name": "南京市",
		"total": 17,
		"city_id": "0"
	},
	{
		"city_name": "常州市",
		"total": 5,
		"city_id": "3"
	},
	{
		"city_name": "无锡市",
		"total": 3,
		"city_id": "1"
	},
	{
		"city_name": "外省",
		"total": 3,
		"city_id": "13"
	},
	{
		"city_name": "徐州市",
		"total": 2,
		"city_id": "2"
	},
	{
		"city_name": "宿迁市",
		"total": 1,
		"city_id": "12"
	},
	{
		"city_name": "镇江市",
		"total": 1,
		"city_id": "10"
	}
]

这样就达到目的了。

总结:

        list map 聚合求和,要熟悉第二种方式处理方式,写法比较简便。想不到就用第一种的方式,肯定可以。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2235096.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

(二)基于Bayes方法的道路分割

一、实验目的 1、实验目标 学习掌握Bayes定理&#xff08;Bayes Theorem&#xff09;的基本原理及推导过程&#xff0c;以及公式中的先验概率、条件概率、后验概率、相似度等概念。在MATLAB的概率分布函数基础上&#xff0c;通过编写程序&#xff0c;实现图像块内结果统计和序…

从新手到专家:7款电脑平面设计软件评测

平面设计在时尚、广告等多个领域扮演着重要角色&#xff0c;而创作出独特且富有创意的设计作品则需要依赖优秀的电脑平面设计软件。市场上的电脑平面设计软件众多&#xff0c;每款软件都有其独到之处。本文将为你推荐几款值得关注的电脑平面设计软件&#xff0c;并分析它们的特…

Django安装

在终端创建django项目 1.查看自己的python版本 输入对应自己本机python的版本&#xff0c;列如我的是3.11.8 先再全局安装django依赖包 2.在控制窗口输入安装命令&#xff1a; pip3.11 install django 看到Successflully 说明我们就安装成功了 python的Scripts文件用于存…

elementui中的新增弹窗在新增数据成功后再新增 发现数据无法清除解决方法

elementui中的新增弹窗在新增数据成功后再新增 发现数据无法清除解决方法 试过网上其他方法&#xff0c;发现表单清空数据还是有问题&#xff0c;索性用下面方法解决: // 给弹框里面添加 v-ifvisible测试无问题&#xff0c;暂时先这样解决&#xff0c;如果有其他方法&#x…

计算机网络——路由器构成

算路由表是分布式去算——你算你的&#xff0c;我算我的 输出队列非先来先传 调度发生在哪里 缓存队列一般是应对——来数据方向的速度过快问题

PMP–一、二、三模、冲刺–分类–7.成本管理–技巧–挣值分析

文章目录 技巧一模7.成本管理--4.控制成本--数据分析--挣值分析--进度绩效指数&#xff08;SPI&#xff09;是测量进度效率的一种指标&#xff0c;表示为挣值与计划价值之比&#xff0c;反映了项目团队完成工作的效率。 当 SPI小于 1.0 时&#xff0c;说明已完成的工作量未达到…

CentOS 7 更换软件仓库

CentOS 7 于2024年6月30日停止维护&#xff0c;官方仓库已经没有软件了&#xff0c;想要继续使用 &#xff0c;需要更换软件仓库&#xff0c;这里更换到阿里云的软件仓库 https://developer.aliyun.com/mirror/ 查看目前可用的软件数量 yum repolist 更换软件仓库&#xff1a…

Dermaseptin;抗菌肽;皮抑菌肽;ALWKTMLKKLGTMALHAGKAALGAAADTISQGTQ;136212-91-4

【Dermaseptin 简介】 Dermaseptin&#xff0c;也被称为皮抑菌肽&#xff0c;是一类由蛙类皮肤分泌的多阳离子抗菌肽&#xff0c;主要存在于树蛙科&#xff08;Hylid frogs&#xff09;的蛙类&#xff0c;特别是 Agalychnis 和 Phyllomedusa 属的蛙类。它具有显著的抗菌活性&a…

在培训班学网络安全有用吗

在当今数字化时代&#xff0c;网络安全问题日益凸显&#xff0c;成为了企业和个人关注的焦点。随着对网络安全人才需求的不断增长&#xff0c;各种网络安全培训班也如雨后春笋般涌现。然而&#xff0c;在培训班学网络安全真的有用吗? 一、网络安全的重要性与挑战 1. 信息时代的…

微积分复习笔记 Calculus Volume 1 - 4.7 Applied Optimization Problems

4.7 Applied Optimization Problems - Calculus Volume 1 | OpenStax

绿色能源发展关键:优化风电运维体系

根据QYResearch调研团队最新发布的《全球风电运维市场报告2023-2029》显示&#xff0c;预计到2029年&#xff0c;全球风电运维市场的规模将攀升至307.8亿美元&#xff0c;并且在接下来的几年里&#xff0c;其年复合增长率&#xff08;CAGR&#xff09;将达到12.5%。 上述图表及…

软件工程笔记一

目录 软件的概念、特性和分类 软件与程序 软件的特性 软件的分类 软件危机与软件工程 软件危机 如何摆脱软件危机? 软件工程概念的提出 什么是软件工程&#xff1f; 软件工程的若干定义 系统工程的目标 软件工程的基本原理 软件工程的目标 软件的质量特性 软件生存…

【数据结构】线性表——顺序表

文章目录 一、线性表二、顺序表2.1概念及结构2.2、顺序表接口实现2.2.1、顺序表的动态存储2.2.2、顺序表初始化2.2.3、检查空间判断进行增容2.2.4、顺序表尾插、尾删2.2.5、顺序表头插、头删2.2.6、顺序表查找2.2.7、顺序表在pos位置插入x2.2.8、顺序表删除pos位置的值2.2.9、顺…

stable diffusion 大模型

本节内容&#xff0c;给大家带来的是stable diffusion的基础模型课程。基础模型&#xff0c;我们有时候也称之为大模型。在之前的课程中&#xff0c;我们已经多次探讨过大模型&#xff0c;并且也见识过一些大模型绘制图片的独特风格&#xff0c;相信大家对stable diffusion大模…

ChatPaper.ai:研究生文献阅读的AI助手利器

为什么选择 ChatPaper.ai&#xff1f; 作为研究生&#xff0c;我们每天都面临着大量文献阅读的挑战。一篇关键论文往往需要反复阅读数小时&#xff0c;还要做笔记、提取要点、理解创新点&#xff0c;这个过程既耗时又费力。ChatPaper.ai&#xff08;ChatPaper.ai - Chat with …

python-docx -- 读取word图片

文章目录 概念介绍形状对象读取图片自定义图形 概念介绍 从概念上来讲&#xff0c;word文档分为两层&#xff0c;一个文本层&#xff0c;一个绘画层&#xff1b; 文本层&#xff0c;从上到下&#xff0c;从左到右&#xff0c;流式排版&#xff0c;本页填满则开启新页面&#…

Python邮差:如何用代码精确投递商品快递费用的密信

目录 一、准备工作 二、编写API请求脚本 三、解析与处理快递费用数据 四、案例应用&#xff1a;模拟电商平台的快递费用计算 五、自动化邮件通知 六、总结 在电子商务的广阔天地里&#xff0c;精确计算并快速传递商品快递费用是一项至关重要的任务。作为Python邮差&#…

swoole扩展安装--入门篇

对于php来说&#xff0c;swoole是个强大的补充扩展。这是我第3次写swoole扩展安装&#xff0c;这次基于opencloudos8系统&#xff0c;php使用8.2。 安装swoole扩展首先想到的是用宝塔来安装&#xff0c;毕竟安装方便&#xff0c;还能统一管理。虽然获得swoole版本不是最新的&am…

Linux信号_信号的保存

我们知道向进程发送信号&#xff0c;进程并不是立即处理&#xff0c;而是等合适的时机进行处理。那么就需要保存信号。在信号的产生中说过信号保存在进程PCB里面的信号位图里&#xff0c;那信号位图到底是什么&#xff1f; 一.信号保存 我们先补充一些概念 1.阻塞 忽略概念 实…

如何使用示波器测量信号强度

示波器是一种用于观察和分析电信号的电子测试仪器。它可以显示信号的波形、幅度、频率和其他特性&#xff0c;是工程师和技术人员进行电路设计、调试和故障排除的重要工具。本文将详细介绍如何使用示波器测量信号强度。 一、认识示波器的基本组成部分 显示屏&#xff1a;用于显…