From 34491829675033e41715648b1e92f339bf2f35d1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 25 八月 2022 17:51:10 +0800
Subject: [PATCH] Changes
---
juejin.py | 32 ++++++++++++++++++++++----------
1 files changed, 22 insertions(+), 10 deletions(-)
diff --git a/juejin.py b/juejin.py
index 881b983..166c3ba 100644
--- a/juejin.py
+++ b/juejin.py
@@ -44,9 +44,9 @@
# 澶氫釜鏃堕棿鐐硅幏鍙栨敹鐩樹环
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')
- gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='09:15:00')
+ gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='09:28:00')
+ gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:25:00')
gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:29:00')
- gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:29:35')
re_subscribe_tick()
# re_subscribe_bar()
@@ -63,15 +63,16 @@
for c in clients:
for i in range(0, 8):
gpcode_manager.init_listen_code_by_pos(int(c), i)
- data = gpcode_manager.get_gp_list();
- result = JueJinManager.get_gp_latest_info(data);
+ codes = gpcode_manager.get_gp_list();
+ result = JueJinManager.get_gp_latest_info(codes);
for item in result:
sec_level = item['sec_level']
symbol = item['symbol']
symbol = symbol.split(".")[1]
pre_close = tool.to_price(decimal.Decimal(str(item['pre_close'])))
if sec_level == 1:
- gpcode_manager.set_price_pre(symbol, pre_close)
+ if symbol in codes:
+ gpcode_manager.set_price_pre(symbol, pre_close)
else:
gpcode_manager.rm_gp(symbol)
@@ -90,12 +91,12 @@
# 璁剧疆鏀剁洏浠�
-def set_price_pre(code):
+def re_set_price_pre(code):
codes = [code]
- set_price_pres(codes)
+ re_set_price_pres(codes)
-def set_price_pres(codes):
+def re_set_price_pres(codes):
result = JueJinManager.get_gp_latest_info(codes);
for item in result:
symbol = item['symbol']
@@ -175,9 +176,20 @@
def recieve_msg(pipe):
while True:
value = pipe.recv()
- print(value)
- if value == 'resub':
+ print("璺ㄨ繘绋嬮�氫俊锛�",value)
+ jsonValue= json.loads(value)
+ action=jsonValue["type"]
+ if action == 'resub':
re_subscribe_tick()
+ elif action == 'accpt_price':
+ try:
+ datas=jsonValue["data"]
+ for data in datas:
+ accpt_price(data["code"],float(data["price"]))
+ except Exception as e:
+ print(str(e))
+
+
class JueJinManager:
--
Gitblit v1.8.0