|
15 | 15 | MinValueValidator, |
16 | 16 | MinLengthValidator, |
17 | 17 | ) |
| 18 | +from django_email_learning.services.email_sender_service import EmailSenderService |
| 19 | +from django.core.mail import EmailMultiAlternatives |
| 20 | +from django.template.loader import render_to_string |
18 | 21 | from django.core.exceptions import ImproperlyConfigured |
19 | 22 | from cryptography.fernet import Fernet, InvalidToken |
20 | 23 | from cryptography.hazmat.primitives.kdf.pbkdf2 import PBKDF2HMAC |
21 | 24 | from cryptography.hazmat.primitives import hashes |
22 | 25 | from django.forms import ValidationError |
23 | 26 | from django.contrib.auth.models import User |
24 | 27 | from django.utils import timezone |
| 28 | +from django.utils.translation import gettext as _ |
25 | 29 | from datetime import timedelta |
26 | 30 | from django_email_learning.services import jwt_service |
| 31 | + |
27 | 32 | from PIL import Image |
28 | 33 | from typing import Optional |
| 34 | +from datetime import datetime |
29 | 35 |
|
30 | 36 |
|
31 | 37 | logger = logging.getLogger(__name__) |
@@ -522,16 +528,58 @@ class Meta: |
522 | 528 | ] |
523 | 529 |
|
524 | 530 | def graduate(self) -> None: |
525 | | - if self.status != EnrollmentStatus.ACTIVE: |
526 | | - raise ValidationError("Only active enrollments can be marked as completed.") |
527 | | - self.status = EnrollmentStatus.COMPLETED |
528 | | - self.final_state_at = timezone.now() |
529 | | - logger.info( |
530 | | - f"Learner ID {self.learner.id} has completed the course {self.course.title}." |
| 531 | + with transaction.atomic(): |
| 532 | + if self.status != EnrollmentStatus.ACTIVE: |
| 533 | + raise ValidationError( |
| 534 | + "Only active enrollments can be marked as completed." |
| 535 | + ) |
| 536 | + self.status = EnrollmentStatus.COMPLETED |
| 537 | + self.final_state_at = timezone.now() |
| 538 | + logger.info( |
| 539 | + f"Learner ID {self.learner.id} has completed the course {self.course.title}." |
| 540 | + ) |
| 541 | + self.save() |
| 542 | + self.send_certificate_form() |
| 543 | + |
| 544 | + def send_certificate_form(self) -> None: |
| 545 | + if self.status != EnrollmentStatus.COMPLETED: |
| 546 | + raise ValidationError( |
| 547 | + "Certificate form can only be sent for completed enrollments." |
| 548 | + ) |
| 549 | + token_payload = { |
| 550 | + "enrollment_id": self.id, |
| 551 | + } |
| 552 | + logging.info( |
| 553 | + f"Executing SendCertificateFormCommand for enrollment ID {self.id}" |
531 | 554 | ) |
| 555 | + token = jwt_service.generate_jwt(token_payload, exp=datetime.max) |
| 556 | + certificate_path = reverse( |
| 557 | + "django_email_learning:personalised:certificate_form" |
| 558 | + ) |
| 559 | + link = f"{settings.DJANGO_EMAIL_LEARNING['SITE_BASE_URL']}{certificate_path}?token={token}" |
532 | 560 |
|
533 | | - # TODO: send certificate email here |
534 | | - self.save() |
| 561 | + subject = _("Finalize your Certificate") |
| 562 | + |
| 563 | + context = { |
| 564 | + "course_title": self.course.title, |
| 565 | + "organization_name": self.course.organization.name, |
| 566 | + "link": link, |
| 567 | + } |
| 568 | + payload = render_to_string("emails/certificate_form.txt", context) |
| 569 | + |
| 570 | + email_service = EmailSenderService() |
| 571 | + email_message = EmailMultiAlternatives( |
| 572 | + subject=subject, |
| 573 | + body=payload, |
| 574 | + from_email=email_service.from_email, |
| 575 | + to=[self.learner.email], |
| 576 | + ) |
| 577 | + email_message.attach_alternative( |
| 578 | + render_to_string("emails/certificate_form.html", context), "text/html" |
| 579 | + ) |
| 580 | + |
| 581 | + email_service.send(email_message) |
| 582 | + logging.info(f"Certificate form email sent for enrollment ID {self.id}") |
535 | 583 |
|
536 | 584 | def fail(self) -> None: |
537 | 585 | if self.status != EnrollmentStatus.ACTIVE: |
@@ -565,6 +613,31 @@ def schedule_first_content_delivery(self) -> None: |
565 | 613 | raise ValidationError("No published content available to schedule.") |
566 | 614 |
|
567 | 615 |
|
| 616 | +class Certificate(models.Model): |
| 617 | + enrollment = models.OneToOneField( |
| 618 | + Enrollment, on_delete=models.CASCADE, related_name="certificate" |
| 619 | + ) |
| 620 | + issued_at = models.DateTimeField(auto_now_add=True) |
| 621 | + name_on_certificate = models.CharField(max_length=200) |
| 622 | + random_suffix = models.IntegerField() |
| 623 | + |
| 624 | + @property |
| 625 | + def certificate_number(self) -> str: |
| 626 | + return f"{self.enrollment.course.id}-{self.enrollment.id}-{self.id}-{self.random_suffix}" |
| 627 | + |
| 628 | + def save( # type: ignore[no-untyped-def] |
| 629 | + self, *, force_insert=False, force_update=False, using=None, update_fields=None |
| 630 | + ): |
| 631 | + if not self.random_suffix: |
| 632 | + self.random_suffix = random.randint(100000, 999999) |
| 633 | + return super().save( |
| 634 | + force_insert=force_insert, |
| 635 | + force_update=force_update, |
| 636 | + using=using, |
| 637 | + update_fields=update_fields, |
| 638 | + ) |
| 639 | + |
| 640 | + |
568 | 641 | class ContentDelivery(models.Model): |
569 | 642 | enrollment = models.ForeignKey( |
570 | 643 | Enrollment, on_delete=models.CASCADE, related_name="content_deliveries" |
@@ -664,6 +737,7 @@ class DeliverySchedule(models.Model): |
664 | 737 | db_index=True, |
665 | 738 | ) |
666 | 739 | failed_attempts = models.IntegerField(default=0) |
| 740 | + delivered_at = models.DateTimeField(null=True, blank=True) |
667 | 741 |
|
668 | 742 | def generate_link(self) -> str: |
669 | 743 | payload = { |
@@ -695,6 +769,11 @@ def generate_link(self) -> str: |
695 | 769 | def __str__(self) -> str: |
696 | 770 | return f"Delivery for {self.delivery.course_content.title} to {self.delivery.enrollment.learner.email} at {self.time} - Status: {self.status}" |
697 | 771 |
|
| 772 | + def save(self, *args, **kwargs) -> None: # type: ignore[no-untyped-def] |
| 773 | + if self.status == DeliveryStatus.DELIVERED and not self.delivered_at: |
| 774 | + self.delivered_at = timezone.now() |
| 775 | + super().save(*args, **kwargs) |
| 776 | + |
698 | 777 |
|
699 | 778 | class QuizSubmission(models.Model): |
700 | 779 | delivery = models.ForeignKey( |
|
0 commit comments