新增事件首次触发间隔分析1

api/api_v1/endpoints/query.py

@@ -1717,6 +1717,8 @@ async def first_event_model(
     res_msg = {
         'level': true_step,
         'list': list_data,
+        'start_date': res['start_date'],
+        'end_date': res['end_date'],
         'p': p_data
     }
     return schemas.Msg(code=0, msg='ok', data=res_msg)

models/behavior_analysis.py

@@ -361,7 +361,7 @@ class BehaviorAnalysis:
 
         return event_filters, user_filters
 
-    async def handler_filts(self, *filters,nu=0):
+    async def handler_filts(self, *filters, nu=0):
         """
 
         :param filters: (filts:list,relation:str)
@@ -568,7 +568,7 @@ class BehaviorAnalysis:
         """事件分析生成sql会经过"""
         sqls = []
         event_time_col = getattr(self.event_tbl.c, '#event_time')
-        for idx,event in enumerate(self.events):
+        for idx, event in enumerate(self.events):
             operator_ = event.get('operator_val', '')
             # 排头显示名
             event_name_display = event.get('eventNameDisplay')
@@ -947,7 +947,16 @@ ORDER BY level
         event_end = self.events[1]  # 查询事件
         start_event_name = event_start.get('eventName', 'create_account')
         end_event_name = event_end.get('eventName', 'pay')
-        sql_diff = self.event_view.get('event_diff', 'minute')  # 类型选择 'year','month','day','hour','minute','second'
+        diff_dict = {
+            'year': 'year',
+            'P1M': 'year',
+            'P1D': 'year',
+            'PT1H': 'year',
+            'PT1M': 'minute',
+            'second': 'second'
+        }
+        view_diff = self.event_view.get('event_diff', 'PT1M')  # 类型选择 'year','month','day','hour','minute','second'
+        sql_diff = diff_dict.get(view_diff, 'minute')
         # end_where = event_end.get('filts', [])
         # end_where_str = ''
         # if end_where: