|
@@ -1,4 +1,5 @@
|
|
|
import time
|
|
|
+import traceback
|
|
|
|
|
|
from datetime import date, timedelta, datetime
|
|
|
from log import Log
|
|
@@ -199,12 +200,18 @@ class PoolRecall(object):
|
|
|
|
|
|
redis_helper = RedisHelper()
|
|
|
for item in view_count_result:
|
|
|
- if item[2] > 0:
|
|
|
+ try:
|
|
|
+ remain_count = int(item[2])
|
|
|
+ except Exception as e:
|
|
|
+ log_.error('remain_count type error...')
|
|
|
+ log_.error(traceback.format_exc())
|
|
|
+ continue
|
|
|
+ if remain_count > 0:
|
|
|
# viewCount > 0
|
|
|
check_result.append(item)
|
|
|
# 将分发数更新到本地记录
|
|
|
key_name = '{}{}.{}'.format(config_.LOCAL_DISTRIBUTE_COUNT_PREFIX, item[0], item[1])
|
|
|
- redis_helper.incr_key(key_name=key_name, amount=int(item[2]), expire_time=5 * 60)
|
|
|
+ redis_helper.incr_key(key_name=key_name, amount=remain_count, expire_time=5 * 60)
|
|
|
|
|
|
# # 判断本地分发数
|
|
|
# cur_count = get_videos_local_distribute_count(video_id=item[0], flow_pool=item[1])
|