update

eda/smart_rank/dist_update_user_history_order_tags.py

@@ -56,8 +56,8 @@ def get_user_history_order_service_tag(user_id, stat_date):
             db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
                                             db='jerry_test', charset='utf8')
             cur_jerry_test = db_jerry_test.cursor()
-            replace_sql = """replace into user_history_order_tags (stat_date, cl_id, user_id, tag_list) values("{stat_date}","{cl_id}",user_id,"{tag_list}")"""\
-                .format(stat_date=stat_date, cl_id=cl_id, tag_list=tags_list)
+            replace_sql = """replace into user_history_order_tags (stat_date, cl_id, user_id, tag_list) values("{stat_date}","{cl_id}",{user_id},"{tag_list}")"""\
+                .format(stat_date=stat_date, cl_id=cl_id, user_id=user_id, tag_list=tags_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()
             db_jerry_test.close()

eda/smart_rank/dist_update_user_portrait.py

@@ -97,7 +97,7 @@ def get_user_tag_score(cl_id, all_log_df, stat_date, size=10):
 
             user_id = get_device_user_id(cl_id)
             replace_sql = """replace into user_portrait_tags (stat_date, cl_id, user_id, tag_list) values("{stat_date}","{cl_id}",{user_id},"{tag_list}")"""\
-                .format(stat_date=stat_date, cl_id=cl_id, user_id=int(user_id), tag_list=tag_id_list)
+                .format(stat_date=stat_date, cl_id=cl_id, user_id=user_id, tag_list=tag_id_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()
             db_jerry_test.close()