| | |
|---|
| | | import dask |
|---|
| | | import constant |
|---|
| | | |
|---|
| | | from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug |
|---|
| | | 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 utils import tool, hx_qc_value_util |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | data = (kpl_api.getMarketJingXuanRealRankingInfo()) |
|---|
| | | market_sift_plate = json.loads(data) |
|---|
| | | # logger_kpl_jingxuan_in 打印的日志专用于开盘了数据的存储分析，不能轻易删除 |
|---|
| | | # print(f"market_sift_plate 数 ======{len(market_sift_plate['list'])}") |
|---|
| | | # 行情》精选板块》排名前20中》对应个股》符合条件的个股 |
|---|
| | | # logger.info(f"market_sift_plate['list']======{market_sift_plate['list']}") |
|---|
| | | |
|---|
| | | # 精选板块【前20】 market_sift_plate['list'] ====== |
|---|
| | | logger_kpl_market_sift_plate.info(f"{market_sift_plate['list']}") |
|---|
| | | # market_sift_plate['list'][0] = ['801062', '军工', 3520, -0.49, 0.666, 139133934669, 383864272, 9077352839, -8693488567, 1.183, 6129448037490,-0.12, 168245858, 7088854452019, -290614763, 50.2408, 30.3672, 3520, 0] |
|---|
| | | # 行情精选板块列表 前20 中的 第一个板块列表数据 = 【代码，板块名称，强度，涨幅？，0.666？，成交额？，现额？，主买，主卖，1.183？，流通值？，-0.12？，300W大单净额？，总市值？，上季度机构增仓，今年平均PE，次年平均PE，强度，未知0值】 |
|---|
| | | # logger.info(f"market_sift_plate['list'][0] ======{market_sift_plate['list'][0]}") |
|---|
| | | # 初始化精选板块对应个股字典 |
|---|
| | | market_sift_plate_stock_dict = {} |
|---|
| | | if 'list' in market_sift_plate: |
|---|
| | | ds = [] |
|---|
| | | for d in market_sift_plate['list']: |
|---|
| | | # todo 获取板块名称和板块代码 主要是板块的强度和主力净额这些 |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | compute_results = dask_result.compute() |
|---|
| | |
|---|
| | | # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | kpl_api.KPLStockOfMarketsPlateLogManager().add_log(market_sift_plate['list'], log_datas) |
|---|
| | | |
|---|
| | | # 行情》精选板块》排名前20中》对应个股》符合条件的个股 |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | its_stock_power = get_market_sift_plate_its_stock_power() |
|---|
| | | 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}") |
|---|
| | | callback(its_stock_power) |
|---|
| | | # print(f"精选板块拉升个股更新===={its_stock_power}") |
|---|
