# (c) cavaliba.com - sirene - sms_view.py

from app_home.configuration import get_configuration
from app_home.log import DEBUG, INFO, WARNING, log

# Celery tasks
from app_sirene.notify import task_send_sms
from app_user.aaa import start_view
from django.contrib import messages
from django.db.models import Count
from django.db.models.functions import ExtractDay, ExtractMonth, ExtractYear
from django.shortcuts import redirect, render
from django.utils.translation import gettext as _

from .forms import SMSForm
from .models import SMSJournal
from .sms import get_sms_quota, sms_check_valid_number

# -------------------------------------------
#
# -------------------------------------------

def sms_send(request):

    context = start_view(request, app="sirene", view="sms_send",
        noauth="app_sirene:index", perm="p_sirene_sms_send", noauthz="app_sirene:private")
    if context["redirect"]:
        return redirect(context["redirect"])
    aaa = context["aaa"]

    if get_sms_quota(aaa) < 1:
        messages.add_message(request, messages.ERROR, _("Insufficient SMS Quota"))
        log(WARNING, aaa=aaa, app="sirene", view="sms", action="quota", status="KO", data="insufficient SMS quota")
        return redirect("app_sirene:private")

    if request.method == "POST":

        form = SMSForm(request.POST)
        if form.is_valid():

            cd = form.cleaned_data
            mobile = cd["mobile"]
            message= cd["message"]

            if not sms_check_valid_number(mobile):
                messages.add_message(request, messages.ERROR, _("Invalid SMS number"))
                log(WARNING, aaa=aaa, app="sirene", view="sms", action="send", status="KO", data="Invalid number")
            else:
                task_send_sms.delay([mobile], message, aaa=aaa)
                messages.add_message(request, messages.SUCCESS, _("SMS sent"))
                log(INFO, aaa=aaa, app="sirene", view="sms", action="send", status="OK", data="Queued")
                return redirect("app_sirene:private")
    else:
        form = SMSForm()
        log(DEBUG, aaa=aaa, app="sirene", view="sms", action="form", status="OK", data="Get form")

    context["sms_warning"] = get_configuration("sirene", "SMS_WARNING")
    context["form"] = form
    return render(request, 'app_sirene/sms_send.html', context)


#-----------------------------------------
#  SMS journal
#-----------------------------------------
def sms_journal(request):

    context = start_view(request, app="sirene", view="sms_journal",
        noauth="app_sirene:index", perm="p_sirene_sms_journal", noauthz="app_sirene:private")
    if context["redirect"]:
        return redirect(context["redirect"])
    aaa = context["aaa"]

    bigset_size = int(get_configuration("data", "DATA_BIGSET_SIZE"))
    count = SMSJournal.objects.count()
    context["count"] = count
    context["bigset"] = True

    # Search query (POST)
    import re
    query = ""
    if request.method == "POST":
        if request.POST.get('query'):
            query = request.POST.get('query')
            m = re.compile(r'[a-zA-Z0-9()_/.-]*$')
            if not m.match(query):
                query = ""
    context["query"] = query

    # Pagination (GET)
    try:
        size = int(request.GET.get("size", bigset_size))
        page = int(request.GET.get("page", 1))
    except Exception:
        return redirect("app_sirene:sms_journal")

    if page < 1 or size > 10000 or size < 1:
        return redirect("app_sirene:sms_journal")

    offset = (page - 1) * size
    limit = offset + size

    qs = SMSJournal.objects.order_by('-created_at')
    if query:
        qs = qs.filter(created_by__icontains=query)

    journal = qs[offset:limit]

    log(DEBUG, aaa=aaa, app="sirene", view="sms", action="journal", status="OK", data=f"{count} entries")

    # Pagination context
    context["size"] = size
    context["page"] = page
    page_last = int(count / size) + 1
    context["page_prev"] = max(page - 1, 1)
    context["page_first"] = (page == 1)
    context["page_current"] = (1 < page < page_last)
    context["page_last"] = page_last
    context["page_last_active"] = (page >= page_last)
    context["page_next"] = min(page + 1, page_last)

    context["journal"] = journal
    return render(request, 'app_sirene/sms_journal.html', context)



#-----------------------------------------
#  SMS stats
#-----------------------------------------
def sms_stat(request):

    context = start_view(request, app="sirene", view="sms_stat",
        noauth="app_sirene:index", perm="p_sirene_sms_stat", noauthz="app_sirene:private")
    if context["redirect"]:
        return redirect(context["redirect"])
    aaa = context["aaa"]


    stat_year = (SMSJournal.objects
        .annotate(year=ExtractYear('created_at'))
        .values('year')
        .annotate(count=Count('id'))
        .annotate(numsender=Count('created_by', distinct=True))
        .annotate(numdest=Count('mobile', distinct=True))
    )

    stat_month = (SMSJournal.objects
        .annotate(year=ExtractYear('created_at'))
        .annotate(month=ExtractMonth('created_at'))
        .values('year','month')
        .annotate(count=Count('id'))
        .annotate(numsender=Count('created_by', distinct=True))
        .annotate(numdest=Count('mobile', distinct=True))
    )


    stat_day = (SMSJournal.objects
        .annotate(year=ExtractYear('created_at'))
        .annotate(month=ExtractMonth('created_at'))
        .annotate(day=ExtractDay('created_at'))
        .values('year', 'month', 'day')
        .annotate(count=Count('id'))
        .annotate(numsender=Count('created_by', distinct=True))
        .annotate(numdest=Count('mobile', distinct=True))
    )

    log(DEBUG, aaa=aaa, app="sirene", view="sms", action="stat", status="OK", data="Get form")

    context["stat_year"] = stat_year
    context["stat_month"] = stat_month
    context["stat_day"] = stat_day
    return render(request, 'app_sirene/sms_stat.html', context)