From 466cd5b36cd4a3bb46e8449f640c51d06b99a90d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 11 六月 2024 17:25:04 +0800
Subject: [PATCH] API输出正股详细的信息
---
third_data/kpl_data_manager.py | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 14409ae..7313018 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -269,7 +269,7 @@
pre_close_price = round(float(limit_up_price) / tool.get_limit_up_rate(code), 2)
# 濡傛灉娑ㄥ箙澶т簬7%灏辫鍙栨澘鍧�
price_rate = (buy_1_price - pre_close_price) / pre_close_price
- if price_rate > 0.07:
+ if price_rate > 0.07 * (tool.get_limit_up_rate(code)-1) * 10:
jx_blocks_info = self.get_jx_blocks_cache(code)
if not jx_blocks_info:
start_time = time.time()
@@ -297,7 +297,7 @@
async_log_util.info(logger_kpl_block_can_buy,
f"{code}:鑾峰彇鍒扮簿閫夋澘鍧楋紙鏇存柊锛�-{blocks} 鑰楁椂:{int(time.time() - start_time)}s")
self.save_jx_blocks(code, blocks, current_limit_up_blocks)
- elif price_rate > 0.03:
+ elif price_rate > 0.03 * (tool.get_limit_up_rate(code)-1) * 10:
# 娣诲姞澶囩敤鏉垮潡
if not self.get_jx_blocks_cache(code, by=True):
start_time = time.time()
@@ -491,16 +491,16 @@
threading.Thread(target=cls.run_limit_up_task, daemon=True).start()
@classmethod
- def run_limit_up_task(cls):
+ def run_limit_up_task(cls, limit_up_result_callback):
# 鍏抽棴log
log.close_print()
while True:
try:
- if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")):
+ if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")) or True:
results = kpl_api.getLimitUpInfoNew()
result = json.loads(results)
start_time = time.time()
- cls.__upload_data("limit_up", result)
+ limit_up_result_callback(result)
except Exception as e:
try:
logging.exception(e)
--
Gitblit v1.8.0