修改志伟ctr统计文件

eda/gray_stat/ffm_get_data.py

@@ -22,34 +22,30 @@ def get_yesterday_date():
 def get_data():
     conn2db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
     cursor = conn2db.cursor()
-    sql = "select device_id from eagle.ffm_diary_queue_temp where device_id regexp '[5|6]$'"
+    sql = "select device_id from eagle.ffm_diary_queue where device_id regexp '[5|6]$'"
     cursor.execute(sql)
     result = cursor.fetchall()
-    device_id = tuple(pd.DataFrame(list(result))[0].values.tolist())
+    df = pd.DataFrame(list(result))
+    df.to_csv("/data2/ffm/10.3-10.9device_id.csv")
+    device_id = tuple(df[0].values.tolist())
     cursor.close()
     return device_id
 
 
-def ctr(date):
+def ctr():
     device_id = get_data()
-    sql_click = "select count(cid) from data_feed_click " \
-              "where cid_type = 'diary' " \
-                "and stat_date = '{}' and device_id in {};".format(date,device_id)
     db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='jerry_prod')
     cursor = db.cursor()
-    cursor.execute(sql_click)
-    click = cursor.fetchone()[0]
-    print("点击数："+str(click))
+    print("点击数："+str(len(device_id)))
     sql_exp = "select count(cid) from data_feed_exposure " \
-              "where cid_type = 'diary' and stat_date = '{}' and " \
-              "device_id in {}".format(date,device_id)
+              "where cid_type = 'diary' and stat_date <= '2018-10-09' and stat_date >= '2018-10-07' and " \
+              "device_id in {}".format(device_id)
     cursor.execute(sql_exp)
     exp = cursor.fetchone()[0]
     print("曝光数："+str(exp))
     if exp != 0:
-        print("点击率："+str(click/exp))
+        print("点击率："+str(len(device_id)/exp))
 
 
 if __name__ == "__main__":
-    date = get_yesterday_date()
-    ctr(date)
+    ctr()