| | |
|---|
| | | # 真实撤成功 |
|---|
| | | def real_cancel_success(code, buy_single_index, buy_exec_index, total_datas): |
|---|
| | | # 安全笔数计算 |
|---|
| | | f1 = dask.delayed(__buyL2SafeCountManager.save_place_order_info)(code, buy_single_index, buy_exec_index, |
|---|
| | | total_datas[-1]["index"]) |
|---|
| | | __buyL2SafeCountManager.save_place_order_info(code, buy_single_index, buy_exec_index, |
|---|
| | | total_datas[-1]["index"]) |
|---|
| | | # 取消买入标识 |
|---|
| | | f2 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_point)(code) |
|---|
| | | f3 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code) |
|---|
| | | f6 = dask.delayed(SecondCancelBigNumComputer().cancel_success)(code) |
|---|
| | | f7 = dask.delayed(DCancelBigNumComputer().cancel_success)(code) |
|---|
| | | f8 = dask.delayed(LCancelBigNumComputer().cancel_success)(code) |
|---|
| | | |
|---|
| | | dask.compute(f1, f2, f3, f6, f7, f8) |
|---|
| | | l2_data_manager.TradePointManager().delete_buy_point(code) |
|---|
| | | l2_data_manager.TradePointManager().delete_buy_cancel_point(code) |
|---|
| | | SecondCancelBigNumComputer().cancel_success(code) |
|---|
| | | DCancelBigNumComputer().cancel_success(code) |
|---|
| | | LCancelBigNumComputer().cancel_success(code) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | code = "600246" |
|---|
| | | f2 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_point)(code) |
|---|
| | | f3 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code) |
|---|
| | | f6 = dask.delayed(SecondCancelBigNumComputer().cancel_success)(code) |
|---|
| | | f7 = dask.delayed(DCancelBigNumComputer().cancel_success)(code) |
|---|
| | | f8 = dask.delayed(LCancelBigNumComputer().cancel_success)(code) |
|---|
| | | dask.compute(f2, f3, f6, f7, f8) |
|---|
| | | pass |
|---|
