From 3188666e40694641e954f3334a28e3bee8cc4b17 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 三月 2024 09:08:43 +0800
Subject: [PATCH] bug修复
---
third_data/kpl_data_manager.py | 23 +++++++++++++++++++----
1 files changed, 19 insertions(+), 4 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 34e589a..b2ae85d 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -14,7 +14,8 @@
# 寮�鐩樺暒鍘嗗彶娑ㄥ仠鏁版嵁绠＄悊
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
-from log_module.log import logger_kpl_limit_up_reason_change, logger_debug, logger_kpl_limit_up
+from log_module.log import logger_kpl_limit_up_reason_change, logger_debug, logger_kpl_limit_up, \
+ logger_kpl_open_limit_up
from third_data import kpl_util, kpl_api
from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodesHisReasonAndBlocksManager
@@ -67,6 +68,20 @@
@classmethod
def save_record(cls, day, records):
+ # 缁熻鐐告澘
+ try:
+ last_codes = set()
+ if cls.latest_origin_datas:
+ last_codes = set([x[0] for x in cls.latest_origin_datas])
+ now_codes = set()
+ if records:
+ now_codes = set([x[0] for x in records])
+ open_limit_up_codes = last_codes - now_codes
+ if open_limit_up_codes:
+ logger_kpl_open_limit_up.info(f"鐐告澘浠ｇ爜锛歿open_limit_up_codes}")
+ except Exception as e:
+ pass
+
# 缁熻浠ｇ爜鎵�灞炴澘鍧�
code_block_dict = {}
for data in records:
@@ -77,6 +92,7 @@
code_block_dict[code] = set()
code_block_dict[code].add(b)
# 璁剧疆娑ㄥ仠鏁版嵁
+
if records:
cls.latest_origin_datas = records
cls.__LimitUpCodesPlateKeyManager.set_today_limit_up([(r[0], r[5]) for r in records])
@@ -401,10 +417,9 @@
def get_limit_up():
while True:
- if tool.is_trade_time():
+ if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")):
try:
results = kpl_api.getLimitUpInfoNew()
- results = kpl_util.filter_block(results)
result = json.loads(results)
start_time = time.time()
__upload_data("limit_up", result)
@@ -447,7 +462,7 @@
time.sleep(3)
threading.Thread(target=get_limit_up, daemon=True).start()
- threading.Thread(target=get_bidding_money, daemon=True).start()
+ # threading.Thread(target=get_bidding_money, daemon=True).start()
# threading.Thread(target=get_market_industry, daemon=True).start()
# threading.Thread(target=get_market_jingxuan, daemon=True).start()
--
Gitblit v1.8.0