add route /applet/video/update/rov

app.py

@@ -4,6 +4,8 @@ from log import Log
 from config import set_config
 from recommend import video_recommend
 from category import get_category_videos
+from video_recall import PoolRecall
+from db_helper import RedisHelper
 
 
 app = Flask(__name__)
@@ -57,7 +59,22 @@ def homepage_recommend():
 # 管理后台实时修改rov
 @app.route('/applet/video/update/rov', methods=['GET', 'POST'])
 def update_rov():
-    pass
+    try:
+        request_data = json.loads(request.get_data())
+        app_type = request_data.get('appType')
+        video_id = request_data.get('videoId')
+        rov_score = request_data.get('rovScore')
+        pool_recall = PoolRecall(app_type=app_type)
+        rov_pool_key, _ = pool_recall.get_pool_redis_key('rov')
+        redis_helper = RedisHelper()
+        redis_helper.update_score_with_value(key_name=rov_pool_key, value=video_id, score=rov_score)
+        result = {'code': 200, 'message': 'success'}
+        log_.info('result: {}'.format(result))
+        return json.dumps(result)
+    except Exception as e:
+        log_.error(e)
+        result = {'code': -1, 'message': 'fail'}
+        return json.dumps(result)
 
 
 if __name__ == '__main__':