a

.gitignore

@@ -13,3 +13,4 @@ Thumbs.db
 .pem
 test_*
 *.pid
+.vscode/settings.json

ad_interface_tornado.py

@@ -140,7 +140,7 @@ class DispatchHandler(tornado.web.RequestHandler):
             input = json.loads(self.get_query_argument('body'))
             gameid = input['gameid']
             channelid=input.get('channelid',None) or 6001
-            area=input.get('area',0)
+            area=input.get('area',None)
             locationid = input.get('locationid',0)
         except Exception as e:
             result = {'errcode': 2, "errmsg": f"get args failed,{str(e)}"}
@@ -190,7 +190,8 @@ class DispatchHandler(tornado.web.RequestHandler):
                     temp = my_redis.hgetall(f"adinfo::{id}::info")
                     if temp:
                         info.append(temp)
-                result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
+                info_new = sorted(info, key=lambda s: int(s.get('ad_sort', 9999)))
+                result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info_new), "result": info_new}}
             except Exception as e:
                 result = {'errcode': 1, "errmsg": e}
         return self.write(result)

ops/ad_produce.py

@@ -95,7 +95,7 @@ def produce_task():
                     for k, v in zip(field, line):
                         item[k] = v
 
-                    item['createtime'] = datetime.datetime.strftime(item['createtime'], "%Y-%m-%d %H:%M:%S")
+                    item['createtime'] = datetime.datetime.strftime(item['createtime'], "%Y-%m-%dT%H:%M:%S")
                     if item:
                         if item.get('jump_param', "") and (item['ad_property'].find("jump_param") == -1):
                             try:

server.py

@@ -30,4 +30,4 @@ api.add_resource(RelushADinfo, '/interface/reflush_adinfo')
 
 
 if __name__ == '__main__':
-	app.run(host='0.0.0.0', debug=True, port=priv_i_port)
+	app.run(host='0.0.0.0', debug=True, port=6015)