leguadmin/xbackend
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

分布分析h5总数兼容

Browse Source
This commit is contained in:
Àî×ÚÕñ 2022-08-19 11:49:32 +08:00
parent a0592f8d0b
commit f074d0eb47
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
api/api_v1/endpoints/query.py
View File

@ -1557,7 +1557,14 @@ async def scatter_model(
if where == "step_id" and event_type == "guide": if where == "step_id" and event_type == "guide":
sql = f"""SELECT toDate(addHours({game}.event."#event_time", 8)) AS date, count(DISTINCT {game}.event."#account_id") AS values FROM {game}.event WHERE addHours({game}.event."#event_time", 8) >= '{start_date}' AND addHours({game}.event."#event_time", 8) <= '{end_date}' AND {game}.event."#event_name" = 'create_account' GROUP BY toDate(addHours({game}.event."#event_time", 8)) ORDER BY date""" sql = f"""SELECT toDate(addHours({game}.event."#event_time", 8)) AS date, count(DISTINCT {game}.event."#account_id") AS values FROM {game}.event WHERE addHours({game}.event."#event_time", 8) >= '{start_date}' AND addHours({game}.event."#event_time", 8) <= '{end_date}' AND {game}.event."#event_name" = 'create_account' GROUP BY toDate(addHours({game}.event."#event_time", 8)) ORDER BY date"""
df = await ckdb.query_dataframe(sql) df = await ckdb.query_dataframe(sql)
# for kk, ste_df in df.groupby('date'):
# if str(kk) not in resp['list']:
# continue
# value_list = ste_df.iloc[:, -1].to_list()
# resp['list'][str(kk)]['总体']['total'] = int(sum(value_list))
for i in range(len(df)): for i in range(len(df)):
if str(df['date'][i]) not in resp['list']:
continue
resp['list'][str(df['date'][i])]['总体']['total'] = int(df['values'][i]) resp['list'][str(df['date'][i])]['总体']['total'] = int(df['values'][i])
# 兼容下载功能 # 兼容下载功能
download = analysis.event_view.get('download', '') download = analysis.event_view.get('download', '')