otpimize code

flowpool_data_update_with_level_supply.py

@@ -102,50 +102,6 @@ def get_videos_remain_view_count(video_info_list):
                     redis_helper.remove_value_from_set(key_name=quick_flow_pool_key, values=(value, ))
                 bu_fen_fa_cnt = bu_fen_fa_cnt + 1
     log_.info(f"新增加不分发过滤前后整体数量: {len(video_info_list)}:{str(bu_fen_fa_cnt)}")
-def get_flow_pool_recommend_config(flow_pool_id):
-    """获取流量池推荐分发配置"""
-    result = request_post(request_url=config_.GET_FLOW_POOL_RECOMMEND_CONFIG_URL)
-    if result is None:
-        return None
-    if result['code'] != 0:
-        return None
-    flow_pool_distribute_config = result['data'].get('flowPoolDistributeConfig')
-    if flow_pool_distribute_config:
-        if int(eval(flow_pool_distribute_config).get('flowPoolId')) == flow_pool_id:
-            return eval(eval(flow_pool_distribute_config).get('distributeRate'))
-        else:
-            return None
-    else:
-        return None
-
-
-def online_flow_pool_data_to_redis(app_type, video_ids_set, video_info_data):
-    redis_helper = RedisHelper()
-    for tag, values in video_ids_set.items():
-        if tag == 'quick_flow_pool':
-            key_name_video_ids = \
-                f"{config_.QUICK_FLOWPOOL_VIDEO_ID_KEY_NAME_PREFIX}{app_type}:{config_.QUICK_FLOW_POOL_ID}"
-            key_prefix_video_info = \
-                f"{config_.QUICK_FLOWPOOL_VIDEO_INFO_KEY_NAME_PREFIX}{app_type}:{config_.QUICK_FLOW_POOL_ID}"
-        else:
-            key_name_video_ids = f"{config_.FLOWPOOL_VIDEO_ID_KEY_NAME_PREFIX}{app_type}"
-            key_prefix_video_info = f"{config_.FLOWPOOL_VIDEO_INFO_KEY_NAME_PREFIX}{app_type}"
-        # 如果key已存在，删除key
-        if redis_helper.key_exists(key_name=key_name_video_ids):
-            redis_helper.del_keys(key_name=key_name_video_ids)
-        # 写入redis
-        if len(values) > 0:
-            redis_helper.add_data_with_set(key_name=key_name_video_ids, values=values, expire_time=3600)
-            info_values = video_info_data[tag]
-            if len(info_values) > 0:
-                for video_id, info_value in info_values.items():
-                    key_name_video_info = f"{key_prefix_video_info}:{video_id}"
-                    # 如果key已存在，删除key
-                    if redis_helper.key_exists(key_name=key_name_video_info):
-                        redis_helper.del_keys(key_name=key_name_video_info)
-                    if len(info_value) > 0:
-                        redis_helper.add_data_with_set(key_name=key_name_video_info, values=info_value,
-                                                       expire_time=3600)
 
 
 def get_flow_pool_data(app_type, video_info_list, flow_pool_id_list):