| | |
| | | # 代码的上次成交的订单唯一索引 |
| | | __last_transaction_keys_dict = {} |
| | | |
| | | # 买入的大单订单号 |
| | | |
| | | def __init__(self, api): |
| | | lev2mdapi.CTORATstpLev2MdSpi.__init__(self) |
| | | self.__api = api |
| | |
| | | min_volume, limit_up_price = self.codes_volume_and_price_dict.get(code) |
| | | # 输出逐笔成交数据 |
| | | if pTransaction['ExecType'] == b"2": |
| | | transaction_big_order_no = l2_data_manager.get_latest_transaction_order_no(code) |
| | | if transaction_big_order_no == pTransaction['BuyNo']: |
| | | # 正在成交的订单撤单了 |
| | | l2_data_manager.trading_order_canceled(code, pTransaction['BuyNo']) |
| | | if min_volume is None: |
| | | # 默认筛选50w |
| | | if pTransaction['TradePrice'] * pTransaction['Volume'] < 500000: |
| | |
| | | item["Side"] = "2" |
| | | # 深证撤单 |
| | | print("逐笔委托", item) |
| | | |
| | | l2_data_manager.add_l2_order_detail(item, True) |
| | | else: |
| | | if abs(pTransaction['TradePrice'] - limit_up_price) < 0.201: |
| | |
| | | else: |
| | | self.special_code_volume_for_order_dict.pop(code) |
| | | if not can_listen: |
| | | |
| | | transaction_big_order_no = l2_data_manager.get_latest_transaction_order_no(code) |
| | | if transaction_big_order_no == pOrderDetail['OrderNO'] and pOrderDetail['OrderStatus'] == b'D': |
| | | # 正在成交的订单撤单了 |
| | | l2_data_manager.trading_order_canceled(code,pOrderDetail['OrderNO']) |
| | | |
| | | min_volume, limit_up_price = self.codes_volume_and_price_dict.get(code) |
| | | if min_volume is None: |
| | | # 默认筛选50w |
| | |
| | | t1.start() |
| | | __init_l2() |
| | | l2_data_manager.run_upload_common() |
| | | l2_data_manager.run_upload_trading_canceled() |
| | | global l2CommandManager |
| | | l2CommandManager = command_manager.L2CommandManager() |
| | | l2CommandManager.init(MyL2ActionCallback()) |