每天凌晨一点进行跑批,对昨天一天内交易表所有交易账户的交易数据进行跑批,要求查找出每三分钟内所有符合规则的交易账号,并且进行统计汇总到表格中。
通过前置功能获取交易表中的所有账户编号去重,通过账户编号查出一天内所有的交易数据,通过交易时间排序,然后根据时间段分片,判断没个时间片内的交易数据是否符合规则逻辑,然后汇总。
这里将忽略数据查找(时间排序),将时间分片封装成一个公共类,通过传入交易数据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;
}
}
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。