From 03aafe645d0fc33209c067ee58dfaa2f706731ad Mon Sep 17 00:00:00 2001 From: wuaho Date: Mon, 13 Sep 2021 11:51:33 +0800 Subject: [PATCH] 1 --- api/api_v1/endpoints/query.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/api/api_v1/endpoints/query.py b/api/api_v1/endpoints/query.py index a70a3dc..0f40941 100644 --- a/api/api_v1/endpoints/query.py +++ b/api/api_v1/endpoints/query.py @@ -145,7 +145,8 @@ async def event_model( df = await ckdb.query_dataframe(sql) df.fillna(0, inplace=True) if df.shape[0] == 0: - continue + df = pd.DataFrame({'date':date_range,'values':0*len(date_range)}) + # continue # return schemas.Msg(code=0, msg='ok', data=[q]) if item['time_particle'] == 'total': # for group, df_group in df.groupby(groupby): @@ -198,7 +199,7 @@ async def event_model( if len(df) >= 2: q['chain_ratio'] = division((df.iloc[-1, 1] - df.iloc[-2, 1]) * 100, df.iloc[-2, 1], 2) if len(df) >= 8: - q['wow'] = division((df.iloc[-1, 1] - df.iloc[-8, 1]) * 100 / df.iloc[-8, 1], 2) or 0 + q['wow'] = division((df.iloc[-1, 1] - df.iloc[-8, 1]) * 100, df.iloc[-8, 1], 2) or 0 q['values'].append(df['values'].to_list()) for last_value in df['values'].values[::-1]: if last_value > 0: