| | |
| | | "ExecType": pTransaction['ExecType'].decode()} |
| | | huaxin_l2_log.info(logger_local_huaxin_l2_transaction, f"{item}") |
| | | |
| | | result = self.buyStrategyDataManager.add_transaction_info(item) |
| | | results = self.buyStrategyDataManager.add_transaction_info(item) |
| | | for result in results: |
| | | if result[0]: |
| | | l2_transaction_price_queue.put_nowait( |
| | | (pTransaction['SecurityID'], pTransaction['TradePrice'], pTransaction['TradeTime'], result)) |
| | | (pTransaction['SecurityID'], pTransaction['TradePrice'], pTransaction['TradeTime'], results)) |
| | | break |
| | | except Exception as e: |
| | | logger_local_huaxin_l2_error.exception(e) |
| | | |
| | |
| | | "SellNo": pTick['SellNo'], |
| | | "ExecType": '1'} |
| | | huaxin_l2_log.info(logger_local_huaxin_l2_transaction, f"{item}") |
| | | result = self.buyStrategyDataManager.add_transaction_info(item) |
| | | results = self.buyStrategyDataManager.add_transaction_info(item) |
| | | for result in results: |
| | | if result[0]: |
| | | l2_transaction_price_queue.put_nowait( |
| | | (pTick['SecurityID'], pTick['Price'], pTick['TickTime'], result)) |
| | | (pTick['SecurityID'], pTick['Price'], pTick['TickTime'], results)) |
| | | break |
| | | except Exception as e: |
| | | logger_local_huaxin_l2_error.exception(e) |
| | | |