From b946684114d097e937b766f986d12c7eea8edce8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 18 九月 2022 17:23:43 +0800
Subject: [PATCH] l2数据计算优化
---
juejin.py | 35 ++++++++++++++++++++++++++---------
1 files changed, 26 insertions(+), 9 deletions(-)
diff --git a/juejin.py b/juejin.py
index 13de712..331756e 100644
--- a/juejin.py
+++ b/juejin.py
@@ -7,6 +7,8 @@
import gm.api as gmapi
+import big_money_num_manager
+import code_volumn_manager
import global_util
import gpcode_manager
import threading
@@ -41,6 +43,7 @@
# 姣忔棩鍒濆鍖�
def everyday_init():
+ codes = gpcode_manager.get_gp_list()
logger_system.info("姣忔棩鍒濆鍖�")
# 杞藉叆琛屼笟鑲＄エ浠ｇ爜
global_util.load_industry()
@@ -50,7 +53,21 @@
global_util.add_limit_up_codes([], True)
# 涓昏鑾峰彇鏀剁洏浠�
get_latest_info(None)
-
+ # 鑾峰彇60澶╂渶澶ч噺涓庢槰鏃ラ噺
+ global_util.today_volumn.clear()
+ global_util.max60_volumn.clear()
+ global_util.yesterday_volumn.clear()
+ volumn_dict = get_volumns(codes)
+ for key in volumn_dict:
+ code_volumn_manager.set_histry_volumn(key, volumn_dict[key][0], volumn_dict[key][1])
+ # 娓呴櫎澶у崟鏁版嵁
+ global_util.big_money_num.clear()
+ # 鍒濆鍖栧ぇ鍗曟暟鎹�
+ for code in codes:
+ big_money_num_manager.add_num(code, 0)
+ big_money_num_manager.expire(code)
+ # 娓呴櫎娑ㄥ仠鏃堕棿
+ global_util.limit_up_time.clear()
def __run_schedule():
while True:
@@ -170,15 +187,15 @@
if pricePre is not None:
rate = round((price - pricePre) * 100 / pricePre, 1)
if rate >= 7:
- logger_juejin_tick.info("{}-{}-{}",code, price, rate)
+ logger_juejin_tick.info("{}-{}-{}", code, price, rate)
if not gpcode_manager.is_listen(code) and not gpcode_manager.is_operate(
code) and not gpcode_manager.is_listen_full():
- L2CodeOperate.get_instance().add_operate(1, code,"鐜颁环鍙樺寲")
+ L2CodeOperate.get_instance().add_operate(1, code, "鐜颁环鍙樺寲")
# 杩涘叆鐩戞帶
elif rate < 5:
# 绉婚櫎鐩戞帶
if gpcode_manager.is_listen(code) and not gpcode_manager.is_operate(code):
- L2CodeOperate.get_instance().add_operate(0, code,"鐜颁环鍙樺寲")
+ L2CodeOperate.get_instance().add_operate(0, code, "鐜颁环鍙樺寲")
def on_bar(context, bars):
@@ -290,14 +307,14 @@
volumn = int(result["volume"])
day = "{:%Y-%m-%d}".format(result["eob"])
if _fresult.get(code) is None:
- _fresult[code] = {"max_volumn": volumn, "latest_volumn": volumn}
+ _fresult[code] = (volumn, volumn)
- if volumn > _fresult[code]["max_volumn"]:
- _fresult[code]["max_volumn"] = volumn;
- _fresult[code]["latest_volumn"] = volumn;
+ if volumn > _fresult[code][0]:
+ _fresult[code][0] = volumn;
+ _fresult[code][1] = volumn;
return _fresult
if __name__ == '__main__':
- _fresult=get_volumns(["000333","002531"])
+ _fresult = get_volumns(["000333", "002531"])
print(_fresult)
--
Gitblit v1.8.0