diff --git a/apps/rpm/tasks.py b/apps/rpm/tasks.py index aa24d3f9..8d314a34 100644 --- a/apps/rpm/tasks.py +++ b/apps/rpm/tasks.py @@ -5,6 +5,7 @@ from apps.rpm.services import rpj_member_leave from apps.utils.tasks import CustomTask from celery import shared_task from django.utils import timezone +from datetime import datetime @shared_task(base=CustomTask) @@ -30,3 +31,13 @@ def close_rpj_by_leave_time(): for m in Rpjmember.objects.filter(rpj__in=rpjs): rpj_member_leave(m) + + +def check_remployee_leave(): + """ + 检查相关方是否已经离开 + """ + now = datetime.now() + now_str = now.strftime('%Y-%m-%d %H:%M:%S') + from apps.hrm.models import Employee + Employee.objects.filter(type='remployee', third_info__dh_face_card_end__lte=now_str).update(job_state=Employee.JOB_OFF) \ No newline at end of file