| | |
|---|
| | | import constant |
|---|
| | | # 引入掘金API |
|---|
| | | import utils.juejin_api |
|---|
| | | from log_module.log import logger_common |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_common, logger_target_codes |
|---|
| | | # from logging_config import get_logger |
|---|
| | | from utils import tool, hx_qc_value_util |
|---|
| | | |
|---|
| | |
|---|
| | | # 获取A股市场（包含沪深两市）的股票列表跳过停牌，跳过ST 上交所 SHSE.600000 深交所 SZSE.000000 target = ['SHSE.603839', 'SZSE.002855'] |
|---|
| | | self.all_stocks = utils.juejin_api.JueJinApi.get_target_codes() |
|---|
| | | # self.all_stocks = [{'sec_level': 1, 'symbol': 'SZSE.301633','pre_close': 78.72000122070312, 'is_suspended': 0, 'sec_name': '港迪技术', 'listed_date': datetime.datetime(2024, 11, 7, 0, 0,tzinfo=datetime.timezone(datetime.timedelta(seconds=28800))), 'sec_type': 1, 'sec_id': '301633'}] |
|---|
| | | |
|---|
| | | async_log_util.info(logger_target_codes, f"{ self.all_stocks}") |
|---|
| | | # self.all_stocks = self.all_stocks[:10] |
|---|
| | | # 缓存代码的名称 |
|---|
| | | self.code_name_dict = {x['symbol']: x['sec_name'] for x in self.all_stocks} |
|---|
| | |
|---|
| | | # stock.startswith('SHSE.60') or (stock.startswith('SZSE.00'))] |
|---|
| | | self.filtered_stocks = [stock['symbol'] for stock in self.all_stocks if |
|---|
| | | isinstance(stock.get('symbol'), str) and ( |
|---|
| | | stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith( |
|---|
| | | 'SZSE.00'))] |
|---|
| | | stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith( |
|---|
| | | 'SZSE.00'))] |
|---|
| | | # self.filtered_stocks = self.filtered_stocks[:10] |
|---|
| | | print(f"过滤后上证A股和深证A股数量filtered_stocks：{len(self.filtered_stocks)}") |
|---|
| | | # 声明一下需要拉取K线的列表 |
|---|
| | |
|---|
| | | limit_up_block_names = [] |
|---|
| | | # 初始化板块强度下的个股强度 |
|---|
| | | market_sift_plate_stock_dict = {} |
|---|
| | | # 精选流入板块 |
|---|
| | | market_sift_plates = [] |
|---|
| | | |
|---|
| | | # 初始化实时大盘行情市场情绪综合强度【完整】字典 |
|---|
| | | rise_and_fall_statistics_dirt = {} |
|---|
| | | # 初始化实时大盘行情情绪综合强度[分数] |
|---|
| | |
|---|
| | | |
|---|
| | | # 有意购买的股票名称列表 |
|---|
| | | willing_buy_list = [] |
|---|
| | | # 已成交股票详情列表 |
|---|
| | | purchased_stocks_details_list = [] |
|---|
| | | |
|---|
| | | logging.info(f"全局初始化数据 完成《《《 - {os.getpid()}") |
|---|
