Function run_contest_analysis_interactive

cli/main.py:389–485

在交互界面中运行竞赛分析

(trigger_time: str, market: str)

def run_contest_analysis_interactive(trigger_time: str, market: str):
    """在交互界面中运行竞赛分析"""
    try:
        # 创建显示管理器
        display = ContestTradeDisplay()
        
        # 在显示中添加市场信息
        display.set_current_task(get_text(f"初始化ContestTrade系统... (市场: {market})", f"Initializing ContestTrade system... (Market: {market})"))
        
        # 创建初始布局
        layout = display.create_layout(trigger_time)
        
        # 使用Live界面运行 - 提高刷新频率以更好响应窗口大小变化
        with Live(layout, refresh_per_second=4, screen=True, auto_refresh=True, console=console) as live:
            # 初始显示
            display.update_display(layout, trigger_time)
            
            # 添加初始消息
            display.add_message(get_text("系统", "System"), get_text(f"开始分析 - 市场: {market}, 时间: {trigger_time}", f"Starting analysis - Market: {market}, Time: {trigger_time}"))
            display.update_display(layout, trigger_time)
            
            # 检查模块导入 - Import when needed
            try:
                from contest_trade.main import SimpleTradeCompany
                if SimpleTradeCompany is None:
                    raise ImportError("SimpleTradeCompany模块导入失败")
                    
                display.add_message(get_text("系统", "System"), get_text("✅ 成功导入SimpleTradeCompany模块", "✅ Successfully imported SimpleTradeCompany module"))
                display.update_display(layout, trigger_time)
                
                # 创建公司实例
                company = SimpleTradeCompany()
                display.add_message(get_text("系统", "System"), get_text("✅ 成功创建SimpleTradeCompany实例", "✅ Successfully created SimpleTradeCompany instance"))
                display.update_display(layout, trigger_time)
                
            except Exception as e:
                display.add_message("错误", f"❌ 模块导入失败: {str(e)}")
                display.update_display(layout, trigger_time)
                return None, display
            
            # 运行工作流并捕获输出
            final_state = asyncio.run(run_with_events_capture(company, trigger_time, display, layout, live))
            
            # 运行结束后
            if final_state:
                display.add_message(get_text("完成", "Completed"), get_text("✅ 分析完成！", "✅ Analysis completed!"))
                display.set_current_task(get_text("分析完成，生成报告...", "Analysis completed, generating report..."))
                display.set_analysis_completed(True)
                display.final_state = final_state
                display.update_display(layout, trigger_time)
                
                # 自动生成MD报告
                try:
                    from contest_trade.config.config import PROJECT_ROOT
                    results_dir = Path(PROJECT_ROOT) / "agents_workspace" / "results"
                    from .static.report_template import generate_final_report, generate_data_report
                    
                    # 生成研究报告