From 7df08608edda0361fb272b397a20b80990bd1908 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 16 十一月 2023 14:02:18 +0800
Subject: [PATCH] 删除分数相关代码
---
output/code_info_output.py | 57 +++------------------------------------------------------
1 files changed, 3 insertions(+), 54 deletions(-)
diff --git a/output/code_info_output.py b/output/code_info_output.py
index 12f249f..be7f221 100644
--- a/output/code_info_output.py
+++ b/output/code_info_output.py
@@ -11,7 +11,6 @@
import time
import code_attribute
from code_attribute import code_volumn_manager, limit_up_time_manager, global_data_loader, gpcode_manager
-import constant
from l2.l2_data_manager import OrderBeginPosInfo
from l2.l2_data_util import L2DataUtil
from utils import global_util, tool
@@ -21,9 +20,8 @@
import l2.l2_data_manager_new
from third_data import kpl_data_manager, kpl_api
from third_data.kpl_data_manager import KPLLimitUpDataRecordManager
-from trade import first_code_score_manager, l2_trade_factor, trade_manager, l2_trade_util, trade_record_log_util
+from trade import l2_trade_factor, trade_manager, l2_trade_util, trade_record_log_util
from trade.l2_trade_factor import L2TradeFactorUtil
-import trade.deal_big_money_manager
base_output_content = {}
kpl_block_info_dict = {}
@@ -89,8 +87,6 @@
limit_up_price = gpcode_manager.get_limit_up_price(code)
limit_up_time = limit_up_time_manager.LimitUpTimeManager().get_limit_up_time_cache(code)
volume_rate, volume_info = code_volumn_manager.get_volume_rate(code, True)
- (score, score_list), score_source_list = first_code_score_manager.get_score(code, volume_rate, limit_up_time,
- True)
################################涔板墠璇勫垎################################
@@ -103,13 +99,10 @@
params["trade_data"] = {}
# 鑾峰彇涔板叆鎰忔効
- volume_rate = score_source_list[6]
__L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, True, volume_rate,
code_volumn_manager.get_volume_rate_index(
volume_rate),
- (
- (score, score_list),
- score_source_list))
+ None)
# 鏄惁鍙互涔板叆鐨勪俊鎭�
can_buy_info = l2.l2_data_manager_new.L2TradeDataProcessor.can_buy_first(code, limit_up_price)
params["trade_data"]["can_buy_info"] = can_buy_info
@@ -117,8 +110,7 @@
__base_L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, False, volume_rate,
code_volumn_manager.get_volume_rate_index(
volume_rate),
- ((score, score_list),
- score_source_list))
+ None)
if -1 < __L2PlaceOrderParamsManager.score_index < 3:
params["trade_data"]["star"] = {"desc": "涓诲姩涔板叆"}
if __L2PlaceOrderParamsManager.score_index == 0:
@@ -299,49 +291,6 @@
log.logger_debug.info(f"鑾峰彇浠ｇ爜鐨勫巻鍙叉定鍋滄暟鎹�楁椂锛歿time.time() - __start_time}")
__start_time = time.time()
return params
-
-
-def __load_codes_scores():
- # 鑾峰彇鎵�鏈夌洃鍚腑鐨勪唬鐮�
- codes = gpcode_manager.FirstGPCodesManager().get_first_gp_codes()
- scores = {} # l2_data_manager_new.L2TradeDataProcessor.get_code_scores()
- for code in codes:
- if code not in scores:
- # 鑾峰彇鍒嗘暟
- try:
- limit_up_time = limit_up_time_manager.LimitUpTimeManager().get_limit_up_time_cache(code)
- volume_rate, volume_info = code_volumn_manager.get_volume_rate(code, True)
- (score, score_list), score_source_list = first_code_score_manager.get_score(code, volume_rate,
- limit_up_time,
- True)
- scores[code] = score
- except:
- pass
- # 绛涢��180鍒嗕互涓婄殑浠ｇ爜
- scores_list = []
- for code in scores:
- code_name = gpcode_manager.get_code_name(code)
- # 鑾峰彇鐜颁环锛屽垽鏂槸鍚︽定鍋�
- current_price_info = global_util.cuurent_prices.get(code)
- limit_up_info = code_price_manager.Buy1PriceManager().get_limit_up_info(code)
- is_limit_up = True
- open_limit_up = limit_up_info[0] and limit_up_info[1]
- if current_price_info is not None and not current_price_info[1]:
- is_limit_up = False
- else:
- is_limit_up = True
- scores_list.append((code, code_name, scores[code], is_limit_up, open_limit_up))
- scores_list.sort(key=lambda x: x[2], reverse=True)
- fscores_list = [[], [], []]
- for score in scores_list:
- if score[2] >= constant.BUY_SCORE_RANK_1:
- fscores_list[0].append(score)
- elif score[2] >= constant.BUY_SCORE_RANK_0:
- fscores_list[1].append(score)
- else:
- fscores_list[2].append(score)
-
- return fscores_list
def __load_trade_record(code, total_datas):
--
Gitblit v1.8.0