From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
code_attribute/first_target_code_data_processor.py | 44 +++++++++++++++++++++++++-------------------
1 files changed, 25 insertions(+), 19 deletions(-)
diff --git a/code_attribute/first_target_code_data_processor.py b/code_attribute/first_target_code_data_processor.py
index ec08354..eec5b75 100644
--- a/code_attribute/first_target_code_data_processor.py
+++ b/code_attribute/first_target_code_data_processor.py
@@ -109,25 +109,31 @@
code) is None:
need_get_volumn = True
if need_get_volumn:
- volumes_data = inited_data.get_volumns_by_code(code, 150)
- volumes = inited_data.parse_max_volume(volumes_data[:90],
- code_nature_analyse.is_new_top(
- gpcode_manager.get_limit_up_price(code),
- volumes_data[:90]))
- logger_first_code_record.info("{} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿}", code, volumes)
- code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])
- # 鍒ゆ柇K绾垮舰鎬�
- # is_has_k_format, msg = code_nature_analyse.is_has_k_format(
- # gpcode_manager.get_limit_up_price(code), volumes_data)
- # if not is_has_k_format:
- # logger_first_code_record.info("{}棣栨澘K绾垮舰鎬佷笉濂�,{}", code, msg)
- # # 鑲℃�т笉濂斤紝灏变笉瑕佸姞鍏�
- # bad_codes.add(code)
- # # 鍔犲叆绂佹浜ゆ槗浠ｇ爜
- # l2_trade_util.forbidden_trade(code)
- code_nature_analyse.set_record_datas(code,
- gpcode_manager.get_limit_up_price(code),
- volumes_data)
+ limit_up_price = gpcode_manager.get_limit_up_price(code)
+ if limit_up_price is None:
+ continue
+ try:
+ volumes_data = inited_data.get_volumns_by_code(code, 150)
+ volumes = inited_data.parse_max_volume(volumes_data[:90],
+ code_nature_analyse.is_new_top(
+ limit_up_price,
+ volumes_data[:90]))
+ logger_first_code_record.info("{} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿}", code, volumes)
+ code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])
+ # 鍒ゆ柇K绾垮舰鎬�
+ # is_has_k_format, msg = code_nature_analyse.is_has_k_format(
+ # gpcode_manager.get_limit_up_price(code), volumes_data)
+ # if not is_has_k_format:
+ # logger_first_code_record.info("{}棣栨澘K绾垮舰鎬佷笉濂�,{}", code, msg)
+ # # 鑲℃�т笉濂斤紝灏变笉瑕佸姞鍏�
+ # bad_codes.add(code)
+ # # 鍔犲叆绂佹浜ゆ槗浠ｇ爜
+ # l2_trade_util.forbidden_trade(code)
+ code_nature_analyse.set_record_datas(code,
+ gpcode_manager.get_limit_up_price(code),
+ volumes_data)
+ except Exception as e:
+ logger_first_code_record.error(f"{code}:{str(e)}")
gpcode_manager.FirstCodeManager.add_record(codes)
# 鍒濆鍖栨澘鍧椾俊鎭�
for code in codes:
--
Gitblit v1.8.0