update

eda/smart_rank/dist_update_user_history_order_tags.py

@@ -19,24 +19,6 @@ 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:
@@ -50,9 +32,12 @@ 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)
+
+            sql_cl_id = "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)
+            cl_id = cur_zhengxing.fetchall()[0]["device_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()