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

添加返回条数控制

Browse Source
This commit is contained in:
pengtao 2019-07-17 17:53:03 +08:00
parent fb0ef6cf7b
commit 7a05e45ab2
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ad_interface_tornado.py
View File

@ -61,14 +61,16 @@ def send_cache_data():
# log.info(f"get data was {all}!\n") # log.info(f"get data was {all}!\n")
for line in all: for line in all:
key = f"ad::{line.get('gameid', 0)}::{line.get('locationid', 0)}" key = f"ad::{line.get('gameid', 0)}::{line.get('locationid', 0)}"
if int(line['ad_num']) > 0: if int(line['ad_num']) > 0:
num = my_redis.get(f"ad::{line['id']}::num") num = my_redis.get(f"ad::{line['id']}::num")
print(f"1 ={line['ad_num']},2={num}")
if not num: if not num:
num = 0 num = 0
if int(line['ad_num']) > int(num): if int(line['ad_num']) > int(num):
my_redis.sadd(key, line['id']) my_redis.sadd(key, line['id'])
my_redis.expire(key, 120) 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}!") log.info(f"add {line['id']} to {key} ,num was {line['ad_num']},limit was {n}!")
else: else:
my_redis.srem(key, line['id']) my_redis.srem(key, line['id'])