add level id 2

tensnsorflow/ffm.py

@@ -138,7 +138,7 @@ class multiFFMFormatPandas:
 
 def get_data():
     # db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
-    # sql = "select max(stat_date) from esmm_train_data"
+    # sql = "select max(stat_date) from jerry_test.esmm_train_data"
     # validate_date = con_sql(db, sql)[0].values.tolist()[0]
     validate_date = "2018-12-19"
     print("validate_date:" + validate_date)
@@ -146,17 +146,14 @@ def get_data():
     # start = (temp - datetime.timedelta(days=30)).strftime("%Y-%m-%d")
     start = "2018-11-19"
     print(start)
-    # db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_test')
-    # sql = "select e.y,e.z,e.stat_date,e.ucity_id,f.level2_ids,e.ccity_name," \
-    #       "u.device_type,u.manufacturer,u.channel,c.top,cid_time.time,s.hospital_id,s.doctor_id " \
-    #       "from esmm_train_data e left join user_feature u on e.device_id = u.device_id " \
-    #       "left join cid_type_top c on e.device_id = c.device_id left join cid_time on e.cid_id = cid_time.cid_id " \
-    #       "left join service_hospital s on e.diary_service_id = s.id left join diary_feat f" \
-    #       "where e.stat_date >= '{}'".format(start)
     db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC')
-    sql = "select e.y,e.z,e.stat_date,e.ucity_id,f.level2_ids " \
-          "from jerry_test.esmm_train_data e left join jerry_prod.diary_feat f " \
+    sql = "select e.y,e.z,e.stat_date,e.ucity_id,f.level2_ids,e.ccity_name," \
+          "u.device_type,u.manufacturer,u.channel,c.top,cid_time.time,s.hospital_id,s.doctor_id " \
+          "from jerry_test.esmm_train_data e left join jerry_test.user_feature u on e.device_id = u.device_id " \
+          "left join jerry_test.cid_type_top c on e.device_id = c.device_id left join jerry_test.cid_time on e.cid_id = cid_time.cid_id " \
+          "left join jerry_test.service_hospital s on e.diary_service_id = s.id left join jerry_prod.diary_feat f on e.cid_id = f.diary_id " \
           "where e.stat_date >= '{}'".format(start)
+
     df = con_sql(db, sql)
     print(df.shape)
     df = df.rename(columns={0: "y", 1: "z", 2: "stat_date", 3: "ucity_id",4: "clevel1_id", 5: "ccity_name",