业务场景

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

说明

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

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

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

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

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;
    }
}