diff --git a/ad_tasks.py b/ad_tasks.py index 115bb38..f2559c9 100644 --- a/ad_tasks.py +++ b/ad_tasks.py @@ -33,11 +33,11 @@ def get_area_by_locationid(ldid): def split_ad_info(localtionid, line): # 从locationid获取位置相关属性,与ad信息打包,产生提供给接口用的数据 new = copy.deepcopy(line) - location_sql = f"select area,x,y,x_offset,y_offset,type,mode,ld_property from location WHERE in_used=1 and id={localtionid}" + location_sql = f"select x,y,x_offset,y_offset,type,mode,ld_property from location WHERE in_used=1 and id={localtionid}" data = mydb.query(location_sql) try: - new['area'], new['x'], new['y'], new['x_offset'], new['y_offset'], new['type'], new['mode'], new[ - 'ld_property'] = data[0] + new['x'], new['y'], new['x_offset'], new['y_offset'], new['type'], new['mode'], new['ld_property'] = data[0] + new['area'] = f"{new['area']},{new['x']},{new['y']},{new['x_offset']},{new['y_offset']}" except Exception: log.error(f"get localtion info by sql={location_sql} error!", exc_info=True) return None @@ -129,6 +129,10 @@ def send_cache_data(): for item in locationid: area = get_area_by_locationid(item) for one in area.split(','): + + line['locationid'] = item + line['area'] = one + key = f"ad::{line.get('gameid', 0)}_{item}::{line.get('channelid', 0)}::{one}::{item}" if int(line['ad_num']) == 0: sadd_adkey(key, line, item)