update

task/portary_article_distribution.py

@@ -52,7 +52,7 @@ bulk_dict = {
 task_list = []
 user_portrait_scan = user_portrait_scan_info()
 for redis_count,res in enumerate(user_portrait_scan):
-    # if redis_count >= 50:break
+    if redis_count >= 50:break
     second_demands = []
     projects = []
     total_answer_content_num = 0
@@ -139,20 +139,19 @@ for page_type in range(3):
         page_type_str = "帖子"
     else:
         page_type_str = "日记"
-    pid = str(page_type)
-    instert_sql = """replace into portary_article_distribution(
-    page_type,C0,C10,C50,C100,C200,C500,C1000,pid) VALUES('{page_type_str}',{C0},{C10},{C50},{C100},{C200},{C500},{C1000},'{pid}');""".format(
-        page_type_str=page_type_str,C0=bulk_dict[0][page_type],C10=bulk_dict[10][page_type],C50=bulk_dict[50][page_type],
-        C100=bulk_dict[100][page_type],C200=bulk_dict[200][page_type],C500=bulk_dict[500][page_type],
-        C1000=bulk_dict[1000][page_type],pid=pid
-    )
-    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 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)
 # cursor.executemany()
 db.close()