| | |
|---|
| | | logger_trade_position_api_request, logger_l2_error, hx_logger_l2_transaction, printlog |
|---|
| | | from trade import huaxin_trade_data_update, huaxin_sell_util, huaxin_trade_api |
|---|
| | | from trade.huaxin_trade_record_manager import PositionManager, DelegateSellOrderManager |
|---|
| | | from trade.l2_data_manager import L2TransactionDataManager |
|---|
| | | from trade.sell_rule_manager import TradeRuleManager, SellRule |
|---|
| | | from utils import outside_api_command_manager, middle_api_protocol, tool, huaxin_util, socket_util, cb_data_util |
|---|
| | | from utils.outside_api_command_manager import ActionCallback |
|---|
| | |
|---|
| | | L2DataProcessor.set_deal_price(code, price, time_str) |
|---|
| | | # 获取当前票是否有09:30之前的委托卖 |
|---|
| | | try: |
|---|
| | | for data in datas: |
|---|
| | | L2TransactionDataManager().add_transaction_data(code, data) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | try: |
|---|
| | | delegate_sell_orders = DelegateSellOrderManager.get_delegate_sell_orders(code) |
|---|
| | | if delegate_sell_orders: |
|---|
| | | for d in delegate_sell_orders: |
|---|
| | |
|---|
| | | if code in codes: |
|---|
| | | async_log_util.info(logger_debug, f"OnRealTimeBuy1Info：{code}-{buy1_info}") |
|---|
| | | # L1DataProcessor.excute_sell_rule(code, buy1_info[3], buy1_info[1], "l2-real") |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 做一些初始化的操作 |
|---|
