| | |
|---|
| | | # 尝试过滤掉无意义的概念板块(plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革','超跌', '壳资源', '股权转让', '送转填权']) and '增长' in plate_name |
|---|
| | | if (plate_name not in ['科创板', '北交所', '次新股', '无', 'ST板块', 'ST摘帽', '并购重组', '国企改革', '超跌', |
|---|
| | | '壳资源', '股权转让', '送转填权']) or ('增长' in plate_name): |
|---|
| | | |
|---|
| | | # print(f"{i[1]} 强度:{i[2]}") |
|---|
| | | # 通过板块ID获取其下面的个股强度列表 |
|---|
| | | # print(f"======={i[0]}=======") |
|---|
| | | |
|---|
| | | its_stock = json.loads(getCodesByPlate(i[0])) |
|---|
| | | |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}") |
|---|
| | | logger.info(f"its_stock['list'] ===》》 {its_stock['list']}") |
|---|
| | | log_data = {plate_name: its_stock['list']} |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{log_data}") |
|---|
| | | |
|---|
| | | # logger.info(f"its_stock['list'] ===》》 {log_data}") |
|---|
| | | # logger.info(f"its_stock['list'][0] === {its_stock['list'][0]}") |
|---|
| | | |
|---|
| | | # its_stock_list_info = its_stock['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}") |
|---|
| | | 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 |
|---|
| | | |
|---|
| | | |
|---|
