diff --git a/ad_tasks.py b/ad_tasks.py index bd2eae5..80efd7f 100644 --- a/ad_tasks.py +++ b/ad_tasks.py @@ -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: