Function process_feedback

agents/feedback-agent/main.py:617–880

处理用户反馈 Args: user_id: 用户 ID push_id: 推送 ID（用于关联行为日志） reply: 用户回复文本 papers: 推送的论文列表 feishu_user_id: 飞书用户 ID（open_id） chat_id: 聊天 ID（优先使用，发送到原对话框） Returns: 处理结果

(
    user_id: str,
    push_id: str,
    reply: str,
    papers: List[Dict],
    feishu_user_id: Optional[str] = None,
    chat_id: Optional[str] = None,
    send_to_feishu: bool = True,
    auto_create_reports: Optional[bool] = None
)

def process_feedback(
    user_id: str,
    push_id: str,
    reply: str,
    papers: List[Dict],
    feishu_user_id: Optional[str] = None,
    chat_id: Optional[str] = None,
    send_to_feishu: bool = True,
    auto_create_reports: Optional[bool] = None
) -> Dict[str, Any]:
    """
    处理用户反馈

    Args:
        user_id: 用户 ID
        push_id: 推送 ID（用于关联行为日志）
        reply: 用户回复文本
        papers: 推送的论文列表
        feishu_user_id: 飞书用户 ID（open_id）
        chat_id: 聊天 ID（优先使用，发送到原对话框）

    Returns:
        处理结果
    """
    print(f"Processing feedback from user: {user_id}")
    print(f"Reply: {reply}")

    # 优先使用 chat_id，否则使用 feishu_user_id
    target_id = chat_id or feishu_user_id
    use_chat_id = chat_id is not None

    # 1. 解析用户回复
    parsed_selected = parse_user_reply(reply, papers)
    reply_lower = reply.lower().strip()
    is_none_command = reply_lower == "none"

    if not parsed_selected and not is_none_command:
        # 没有有效选择，发送提示
        message = "未识别到有效的论文编号。请回复数字，如：1 2 4 6、1-5 8 10，或直接回复 none。"
        if target_id and send_to_feishu:
            send_text(target_id, message, use_chat_id=use_chat_id)
        return {"status": "error", "message": message}

    previously_selected = get_existing_selected_numbers(user_id, push_id, papers)
    selected = set() if is_none_command else previously_selected | parsed_selected
    newly_selected = set() if is_none_command else parsed_selected - previously_selected

    print(f"Selected paper numbers: {sorted(selected)}")
    if previously_selected:
        print(f"Previously selected in this push: {sorted(previously_selected)}")
    if newly_selected != parsed_selected:
        print(f"Newly selected in this reply: {sorted(newly_selected)}")
    current_timestamp = datetime.now()
    feedback_strength_multiplier, feedback_latency_seconds = estimate_feedback_strength_multiplier(push_id, current_timestamp)
    history_before_update = get_recent_selected_papers(
        user_id,
        limit=60,
        days=60,
        before_timestamp=current_timestamp.isoformat(sep=" "),
    )