update

task/tractate_analysis_in_7000.py

@@ -279,14 +279,14 @@ for res in sql_res:
         session_pv = res.session_pv
         # card_id_set.update(card_id)
         if cl_id in second_demands_tag_dict:
-            if int(card_id) not in second_demands_card_id_list:
-                continue
-            for tag_id in second_demands_tag_dict[cl_id]:
-                if tag_id in second_demands_id_count:
-                    second_demands_id_count[tag_id][int(card_id)] = 1
-                else:
-                    second_demands_id_count[tag_id] = {}
-                    second_demands_id_count[tag_id][int(card_id)] = 1
+            if int(card_id)  in second_demands_card_id_list:
+
+                for tag_id in second_demands_tag_dict[cl_id]:
+                    if tag_id in second_demands_id_count:
+                        second_demands_id_count[tag_id][int(card_id)] = 1
+                    else:
+                        second_demands_id_count[tag_id] = {}
+                        second_demands_id_count[tag_id][int(card_id)] = 1
 
                 # if tag_id in baoguang_dict:
                 #     baoguang_dict[tag_id] += session_pv
@@ -294,14 +294,13 @@ for res in sql_res:
                 #     baoguang_dict[tag_id] = session_pv
 
         if cl_id in projects_demands_tag_dict:
-            if int(card_id) not in tags_v3_card_id_list:
-                continue
-            for tag_id in projects_demands_tag_dict[cl_id]:
-                if tag_id in projects_demands_id_count:
-                    projects_demands_id_count[tag_id][int(card_id)] = 1
-                else:
-                    projects_demands_id_count[tag_id] = {}
-                    projects_demands_id_count[tag_id][int(card_id)] = 1
+            if int(card_id) in tags_v3_card_id_list:
+                for tag_id in projects_demands_tag_dict[cl_id]:
+                    if tag_id in projects_demands_id_count:
+                        projects_demands_id_count[tag_id][int(card_id)] = 1
+                    else:
+                        projects_demands_id_count[tag_id] = {}
+                        projects_demands_id_count[tag_id][int(card_id)] = 1
 
 final_projects_list = []
 second_demands_list = []

utils/func_from_es_get_article.py

@@ -344,7 +344,7 @@ def get_user_post_from_mysql(sql):
     tags_v3_count_dict = {}
     sql_res = con_sql_doris_prod(sql)
     for card_id in sql_res:
-        print(type(card_id[0]),card_id)
+        # print(type(card_id[0]),card_id)
 
         es_res = get_tractate_tags_from_es(card_id[0])
         for position in es_res["_source"]["second_demands"]: