From 1b49e9a1c5d31a568406a361b883eec211326983 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 07 六月 2024 14:45:03 +0800
Subject: [PATCH] 自由流通量相关测试
---
test/test_log.py | 28 ++++++++++++++++++++++++----
1 files changed, 24 insertions(+), 4 deletions(-)
diff --git a/test/test_log.py b/test/test_log.py
index 292a863..80a1169 100644
--- a/test/test_log.py
+++ b/test/test_log.py
@@ -1,8 +1,28 @@
+from code_attribute.code_data_util import ZYLTGBUtil
+from code_attribute.gpcode_manager import CodePrePriceManager
+from huaxin_client import l1_subscript_codes_manager
from log_module.async_log_util import huaxin_l2_log
from log_module.log import logger_local_huaxin_l2_error
+from third_data import history_k_data_util, kpl_api
if __name__ == "__main__":
- use_time = 0.02
- temp_list = ["123123"]
- huaxin_l2_log.info(logger_local_huaxin_l2_error, f"鑰楁椂:{use_time}s 缁撴潫鏁版嵁锛歿temp_list[-1]}")
- huaxin_l2_log.run_sync()
+ codes_sh, codes_sz = l1_subscript_codes_manager.get_codes()
+ codes = set()
+ if codes_sh:
+ for code_byte in codes_sh:
+ codes.add(code_byte.decode())
+ for code_byte in codes_sz:
+ codes.add(code_byte.decode())
+
+ updated_codes = ZYLTGBUtil.get_today_updated_volume_codes()
+ codes = codes - set(updated_codes)
+
+ # 鑾峰彇鏈�杩戠殑浠锋牸
+ price_datas = history_k_data_util.JueJinApi.get_gp_current_info(codes, "symbol,price")
+ price_dict = {x['symbol'].split(".")[1]: x['price'] for x in price_datas}
+ for code in price_dict:
+ try:
+ zylt = kpl_api.getZYLTAmount(code)
+ ZYLTGBUtil.save_volume(code, int(zylt / price_dict[code]))
+ except:
+ pass
--
Gitblit v1.8.0