默认交易模式变更/真实下单位置计算位置修改

Administrator

30 分钟以前 2f2516749615da866e96d8d24e499b7ecbb63a3e

 msg/push_msg_manager.py

@@ -9,12 +9,37 @@

TYPE_DELEGATE_QUEUE_CHANGE = "delegate_queue_change"  # 委托队列变化

TYPE_DELEGATE_ORDER_DANGER = "delegate_order_danger"  # 委托的订单危险

thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=5)

__order_almost_deal_filter_dict = {}

__delegate_order_danger_filter_dict = {}


# 推送订单快成交信息
def push_order_almost_deal(code, code_name):
    __push_msg(TYPE_ORDER_ALMOST_DEAL, data={"code": code, "code_name": code_name})
def push_order_almost_deal(code, code_name, buy_single_index, msg, ctype='', force=False):
    if code not in __order_almost_deal_filter_dict:
        __order_almost_deal_filter_dict[code] = set()
    notify_key = f"{buy_single_index}_{ctype}"
    if force or notify_key not in __order_almost_deal_filter_dict[code]:
        __order_almost_deal_filter_dict[code].add(notify_key)
        # 强制推送或这次下单之前未推送
        __push_msg(TYPE_ORDER_ALMOST_DEAL,
                   data={"code": code, "code_name": code_name, "msg": msg})


# 推送委托的订单危险信息
def push_delegate_order_danger(code, code_name, buy_single_index, msg, ctype='', force=False):
    if code not in __delegate_order_danger_filter_dict:
        __delegate_order_danger_filter_dict[code] = set()
    notify_key = f"{buy_single_index}_{ctype}"
    if force or notify_key not in __delegate_order_danger_filter_dict[code]:
        __delegate_order_danger_filter_dict[code].add(notify_key)
        # 强制推送或这次下单之前未推送
        __push_msg(TYPE_DELEGATE_ORDER_DANGER,
                   data={"code": code, "code_name": code_name, "msg": msg})


# 推送委托队列变化消息
@@ -29,4 +54,5 @@
        if data:
            fdata["data"] = data
        middle_api_protocol.request(middle_api_protocol.load_push_msg(fdata))
    thread_pool.submit(push)

    thread_pool.submit(push)