From 25b1dfff65e34fcdb22f02dbe523b38e4d5b12e8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 29 十一月 2023 11:02:05 +0800
Subject: [PATCH] bug修改
---
third_data/code_plate_key_manager.py | 72 +++++++++++++++++++-----------------
1 files changed, 38 insertions(+), 34 deletions(-)
diff --git a/third_data/code_plate_key_manager.py b/third_data/code_plate_key_manager.py
index bcf88d9..57179bf 100644
--- a/third_data/code_plate_key_manager.py
+++ b/third_data/code_plate_key_manager.py
@@ -91,42 +91,46 @@
# 浠庣綉缁滀笂鍔犺浇绮鹃�夋澘鍧�
def load_jx_blocks(self, code, buy_1_price, limit_up_price):
- if limit_up_price and buy_1_price:
- # 澶勭悊涔�1,鍗�1淇℃伅
- pre_close_price = round(float(limit_up_price) / 1.1, 2)
- # 濡傛灉娑ㄥ箙澶т簬7%灏辫鍙栨澘鍧�
- price_rate = (buy_1_price - pre_close_price) / pre_close_price
- if price_rate > 0.07:
- jx_blocks_info = self.get_jx_blocks_cache(code)
- if not jx_blocks_info:
- blocks = kpl_api.getCodeJingXuanBlocks(code)
- self.save_jx_blocks(code, blocks)
- async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧�-{blocks}")
- else:
- # 杩樻病娑ㄥ仠鐨勯渶瑕佹洿鏂扮簿閫夋澘鍧� 鏇存柊绮鹃�夋澘鍧�
- if abs(float(buy_1_price) - float(limit_up_price)) >= 0.001 or True:
- # 闈炴定鍋滅姸鎬�
- UPDATE_TIME_SPACE = 5 * 60
- time_diff = tool.trade_time_sub(tool.get_now_time_str(), "09:30:00")
- if time_diff < 0:
- UPDATE_TIME_SPACE = 60 * 60
- else:
- UPDATE_TIME_SPACE = int(time_diff / 30) + 60
- if UPDATE_TIME_SPACE > 5 * 60:
- UPDATE_TIME_SPACE = 5 * 60
+ try:
+ if limit_up_price and buy_1_price:
+ # 澶勭悊涔�1,鍗�1淇℃伅
+ pre_close_price = round(float(limit_up_price) / 1.1, 2)
+ # 濡傛灉娑ㄥ箙澶т簬7%灏辫鍙栨澘鍧�
+ price_rate = (buy_1_price - pre_close_price) / pre_close_price
+ if price_rate > 0.07:
+ jx_blocks_info = self.get_jx_blocks_cache(code)
+ if not jx_blocks_info:
+ blocks = kpl_api.getCodeJingXuanBlocks(code)
+ self.save_jx_blocks(code, blocks)
+ async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧�-{blocks}")
+ else:
+ # 杩樻病娑ㄥ仠鐨勯渶瑕佹洿鏂扮簿閫夋澘鍧� 鏇存柊绮鹃�夋澘鍧�
+ if abs(float(buy_1_price) - float(limit_up_price)) >= 0.001 or True:
+ # 闈炴定鍋滅姸鎬�
+ UPDATE_TIME_SPACE = 5 * 60
+ time_diff = tool.trade_time_sub(tool.get_now_time_str(), "09:30:00")
+ if time_diff < 0:
+ UPDATE_TIME_SPACE = 60 * 60
+ else:
+ UPDATE_TIME_SPACE = int(time_diff / 30) + 60
+ if UPDATE_TIME_SPACE > 5 * 60:
+ UPDATE_TIME_SPACE = 5 * 60
- if time.time() - jx_blocks_info[1] > UPDATE_TIME_SPACE:
- # 璺濈涓婃鏇存柊鏃堕棿杩囧幓浜�5鍒嗛挓
- blocks = kpl_api.getCodeJingXuanBlocks(code)
- self.save_jx_blocks(code, blocks)
- async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧楋紙鏇存柊锛�-{blocks}")
+ if time.time() - jx_blocks_info[1] > UPDATE_TIME_SPACE:
+ # 璺濈涓婃鏇存柊鏃堕棿杩囧幓浜�5鍒嗛挓
+ blocks = kpl_api.getCodeJingXuanBlocks(code)
+ self.save_jx_blocks(code, blocks)
+ async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧楋紙鏇存柊锛�-{blocks}")
- elif price_rate > 0.03:
- # 娣诲姞澶囩敤鏉垮潡
- if not self.get_jx_blocks_cache(code, by=True):
- blocks = kpl_api.getCodeJingXuanBlocks(code)
- self.save_jx_blocks(code, blocks, by=True)
- async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧�(澶囩敤)-{blocks}")
+ elif price_rate > 0.03:
+ # 娣诲姞澶囩敤鏉垮潡
+ if not self.get_jx_blocks_cache(code, by=True):
+ blocks = kpl_api.getCodeJingXuanBlocks(code)
+ self.save_jx_blocks(code, blocks, by=True)
+ async_log_util.info(logger_kpl_block_can_buy, f"{code}:鑾峰彇鍒扮簿閫夋澘鍧�(澶囩敤)-{blocks}")
+ except Exception as e:
+ logger_kpl_block_can_buy.error(f"{code} 鑾峰彇鏉垮潡鍑洪敊")
+ logger_kpl_block_can_buy.exception(e)
# 寮�鐩樺暒绂佹浜ゆ槗鏉垮潡绠＄悊
--
Gitblit v1.8.0