Pieteikums saņemts

# ============================================================= # pieteikumi/views.py — Pieteikumu API # ============================================================= # Izmaiņas: # ✅ Klienta apstiprinājuma e-pasts pēc pieteikuma iesniegšanas # ✅ Admina paziņojums (nemainīts) # ✅ HTML e-pasta veidne ar Matrix stilu # ============================================================= import logging from rest_framework import viewsets, permissions, status from rest_framework.response import Response from django.core.mail import send_mail, EmailMultiAlternatives from django.conf import settings from .models import Pieteikums from .serializers import PieteikumsSerializer, PieteikumsCreateSerializer logger = logging.getLogger(__name__) class PieteikumsViewSet(viewsets.ModelViewSet): """ Pieteikumu CRUD. GET /api/pieteikumi/ — saraksts (filtrēts pēc lomas) POST /api/pieteikumi/ — jauns pieteikums (tikai klients) GET /api/pieteikumi/ — detaļas RBAC: - Klients → redz un veido TIKAI savus - Admins → redz VISUS, nevar veidot """ permission_classes = [permissions.IsAuthenticated] def get_serializer_class(self): if self.action == "create": return PieteikumsCreateSerializer return PieteikumsSerializer def get_queryset(self): user = self.request.user if user.is_staff or getattr(user, "role", "") in ("admin", "superadmin"): return Pieteikums.objects.select_related("iesniedzejs").all() return Pieteikums.objects.select_related("iesniedzejs").filter( iesniedzejs=user ) def perform_create(self, serializer): pieteikums = serializer.save(iesniedzejs=self.request.user) # Sūtam abus e-pastus self._notify_admin(pieteikums) self._notify_client(pieteikums) def create(self, request, *args, **kwargs): write_ser = PieteikumsCreateSerializer(data=request.data) write_ser.is_valid(raise_exception=True) self.perform_create(write_ser) read_ser = PieteikumsSerializer(write_ser.instance) return Response(read_ser.data, status=status.HTTP_201_CREATED) # ── ADMINA PAZIŅOJUMS ───────────────────────────────────── def _notify_admin(self, p: Pieteikums): """Nosūta e-pasta paziņojumu adminam par jaunu pieteikumu.""" admin_email = getattr(settings, "ADMIN_EMAIL", None) or getattr( settings, "EMAIL_HOST_USER", None ) if not admin_email: logger.warning("ADMIN_EMAIL nav iestatīts — admina e-pasts netika nosūtīts.") return user = p.iesniedzejs client_name = getattr(user, "full_name", None) or user.email subject = f"🔔 MIM — Jauns Pieteikums #{p.pk} no {client_name}" text_body = ( f"Jauns projekta pieteikums saņemts!\n\n" f"{'─'*40}\n" f"ID: #{p.pk}\n" f"Klients: {client_name} ({user.email})\n" f"Nosaukums: {p.nosaukums}\n" f"Tips: {p.get_tips_display()}\n" f"Budžets: {p.budzets or 'Nav norādīts'}\n" f"Termiņš: {p.termins or 'Nav norādīts'}\n" f"{'─'*40}\n\n" f"APRAKSTS:\n{p.apraksts}\n\n" f"Skatīt portālā: {settings.FRONTEND_URL}/dashboard" ) try: send_mail( subject, text_body, settings.EMAIL_HOST_USER, [admin_email], fail_silently=False, ) logger.info(f"Pieteikums #{p.pk} — admina e-pasts nosūtīts uz {admin_email}") except Exception as e: logger.error(f"Pieteikums #{p.pk} — admina e-pasta kļūda: {e}") # ── KLIENTA APSTIPRINĀJUMS ──────────────────────────────── def _notify_client(self, p: Pieteikums): """Nosūta apstiprinājuma e-pastu klientam.""" user = p.iesniedzejs client_email = user.email client_name = getattr(user, "full_name", None) or client_email.split("@")[0] portal_url = getattr(settings, "PORTAL_URL", "https://mim.melgalis.lv") contact_email = getattr(settings, "ADMIN_EMAIL", settings.EMAIL_HOST_USER) subject = f"✅ Pieteikums #{p.pk} saņemts — MIM / DevSprintAI" # ── TEKSTA VERSIJA ────────────────────────────────── text_body = ( f"Labdien, {client_name}!\n\n" f"Jūsu pieteikums ir veiksmīgi saņemts. Mēs ar Jums sazināsimies " f"darba dienas laikā.\n\n" f"{'─'*40}\n" f"PIETEIKUMA DATI:\n" f" Numurs: #{p.pk}\n" f" Projekts: {p.nosaukums}\n" f" Tips: {p.get_tips_display()}\n" f" Budžets: {p.budzets or 'Nav norādīts'}\n" f" Termiņš: {p.termins or 'Nav norādīts'}\n" f"{'─'*40}\n\n" f"Sekot pieteikuma statusam:\n{portal_url}\n\n" f"Jautājumu gadījumā rakstiet: {contact_email}\n\n" f"Ar cieņu,\nDevSprintAI komanda" ) # ── HTML VERSIJA ──────────────────────────────────── html_body = f""" Pieteikums saņemts

MIM v1.0

DevSprintAI

✅

PIETEIKUMS SAŅEMTS

#{p.pk}

Labdien, {client_name}!

Jūsu pieteikums ir veiksmīgi saņemts mūsu sistēmā. Mēs ar Jums sazināsimies darba dienas laikā.

PIETEIKUMA_DATI
PROJEKTS	{p.nosaukums}
TIPS	{p.get_tips_display()}
BUDŽETS	{p.budzets or '—'}
VĒLAMAIS TERMIŅŠ	{p.termins or '—'}

NĀKAMIE_SOĻI

01. Mēs izskatīsim Jūsu pieteikumu
02. Sazināsimies ar Jums darba dienas laikā
03. Sagatavosim individuālu piedāvājumu
04. Uzsāksim projektu pēc vienošanās

SKATĪT_PORTĀLĀ →

Jautājumu gadījumā: {contact_email}

""" try: msg = EmailMultiAlternatives( subject=subject, body=text_body, from_email=settings.EMAIL_HOST_USER, to=[client_email], ) msg.attach_alternative(html_body, "text/html") msg.send(fail_silently=False) logger.info( f"Pieteikums #{p.pk} — klienta e-pasts nosūtīts uz {client_email}" ) except Exception as e: logger.error( f"Pieteikums #{p.pk} — klienta e-pasta kļūda: {e}" ) # ============================================================= # MAILBOX (SAZIŅAS) VIEWSET — ar Telegram Tiešo Rūteri # ============================================================= from .models import Message from .serializers import MessageSerializer class MessageViewSet(viewsets.ModelViewSet): serializer_class = MessageSerializer permission_classes = [permissions.IsAuthenticated] def get_queryset(self): user = self.request.user # Ja admin -> var filtrēt pēc client_id if user.is_staff or getattr(user, 'role', '') in ('admin', 'superadmin'): client_id = self.request.query_params.get('client_id') if client_id: return Message.objects.filter(client_id=client_id) return Message.objects.all() # Ja parasts KLIENTS -> Redz tikai savas pastkastes ziņas return Message.objects.filter(client=user) def perform_create(self, serializer): user = self.request.user client_id_from_request = self.request.data.get('client_id') # Ja admin atbild, viņam jānorāda `client_id` if (user.is_staff or getattr(user, 'role', '') in ('admin', 'superadmin')) and client_id_from_request: message = serializer.save(sender=user, client_id=client_id_from_request) else: # Klients raksta ziņu savā pastkastē message = serializer.save(sender=user, client=user) # ── TIEŠAIS RŪTERIS: Pārsūtam uz Telegram ── self._forward_to_telegram(message) def _forward_to_telegram(self, message): """Nosūta klienta ziņu uz Telegram admina čatu.""" try: import requests as req admin_chat_id = getattr(settings, 'TELEGRAM_ADMIN_CHAT_ID', None) bot_token = getattr(settings, 'TELEGRAM_BOT_TOKEN', None) if not admin_chat_id or not bot_token: logger.warning("TELEGRAM_ADMIN_CHAT_ID vai BOT_TOKEN nav iestatīts — ziņa netika pārsūtīta.") return client = message.client client_name = getattr(client, 'full_name', '') or client.email text = ( f"📨 *Jauna ziņa no Dashboard*\n\n" f"👤 *Klients:* {client_name}\n" f"📧 {client.email}\n\n" f"💬 _{message.content}_\n\n" f"↩️ Atbildi šeit ar /reply\\_{client.id} [tavs teksts]" ) url = f"https://api.telegram.org/bot{bot_token}/sendMessage" payload = { "chat_id": admin_chat_id, "text": text, "parse_mode": "Markdown", } resp = req.post(url, json=payload, timeout=10) resp.raise_for_status() logger.info(f"Mailbox ziņa pārsūtīta uz Telegram (client={client.email})") except Exception as e: logger.error(f"Telegram pārsūtīšanas kļūda: {e}") # ============================================================= # ADMIN KLIENTU API (Aģentūras Iekšējais Dashboards) # ============================================================= from django.db.models import Count, Sum, Q, Max from mim_auth.models import UserPanelis class AdminClientListView(viewsets.ViewSet): """ GET /api/admin/clients/ — Atgriež visu klientu sarakstu ar agregētiem datiem. Pieejams TIKAI adminiem (is_staff=True). """ permission_classes = [permissions.IsAuthenticated] def list(self, request): if not request.user.is_staff: return Response({"detail": "Nav atļaujas."}, status=status.HTTP_403_FORBIDDEN) clients = UserPanelis.objects.filter( is_staff=False # Tikai klientus, ne adminus ).annotate( project_count=Count('projekti', distinct=True), active_project_count=Count('projekti', filter=Q(projekti__statuss__in=['AKTĪVS', 'PROCESĀ']), distinct=True), invoice_count=Count('invoices', distinct=True), unpaid_invoice_count=Count('invoices', filter=Q(invoices__status='unpaid'), distinct=True), unpaid_total=Sum('invoices__amount', filter=Q(invoices__status='unpaid')), message_count=Count('client_messages', distinct=True), last_message_at=Max('client_messages__created_at'), task_count=Count('assigned_tasks', distinct=True), ).order_by('-last_message_at', '-id') data = [] for c in clients: data.append({ "id": c.id, "email": c.email, "full_name": c.full_name or "", "role": c.role, "is_active": c.is_active, # DROŠĪBA (HIGH-06): telegram_id nav atklāts — tikai boolean "telegram_linked": c.telegram_id is not None, "date_joined": c.date_joined.isoformat() if hasattr(c, 'date_joined') else None, "terms_accepted": c.terms_accepted, "project_count": c.project_count or 0, "active_project_count": c.active_project_count or 0, "invoice_count": c.invoice_count or 0, "unpaid_invoice_count": c.unpaid_invoice_count or 0, "unpaid_total": float(c.unpaid_total or 0), "message_count": c.message_count or 0, "last_message_at": c.last_message_at.isoformat() if c.last_message_at else None, "task_count": c.task_count or 0, }) return Response(data)