增加获取交易进度接口

Administrator

2023-10-30 e924cbefe89aca8927b94b4ba74806efe4704253

增加获取交易进度接口

 third_data/data_server.py

@@ -11,7 +11,7 @@
from utils import global_util, tool, data_export_util
from code_attribute import gpcode_manager
from log_module import log, log_analyse, log_export
from l2 import code_price_manager, l2_data_util, l2_data_manager_new, cancel_buy_strategy
from l2 import code_price_manager, l2_data_util, l2_data_manager_new, cancel_buy_strategy, transaction_progress
from l2.cancel_buy_strategy import HourCancelBigNumComputer
from output.limit_up_data_filter import IgnoreCodeManager
from third_data import kpl_util, kpl_data_manager, kpl_api, block_info
@@ -28,10 +28,10 @@
from trade.l2_trade_util import BlackListCodeManager
import concurrent.futures


# 禁用http.server的日志输出
logger = logging.getLogger("http.server")
logger.setLevel(logging.CRITICAL)


class DataServer(BaseHTTPRequestHandler):
    ocr_temp_data = {}
@@ -321,6 +321,14 @@
            code = ps_dict['code']
            datas = data_export_util.get_l2_datas(code)
            response_data = json.dumps({"code": 0, "data": datas})
        elif url.path == "/get_trade_progress":
            # 获取交易进度
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
            code = ps_dict['code']
            trade_progress, is_default = transaction_progress.TradeBuyQueue().get_traded_index(code)
            datas = data_export_util.get_l2_datas(code)
            response_data = json.dumps(
                {"code": 0, "data": {"trade_progress": trade_progress, "is_default": is_default}})
        elif url.path == "/kpl/get_limit_up_list":
            response_data = self.__get_limit_up_list()

@@ -522,7 +530,6 @@
                            limit_up_reason_code_dict[b] = set()
                        limit_up_reason_code_dict[b].add(code)
                    cancel_buy_strategy.LCancelRateManager.set_block_limit_up_count(limit_up_reason_code_dict)


                if add_codes:
                    for code in add_codes: