调整广告数据上报及统计均以adid_locationid为主键
This commit is contained in:
parent
c4ef0ea578
commit
f586440d77
@ -124,7 +124,7 @@ 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:
|
||||||
if line:
|
if line:
|
||||||
print(f"1={line}")
|
#print(f"1={line}")
|
||||||
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)
|
||||||
@ -137,8 +137,8 @@ def send_cache_data():
|
|||||||
if int(line['ad_num']) == 0:
|
if int(line['ad_num']) == 0:
|
||||||
sadd_adkey(key, line, item)
|
sadd_adkey(key, line, item)
|
||||||
elif int(line['ad_num']) > 0:
|
elif int(line['ad_num']) > 0:
|
||||||
num = my_redis.get(f"adnum::{line['id']}_{one}::num")
|
num = my_redis.get(f"adnum::{line['id']}_{item}::num")
|
||||||
print(f" get {line['id']} {one} num was {num}!")
|
print(f" get {line['id']} {item} num was {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):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user