v0.1

deal/db_deal.py

@@ -31,6 +31,6 @@ async def get_text_by_id(mysql_client, video_id):
     select_sql = f"""select video_text from video_text where video_id = {video_id}"""
     result = await mysql_client.select(select_sql)
     if result:
-        return result[0]
+        return result[0][0]
     else:
         return None

deal/request_deal.py

@@ -20,13 +20,16 @@ class RequestDeal(object):
         """
         处理 return 信息
         :param data_list:
-        :return:
+        :return:video_id, title, view_, return_, video_url, rov
         """
         result_list = [
             {
                 "video_id": obj[0],
                 "title": obj[1],
-                "video_url": obj[2],
+                "view": obj[2],
+                "return": obj[3],
+                "video_url": obj[4],
+                "rov": obj[5],
                 "video_text": get_text(video_id=obj[0])['text']
             } for obj in data_list
         ]
@@ -60,7 +63,7 @@ class RequestDeal(object):
         :return:
         """
         sql = f"""
-        select video_id, title, video_url 
+        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
@@ -75,7 +78,7 @@ class RequestDeal(object):
         :return:
         """
         sql = f"""
-        select video_id, title, video_url 
+        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 view_  DESC
@@ -90,7 +93,7 @@ class RequestDeal(object):
         :return:
         """
         sql = f"""
-        select video_id, title, video_url 
+        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 rov DESC

test_req.py

@@ -9,7 +9,7 @@ import requests
 cate: video_return, video_view, video_rov
 """
 
-url = "http://47.99.132.47:8888/videos"
+url = "http://localhost:8888/videos"
 
 body = {
     "cate": "video_rov",