45 lines
1.8 KiB
Python
45 lines
1.8 KiB
Python
"""
|
||
تشخیصِ «نصفه‌رها» (abandoned) با سیگنال قابل انجام نیست چون به گذر زمانِ
|
||
بدون هیچ رویدادی نیاز داره، نه یک event مشخص؛ برای همین management
|
||
commandه، نه receiver. باید periodic اجرا بشه (cron / celery beat)،
|
||
مثلاً یک‌بار در روز:
|
||
|
||
python manage.py mark_abandoned_node_progress
|
||
|
||
آستانه از settings.NODE_PROGRESS_ABANDON_DAYS خونده می‌شه (پیش‌فرض ۱۴ روز).
|
||
"""
|
||
from django.conf import settings
|
||
from django.core.management.base import BaseCommand
|
||
from django.utils import timezone
|
||
|
||
from content.models import NodeProgress
|
||
from statuslog.signals import status_changed
|
||
|
||
|
||
class Command(BaseCommand):
|
||
help = 'رکوردهای NodeProgress در حال انجام که مدت‌ها فعالیتی نداشته‌اند را نصفه‌رها (abandoned) علامت می‌زند.'
|
||
|
||
def handle(self, *args, **options):
|
||
abandon_days = getattr(settings, 'NODE_PROGRESS_ABANDON_DAYS', 14)
|
||
threshold = timezone.now() - timezone.timedelta(days=abandon_days)
|
||
|
||
stale_qs = NodeProgress.objects.filter(
|
||
status='in_progress', last_activity_at__lt=threshold,
|
||
)
|
||
|
||
count = 0
|
||
for progress in stale_qs:
|
||
old_status = progress.status
|
||
progress.status = 'abandoned'
|
||
progress.save(update_fields=['status'])
|
||
status_changed.send(
|
||
sender='content.NodeProgress', object_id=progress.id,
|
||
old_status=old_status, new_status='abandoned',
|
||
event='inactivity_timeout', user_id=progress.user_id,
|
||
)
|
||
count += 1
|
||
|
||
self.stdout.write(self.style.SUCCESS(
|
||
f'{count} رکورد NodeProgress به abandoned تغییر کرد (آستانه: {abandon_days} روز).'
|
||
))
|