diff --git a/api/api_v1/endpoints/xquery.py b/api/api_v1/endpoints/xquery.py index e1dcf05..affc29e 100644 --- a/api/api_v1/endpoints/xquery.py +++ b/api/api_v1/endpoints/xquery.py @@ -77,6 +77,9 @@ async def ltv_model_sql( avg_ltv = (df2[[f'sumpay_{i}' for i in ltv_n]].sum() / df2[cat].sum()).round(2) df1.loc[len(df1)] = ['均值', df2[cat].sum(), *avg_ltv] df1.insert(2, '累计LTV', 0) + + + last_ltv = [] for items in df1.values: for item in items[::-1]: @@ -84,6 +87,9 @@ async def ltv_model_sql( last_ltv.append(item) break df1['累计LTV'] = last_ltv + days = (pd.Timestamp.now().date() - pd.to_datetime(res['start_date']).date()).days + + df1.iloc[len(df1) - 1, days + 4:] = '-' data = { 'title': df1.columns.tolist(),