| | |
|---|
| | | # 如果成交了需要刷新委托列表 |
|---|
| | | huaxin_trade_data_update.add_delegate_list("买成交") |
|---|
| | | need_cancel = TradeResultProcessor.process_buy_order(order) |
|---|
| | | if need_cancel: |
|---|
| | | # 需要撤买单 |
|---|
| | | threading.Thread(target=lambda: cancel_order(TRADE_DIRECTION_SELL, order.code, order.orderSysID), |
|---|
| | | daemon=True).start() |
|---|
| | | # if need_cancel: |
|---|
| | | # # 需要撤买单 |
|---|
| | | # threading.Thread(target=lambda: cancel_order(TRADE_DIRECTION_SELL, order.code, order.orderSysID), |
|---|
| | | # daemon=True).start() |
|---|
| | | need_watch_cancel = TradeResultProcessor.process_sell_order(order) |
|---|
| | | if need_watch_cancel: |
|---|
| | | # 需要撤卖单 |
|---|
| | | threading.Thread(target=lambda: __cancel_order(order.code, order.orderRef), daemon=True).start() |
|---|
| | | # if need_watch_cancel: |
|---|
| | | # # 需要撤卖单 |
|---|
| | | # threading.Thread(target=lambda: __cancel_order(order.code, order.orderRef), daemon=True).start() |
|---|
| | | finally: |
|---|
| | | try: |
|---|
| | | # 加入2次，增大加入成功率 |
|---|
