update

check_video_limit_distribute.py

@@ -216,7 +216,8 @@ def check_region_videos(rule_params):
         return
 
     # 对已超分发的视频进行移除
-    region_code_list = [code for region, code in config_.REGION_CODE.items()]
+    region_code_list = [code for region, code in config_.REGION_CODE.items()] + \
+                       [code for city, code in config_.CITY_CODE.items()]
 
     for param in rule_params.get('params_list'):
         data_key = param.get('data')

videos_filter.py

@@ -639,7 +639,8 @@ def filter_process_with_param(param, region_code_list, now_date, now_h):
 
 def filter_region_videos(rule_params):
     """过滤地域分组规则视频"""
-    region_code_list = [code for region, code in region_code.items()]
+    region_code_list = [code for region, code in region_code.items()] + \
+                       [code for city, code in config_.CITY_CODE.items()]
     log_.info("region_h videos filter start ...")
     # 获取当前日期
     now_date = date.today().strftime('%Y%m%d')