leguadmin/prs_server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

1.修改附件逻辑

Browse Source
This commit is contained in:
李伟 2022-09-28 14:17:12 +08:00
parent 7eaea90d7c
commit 2f9ef29bf8
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
api/api_v1/endpoints/interview.py
View File

@ -1071,7 +1071,6 @@ async def find_criterion(
@router.post("/resume_affix") @router.post("/resume_affix")
async def resume_affix( async def resume_affix(
request: Request, request: Request,
data_in: schemas.Post_uid,
file: UploadFile = File(...), file: UploadFile = File(...),
ckdb: CKDrive = Depends(get_ck_db), ckdb: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user) current_user: schemas.UserDB = Depends(deps.get_current_user)
@ -1088,7 +1087,7 @@ async def resume_affix(
f.write(contents) f.write(contents)
f.close() f.close()
except: except:
return schemas.Msg(code=400, msg='上传文件有误', data=None) return schemas.Msg(code=400, msg='上传文件有误', data='')
try: try:
# 附件正常上传到华为云 # 附件正常上传到华为云
res = obsClient.putFile('legu-cdn-source', 'hrms/accessory/' + filename, path_data + '/' + filename) res = obsClient.putFile('legu-cdn-source', 'hrms/accessory/' + filename, path_data + '/' + filename)
@ -1096,19 +1095,20 @@ async def resume_affix(
# 地址 # 地址
url = res.body.objectUrl url = res.body.objectUrl
resData = {'file_url': url, 'filename': 'hrms/accessory/' + filename} resData = {'file_url': url, 'filename': 'hrms/accessory/' + filename}
sql = f""" res=json.dumps(resData)
ALTER table HR.resumes update resume_affix_id = {url} WHERE uid = '{data_in.uid}' # sql = f"""
""" # ALTER table HR.resumes update resume_affix_id = {url} WHERE uid = '{data_in.uid}'
await ckdb.execute(sql) # """
return schemas.Msg(code=200, msg='ok', data=resData) # await ckdb.execute(sql)
return schemas.Msg(code=200, msg='ok', data=res)
else: else:
# print('errorCode:', res.errorCode) # print('errorCode:', res.errorCode)
# print('errorMessage:', res.errorMessage) # print('errorMessage:', res.errorMessage)
return schemas.Msg(code=400, msg='上传华为云失败', data=None) return schemas.Msg(code=400, msg='上传华为云失败', data='')
except: except:
import traceback import traceback
print(traceback.format_exc()) print(traceback.format_exc())
return schemas.Msg(code=400, msg='上传华为云失败', data=None) return schemas.Msg(code=400, msg='上传华为云失败', data='')
@router.post("/updata_entry") @router.post("/updata_entry")
@ -2152,7 +2152,7 @@ async def add_interviewee(
@router.post("/head_to_hw") @router.post("/head_to_hw")
async def head_to_hw( async def head_to_hw(
request: Request, request: Request,
data_in: schemas.Post_uid, # data_in: schemas.Post_uid,
file: UploadFile = File(...), file: UploadFile = File(...),
ckdb: CKDrive = Depends(get_ck_db), ckdb: CKDrive = Depends(get_ck_db),
current_user: schemas.UserDB = Depends(deps.get_current_user) current_user: schemas.UserDB = Depends(deps.get_current_user)