| | |
| | | |
| | | from code_attribute.gpcode_manager import MustBuyCodesManager |
| | | from l2 import l2_data_manager |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer, SecondCancelBigNumComputer, \ |
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer, SCancelBigNumComputer, \ |
| | | LCancelBigNumComputer, DCancelBigNumComputer, GCancelBigNumComputer, FCancelBigNumComputer |
| | | from l2.l2_data_manager import OrderBeginPosInfo |
| | | from l2.l2_data_util import local_today_datas, local_today_num_operate_map, L2DataUtil |
| | |
| | | # 虚拟撤成功 |
| | | def virtual_cancel_success(code, buy_single_index, buy_exec_index, total_datas): |
| | | l2_data_manager.TradePointManager().delete_buy_point(code) |
| | | SecondCancelBigNumComputer().cancel_success(code) |
| | | SCancelBigNumComputer().cancel_success(code) |
| | | LCancelBigNumComputer().cancel_success(code) |
| | | GCancelBigNumComputer().cancel_success(code) |
| | | # dask.compute(f1, f2, f5, f6, f7, f8) |
| | |
| | | |
| | | def s_cancel(code): |
| | | try: |
| | | SecondCancelBigNumComputer().place_order_success(code) |
| | | SCancelBigNumComputer().place_order_success(code) |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | logger_l2_error.exception(e) |
| | |
| | | def real_cancel_success(code, buy_single_index, buy_exec_index, total_datas): |
| | | # 取消买入标识 |
| | | l2_data_manager.TradePointManager().delete_buy_point(code) |
| | | SecondCancelBigNumComputer().cancel_success(code) |
| | | SCancelBigNumComputer().cancel_success(code) |
| | | LCancelBigNumComputer().cancel_success(code) |
| | | FCancelBigNumComputer().cancel_success(code) |
| | | GCancelBigNumComputer().cancel_success(code) |