| | |
|---|
| | | |
|---|
| | | @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摘帽', '并购重组', '国企改革', '超跌', |
|---|
| | |
|---|
| | | |
|---|
| | | 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: |
|---|
| | | print("====logger_stock_of_markets_plate====") |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}") |
|---|
| | | 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}") |
|---|
| | | |
|---|
| | | # its_stock_list_info = its_stock['list'] |
|---|
| | | # logger.info(f"its_stock_list_info==={its_stock_list_info}") |
|---|
| | | # 将板块强度下面对应的个股列表打印到日志中 |
|---|
| | | # for i in its_stock_list_info: |
|---|
| | | # if i[0] != 1: |
|---|
