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-09-29 12:16:46 +08:00
parent c6cdd1f6e7
commit 4a62f9a8f0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ops/ad_produce.py
View File

@ -124,7 +124,7 @@ def produce_task():
if all: if all:
for line in all: for line in all:
if line: if line:
print(f"line={line}") # print(f"line={line}")
try: try:
locationids = json.loads(line.get('locationid')) locationids = json.loads(line.get('locationid'))
for locationid in str(locationids).strip('[]').split(','): for locationid in str(locationids).strip('[]').split(','):
@ -138,11 +138,13 @@ def produce_task():
key = "ad::{0}::{1}::{2}".format(str01, area, locationid) key = "ad::{0}::{1}::{2}".format(str01, area, locationid)
if int(line['ad_num']) == 0: if int(line['ad_num']) == 0:
sadd_adkey(key, line) sadd_adkey(key, line)
print(f"add {line} 2 {key}!")
elif int(line['ad_num']) > 0: elif int(line['ad_num']) > 0:
num = my_redis.get(f"adnum::{line['id']}_{locationid}::num") or 0 num = my_redis.get(f"adnum::{line['id']}_{locationid}::num") or 0
print(f" get {line['id']} {locationid} num was {num}!") print(f" get {line['id']} {locationid} num was {num}!")
if int(line['ad_num']) > int(num): if int(line['ad_num']) > int(num):
sadd_adkey(key, line) sadd_adkey(key, line)
print(f"add {line} 2 {key}!")
else: else:
redis_key = f"{line['id']}_{locationid}" redis_key = f"{line['id']}_{locationid}"
if my_redis.sismember(key, redis_key): if my_redis.sismember(key, redis_key):