mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-10-22 00:09:14 +00:00
b4cf540e51
* [Update] 操作日志 Model Need Record 添加RemoteApp、DatabaseApp、DatabaseAppPermission * [Update] 用户登录日志，采用同步机制 * [Update] 修改DatabaseApp API权限OrgAdmin和AppUser
34 lines
911 B
Python
34 lines
911 B
Python
# -*- coding: utf-8 -*-
|
|
#
|
|
import datetime
|
|
from django.utils import timezone
|
|
from django.conf import settings
|
|
from celery import shared_task
|
|
|
|
from ops.celery.decorator import register_as_period_task
|
|
from .models import UserLoginLog, OperateLog
|
|
|
|
|
|
@register_as_period_task(interval=3600*24)
|
|
@shared_task
|
|
def clean_login_log_period():
|
|
now = timezone.now()
|
|
try:
|
|
days = int(settings.LOGIN_LOG_KEEP_DAYS)
|
|
except ValueError:
|
|
days = 90
|
|
expired_day = now - datetime.timedelta(days=days)
|
|
UserLoginLog.objects.filter(datetime__lt=expired_day).delete()
|
|
|
|
|
|
@register_as_period_task(interval=3600*24)
|
|
@shared_task
|
|
def clean_operation_log_period():
|
|
now = timezone.now()
|
|
try:
|
|
days = int(settings.LOGIN_LOG_KEEP_DAYS)
|
|
except ValueError:
|
|
days = 90
|
|
expired_day = now - datetime.timedelta(days=days)
|
|
OperateLog.objects.filter(datetime__lt=expired_day).delete()
|