java操作 mongodb 进行 按天、周、月分组统计

Wesley13
• 阅读 741
public List<PlaybackEntity> queryPlaybackRecord(FunctionUseQueryEntity queryEntity){
        Criteria criteria = Criteria.where("createTime").gte(queryEntity.getStartTime()).lte(queryEntity.getEndTime())
                            .and("status").is(1);
        Query query = Query.query(criteria);    
        
        BasicDBObject initial = new BasicDBObject();
        initial.put("playbackNum", 0);
        
        String reduce = getReduce();
        //进行按天、周、月分组
        String keyf = getKeyf(queryEntity);
           
        DBCollection collection = mongoTemplate.getCollection(COLLNAME);
        
        GroupCommand xx = new GroupCommand(collection, keyf, query.getQueryObject(), initial, reduce, null);
 
        BasicDBList  objects =  (BasicDBList)collection.group(xx);
        
        List<PlaybackEntity> results = new ArrayList<PlaybackEntity>();
        if (objects != null) {
            for (int i = 0; i < objects.size(); i++) {
                PlaybackEntity play = new PlaybackEntity();
                DBObject obj = (DBObject) objects.get(i);
                play.setFormateTime((String)obj.get("strData"));
                play.setPlaybackNum((Double)obj.get("playbackNum"));
                results.add(play);
            }
        }
        return results;
    }

    private String getKeyf(FunctionUseQueryEntity queryEntity) {
        StringBuilder keyfBuilder = new StringBuilder();
        keyfBuilder.append("function(doc){ ")
                    .append("    var date = new Date(doc.createTime); ");
        if(DateType.DATE.getValue().equals(queryEntity.getType())){
            keyfBuilder.append("    var dateKey = '' + date.getFullYear()+ '-' + (date.getMonth()+1) + '-' + date.getDate();");
        }else if(DateType.WEEK.getValue().equals(queryEntity.getType())){
            keyfBuilder.append("    var firstDay = new Date(date.getFullYear(),0, 1);")
                       .append("    var dayOfWeek = firstDay.getDay();") 
                       .append("    var spendDay= 1;") 
                       .append("    if (dayOfWeek !=0) {") 
                       .append("         spendDay= 7 - dayOfWeek + 1;") 
                       .append("    }") 
                       .append("    firstDay = new Date(date.getFullYear(), 0, 1 + spendDay);") 
                       .append("    var d =Math.ceil((date.valueOf()- firstDay.valueOf())/ 86400000);") 
                       .append("    var week =Math.ceil(d/7);") 
                       .append("    week = week + 1;"); 
            keyfBuilder.append("    var dateKey = '' + date.getFullYear()+ '-' + week;");
        }else if(DateType.MONTH.getValue().equals(queryEntity.getType())){
            keyfBuilder.append("    var dateKey = '' + date.getFullYear()+ '-' + (date.getMonth()+1);");
        }
        keyfBuilder.append("    return {'strData':dateKey};  ")
                   .append(" }");
        return keyfBuilder.toString();
    }

    private String getReduce() {
        StringBuilder reduceBuilder = new StringBuilder();
        reduceBuilder.append("function Reduce(doc, out) { ")
                     .append("    out.playbackNum += 1; ")
                     .append(" }");
        return reduceBuilder.toString();
    }
点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Wesley13 Wesley13
3年前
java基础知识随身记
2018年11月12日20:51:35一、基础知识:1、JVM、JRE和JDK的区别:JVM(JavaVirtualMachine):java虚拟机,用于保证java的跨平台的特性。  java语言是跨平台,jvm不是跨平台的。JRE(JavaRuntimeEnvironment):java的运行环境,包括jvmjava的核心类
Wesley13 Wesley13
3年前
Java日期时间API系列31
  时间戳是指格林威治时间1970年01月01日00时00分00秒起至现在的总毫秒数,是所有时间的基础,其他时间可以通过时间戳转换得到。Java中本来已经有相关获取时间戳的方法,Java8后增加新的类Instant等专用于处理时间戳问题。 1获取时间戳的方法和性能对比1.1获取时间戳方法Java8以前
Stella981 Stella981
3年前
Python之time模块的时间戳、时间字符串格式化与转换
Python处理时间和时间戳的内置模块就有time,和datetime两个,本文先说time模块。关于时间戳的几个概念时间戳,根据1970年1月1日00:00:00开始按秒计算的偏移量。时间元组(struct_time),包含9个元素。 time.struct_time(tm_y
Wesley13 Wesley13
3年前
4,MongoDB 之 $关键字 及 $修改器 $set $inc $push $pull $pop MongoDB
MongoDB中的关键字有很多,$lt$gt$lte$gte等等,这么多我们也不方便记,这里我们说说几个比较常见的一.查询中常见的等于大于小于大于等于小于等于等于:在MongoDB中什么字段等于什么值其实就是":"来搞定比如"name":"路飞学城"!(https://oscimg.oschin
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Wesley13 Wesley13
3年前
oracle查询表数据并重新插入到本表
oracle查询表数据并重新插入到本表CreateTime2018年5月17日10:30:10Author:Marydon1.情景描述查询表中数据SELECTFROMat_aut
Wesley13 Wesley13
3年前
JavaWeb 调用接口
JavaWeb 如何调用接口CreateTime2018年4月2日19:04:29Author:Marydon1.所需jar包!(https://oscimg.oschina.net/oscnet/0f139
Wesley13 Wesley13
3年前
Java日期时间API系列23
  有时候,往往需要统计某个时间区间的销量等问题,这就需要准确的起始时间,获取准确开始时间00:00:00,获取准确结束时间23:59:59。下面增加了一一些方法,获取当天起始时间,昨天起始时间,当前月第一天开始时间,当前月最后一天结束时间,上个月第一天开始时间,上个月最后一天结束时间,某个指定月的起始结束时间等等。其中月份最后一天往往因为月份不同和