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-07-25 16:50:10 +08:00
parent 804f2813ac
commit c86de9c326
1 changed files with 28 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
ad_interface_tornado.py
View File

@ -149,7 +149,6 @@ class DispatchHandler(tornado.web.RequestHandler):
def _selfGetAdList(self): def _selfGetAdList(self):
try: try:
pdb.set_trace()
input = json.loads(self.get_query_argument('body')) input = json.loads(self.get_query_argument('body'))
gameid = input['gameid'] gameid = input['gameid']
channelid=input.get('channelid',None) or 6001 channelid=input.get('channelid',None) or 6001
@ -175,37 +174,35 @@ class DispatchHandler(tornado.web.RequestHandler):
except Exception: except Exception:
log.error(f"get redis data failed!", exc_info=True) log.error(f"get redis data failed!", exc_info=True)
return self.write({'errcode': 2, "errmsg": f"get redis data failed!"}) return self.write({'errcode': 2, "errmsg": f"get redis data failed!"})
dist_ids = list(set(ids)) dist_ids = list(set(ids))
info = [] info = []
if not dist_ids: if not dist_ids:
result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}} result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
else:
try:
# 如果取得的记录条数大于预设，扔掉多余的记录,当前采用的是随机选择，以后可能需要添加加权选择
id_list = []
if limit < len(dist_ids):
nums = limit
else:
nums = len(dist_ids)
for i in range(nums):
while 1:
# new = my_redis.srandmember(key)
import random
new = random.choice(dist_ids)
if new not in id_list:
id_list.append(new)
break
for id in id_list:
temp = my_redis.hgetall(f"ad::{id}::info")
info.append(temp)
result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
except Exception as e:
result = {'errcode': 1, "errmsg": e}
return self.write(result)
else: else:
result = {'errcode': 2, "errmsg": f"get args failed!"} try:
return self.write(result) # 如果取得的记录条数大于预设，扔掉多余的记录,当前采用的是随机选择，以后可能需要添加加权选择
id_list = []
if limit < len(dist_ids):
nums = limit
else:
nums = len(dist_ids)
for i in range(nums):
while 1:
# new = my_redis.srandmember(key)
import random
new = random.choice(dist_ids)
if new not in id_list:
id_list.append(new)
break
for id in id_list:
temp = my_redis.hgetall(f"ad::{id}::info")
info.append(temp)
result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
except Exception as e:
result = {'errcode': 1, "errmsg": e}
return self.write(result)
def make_app(): def make_app():