去掉阈值，

分页

deal/videos_deal.py

@@ -18,7 +18,7 @@ class VideoDeal(object):
         self.pageSize = params.get("page_size", 50)
         self.mysql_client = mysql_client
 
-    def response_obj(self, data_list):
+    def response_obj(self, data_list, data_list2):
         """
         处理 return 信息
         :param data_list:
@@ -50,8 +50,8 @@ class VideoDeal(object):
             "cate": self.cate,
             "start_date": self.start_dt,
             "end_dt": self.end_dt,
-            # "topN": self.topN,
-            "data": L
+            "data": L,
+            "next_page": True if data_list2 else False
         }
         return response
 
@@ -74,7 +74,7 @@ class VideoDeal(object):
         return
         :return:
         """
-        sql = f"""
+        this_pag_sql = f"""
             SELECT video_id, title, view_, return_, video_url, rov
             FROM top_return_daily 
             WHERE dt >= '{self.start_dt}' and dt < '{self.end_dt}' 
@@ -82,15 +82,17 @@ class VideoDeal(object):
             LIMIT {self.pageSize}
             OFFSET {self.pageSize * (self.pageIndex - 1)};
         """
-        result_list = await self.mysql_client.select(sql)
-        title_list = [i[1] for i in result_list]
-        score_list = title_filter(title_list)
-        res = list(zip(score_list, title_list))
-        result_list_final = []
-        for index, item in enumerate(result_list):
-            if score_list[index] > 0.4:
-                result_list_final.append(item)
-        return self.response_obj(result_list_final)
+        next_page_sql = f"""
+            SELECT video_id, title, view_, return_, video_url, rov
+                FROM top_return_daily 
+                WHERE dt >= '{self.start_dt}' and dt < '{self.end_dt}' 
+                ORDER BY return_ DESC
+                LIMIT {self.pageSize}
+                OFFSET {self.pageSize * (self.pageIndex)};
+        """
+        response_01 = await self.mysql_client.select(this_pag_sql)
+        response_02 = await self.mysql_client.select(next_page_sql)
+        return self.response_obj(response_01, response_02)
 
     async def deal_view(self):
         """