| | |
|---|
| | | from log_module.async_log_util import huaxin_l2_log |
|---|
| | | from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_l2_codes_subscript, \ |
|---|
| | | logger_local_huaxin_l2_transaction, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_error, printlog, \ |
|---|
| | | logger_trade, logger_debug |
|---|
| | | logger_trade, logger_debug, logger_local_huaxin_trade_debug |
|---|
| | | from trade.buy_strategy import BuyStrategyDataManager |
|---|
| | | from utils import tool, l2_huaxin_util |
|---|
| | | |
|---|
| | |
|---|
| | | results = self.buyStrategyDataManager.add_transaction_info(item) |
|---|
| | | for result in results: |
|---|
| | | if result[0]: |
|---|
| | | huaxin_l2_log.info(logger_local_huaxin_trade_debug, f"达到买入条件：{pTick['SecurityID']} - {results} - {item}") |
|---|
| | | l2_transaction_price_queue.put_nowait( |
|---|
| | | (pTick['SecurityID'], pTick['Price'], pTick['TickTime'], results)) |
|---|
| | | break |
|---|
