31 lines
878 B
Python
31 lines
878 B
Python
from __future__ import absolute_import, unicode_literals
|
|
|
|
from celery import shared_task
|
|
from apps.hrm.models import Employee
|
|
from apps.system.models import User
|
|
from django.core.cache import cache
|
|
|
|
|
|
@shared_task
|
|
def update_all_user_not_atwork():
|
|
"""
|
|
将所有员工设为非在岗状态
|
|
"""
|
|
User.objects.all().update(is_atwork=False, last_check_time = None)
|
|
|
|
@shared_task
|
|
def update_all_user_facedata_cache():
|
|
"""
|
|
更新人脸数据缓存
|
|
"""
|
|
facedata_queyset = Employee.objects.filter(face_data__isnull=False,
|
|
user__is_active=True).values('user', 'face_data')
|
|
face_users = []
|
|
face_datas = []
|
|
for i in facedata_queyset:
|
|
face_users.append(i['user'])
|
|
face_datas.append(i['face_data'])
|
|
cache.set('face_users', face_users, timeout=None)
|
|
cache.set('face_datas', face_datas, timeout=None)
|
|
|
|
|