ElasticSearch Java SpringBoot根据时间范围分组求和

需求是这样的:
近7天的用户登陆统计,根据日期来返回的要是data:[{date:“2021-04-01”,count:“1”}]

@Autowired
private ElasticsearchTemplate elasticsearchTemplate;SimpleDateFormat formater = new SimpleDateFormat("yyyy-MM-dd");
//这个是获取7天前的时间,比如说今天是4月29,7天前就是4月23,
//因为要包括今天,输出为"2021-04-23"
String startTime = DateUtil.getWeekFromNow();
//这个是输出今天的时间,格式为"2021-04-29"
String endTime = formater.format(new Date());
List<LoginLogDoc> loginLogDocList = new ArrayList<>();
List<EchartsVO> echartsVOS = new ArrayList<>();
BoolQueryBuilder bqb = QueryBuilders.boolQuery();
bqb.must(QueryBuilders.rangeQuery("createTime").from(startTime).to(endTime));
SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(bqb).withIndices("login_log").withTypes("login_log").withSearchType(SearchType.DEFAULT).build();
loginLogDocList= elasticsearchTemplate.queryForList(searchQuery,LoginLogDoc.class);
//因为我的createTime 是String型的,而且他的格式为"2021-04-29 12:00:00"
//循环list,把时间格式统一成yyyy-MM-dd
for (LoginLogDoc loginLogDoc : loginLogDocList) {loginLogDoc.setCreateTime(loginLogDoc.getCreateTime().substring(0,10));}
//loginLogDocList其实不是我想要返回的,因为我们主要是想返回 时间和count,现在查出来的是一条条的记录,我们要根据这些记录分组
//再把list根据时间createTime来分组统计,然后存入map
Map resultMap = new HashMap();
for (LoginLogDoc loginLogDoc : loginLogDocList) {loginLogDoc.setCreateTime(loginLogDoc.getCreateTime());Object obj = resultMap.get(loginLogDoc.getCreateTime());if(obj != null){resultMap.put(loginLogDoc.getCreateTime(), ((Integer) obj  + 1));}else{resultMap.put(loginLogDoc.getCreateTime(), 1);}
}
//再将map转换成我们需要的list。echartsVOS
resultMap.forEach((key, value) -> {EchartsVO echartsVO = new EchartsVO();echartsVO.setDate((String) key);echartsVO.setCount((Integer) value);echartsVOS.add(echartsVO);
});
//最好这个echartsVOS就是我们要的

在这里插入图片描述

login_log 是我们的实体类的名称:

@Getter
@Setter
@ToString
@Document(indexName = "login_log", type = "login_log", createIndex = false)
public class LoginLogDoc implements Serializable {/*** 记录id*/@Idprivate String loginLogId;/*** 用户id*/private Integer userId;/*** 登陆时间*/private String createTime;
}

有什么问题就给我留言吧

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

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

相关文章

开发springboot项目,遇到的一些问题总结

首先看一下我的项目目录吧 1&#xff0c;添加拦截器 我们做项目肯定要用到拦截器这个功能哈&#xff0c;没登录的话一些页面我们是不能访问的哈&#xff0c;这里是用到了HandlerInterceptor。 分别在图中的位置创建2个目录和2个文件&#xff1a; WebConfig: import org.sp…

elasticsearch根据时间范围查询总条数

根据创建时间来查询总条数 Autowired private ElasticsearchTemplate elasticsearchTemplate;String morning "2021-06-01"; String times "2021-06-02"; BoolQueryBuilder bqb QueryBuilders.boolQuery(); bqb.must(QueryBuilders.rangeQuery("cr…

利用tushare进行对兴业银行股价的爬取,并使用numpy进行分析

import sysimport tushare as tsimport numpy as npdatats.get_h_data(601066)print(data)#读出兴业银行7列数据date open high close low volume amount data.to_csv(E:/csv statistic/day/601066.csv) 把读取的股票数据存入某个内存空间中 #开始读某…

elasticsearch根据某个字段来查询,以及通过时间筛选

elasticsearch根据某个字段来查询&#xff0c;以及通过时间筛选 String startTime "2021-06-01"; String endTime "2021-06-02"; BoolQueryBuilder bqb QueryBuilders.boolQuery(); bqb.must(QueryBuilders.matchPhraseQuery("userId",userSt…

centOS下lnamp安装

首先安装apache,mysql ,最后安装php 1>apache安装 安装&#xff1a;yum install -y httpd 运行&#xff1a;/bin/systemctl start httpd.service 执行完运行命令之后是看不到效果的&#xff0c;这时候再输入查看apache服务状态命令来查看服务是否已经启动&#xff1a; 查看状…

java使用itext填充pdf模板,超简单教学,有手就行

java使用itext填充pdf模板1、先去建一个Word文件&#xff0c;设置好想要填充的地方&#xff0c;留好位置&#xff0c;设置好下划线2、将Word另存为pdf3、打开电脑中的Adobe Acrobat pro DC&#xff08;这个应该win10 都有&#xff0c;搜索一下就出来了&#xff09;&#xff0c;…

java使用itext将图片放到pdf模板的指定位置

java使用itext将图片放到pdf模板的指定位置前面的准备步骤可以参考我的上一篇文章这里直接上代码这里用的图片是路径的形式&#xff0c;还有种情况是图片是base64的时候&#xff0c;这种情况就需要转一下图片格式了&#xff0c;具体代码如下&#xff1a;前面的准备步骤可以参考…

KVM使用

这里使用的是Ubuntu18.04桌面版虚拟机 关于KVM可以看一下我之前的博客,有一些简单的介绍。 1.在打开虚拟机之前先开启此虚拟机的虚拟化功能。 2.安装KVM及其依赖项 wywy-virtual-machine:~$ sudo apt install qemu qemu-kvm libvirt-bin bridge-utils virt-manager 3.安装完成…

mybatis-plus3.5.1学习笔记

1、ID 1>id策略有6种&#xff1a; 想要id自增就在id上面添加 TableId(type IdType.AUTO)mybaits-plus的默认的主键策略是&#xff1a; TableId(type IdType.ID_WORKER)这样生成的是19位的数字id。 有的人喜欢使用UUID&#xff1a; TableId(type IdType.UUID)2、cre…

Python网络编程之socket编程

什么是Socket&#xff1f; Socket是应用层与TCP/IP协议族通信的中间软件抽象层&#xff0c;它是一组接口。在设计模式中&#xff0c;Socket其实就是一个门面模式&#xff0c;它把复杂的TCP/IP协议族隐藏在Socket接口后面&#xff0c;对用户来说&#xff0c;一组简单的接口就是全…

idea必装插件

1、lombok 这个是自动生成getter,setter的插件工具&#xff0c;现在idea已经集成了&#xff0c;好像不用单独去插件市场下载。 2、Free MyBatis Tool 官方话术&#xff1a; Free MyBatis Tool 是一款增强idea对mybatis支持的插件 主要功能如下&#xff1a; 生成mapper xml文…

mongodb查询分页优化

mongodb查询分页优化 转自&#xff1a;https://blog.csdn.net/chunqiuwei/article/details/11669885项目中需要用mongodb来进行数据测存储和查询,其中涉及到分页:分页的要求如下 1)每页显示10条 由于数据量太大,cursor.count()获取的符合条件的数据量也很大,导致分页得分好几万…

Contest Hunter 0103最短Hamilton路径 【状压dp】 By cellur925

题目传送门 Hamilton路径的定义&#xff1a;从0&#xff08;起点&#xff09;到n-1&#xff08;终点&#xff09;不重不漏地经过每个点恰好一次。 由于数据范围非常小&#xff0c;考虑状压。如NOIP2017宝藏一题&#xff0c;把状态压缩设为n个点是否已到达的二进制数。1表示到达…

Failed to execute operation: No such file or directory解决办法

在给Linux服务器安装docker的时候报错解决办法&#xff1a;1&#xff0c;在/etc/systemd/system/目录下创建docker.service2&#xff0c;进入docker.service文件3&#xff0c;将下面的代码复制进去4&#xff0c;复制进去以后&#xff0c;按Esc&#xff0c;在输入&#xff1a;wq…

The goal you specified requires a project to execute but there is no POM in this directory

使用maven安装jar包到本地仓库时遇到The goal you specified requires a project to execute but there is no POM in this directory我的命令是 mvn install:install-file -DfileD:\cao\gofastdfs-2.0.jar -DgroupIdcom.aaa-DartifactIdgofastdfs -Dversion2.0 找遍了百度才…

python实现二叉树的镜像

题目描述 操作给定的二叉树&#xff0c;将其变换为源二叉树的镜像。输入描述: 二叉树的镜像定义&#xff1a;源二叉树 8/ \6 10/ \ / \5 7 9 11镜像二叉树8/ \10 6/ \ / \11 9 7 5 # -*- coding:utf-8 -*- # class TreeNode: # def __init__(self, x): # …

java使用itext生成pdf,超简单教学,有手就行

前言&#xff1a;以前出过两期用itext填充pdf的文章&#xff0c;有人说那个会那字体加入到pdf中&#xff0c;导致pdf占用内存过大&#xff0c;那么今天就来分享一期另外的方法。 java使用itext生成pdf1、导包2、直接贴代码&#xff0c;然后大家看注释3、效果1、导包 <depen…

2018-2019-1 20165221 《信息安全系统设计基础》第一周学习总结

2018-2019-1 20165221 《信息安全系统设计基础》第一周学习总结 教材学习总结 有关vim 打开方式&#xff1a;vim [文件名]按i会进入insert模式&#xff0c;可以对代码进行编辑按Esc会进入普通模式&#xff0c;此时可以使用快捷键进行编辑&#xff0c;编辑方式为&#xff1a; 指…

itext5固定段落Paragraph,指定段落位置

前几期分析了怎么用itext生成pdf&#xff0c;有兴趣的可以去看看。 1&#xff0c;java使用itext生成pdf&#xff0c;超简单教学&#xff0c;有手就行 2&#xff0c;java使用itext填充pdf模板&#xff0c;超简单教学&#xff0c;有手就行 然后现在有了新的需求&#xff0c;需…

wordcount C

Gitee 代码链接&#xff1a;https://gitee.com/huangxue1111/codes/12rfs3ztj5ga8ymce7qi910 #include<stdio.h>#include<stdlib.h>#include<string.h>#include<windows.h>#define IN 1#define OUT 0void main() {FILE *fp;int length;fp fopen("…