offerpai/offerpai_python_ai
6
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

修改接口参数

Browse Source
This commit is contained in:
zk
2026-04-08 16:55:25 +08:00
parent d79e899f7b
commit 3cf4ebaa78
2 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/api/resume_diagnose.py
+3 -7
View File
@@ -15,10 +15,6 @@ class DiagnoseParam(BaseModel):
resume_id: int = Field(..., alias="resumeId") resume_id: int = Field(..., alias="resumeId")
class ResolveParam(BaseModel):
user_feedback: int = Field(..., alias="userFeedback")
@router.post("", summary="触发简历诊断") @router.post("", summary="触发简历诊断")
async def diagnose_resume(param: DiagnoseParam): async def diagnose_resume(param: DiagnoseParam):
"""触发简历AI诊断，返回报告ID""" """触发简历AI诊断，返回报告ID"""
@@ -68,12 +64,12 @@ async def get_diagnosis_report(resume_id: int):
@router.put("/issue/{issue_id}/resolve", summary="标记问题已处理") @router.put("/issue/{issue_id}/resolve", summary="标记问题已处理")
async def resolve_issue(issue_id: int, param: ResolveParam): async def resolve_issue(issue_id: int):
"""标记诊断问题已处理 + 用户评价""" """标记诊断问题已处理"""
user_id = RequestContext.user_id.get() user_id = RequestContext.user_id.get()
async for session in get_db(): async for session in get_db():
service = ResumeDiagnoseService(session) service = ResumeDiagnoseService(session)
await service.resolve_issue(issue_id, user_id, param.user_feedback) await service.resolve_issue(issue_id, user_id)
class FeedbackParam(BaseModel): class FeedbackParam(BaseModel):
app/services/resume_diagnose_service.py
+2 -3
View File
@@ -138,8 +138,8 @@ class ResumeDiagnoseService:
"issues": [_issue_to_dict(i) for i in issues], "issues": [_issue_to_dict(i) for i in issues],
} }
async def resolve_issue(self, issue_id: int, user_id: int, user_feedback: int) -> None: async def resolve_issue(self, issue_id: int, user_id: int) -> None:
"""标记问题已处理 + 用户评价""" """标记问题已处理"""
result = await self.session.execute( result = await self.session.execute(
select(ResumeDiagnosisIssue).where( select(ResumeDiagnosisIssue).where(
ResumeDiagnosisIssue.id == issue_id, ResumeDiagnosisIssue.user_id == user_id)) ResumeDiagnosisIssue.id == issue_id, ResumeDiagnosisIssue.user_id == user_id))
@@ -147,7 +147,6 @@ class ResumeDiagnoseService:
if issue is None: if issue is None:
raise ValueError("诊断问题不存在") raise ValueError("诊断问题不存在")
issue.status = 1 issue.status = 1
issue.user_feedback = user_feedback
await self.session.flush() await self.session.flush()
async def update_feedback(self, issue_id: int, user_id: int, user_feedback: int) -> None: async def update_feedback(self, issue_id: int, user_id: int, user_feedback: int) -> None: