| | |
|---|
| | | pass |
|---|
| | | return None, "" |
|---|
| | | |
|---|
| | | # B撤 |
|---|
| | | def b_cancel(_buy_single_index, _buy_exec_index): |
|---|
| | | try: |
|---|
| | | b_need_cancel, b_cancel_data, extra_msg = cls.__GCancelBigNumComputer.need_cancel_for_b(code, |
|---|
| | | start_index, |
|---|
| | | end_index) |
|---|
| | | if b_need_cancel and b_cancel_data: |
|---|
| | | return b_cancel_data, f"G撤({extra_msg})" |
|---|
| | | except Exception as e: |
|---|
| | | async_log_util.error(logger_l2_error, |
|---|
| | | f"B撤出错 参数：buy_single_index-{_buy_single_index} buy_exec_index-{_buy_exec_index} 错误原因：{str(e)}") |
|---|
| | | return None, "" |
|---|
| | | |
|---|
| | | if start_index < 0: |
|---|
| | | start_index = 0 |
|---|
| | | |
|---|
| | |
|---|
| | | cancel_data, cancel_msg = None, "" |
|---|
| | | if not cancel_data: |
|---|
| | | cancel_data, cancel_msg = g_cancel(order_begin_pos.buy_single_index, order_begin_pos.buy_exec_index) |
|---|
| | | |
|---|
| | | # 依次处理 |
|---|
| | | if not cancel_data: |
|---|
| | | cancel_data, cancel_msg = l_cancel(order_begin_pos.buy_single_index, order_begin_pos.buy_exec_index) |
|---|
| | | # 暂时取消S撤 |
|---|
| | | # if not cancel_data: |
|---|
| | | # cancel_data, cancel_msg = s_cancel(order_begin_pos.buy_single_index, order_begin_pos.buy_exec_index) |
|---|
| | | # B撤 |
|---|
| | | if not cancel_data: |
|---|
| | | cancel_data, cancel_msg = b_cancel(order_begin_pos.buy_single_index, order_begin_pos.buy_exec_index) |
|---|
| | | if not cancel_data: |
|---|
| | | cancel_data, cancel_msg = h_cancel(order_begin_pos.buy_single_index, order_begin_pos.buy_exec_index) |
|---|
| | | if cancel_data and not DCancelBigNumComputer().has_auto_cancel_rules(code): |
|---|
| | | l2_log.debug(code, "触发撤单，撤单位置：{} ，撤单原因：{}", cancel_data["index"], cancel_msg) |
|---|
| | | |
|---|
| | | # 撤单 |
|---|
| | | cls.cancel_buy(code, cancel_msg, cancel_index=cancel_data["index"]) |
|---|
| | | # 撤单成功，继续计算下单 |
|---|
