修改数据量连接为关闭异常
This commit is contained in:
@@ -91,15 +91,18 @@ async def save(user_id: int, job_id: int, cr: CustomizeResume) -> None:
|
|||||||
|
|
||||||
async def get(user_id: int, job_id: int) -> dict | None:
|
async def get(user_id: int, job_id: int) -> dict | None:
|
||||||
"""查询定制简历,查不到则加载默认简历构建返回"""
|
"""查询定制简历,查不到则加载默认简历构建返回"""
|
||||||
|
data = None
|
||||||
async for session in get_db():
|
async for session in get_db():
|
||||||
result = await session.execute(select(UserJobCustomizeResume).where(
|
result = await session.execute(select(UserJobCustomizeResume).where(
|
||||||
UserJobCustomizeResume.user_id == user_id, UserJobCustomizeResume.job_id == job_id))
|
UserJobCustomizeResume.user_id == user_id, UserJobCustomizeResume.job_id == job_id))
|
||||||
record = result.scalar_one_or_none()
|
record = result.scalar_one_or_none()
|
||||||
if record:
|
if record:
|
||||||
return CustomizeResume.model_validate(record.content).model_dump(by_alias=True)
|
data = CustomizeResume.model_validate(record.content).model_dump(by_alias=True)
|
||||||
|
else:
|
||||||
# 没有定制简历,加载默认简历构建
|
# 没有定制简历,加载默认简历构建
|
||||||
detail = await load_default_resume_detail(session, user_id)
|
detail = await load_default_resume_detail(session, user_id)
|
||||||
return build_from_detail(detail).model_dump(by_alias=True)
|
data = build_from_detail(detail).model_dump(by_alias=True)
|
||||||
|
return data
|
||||||
|
|
||||||
|
|
||||||
async def rollback(user_id: int, job_id: int) -> None:
|
async def rollback(user_id: int, job_id: int) -> None:
|
||||||
|
|||||||
Reference in New Issue
Block a user