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

Administrator

2023-08-16 8316c16bbfcb120683e16721aace4eef803f2386

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

 l2/l2_data_manager_new.py

@@ -353,12 +353,13 @@
            if limit_up_time is None:
                limit_up_time = tool.get_now_time_str()
            # score = first_code_score_manager.get_score(code, volume_rate, limit_up_time, True)
            # cls.__l2PlaceOrderParamsManagerDict[code] = l2_trade_factor.L2PlaceOrderParamsManager(code, is_first_code,
            #                                                                                       volume_rate,
            #                                                                                       volume_rate_index,
            #                                                                                       score,
            #                                                                                       total_datas[-1][
            #                                                                                           'val']['time'])
            score = None
            cls.__l2PlaceOrderParamsManagerDict[code] = l2_trade_factor.L2PlaceOrderParamsManager(code, is_first_code,
                                                                                                  volume_rate,
                                                                                                  volume_rate_index,
                                                                                                  score,
                                                                                                  total_datas[-1][
                                                                                                      'val']['time'])
            cls.volume_rate_info[code] = (volume_rate, volume_rate_index)

            latest_time = add_datas[len(add_datas) - 1]["val"]["time"]

 trade/l2_trade_factor.py

@@ -89,15 +89,16 @@
        self.is_first_code = is_first_code
        score_ranks = [constant.BUY_SCORE_RANK_3, constant.BUY_SCORE_RANK_2, constant.BUY_SCORE_RANK_1,
                       constant.BUY_SCORE_RANK_0]
        self.score = score[0][0]
        self.score_info = score
        # self.score = score[0][0]
        # self.score_info = score
        # 为分数设置等级
        score_index = -1
        for i in range(0, len(score_ranks)):
            if self.score >= score_ranks[i]:
                score_index = i
                break
        self.score_index = score_index
        # score_index = -1
        # for i in range(0, len(score_ranks)):
        #     if self.score >= score_ranks[i]:
        #         score_index = i
        #         break
        # 固定设置为2
        self.score_index = 2
        # 只要加入想买单的，全部执行主动买入二星方案
        if gpcode_manager.WantBuyCodesManager().is_in_cache(code):
            self.score_index = 1