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

1.职位模糊查询

Browse Source
This commit is contained in:
李伟 2022-09-21 14:44:44 +08:00
parent e6e35db563
commit db8648a87f
1 changed files with 21 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -346,29 +346,31 @@ async def interview_update(
res = interview.update_interview_sql()
sql = res['sql']
# try:
inte_stage=interview.data_in.get('interview_stage',0) # 修改的简历阶段
inte_stage = interview.data_in.get('interview_stage', 0) # 修改的简历阶段
if inte_stage == 1: # 人才推荐进入初筛时分配面试官和HR
job=await crud.jobs.find_job(db,interview.data_in.get('job_id'))
#面试官
if job.get('interview'):
nickname=[]
user_id=[]
job = await crud.jobs.find_job(db, interview.data_in.get('job_id'))
# 面试官
if job.get('interview') != []:
nickname = []
user_id = []
for i in job.get('interview'):
nickname.append(i['nickname'])
user_id.append(i['user_id'])
nicknames=','.join(nickname)
user_ids=','.join(user_id)
sql = sql.replace('interview_stage = 1 ,',f"interview_stage = 1 ,interview_name = '{nicknames}',interview_id = '{user_ids}',", 1)
#hr
if job.get('patronn'):
nickname1=[]
user_id1=[]
nicknames = ','.join(nickname)
user_ids = ','.join(user_id)
sql = sql.replace('interview_stage = 1 ,',
f"interview_stage = 1 ,interview_name = '{nicknames}',interview_id = '{user_ids}',", 1)
# hr
if job.get('patronn') != []:
nickname1 = []
user_id1 = []
for i in job.get('patronn'):
nickname1.append(i['nickname'])
user_id1.append(i['user_id'])
nicknames1=','.join(nickname1)
user_ids1=','.join(user_id1)
sql=sql.replace('interview_stage = 1 ,',f"interview_stage = 1 ,hr_name = '{nicknames1}',hr_id = '{user_ids1}',",1)
nicknames1 = ','.join(nickname1)
user_ids1 = ','.join(user_id1)
sql = sql.replace('interview_stage = 1 ,',
f"interview_stage = 1 ,hr_name = '{nicknames1}',hr_id = '{user_ids1}',", 1)
data = await ckdb.execute(sql)
print(sql)
# except:
@ -1973,8 +1975,8 @@ async def send_interviewee(
user_list = [i['user_id'] for i in user['hr_name']]
send = f"""【推荐通知】\n{current_user.name}给你推荐了一位面试者\n面试者姓名：{res[0]['name']}\n岗位：{res[0]['job_names']}"""
send_dates(send, user_list)
department=','.join(user_list)
up_sql=f"""ALTER TABLE HR.resumes update department = '{department}' where uid = '{data_in.uid}'"""
department = ','.join(user_list)
up_sql = f"""ALTER TABLE HR.resumes update department = '{department}' where uid = '{data_in.uid}'"""
print(up_sql)
await ckdb.execute(up_sql)
return schemas.Msg(code=200, msg='ok', data='')
@ -2361,4 +2363,3 @@ async def hint(
res.append(i)
data = sorted(res, key=operator.itemgetter('times'))
return schemas.Msg(code=200, msg='ok', data=data)