diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index d699b0f..918ce2f 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -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) # 修改的简历阶段 - 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=[] + 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 = [] 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) -