| | |
|---|
| | | from trade.huaxin import huaxin_trade_data_update, huaxin_trade_record_manager |
|---|
| | | from trade.huaxin.huaxin_trade_record_manager import TradeOrderIdManager |
|---|
| | | from trade.huaxin.huaxin_trade_order_processor import CancelOrderManager, HuaxinOrderEntity, TradeResultProcessor |
|---|
| | | from trade.trade_manager import CodesContinueBuyMoneyManager |
|---|
| | | # from trade.trade_manager import CodesContinueBuyMoneyManager |
|---|
| | | from utils import socket_util, huaxin_util, tool |
|---|
| | | |
|---|
| | | __response_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=15) |
|---|
| | |
|---|
| | | # 如果成交了需要刷新委托列表 |
|---|
| | | huaxin_trade_data_update.add_delegate_list("买成交") |
|---|
| | | # 订单成交回调，移除续买金额+拉黑 |
|---|
| | | CodesContinueBuyMoneyManager().remove_continue_buy_money(order.code) |
|---|
| | | # TODO |
|---|
| | | # CodesContinueBuyMoneyManager().remove_continue_buy_money(order.code) |
|---|
| | | |
|---|
| | | need_cancel = TradeResultProcessor.process_buy_order(order) |
|---|
| | | # if need_cancel: |
|---|
