++++++++++++++++ 取消不必要的并行计算框架

Administrator

2023-08-16 965bd2fea182851382f61d9c7c1492d04546bf4d

 trade/trade_result_manager.py

@@ -1,8 +1,6 @@
# 虚拟买成功
import logging

import dask

from l2 import l2_data_manager
from l2.cancel_buy_strategy import HourCancelBigNumComputer, SecondCancelBigNumComputer, L2LimitUpSellStatisticUtil, \
    LCancelBigNumComputer, DCancelBigNumComputer
@@ -25,25 +23,25 @@

# 虚拟撤成功
def virtual_cancel_success(code, buy_single_index, buy_exec_index, total_datas):
    f1 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_point)(code)
    f2 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code)
    l2_data_manager.TradePointManager().delete_buy_point(code)
    l2_data_manager.TradePointManager().delete_buy_cancel_point(code)
    # 安全笔数计算
    f5 = dask.delayed(__buyL2SafeCountManager.save_place_order_info)(code, buy_single_index, buy_exec_index,
                                                                     total_datas[-1]["index"])
    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, f5, f6, f7, f8)
    __buyL2SafeCountManager.save_place_order_info(code, buy_single_index, buy_exec_index,
                                                  total_datas[-1]["index"])
    SecondCancelBigNumComputer().cancel_success(code)
    DCancelBigNumComputer().cancel_success(code)
    LCancelBigNumComputer().cancel_success(code)
    # dask.compute(f1, f2, f5, f6, f7, f8)


# 真实买成功
def real_buy_success(code):
    @dask.delayed
    # @dask.delayed
    def clear_max_buy1_volume(code):
        # 下单成功，需要删除最大买1
        __thsBuy1VolumnManager.clear_max_buy1_volume(code)

    @dask.delayed
    # @dask.delayed
    def safe_count(code, buy_single_index, buy_exec_index):
        try:
            __buyL2SafeCountManager.save_place_order_info(code, buy_single_index, buy_exec_index, None)
@@ -51,7 +49,7 @@
            logging.exception(e)
            logger_l2_error.exception(e)

    @dask.delayed
    # @dask.delayed
    def h_cancel(code, buy_single_index, buy_exec_index):
        try:
            HourCancelBigNumComputer().place_order_success(code, buy_single_index, buy_exec_index,
@@ -61,7 +59,7 @@
            logging.exception(e)
            logger_l2_error.exception(e)

    @dask.delayed
    # @dask.delayed
    def l_cancel(code):
        try:
            LCancelBigNumComputer().del_watch_index(code)
@@ -72,11 +70,10 @@
    buy_single_index, buy_exec_index, buy_compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(
        code)

    f1 = clear_max_buy1_volume(code)
    f2 = safe_count(code, buy_single_index, buy_exec_index)
    f3 = h_cancel(code, buy_single_index, buy_exec_index)
    f4 = l_cancel(code)
    dask.compute(f1, f2, f3, f4)
    clear_max_buy1_volume(code)
    safe_count(code, buy_single_index, buy_exec_index)
    h_cancel(code, buy_single_index, buy_exec_index)
    l_cancel(code)
    l2_data_manager.TradePointManager().delete_buy_cancel_point(code)