diff --git a/ad_interface_tornado.py b/ad_interface_tornado.py index 952ce88..21d48fa 100644 --- a/ad_interface_tornado.py +++ b/ad_interface_tornado.py @@ -61,14 +61,16 @@ def send_cache_data(): # log.info(f"get data was {all}!\n") for line in all: key = f"ad::{line.get('gameid', 0)}::{line.get('locationid', 0)}" + if int(line['ad_num']) > 0: num = my_redis.get(f"ad::{line['id']}::num") + print(f"1 ={line['ad_num']},2={num}") if not num: num = 0 if int(line['ad_num']) > int(num): my_redis.sadd(key, line['id']) my_redis.expire(key, 120) - n = int(line['ad_num'] - num) + n = int(line['ad_num']) - int(num) log.info(f"add {line['id']} to {key} ,num was {line['ad_num']},limit was {n}!") else: my_redis.srem(key, line['id'])