| 
					
				 | 
			
			
				@@ -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]) 
			 |