取消测试

Administrator

2024-03-14 b760cd36ceda59103e6d8b6524b393bc0073b156

取消测试

 huaxin_client/l2_data_manager.py

@@ -97,9 +97,8 @@
        #         log_queue.put_nowait(data)

        q: collections.deque = self.temp_order_queue_dict.get(code)
        # TODO 测试线程
        q.append((data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], data['OrderTime'],
                  data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), tool.get_thread_id()))
                  data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), start_time))

    # 添加逐笔成交
    def add_transaction_detail(self, data):
@@ -114,10 +113,9 @@
        #                           data['SellNo'], data['ExecType']))

        q: collections.deque = self.temp_transaction_queue_dict.get(code)
        # TODO 测试线程
        q.append((data['SecurityID'], data['TradePrice'], data['TradeVolume'],
                  data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'],
                  data['SellNo'], data['ExecType'], tool.get_thread_id()))
                  data['SellNo'], data['ExecType']))

    def add_market_data(self, data):
        # 加入上传队列

 trade/huaxin/huaxin_trade_api.py

@@ -433,6 +433,10 @@

def cancel_order(direction, code, orderSysID, orderRef=None, blocking=False, sinfo=None, request_id=None,
                 recancel=False):
    if tool.trade_time_sub(tool.get_now_time_str(), "14:57:00") >= 0:
        # 集合竞价不撤单
        return

    if not recancel:
        CancelOrderManager().start_cancel(code, orderRef, orderSysID)
    if not sinfo: