|
@@ -6,6 +6,7 @@ import json
|
|
|
import time
|
|
|
import traceback
|
|
|
from argparse import ArgumentParser
|
|
|
+from collections import defaultdict
|
|
|
from datetime import datetime, timedelta
|
|
|
from typing import List, Dict
|
|
|
|
|
@@ -224,6 +225,18 @@ class UpdateMiniProgramInfoTask(object):
|
|
|
L[key] = temp
|
|
|
return L
|
|
|
|
|
|
+ def summarize_v2(value):
|
|
|
+ """
|
|
|
+
|
|
|
+ :param value:
|
|
|
+ :return:
|
|
|
+ """
|
|
|
+ first_level = defaultdict(set)
|
|
|
+ fission_level = defaultdict(list)
|
|
|
+
|
|
|
+ for record in value:
|
|
|
+ type_, machinecode, create_time, first_level_dt = record
|
|
|
+
|
|
|
try:
|
|
|
response = summarize(result_list)
|
|
|
log(
|