{escaped_source} ({len(source_data['titles'])} 条)
- "
@@ -1433,7 +1560,6 @@ class ReportGenerator:
formatted_title = ReportGenerator._format_title_html(
title_data_copy
)
- # 移除来源标签
if "] " in formatted_title:
formatted_title = formatted_title.split("] ", 1)[1]
html += f"
- {formatted_title} " @@ -1452,7 +1578,7 @@ class ReportGenerator: @staticmethod def _format_title_feishu(title_data: Dict, show_source: bool = True) -> str: """格式化飞书标题显示""" - rank_display = StatisticsCalculator._format_rank_for_feishu( + rank_display = StatisticsCalculator.format_rank_for_feishu( title_data["ranks"], title_data["rank_threshold"] ) @@ -1468,7 +1594,7 @@ class ReportGenerator: title_prefix = "🆕 " if title_data["is_new"] else "" if show_source: - result = f"[{title_data['source_alias']}] {title_prefix}{formatted_title}" + result = f"[{title_data['source_name']}] {title_prefix}{formatted_title}" else: result = f"{title_prefix}{formatted_title}" @@ -1484,7 +1610,7 @@ class ReportGenerator: @staticmethod def _format_title_dingtalk(title_data: Dict, show_source: bool = True) -> str: """格式化钉钉标题显示""" - rank_display = StatisticsCalculator._format_rank_for_dingtalk( + rank_display = StatisticsCalculator.format_rank_for_dingtalk( title_data["ranks"], title_data["rank_threshold"] ) @@ -1500,7 +1626,7 @@ class ReportGenerator: title_prefix = "🆕 " if title_data["is_new"] else "" if show_source: - result = f"[{title_data['source_alias']}] {title_prefix}{formatted_title}" + result = f"[{title_data['source_name']}] {title_prefix}{formatted_title}" else: result = f"{title_prefix}{formatted_title}" @@ -1516,7 +1642,7 @@ class ReportGenerator: @staticmethod def _format_title_wework(title_data: Dict, show_source: bool = True) -> str: """格式化企业微信标题显示""" - rank_display = StatisticsCalculator._format_rank_for_wework( + rank_display = StatisticsCalculator.format_rank_for_wework( title_data["ranks"], title_data["rank_threshold"] ) @@ -1532,7 +1658,7 @@ class ReportGenerator: title_prefix = "🆕 " if title_data["is_new"] else "" if show_source: - result = f"[{title_data['source_alias']}] {title_prefix}{formatted_title}" + result = f"[{title_data['source_name']}] {title_prefix}{formatted_title}" else: result = f"{title_prefix}{formatted_title}" @@ -1548,7 +1674,7 @@ class ReportGenerator: @staticmethod def _format_title_telegram(title_data: Dict, show_source: bool = True) -> str: """格式化Telegram标题显示""" - rank_display = StatisticsCalculator._format_rank_for_telegram( + rank_display = StatisticsCalculator.format_rank_for_telegram( title_data["ranks"], title_data["rank_threshold"] ) @@ -1564,7 +1690,7 @@ class ReportGenerator: title_prefix = "🆕 " if title_data["is_new"] else "" if show_source: - result = f"[{title_data['source_alias']}] {title_prefix}{formatted_title}" + result = f"[{title_data['source_name']}] {title_prefix}{formatted_title}" else: result = f"{title_prefix}{formatted_title}" @@ -1579,14 +1705,13 @@ class ReportGenerator: @staticmethod def _render_feishu_content( - report_data: Dict, update_info: Optional[Dict] = None + report_data: Dict, update_info: Optional[Dict] = None, mode: str = "daily" ) -> str: """渲染飞书内容""" text_content = "" - # 渲染热点词汇统计 if report_data["stats"]: - text_content += "📊 **热点词汇统计**\n\n" + text_content += f"📊 **热点词汇统计**\n\n" total_count = len(report_data["stats"]) @@ -1616,9 +1741,14 @@ class ReportGenerator: text_content += f"\n{CONFIG['FEISHU_MESSAGE_SEPARATOR']}\n\n" if not text_content: - text_content = "📭 暂无匹配的热点词汇\n\n" + if mode == "incremental": + mode_text = "增量模式下暂无新增匹配的热点词汇" + elif mode == "current": + mode_text = "当前榜单模式下暂无匹配的热点词汇" + else: + mode_text = "暂无匹配的热点词汇" + text_content = f"📭 {mode_text}\n\n" - # 渲染新增新闻部分 if report_data["new_titles"]: if text_content and "暂无匹配" not in text_content: text_content += f"\n{CONFIG['FEISHU_MESSAGE_SEPARATOR']}\n\n" @@ -1628,7 +1758,7 @@ class ReportGenerator: ) for source_data in report_data["new_titles"]: - text_content += f"**{source_data['source_alias']}** ({len(source_data['titles'])} 条):\n" + text_content += f"**{source_data['source_name']}** ({len(source_data['titles'])} 条):\n" for j, title_data in enumerate(source_data["titles"], 1): title_data_copy = title_data.copy() @@ -1640,7 +1770,6 @@ class ReportGenerator: text_content += "\n" - # 渲染失败平台 if report_data["failed_ids"]: if text_content and "暂无匹配" not in text_content: text_content += f"\n{CONFIG['FEISHU_MESSAGE_SEPARATOR']}\n\n" @@ -1649,11 +1778,9 @@ class ReportGenerator: for i, id_value in enumerate(report_data["failed_ids"], 1): text_content += f" • {id_value}\n" - # 添加时间戳 now = TimeHelper.get_beijing_time() text_content += f"\n\n更新时间：{now.strftime('%Y-%m-%d %H:%M:%S')}" - # 版本更新提示 if update_info: text_content += f"\nTrendRadar 发现新版本 {update_info['remote_version']}，当前 {update_info['current_version']}" @@ -1661,27 +1788,24 @@ class ReportGenerator: @staticmethod def _render_dingtalk_content( - report_data: Dict, update_info: Optional[Dict] = None + report_data: Dict, update_info: Optional[Dict] = None, mode: str = "daily" ) -> str: """渲染钉钉内容""" text_content = "" - # 计算总标题数 total_titles = sum( len(stat["titles"]) for stat in report_data["stats"] if stat["count"] > 0 ) now = TimeHelper.get_beijing_time() - # 顶部统计信息 text_content += f"**总新闻数：** {total_titles}\n\n" text_content += f"**时间：** {now.strftime('%Y-%m-%d %H:%M:%S')}\n\n" text_content += f"**类型：** 热点分析报告\n\n" text_content += "---\n\n" - # 渲染热点词汇统计 if report_data["stats"]: - text_content += "📊 **热点词汇统计**\n\n" + text_content += f"📊 **热点词汇统计**\n\n" total_count = len(report_data["stats"]) @@ -1715,9 +1839,14 @@ class ReportGenerator: text_content += f"\n---\n\n" if not report_data["stats"]: - text_content += "📭 暂无匹配的热点词汇\n\n" + if mode == "incremental": + mode_text = "增量模式下暂无新增匹配的热点词汇" + elif mode == "current": + mode_text = "当前榜单模式下暂无匹配的热点词汇" + else: + mode_text = "暂无匹配的热点词汇" + text_content += f"📭 {mode_text}\n\n" - # 渲染新增新闻部分 if report_data["new_titles"]: if text_content and "暂无匹配" not in text_content: text_content += f"\n---\n\n" @@ -1727,7 +1856,7 @@ class ReportGenerator: ) for source_data in report_data["new_titles"]: - text_content += f"**{source_data['source_alias']}** ({len(source_data['titles'])} 条):\n\n" + text_content += f"**{source_data['source_name']}** ({len(source_data['titles'])} 条):\n\n" for j, title_data in enumerate(source_data["titles"], 1): title_data_copy = title_data.copy() @@ -1739,7 +1868,6 @@ class ReportGenerator: text_content += "\n" - # 渲染失败平台 if report_data["failed_ids"]: if text_content and "暂无匹配" not in text_content: text_content += f"\n---\n\n" @@ -1748,10 +1876,8 @@ class ReportGenerator: for i, id_value in enumerate(report_data["failed_ids"], 1): text_content += f" • **{id_value}**\n" - # 添加时间戳 text_content += f"\n\n> 更新时间：{now.strftime('%Y-%m-%d %H:%M:%S')}" - # 版本更新提示 if update_info: text_content += f"\n> TrendRadar 发现新版本 **{update_info['remote_version']}**，当前 **{update_info['current_version']}**" @@ -1763,11 +1889,11 @@ class ReportGenerator: format_type: str, update_info: Optional[Dict] = None, max_bytes: int = CONFIG["MESSAGE_BATCH_SIZE"], + mode: str = "daily", ) -> List[str]: """分批处理消息内容，确保词组标题+至少第一条新闻的完整性""" batches = [] - # 基础信息构建 total_titles = sum( len(stat["titles"]) for stat in report_data["stats"] if stat["count"] > 0 ) @@ -1792,20 +1918,25 @@ class ReportGenerator: stats_header = "" if report_data["stats"]: if format_type == "wework": - stats_header = "📊 **热点词汇统计**\n\n" + stats_header = f"📊 **热点词汇统计**\n\n" elif format_type == "telegram": - stats_header = "📊 热点词汇统计\n\n" + stats_header = f"📊 热点词汇统计\n\n" current_batch = base_header current_batch_has_content = False - # 空内容处理 if ( not report_data["stats"] and not report_data["new_titles"] and not report_data["failed_ids"] ): - simple_content = "📭 暂无匹配的热点词汇\n\n" + if mode == "incremental": + mode_text = "增量模式下暂无新增匹配的热点词汇" + elif mode == "current": + mode_text = "当前榜单模式下暂无匹配的热点词汇" + else: + mode_text = "暂无匹配的热点词汇" + simple_content = f"📭 {mode_text}\n\n" final_content = base_header + simple_content + base_footer batches.append(final_content) return batches @@ -1970,9 +2101,9 @@ class ReportGenerator: for source_data in report_data["new_titles"]: source_header = "" if format_type == "wework": - source_header = f"**{source_data['source_alias']}** ({len(source_data['titles'])} 条):\n\n" + source_header = f"**{source_data['source_name']}** ({len(source_data['titles'])} 条):\n\n" elif format_type == "telegram": - source_header = f"{source_data['source_alias']} ({len(source_data['titles'])} 条):\n\n" + source_header = f"{source_data['source_name']} ({len(source_data['titles'])} 条):\n\n" # 构建第一条新增新闻 first_news_line = "" @@ -2049,7 +2180,6 @@ class ReportGenerator: current_batch += "\n" - # 处理失败平台 if report_data["failed_ids"]: failed_header = "" if format_type == "wework": @@ -2095,55 +2225,62 @@ class ReportGenerator: def send_to_webhooks( stats: List[Dict], failed_ids: Optional[List] = None, - report_type: str = "单次爬取", + report_type: str = "当日汇总", new_titles: Optional[Dict] = None, - id_to_alias: Optional[Dict] = None, + id_to_name: Optional[Dict] = None, update_info: Optional[Dict] = None, proxy_url: Optional[str] = None, - hide_new_section: bool = False, + mode: str = "daily", ) -> Dict[str, bool]: """发送数据到多个webhook平台""" results = {} - # 数据处理层 report_data = ReportGenerator._prepare_report_data( - stats, failed_ids, new_titles, id_to_alias, hide_new_section + stats, failed_ids, new_titles, id_to_name, mode ) - # 获取环境变量中的webhook配置 - feishu_url = os.environ.get("FEISHU_WEBHOOK_URL", CONFIG["FEISHU_WEBHOOK_URL"]) - dingtalk_url = os.environ.get( - "DINGTALK_WEBHOOK_URL", CONFIG["DINGTALK_WEBHOOK_URL"] - ) - wework_url = os.environ.get("WEWORK_WEBHOOK_URL", CONFIG["WEWORK_WEBHOOK_URL"]) - telegram_token = os.environ.get( - "TELEGRAM_BOT_TOKEN", CONFIG["TELEGRAM_BOT_TOKEN"] - ) - telegram_chat_id = os.environ.get( - "TELEGRAM_CHAT_ID", CONFIG["TELEGRAM_CHAT_ID"] - ) + feishu_url = CONFIG["FEISHU_WEBHOOK_URL"] + dingtalk_url = CONFIG["DINGTALK_WEBHOOK_URL"] + wework_url = CONFIG["WEWORK_WEBHOOK_URL"] + telegram_token = CONFIG["TELEGRAM_BOT_TOKEN"] + telegram_chat_id = CONFIG["TELEGRAM_CHAT_ID"] update_info_to_send = update_info if CONFIG["SHOW_VERSION_UPDATE"] else None # 发送到飞书 if feishu_url: results["feishu"] = ReportGenerator._send_to_feishu( - feishu_url, report_data, report_type, update_info_to_send, proxy_url + feishu_url, + report_data, + report_type, + update_info_to_send, + proxy_url, + mode, ) # 发送到钉钉 if dingtalk_url: results["dingtalk"] = ReportGenerator._send_to_dingtalk( - dingtalk_url, report_data, report_type, update_info_to_send, proxy_url + dingtalk_url, + report_data, + report_type, + update_info_to_send, + proxy_url, + mode, ) # 发送到企业微信 if wework_url: results["wework"] = ReportGenerator._send_to_wework( - wework_url, report_data, report_type, update_info_to_send, proxy_url + wework_url, + report_data, + report_type, + update_info_to_send, + proxy_url, + mode, ) - # 发送到Telegram + # 发送到 Telegram if telegram_token and telegram_chat_id: results["telegram"] = ReportGenerator._send_to_telegram( telegram_token, @@ -2152,6 +2289,7 @@ class ReportGenerator: report_type, update_info_to_send, proxy_url, + mode, ) if not results: @@ -2166,11 +2304,14 @@ class ReportGenerator: report_type: str, update_info: Optional[Dict] = None, proxy_url: Optional[str] = None, + mode: str = "daily", ) -> bool: """发送到飞书""" headers = {"Content-Type": "application/json"} - text_content = ReportGenerator._render_feishu_content(report_data, update_info) + text_content = ReportGenerator._render_feishu_content( + report_data, update_info, mode + ) total_titles = sum( len(stat["titles"]) for stat in report_data["stats"] if stat["count"] > 0 ) @@ -2213,12 +2354,13 @@ class ReportGenerator: report_type: str, update_info: Optional[Dict] = None, proxy_url: Optional[str] = None, + mode: str = "daily", ) -> bool: """发送到钉钉""" headers = {"Content-Type": "application/json"} text_content = ReportGenerator._render_dingtalk_content( - report_data, update_info + report_data, update_info, mode ) payload = { @@ -2263,6 +2405,7 @@ class ReportGenerator: report_type: str, update_info: Optional[Dict] = None, proxy_url: Optional[str] = None, + mode: str = "daily", ) -> bool: """发送到企业微信（支持分批发送）""" headers = {"Content-Type": "application/json"} @@ -2272,7 +2415,7 @@ class ReportGenerator: # 获取分批内容 batches = ReportGenerator._split_content_into_batches( - report_data, "wework", update_info + report_data, "wework", update_info, mode=mode ) print(f"企业微信消息分为 {len(batches)} 批次发送 [{report_type}]") @@ -2335,6 +2478,7 @@ class ReportGenerator: report_type: str, update_info: Optional[Dict] = None, proxy_url: Optional[str] = None, + mode: str = "daily", ) -> bool: """发送到Telegram（支持分批发送）""" headers = {"Content-Type": "application/json"} @@ -2346,7 +2490,7 @@ class ReportGenerator: # 获取分批内容 batches = ReportGenerator._split_content_into_batches( - report_data, "telegram", update_info + report_data, "telegram", update_info, mode=mode ) print(f"Telegram消息分为 {len(batches)} 批次发送 [{report_type}]") @@ -2403,21 +2547,98 @@ class ReportGenerator: return True +@dataclass +class ModeStrategy: + """模式策略配置""" + + mode_name: str + description: str + realtime_report_type: str + summary_report_type: str + should_send_realtime: bool + should_generate_summary: bool + summary_mode: str + + def get_log_messages(self) -> Dict[str, str]: + """返回该模式的各种日志消息""" + return { + "mode_description": self.description, + "realtime_skip": f"跳过实时推送通知：{self.mode_name}下未检测到匹配的新闻", + "summary_skip": f"跳过{self.summary_report_type}通知：未匹配到有效的新闻内容", + } + + class NewsAnalyzer: """新闻分析器""" + MODE_STRATEGIES = { + "incremental": ModeStrategy( + mode_name="增量模式", + description="增量模式（只关注新增新闻，无新增时不推送）", + realtime_report_type="实时增量", + summary_report_type="当日汇总", + should_send_realtime=True, + should_generate_summary=True, + summary_mode="daily", + ), + "current": ModeStrategy( + mode_name="当前榜单模式", + description="当前榜单模式（当前榜单匹配新闻 + 新增新闻区域 + 按时推送）", + realtime_report_type="实时当前榜单", + summary_report_type="当前榜单汇总", + should_send_realtime=True, + should_generate_summary=True, + summary_mode="current", + ), + "daily": ModeStrategy( + mode_name="当日汇总模式", + description="当日汇总模式（所有匹配新闻 + 新增新闻区域 + 按时推送）", + realtime_report_type="", + summary_report_type="当日汇总", + should_send_realtime=False, + should_generate_summary=True, + summary_mode="daily", + ), + } + def __init__( self, request_interval: int = CONFIG["REQUEST_INTERVAL"], - report_type: str = CONFIG["REPORT_TYPE"], + report_mode: str = CONFIG["REPORT_MODE"], rank_threshold: int = CONFIG["RANK_THRESHOLD"], ): self.request_interval = request_interval - self.report_type = report_type + self.report_mode = report_mode self.rank_threshold = rank_threshold self.is_github_actions = os.environ.get("GITHUB_ACTIONS") == "true" + self.is_docker_container = self._detect_docker_environment() self.update_info = None self.proxy_url = None + self._setup_proxy() + self.data_fetcher = DataFetcher(self.proxy_url) + + if self.is_github_actions: + self._check_version_update() + + def _detect_docker_environment(self) -> bool: + """检测是否运行在 Docker 容器中""" + try: + if os.environ.get("DOCKER_CONTAINER") == "true": + return True + + if os.path.exists("/.dockerenv"): + return True + + return False + except Exception: + return False + + def _should_open_browser(self) -> bool: + """判断是否应该打开浏览器""" + return not self.is_github_actions and not self.is_docker_container + + def _setup_proxy(self) -> None: + """设置代理配置""" if not self.is_github_actions and CONFIG["USE_PROXY"]: self.proxy_url = CONFIG["DEFAULT_PROXY"] print("本地环境，使用代理") @@ -2426,11 +2647,6 @@ class NewsAnalyzer: else: print("GitHub Actions环境，不使用代理") - self.data_fetcher = DataFetcher(self.proxy_url) - - if self.is_github_actions: - self._check_version_update() - def _check_version_update(self) -> None: """检查版本更新""" try: @@ -2449,169 +2665,76 @@ class NewsAnalyzer: except Exception as e: print(f"版本检查出错: {e}") + def _get_mode_strategy(self) -> ModeStrategy: + """获取当前模式的策略配置""" + return self.MODE_STRATEGIES.get(self.report_mode, self.MODE_STRATEGIES["daily"]) + + def _has_webhook_configured(self) -> bool: + """检查是否配置了webhook""" + return any( + [ + CONFIG["FEISHU_WEBHOOK_URL"], + CONFIG["DINGTALK_WEBHOOK_URL"], + CONFIG["WEWORK_WEBHOOK_URL"], + (CONFIG["TELEGRAM_BOT_TOKEN"] and CONFIG["TELEGRAM_CHAT_ID"]), + ] + ) + def _has_valid_content( self, stats: List[Dict], new_titles: Optional[Dict] = None ) -> bool: """检查是否有有效的新闻内容""" - if CONFIG["FOCUS_NEW_ONLY"]: - # 新增模式下，只要stats有内容就说明有新增的匹配新闻 + if self.report_mode in ["incremental", "current"]: + # 增量模式和current模式下，只要stats有内容就说明有匹配的新闻 return any(stat["count"] > 0 for stat in stats) else: - # 正常模式下，检查是否有匹配的频率词新闻或新增新闻 + # 当日汇总模式下，检查是否有匹配的频率词新闻或新增新闻 has_matched_news = any(stat["count"] > 0 for stat in stats) has_new_news = bool( new_titles and any(len(titles) > 0 for titles in new_titles.values()) ) return has_matched_news or has_new_news - def generate_daily_summary(self) -> Optional[str]: - """生成当日统计报告""" - print("生成当日统计报告...") + def _load_analysis_data( + self, + ) -> Optional[Tuple[Dict, Dict, Dict, Dict, List, List]]: + """统一的数据加载和预处理，使用当前监控平台列表过滤历史数据""" + try: + # 获取当前配置的监控平台ID列表 + current_platform_ids = [] + for platform in PLATFORMS: + current_platform_ids.append(platform["id"]) - all_results, id_to_alias, title_info = DataProcessor.read_all_today_titles() + print(f"当前监控平台: {current_platform_ids}") - if not all_results: - print("没有找到当天的数据") + all_results, id_to_name, title_info = DataProcessor.read_all_today_titles( + current_platform_ids + ) + + if not all_results: + print("没有找到当天的数据") + return None + + total_titles = sum(len(titles) for titles in all_results.values()) + print(f"读取到 {total_titles} 个标题（已按当前监控平台过滤）") + + new_titles = DataProcessor.detect_latest_new_titles(current_platform_ids) + word_groups, filter_words = DataProcessor.load_frequency_words() + + return ( + all_results, + id_to_name, + title_info, + new_titles, + word_groups, + filter_words, + ) + except Exception as e: + print(f"数据加载失败: {e}") return None - total_titles = sum(len(titles) for titles in all_results.values()) - print(f"读取到 {total_titles} 个标题") - - new_titles = DataProcessor.detect_latest_new_titles(id_to_alias) - word_groups, filter_words = DataProcessor.load_frequency_words() - - stats, total_titles = StatisticsCalculator.count_word_frequency( - all_results, - word_groups, - filter_words, - id_to_alias, - title_info, - self.rank_threshold, - new_titles, - focus_new_only=CONFIG["FOCUS_NEW_ONLY"], - ) - - html_file = ReportGenerator.generate_html_report( - stats, - total_titles, - is_daily=True, - new_titles=new_titles, - id_to_alias=id_to_alias, - ) - print(f"当日HTML统计报告已生成: {html_file}") - - # 检查通知配置 - has_webhook = any( - [ - os.environ.get("FEISHU_WEBHOOK_URL", CONFIG["FEISHU_WEBHOOK_URL"]), - os.environ.get("DINGTALK_WEBHOOK_URL", CONFIG["DINGTALK_WEBHOOK_URL"]), - os.environ.get("WEWORK_WEBHOOK_URL", CONFIG["WEWORK_WEBHOOK_URL"]), - ( - os.environ.get("TELEGRAM_BOT_TOKEN", CONFIG["TELEGRAM_BOT_TOKEN"]) - and os.environ.get("TELEGRAM_CHAT_ID", CONFIG["TELEGRAM_CHAT_ID"]) - ), - ] - ) - - if ( - CONFIG["ENABLE_NOTIFICATION"] - and has_webhook - and self.report_type in ["daily", "both"] - and self._has_valid_content(stats, new_titles) - ): - hide_new_section = CONFIG["FOCUS_NEW_ONLY"] - - ReportGenerator.send_to_webhooks( - stats, - [], - "当日汇总", - new_titles, - id_to_alias, - self.update_info, - self.proxy_url, - hide_new_section=hide_new_section, - ) - elif CONFIG["ENABLE_NOTIFICATION"] and not has_webhook: - print("⚠️ 警告：通知功能已启用但未配置webhook URL，将跳过通知发送") - elif not CONFIG["ENABLE_NOTIFICATION"]: - print("跳过当日汇总通知：通知功能已禁用") - elif ( - CONFIG["ENABLE_NOTIFICATION"] - and has_webhook - and not self._has_valid_content(stats, new_titles) - ): - if CONFIG["FOCUS_NEW_ONLY"]: - print("跳过当日汇总通知：新增模式下未检测到匹配的新增新闻") - else: - print("跳过当日汇总通知：未匹配到有效的新闻内容") - - return html_file - - def run(self) -> None: - """执行分析流程""" - now = TimeHelper.get_beijing_time() - print(f"当前北京时间: {now.strftime('%Y-%m-%d %H:%M:%S')}") - - if not CONFIG["ENABLE_CRAWLER"]: - print("爬虫功能已禁用（ENABLE_CRAWLER=False），程序退出") - return - - # 检查是否配置了任何webhook URL - has_webhook = any( - [ - os.environ.get("FEISHU_WEBHOOK_URL", CONFIG["FEISHU_WEBHOOK_URL"]), - os.environ.get("DINGTALK_WEBHOOK_URL", CONFIG["DINGTALK_WEBHOOK_URL"]), - os.environ.get("WEWORK_WEBHOOK_URL", CONFIG["WEWORK_WEBHOOK_URL"]), - ( - os.environ.get("TELEGRAM_BOT_TOKEN", CONFIG["TELEGRAM_BOT_TOKEN"]) - and os.environ.get("TELEGRAM_CHAT_ID", CONFIG["TELEGRAM_CHAT_ID"]) - ), - ] - ) - - # 通知功能状态检查和提示 - if not CONFIG["ENABLE_NOTIFICATION"]: - print("通知功能已禁用（ENABLE_NOTIFICATION=False），将只进行数据抓取") - elif not has_webhook: - print("未配置任何webhook URL，将只进行数据抓取，不发送通知") - else: - print("通知功能已启用，将发送webhook通知") - - print(f"报告类型: {self.report_type}") - - if CONFIG["FOCUS_NEW_ONLY"]: - print("运行模式: 新增检测模式（只关注新增新闻）") - else: - print("运行模式: 正常模式（频率词统计 + 新增检测）") - - ids = [ - ("toutiao", "今日头条"), - ("baidu", "百度热搜"), - ("wallstreetcn-hot", "华尔街见闻"), - ("thepaper", "澎湃新闻"), - ("bilibili-hot-search", "bilibili 热搜"), - ("cls-hot", "财联社热门"), - ("ifeng", "凤凰网"), - "tieba", - "weibo", - "douyin", - "zhihu", - ] - - print(f"开始爬取数据，请求间隔 {self.request_interval} 毫秒") - FileHelper.ensure_directory_exists("output") - - results, id_to_alias, failed_ids = self.data_fetcher.crawl_websites( - ids, self.request_interval - ) - - title_file = DataProcessor.save_titles_to_file(results, id_to_alias, failed_ids) - print(f"标题已保存到: {title_file}") - - new_titles = DataProcessor.detect_latest_new_titles(id_to_alias) - - # 构建标题信息 - time_info = Path(title_file).stem + def _prepare_current_title_info(self, results: Dict, time_info: str) -> Dict: + """从当前抓取结果构建标题信息""" title_info = {} for source_id, titles_data in results.items(): title_info[source_id] = {} @@ -2628,78 +2751,357 @@ class NewsAnalyzer: "url": url, "mobileUrl": mobile_url, } + return title_info - word_groups, filter_words = DataProcessor.load_frequency_words() + def _run_analysis_pipeline( + self, + data_source: Dict, + mode: str, + title_info: Dict, + new_titles: Dict, + word_groups: List[Dict], + filter_words: List[str], + id_to_name: Dict, + failed_ids: Optional[List] = None, + is_daily_summary: bool = False, + ) -> Tuple[List[Dict], str]: + """统一的分析流水线：数据处理 → 统计计算 → HTML生成""" + # 统计计算 stats, total_titles = StatisticsCalculator.count_word_frequency( - results, + data_source, word_groups, filter_words, - id_to_alias, + id_to_name, title_info, self.rank_threshold, new_titles, - focus_new_only=CONFIG["FOCUS_NEW_ONLY"], + mode=mode, ) - # 只有启用通知且配置了webhook且有有效内容时才发送通知 + # HTML生成 + html_file = ReportGenerator.generate_html_report( + stats, + total_titles, + failed_ids=failed_ids, + new_titles=new_titles, + id_to_name=id_to_name, + mode=mode, + is_daily_summary=is_daily_summary, + ) + + return stats, html_file + + def _send_notification_if_needed( + self, + stats: List[Dict], + report_type: str, + mode: str, + failed_ids: Optional[List] = None, + new_titles: Optional[Dict] = None, + id_to_name: Optional[Dict] = None, + ) -> bool: + """统一的通知发送逻辑，包含所有判断条件""" + has_webhook = self._has_webhook_configured() + if ( CONFIG["ENABLE_NOTIFICATION"] and has_webhook - and self.report_type in ["current", "both"] and self._has_valid_content(stats, new_titles) ): - hide_new_section = CONFIG["FOCUS_NEW_ONLY"] - ReportGenerator.send_to_webhooks( stats, - failed_ids, - "单次爬取", + failed_ids or [], + report_type, new_titles, - id_to_alias, + id_to_name, self.update_info, self.proxy_url, - hide_new_section=hide_new_section, + mode=mode, ) + return True elif CONFIG["ENABLE_NOTIFICATION"] and not has_webhook: print("⚠️ 警告：通知功能已启用但未配置webhook URL，将跳过通知发送") elif not CONFIG["ENABLE_NOTIFICATION"]: - print("跳过单次爬取通知：通知功能已禁用") + print(f"跳过{report_type}通知：通知功能已禁用") elif ( CONFIG["ENABLE_NOTIFICATION"] and has_webhook and not self._has_valid_content(stats, new_titles) ): - if CONFIG["FOCUS_NEW_ONLY"]: - print("跳过单次爬取通知：新增模式下未检测到匹配的新增新闻") + mode_strategy = self._get_mode_strategy() + log_messages = mode_strategy.get_log_messages() + if "实时" in report_type: + print(log_messages["realtime_skip"]) else: - print("跳过单次爬取通知：未匹配到有效的新闻内容") + print(log_messages["summary_skip"]) - html_file = ReportGenerator.generate_html_report( - stats, total_titles, failed_ids, False, new_titles, id_to_alias + return False + + def _generate_summary_report(self, mode_strategy: ModeStrategy) -> Optional[str]: + """生成汇总报告（带通知）""" + summary_type = ( + "当前榜单汇总" if mode_strategy.summary_mode == "current" else "当日汇总" ) - print(f"HTML报告已生成: {html_file}") + print(f"生成{summary_type}报告...") - daily_html = self.generate_daily_summary() + # 加载分析数据 + analysis_data = self._load_analysis_data() + if not analysis_data: + return None - if not self.is_github_actions and html_file: - file_url = "file://" + str(Path(html_file).resolve()) - print(f"正在打开HTML报告: {file_url}") - webbrowser.open(file_url) + all_results, id_to_name, title_info, new_titles, word_groups, filter_words = ( + analysis_data + ) - if daily_html: - daily_url = "file://" + str(Path(daily_html).resolve()) - print(f"正在打开当日统计报告: {daily_url}") - webbrowser.open(daily_url) + # 运行分析流水线 + stats, html_file = self._run_analysis_pipeline( + all_results, + mode_strategy.summary_mode, + title_info, + new_titles, + word_groups, + filter_words, + id_to_name, + is_daily_summary=True, + ) + + print(f"{summary_type}报告已生成: {html_file}") + + # 发送通知 + self._send_notification_if_needed( + stats, + mode_strategy.summary_report_type, + mode_strategy.summary_mode, + new_titles=new_titles, + id_to_name=id_to_name, + ) + + return html_file + + def _generate_summary_html(self, mode: str = "daily") -> Optional[str]: + """生成汇总HTML""" + summary_type = "当前榜单汇总" if mode == "current" else "当日汇总" + print(f"生成{summary_type}HTML...") + + # 加载分析数据 + analysis_data = self._load_analysis_data() + if not analysis_data: + return None + + all_results, id_to_name, title_info, new_titles, word_groups, filter_words = ( + analysis_data + ) + + # 运行分析流水线 + _, html_file = self._run_analysis_pipeline( + all_results, + mode, + title_info, + new_titles, + word_groups, + filter_words, + id_to_name, + is_daily_summary=True, + ) + + print(f"{summary_type}HTML已生成: {html_file}") + return html_file + + def _initialize_and_check_config(self) -> None: + """通用初始化和配置检查""" + now = TimeHelper.get_beijing_time() + print(f"当前北京时间: {now.strftime('%Y-%m-%d %H:%M:%S')}") + + if not CONFIG["ENABLE_CRAWLER"]: + print("爬虫功能已禁用（ENABLE_CRAWLER=False），程序退出") + return + + has_webhook = self._has_webhook_configured() + if not CONFIG["ENABLE_NOTIFICATION"]: + print("通知功能已禁用（ENABLE_NOTIFICATION=False），将只进行数据抓取") + elif not has_webhook: + print("未配置任何webhook URL，将只进行数据抓取，不发送通知") + else: + print("通知功能已启用，将发送webhook通知") + + mode_strategy = self._get_mode_strategy() + print(f"报告模式: {self.report_mode}") + print(f"运行模式: {mode_strategy.description}") + + def _crawl_data(self) -> Tuple[Dict, Dict, List]: + """执行数据爬取""" + ids = [] + for platform in PLATFORMS: + if "name" in platform: + ids.append((platform["id"], platform["name"])) + else: + ids.append(platform["id"]) + + print(f"配置的监控平台: {[p.get('name', p['id']) for p in PLATFORMS]}") + print(f"开始爬取数据，请求间隔 {self.request_interval} 毫秒") + FileHelper.ensure_directory_exists("output") + + results, id_to_name, failed_ids = self.data_fetcher.crawl_websites( + ids, self.request_interval + ) + + title_file = DataProcessor.save_titles_to_file(results, id_to_name, failed_ids) + print(f"标题已保存到: {title_file}") + + return results, id_to_name, failed_ids + + def _execute_mode_strategy( + self, + mode_strategy: ModeStrategy, + results: Dict, + id_to_name: Dict, + failed_ids: List, + ) -> Optional[str]: + """执行模式特定逻辑""" + # 获取当前监控平台ID列表 + current_platform_ids = [platform["id"] for platform in PLATFORMS] + + new_titles = DataProcessor.detect_latest_new_titles(current_platform_ids) + time_info = Path( + DataProcessor.save_titles_to_file(results, id_to_name, failed_ids) + ).stem + word_groups, filter_words = DataProcessor.load_frequency_words() + + # current模式下，实时推送需要使用完整的历史数据来保证统计信息的完整性 + if self.report_mode == "current": + # 加载完整的历史数据（已按当前平台过滤） + analysis_data = self._load_analysis_data() + if analysis_data: + ( + all_results, + historical_id_to_name, + historical_title_info, + historical_new_titles, + _, + _, + ) = analysis_data + + print( + f"current模式：使用过滤后的历史数据，包含平台：{list(all_results.keys())}" + ) + + stats, html_file = self._run_analysis_pipeline( + all_results, + self.report_mode, + historical_title_info, + historical_new_titles, + word_groups, + filter_words, + historical_id_to_name, + failed_ids=failed_ids, + ) + + combined_id_to_name = {**historical_id_to_name, **id_to_name} + + print(f"HTML报告已生成: {html_file}") + + # 发送实时通知（使用完整历史数据的统计结果） + summary_html = None + if mode_strategy.should_send_realtime: + self._send_notification_if_needed( + stats, + mode_strategy.realtime_report_type, + self.report_mode, + failed_ids=failed_ids, + new_titles=historical_new_titles, + id_to_name=combined_id_to_name, + ) + else: + print("❌ 严重错误：无法读取刚保存的数据文件") + raise RuntimeError("数据一致性检查失败：保存后立即读取失败") + else: + title_info = self._prepare_current_title_info(results, time_info) + stats, html_file = self._run_analysis_pipeline( + results, + self.report_mode, + title_info, + new_titles, + word_groups, + filter_words, + id_to_name, + failed_ids=failed_ids, + ) + print(f"HTML报告已生成: {html_file}") + + # 发送实时通知（如果需要） + summary_html = None + if mode_strategy.should_send_realtime: + self._send_notification_if_needed( + stats, + mode_strategy.realtime_report_type, + self.report_mode, + failed_ids=failed_ids, + new_titles=new_titles, + id_to_name=id_to_name, + ) + + # 生成汇总报告（如果需要） + summary_html = None + if mode_strategy.should_generate_summary: + if mode_strategy.should_send_realtime: + # 如果已经发送了实时通知，汇总只生成HTML不发送通知 + summary_html = self._generate_summary_html(mode_strategy.summary_mode) + else: + # daily模式：直接生成汇总报告并发送通知 + summary_html = self._generate_summary_report(mode_strategy) + + # 打开浏览器（仅在非容器环境） + if self._should_open_browser() and html_file: + if summary_html: + summary_url = "file://" + str(Path(summary_html).resolve()) + print(f"正在打开汇总报告: {summary_url}") + webbrowser.open(summary_url) + else: + file_url = "file://" + str(Path(html_file).resolve()) + print(f"正在打开HTML报告: {file_url}") + webbrowser.open(file_url) + elif self.is_docker_container and html_file: + if summary_html: + print(f"汇总报告已生成（Docker环境）: {summary_html}") + else: + print(f"HTML报告已生成（Docker环境）: {html_file}") + + return summary_html + + def run(self) -> None: + """执行分析流程""" + try: + self._initialize_and_check_config() + + mode_strategy = self._get_mode_strategy() + + results, id_to_name, failed_ids = self._crawl_data() + + self._execute_mode_strategy(mode_strategy, results, id_to_name, failed_ids) + + except Exception as e: + print(f"分析流程执行出错: {e}") + raise def main(): - analyzer = NewsAnalyzer( - request_interval=CONFIG["REQUEST_INTERVAL"], - report_type=CONFIG["REPORT_TYPE"], - rank_threshold=CONFIG["RANK_THRESHOLD"], - ) - analyzer.run() + try: + analyzer = NewsAnalyzer( + request_interval=CONFIG["REQUEST_INTERVAL"], + report_mode=CONFIG["REPORT_MODE"], + rank_threshold=CONFIG["RANK_THRESHOLD"], + ) + analyzer.run() + except FileNotFoundError as e: + print(f"❌ 配置文件错误: {e}") + print("\n请确保以下文件存在:") + print(" • config/config.yaml") + print(" • config/frequency_words.txt") + print("\n参考项目文档进行正确配置") + except Exception as e: + print(f"❌ 程序运行错误: {e}") + raise if __name__ == "__main__": diff --git a/readme.md b/readme.md index 4d6e965..9d6ab25 100644 --- a/readme.md +++ b/readme.md @@ -1,6 +1,6 @@
-# 🎯 TrendRadar
+# 🎯TrendRadar
**你的专属热点助手 —— 让手机只推送你真正关心的新闻**
@@ -10,7 +10,7 @@
[](https://github.com/sansan0/TrendRadar/network/members)
[](LICENSE)
[](https://www.python.org/)
-[](https://github.com/sansan0/TrendRadar)
+[](https://github.com/sansan0/TrendRadar)
[](https://work.weixin.qq.com/)
[](https://telegram.org/)
@@ -18,34 +18,50 @@
[](https://www.feishu.cn/)
[](https://github.com/sansan0/TrendRadar)
[](https://sansan0.github.io/TrendRadar)
+[](https://hub.docker.com/)
----
> 如果本项目对你有所帮助，**点个 Star ⭐** 就是对我最大的支持。
>
-> 遇到问题可以直接提 issues，我会认真回复每一个。也可以关注【硅基茶水间】公众号，那里我会分享开源项目的思路和经验。
->
-> 我从 2025 年 4 月末开始经常开源项目，之前一直各种使用其他大佬的开源项目，虽然也勤于 star, 但确实更多的是在"白嫖"。现在想通过自己的项目回馈开源社区，同时记录这个过程中的收获和思考。
->
-> 本账号专门用来维护开源项目。如果你也在做开源，或者对开源感兴趣，**欢迎一起交流**。
+> 遇到问题可以直接提 issues。也可以【硅基茶水间】公众号留言问题。
+
----
## ✨ 核心功能
### **全网热点聚合**
-一次监控 11+ 个主流平台（微博、知乎、抖音、百度等），再也不用逐个 APP 刷新闻）
+默认监控 11 个主流平台
-> _理论上支持 35 个左右的平台，我默认只放了 11 个，想增加什么股票等金融相关资讯的，需要你自己手动添加，有需求的看最下方的**高级用法**_
+- 今日头条
+- 百度热搜
+- 华尔街见闻
+- 澎湃新闻
+- bilibili 热搜
+- 财联社热门
+- 凤凰网
+- 贴吧
+- 微博
+- 抖音
+- 知乎
+
+> _理论上支持 35 个左右，如果你想增加额外的金融类等相关资讯推送，可看最下方的**自定义监控平台**_
### **智能推送策略**
-提供两种工作模式满足不同需求：**默认模式**持续追踪热点排名变化、出现频次和时间跨度，定时推送完整分析报告（也包括新增热点）；**增量模式**仅检测新增热点，无新内容时不推送，避免信息噪音
+提供三种工作模式满足不同需求：
-> _默认模式适合全面了解热点趋势，增量模式适合高频监控（≤30 分钟）场景，专注最新动态而非持续热度_
+| 模式 | 推送时机 | 显示内容 | 适用场景 |
+|------|----------|----------|----------|
+| **当日汇总模式**`daily` | 按时推送 | 当日所有匹配新闻
+ 新增新闻区域 | 日报总结
全面了解当日热点趋势 | +| **当前榜单模式**
`current` | 按时推送 | 当前榜单匹配新闻
+ 新增新闻区域 | 实时热点追踪
了解当前最火的内容 | +| **增量监控模式**
`incremental` | 有新增才推送 | 新出现的匹配频率词新闻 | 避免重复信息干扰
高频监控场景 | + +- **📈 投资者/交易员** → 选择 `incremental`，及时获取新增资讯(建议自建服务器进行 docker 部署，提高检测频率) +- **📰 自媒体人/内容创作者** → 选择 `current`，掌握实时热点趋势 +- **📋 企业管理者/普通用户** → 选择 `daily`，定时获取完整日报 ### **精准内容筛选** @@ -59,9 +75,9 @@ ### **零技术门槛部署** -GitHub 一键 Fork 即可使用，无需服务器，无需编程基础。如果要手机接收通知， 要达到 1 分钟部署完毕的效果，请选择**企业微信** +GitHub 一键 Fork 即可使用，无需编程基础。 -> _就，很快_ +> _如果要手机接收通知， 要达到 1 分钟部署完毕的效果，请选择**企业微信**_ ### **减少 APP 依赖** @@ -73,7 +89,7 @@ GitHub 一键 Fork 即可使用，无需服务器，无需编程基础。如果 **典型场景：** 股市投资监控、品牌舆情追踪、行业动态关注、生活资讯获取 -**💡 提示：** 想要网页版？启用 GitHub Pages 即可获得自动更新的新闻页面。进入你的仓库 Settings → Pages，启用后就能获得专属链接，比如我这里[TrendRadar](https://sansan0.github.io/TrendRadar/)。 +**💡 提示：** 想要网页版？进入你的仓库 Settings → Pages，启用 GitHub Pages 即可获得自动更新的新闻页面链接。比如我这里[TrendRadar](https://sansan0.github.io/TrendRadar/)。
@@ -81,7 +97,24 @@ GitHub 一键 Fork 即可使用，无需服务器，无需编程基础。如果
## 📝 更新日志
-**升级说明：** 已**fork**的同学，如果想获得最新功能：只需把本项目中 main.py 的所有代码替换掉你的旧代码即可（直接 GitHub 网页上编辑）。
+**升级说明：**
+- **小版本更新**：直接在 GitHub 网页编辑器中，用本项目的 `main.py` 代码替换你 fork 仓库中的对应文件
+- **大版本升级**：从 v1.x 升级到 v2.0 建议删除现有 fork 后重新 fork，这样更省力且避免配置冲突
+
+### 2025/07/17 - v2.0.0
+
+**重大重构**：
+- 配置管理重构：所有配置现在通过 `config/config.yaml` 文件管理（main.py 我依旧没拆分，方便你们复制升级）
+- 运行模式升级：支持三种模式 - `daily`（当日汇总）、`current`（当前榜单）、`incremental`（增量监控）
+- Docker 支持：完整的 Docker 部署方案，支持容器化运行
+
+**配置文件说明**：
+- `config/config.yaml` - 主配置文件（应用设置、爬虫配置、通知配置、平台配置等）
+- `config/frequency_words.txt` - 关键词配置（监控词汇设置）
+
+
+
+
📝 点击查看历史更新
### 2025/07/09 - v1.4.1
@@ -89,9 +122,6 @@ GitHub 一键 Fork 即可使用，无需服务器，无需编程基础。如果
**修复问题**: 某些情况下，由于新闻本身含有特殊符号导致的偶发性排版异常。
-
-
-## 🔍 支持的平台
-
-目前已支持以下 11 个热门平台:
-
-- 今日头条
-- 百度热搜
-- 华尔街见闻
-- 澎湃新闻
-- bilibili 热搜
-- 财联社热门
-- 凤凰网
-- 贴吧
-- 微博
-- 抖音
-- 知乎
## 🚀 使用方式
@@ -286,7 +301,7 @@ frequency_words.txt 文件增加了一个【必须词】功能，使用 + 号
📝 查看历史更新
-
### 2025/06/23 - v1.3.0
企业微信 和 Telegram 的推送消息有长度限制，对此我采用将消息拆分推送的方式。开发文档详见[企业微信](https://developer.work.weixin.qq.com/document/path/91770) 和 [Telegram](https://core.telegram.org/bots/api)
@@ -168,21 +198,6 @@ frequency_words.txt 文件增加了一个【必须词】功能，使用 + 号
-
-3. **自定义关键词**:
+3. **配置关键词和设置**:
- - 修改`frequency_words.txt`文件，添加你关心的关键词
+ - **关键词配置**: 修改 `config/frequency_words.txt` 文件，添加你关心的关键词
+ - **运行模式配置**: 在 `config/config.yaml` 中修改 `report.mode` 设置：
+ - `"daily"` - 当日汇总模式（默认）
+ - `"current"` - 当前榜单模式
+ - `"incremental"` - 增量监控模式
🟣 Telegram Bot（配置最复杂）
+ 🟣 Telegram Bot
**GitHub Secret 配置：**
- 名称：`TELEGRAM_BOT_TOKEN` - 你的 Telegram Bot Token
@@ -316,12 +331,16 @@ frequency_words.txt 文件增加了一个【必须词】功能，使用 + 号
- `TELEGRAM_CHAT_ID`：填入第 2 步获得的 Chat ID
- ⚙️ 点击查看 frequency_words.txt 完整配置教程
+ ⚙️ 点击查看 frequency_words.txt 配置教程
在 `frequency_words.txt` 文件中配置监控的关键词，支持三种语法和词组功能。
@@ -472,7 +491,7 @@ frequency_words.txt 文件增加了一个【必须词】功能，使用 + 号
4. **自动运行**:
- - 项目已包含`.github/workflows/crawler.yml`配置文件，默认每 50 分钟自动运行一次
+ - 项目已包含`.github/workflows/crawler.yml`配置文件，默认每 30 分钟自动运行一次
- 你也可以在 GitHub 仓库的 Actions 页面手动触发运行
5. **查看结果**:
@@ -508,64 +527,128 @@ frequency_words.txt 文件增加了一个【必须词】功能，使用 + 号
| [时间 ~ 时间] | [12 时 30 分 ~ 14 时 00 分] | 时间范围 | 标题出现的时间范围(首次~最后) |
| (N 次) | (4 次) | 出现次数 | 标题在监控期间出现的总次数 |
-## 🔧 高级用法
-### 自定义监控平台
+### 🔧 自定义监控平台
-本项目的数据来源于 [newsnow](https://github.com/ourongxing/newsnow) 项目，你可以点击[这个网站](https://newsnow.busiyi.world/)，点击里面的【更多】，可以看到所有支持的平台。如果你想支持更多平台或者不想看某些平台，可以访问 https://github.com/ourongxing/newsnow/tree/main/server/sources ，根据里面的文件名来调整 main.py 中的下面代码(如果不懂怎么看这些代码，也可以去我公众号留言)：
+本项目的资讯数据来源于 [newsnow](https://github.com/ourongxing/newsnow) ，你可以点击[网站](https://newsnow.busiyi.world/)，点击[更多]，查看是否有你想要的平台。
-```python
-ids = [
- ("toutiao", "今日头条"),
- ("baidu", "百度热搜"),
- ("wallstreetcn-hot", "华尔街见闻"),
- ("thepaper", "澎湃新闻"),
- ("bilibili-hot-search", "bilibili 热搜"),
- ("cls-hot", "财联社热门"),
- ("ifeng", "凤凰网"),
- "tieba",
- "weibo",
- "douyin",
- "zhihu",
-]
+具体添加可访问 [项目源代码](https://github.com/ourongxing/newsnow/tree/main/server/sources)，根据里面的文件名，在 `config/config.yaml` 文件中修改 `platforms` 配置：
+
+```yaml
+platforms:
+ - id: "toutiao"
+ name: "今日头条"
+ - id: "baidu"
+ name: "百度热搜"
+ - id: "wallstreetcn-hot"
+ name: "华尔街见闻"
+ # 添加更多平台...
```
-## ❓ 常见问题
+### 🐳 Docker 部署
-1. **GitHub Actions 不执行怎么办？**
+1. **克隆项目并进入目录**:
+ ```bash
+ git clone https://github.com/sansan0/TrendRadar.git
+ cd TrendRadar
+ ```
- - 检查`.github/workflows/crawler.yml`文件是否存在
- - 在 Actions 页面手动触发一次 workflow
- - 确认你有足够的 GitHub Actions 免费分钟数
+2. **配置文件**:
+ - 修改 `config/config.yaml` 和 `config/frequency_words.txt`
+ - **推送链接填写**，**设置推送定时**可通过 .env 进行配置
-2. **没有收到飞书通知怎么办？**
+3. **启动服务**:
+ ```bash
+ cd docker
+ docker-compose up -d
+ ```
- - 检查`FEISHU_WEBHOOK_URL`是否正确设置（环境变量或 CONFIG 中）
- - 检查飞书机器人是否仍在群内且启用
- - 查看程序输出中是否有发送失败的错误信息
- - 确认飞书流程配置中的参数结构正确
+4. **管理服务**:
+ ```bash
+ # 查看运行状态
+ docker exec -it trend-radar python manage.py status
+
+ # 手动执行一次爬虫
+ docker exec -it trend-radar python manage.py run
+
+ # 查看实时日志
+ docker exec -it trend-radar python manage.py logs
+
+ # 显示当前配置
+ docker exec -it trend-radar python manage.py config
+
+ # 显示输出文件
+ docker exec -it trend-radar python manage.py files
+
+ # 重启定时服务
+ docker exec -it trend-radar python manage.py restart
+
+ # 显示帮助信息
+ docker exec -it trend-radar python manage.py help
+ ```
-3. **想要停止手机接收新闻通知消息？**
- - 将`ENABLE_NOTIFICATION`设置为`False`
-
-4. **想要停止在本地继续生成新闻数据？**
-
- - 将`ENABLE_CRAWLER`设置为`False`
-
-## 📧 学习交流
-
-扫码关注微信公众号，里面有文章是讲我写的这些项目的，咳如果对你有了点帮助，献上【点赞,转发,推荐】三连，就算支持了俺这个作者的开发了，顺便也可以反馈使用问题：
+## ☕ 赞助让代码更香.jpg
-
+| Wechat | Alipay |
+|:---:|:---:|
+|
-
-## Star History
+## 📧 学习交流
+
+
| 
|
+
+
+
+
+```mermaid
+flowchart TD
+ A[👤 用户开始] --> B[🍴 Fork 项目]
+ B --> C[⚙️ 选择通知方式]
+
+ C --> D1[📱 企业微信群机器人
+
+
+
+
最简单快速]
+ C --> D2[💬 飞书机器人
显示效果最佳]
+ C --> D3[🔔 钉钉机器人
]
+ C --> D4[📟 Telegram Bot
]
+
+ D1 --> E[🔑 配置 GitHub Secrets
填入机器人 Webhook 地址]
+ D2 --> E
+ D3 --> E
+ D4 --> E
+
+ E --> F[📝 编辑关键词配置
config/frequency_words.txt
添加你关心的词汇]
+ F --> G[🎯 选择运行模式
config/config.yaml
daily/current/incremental]
+
+ G --> H[✅ 配置完成]
+ H --> I[🤖 系统每30分钟自动运行]
+
+ I --> J[📊 爬取各大平台热点]
+ J --> K[🔍 根据关键词筛选]
+ K --> L[📱 推送到你的手机]
+
+ L --> M[📈 查看推送结果]
+ M --> N{满意效果?}
+ N -->|不满意| F
+ N -->|满意| O[🎉 持续接收精准推送]
+
+ style A fill:#e1f5fe
+ style B fill:#f3e5f5
+ style E fill:#fff3e0
+ style F fill:#e8f5e8
+ style G fill:#e8f5e8
+ style L fill:#ffebee
+ style O fill:#e8f5e8
+```
+
[](https://www.star-history.com/#sansan0/TrendRadar&Date)
@@ -583,6 +666,6 @@ GPL-3.0 License
**⭐ 如果这个工具对你有帮助，请给项目点个 Star 支持开发！**
-[🔝 回到顶部](#TrendRadar-多平台热点资讯监控分析系统)
+[🔝 回到顶部](#trendradar)