| | |
| | | from ths import client_manager |
| | | import constant |
| | | from code_attribute import gpcode_manager |
| | | from trade.huaxin import huaxin_trade_api |
| | | from utils import tool, import_util |
| | | from ths.l2_code_operate import L2CodeOperate |
| | | from trade import trade_manager, l2_trade_util |
| | |
| | | trade_gui = import_util.import_lib("trade.trade_gui") |
| | | |
| | | __actualPriceProcessor = CodeActualPriceProcessor() |
| | | |
| | | latest_add_codes = set() |
| | | |
| | | |
| | | def accept_prices(prices): |
| | |
| | | |
| | | if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_HUAXIN: |
| | | # 华鑫L2,获取加入代码的涨停价 |
| | | |
| | | # 是否和上次一样 |
| | | add_code_set = set(add_code_list) |
| | | global latest_add_codes |
| | | if tuple(latest_add_codes) != tuple(add_code_set): |
| | | latest_add_codes = add_code_set |
| | | add_datas = [] |
| | | for d in add_code_list: |
| | | limit_up_price = gpcode_manager.get_limit_up_price(d) |