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

1.修改各种通知，改换成待办通知

Browse Source
This commit is contained in:
李伟 2022-10-17 15:49:13 +08:00
parent 92c97792bb
commit 6b44817fa5
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -32,6 +32,7 @@ from datetime import timedelta
from models.interview_zsgc import InterviewDo from models.interview_zsgc import InterviewDo
from utils import get_time, qujian_time, Download_xlsx, send_str_mail, doc2pdf, png2pdf from utils import get_time, qujian_time, Download_xlsx, send_str_mail, doc2pdf, png2pdf
from LAC import LAC from LAC import LAC
lac = LAC(mode='lac') lac = LAC(mode='lac')
router = APIRouter() router = APIRouter()
@ -419,7 +420,9 @@ async def interview_update(
content = f"""【淘汰通知】\n姓名：{interview_id[0]['name']}\n求职岗位：{interview_id[0]['job_names']}\n淘汰原因：{why}\n简历阶段：{interview_stage}\n操作人：{current_user.nickname}""" content = f"""【淘汰通知】\n姓名：{interview_id[0]['name']}\n求职岗位：{interview_id[0]['job_names']}\n淘汰原因：{why}\n简历阶段：{interview_stage}\n操作人：{current_user.nickname}"""
else: else:
content = f"""【淘汰通知】\n姓名：{interview_id[0]['name']}\n求职岗位：{interview_id[0]['job_names']}\n淘汰原因：{why}\n具体淘汰原因：{interview.data_in.get('pass_text')}\n简历阶段：{interview_stage}\n操作人：{current_user.nickname}""" content = f"""【淘汰通知】\n姓名：{interview_id[0]['name']}\n求职岗位：{interview_id[0]['job_names']}\n淘汰原因：{why}\n具体淘汰原因：{interview.data_in.get('pass_text')}\n简历阶段：{interview_stage}\n操作人：{current_user.nickname}"""
send_dates(content, userid_list) if current_user.name != 'root':
# send_dates(content, userid_list)# 工作通知
Sample.create_task('淘汰通知', current_user.user_id, content, userid_list) # 待办通知
return schemas.Msg(code=200, msg='ok', data=data) return schemas.Msg(code=200, msg='ok', data=data)
@ -1532,8 +1535,10 @@ async def teacher_state(
# 同步钉钉发消息给面试官 # 同步钉钉发消息给面试官
try: try:
now_time = str(datetime.now()).split('.')[0] now_time = str(datetime.now()).split('.')[0]
if current_user.name != 'root':
content = f"【催促反馈】\n请面试官尽快给{data_in.name}做面试反馈\n提醒时间：{now_time}" content = f"【催促反馈】\n请面试官尽快给{data_in.name}做面试反馈\n提醒时间：{now_time}"
send_dates(content, data_in.user_id) #send_dates(content, data_in.user_id)#工作通知
Sample.create_task('催促反馈',current_user.user_id,content,data_in.user_id) # 待办通知
return schemas.Msg(code=200, msg='发送成功', data='') return schemas.Msg(code=200, msg='发送成功', data='')
except Exception: except Exception:
return schemas.Msg(code=-9, msg='发送失败', data='') return schemas.Msg(code=-9, msg='发送失败', data='')
@ -2379,8 +2384,10 @@ async def send_interviewee(
if not user: if not user:
return schemas.Msg(code=-9, msg='职位不存在', data='') return schemas.Msg(code=-9, msg='职位不存在', data='')
user_list = [i['user_id'] for i in user['hr_name']] user_list = [i['user_id'] for i in user['hr_name']]
if current_user.name != 'root':
send = f"""【推荐通知】\n{current_user.nickname}给你推荐了一位面试者\n面试者姓名：{res[0]['name']}\n岗位：{res[0]['job_names']}""" send = f"""【推荐通知】\n{current_user.nickname}给你推荐了一位面试者\n面试者姓名：{res[0]['name']}\n岗位：{res[0]['job_names']}"""
send_dates(send, user_list) # send_dates(send, user_list) #工作通知
Sample.create_task('推荐通知', current_user.user_id, send, user_list) # 待办通知
department = ','.join(user_list) department = ','.join(user_list)
up_sql = f"""ALTER TABLE HR.resumes update department = '{department}' where uid = '{data_in.uid}'""" up_sql = f"""ALTER TABLE HR.resumes update department = '{department}' where uid = '{data_in.uid}'"""
print(up_sql) print(up_sql)
@ -2419,7 +2426,9 @@ async def add_interviewee(
send = f"""【面试通知】\n面试岗位：{df['job_names'][0]}\n面试时间：{data_in.star_time}\n面试者：{df['name'][0]}\nHR：{hr_names}\n面试官：{interview_names}""" send = f"""【面试通知】\n面试岗位：{df['job_names'][0]}\n面试时间：{data_in.star_time}\n面试者：{df['name'][0]}\nHR：{hr_names}\n面试官：{interview_names}"""
hr_user = data_in.hr_user hr_user = data_in.hr_user
hr_user.extend(data_in.user_id) hr_user.extend(data_in.user_id)
send_dates(send, hr_user) if current_user.name != 'root':
# send_dates(send, hr_user)#工作通知
Sample.create_task('面试通知', current_user.user_id, send, hr_user) # 待办通知
find_sql = f""" find_sql = f"""
select uid,name,interview_name,hr_name,star_time,interview_sign,interview_id,job_id,job_names,mail from HR.resumes where uid = '{data_in.uid}' select uid,name,interview_name,hr_name,star_time,interview_sign,interview_id,job_id,job_names,mail from HR.resumes where uid = '{data_in.uid}'
""" """