|
@@ -9,7 +9,6 @@ db = MysqlUtils()
|
|
|
|
|
|
|
|
|
def insert_order_data(ymd):
|
|
|
- # TODO: 游戏名字为''就是游戏id为0的那个游戏
|
|
|
logging.info('订单数据格式转换 ,开始 ')
|
|
|
datatime_ymd = datetime.strptime(ymd, '%Y-%m-%d').astimezone(timezone(timedelta(hours=8))).timetuple()
|
|
|
timestamp_ymd = time.mktime(datatime_ymd)
|
|
@@ -21,16 +20,16 @@ def insert_order_data(ymd):
|
|
|
select DATE(FROM_UNIXTIME(a.create_time)),'',payway as order_type,c.wx_name,a.app_id ,f.id as user_id,
|
|
|
DATE_FORMAT(FROM_UNIXTIME(a.create_time), '%Y-%m-%d %H:%i:%s') as order_time,
|
|
|
DATE_FORMAT(FROM_UNIXTIME(f.create_time), '%Y-%m-%d %H:%i:%s') as reg_time,
|
|
|
- a.amount ,ifnull(e.name,''),a.order_id ,a.status
|
|
|
+ a.amount ,ifnull(d.name,''),a.order_id ,a.status
|
|
|
from db_mp.h_pay a
|
|
|
left join db_mp.mp_conf_agent b on a.app_id =b.app_id and a.agent_id =b.agent_id
|
|
|
left join db_mp.mp_mp_conf c on b.advertiser_conf_id =c.id
|
|
|
left join db_mp.h_game d on a.app_id =d.id
|
|
|
- left join db_mp.h_game e on d.parent_id = e.id
|
|
|
left join db_mp.h_member f on a.mem_id = f.id
|
|
|
where c.`type` =7
|
|
|
and a.create_time<{timestamp_tom} and a.create_time>{timestamp_ymd}
|
|
|
'''
|
|
|
+ # print(sql)
|
|
|
list_ = db.db_mp.get_data_list(sql)
|
|
|
data_list = []
|
|
|
for _ in list_:
|
|
@@ -43,14 +42,16 @@ def insert_order_data(ymd):
|
|
|
db.quchen_text.executeMany(sql, data_list)
|
|
|
logging.info('订单数据格式转换 ,结束 ')
|
|
|
|
|
|
+
|
|
|
def insert_order_data_hourly():
|
|
|
insert_order_data(du.getNow())
|
|
|
|
|
|
|
|
|
def insert_order_data_daily():
|
|
|
- for i in du.getDateLists(du.get_n_days(-10),du.get_n_days(0)):
|
|
|
+ for i in du.getDateLists(du.get_n_days(-200), du.get_n_days(0)):
|
|
|
+ # print(i)
|
|
|
insert_order_data(i)
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
- insert_order_data_daily()
|
|
|
+ insert_order_data_daily()
|