| | |
| | | self.__latest_buy_order[3] = order_time |
| | | self.__latest_buy_order[4] = price |
| | | else: |
| | | if self.__latest_buy_order[2] > 1e6: |
| | | if self.__latest_buy_order[2] >= big_order_money_threshold: |
| | | d = (self.__latest_buy_order[0], self.__latest_buy_order[1], self.__latest_buy_order[2], |
| | | self.__latest_buy_order[3], self.__latest_buy_order[4]) |
| | | self.__big_buy_orders.append(d) |
| | |
| | | self.__latest_sell_order[3] = order_time |
| | | self.__latest_sell_order[4] = price |
| | | else: |
| | | if self.__latest_sell_order[2] > 1e6: |
| | | if self.__latest_sell_order[2] > big_order_money_threshold: |
| | | d = (self.__latest_sell_order[0], self.__latest_sell_order[1], self.__latest_sell_order[2], |
| | | self.__latest_sell_order[3], self.__latest_sell_order[4]) |
| | | self.__big_sell_orders.append(d) |
| | |
| | | if item["SecurityID"] not in l2_transaction_data_dict: |
| | | l2_transaction_data_dict[item["SecurityID"]] = L2TransactionDataManager(item["SecurityID"], item[ |
| | | "SecurityID"] in self.special_codes) |
| | | l2_transaction_data_dict[item["SecurityID"]].add_transaction_data(item) |
| | | l2_transaction_data_dict[item["SecurityID"]].add_transaction_data(item, big_order_money_threshold=60e4) |
| | | |
| | | def OnRtnNGTSTick(self, pTick): |
| | | """ |
| | |
| | | if item["SecurityID"] not in l2_transaction_data_dict: |
| | | l2_transaction_data_dict[item["SecurityID"]] = L2TransactionDataManager(item["SecurityID"], item[ |
| | | "SecurityID"] in self.special_codes) |
| | | l2_transaction_data_dict[item["SecurityID"]].add_transaction_data(item) |
| | | l2_transaction_data_dict[item["SecurityID"]].add_transaction_data(item, big_order_money_threshold=60e4) |
| | | except Exception as e: |
| | | logger_local_huaxin_l2_subscript.exception(e) |
| | | |