From e7f8c6013d777dd5ba10b8d548d2d3db6158d37a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 08 九月 2022 17:04:27 +0800
Subject: [PATCH] '完善'

---
 juejin.py |   61 ++++++++++++++++++++----------
 1 files changed, 41 insertions(+), 20 deletions(-)

diff --git a/juejin.py b/juejin.py
index 166c3ba..88ee28b 100644
--- a/juejin.py
+++ b/juejin.py
@@ -3,17 +3,22 @@
 import datetime
 import json
 import time as t
+import schedule
 
 import gm.api as gmapi
+
+import global_util
 import gpcode_manager
 import threading
+
+import server
 import tool
 
 import redis_manager
 import authority
 import decimal
 from l2_code_operate import L2CodeOperate
-from log import logger_juejin_tick
+from log import logger_juejin_tick, logger_system
 
 redisManager = redis_manager.RedisManager()
 
@@ -34,13 +39,37 @@
     return account_id, strategy_id, token
 
 
+# 姣忔棩鍒濆鍖�
+def everyday_init():
+    logger_system.info("姣忔棩鍒濆鍖�")
+    # 杞藉叆琛屼笟鑲＄エ浠ｇ爜
+    global_util.load_industry()
+    # 杞藉叆浠ｇ爜鑷敱娴侀�氬競鍊�
+    global_util.load_zyltgb()
+    # 浠婃棩瀹炴椂娑ㄥ仠
+    global_util.add_limit_up_codes([], True)
+    # 涓昏鑾峰彇鏀剁洏浠�
+    get_latest_info(None)
+
+
+def __run_schedule():
+    while True:
+        schedule.run_pending()
+
+
 def init(context):
     # gmapi.subscribe(symbols="SZSE.002529", frequency="1d", count=30)
 
     # 璁㈤槄娴﹀彂閾惰, bar棰戠巼涓轰竴澶╁拰涓�鍒嗛挓
     # 璁㈤槄璁㈤槄澶氫釜棰戠巼鐨勬暟鎹紝鍙娆¤皟鐢╯ubscribe
     # 鑾峰彇闇�瑕佺洃鍚殑鑲＄エ
-    print("鎺橀噾鍒濆鍖�")
+    logger_system.info("鎺橀噾鍒濆鍖�")
+    schedule.every().day.at("09:00:00").do(everyday_init)
+    t1 = threading.Thread(target=lambda: __run_schedule())
+    # 鍚庡彴杩愯
+    t1.setDaemon(True)
+    t1.start()
+
     # 澶氫釜鏃堕棿鐐硅幏鍙栨敹鐩樹环
     gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='08:30:00')
     gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='08:50:00')
@@ -81,7 +110,7 @@
 def get_current_info():
     data = gpcode_manager.get_gp_list();
     results = JueJinManager.get_gp_current_info(data);
-    logger_juejin_tick.debug("瀹氭椂鑾峰彇锛歿}",results)
+    logger_juejin_tick.debug("瀹氭椂鑾峰彇锛歿}", results)
     for result in results:
         price = result["price"]
         symbol = result['symbol']
@@ -176,20 +205,18 @@
 def recieve_msg(pipe):
     while True:
         value = pipe.recv()
-        print("璺ㄨ繘绋嬮�氫俊锛�",value)
-        jsonValue= json.loads(value)
-        action=jsonValue["type"]
+        print("璺ㄨ繘绋嬮�氫俊锛�", value)
+        jsonValue = json.loads(value)
+        action = jsonValue["type"]
         if action == 'resub':
             re_subscribe_tick()
         elif action == 'accpt_price':
             try:
-                datas=jsonValue["data"]
+                datas = jsonValue["data"]
                 for data in datas:
-                    accpt_price(data["code"],float(data["price"]))
+                    accpt_price(data["code"], float(data["price"]))
             except Exception as e:
                 print(str(e))
-
-
 
 
 class JueJinManager:
@@ -241,6 +268,7 @@
     print(result)
 
 
+# 鑾峰彇杩�90澶╃殑鏈�澶ч噺涓庢渶杩戠殑閲�
 def get_volumns(codes):
     end = datetime.datetime.now()
     # 鑾峰彇杩�90澶╃殑鍘嗗彶鏁版嵁
@@ -254,6 +282,7 @@
                             start_time="{:%Y-%m-%d}".format(start),
                             fields="symbol,volume,eob",
                             end_time="{:%Y-%m-%d}".format(end))
+    print(len(results))
     _fresult = {}
 
     for result in results:
@@ -270,13 +299,5 @@
 
 
 if __name__ == '__main__':
-    # trade("SZSE.000521", 100)
-    # print("")
-    # JueJinManager.get_gp_latest_info(["000592","002808"])
-    get_current_info()
-
-    # data_process.saveCodeVolumn(get_volumns(["000333","002911"]))
-    # _redis_manager = redis_manager.RedisManager()
-    # redis = _redis_manager.getRedis()
-    # keys = redis.keys("test-inrec")
-    # print(keys)
+    _fresult=get_volumns(["000333","002531"])
+    print(_fresult)

--
Gitblit v1.8.0