前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >写一个工具类-根据分钟片将一个按时间有序的List分片

写一个工具类-根据分钟片将一个按时间有序的List分片

原创
作者头像
青衫染红尘
发布2021-11-30 20:00:33
3730
发布2021-11-30 20:00:33
举报
文章被收录于专栏:Surpass' BlogSurpass' Blog

业务场景

每天凌晨一点进行跑批,对昨天一天内交易表所有交易账户的交易数据进行跑批,要求查找出每三分钟内所有符合规则的交易账号,并且进行统计汇总到表格中。

说明

通过前置功能获取交易表中的所有账户编号去重,通过账户编号查出一天内所有的交易数据,通过交易时间排序,然后根据时间段分片,判断没个时间片内的交易数据是否符合规则逻辑,然后汇总。

这里将忽略数据查找(时间排序),将时间分片封装成一个公共类,通过传入交易数据List, 时间分片要求,和排序的字段名称,方法内部通过队列先进先出的特点,一次比较后进来的交易,大于时间片要求则弹出,反复如此,最终得到每个时间片集合。

注意:该类具有一定的针对性,适合该业务流程,非通用方法。例如返回类型,时间片等。

还有没想到的地方,如果有什么问题还请提出来,一定及时回复。

代码语言:java
复制
public class MinuteTransUtil {

    /**
     *
     * @param list  交易时间正序的交易数据
     * @param minute  限定的分钟切割点
     * @param transTimeKey  mongoDB交易时间key
     * @return java.util.List<java.util.Map < java.lang.String, java.lang.Object>>
     * @throws
     * @author Surpass
     * @date 2021/8/9 11:18
     */
    public static Map<String, Object> minutesTransForObj(List<DBObject> list, Integer minute,
                                                    String transTimeKey){
        Map<String, Object> returnMap = new HashMap<>();
        //队列中最早的时间
        Date firstTransTime = null;
        Queue<DBObject> mintuesQueue = new LinkedList<>();
        Integer key = 1;
        for (DBObject dbObject : list) {
            if (mintuesQueue.size() == 0){
                mintuesQueue.offer(dbObject);
                continue;
            }
            DBObject start = mintuesQueue.peek();
            firstTransTime = (Date) start.get(transTimeKey);
            Date currentTransTime = (Date) dbObject.get(transTimeKey);
            if (DateUtil.between(firstTransTime, currentTransTime, DateUnit.SECOND) <= (minute * 60)){
                //将指定分钟数的所有交易放入队列中
                mintuesQueue.offer(dbObject);
                continue;
            }else {
                //分钟片
                returnMap.put(key.toString(), new ArrayList(mintuesQueue));
                key++;

                //将队列中所有第一个交易时间和当前交易时间对比,大于指定分钟数的逐一弹出
                while (DateUtil.between(firstTransTime, currentTransTime, DateUnit.SECOND) > (minute * 60)){
                    DBObject first = mintuesQueue.peek();
                    firstTransTime = (Date)first.get(transTimeKey);
                    if (DateUtil.between(firstTransTime, currentTransTime, DateUnit.SECOND) > (minute * 60)){
                        mintuesQueue.poll();
                    }
                    first = mintuesQueue.peek();
                    if (first != null){
                        firstTransTime = (Date) mintuesQueue.peek().get(transTimeKey);
                    }else {
                        mintuesQueue.offer(dbObject);
                        break;
                    }
                }
                if (DateUtil.between(firstTransTime, currentTransTime, DateUnit.SECOND) <= (minute * 60)){
                    mintuesQueue.offer(dbObject);
                }
            }
        }
        returnMap.put(key.toString(), new ArrayList(mintuesQueue));

        return returnMap;
    }
}

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 业务场景
  • 说明
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档