update

task/portary_article_distribution.py

@@ -40,20 +40,62 @@ def con_sql(sql):
     return result
 
 
+bulk_dict = {
+    0: [0, 0, 0],
+    10: [0, 0, 0],
+    50: [0, 0, 0],
+    100: [0, 0, 0],
+    200: [0, 0, 0],
+    500: [0, 0, 0],
+    1000: [0, 0, 0],
+}
 task_list = []
 user_portrait_scan = user_portrait_scan_info()
 for res in user_portrait_scan:
     second_demands = []
     projects = []
+    total_answer_content_num = 0
+    total_tractate_content_num = 0
+    total_diary_content_num = 0
     if res.get("second_demands"):
         second_demands = res.get("second_demands")
-        count_res = get_es_article_num({"second_demands": second_demands},allow_tag=["second_demands"])
+        count_res = get_es_article_num({"second_demands": second_demands[0:3]}, allow_tag=["second_demands"])
         print(count_res)
+        for article_type in count_res:
+            for tag in count_res[article_type]:
+                total_answer_content, total_tractate_content, total_diary_content, sum_num = \
+                    count_res[article_type][tag]
+                total_answer_content_num += total_answer_content
+                total_tractate_content_num += total_tractate_content
+                total_diary_content_num += total_diary_content
     if res.get("projects"):
         projects = res.get("projects")
-        count_res = get_es_article_num({"tags_v3": projects}, allow_tag=["tags_v3"])
+        count_res = get_es_article_num({"tags_v3": projects[0:3]}, allow_tag=["tags_v3"])
         print(count_res)
+        for article_type in count_res:
+            for tag in count_res[article_type]:
+                total_answer_content, total_tractate_content, total_diary_content, sum_num = \
+                    count_res[article_type][tag]
+                total_answer_content_num += total_answer_content
+                total_tractate_content_num += total_tractate_content
+                total_diary_content_num += total_diary_content
+    tmp_count_num = 0
+    for count_num in bulk_dict:
+        if tmp_count_num > total_answer_content_num:
+            pass
+        elif count_num <= total_answer_content_num:
+            bulk_dict[tmp_count_num][0] += 1
 
+        if tmp_count_num > total_tractate_content_num:
+            pass
+        elif count_num <= total_tractate_content_num:
+            bulk_dict[tmp_count_num][1] += 1
+
+        if tmp_count_num > total_diary_content_num:
+            pass
+        elif count_num <= total_diary_content_num:
+            bulk_dict[tmp_count_num][2] += 1
+    print(bulk_dict)
 #     for active_type in res_dict:
 #         for device_os_type in res_dict[active_type]:
 #             partition_date = yesterday_str