rm user_i

eda/smart_rank/dist_update_user_portrait.py

@@ -91,24 +91,6 @@ def tag_list2dict(lst, size):
     return result[:size]
 
 
-def get_device_user_id(cl_id):
-    try:
-        db_zhengxing = pymysql.connect(host="172.16.30.141", port=3306, user="work",
-                                       password="BJQaT9VzDcuPBqkd",
-                                       db="zhengxing", cursorclass=pymysql.cursors.DictCursor)
-        cur_zhengxing = db_zhengxing.cursor()
-
-        sql = """select user_id from statistic_device_user where device_id = (select id from statistic_device where device_id = "{}")""".format(cl_id)
-        cur_zhengxing.execute(sql)
-        cl_id = cur_zhengxing.fetchall()
-        if cl_id:
-            return cl_id[0]["user_id"]
-        else:
-            return ""
-    except Exception as e:
-        print(e)
-
-
 def get_user_tag_score(cl_id, all_log_df, stat_date, size=10):
     try:
         db_jerry_test = pymysql.connect(host='172.16.40.158', port=4000, user='root', passwd='3SYz54LS9#^9sBvC',
@@ -128,9 +110,8 @@ def get_user_tag_score(cl_id, all_log_df, stat_date, size=10):
             finally_score_lst = finally_score[["tag_id","tag_score"]].to_dict('record')
             tag_id_list = tag_list2dict(finally_score_lst, size)
 
-            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=user_id, tag_list=tag_id_list)
+            replace_sql = """replace into user_portrait_tags (stat_date, cl_id, user_id, tag_list) values("{stat_date}","{cl_id}","{tag_list}")"""\
+                .format(stat_date=stat_date, cl_id=cl_id, tag_list=tag_id_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()
             db_jerry_test.close()