"""求职助手 Agent 对话 Service 主要功能:查询简历数据,调用 AI 模块完成对话。 依赖:resume_loader(简历统一查询)、job_agent.chat AI 模块 使用表:bg_user_resume + 5张子表(通过 resume_loader 查询) """ from sqlalchemy.ext.asyncio import AsyncSession from app.ai.job_agent.chat import agent_chat from app.services.resume_loader import ResumeDetail, load_resume_detail class JobAgentChatService: def __init__(self, session: AsyncSession): self.session = session async def chat(self, user_id: int, resume_id: int, message: str, history: list[dict], job_categories: list[str], regions: list[str], industries: list[str]) -> dict: """求职助手对话:查简历 → 序列化 → 调 AI 模块""" detail = await load_resume_detail(self.session, resume_id, user_id) resume_text = self._build_resume_text(detail) return await agent_chat(resume_text, message, history, job_categories, regions, industries) @staticmethod def _build_resume_text(detail: ResumeDetail) -> str: """将简历数据序列化为文本供 AI 使用""" resume = detail.resume parts = [] if resume.name: parts.append(f"姓名:{resume.name}") if resume.target_position: parts.append(f"目标岗位:{resume.target_position}") if resume.skills: parts.append(f"技能:{'、'.join(resume.skills)}") if resume.certificates: parts.append(f"证书:{'、'.join(resume.certificates)}") if resume.summary: parts.append(f"个人概述:{resume.summary}") if detail.education: parts.append("教育经历:") for r in detail.education: parts.append(f" - {r.school or ''} {r.major or ''} {r.degree or ''}") if detail.work: parts.append("工作经历:") for r in detail.work: parts.append(f" - {r.company_name or ''} {r.position or ''}") if detail.internship: parts.append("实习经历:") for r in detail.internship: parts.append(f" - {r.company_name or ''} {r.position or ''}") if detail.project: parts.append("项目经历:") for r in detail.project: parts.append(f" - {r.project_name or ''} {r.role or ''}") if detail.competition: parts.append("竞赛经历:") for r in detail.competition: parts.append(f" - {r.competition_name or ''} {r.award or ''}") return "\n".join(parts) if parts else "暂无简历信息"