| | |
|---|
| | | buy_nums, |
|---|
| | | buy_count, total_datas[compute_index], cls.volume_rate_info[code]) |
|---|
| | | |
|---|
| | | f1 = dask.delayed(cls.__save_order_begin_data)(code, buy_single_index, compute_index, compute_index, |
|---|
| | | cls.__save_order_begin_data(code, buy_single_index, compute_index, compute_index, |
|---|
| | | buy_nums, buy_count, max_num_set_new, |
|---|
| | | cls.volume_rate_info[code][0]) |
|---|
| | | f2 = dask.delayed(limit_up_time_manager.LimitUpTimeManager().save_limit_up_time)(code, |
|---|
| | | limit_up_time_manager.LimitUpTimeManager().save_limit_up_time(code, |
|---|
| | | total_datas[compute_index][ |
|---|
| | | "val"]["time"]) |
|---|
| | | f3 = dask.delayed(cls.__virtual_buy)(code, buy_single_index, compute_index, capture_time) |
|---|
| | | f4 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code) |
|---|
| | | cls.__virtual_buy(code, buy_single_index, compute_index, capture_time) |
|---|
| | | l2_data_manager.TradePointManager().delete_buy_cancel_point(code) |
|---|
| | | # 暂时不需要 |
|---|
| | | # f5 = dask.delayed(L2LimitUpMoneyStatisticUtil.process_data)(code, buy_single_index, |
|---|
| | | # compute_index, |
|---|
| | | # buy_single_index, |
|---|
| | | # buy_exec_index, False) |
|---|
| | | dask.compute(f1, f2, f3, f4) |
|---|
| | | |
|---|
| | | # 已被并行处理 |
|---|
| | | # # 记录买入信号位置 |
|---|
