From 7bfdbe969da0b3a132d805cd15e9e83e7f2a8f8a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 25 六月 2023 11:12:26 +0800
Subject: [PATCH] 将掘金接口抽象出单独的类
---
server.py | 38 +++++++++++++++++++-------------------
1 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/server.py b/server.py
index 9a0f1ff..e8af3f1 100644
--- a/server.py
+++ b/server.py
@@ -21,7 +21,7 @@
import gpcode_first_screen_manager
import gpcode_manager
import authority
-import juejin
+import init
from l2 import l2_data_manager_new, l2_data_manager, l2_data_log, l2_log, code_price_manager
import l2_data_util
from l2.cancel_buy_strategy import HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil
@@ -33,6 +33,7 @@
from output import code_info_output
from third_data import hot_block_data_process, block_info, kpl_api
from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager
+from third_data.history_k_data_util import HistoryKDatasUtils
from third_data.kpl_data_manager import KPLCodeLimitUpReasonManager, KPLLimitUpDataRecordManager
from ths import l2_listen_pos_health_manager, l2_code_operate
from trade import trade_gui, trade_data_manager, trade_manager, l2_trade_util, deal_big_money_manager, \
@@ -225,7 +226,7 @@
for data in data_list:
code_list.append(data["code"])
# 鑾峰彇鍩烘湰淇℃伅
- code_datas = juejin.JueJinManager.get_gp_latest_info(code_list)
+ code_datas = HistoryKDatasUtils.get_gp_latest_info(code_list)
# if is_add:
# gpcode_manager.add_gp_list(code_datas)
# else:
@@ -294,7 +295,7 @@
# 鑾峰彇娑ㄥ仠浠�
_limit_up_price = gpcode_manager.get_limit_up_price(code)
if not _limit_up_price:
- juejin.re_set_price_pres([code],True)
+ init.re_set_price_pres([code], True)
# 鍐嶆鑾峰彇娑ㄥ仠浠�
_limit_up_price = gpcode_manager.get_limit_up_price(code)
if _limit_up_price:
@@ -333,7 +334,7 @@
for code in codes:
# 濡傛灉娑ㄥ仠浠锋槸绌哄�煎氨闇�瑕佽缃槰鏃ユ敹鐩樹环鏍�
if gpcode_manager.get_limit_up_price(code) is None:
- juejin.re_set_price_pres([code], True)
+ init.re_set_price_pres([code], True)
# 鏉垮潡鍏抽敭瀛楀噯澶�
for code in codes:
@@ -359,8 +360,8 @@
code) is None:
need_get_volumn = True
if need_get_volumn:
- volumes_data = juejin.get_volumns_by_code(code, 150)
- volumes = juejin.parse_max_volume(volumes_data[:90], code_nature_analyse.is_new_top(
+ volumes_data = init.get_volumns_by_code(code, 150)
+ volumes = init.parse_max_volume(volumes_data[:90], code_nature_analyse.is_new_top(
gpcode_manager.get_limit_up_price(code), volumes_data[:90]))
logger_first_code_record.info("{} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿}", code, volumes)
code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])
@@ -378,8 +379,7 @@
volumes_data)
gpcode_manager.FirstCodeManager.add_record(codes)
if new_add_codes:
- gpcode_manager.set_first_gp_codes_with_data(juejin.JueJinManager.get_gp_latest_info(codes,
- fields="symbol,sec_name,sec_type,sec_level"))
+ gpcode_manager.set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes,fields = "symbol,sec_name,sec_type,sec_level"))
# 鍔犲叆棣栨澘鍘嗗彶璁板綍
logger_first_code_record.info("鏂板棣栨澘锛歿}", new_add_codes)
@@ -406,7 +406,7 @@
# 鑾峰彇娑ㄥ仠浠�
if temp_codes:
# 鑾峰彇娑ㄥ仠浠�
- juejin.re_set_price_pres(temp_codes)
+ init.re_set_price_pres(temp_codes)
# 閲嶆柊鑾峰彇娑ㄥ仠浠�
for code in temp_codes:
limit_up_price = gpcode_manager.get_limit_up_price(code)
@@ -435,7 +435,7 @@
gpcode_manager.FirstCodeManager.add_limited_up_record([code])
pricePre = gpcode_manager.get_price_pre(code)
if pricePre is None:
- juejin.re_set_price_pres([code])
+ init.re_set_price_pres([code])
rate = round((float(price) - pricePre) * 100 / pricePre, 1)
prices.append(
@@ -515,7 +515,7 @@
# 鏍规嵁浠ｇ爜鑾峰彇浠ｇ爜鍚嶇О
codes_name = {}
if codes:
- codes_name = juejin.JueJinManager.get_gp_codes_names(codes)
+ codes_name = HistoryKDatasUtils.get_gp_codes_names(codes)
ths_industry_util.save_industry_code(dataList, codes_name)
elif type == 6:
# 鍙敤閲戦
@@ -775,7 +775,7 @@
day = tool.get_now_date_str()
data_dict = {}
for i in range(0, 2):
- day = juejin.JueJinManager.get_previous_trading_date(day)
+ day = HistoryKDatasUtils.get_previous_trading_date(day)
data_list = list(block_info.KPLLimitUpDataRecordManager.list_all(day))
codes_set = set()
if data_list:
@@ -808,7 +808,7 @@
l2_trade_util.forbidden_trade(code)
name = gpcode_manager.get_code_name(code)
if not name:
- results = juejin.JueJinManager.get_gp_codes_names([code])
+ results = HistoryKDatasUtils.get_gp_codes_names([code])
if results:
gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
@@ -833,7 +833,7 @@
l2_trade_util.WhiteListCodeManager.add_code(code)
name = gpcode_manager.get_code_name(code)
if not name:
- results = juejin.JueJinManager.get_gp_codes_names([code])
+ results = HistoryKDatasUtils.get_gp_codes_names([code])
if results:
gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
return_str = json.dumps({"code": 0})
@@ -878,7 +878,7 @@
gpcode_manager.WantBuyCodesManager.add_code(code)
name = gpcode_manager.get_code_name(code)
if not name:
- results = juejin.JueJinManager.get_gp_codes_names([code])
+ results = HistoryKDatasUtils.get_gp_codes_names([code])
if results:
gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
if "plates" in data["data"]:
@@ -920,7 +920,7 @@
gpcode_manager.PauseBuyCodesManager.add_code(code)
name = gpcode_manager.get_code_name(code)
if not name:
- results = juejin.JueJinManager.get_gp_codes_names([code])
+ results = HistoryKDatasUtils.get_gp_codes_names([code])
if results:
gpcode_manager.CodesNameManager.add_first_code_name(code, results[code])
return_str = json.dumps({"code": 0})
@@ -1120,10 +1120,10 @@
try:
global_data_loader.load_zyltgb()
limit_up_price = float(gpcode_manager.get_limit_up_price(code))
- volumes_data = juejin.get_volumns_by_code(code, 150)
+ volumes_data = init.get_volumns_by_code(code, 150)
volumes_data = volumes_data[1:]
- volumes = juejin.parse_max_volume(volumes_data[:60],
- code_nature_analyse.is_new_top(limit_up_price,
+ volumes = init.parse_max_volume(volumes_data[:60],
+ code_nature_analyse.is_new_top(limit_up_price,
volumes_data[:60]))
logger_first_code_record.info("{} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿}", code, volumes)
code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])
--
Gitblit v1.8.0