ops/promotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
pengtao 2019-09-16 16:56:42 +08:00
parent bd9dcfbddc
commit 2b4627a062
1 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
ad_tasks.py
View File

@ -24,8 +24,7 @@ def get_area_by_locationid(ldid):
sql = f"select area from location where id={ldid}" sql = f"select area from location where id={ldid}"
data = mydb.query(sql) data = mydb.query(sql)
if data: if data:
for line in data: return data[0][0]
area.append(line[0])
else: else:
log.error(f"get area from location failed!,sql={sql}") log.error(f"get area from location failed!,sql={sql}")
return area return area
@ -128,23 +127,22 @@ 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 area_temp in area: for one in area.split(','):
for one in area_temp.split(","): key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}"
key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}" if int(line['ad_num']) == 0:
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) 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:
log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}") 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.info("remove expire data from cache!") log.info("remove expire data from cache!")
@ -162,7 +160,7 @@ def send_cache_data():
id, gameid, channelid, locationid = line id, gameid, channelid, locationid = line
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 one in area.split(','):
key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}" key = f"ad::{line.get('gameid', 0)}::{line.get('channelid', 0)}::{one}::{item}"
if my_redis.sismember(key, id): if my_redis.sismember(key, id):
my_redis.srem(key, id) my_redis.srem(key, id)