From 6b44817fa58f043f7307e2e080798a61c4006b92 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E4=BC=9F?= <250213850@qq.com> Date: Mon, 17 Oct 2022 15:49:13 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E5=90=84=E7=A7=8D=E9=80=9A?= =?UTF-8?q?=E7=9F=A5=EF=BC=8C=E6=94=B9=E6=8D=A2=E6=88=90=E5=BE=85=E5=8A=9E?= =?UTF-8?q?=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/api_v1/endpoints/interview.py | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/api/api_v1/endpoints/interview.py b/api/api_v1/endpoints/interview.py index ac23ec6..e8ce57f 100644 --- a/api/api_v1/endpoints/interview.py +++ b/api/api_v1/endpoints/interview.py @@ -32,6 +32,7 @@ from datetime import timedelta from models.interview_zsgc import InterviewDo from utils import get_time, qujian_time, Download_xlsx, send_str_mail, doc2pdf, png2pdf from LAC import LAC + lac = LAC(mode='lac') 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}""" 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}""" - 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) @@ -965,7 +968,7 @@ async def files_to_hw( break if not user_chk_name: user_chk_name = file.split('.')[0] - files_other = [i for i in file_list if user_chk_name in i and i !=file] + files_other = [i for i in file_list if user_chk_name in i and i != file] # 存在相关附件 if files_other: resume_affix_id = [] @@ -1532,8 +1535,10 @@ async def teacher_state( # 同步钉钉发消息给面试官 try: now_time = str(datetime.now()).split('.')[0] - content = f"【催促反馈】\n请面试官尽快给{data_in.name}做面试反馈\n提醒时间：{now_time}" - send_dates(content, data_in.user_id) + if current_user.name != 'root': + content = f"【催促反馈】\n请面试官尽快给{data_in.name}做面试反馈\n提醒时间：{now_time}" + #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='') except Exception: return schemas.Msg(code=-9, msg='发送失败', data='') @@ -2379,8 +2384,10 @@ async def send_interviewee( if not user: return schemas.Msg(code=-9, msg='职位不存在', data='') user_list = [i['user_id'] for i in user['hr_name']] - send = f"""【推荐通知】\n{current_user.nickname}给你推荐了一位面试者\n面试者姓名：{res[0]['name']}\n岗位：{res[0]['job_names']}""" - send_dates(send, user_list) + if current_user.name != 'root': + send = f"""【推荐通知】\n{current_user.nickname}给你推荐了一位面试者\n面试者姓名：{res[0]['name']}\n岗位：{res[0]['job_names']}""" + # send_dates(send, user_list) #工作通知 + Sample.create_task('推荐通知', current_user.user_id, send, user_list) # 待办通知 department = ','.join(user_list) up_sql = f"""ALTER TABLE HR.resumes update department = '{department}' where uid = '{data_in.uid}'""" 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}""" hr_user = data_in.hr_user 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""" 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}' """