测试

Administrator

2024-03-14 3ddb32c12a37985f00c3cc372a82c0fdfeaf2034

测试

 huaxin_client/l2_data_manager.py

@@ -97,8 +97,9 @@
        #         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(), start_time))
                  data['MainSeq'], data['SubSeq'], data['OrderNO'], data['OrderStatus'], time.time(), tool.get_thread_id()))

    # 添加逐笔成交
    def add_transaction_detail(self, data):
@@ -113,9 +114,10 @@
        #                           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']))
                  data['SellNo'], data['ExecType'], tool.get_thread_id()))

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