update

task/portary_article_distribution.py

@@ -51,7 +51,7 @@ bulk_dict = {
 }
 task_list = []
 user_portrait_scan = user_portrait_scan_info()
-for res in user_portrait_scan:
+for redis_count,res in enumerate(user_portrait_scan):
     # if redis_count >= 50:break
     second_demands = []
     projects = []
@@ -131,6 +131,31 @@ for res in user_portrait_scan:
         bulk_dict[1000][2] += 1
 
     print(bulk_dict)
+    if redis_count % 500 == 0:
+        for page_type in range(3):
+            if page_type == 0:
+                page_type_str = "回答"
+            elif page_type == 1:
+                page_type_str = "帖子"
+            else:
+                page_type_str = "日记"
+            for count_num in bulk_dict:
+                pid = hashlib.md5((page_type_str + str(count_num)).encode("utf8")).hexdigest()
+                instert_sql = """replace into portary_article_distribution(
+                page_type,num_type,num_value,pid) VALUES('{page_type_str}','{num_type}',{num_value},'{pid}');""".format(
+                    page_type_str=page_type_str, pid=pid, num_type=str(count_num),
+                    num_value=bulk_dict[count_num][page_type]
+                )
+                print(instert_sql)
+                # cursor.execute("set names 'UTF8'")
+                db = pymysql.connect(host='172.16.40.158', port=4000, user='st_user',
+                                     passwd='aqpuBLYzEV7tML5RPsN1pntUzFy',
+                                     db='jerry_prod')
+                cursor = db.cursor()
+                res = cursor.execute(instert_sql)
+                db.commit()
+                print(res)
+
 
 for page_type in range(3):
     if page_type == 0: