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

admin

5 天以前 cea6eee0edb661e0215a90a61642bf31afb3e502

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

 data_server.py

@@ -253,7 +253,7 @@
            response_data = json.dumps({"code": 0, "data": {}})
        elif url.path == "/get_market_sift_plate_stock_dict":
            # 获取开盘啦板块精选流入
            data = data_cache.market_sift_plate_stock_dict
            data = data_cache.market_sift_plates
            response_data = json.dumps({"code": 0, "data": data})

        self.send_response(200)

 main.py

@@ -107,11 +107,13 @@
                     daemon=True).start()

    # # 开盘啦的板块强度下的个股强度回调函数
    def get_market_sift_plate_its_stock_power_process(market_sift_plate_stock_dict):
    def get_market_sift_plate_its_stock_power_process(market_sift_plate_info):
        # print(f"回调成功===精选板块股票强度数据更新==={market_sift_plate_stock_dict}")
        # logger_kpl_jingxuan_in.info(f"{market_sift_plate_stock_dict}")
        market_sift_plate_stock_dict,  market_sift_plates = market_sift_plate_info[0], market_sift_plate_info[1]
        if market_sift_plate_stock_dict:
            data_cache.market_sift_plate_stock_dict = market_sift_plate_stock_dict
            data_cache.market_sift_plates = market_sift_plates

    # 板块强度下个股强度线程
    threading.Thread(target=plate_strength_analysis.get_market_sift_plate_its_stock_power_process,

 strategy/data_cache.py

@@ -156,6 +156,9 @@
limit_up_block_names = []
# 初始化板块强度下的个股强度
market_sift_plate_stock_dict = {}
# 精选流入板块
market_sift_plates = []

# 初始化实时大盘行情市场情绪综合强度【完整】字典
rise_and_fall_statistics_dirt = {}
# 初始化实时大盘行情情绪综合强度[分数]

 strategy/plate_strength_analysis.py

@@ -13,6 +13,10 @@

# 获取行情精选板块 强度排名
def get_market_sift_plate_its_stock_power():
    """

    :return: {板块:[代码信息]}, 精选流入板块
    """
    @dask.delayed
    def batch_get_plate_codes(fs):
        return fs
@@ -105,7 +109,7 @@
        # 只在盘中时间获取
        KPLMarketStockHeatLogManager().add_log(market_sift_plate['list'], log_datas)
    # 行情》精选板块》排名前20中》对应个股》符合条件的个股
    return market_sift_plate_stock_dict
    return market_sift_plate_stock_dict, market_sift_plate.get("list",[])


# 调用一下获取精选板块股票强度数据函数  【本模块内使用时调用】
@@ -124,7 +128,7 @@
                time_str = datetime.datetime.now().strftime("%H%M%S")
                if 92900 < int(time_str) < 95000:
                    # logger_kpl_jingxuan_in 打印的日志专用于开盘了数据的存储分析，不能轻易删除
                    logger_kpl_jingxuan_in.info(f"耗时：{time.time() - start_time}  数据：{its_stock_power}")
                    logger_kpl_jingxuan_in.info(f"耗时：{time.time() - start_time}  数据：{its_stock_power[0]}")
                callback(its_stock_power)
                # print(f"精选板块拉升个股更新===={its_stock_power}")
        except Exception as e: