Function create_reading_report

agents/reading-agent/main.py:4775–5128

(
    user_id: str,
    paper_ids: List[int],
    papers: List[Dict],
    folder_id: Optional[str] = None,
    send_to_feishu: bool = True,
    feishu_user_id: Optional[str] = None,
    chat_id: Optional[str] = None,
    request_metadata: Optional[Dict[str, Any]] = None,
)

def create_reading_report(
    user_id: str,
    paper_ids: List[int],
    papers: List[Dict],
    folder_id: Optional[str] = None,
    send_to_feishu: bool = True,
    feishu_user_id: Optional[str] = None,
    chat_id: Optional[str] = None,
    request_metadata: Optional[Dict[str, Any]] = None,
) -> List[Dict[str, Any]]:
    print(f"Creating reading reports for user: {user_id}")
    print(f"Selected papers: {paper_ids}")

    target_id = chat_id or feishu_user_id
    use_chat_id = chat_id is not None
    request_metadata = dict(request_metadata or {})
    report_style = _normalize_report_style(request_metadata.get("report_style"))
    response_language = _normalize_response_language(request_metadata.get("response_language"))
    request_metadata["response_language"] = response_language

    profile = get_profile(user_id)
    if not profile:
        print(f"Warning: No profile found for user {user_id}, using default")
        profile = {"core_directions": {}, "methodology_preferences": {}}
    profile = ensure_profile_schema(profile)

    selected_papers = resolve_selected_papers(paper_ids, papers)
    if not selected_papers:
        print("No valid papers selected")
        if send_to_feishu and target_id:
            send_text(
                target_id,
                "这次没有找到可生成精读的论文，请先推送后回复编号，或重新发送“精读”。",
                use_chat_id=use_chat_id,
            )
        return []

    # 1. If this request comes from a specific uploaded PDF, reuse the existing
    # report when the same source key has already been processed successfully.
    existing_pdf_doc = None
    if request_metadata.get("report_source_type") and request_metadata.get("report_source_key"):
        existing_pdf_doc = _lookup_existing_pdf_report(user_id, request_metadata, selected_papers[0])
        if existing_pdf_doc:
            print(
                "Reusing existing PDF reading report for "
                f"{request_metadata.get('report_source_type')}={request_metadata.get('report_source_key')}"
            )
            if send_to_feishu and target_id:
                summary_text = format_created_docs_summary([existing_pdf_doc])
                try:
                    send_text(target_id, summary_text, use_chat_id=use_chat_id)
                    print(f"\nNotification sent to Feishu target: {target_id}")
                except Exception as exc:
                    print(f"\nFailed to send reused PDF doc summary to Feishu: {exc}")
            return [existing_pdf_doc]

    # 2. For pushed/selected papers, reuse already-created docs by paper_id and
    # only generate reports for the missing subset.
    existing_reports_by_paper_id: Dict[int, Dict[str, Any]] = {}