增加测试/记录精选流入板块

admin

5 天以前 cea6eee0edb661e0215a90a61642bf31afb3e502

 strategy/data_cache.py

@@ -76,8 +76,8 @@
        #                         stock.startswith('SHSE.60') or (stock.startswith('SZSE.00'))]
        self.filtered_stocks = [stock['symbol'] for stock in self.all_stocks if
                                isinstance(stock.get('symbol'), str) and (
                                            stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
                                        'SZSE.00'))]
                                        stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
                                    'SZSE.00'))]
        # self.filtered_stocks =  self.filtered_stocks[:10]
        print(f"过滤后上证A股和深证A股数量filtered_stocks：{len(self.filtered_stocks)}")
        # 声明一下需要拉取K线的列表
@@ -156,6 +156,9 @@
limit_up_block_names = []
# 初始化板块强度下的个股强度
market_sift_plate_stock_dict = {}
# 精选流入板块
market_sift_plates = []

# 初始化实时大盘行情市场情绪综合强度【完整】字典
rise_and_fall_statistics_dirt = {}
# 初始化实时大盘行情情绪综合强度[分数]
@@ -273,7 +276,12 @@
# 最新成交价格
latest_deal_price_dict = {}

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")

# 大单成交数据: {"代码":[大单数据1,大单数据2,...]}
big_order_deal_dict = {}

# 有意购买的股票名称列表
willing_buy_list = []
# 已成交股票详情列表
purchased_stocks_details_list = []

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")