From 4c7ae89ebaac6e87d0b15e9d7ceff6f9407178a7 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期三, 15 一月 2025 15:38:00 +0800
Subject: [PATCH] 缓存目录修改
---
strategy/kpl_api.py | 40 +++++++++++++++++++++-------------------
1 files changed, 21 insertions(+), 19 deletions(-)
diff --git a/strategy/kpl_api.py b/strategy/kpl_api.py
index f838aad..8c2d307 100644
--- a/strategy/kpl_api.py
+++ b/strategy/kpl_api.py
@@ -2,6 +2,7 @@
kpl API鏁版嵁鑾峰彇涓庡鐞�
"""
import json
+import os.path
import time
import datetime
@@ -355,33 +356,34 @@
# 鏋勫缓娑ㄥ仠淇℃伅璇诲啓瀵硅薄
class DailyLimitUpInfoStorageManager:
# 鍒濆鍖栨枃浠惰矾寰�
- def __init__(self, file_path='local_storage_data/limit_up_block_date_data.jsonl'):
+ def __init__(self, file_path=constant.KPL_LIMIT_UP_DATA_PATH):
self.file_path = file_path
# 娣诲姞鍗曟棩娑ㄥ仠淇℃伅鏁版嵁鍒版枃浠朵腑鐨勪竴琛� 鍑芥暟
def append_data_to_file(self, data_to_append):
# print(f"data_to_append=={data_to_append}")
# 璇诲彇鎵�鏈夎骞惰В鏋愪负 JSON 瀵硅薄鍒楄〃
- with open(self.file_path, 'r', encoding='utf-8') as file:
- # 鑾峰彇褰撳墠鏃ユ湡骞舵牸寮忓寲
- current_date = datetime.datetime.now().strftime('%Y-%m-%d')
- lines = [json.loads(line.strip()) for line in file if line.strip()]
- # print(f"lines type=={type(lines)}")
- # print(f"lines=={lines}")
- # 妫�鏌ュ綋鍓嶆棩鏈熸槸鍚﹀凡瀛樺湪浜庢枃浠朵腑
- if lines: # 濡傛灉璇诲彇鍒扮殑琛屾枃浠跺垪琛ㄤ笉涓虹┖锛堜负鐪燂級
- if lines[-1].get(current_date) is None: # 濡傛灉鍒楄〃涓殑鍊掓暟鏈�鍚庝竴琛岃幏鍙栦笉鍒板綋鏃ョ殑鏃ユ湡锛堟渶鍚庝竴琛岀殑閿� 涓� 褰撴棩鏃ユ湡锛�
- # 灏嗘棩鏈熷拰data_to_append杞崲涓篔SON鏍煎紡鐨勫瓧绗︿覆
+ if os.path.exists(self.file_path):
+ with open(self.file_path, 'r', encoding='utf-8') as file:
+ # 鑾峰彇褰撳墠鏃ユ湡骞舵牸寮忓寲
+ current_date = datetime.datetime.now().strftime('%Y-%m-%d')
+ lines = [json.loads(line.strip()) for line in file if line.strip()]
+ # print(f"lines type=={type(lines)}")
+ # print(f"lines=={lines}")
+ # 妫�鏌ュ綋鍓嶆棩鏈熸槸鍚﹀凡瀛樺湪浜庢枃浠朵腑
+ if lines: # 濡傛灉璇诲彇鍒扮殑琛屾枃浠跺垪琛ㄤ笉涓虹┖锛堜负鐪燂級
+ if lines[-1].get(current_date) is None: # 濡傛灉鍒楄〃涓殑鍊掓暟鏈�鍚庝竴琛岃幏鍙栦笉鍒板綋鏃ョ殑鏃ユ湡锛堟渶鍚庝竴琛岀殑閿� 涓� 褰撴棩鏃ユ湡锛�
+ # 灏嗘棩鏈熷拰data_to_append杞崲涓篔SON鏍煎紡鐨勫瓧绗︿覆
+ json_line = json.dumps({current_date: data_to_append}, ensure_ascii=False) + '\n'
+ # 鎵撳紑鏂囦欢骞惰拷鍔燡SON琛�
+ with open(self.file_path, 'a', encoding='utf-8') as file:file.write(json_line)
+ else:
+ print(f"锛堝綋鏃ユ棩鏈熷凡瀛樺湪浜庢枃浠剁殑鏈�鍚庝竴琛屼簡锛屼笉鍐嶉噸澶嶈拷鍔犲啓鍏ワ級")
+ else:
json_line = json.dumps({current_date: data_to_append}, ensure_ascii=False) + '\n'
# 鎵撳紑鏂囦欢骞惰拷鍔燡SON琛�
- with open(self.file_path, 'a', encoding='utf-8') as file:file.write(json_line)
- else:
- print(f"锛堝綋鏃ユ棩鏈熷凡瀛樺湪浜庢枃浠剁殑鏈�鍚庝竴琛屼簡锛屼笉鍐嶉噸澶嶈拷鍔犲啓鍏ワ級")
- else:
- json_line = json.dumps({current_date: data_to_append}, ensure_ascii=False) + '\n'
- # 鎵撳紑鏂囦欢骞惰拷鍔燡SON琛�
- with open(self.file_path, 'a', encoding='utf-8') as file:
- file.write(json_line)
+ with open(self.file_path, 'a', encoding='utf-8') as file:
+ file.write(json_line)
# 娓呯悊澶氫綑鏁版嵁鍑芥暟
def check_and_remove_oldest_entry(self, max_entries):
--
Gitblit v1.8.0