From cf32945520de905d86f87c04cad426a7402d12d8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 十一月 2024 17:12:20 +0800
Subject: [PATCH] 删除原有的资金净流入统计方式
---
huaxin_client/l1_client.py | 42 +-----------------------------------------
1 files changed, 1 insertions(+), 41 deletions(-)
diff --git a/huaxin_client/l1_client.py b/huaxin_client/l1_client.py
index b9af1f0..0f2eb91 100644
--- a/huaxin_client/l1_client.py
+++ b/huaxin_client/l1_client.py
@@ -11,8 +11,6 @@
from huaxin_client import tool, constant
from log_module.log import logger_system, logger_local_huaxin_l1, logger_l2_codes_subscript, logger_debug
from third_data import custom_block_in_money_manager
-from third_data.custom_block_in_money_manager import BlockInMoneyRankManager, CodeInMoneyManager
-from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi
from utils import tool as out_tool
################B绫�##################
@@ -137,11 +135,6 @@
pMarketDataField.SecurityID, pMarketDataField.LastPrice, rate, pMarketDataField.Volume, time.time(),
pMarketDataField.BidPrice1, pMarketDataField.BidVolume1, pMarketDataField.BidPrice2,
pMarketDataField.BidVolume2, pMarketDataField.UpdateTime)
- try:
- custom_block_in_money_manager.CodeInMoneyManager.set_market_info(pMarketDataField.SecurityID, lastPrice,
- close_price, pMarketDataField.Turnover)
- except:
- pass
__latest_subscript_codes = set()
@@ -217,37 +210,13 @@
finally:
time.sleep(3)
-def __test_block_in_money():
- codes = BlockInMoneyRankManager().get_codes()
- logger_debug.info("鑾峰彇鍒版祴璇曞噣娴佸叆浠ｇ爜鏁伴噺锛歿}", len(codes))
- page_size = 200
- total_page = len(codes) // page_size + 1
- for i in range(0, total_page):
- temp_codes = codes[i * page_size: (i + 1) * page_size]
- print(temp_codes)
- # 鑾峰彇鏈�杩戠殑淇℃伅
- latest_infos = HistoryKDatasUtils.get_gp_latest_info(temp_codes, "sec_id,pre_close")
- pre_close_dict = {x["sec_id"]: x["pre_close"] for x in latest_infos}
-
- current_infos = JueJinApi.get_gp_current_info(temp_codes, "symbol,price,cum_amount")
- current_infos = {x["symbol"].split(".")[1]: (x["price"], x["cum_amount"]) for x in
- current_infos}
-
- for code in current_infos:
- if code not in pre_close_dict:
- continue
- CodeInMoneyManager.set_market_info(code, current_infos[code][0], pre_close_dict[code],
- current_infos[code][1])
-
-
-def run(queue_l1_w_strategy_r, queue_l1_r_strategy_w, queue_custom_block_in_money, fixed_codes=None):
+def run(queue_l1_w_strategy_r, queue_l1_r_strategy_w, fixed_codes=None):
"""
杩愯l1璁㈤槄浠诲姟
@param queue_l1_w_strategy_r: L1鏂瑰啓锛岀瓥鐣ユ柟璇�
@param queue_l1_r_strategy_w: L1鏂硅锛岀瓥鐣ユ柟鍐�
- @param queue_custom_block_in_money: 鏉垮潡娴佸叆娴佸嚭璁＄畻缁撴灉
@param fixed_codes: 鍥哄畾瑕佽繑鍥炴暟鎹殑浠ｇ爜
@return:
"""
@@ -306,19 +275,10 @@
threading.Thread(target=__run_subscript_task, args=(spi,), daemon=True).start()
- # 娴嬭瘯
- # __test_block_in_money()
-
# 绛夊緟绋嬪簭缁撴潫
while True:
# print("鏁伴噺", len(level1_data_dict))
try:
- # 璁＄畻娴佸叆娴佸嚭骞朵笂浼�
- custom_block_in_money_manager.BlockInMoneyRankManager().compute()
- val = (custom_block_in_money_manager.BlockInMoneyRankManager().get_in_list(), custom_block_in_money_manager.BlockInMoneyRankManager().get_out_list())
- val = json.dumps(val)
- queue_custom_block_in_money.put_nowait(val)
-
if len(level1_data_dict) < 1:
continue
# 鏍规嵁娑ㄥ箙鎺掑簭
--
Gitblit v1.8.0