From 6391c7d058675e1c32e7d207d24c30e98c4aab50 Mon Sep 17 00:00:00 2001 From: pengtao Date: Mon, 16 Sep 2019 15:33:13 +0800 Subject: [PATCH] fix --- ad_tasks.py | 29 +++++++++++++++-------------- 1 file changed, 15 insertions(+), 14 deletions(-) diff --git a/ad_tasks.py b/ad_tasks.py index 4416fbf..38c9c99 100644 --- a/ad_tasks.py +++ b/ad_tasks.py @@ -125,22 +125,23 @@ def send_cache_data(): locationid = json.loads(line.get('locationid')) for item in locationid: area = get_area_by_locationid(item) - for one in area: - key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}" - if int(line['ad_num']) == 0: - sadd_adkey(key, line, item) - elif int(line['ad_num']) > 0: - num = my_redis.get(f"adnum::{line['id']}::num") - if not num: - num = 0 - if int(line['ad_num']) > int(num): + for area_temp in area: + for one in area_temp.split(","): + key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}" + if int(line['ad_num']) == 0: sadd_adkey(key, line, item) + elif int(line['ad_num']) > 0: + num = my_redis.get(f"adnum::{line['id']}::num") + if not num: + num = 0 + if int(line['ad_num']) > int(num): + sadd_adkey(key, line, item) + else: + if my_redis.sismember(key, line['id']): + my_redis.srem(key, line['id']) + log.info(f"remove {line['id']} from {key}!") else: - if my_redis.sismember(key, line['id']): - my_redis.srem(key, line['id']) - log.info(f"remove {line['id']} from {key}!") - else: - log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}") + log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}") # 删除过期的数据 log.info("remove expire data from cache!")