Browse Source

后台界面云存用户新增播放时间段过滤

chenshibin 3 years ago
parent
commit
416e4bfa3d
1 changed files with 21 additions and 0 deletions
  1. 21 0
      AdminController/ServeManagementController.py

+ 21 - 0
AdminController/ServeManagementController.py

@@ -751,6 +751,9 @@ class serveManagement(View):
         ucode = request_dict.getlist('ucode', None)
         ucode = request_dict.getlist('ucode', None)
         version = request_dict.getlist('version', None)
         version = request_dict.getlist('version', None)
 
 
+        # 日志表查询
+        logTimeRange = request_dict.getlist('logTimeRange[]', None)
+
         pageNo = request_dict.get('pageNo', None)
         pageNo = request_dict.get('pageNo', None)
         pageSize = request_dict.get('pageSize', None)
         pageSize = request_dict.get('pageSize', None)
         if not all([pageNo, pageSize]):
         if not all([pageNo, pageSize]):
@@ -810,6 +813,16 @@ class serveManagement(View):
 
 
             cg_qs = CloudLogModel.objects.filter(
             cg_qs = CloudLogModel.objects.filter(
                 operation='cloudstorage/queryvodlist')
                 operation='cloudstorage/queryvodlist')
+            if logTimeRange:
+                logStartTime, logEndTime = int(
+                    logTimeRange[0][:-3]), int(logTimeRange[1][:-3])
+                cg_qs = cg_qs.filter(
+                    time__gte=logStartTime,
+                    time__lte=logEndTime)
+                # 过滤套餐关联的UID_Bucket数据
+                uid_bucket_qs = uid_bucket_qs.filter(
+                    uid__in=cg_qs.values('uid'))
+
             list_data = []
             list_data = []
             count = uid_bucket_qs.count()
             count = uid_bucket_qs.count()
             uid_bucket_qs = uid_bucket_qs[(page - 1) * line:page * line]
             uid_bucket_qs = uid_bucket_qs[(page - 1) * line:page * line]
@@ -887,6 +900,8 @@ class serveManagement(View):
         ucode = request_dict.getlist('ucode', None)
         ucode = request_dict.getlist('ucode', None)
         version = request_dict.getlist('version', None)
         version = request_dict.getlist('version', None)
 
 
+        # 日志表查询
+        logTimeRange = request_dict.getlist('logTimeRange[]', None)
 
 
         try:
         try:
             uid_bucket_qs = UID_Bucket.objects.all()
             uid_bucket_qs = UID_Bucket.objects.all()
@@ -940,6 +955,12 @@ class serveManagement(View):
 
 
             cg_qs = CloudLogModel.objects.filter(
             cg_qs = CloudLogModel.objects.filter(
                 operation='cloudstorage/queryvodlist')
                 operation='cloudstorage/queryvodlist')
+            if logTimeRange:
+                logStartTime, logEndTime = int(
+                    logTimeRange[0][:-3]), int(logTimeRange[1][:-3])
+                cg_qs = cg_qs.filter(
+                    time__gte=logStartTime,
+                    time__lte=logEndTime)
             list_data = []
             list_data = []
             count = uid_bucket_qs.count()
             count = uid_bucket_qs.count()
             for uid_bucket in uid_bucket_qs:
             for uid_bucket in uid_bucket_qs: