Method process

agents/master-coordinator/main.py:2444–2501

处理用户输入 Args: text: 用户输入文本 Returns: 处理结果

(self, text: str)

        return {"success": False, "message": "Unknown intent"}

    def process(self, text: str) -> Dict[str, Any]:
        """
        处理用户输入

        Args:
            text: 用户输入文本

        Returns:
            处理结果
        """
        text_clean = safe_console_text(text, 100)
        print(f"\n{'='*60}")
        print(f"Processing: {text_clean}")
        print(f"{'='*60}")

        # 检测意图
        intent = self.detect_intent(text)
        print(f"Detected intent: {intent['intent']} (confidence: {intent['confidence']:.2f})")

        # 路由到对应处理器
        handlers = {
            "ignore": lambda: {"success": True, "ignored": True},
            "confirm_direction": lambda: self.handle_confirm_direction(intent["slots"].get("topic", text)),
            "cold_start": lambda: self.handle_cold_start(text),
            "daily_push": self.handle_daily_push,
            "feedback": lambda: self.handle_feedback(intent["slots"].get("reply", text)),
            "expand_push": lambda: self.handle_expand_push(
                category=intent["slots"].get("category", ""),
                query=intent["slots"].get("query", ""),
            ),
            "classification_correction": lambda: self.handle_classification_correction(
                int(intent["slots"].get("paper_number", 0)),
                intent["slots"].get("target_category", ""),
            ),
            "report_feedback": lambda: self.handle_report_feedback(intent["slots"].get("sentiment", "")),
            "reviewer_watch": lambda: self.handle_reviewer_watch(
                intent["slots"].get("conference", ""),
                int(intent["slots"].get("year", datetime.now().year)),
                text,
            ),
            "reading_report": lambda: self.handle_reading_report(
                paper_ids=intent["slots"].get("paper_ids"),
                pdf_url=intent["slots"].get("pdf_url"),
                title_hint=intent["slots"].get("title_hint", ""),
            ),
            "clear_reading_list": self.handle_clear_reading_list,
            "weekly_report": self.handle_weekly_report,
            "must_read": lambda: self.handle_must_read(intent["slots"].get("command", text)),
            "show_profile": self.handle_show_profile,
            "profile_update": lambda: self.handle_profile_update(text, intent["slots"]),
            "role_manager": lambda: self.handle_role_manager(intent["slots"].get("command", text)),
        }

        handler = handlers.get(intent["intent"], lambda: self.handle_unknown(text))
        result = handler()

        print(f"Result: {safe_console_text(result, 200)}")
        return result