bug修复

Administrator

2024-06-17 51214f359c531eb772f5d782cf1837293f1b7388

bug修复

 third_data/data_server.py

@@ -280,6 +280,7 @@
    def do_GET(self):
        path = self.path
        url = urlparse.urlparse(path)
        async_log_util.info(logger_request_api, f"开始请求{tool.get_thread_id()}-{url}")
        response_data = ""
        if url.path == "/get_kpl_data":
            best_feng_kou = self.__kplDataManager.get_data(kpl_util.KPLDataType.BEST_FENG_KOU)
@@ -351,7 +352,6 @@
                logging.exception(e)

        elif url.path == "/get_l2_datas":
            async_log_util.info(logger_request_api, f"开始请求{tool.get_thread_id()}-{url}")
            try:
                # 获取L2的数据
                ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
@@ -371,8 +371,6 @@
                                                                         "transactions": transaction_datas}}})
            except Exception as e:
                logger_debug.exception(e)
            finally:
                async_log_util.info(logger_request_api, f"结束请求{tool.get_thread_id()}-{url}")
        elif url.path == "/get_trade_progress":
            # 获取交易进度
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
@@ -694,6 +692,7 @@
            msg_list = [f"{msg.split('|')[0]}{msg.split('|')[-1].split('-')[1].strip()}" for msg in msg_list]
            response_data = json.dumps({"code": 0, "data": msg_list})

        async_log_util.info(logger_request_api, f"结束请求{tool.get_thread_id()}-{url}")
        self.send_response(200)
        # 发给请求客户端的响应数据
        self.send_header('Content-type', 'application/json')

 third_data/kpl_data_manager.py

@@ -455,7 +455,7 @@
        log.close_print()
        while True:
            try:
                if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")) or True:
                if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")):
                    results = kpl_api.getLimitUpInfoNew()
                    result = json.loads(results)
                    start_time = time.time()