update

task/tractate_analysis_in_7000.py

@@ -182,44 +182,44 @@ total_tag_count_pro = {}
 temp_null_count = 0
 
 
-# for redis_count, device_id in enumerate(device_id_dict):
-#
-#     # if redis_count >= 50:break
-#     second_demands = []
-#     projects = []
-#     total_answer_content_num = 0
-#     total_tractate_content_num = 0
-#     total_diary_content_num = 0
-#     # print(sql_res)
-#     try:
-#         res = get_user_portrait_tag3_from_redis(device_id)
-#     except:
-#         continue
-#     if res.get("second_demands"):
-#         second_demands = res.get("second_demands")
-#         # print(count_res)
-#         for tag in second_demands:
-#             if tag in second_demands_tag_count:
-#                 second_demands_tag_count[tag] += 1
-#             else:
-#                 second_demands_tag_count[tag] = 1
-#             if tag in second_demands_count_dict:
-#                 total_tractate_content_num += second_demands_count_dict[tag]
-#         second_demands_tag_dict[device_id] = second_demands
-#     if res.get("projects"):
-#         projects = res.get("projects")
-#         # print(count_res)
-#         for tag in projects:
-#             if tag in projects_demands_tag_count:
-#                 projects_demands_tag_count[tag] += 1
-#             else:
-#                 projects_demands_tag_count[tag] = 1
-#
-#             if tag in tags_v3_count_dict:
-#                 total_tractate_content_num += tags_v3_count_dict[tag]
-#         projects_demands_tag_dict[device_id] = projects
-#     # print(total_answer_content_num, total_tractate_content_num, total_diary_content_num)
-#     tmp_count_num = 0
+for redis_count, device_id in enumerate(device_id_dict):
+
+    # if redis_count >= 50:break
+    second_demands = []
+    projects = []
+    total_answer_content_num = 0
+    total_tractate_content_num = 0
+    total_diary_content_num = 0
+    # print(sql_res)
+    try:
+        res = get_user_portrait_tag3_from_redis(device_id)
+    except:
+        continue
+    if res.get("second_demands"):
+        second_demands = res.get("second_demands")
+        # print(count_res)
+        for tag in second_demands:
+            if tag in second_demands_tag_count:
+                second_demands_tag_count[tag] += 1
+            else:
+                second_demands_tag_count[tag] = 1
+            if tag in second_demands_count_dict:
+                total_tractate_content_num += second_demands_count_dict[tag]
+        second_demands_tag_dict[device_id] = second_demands
+    if res.get("projects"):
+        projects = res.get("projects")
+        # print(count_res)
+        for tag in projects:
+            if tag in projects_demands_tag_count:
+                projects_demands_tag_count[tag] += 1
+            else:
+                projects_demands_tag_count[tag] = 1
+
+            if tag in tags_v3_count_dict:
+                total_tractate_content_num += tags_v3_count_dict[tag]
+        projects_demands_tag_dict[device_id] = projects
+    # print(total_answer_content_num, total_tractate_content_num, total_diary_content_num)
+    tmp_count_num = 0
 
 # 7000片内容的曝光
 
@@ -271,9 +271,10 @@ for res in sql_res:
     # print(res)
     cl_id = res.cl_id
     if cl_id in device_id_dict:
+        print("has device")
         card_id = res.card_id
         if card_id not in card_id_list:continue
-
+        print("has card_id")
         session_pv = res.session_pv
         # card_id_set.update(card_id)
         if cl_id in second_demands_tag_dict: