| | |
| | | import threading |
| | | import time |
| | | |
| | | from code_attribute import target_codes_manager, gpcode_manager, code_market_manager |
| | | from code_attribute import target_codes_manager, gpcode_manager, code_market_manager, history_k_data_util |
| | | from huaxin_client import l2_client_for_cb, trade_client_for_cb |
| | | from huaxin_client.client_network import SendResponseSkManager |
| | | from log_module import async_log_util |
| | |
| | | market_info = code_market_manager.get_market_info(code) |
| | | if market_info: |
| | | current_price = market_info.price |
| | | else: |
| | | price_results = history_k_data_util.HistoryKDatasUtils.get_gp_current_info([code]) |
| | | current_price = price_results[0]["price"] |
| | | limit_down_price = target_codes_manager.get_limit_down_price(code) |
| | | limit_up_price = target_codes_manager.get_limit_up_price(code) |
| | | order_ref = huaxin_util.create_order_ref() |