generated from westfarn/web_django_template
50 lines
1.3 KiB
Python
50 lines
1.3 KiB
Python
"""Register portal nav, dashboard widgets, and due-work dispatch."""
|
|
|
|
from django.utils import timezone
|
|
|
|
from core.registry import (
|
|
register_dashboard_collector,
|
|
register_dispatcher,
|
|
register_feature,
|
|
register_portal_nav,
|
|
)
|
|
|
|
|
|
def register() -> None:
|
|
register_feature("email_sms")
|
|
register_portal_nav(
|
|
section="campaigns",
|
|
label="Campaigns",
|
|
url_name="email_sms:campaign_list",
|
|
group="Outreach",
|
|
order=20,
|
|
)
|
|
register_dashboard_collector(_dashboard)
|
|
register_dispatcher(_dispatch_due)
|
|
|
|
|
|
def _dashboard(request) -> dict:
|
|
from email_sms.models import Campaign
|
|
|
|
upcoming = Campaign.objects.exclude(
|
|
status__in=[Campaign.Status.COMPLETED, Campaign.Status.CANCELLED]
|
|
).order_by("scheduled_for", "-created_at")[:5]
|
|
return {"upcoming_campaigns": upcoming}
|
|
|
|
|
|
def _dispatch_due() -> int:
|
|
from email_sms.models import Message
|
|
from email_sms.tasks import send_campaign_message
|
|
|
|
now = timezone.now()
|
|
enqueued = 0
|
|
for message in Message.objects.filter(
|
|
status=Message.Status.SCHEDULED,
|
|
scheduled_for__lte=now,
|
|
).iterator():
|
|
message.status = Message.Status.QUEUED
|
|
message.save(update_fields=["status", "updated_at"])
|
|
send_campaign_message.enqueue(message_id=str(message.pk))
|
|
enqueued += 1
|
|
return enqueued
|