diff --git a/data_collect_interface.py b/data_collect_interface.py index d710a3c..07b9d53 100644 --- a/data_collect_interface.py +++ b/data_collect_interface.py @@ -21,7 +21,7 @@ from urllib.parse import unquote from config import * #sched = TornadoScheduler() -define_logger("/data/logs/report_interface.log") +define_logger("/data/logs/data_collect_interface.log") log = logging.getLogger(__name__) tornado.options.define("port", default=5022, type=int, help="run server on the given port.") @@ -109,7 +109,7 @@ class DispatchHandler(tornado.web.RequestHandler): try: all = self._get_dailyreport_data(gameid, times, channel, methods) - return self.write({'errcode': 0, "errmsg": "", "result": json.dumps(all, ensure_ascii=False)}) + return self.write({'errcode': 0, "errmsg": "", "result": all}) except Exception: log.error(f"run self._get_tap_data(**kwargs) failed", exc_info=True) return self.write({'errcode': 2, "errmsg": "get data failed`"}) @@ -117,7 +117,7 @@ class DispatchHandler(tornado.web.RequestHandler): def _get_dailyreport_data(self, gameid, times, channel, methods): sql = f"""SELECT result FROM v_event_{self.suffix} where "$part_event"='rep_{methods}'and date='{times}' - and "gameid"={gameid} and channelid={channel} """ + and "gameid"='{gameid}' and channelid={channel} """ data = self.tga.get_data(sql) print(f"sql={sql}") all = []