ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

传递日期参数

Browse Source
This commit is contained in:
pengtao 2019-10-24 14:18:53 +08:00
parent 1aaa4c4bf7
commit d96abe48ee
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
daily_report/dreport.py
View File

@ -196,7 +196,7 @@ class Report:
and gameid='{args['gameid']}' and gameid='{args['gameid']}'
and "channel"='{args['channelid']}' and "channel"='{args['channelid']}'
and "$part_date"='{self.day}' and "$part_date"='{self.day}'
and "button_name" ='jc_promotipn'""" and "button_name" like 'wx%_success'"""
try: try:
activa = args['tga'].get_data(activa_sql)[0][0] activa = args['tga'].get_data(activa_sql)[0][0]
@ -275,7 +275,6 @@ class Report:
def get_output_fromappid(self, **args): def get_output_fromappid(self, **args):
log.info(f"XXXX gameid={args['gameid']} P{args}")
if args['gameid'] not in (2001, 2002): if args['gameid'] not in (2001, 2002):
jump_sql = f"""SELECT jump_sql = f"""SELECT
count("#account_id"),count(distinct "#account_id") count("#account_id"),count(distinct "#account_id")
@ -298,8 +297,7 @@ class Report:
and gameid='{args['gameid']}' and gameid='{args['gameid']}'
and "channel"='{args['channelid']}' and "channel"='{args['channelid']}'
and "$part_date"='{self.day}' and "$part_date"='{self.day}'
and "button_name" ='jc_promotipn' and "button_name"='{args['fromappid']}_success'"""
and cast(json_extract(trim(button_param,'[]"'),'$.appid') as varchar)='{args['fromappid']}'"""
data = args['tga'].get_data(jump_sql) data = args['tga'].get_data(jump_sql)
if data: if data:
@ -375,7 +373,9 @@ class Report:
for f_key in f_keys: for f_key in f_keys:
args['fromappid'] = f_key args['fromappid'] = f_key
args['fromappid_cn'] = fromappids.get(f_key, None) or "未知" args['fromappid_cn'] = fromappids.get(f_key, None) or "未知"
temp['input'].append(self.get_input_fromappid(**args)) # 2001 暂无买量数据
if args['gameid'] not in (2001, 2002):
temp['input'].append(self.get_input_fromappid(**args))
temp['output'].append(self.get_output_fromappid(**args)) temp['output'].append(self.get_output_fromappid(**args))
print(temp) print(temp)
data.append(temp) data.append(temp)