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

修复 jump_param 参数处理

Browse Source
This commit is contained in:
pengtao 2019-09-05 17:25:07 +08:00
parent e0fc80df03
commit 0613c4cf06
1 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
ad_tasks.py
View File

@ -95,20 +95,23 @@ def send_cache_data():
item['y_offset'] = item['area'].split(',')[-1].strip().strip(')')
except:
item['y_offset'] = 0
try:
temp = {}
temp['jump_param'] = item.get('jump_param', "")
if not item['ad_property']:
item['ad_property']={}
if not isinstance(item.get('ad_property', {}), dict):
if not item.get('ad_property', {}) :
item['ad_property'] = {}.update(temp)
else:
item['ad_property'] = json.loads(item.get('ad_property', {}).replace("‘", '"').replace("’", '"'))
item['ad_property'].update(temp)
item['ad_property']=json.dumps(item['ad_property'])
except Exception:
log.error(f"write {item}", exc_info=True)
if item.get('jump_param', "") and (item['ad_property'].find("jump_param") == -1):
try:
temp = {}
temp['jump_param'] = item.get('jump_param', "")
if not item['ad_property']:
item['ad_property'] = {}
if not isinstance(item.get('ad_property', {}), dict):
if not item.get('ad_property', {}):
item['ad_property'] = {}.update(temp)
else:
item['ad_property'] = json.loads(
item.get('ad_property', {}).replace("‘", '"').replace("’", '"'))
item['ad_property'].update(temp)
item['ad_property'] = json.dumps(item['ad_property'])
except Exception:
log.error(f"write {item}", exc_info=True)
all.append(item)
except Exception: