online_test/notification/tasks.py at 47a34cee3e4caa9acfb2a972baa47e74471e49f0 · FOSSEE/online_test · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
from textwrap import dedent
from collections import OrderedDict

from django.utils import timezone
from django.core.mail import send_mail
from django.template.loader import render_to_string

from celery import task
from celery.decorators import periodic_task
from celery.task.schedules import crontab
from notifications_plugin.models import NotificationMessage, Notification

from yaksh.models import Course, Quiz, QuestionPaper, AnswerPaper
from .models import Subscription


@periodic_task(
    run_every=(
        crontab(
            hour='08', minute=36, day_of_week='*/3', day_of_month='*',
            month_of_year='*'
        )
    ), name='course_deadline_task'
)
def course_deadline_task():
    courses = Course.objects.filter(active=True, is_trial=False)
    for course in courses:
        if course.is_active_enrollment():
            message = dedent("""
                The deadline for the course {0} is {1}, please complete
                the course if not completed before the deadline.
                """.format(course.name, course.end_enroll_time)
            )
            creator = course.creator
            students_id = course.students.values_list('id', flat=True)
            if students_id:
                notification_type = "warning"
                nm = NotificationMessage.objects.add_single_message(
                    creator_id=creator.id, summary='Course Notification',
                    description=message, msg_type=notification_type
                )
                Notification.objects.add_bulk_user_notifications(
                    receiver_ids=students_id, msg_id=nm.id
                )


@periodic_task(
    run_every=(
        crontab(
            hour='09', minute=12, day_of_week='*/3', day_of_month='*',
            month_of_year='*'
        )
    ), name='quiz_deadline_task'
)
def quiz_deadline_task():
    courses = Course.objects.filter(active=True, is_trial=False)
    for course in courses:
        students_id = course.students.values_list('id', flat=True)
        creator = course.creator
        quizzes = course.get_quizzes()
        if students_id:
            for quiz in quizzes:
                if not quiz.is_expired():
                    message = dedent("""
                        The deadline for the quiz {0} of course {1} is
                        {2}, please complete the quiz if not completed
                        before the deadline.
                        """.format(
                            quiz.description, course.name, quiz.end_date_time
                        )
                    )
                    notification_type = 'warning'
                    nm = NotificationMessage.objects.add_single_message(
                        creator_id=creator.id, summary='Quiz Notification',
                        description=message, msg_type=notification_type
                    )
                    Notification.objects.add_bulk_user_notifications(
                        receiver_ids=students_id, msg_id=nm.id
                    )


@periodic_task(
    run_every=(
        crontab(
            hour='23', minute=30, day_of_week='Tuesday', day_of_month='*',
            month_of_year='*'
        )
    ), name='course_quiz_deadline_mail_task'
)
def course_quiz_deadline_mail_task():
    courses = Course.objects.filter(active=True, is_trial=False)
    for course in courses:
        if course.is_active_enrollment():
            students = course.students.all()
            quizzes = course.get_quizzes()
            for student in students:
                subscribed = student.subscription.exists()
                if subscribed:
                    data = []
                    for quiz in quizzes:
                        quiz_data = {}
                        answer_paper = AnswerPaper.objects.filter(
                            course=course, user=student
                        )
                        if answer_paper.exists():
                            quiz_data['quiz'] = quiz
                            quiz_data['status'] = True
                        else:
                            quiz_data['quiz'] = quiz
                            quiz_data['status'] = False
                            quiz_data['deadline'] = quiz.end_date_time
                        data.append(quiz_data)
                    msg_html = render_to_string('notification/email.html', {
                            'data': data
                        }
                    )
                    msg_plain = render_to_string('notification/email.txt', {
                            'data': data
                        }
                    )
                    send_mail('email title', msg_plain, 'some@sender.com',
                        [student.email], html_message=msg_html
                    )