From cf19e485eab8efea5625b0fbaa1b21caed0c2254 Mon Sep 17 00:00:00 2001 From: pengtao Date: Mon, 15 Jul 2019 19:20:32 +0800 Subject: [PATCH] fix some error --- ad_interface_tornado.py | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/ad_interface_tornado.py b/ad_interface_tornado.py index d73ee87..1789e8a 100644 --- a/ad_interface_tornado.py +++ b/ad_interface_tornado.py @@ -60,7 +60,7 @@ def send_cache_data(): for line in all: key = f"{line.get('gameid', 0)}::{line.get('locationid', 0)}" if my_redis.exists(key): - my_redis.sadd(key,line['id']) + my_redis.sadd(key, line['id']) # 检查num是否已达到设定数值 num = my_redis.get(f"{line['id']::num") if not num: @@ -70,13 +70,15 @@ def send_cache_data(): my_redis.srem(key, line['id']) # 清理广告详细记录 my_redis.expire(f"{line['id']}::info", 0) - else: - my_redis.sadd(key, line['id']) - log.info(f"check {line['id']}::info") + else: + my_redis.sadd(key, line['id']) + log.info(f"check {line['id']}::info") if not my_redis.exists(f"{line['id']}::info"): - my_redis.hmset(f"{line['id']}::info", line) - len_all = len(all) - log.info(f"write {len_all} to cache!") + my_redis.hmset(f"{line['id']}::info", line) + + +len_all = len(all) +log.info(f"write {len_all} to cache!") class DispatchHandler(tornado.web.RequestHandler):