业务场景
每天凌晨一点进行跑批，对昨天一天内交易表所有交易账户的交易数据进行跑批，要求查找出每三分钟内所有符合规则的交易账号，并且进行统计汇总到表格中。
说明
通过前置功能获取交易表中的所有账户编号去重，通过账户编号查出一天内所有的交易数据，通过交易时间排序，然后根据时间段分片，判断没个时间片内的交易数据是否符合规则逻辑，然后汇总。
这里将忽略数据查找（时间排序），将时间分片封装成一个公共类，通过传入交易数据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;
}
}
