| | |
|---|
| | | |
|---|
| | | from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug, logger_kpl_market_sift_plate |
|---|
| | | from strategy import kpl_api, data_cache, basic_methods |
|---|
| | | from strategy.kpl_data_manager import KPLMarketStockHeatLogManager |
|---|
| | | from utils import tool, hx_qc_value_util |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取行情精选板块 强度排名 |
|---|
| | | def get_market_sift_plate_its_stock_power(): |
|---|
| | | """ |
|---|
| | | |
|---|
| | | :return: {板块:[代码信息]}, 精选流入板块 |
|---|
| | | """ |
|---|
| | | @dask.delayed |
|---|
| | | def batch_get_plate_codes(fs): |
|---|
| | | return fs |
|---|
| | |
|---|
| | | |
|---|
| | | # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | kpl_api.KPLStockOfMarketsPlateLogManager().add_log(market_sift_plate['list'], log_datas) |
|---|
| | | 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",[]) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 调用一下获取精选板块股票强度数据函数 【本模块内使用时调用】 |
|---|
| | |
|---|
| | | 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: |
|---|
