项目简介这个项目实现了一条完整的 A 股概念板块热度自动化工作流每天北京时间 11:00 自动抓取东方财富“AI智能体”板块代码 BK0809成分股按热度综合分排序取 Top10为每只股票生成 49 字以内的摘要和当日关键新闻链接并把榜单同步推送到企业微信、飞书、钉钉、Telegram 或邮件。整个过程不需要人工打开行情软件也不需要手动复制粘贴。## 整体流程text抓取板块成分股↓并发抓取每只股票的新闻提及数↓板块内百分位归一化↓按权重计算热度综合分↓取 Top10 并生成 49 字以内摘要↓生成 Markdown / 纯文本报告↓推送到已启用渠道对应到代码模块| 模块 | 职责 || --- | --- || core/eastmoney.py | 东方财富概念板块、行情资金流、新闻搜索抓取 || core/scoring.py | 热度综合分计算与摘要生成 || core/report.py | Markdown/纯文本报告生成与保存 || core/push.py | 企业微信 / 飞书 / 钉钉 / Telegram / 邮件推送 || core/scheduler.py | 每日北京时间定时调度 || core/workflow.py | 工作流编排 |## 热度综合分怎么算评分不是简单看涨跌幅而是在板块内部对每项指标做百分位归一化再按权重加权text综合分 成交额 40% 涨跌幅 30% 资金净流入 20% 新闻提及 10%百分位的意思是某只股票成交额在板块内越靠前得分越高。这样不同市值、不同成交规模的股票才有可比性。核心代码def compute_scores(stocks, weights): validate_weights(weights) total_weight sum(float(weights[key]) for key in METRICS) ranked [dict(stock) for stock in stocks] for metric in METRICS: value_key METRIC_VALUE_KEYS[metric] values [_num(stock.get(value_key)) for stock in ranked] ranks _percentile_ranks(values) for stock, rank in zip(ranked, ranks): stock[f{metric}_rank] round(rank, 2) for stock in ranked: score sum( float(weights[metric]) * float(stock[f{metric}_rank]) for metric in METRICS ) / total_weight stock[score] round(score, 2) ranked.sort(keylambda stock: (-stock[score], -stock[turnover])) return ranked## 49 字以内摘要推送消息不能太长所以摘要生成采用“先长后短逐级裁剪”的策略先尝试包含完整信息的版本如果超过 49 字就依次去掉成交额、新闻数等次要信息。def make_summary(stock, rank, board_nameAI智能体, max_len49): candidates [ f{name}今日成交{turnover}{change}主力净流入{inflow} f新闻{news}篇{board_name}概念热度第{rank}名。, f{name}成交{turnover}{change}净流入{inflow} f新闻{news}篇{board_name}热度第{rank}名。, f{name}成交{turnover}{change}净流入{inflow} f{board_name}热度第{rank}名。, f{name}{change}净流入{inflow}热度第{rank}名。, ] for candidate in candidates: if len(candidate) max_len: return candidate return candidates[-1][:max_len]## 多端推送项目内置 5 类推送渠道- 企业微信机器人 Webhook 地址- 飞书自定义机器人 Webhook 地址- 钉钉自定义机器人 Webhook 地址可选加签- TelegramBot Token Chat ID- 邮件SMTP 服务器、端口、账号、授权码、发件/收件地址配置保存到 config.json不带敏感信息的模板是 config.example.json。## 定时任务有桌面窗口时直接点击“启动定时”默认每天北京时间 11:00 运行。窗口关闭后定时会停止如果希望关闭窗口也运行可以用 Windows 任务计划程序batpy -3 path\to\test2\core\workflow_cli.pyworkflow_cli.py 是纯命令行入口读取 config.json 执行一次完整流程并打印结果。## 数据源说明- 板块东方财富概念板块 BK0809AI智能体可在设置中改成其他板块代码。- 行情东方财富 push2.eastmoney.com 成分股接口包含成交额、涨跌幅、主力净流入。- 新闻东方财富资讯搜索接口标题、日期、原文链接均来自搜索结果。行情数据以交易所及东方财富为准本项目输出仅作自动化研究演示不构成投资建议。## 可扩展方向1. 把板块代码改成任意概念板块例如机器人、算力、低空经济。2. 把权重改成从配置读取实现不同策略的热度榜。3. 增加历史榜单落库做连续 N 日的热度趋势。4. 推送渠道继续扩展例如企业微信群机器人多群、飞书卡片消息。
项目简介这个项目实现了一条完整的 A 股概念板块热度自动化工作流每天北京时间 11:00 自动抓取东方财富“AI智能体”板块代码 BK0809成分股按热度综合分排序取 Top10为每只股票生成 49 字以内的摘要和当日关键新闻链接并把榜单同步推送到企业微信、飞书、钉钉、Telegram 或邮件。整个过程不需要人工打开行情软件也不需要手动复制粘贴。## 整体流程text抓取板块成分股↓并发抓取每只股票的新闻提及数↓板块内百分位归一化↓按权重计算热度综合分↓取 Top10 并生成 49 字以内摘要↓生成 Markdown / 纯文本报告↓推送到已启用渠道对应到代码模块| 模块 | 职责 || --- | --- || core/eastmoney.py | 东方财富概念板块、行情资金流、新闻搜索抓取 || core/scoring.py | 热度综合分计算与摘要生成 || core/report.py | Markdown/纯文本报告生成与保存 || core/push.py | 企业微信 / 飞书 / 钉钉 / Telegram / 邮件推送 || core/scheduler.py | 每日北京时间定时调度 || core/workflow.py | 工作流编排 |## 热度综合分怎么算评分不是简单看涨跌幅而是在板块内部对每项指标做百分位归一化再按权重加权text综合分 成交额 40% 涨跌幅 30% 资金净流入 20% 新闻提及 10%百分位的意思是某只股票成交额在板块内越靠前得分越高。这样不同市值、不同成交规模的股票才有可比性。核心代码def compute_scores(stocks, weights): validate_weights(weights) total_weight sum(float(weights[key]) for key in METRICS) ranked [dict(stock) for stock in stocks] for metric in METRICS: value_key METRIC_VALUE_KEYS[metric] values [_num(stock.get(value_key)) for stock in ranked] ranks _percentile_ranks(values) for stock, rank in zip(ranked, ranks): stock[f{metric}_rank] round(rank, 2) for stock in ranked: score sum( float(weights[metric]) * float(stock[f{metric}_rank]) for metric in METRICS ) / total_weight stock[score] round(score, 2) ranked.sort(keylambda stock: (-stock[score], -stock[turnover])) return ranked## 49 字以内摘要推送消息不能太长所以摘要生成采用“先长后短逐级裁剪”的策略先尝试包含完整信息的版本如果超过 49 字就依次去掉成交额、新闻数等次要信息。def make_summary(stock, rank, board_nameAI智能体, max_len49): candidates [ f{name}今日成交{turnover}{change}主力净流入{inflow} f新闻{news}篇{board_name}概念热度第{rank}名。, f{name}成交{turnover}{change}净流入{inflow} f新闻{news}篇{board_name}热度第{rank}名。, f{name}成交{turnover}{change}净流入{inflow} f{board_name}热度第{rank}名。, f{name}{change}净流入{inflow}热度第{rank}名。, ] for candidate in candidates: if len(candidate) max_len: return candidate return candidates[-1][:max_len]## 多端推送项目内置 5 类推送渠道- 企业微信机器人 Webhook 地址- 飞书自定义机器人 Webhook 地址- 钉钉自定义机器人 Webhook 地址可选加签- TelegramBot Token Chat ID- 邮件SMTP 服务器、端口、账号、授权码、发件/收件地址配置保存到 config.json不带敏感信息的模板是 config.example.json。## 定时任务有桌面窗口时直接点击“启动定时”默认每天北京时间 11:00 运行。窗口关闭后定时会停止如果希望关闭窗口也运行可以用 Windows 任务计划程序batpy -3 path\to\test2\core\workflow_cli.pyworkflow_cli.py 是纯命令行入口读取 config.json 执行一次完整流程并打印结果。## 数据源说明- 板块东方财富概念板块 BK0809AI智能体可在设置中改成其他板块代码。- 行情东方财富 push2.eastmoney.com 成分股接口包含成交额、涨跌幅、主力净流入。- 新闻东方财富资讯搜索接口标题、日期、原文链接均来自搜索结果。行情数据以交易所及东方财富为准本项目输出仅作自动化研究演示不构成投资建议。## 可扩展方向1. 把板块代码改成任意概念板块例如机器人、算力、低空经济。2. 把权重改成从配置读取实现不同策略的热度榜。3. 增加历史榜单落库做连续 N 日的热度趋势。4. 推送渠道继续扩展例如企业微信群机器人多群、飞书卡片消息。
