From 3da5d1ef00cf7665c2d37f837e6845c92d22e31c Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 15 十二月 2023 16:02:08 +0800 Subject: [PATCH] 前日炸板策略修改 --- third_data/kpl_data_manager.py | 15 ++++++++++----- 1 files changed, 10 insertions(+), 5 deletions(-) diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py index 7f24b2f..1d5e713 100644 --- a/third_data/kpl_data_manager.py +++ b/third_data/kpl_data_manager.py @@ -342,9 +342,14 @@ def get_yesterday_limit_up_codes(): - yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1] + yesterday_limit_up_data_records = get_yesterday_current_limit_up_records() yesterday_codes = set([x[0] for x in yesterday_limit_up_data_records]) return yesterday_codes + + +def get_yesterday_current_limit_up_records(): + yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1] + return yesterday_limit_up_data_records # 杩愯鎷夊彇浠诲姟 @@ -364,11 +369,11 @@ results = kpl_api.getLimitUpInfo() result = json.loads(results) start_time = time.time() - if start_time - last_time >= 60: - last_time = start_time - # 璁板綍娑ㄥ仠鏁版嵁 - async_log_util.info(logger_kpl_limit_up, result) __upload_data("limit_up", result) + if start_time - last_time >= 60: + last_time = time.time() + # 璁板綍娑ㄥ仠鏁版嵁 + logger_kpl_limit_up.info(result) # logger_kpl_limit_up_reason_change.info("涓婁紶鑰楁椂锛歿}", time.time() - start_time) except Exception as e: logging.exception(e) -- Gitblit v1.8.0