| | |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_Overall_market_strength_score |
|---|
| | | from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_Overall_market_strength_score, \ |
|---|
| | | logger_stock_of_markets_plate |
|---|
| | | # import requests |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy import basic_methods |
|---|
| | |
|---|
| | | |
|---|
| | | @dask.delayed |
|---|
| | | def request_plate_codes(i): |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | plate_name = i[1] |
|---|
| | | # 尝试过滤掉无意义的概念板块(plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革','超跌', '壳资源', '股权转让', '送转填权']) and '增长' in plate_name |
|---|
| | | if (plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革', '超跌', |
|---|
| | |
|---|
| | | # print(f"{i[1]} 强度:{i[2]}") |
|---|
| | | # 通过板块ID获取其下面的个股强度列表 |
|---|
| | | # print(f"======={i[0]}=======") |
|---|
| | | |
|---|
| | | its_stock = json.loads(getCodesByPlate(i[0])) |
|---|
| | | |
|---|
| | | # print(f"its_stock['list'] === {its_stock['list']}") |
|---|
| | | # print(f"its_stock['list'][0] === {its_stock['list'][0]}") |
|---|
| | | logger.info(f"its_stock['list'] ===》》 {its_stock['list']}") |
|---|
| | | # logger.info(f"its_stock['list'][0] === {its_stock['list'][0]}") |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}") |
|---|
| | | its_stock_list_info = its_stock['list'] |
|---|
| | | logger.info(f"its_stock_list_info==={its_stock_list_info}") |
|---|
| | | # 将板块强度下面对应的个股列表打印到日志中 |
|---|
| | |
|---|
| | | # f"41未知1值：{i[41]}，第三季度机构持仓【str数据勿用运算符】：{i[42]}万，？年预测净利润：{i[43]}，上年预测净利润：{i[44]}，年内预测净利润：{i[45]}" |
|---|
| | | # ) |
|---|
| | | |
|---|
| | | # 获取该概念板块的的子版块 |
|---|
| | | # its_son_plate = json.loads(getSonPlate(i[0])) |
|---|
| | | # logger.info(f"its_son_plate=={its_son_plate['List']}") |
|---|
| | | # if its_son_plate['List'][0][2] > 0: |
|---|
| | | # print(f"its_son_plate=={its_son_plate['List'][0]}") |
|---|
| | | # for son in its_son_plate['List']: |
|---|
| | | # if son[2] > 0: |
|---|
| | | # print(f"son===={son}") |
|---|
| | | # 初始化股票强度列表 |
|---|
| | | stock_power_list = [] |
|---|
| | | for s in its_stock['list']: |
|---|
| | |
|---|
| | | # 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']: |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | dask_result.compute() |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | # if 'list' in market_sift_plate: |
|---|
| | | # ds = [] |
|---|
| | | # for d in market_sift_plate['list']: |
|---|
| | | # ds.append(request_plate_codes(d)) |
|---|
| | | # dask_result = batch_get_plate_codes(ds) |
|---|
| | | # dask_result.compute() |
|---|
| | | # now_time = tool.get_now_time_str() |
|---|
| | | # if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | # logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | | |
|---|
| | | |
|---|
