20 lines
676 B
Python
Executable File
20 lines
676 B
Python
Executable File
from __future__ import absolute_import, unicode_literals
|
|
|
|
from celery import shared_task
|
|
from apps.hrm.models import Employee
|
|
|
|
|
|
@shared_task
|
|
def update_all_employee_not_atwork():
|
|
"""
|
|
将所有员工设为非在岗状态
|
|
"""
|
|
Employee.objects.all().update(is_atwork=False, last_check_time=None, not_work_remark=None)
|
|
|
|
@shared_task
|
|
def correct_swip_task(start_time, end_time):
|
|
from apps.monitor.models import DrfRequestLog
|
|
from apps.hrm.services import HrmService
|
|
lgs = DrfRequestLog.objects.filter(path='/api/third/dahua/c_swip/', requested_at__gte=start_time, requested_at__lte=end_time)
|
|
for i in lgs:
|
|
HrmService.swipe(data=eval(i.data)) |