update

eda/smart_rank/dist_update_user_history_order_tags.py

@@ -19,6 +19,24 @@ from pyspark.sql.functions import lit
 from pyspark.sql.functions import concat_ws
 
 
+def get_user_device_id(user_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 device_id from statistic_device where id = (select max(device_id) from statistic_device_user where user_id = %d) " % (int(user_id))
+        cur_zhengxing.execute(sql)
+        cl_id = cur_zhengxing.fetchall()
+        if cl_id:
+            return cl_id[0]["device_id"]
+        else:
+            return ""
+    except Exception as e:
+        print(e)
+
+
 def get_user_history_order_service_tag(user_id, stat_date):
     try:
         if user_id:
@@ -32,20 +50,20 @@ def get_user_history_order_service_tag(user_id, stat_date):
                   "and b.tag_type<'4' ".format(user_id=user_id)
             cur_zhengxing.execute(sql)
             tags_dict = cur_zhengxing.fetchall()
+
             tags_list = [i["tag_id"] for i in tags_dict]
+            cl_id = get_user_device_id(user_id)
             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, tag_list) values("{stat_date}","{cl_id}","{tag_list}")"""\
-                .format(stat_date=stat_date, cl_id=cl_id, tag_list=tag_id_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, tag_list=tags_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()
             db_jerry_test.close()
-            return tags_list
-        else:
-            return []
+            return 'sucess'
     except Exception as e:
-        print(e)
+        return 'pass'
 
 
 if __name__ == '__main__':

eda/smart_rank/dist_update_user_portrait.py

@@ -96,8 +96,8 @@ def get_user_tag_score(cl_id, all_log_df, stat_date, size=10):
             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}",{user_id},"{tag_list}")"""\
+                .format(stat_date=stat_date, cl_id=cl_id, user_id=int(user_id), tag_list=tag_id_list)
             cur_jerry_test.execute(replace_sql)
             db_jerry_test.commit()
             db_jerry_test.close()