Java8進(jìn)行多個字段分組統(tǒng)計(jì)的實(shí)例代碼
更新時間：2020年05月09日 08:12:54 作者：胖子學(xué)習(xí)天地
在本篇文章里小編給大家分享的是關(guān)于Java8進(jìn)行多個字段分組統(tǒng)計(jì)的實(shí)例代碼，需要的朋友們可以學(xué)習(xí)下。
Java8進(jìn)行多個字段分組統(tǒng)計(jì)實(shí)現(xiàn)代碼如下：
// 分組統(tǒng)計(jì)
Map<String, Long> countMap = records.stream().collect(Collectors.groupingBy(o -> o.getProductType() + "_" + o.getCountry(), Collectors.counting()));
List<Record> countRecords = countMap.keySet().stream().map(key -> {
String[] temp = key.split("_");
String productType = temp[0];
String country = temp[1];
Record record = new Record();
record.set("device_type", productType);
record.set("location", country;
record.set("count", countMap.get(key).intValue());
return record;
}).collect(Collectors.toList());
實(shí)例補(bǔ)充：
1.本實(shí)例其實(shí)可以用一句簡單的sql去實(shí)現(xiàn) 由于我們項(xiàng)目數(shù)據(jù)庫中時間存的是13位的時間戳 所以必須得轉(zhuǎn)行成日期格式 才能進(jìn)行分組 如下：
SELECT count(1) simpleNumber, SUM(penalty_amount) AS simplePenaltyAmount, Handling_department, create_time, LEFT(FROM_UNIXTIME(LEFT(create_time,10)),7) FROM t_case_simple_case WHERE 1 = 1 GROUP BY Handling_department,LEFT(FROM_UNIXTIME(LEFT(create_time,10)),7)
以上的就能實(shí)現(xiàn)多字段求和統(tǒng)計(jì)等功能 但我們老大考慮到查詢速度和換庫等問題 建議我不要用FROM_UNIXTIME（）函數(shù)，所以只能用最笨的方法一步步實(shí)現(xiàn) 以下是用Java8方式實(shí)現(xiàn)的 代碼如下：
@Override
public List<StatisticalAnalysis> queryFirstCase(String startTime,String condition,String caseType) {
List<StatisticalAnalysis> statisticalAnalyses = null;
//簡易案件
if (caseType.equals(CaseTypeEnum.SIMPLETYPE.code())) {
statisticalAnalyses = statisticalAnalysisDao.querySimpleData();
}
//一般案件
if (caseType.equals(CaseTypeEnum.NORMALTYPE.code())) {
statisticalAnalyses = statisticalAnalysisDao.queryNormalData();
}
for (StatisticalAnalysis analysis : statisticalAnalyses) {
try {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
String newCreateTime = sdf.format(new Date(Long.valueOf(analysis.getCreateTime())));
analysis.setCreateTime(newCreateTime);
SysOrg sysOrg = commonSearchDao.findByOrgId(analysis.getHandlingDepartment());
if (sysOrg != null) {
analysis.setHandlingDepartmentName(sysOrg.getOrgName());
}
if(analysis.getSimplePenaltyAmount()==null){
analysis.setSimplePenaltyAmount(0.0);
}
} catch (Exception e) {
e.printStackTrace();
}
}
List<StatisticalAnalysis> caseTotalList = new ArrayList<>();
//根據(jù)部門 日期進(jìn)行分組 統(tǒng)計(jì)
Map<String, Map<String, Long>> caseTotal = statisticalAnalyses.stream().collect(Collectors.groupingBy(StatisticalAnalysis::getCreateTime, Collectors.groupingBy(StatisticalAnalysis::getHandlingDepartmentName, Collectors.counting())));
//根據(jù)部門 日期進(jìn)行分組 求和
Map<String, Map<String, Double>> sumCase = statisticalAnalyses.stream().collect(Collectors.groupingBy(StatisticalAnalysis::getCreateTime, Collectors.groupingBy(StatisticalAnalysis::getHandlingDepartmentName, Collectors.summingDouble(StatisticalAnalysis::getSimplePenaltyAmount))));
//根據(jù)年份進(jìn)行模糊匹配 取出對應(yīng)的統(tǒng)計(jì)值
for (Map.Entry<String, Map<String, Long>> entry : caseTotal.entrySet()) {
if (entry.getKey().indexOf(startTime) > -1) {
StatisticalAnalysis statisticalAnalysis = new StatisticalAnalysis();
statisticalAnalysis.setCreateTime(entry.getKey());
//將年份-去掉 組成新的數(shù)字 主要作為排序
String key = entry.getKey().replace("-", "");
Integer sortNum = Integer.parseInt(key);
statisticalAnalysis.setSortNum(sortNum);
Map<String, Long> map = entry.getValue();
for (Map.Entry<String, Long> entr : map.entrySet()) {
statisticalAnalysis.setHandlingDepartmentName(entr.getKey());
statisticalAnalysis.setSimpleNumber(entr.getValue());
}
caseTotalList.add(statisticalAnalysis);
}
}
caseTotalList.sort((a, b) -> a.getSortNum() - b.getSortNum());
//根據(jù)年份進(jìn)行模糊匹配 取出對應(yīng)的求和值
List<StatisticalAnalysis> analyses = new ArrayList<>();
for (Map.Entry<String, Map<String, Double>> entry : sumCase.entrySet()) {
if (entry.getKey().indexOf(startTime) > -1) {
StatisticalAnalysis statisticalAnalysis = new StatisticalAnalysis();
statisticalAnalysis.setCreateTime(entry.getKey());
//將年份-去掉 組成新的數(shù)字 主要作為排序
String key = entry.getKey().replace("-", "");
Integer sortNum = Integer.parseInt(key);
statisticalAnalysis.setSortNum(sortNum);
Map<String, Double> map = entry.getValue();
for (Map.Entry<String, Double> entr : map.entrySet()) {
statisticalAnalysis.setHandlingDepartmentName(entr.getKey());
statisticalAnalysis.setSimplePenaltyAmount(entr.getValue());
}
analyses.add(statisticalAnalysis);
}
}
analyses.sort((a, b) -> a.getSortNum() - b.getSortNum());
//將統(tǒng)計(jì)和求和組合成一個新的集合返回前端
List<StatisticalAnalysis> analysisList = new ArrayList<>();
for (StatisticalAnalysis analys : caseTotalList) {
for (StatisticalAnalysis analys2 : analyses) {
StatisticalAnalysis statisticalAnalysis = new StatisticalAnalysis();
if (analys.getSortNum().intValue() == analys2.getSortNum().intValue()) {
statisticalAnalysis.setSimpleNumber(analys.getSimpleNumber());
statisticalAnalysis.setSimplePenaltyAmount(analys2.getSimplePenaltyAmount());
statisticalAnalysis.setCreateTime(analys.getCreateTime());
statisticalAnalysis.setHandlingDepartmentName(analys.getHandlingDepartmentName());
analysisList.add(statisticalAnalysis);
}
}
}
List<StatisticalAnalysis> newAnalysisList = new ArrayList<>();
if (analysisList.size() > 0) {
//查詢第一季度
if (condition.equals(YearEnum.FIRST.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-01") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-02") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-03") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FIRST.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
//查詢第二季度
if (condition.equals(YearEnum.SECOND.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-04") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-05") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-06") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.SECOND.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
//查詢第三季度
if (condition.equals(YearEnum.THREE.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-07") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-08") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-09") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.THREE.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
//查詢第四季度
if (condition.equals(YearEnum.FOUR.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-10") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-11") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-12") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.FOUR.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
//查詢上半年 取前六條數(shù)據(jù)
if (condition.equals(YearEnum.HALF.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-01") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-02") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-03") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-04") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-05") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-06") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.HALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
//查詢下半年 后六條數(shù)據(jù)
if (condition.equals(YearEnum.LASTHALF.code())) {
for (StatisticalAnalysis analysis : analysisList) {
StatisticalAnalysis analysis1 = new StatisticalAnalysis();
if (analysis.getCreateTime().indexOf(startTime + "-07") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-08") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-09") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-10") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-11") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
if (analysis.getCreateTime().indexOf(startTime + "-12") > -1) {
BeanUtils.copyProperties(analysis, analysis1);
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門簡易案件");
}else{
analysis1.setTitle(startTime+YearEnum.LASTHALF.desc()+"各部門一般案件");
}
newAnalysisList.add(analysis1);
}
}
return newAnalysisList;
}
if (condition.equals(YearEnum.FULLYEAR.code())) {
for (StatisticalAnalysis analysis : analysisList) {
if(caseType.equals(CaseTypeEnum.SIMPLETYPE.code())){
analysis.setTitle(startTime+YearEnum.FULLYEAR.desc()+"各部門簡易案件");
}else{
analysis.setTitle(startTime+YearEnum.FULLYEAR.desc()+"各部門一般案件");
}
}
return analysisList;
}
}
return null;
}
到此這篇關(guān)于Java8進(jìn)行多個字段分組統(tǒng)計(jì)的實(shí)例代碼的文章就介紹到這了,更多相關(guān)Java8進(jìn)行多個字段分組統(tǒng)計(jì)實(shí)現(xiàn)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了SpringBoot屬性注入的兩種方法，幫助大家更好的理解和使用springboot框架，感興趣的朋友可以了解下2020-11-11
Spring boot自定義http反饋狀態(tài)碼詳解
這篇文章主要給大家介紹了Spring boot自定義http反饋狀態(tài)碼的相關(guān)資料，文中介紹的非常詳細(xì)，對大家具有一定的參考學(xué)習(xí)價值，需要的朋友們下面跟著小編一起來學(xué)習(xí)學(xué)習(xí)吧。2017-06-06
SpringBoot全局配置long轉(zhuǎn)String丟失精度的問題解決
web項(xiàng)目中，Java后端傳過來的Long/long類型，前端JS接收會丟失精度。那么應(yīng)該如何解決，本文就來介紹一下幾種方法，感興趣的可以了解一下2021-08-08
spring boot2結(jié)合mybatis增刪改查的實(shí)現(xiàn)
這篇文章主要給大家介紹了關(guān)于spring boot2結(jié)合mybatis增刪改查的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家學(xué)習(xí)或者使用spring boot2具有一定的參考學(xué)習(xí)價值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-09-09
在spring注解中，使用聲明式事務(wù)，需要用到兩個核心的注解：@Transactional注解和@EnableTransactionManagement注解。將@Transactional注解加在方法上，@EnableTransactionManagement注解加在配置類上2022-12-12
這篇文章主要介紹了idea前后跳轉(zhuǎn)箭頭的快捷鍵，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-02-02
解決Mybatis查詢方法selectById()主鍵不一致問題
這篇文章主要介紹了解決Mybatis查詢方法selectById()主鍵不一致問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-10-10
一鍵清除maven倉庫中下載失敗的jar包的實(shí)現(xiàn)方法
這篇文章主要介紹了一鍵清除maven倉庫中下載失敗的jar包的實(shí)現(xiàn)方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
java開發(fā)微服務(wù)架構(gòu)設(shè)計(jì)消息隊(duì)列的水有多深
今天我們說說消息隊(duì)列的問題，來帶大家探一探消息隊(duì)列的水有多深，希望看完本文大家在引入消息隊(duì)列的時候先想一想，是不是一定要引入？引入消息隊(duì)列后產(chǎn)生的問題能不能解決2021-10-10
這篇文章主要介紹了JAVA解析XML字符串簡單方法代碼案例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-09-09