fix
This commit is contained in:
parent
71f5cd2550
commit
6391c7d058
29
ad_tasks.py
29
ad_tasks.py
@ -125,22 +125,23 @@ def send_cache_data():
|
|||||||
locationid = json.loads(line.get('locationid'))
|
locationid = json.loads(line.get('locationid'))
|
||||||
for item in locationid:
|
for item in locationid:
|
||||||
area = get_area_by_locationid(item)
|
area = get_area_by_locationid(item)
|
||||||
for one in area:
|
for area_temp in area:
|
||||||
key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}"
|
for one in area_temp.split(","):
|
||||||
if int(line['ad_num']) == 0:
|
key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}"
|
||||||
sadd_adkey(key, line, item)
|
if int(line['ad_num']) == 0:
|
||||||
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)
|
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:
|
else:
|
||||||
if my_redis.sismember(key, line['id']):
|
log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}")
|
||||||
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.info("remove expire data from cache!")
|
log.info("remove expire data from cache!")
|
||||||
|
Loading…
x
Reference in New Issue
Block a user