changes in article update api and get image url method

fixed add junior api

.gitignore

@@ -21,4 +21,4 @@ static/*
 __pycache__/
 *.env
 ve/*
-
+celerybeat-schedule

account/migrations/0009_alter_userdevicedetails_device_id.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.2 on 2023-07-20 11:38
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('account', '0008_userdevicedetails'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='userdevicedetails',
+            name='device_id',
+            field=models.CharField(blank=True, max_length=500, null=True),
+        ),
+    ]

account/models.py

@@ -152,7 +152,7 @@ class UserDeviceDetails(models.Model):
     """
     user = models.OneToOneField(User, on_delete=models.CASCADE, related_name='user_device_details')
     """Device ID"""
-    device_id = models.CharField(max_length=500)
+    device_id = models.CharField(max_length=500, null=True, blank=True)
 
     created_at = models.DateTimeField(auto_now_add=True)
     updated_at = models.DateTimeField(auto_now=True)

account/serializers.py

@@ -144,12 +144,12 @@ class SuperUserSerializer(serializers.ModelSerializer):
     refresh_token = serializers.SerializerMethodField('get_refresh_token')
 
     def get_auth_token(self, obj):
-        refresh = RefreshToken.for_user(obj.auth)
+        refresh = RefreshToken.for_user(obj)
         access_token = str(refresh.access_token)
         return access_token
 
     def get_refresh_token(self, obj):
-        refresh = RefreshToken.for_user(obj.user)
+        refresh = RefreshToken.for_user(obj)
         refresh_token = str(refresh)
         return refresh_token
 

account/templates/templated_email/junior_approval_mail.email

@@ -8,7 +8,7 @@
     <tr>
         <td style="padding: 0 27px 15px;">
             <p style="margin: 0; font-size: 16px; line-height: 20px; padding: 36px 0 0; font-weight: 500; color: #1f2532;">
-                Hi {{full_name}},
+                Hello,
             </p>
         </td>
     </tr>

account/utils.py

@@ -22,7 +22,7 @@ from junior.models import Junior
 from guardian.models import Guardian
 from account.models import UserDelete
 from base.messages import ERROR_CODE
-
+from django.utils import timezone
 
 # Define delete
 # user account condition,
@@ -228,3 +228,4 @@ def generate_code(value, user_id):
     return code
 
 
+OTP_EXPIRY = timezone.now() + timezone.timedelta(days=1)

account/views.py

@@ -36,14 +36,14 @@ from base.messages import ERROR_CODE, SUCCESS_CODE
 from base.constants import NUMBER, ZOD, JUN, GRD
 from guardian.tasks import generate_otp
 from account.utils import (send_otp_email, send_support_email, custom_response, custom_error_response,
-                           generate_code)
+                           generate_code, OTP_EXPIRY)
 from junior.serializers import JuniorProfileSerializer
 from guardian.serializers import GuardianProfileSerializer
 
 class GoogleLoginMixin(object):
     """google login mixin"""
     @staticmethod
-    def google_login(self, request):
+    def google_login(request):
         """google login function"""
         access_token = request.data.get('access_token')
         user_type = request.data.get('user_type')
@@ -228,7 +228,7 @@ class ForgotPasswordAPIView(views.APIView):
                     'verification_code': verification_code
                 }
             )
-            expiry = timezone.now() + timezone.timedelta(days=1)
+            expiry = OTP_EXPIRY
             user_data, created = UserEmailOtp.objects.get_or_create(email=email)
             if created:
                 user_data.expired_at = expiry
@@ -399,7 +399,7 @@ class ReSendEmailOtp(viewsets.ModelViewSet):
     def create(self, request, *args, **kwargs):
         otp = generate_otp()
         if User.objects.filter(email=request.data['email']):
-            expiry = timezone.now() + timezone.timedelta(days=1)
+            expiry = OTP_EXPIRY
             email_data, created = UserEmailOtp.objects.get_or_create(email=request.data['email'])
             if created:
                 email_data.expired_at = expiry

base/constants.py

@@ -61,7 +61,8 @@ TASK_STATUS = (
     ('2', 'in-progress'),
     ('3', 'rejected'),
     ('4', 'requested'),
-    ('5', 'completed')
+    ('5', 'completed'),
+    ('6', 'expired')
 )
 # sign up method
 SIGNUP_METHODS = (
@@ -103,3 +104,8 @@ MAX_ARTICLE_CARD = 6
 # min and max survey
 MIN_ARTICLE_SURVEY = 5
 MAX_ARTICLE_SURVEY = 10
+
+# real time url
+time_url = "http://worldtimeapi.org/api/timezone/Asia/Riyadh"
+
+ARTICLE_CARD_IMAGE_FOLDER = 'article-card-images'

base/messages.py

@@ -42,7 +42,7 @@ ERROR_CODE = {
     "2016": "Invalid search.",
     "2017": "{model} object with {pk} does not exist",
     "2018": "Attached File not found",
-    "2019": "Either File extension or File size doesn't meet the requirements",
+    "2019": "Invalid Referral code",
     "2020": "Enter valid mobile number",
     "2021": "Already register",
     "2022": "Invalid Guardian code",
@@ -74,7 +74,24 @@ ERROR_CODE = {
     "2041": "Article with given id doesn't exist.",
     "2042": "Article Card with given id doesn't exist.",
     "2043": "Article Survey with given id doesn't exist.",
-    "2044": "Task does not exist"
+    "2044": "Task does not exist",
+    "2045": "Invalid guardian",
+    # past due date
+    "2046": "Due date must be future date",
+    # invalid junior id msg
+    "2047": "Invalid Junior ID ",
+    "2048": "Choose right file for image",
+    # task request
+    "2049": "This task is already requested ",
+    "2059": "Already exist junior",
+    # task status
+    "2060": "Task does not exist or not in pending state",
+    "2061": "Please insert image or check the image is valid or not.",
+    # email not null
+    "2062": "Please enter email address",
+    "2063": "Unauthorized access.",
+    "2064": "To change your password first request an OTP and get it verify then change your password.",
+    "2065": "Passwords do not match. Please try again."
 }
 """Success message code"""
 SUCCESS_CODE = {
@@ -120,7 +137,10 @@ SUCCESS_CODE = {
     "3029": "Article has been deleted successfully.",
     "3030": "Article Card has been removed successfully.",
     "3031": "Article Survey has been removed successfully.",
-    "3032": "Task request sent successfully"
+    "3032": "Task request sent successfully",
+    "3033": "Valid Referral code",
+    "3034": "Invite guardian successfully",
+    "3035": "Task started successfully"
 }
 """status code error"""
 STATUS_CODE_ERROR = {

base/tasks.py

@@ -0,0 +1,29 @@
+"""
+web_admin tasks file
+"""
+# third party imports
+from celery import shared_task
+from templated_email import send_templated_mail
+
+# django imports
+from django.conf import settings
+
+
+@shared_task
+def send_email_otp(email, verification_code):
+    """
+    used to send otp on email
+    :param email: e-mail
+    :param verification_code: otp
+    """
+    from_email = settings.EMAIL_FROM_ADDRESS
+    recipient_list = [email]
+    send_templated_mail(
+        template_name='email_reset_verification.email',
+        from_email=from_email,
+        recipient_list=recipient_list,
+        context={
+            'verification_code': verification_code
+        }
+    )
+    return True

docker-compose.yml

@@ -3,6 +3,7 @@ services:
   nginx:
     image: nginx:latest
     container_name: nginx
+    restart: always
     ports:
       - "8000:8000"
     volumes:
@@ -13,6 +14,7 @@ services:
   web:
     build: .
     container_name: django
+    restart: always
     command: bash -c "pip install -r requirements.txt && python manage.py collectstatic --noinput && python manage.py migrate && gunicorn zod_bank.wsgi -b 0.0.0.0:8000 -t 300 --log-level=info"
     volumes:
       - .:/usr/src/app

guardian/migrations/0017_juniortask_is_invited_juniortask_is_password_set.py

@@ -0,0 +1,23 @@
+# Generated by Django 4.2.2 on 2023-07-24 13:21
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('guardian', '0016_juniortask_completed_on_juniortask_rejected_on_and_more'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='juniortask',
+            name='is_invited',
+            field=models.BooleanField(default=False),
+        ),
+        migrations.AddField(
+            model_name='juniortask',
+            name='is_password_set',
+            field=models.BooleanField(default=True),
+        ),
+    ]

guardian/migrations/0018_remove_juniortask_is_invited_and_more.py

@@ -0,0 +1,21 @@
+# Generated by Django 4.2.2 on 2023-07-24 13:23
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('guardian', '0017_juniortask_is_invited_juniortask_is_password_set'),
+    ]
+
+    operations = [
+        migrations.RemoveField(
+            model_name='juniortask',
+            name='is_invited',
+        ),
+        migrations.RemoveField(
+            model_name='juniortask',
+            name='is_password_set',
+        ),
+    ]

guardian/migrations/0019_guardian_is_invited_guardian_is_password_set.py

@@ -0,0 +1,23 @@
+# Generated by Django 4.2.2 on 2023-07-24 13:23
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('guardian', '0018_remove_juniortask_is_invited_and_more'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='guardian',
+            name='is_invited',
+            field=models.BooleanField(default=False),
+        ),
+        migrations.AddField(
+            model_name='guardian',
+            name='is_password_set',
+            field=models.BooleanField(default=True),
+        ),
+    ]

guardian/migrations/0020_alter_juniortask_task_status.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.2 on 2023-07-25 07:44
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('guardian', '0019_guardian_is_invited_guardian_is_password_set'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='juniortask',
+            name='task_status',
+            field=models.CharField(choices=[('1', 'pending'), ('2', 'in-progress'), ('3', 'rejected'), ('4', 'requested'), ('5', 'completed'), ('6', 'expired')], default=1, max_length=15),
+        ),
+    ]

guardian/models.py

@@ -5,7 +5,7 @@ from django.contrib.auth import get_user_model
 """Import Django app"""
 from base.constants import GENDERS, TASK_STATUS, PENDING, TASK_POINTS, SIGNUP_METHODS
 """import Junior model"""
-from junior.models import Junior
+import junior.models
 """Add user model"""
 User = get_user_model()
 
@@ -53,6 +53,10 @@ class Guardian(models.Model):
     gender = models.CharField(choices=GENDERS, max_length=15, null=True, blank=True, default=None)
     """date of birth of the guardian"""
     dob = models.DateField(max_length=15, null=True, blank=True, default=None)
+    # invited junior"""
+    is_invited = models.BooleanField(default=False)
+    # Profile activity"""
+    is_password_set = models.BooleanField(default=True)
     """Profile activity"""
     is_active = models.BooleanField(default=True)
     """guardian is verified or not"""
@@ -101,7 +105,7 @@ class JuniorTask(models.Model):
     """image that is uploaded by junior"""
     image = models.URLField(null=True, blank=True, default=None)
     """associated junior with the task"""
-    junior = models.ForeignKey(Junior, on_delete=models.CASCADE, related_name='junior', verbose_name='Junior')
+    junior = models.ForeignKey('junior.Junior', on_delete=models.CASCADE, related_name='junior', verbose_name='Junior')
     """task status"""
     task_status = models.CharField(choices=TASK_STATUS, max_length=15, default=PENDING)
     """task is active or not"""

guardian/serializers.py

@@ -24,8 +24,11 @@ from junior.serializers import JuniorDetailSerializer
 from base.messages import ERROR_CODE, SUCCESS_CODE
 from base.constants import NUMBER, JUN, ZOD, GRD
 from junior.models import Junior, JuniorPoints
-from .utils import real_time, convert_timedelta_into_datetime
-
+from .utils import real_time, convert_timedelta_into_datetime, update_referral_points
+# notification's constant
+from notifications.constants import TASK_POINTS, TASK_REJECTED
+# send notification function
+from notifications.utils import send_notification
 
 
 # In this serializer file
@@ -61,7 +64,7 @@ class UserSerializer(serializers.ModelSerializer):
         try:
             """Create user profile"""
             user = User.objects.create_user(username=email, email=email, password=password)
-            UserNotification.objects.create(user=user)
+            UserNotification.objects.get_or_create(user=user)
             if user_type == str(NUMBER['one']):
                 # create junior profile
                 Junior.objects.create(auth=user, junior_code=generate_code(JUN, user.id),
@@ -141,7 +144,6 @@ class CreateGuardianSerializer(serializers.ModelSerializer):
             guardian.country_code = validated_data.get('country_code', guardian.country_code)
             guardian.passcode = validated_data.get('passcode', guardian.passcode)
             guardian.country_name = validated_data.get('country_name', guardian.country_name)
-            guardian.referral_code_used = validated_data.get('referral_code_used', guardian.referral_code_used)
             guardian.image = validated_data.get('image', guardian.image)
             """Complete profile of the junior if below all data are filled"""
             complete_profile_field = all([guardian.gender, guardian.country_name,
@@ -150,6 +152,9 @@ class CreateGuardianSerializer(serializers.ModelSerializer):
             guardian.is_complete_profile = False
             if complete_profile_field:
                 guardian.is_complete_profile = True
+            referral_code_used = validated_data.get('referral_code_used')
+            update_referral_points(guardian.referral_code, referral_code_used)
+            guardian.referral_code_used = validated_data.get('referral_code_used', guardian.referral_code_used)
             guardian.save()
         return guardian
 
@@ -167,6 +172,14 @@ class TaskSerializer(serializers.ModelSerializer):
         """Meta info"""
         model = JuniorTask
         fields = ['id', 'task_name','task_description','points', 'due_date', 'junior', 'default_image']
+
+    def validate_due_date(self, value):
+        """validation on due date"""
+        if value < datetime.today().date():
+            raise serializers.ValidationError({"details": ERROR_CODE['2046'],
+                                               "code": 400, "status": "failed",
+                                               })
+        return value
     def create(self, validated_data):
         """create default task image data"""
         validated_data['guardian'] = Guardian.objects.filter(user=self.context['user']).last()
@@ -205,6 +218,7 @@ class TaskDetailsSerializer(serializers.ModelSerializer):
 
     junior = JuniorDetailSerializer()
     remaining_time = serializers.SerializerMethodField('get_remaining_time')
+    is_expired = serializers.SerializerMethodField('get_is_expired')
 
     def get_remaining_time(self, obj):
         """ remaining time to complete task"""
@@ -218,12 +232,16 @@ class TaskDetailsSerializer(serializers.ModelSerializer):
             return str(time_difference.days) + ' days ' + str(time_only)
         return str(NUMBER['zero']) + ' days ' + '00:00:00:00000'
 
-
+    def get_is_expired(self, obj):
+        """ task expired or not"""
+        if obj.due_date < datetime.today().date():
+            return True
+        return False
     class Meta(object):
         """Meta info"""
         model = JuniorTask
         fields = ['id', 'guardian', 'task_name', 'task_description', 'points', 'due_date','default_image', 'image',
-                  'requested_on', 'rejected_on', 'completed_on',
+                  'requested_on', 'rejected_on', 'completed_on', 'is_expired',
                   'junior', 'task_status', 'is_active', 'remaining_time', 'created_at','updated_at']
 
 
@@ -235,7 +253,7 @@ class TopJuniorSerializer(serializers.ModelSerializer):
     class Meta(object):
         """Meta info"""
         model = JuniorPoints
-        fields = ['id', 'junior', 'total_task_points', 'position', 'created_at', 'updated_at']
+        fields = ['id', 'junior', 'total_points', 'position', 'created_at', 'updated_at']
 
     def to_representation(self, instance):
         """Convert instance to representation"""
@@ -290,6 +308,7 @@ class GuardianProfileSerializer(serializers.ModelSerializer):
                   'is_active', 'is_complete_profile', 'created_at', 'image', 'signup_method',
                   'updated_at', 'passcode']
 
+
 class ApproveJuniorSerializer(serializers.ModelSerializer):
     """approve junior serializer"""
     class Meta(object):
@@ -301,9 +320,11 @@ class ApproveJuniorSerializer(serializers.ModelSerializer):
         """update guardian code"""
         instance = self.context['junior']
         instance.guardian_code = [self.context['guardian_code']]
+        instance.is_invited = True
         instance.save()
         return instance
 
+
 class ApproveTaskSerializer(serializers.ModelSerializer):
     """approve task serializer"""
     class Meta(object):
@@ -313,27 +334,30 @@ class ApproveTaskSerializer(serializers.ModelSerializer):
 
     def create(self, validated_data):
         """update task status """
-        instance = self.context['task_instance']
-        junior = self.context['junior']
-        junior_details = Junior.objects.filter(id=junior).last()
-        junior_data, created = JuniorPoints.objects.get_or_create(junior=junior_details)
-        if self.context['action'] == str(NUMBER['one']):
-            # approve the task
-            instance.task_status = str(NUMBER['five'])
-            instance.is_approved = True
-            # update total task point
-            junior_data.total_task_points = junior_data.total_task_points + instance.points
-            # update complete time of task
-            instance.completed_on = real_time()
-        else:
-            # reject the task
-            instance.task_status = str(NUMBER['three'])
-            instance.is_approved = False
-            # update total task point
-            junior_data.total_task_points = junior_data.total_task_points - instance.points
-            # update reject time of task
-            instance.rejected_on = real_time()
-        instance.save()
-        junior_data.save()
-        return instance
+        with transaction.atomic():
+            instance = self.context['task_instance']
+            junior = self.context['junior']
+            junior_details = Junior.objects.filter(id=junior).last()
+            junior_data, created = JuniorPoints.objects.get_or_create(junior=junior_details)
+            if self.context['action'] == str(NUMBER['one']):
+                # approve the task
+                instance.task_status = str(NUMBER['five'])
+                instance.is_approved = True
+                # update total task point
+                junior_data.total_points = junior_data.total_points + instance.points
+                # update complete time of task
+                instance.completed_on = real_time()
+                send_notification.delay(TASK_POINTS, None, junior_details.auth.id, {})
+            else:
+                # reject the task
+                instance.task_status = str(NUMBER['three'])
+                instance.is_approved = False
+                # update total task point
+                junior_data.total_points = junior_data.total_points - instance.points
+                # update reject time of task
+                instance.rejected_on = real_time()
+                send_notification.delay(TASK_REJECTED, None, junior_details.auth.id, {})
+            instance.save()
+            junior_data.save()
+            return junior_details
 

guardian/utils.py

@@ -3,15 +3,25 @@
 import oss2
 """Import setting"""
 from django.conf import settings
+import logging
+import requests
+from django.core.exceptions import ObjectDoesNotExist
 """Import tempfile"""
 import tempfile
 # Import date time module's function
 from datetime import datetime, time
-# Import real time client module
-import ntplib
 # import Number constant
-from base.constants import NUMBER
-
+from base.constants import NUMBER, time_url
+# Import Junior's model
+from junior.models import Junior, JuniorPoints
+# Import guardian's model
+from .models import JuniorTask
+# Import app from celery
+from zod_bank.celery import app
+# notification's constant
+from notifications.constants import REFERRAL_POINTS
+# send notification function
+from notifications.utils import send_notification
 # Define upload image on
 # ali baba cloud
 # firstly save image
@@ -21,6 +31,10 @@ from base.constants import NUMBER
 # bucket and reform the image url"""
 # fetch real time data without depend on system time
 # convert time delta into date time object
+# update junior total points
+# update referral points
+# if any one use referral code of the junior
+# junior earn 5 points
 
 def upload_image_to_alibaba(image, filename):
     """upload image on oss alibaba bucket"""
@@ -38,16 +52,20 @@ def upload_image_to_alibaba(image, filename):
         new_filename = filename.replace(' ', '%20')
     return f"https://{settings.ALIYUN_OSS_BUCKET_NAME}.{settings.ALIYUN_OSS_ENDPOINT}/{new_filename}"
 
+
 def real_time():
-    """ real time """
-    # Fetch real time.
-    # time is not depend on system time
-    # Get the current datetime
-    ntp_client = ntplib.NTPClient()
-    ntp_server = 'pool.ntp.org'
-    response = ntp_client.request(ntp_server)
-    current_datetime = datetime.fromtimestamp(response.tx_time)
-    return current_datetime
+    """fetch real time from world time api"""
+    url = time_url
+    response = requests.get(url)
+    if response.status_code == 200:
+        data = response.json()
+        time_str = data['datetime']
+        realtime = datetime.fromisoformat(time_str.replace('Z', '+00:00')).replace(tzinfo=None)
+        return realtime
+    else:
+        logging.error("Could not fetch error")
+        return None
+
 
 def convert_timedelta_into_datetime(time_difference):
     """convert date time"""
@@ -59,3 +77,30 @@ def convert_timedelta_into_datetime(time_difference):
     # Create a new time object with the extracted time components
     time_only = time(hours, minutes, seconds, microseconds)
     return time_only
+
+def update_referral_points(referral_code, referral_code_used):
+    """Update benefit of referral points"""
+    junior_queryset = Junior.objects.filter(referral_code=referral_code_used).last()
+    if junior_queryset and junior_queryset.referral_code != referral_code:
+        # create data if junior points is not exist
+        junior_query, created = JuniorPoints.objects.get_or_create(junior=junior_queryset)
+        if junior_query:
+            # update junior total points and referral points
+            junior_query.total_points = junior_query.total_points + NUMBER['five']
+            junior_query.referral_points = junior_query.referral_points + NUMBER['five']
+            junior_query.save()
+            send_notification.delay(REFERRAL_POINTS, None, junior_queryset.auth.id, {})
+
+
+
+@app.task
+def update_expired_task_status(data=None):
+    """
+    Update task of the status if due date is in past
+    """
+    try:
+        task_status = [str(NUMBER['one']), str(NUMBER['two']), str(NUMBER['four'])]
+        JuniorTask.objects.filter(due_date__lt=datetime.today().date(),
+                                  task_status__in=task_status).update(task_status=str(NUMBER['six']))
+    except ObjectDoesNotExist as e:
+        logging.error(str(e))

guardian/views.py

@@ -1,6 +1,11 @@
 """Views of Guardian"""
 
 # django imports
+# Import IsAuthenticated
+# Import viewsets and status
+# Import PageNumberPagination
+# Import User
+# Import timezone
 from rest_framework.permissions import IsAuthenticated
 from rest_framework import viewsets, status
 from rest_framework.pagination import PageNumberPagination
@@ -18,19 +23,19 @@ from django.utils import timezone
 # from utils file
 # Import account's serializer
 # Import account's task
-
+# Import notification constant
+# Import send_notification function
 from .serializers import (UserSerializer, CreateGuardianSerializer, TaskSerializer, TaskDetailsSerializer,
                           TopJuniorSerializer, ApproveJuniorSerializer, ApproveTaskSerializer)
 from .models import Guardian, JuniorTask
 from junior.models import Junior, JuniorPoints
 from account.models import UserEmailOtp, UserNotification
 from .tasks import generate_otp
-from account.utils import send_otp_email
-from account.utils import custom_response, custom_error_response
+from account.utils import custom_response, custom_error_response, OTP_EXPIRY, send_otp_email
 from base.messages import ERROR_CODE, SUCCESS_CODE
 from base.constants import NUMBER
 from .utils import upload_image_to_alibaba
-from notifications.constants import REGISTRATION
+from notifications.constants import REGISTRATION, TASK_CREATED, LEADERBOARD_RANKING
 from notifications.utils import send_notification
 
 """ Define APIs """
@@ -51,24 +56,29 @@ class SignupViewset(viewsets.ModelViewSet):
     serializer_class = UserSerializer
     def create(self, request, *args, **kwargs):
         """Create user profile"""
-        if request.data['user_type'] in ['1', '2']:
-            serializer = UserSerializer(context=request.data['user_type'], data=request.data)
-            if serializer.is_valid():
-                user = serializer.save()
-                """Generate otp"""
-                otp = generate_otp()
-                expiry = timezone.now() + timezone.timedelta(days=1)
-                # create user email otp object
-                UserEmailOtp.objects.create(email=request.data['email'], otp=otp,
-                                            user_type=str(request.data['user_type']), expired_at=expiry)
-                """Send email to the register user"""
-                send_otp_email(request.data['email'], otp)
-                send_notification(REGISTRATION, None, user.id, {})
-                return custom_response(SUCCESS_CODE['3001'],
-                                       response_status=status.HTTP_200_OK)
-            return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
-        else:
-            return custom_error_response(ERROR_CODE['2028'], response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            if request.data['user_type'] in [str(NUMBER['one']), str(NUMBER['two'])]:
+                serializer = UserSerializer(context=request.data['user_type'], data=request.data)
+                if serializer.is_valid():
+                    user = serializer.save()
+                    """Generate otp"""
+                    otp = generate_otp()
+                    # expire otp after 1 day
+                    expiry = OTP_EXPIRY
+                    # create user email otp object
+                    UserEmailOtp.objects.create(email=request.data['email'], otp=otp,
+                                                user_type=str(request.data['user_type']), expired_at=expiry)
+                    """Send email to the register user"""
+                    send_otp_email(request.data['email'], otp)
+                    # send push notification for registration
+                    send_notification.delay(REGISTRATION, None, user.id, {})
+                    return custom_response(SUCCESS_CODE['3001'],
+                                           response_status=status.HTTP_200_OK)
+                return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+            else:
+                return custom_error_response(ERROR_CODE['2028'], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 class UpdateGuardianProfile(viewsets.ViewSet):
     """Update guardian profile"""
@@ -78,26 +88,29 @@ class UpdateGuardianProfile(viewsets.ViewSet):
 
     def create(self, request, *args, **kwargs):
         """Create guardian profile"""
-        data = request.data
-        image = request.data.get('image')
-        image_url = ''
-        if image:
-            if image and image.size == NUMBER['zero']:
-                return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
-            filename = f"images/{image.name}"
-            # upload image on ali baba
-            image_url = upload_image_to_alibaba(image, filename)
-            data = {"image":image_url}
-        serializer = CreateGuardianSerializer(context={"user":request.user,
-                                                       "first_name":request.data.get('first_name'),
-                                                       "last_name": request.data.get('last_name'),
-                                                       "image":image_url},
-                                              data=data)
-        if serializer.is_valid():
-            """save serializer"""
-            serializer.save()
-            return custom_response(None, serializer.data,response_status=status.HTTP_200_OK)
-        return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            data = request.data
+            image = request.data.get('image')
+            image_url = ''
+            if image:
+                if image and image.size == NUMBER['zero']:
+                    return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
+                filename = f"images/{image.name}"
+                # upload image on ali baba
+                image_url = upload_image_to_alibaba(image, filename)
+                data = {"image":image_url}
+            serializer = CreateGuardianSerializer(context={"user":request.user,
+                                                           "first_name":request.data.get('first_name'),
+                                                           "last_name": request.data.get('last_name'),
+                                                           "image":image_url},
+                                                  data=data)
+            if serializer.is_valid():
+                """save serializer"""
+                serializer.save()
+                return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class AllTaskListAPIView(viewsets.ModelViewSet):
@@ -119,60 +132,76 @@ class TaskListAPIView(viewsets.ModelViewSet):
     permission_classes = [IsAuthenticated]
     pagination_class = PageNumberPagination
     queryset = JuniorTask.objects.all()
+    http_method_names = ('get',)
 
     def list(self, request, *args, **kwargs):
         """Create guardian profile"""
-        status_value = self.request.GET.get('status')
-        search = self.request.GET.get('search')
-        if search and str(status_value) == '0':
-            queryset = JuniorTask.objects.filter(guardian__user=request.user,
-                                                 task_name__icontains=search).order_by('due_date', 'created_at')
-        elif search and str(status_value) != '0':
-            queryset = JuniorTask.objects.filter(guardian__user=request.user,task_name__icontains=search,
-                                                 task_status=status_value).order_by('due_date', 'created_at')
-        if search is None and str(status_value) == '0':
-            queryset = JuniorTask.objects.filter(guardian__user=request.user).order_by('due_date', 'created_at')
-        elif search is None and str(status_value) != '0':
-            queryset = JuniorTask.objects.filter(guardian__user=request.user,
-                                                 task_status=status_value).order_by('due_date','created_at')
-        paginator = self.pagination_class()
-        # use Pagination
-        paginated_queryset = paginator.paginate_queryset(queryset, request)
-        # use TaskDetailsSerializer serializer
-        serializer = TaskDetailsSerializer(paginated_queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            status_value = self.request.GET.get('status')
+            search = self.request.GET.get('search')
+            if search and str(status_value) == '0':
+                queryset = JuniorTask.objects.filter(guardian__user=request.user,
+                                                     task_name__icontains=search).order_by('due_date', 'created_at')
+            elif search and str(status_value) != '0':
+                queryset = JuniorTask.objects.filter(guardian__user=request.user,task_name__icontains=search,
+                                                     task_status=status_value).order_by('due_date', 'created_at')
+            if search is None and str(status_value) == '0':
+                queryset = JuniorTask.objects.filter(guardian__user=request.user).order_by('due_date', 'created_at')
+            elif search is None and str(status_value) != '0':
+                queryset = JuniorTask.objects.filter(guardian__user=request.user,
+                                                     task_status=status_value).order_by('due_date','created_at')
+            paginator = self.pagination_class()
+            # use Pagination
+            paginated_queryset = paginator.paginate_queryset(queryset, request)
+            # use TaskDetailsSerializer serializer
+            serializer = TaskDetailsSerializer(paginated_queryset, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 class CreateTaskAPIView(viewsets.ModelViewSet):
     """create task for junior"""
     serializer_class = TaskSerializer
     queryset = JuniorTask.objects.all()
+    http_method_names = ('post', )
 
     def create(self, request, *args, **kwargs):
-        image = request.data['default_image']
-        data = request.data
-        if 'https' in str(image):
-            image_data = image
-        else:
-            filename = f"images/{image}"
-            if image and image.size == NUMBER['zero']:
-                return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
-            image_url = upload_image_to_alibaba(image, filename)
-            image_data = image_url
-            data.pop('default_image')
-        # use TaskSerializer serializer
-        serializer = TaskSerializer(context={"user":request.user, "image":image_data}, data=data)
-        if serializer.is_valid():
-            # save serializer
-            serializer.save()
-            return custom_response(SUCCESS_CODE['3018'], serializer.data, response_status=status.HTTP_200_OK)
-        return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            image = request.data['default_image']
+            junior = request.data['junior']
+            allowed_extensions = ['.jpg', '.jpeg', '.png']
+            if not any(extension in str(image) for extension in allowed_extensions):
+                return custom_error_response(ERROR_CODE['2048'], response_status=status.HTTP_400_BAD_REQUEST)
+            if not junior.isnumeric():
+                """junior value must be integer"""
+                return custom_error_response(ERROR_CODE['2047'], response_status=status.HTTP_400_BAD_REQUEST)
+            data = request.data
+            if 'https' in str(image):
+                image_data = image
+            else:
+                filename = f"images/{image}"
+                if image and image.size == NUMBER['zero']:
+                    return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
+                image_url = upload_image_to_alibaba(image, filename)
+                image_data = image_url
+                data.pop('default_image')
+            # use TaskSerializer serializer
+            serializer = TaskSerializer(context={"user":request.user, "image":image_data}, data=data)
+            if serializer.is_valid():
+                # save serializer
+                serializer.save()
+                junior_id = Junior.objects.filter(id=junior).last()
+                send_notification.delay(TASK_CREATED, None, junior_id.auth.id, {})
+                return custom_response(SUCCESS_CODE['3018'], serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 class SearchTaskListAPIView(viewsets.ModelViewSet):
     """Update guardian profile"""
     serializer_class = TaskDetailsSerializer
     permission_classes = [IsAuthenticated]
     pagination_class = PageNumberPagination
-    queryset = JuniorTask.objects.all()
 
     def get_queryset(self):
         """Get the queryset for the view"""
@@ -184,14 +213,16 @@ class SearchTaskListAPIView(viewsets.ModelViewSet):
 
     def list(self, request, *args, **kwargs):
         """Create guardian profile"""
-        queryset = self.get_queryset()
-
-        paginator = self.pagination_class()
-        # use pagination
-        paginated_queryset = paginator.paginate_queryset(queryset, request)
-        # use TaskSerializer serializer
-        serializer = TaskDetailsSerializer(paginated_queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            queryset = self.get_queryset()
+            paginator = self.pagination_class()
+            # use pagination
+            paginated_queryset = paginator.paginate_queryset(queryset, request)
+            # use TaskSerializer serializer
+            serializer = TaskDetailsSerializer(paginated_queryset, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class TopJuniorListAPIView(viewsets.ModelViewSet):
@@ -208,15 +239,19 @@ class TopJuniorListAPIView(viewsets.ModelViewSet):
 
     def list(self, request, *args, **kwargs):
         """Fetch junior list of those who complete their tasks"""
-        junior_total_points = self.get_queryset().order_by('-total_task_points')
+        try:
+            junior_total_points = self.get_queryset().order_by('-total_points')
 
-        # Update the position field for each JuniorPoints object
-        for index, junior in enumerate(junior_total_points):
-            junior.position = index + 1
-            junior.save()
+            # Update the position field for each JuniorPoints object
+            for index, junior in enumerate(junior_total_points):
+                junior.position = index + 1
+                send_notification.delay(LEADERBOARD_RANKING, None, junior.junior.auth.id, {})
+                junior.save()
 
-        serializer = self.get_serializer(junior_total_points, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+            serializer = self.get_serializer(junior_total_points, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class ApproveJuniorAPIView(viewsets.ViewSet):
@@ -233,19 +268,25 @@ class ApproveJuniorAPIView(viewsets.ViewSet):
 
     def create(self, request, *args, **kwargs):
         """ junior list"""
-        queryset = self.get_queryset()
-        # action 1 is use for approve and 2 for reject
-        if request.data['action'] == '1':
-            # use ApproveJuniorSerializer serializer
-            serializer = ApproveJuniorSerializer(context={"guardian_code": queryset[0].guardian_code,
-                                                          "junior": queryset[1], "action": request.data['action']},
-                                                 data=request.data)
-            if serializer.is_valid():
-                # save serializer
-                serializer.save()
-                return custom_response(SUCCESS_CODE['3023'], serializer.data, response_status=status.HTTP_200_OK)
-        else:
-            return custom_response(SUCCESS_CODE['3024'], response_status=status.HTTP_200_OK)
+        try:
+            queryset = self.get_queryset()
+            # action 1 is use for approve and 2 for reject
+            if request.data['action'] == '1':
+                # use ApproveJuniorSerializer serializer
+                serializer = ApproveJuniorSerializer(context={"guardian_code": queryset[0].guardian_code,
+                                                              "junior": queryset[1], "action": request.data['action']},
+                                                     data=request.data)
+                if serializer.is_valid():
+                    # save serializer
+                    serializer.save()
+                    return custom_response(SUCCESS_CODE['3023'], serializer.data, response_status=status.HTTP_200_OK)
+            else:
+                queryset[1].guardian_code = None
+                queryset[1].save()
+                return custom_response(SUCCESS_CODE['3024'], response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
 
 class ApproveTaskAPIView(viewsets.ViewSet):
     """approve junior by guardian"""
@@ -264,20 +305,27 @@ class ApproveTaskAPIView(viewsets.ViewSet):
     def create(self, request, *args, **kwargs):
         """ junior list"""
         # action 1 is use for approve and 2 for reject
-        queryset = self.get_queryset()
-        # use ApproveJuniorSerializer serializer
-        serializer = ApproveTaskSerializer(context={"guardian_code": queryset[0].guardian_code,
-                                                    "task_instance": queryset[1],
-                                                    "action": str(request.data['action']),
-                                                    "junior": self.request.data['junior_id']},
-                                           data=request.data)
-        if str(request.data['action']) == str(NUMBER['one']) and serializer.is_valid():
-            # save serializer
-            serializer.save()
-            return custom_response(SUCCESS_CODE['3025'], response_status=status.HTTP_200_OK)
-        elif str(request.data['action']) == str(NUMBER['two']) and serializer.is_valid():
-            # save serializer
-            serializer.save()
-            return custom_response(SUCCESS_CODE['3026'], response_status=status.HTTP_200_OK)
-        else:
-            return custom_response(ERROR_CODE['2038'], response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            queryset = self.get_queryset()
+            # use ApproveJuniorSerializer serializer
+            serializer = ApproveTaskSerializer(context={"guardian_code": queryset[0].guardian_code,
+                                                        "task_instance": queryset[1],
+                                                        "action": str(request.data['action']),
+                                                        "junior": self.request.data['junior_id']},
+                                               data=request.data)
+            unexpected_task_status = [str(NUMBER['five']), str(NUMBER['six'])]
+            if (str(request.data['action']) == str(NUMBER['one']) and serializer.is_valid()
+                    and queryset[1] and queryset[1].task_status not in unexpected_task_status):
+                # save serializer
+                serializer.save()
+                return custom_response(SUCCESS_CODE['3025'], response_status=status.HTTP_200_OK)
+            elif (str(request.data['action']) == str(NUMBER['two']) and serializer.is_valid()
+                    and queryset[1] and queryset[1].task_status not in unexpected_task_status):
+                # save serializer
+                serializer.save()
+                return custom_response(SUCCESS_CODE['3026'], response_status=status.HTTP_200_OK)
+            else:
+                return custom_response(ERROR_CODE['2038'], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+

junior/admin.py

@@ -2,7 +2,7 @@
 """Third party Django app"""
 from django.contrib import admin
 """Import Django app"""
-from .models import Junior, JuniorPoints
+from .models import Junior, JuniorPoints, JuniorGuardianRelationship
 # Register your models here.
 @admin.register(Junior)
 class JuniorAdmin(admin.ModelAdmin):
@@ -16,8 +16,14 @@ class JuniorAdmin(admin.ModelAdmin):
 @admin.register(JuniorPoints)
 class JuniorPointsAdmin(admin.ModelAdmin):
     """Junior Points Admin"""
-    list_display = ['junior', 'total_task_points', 'position']
+    list_display = ['junior', 'total_points', 'position']
 
     def __str__(self):
         """Return email id"""
         return self.junior.auth.email
+
+@admin.register(JuniorGuardianRelationship)
+class JuniorGuardianRelationshipAdmin(admin.ModelAdmin):
+    """Junior Admin"""
+    list_display = ['guardian', 'junior', 'relationship']
+

junior/migrations/0015_rename_total_task_points_juniorpoints_total_points.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.2 on 2023-07-19 09:40
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('junior', '0014_junior_is_password_set'),
+    ]
+
+    operations = [
+        migrations.RenameField(
+            model_name='juniorpoints',
+            old_name='total_task_points',
+            new_name='total_points',
+        ),
+    ]

junior/migrations/0016_juniorpoints_referral_points.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.2 on 2023-07-19 11:00
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('junior', '0015_rename_total_task_points_juniorpoints_total_points'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='juniorpoints',
+            name='referral_points',
+            field=models.IntegerField(blank=True, default=0, null=True),
+        ),
+    ]

junior/migrations/0017_juniorguardianrelationship.py

@@ -0,0 +1,31 @@
+# Generated by Django 4.2.2 on 2023-07-25 07:44
+
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('guardian', '0020_alter_juniortask_task_status'),
+        ('junior', '0016_juniorpoints_referral_points'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='JuniorGuardianRelationship',
+            fields=[
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('relationship', models.CharField(blank=True, choices=[('1', 'parent'), ('2', 'legal_guardian')], default='1', max_length=31, null=True)),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('updated_at', models.DateTimeField(auto_now=True)),
+                ('guardian', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='guardian_relation', to='guardian.guardian', verbose_name='Guardian')),
+                ('junior', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='junior_relation', to='junior.junior', verbose_name='Junior')),
+            ],
+            options={
+                'verbose_name': 'Junior Guardian Relation',
+                'verbose_name_plural': 'Junior Guardian Relation',
+                'db_table': 'junior_guardian_relation',
+            },
+        ),
+    ]

junior/models.py

@@ -7,6 +7,9 @@ from django.contrib.auth import get_user_model
 from django.contrib.postgres.fields import ArrayField
 """Import django app"""
 from base.constants import GENDERS, SIGNUP_METHODS, RELATIONSHIP
+# Import guardian's model
+from guardian.models import Guardian
+
 """Define User model"""
 User = get_user_model()
 # Create your models here.
@@ -31,7 +34,7 @@ User = get_user_model()
 """Define junior points model"""
 # points of the junior
 # position of the junior
-
+# define junior guardian relation model
 class Junior(models.Model):
     """Junior model"""
     auth = models.ForeignKey(User, on_delete=models.CASCADE, related_name='junior_profile', verbose_name='Email')
@@ -46,9 +49,6 @@ class Junior(models.Model):
     dob = models.DateField(max_length=15, null=True, blank=True, default=None)
     # Image of the junior"""
     image = models.URLField(null=True, blank=True, default=None)
-    # relationship"""
-    relationship = models.CharField(max_length=31, choices=RELATIONSHIP, null=True, blank=True,
-                                    default='1')
     # Sign up method"""
     signup_method = models.CharField(max_length=31, choices=SIGNUP_METHODS, default='1')
     # Codes"""
@@ -89,8 +89,10 @@ class Junior(models.Model):
 class JuniorPoints(models.Model):
     """Junior model"""
     junior = models.OneToOneField(Junior, on_delete=models.CASCADE, related_name='junior_points')
-    # Contact details"""
-    total_task_points = models.IntegerField(blank=True, null=True, default=0)
+    # Total earned points"""
+    total_points = models.IntegerField(blank=True, null=True, default=0)
+    # referral points"""
+    referral_points = models.IntegerField(blank=True, null=True, default=0)
     # position of the junior"""
     position = models.IntegerField(blank=True, null=True, default=99999)
     # Profile created and updated time"""
@@ -107,3 +109,29 @@ class JuniorPoints(models.Model):
     def __str__(self):
         """Return email id"""
         return f'{self.junior.auth}'
+
+class JuniorGuardianRelationship(models.Model):
+    """Junior Guardian relationship  model"""
+    guardian = models.ForeignKey(Guardian, on_delete=models.CASCADE, related_name='guardian_relation',
+                                 verbose_name='Guardian')
+    # associated junior with the task
+    junior = models.ForeignKey(Junior, on_delete=models.CASCADE, related_name='junior_relation', verbose_name='Junior')
+    # relation between guardian and junior"""
+    relationship = models.CharField(max_length=31, choices=RELATIONSHIP, null=True, blank=True,
+                                    default='1')
+    """Profile created and updated time"""
+    created_at = models.DateTimeField(auto_now_add=True)
+    updated_at = models.DateTimeField(auto_now=True)
+
+    class Meta(object):
+        """ Meta class """
+        db_table = 'junior_guardian_relation'
+        """verbose name of the model"""
+        verbose_name = 'Junior Guardian Relation'
+        verbose_name_plural = 'Junior Guardian Relation'
+
+    def __str__(self):
+        """Return email id"""
+        return f'{self.guardian.user}'
+
+

junior/serializers.py

@@ -9,14 +9,17 @@ from rest_framework_simplejwt.tokens import RefreshToken
 
 """Import django app"""
 from account.utils import send_otp_email, generate_code
-from junior.models import Junior, JuniorPoints
+from junior.models import Junior, JuniorPoints, JuniorGuardianRelationship
 from guardian.tasks import generate_otp
 from base.messages import ERROR_CODE, SUCCESS_CODE
 from base.constants import PENDING, IN_PROGRESS, REJECTED, REQUESTED, COMPLETED, NUMBER, JUN, ZOD
 from guardian.models import Guardian, JuniorTask
-from account.models import UserEmailOtp
+from account.models import UserEmailOtp, UserNotification
 from junior.utils import junior_notification_email, junior_approval_mail
-from guardian.utils import real_time
+from guardian.utils import real_time, update_referral_points, convert_timedelta_into_datetime
+from notifications.utils import send_notification
+from notifications.constants import (INVITED_GUARDIAN, APPROVED_JUNIOR, SKIPPED_PROFILE_SETUP, TASK_ACTION,
+                                     TASK_SUBMITTED)
 
 
 class ListCharField(serializers.ListField):
@@ -92,7 +95,6 @@ class CreateJuniorSerializer(serializers.ModelSerializer):
             """Update country code and phone number"""
             junior.phone = validated_data.get('phone', junior.phone)
             junior.country_code = validated_data.get('country_code', junior.country_code)
-            junior.referral_code_used = validated_data.get('referral_code_used', junior.referral_code_used)
             junior.image = validated_data.get('image', junior.image)
             """Complete profile of the junior if below all data are filled"""
             complete_profile_field = all([junior.gender, junior.country_name, junior.image,
@@ -100,6 +102,9 @@ class CreateJuniorSerializer(serializers.ModelSerializer):
             junior.is_complete_profile = False
             if complete_profile_field:
                 junior.is_complete_profile = True
+            referral_code_used = validated_data.get('referral_code_used')
+            update_referral_points(junior.referral_code, referral_code_used)
+            junior.referral_code_used = validated_data.get('referral_code_used', junior.referral_code_used)
             junior.save()
         return junior
 
@@ -245,18 +250,11 @@ class JuniorProfileSerializer(serializers.ModelSerializer):
 
 class AddJuniorSerializer(serializers.ModelSerializer):
     """Add junior serializer"""
-    auth_token = serializers.SerializerMethodField('get_auth_token')
-
-    def get_auth_token(self, obj):
-        """auth token"""
-        refresh = RefreshToken.for_user(obj)
-        access_token = str(refresh.access_token)
-        return access_token
 
     class Meta(object):
         """Meta info"""
         model = Junior
-        fields = ['id', 'gender','dob', 'relationship', 'auth_token', 'is_invited']
+        fields = ['id', 'gender','dob', 'is_invited']
 
 
     def create(self, validated_data):
@@ -264,32 +262,36 @@ class AddJuniorSerializer(serializers.ModelSerializer):
         with transaction.atomic():
             email = self.context['email']
             guardian = self.context['user']
+            relationship = self.context['relationship']
             full_name = self.context['first_name'] + ' ' + self.context['last_name']
             guardian_data = Guardian.objects.filter(user__username=guardian).last()
             user_data = User.objects.create(username=email, email=email,
                                             first_name=self.context['first_name'],
                                             last_name=self.context['last_name'])
-
             password = User.objects.make_random_password()
             user_data.set_password(password)
             user_data.save()
             junior_data = Junior.objects.create(auth=user_data, gender=validated_data.get('gender'),
                                                 dob=validated_data.get('dob'), is_invited=True,
-                                                relationship=validated_data.get('relationship'),
+                                                guardian_code=[guardian_data.guardian_code],
                                                 junior_code=generate_code(JUN, user_data.id),
                                                 referral_code=generate_code(ZOD, user_data.id),
                                                 referral_code_used=guardian_data.referral_code,
                                                 is_password_set=False, is_verified=True)
+            JuniorGuardianRelationship.objects.create(guardian=guardian_data, junior=junior_data,
+                                                      relationship=relationship)
             """Generate otp"""
             otp_value = generate_otp()
             expiry_time = timezone.now() + timezone.timedelta(days=1)
             UserEmailOtp.objects.create(email=email, otp=otp_value,
                                         user_type='1', expired_at=expiry_time, is_verified=True)
-            """Send email to the register user"""
-            send_otp_email(email, otp_value)
+            # add push notification
+            UserNotification.objects.get_or_create(user=user_data)
             """Notification email"""
             junior_notification_email(email, full_name, email, password)
             junior_approval_mail(guardian, full_name)
+            # push notification
+            send_notification.delay(SKIPPED_PROFILE_SETUP, None, junior_data.auth.id, {})
             return junior_data
 
 
@@ -320,6 +322,8 @@ class CompleteTaskSerializer(serializers.ModelSerializer):
         instance.task_status = str(NUMBER['four'])
         instance.is_approved = False
         instance.save()
+        send_notification.delay(TASK_SUBMITTED, None, instance.junior.auth.id, {})
+        send_notification.delay(TASK_ACTION, None, instance.guardian.user.id, {})
         return instance
 
 class JuniorPointsSerializer(serializers.ModelSerializer):
@@ -346,7 +350,7 @@ class JuniorPointsSerializer(serializers.ModelSerializer):
         """total points"""
         points = JuniorPoints.objects.filter(junior=obj.junior).last()
         if points:
-            return points.total_task_points
+            return points.total_points
 
     def get_in_progress_task(self, obj):
         return JuniorTask.objects.filter(junior=obj.junior, task_status=IN_PROGRESS).count()
@@ -371,3 +375,82 @@ class JuniorPointsSerializer(serializers.ModelSerializer):
         model = Junior
         fields = ['junior_id', 'total_points',  'position', 'pending_task', 'in_progress_task', 'completed_task',
                   'requested_task', 'rejected_task']
+
+class AddGuardianSerializer(serializers.ModelSerializer):
+    """Add guardian serializer"""
+
+    class Meta(object):
+        """Meta info"""
+        model = Guardian
+        fields = ['id']
+
+
+    def create(self, validated_data):
+        """ invite and create guardian"""
+        with transaction.atomic():
+            email = self.context['email']
+            junior = self.context['user']
+            relationship = self.context['relationship']
+            full_name = self.context['first_name'] + ' ' + self.context['last_name']
+            junior_data = Junior.objects.filter(auth__username=junior).last()
+            instance = User.objects.filter(username=email).last()
+            if instance:
+                guardian_data = Guardian.objects.filter(user=instance).update(is_invited=True,
+                                                                          referral_code=generate_code(ZOD,
+                                                                                                      instance.id),
+                                                                          referral_code_used=junior_data.referral_code,
+                                                                          is_verified=True)
+                UserNotification.objects.get_or_create(user=instance)
+                return guardian_data
+            else:
+                user = User.objects.create(username=email, email=email,
+                                           first_name=self.context['first_name'],
+                                           last_name=self.context['last_name'])
+
+                password = User.objects.make_random_password()
+                user.set_password(password)
+                user.save()
+                guardian_data = Guardian.objects.create(user=user, is_invited=True,
+                                                        referral_code=generate_code(ZOD, user.id),
+                                                        referral_code_used=junior_data.referral_code,
+                                                        is_password_set=False, is_verified=True)
+                """Generate otp"""
+                otp_value = generate_otp()
+                expiry_time = timezone.now() + timezone.timedelta(days=1)
+                UserEmailOtp.objects.create(email=email, otp=otp_value,
+                                            user_type=str(NUMBER['two']), expired_at=expiry_time,
+                                            is_verified=True)
+                UserNotification.objects.get_or_create(user=user)
+            JuniorGuardianRelationship.objects.create(guardian=guardian_data, junior=junior_data,
+                                                      relationship=relationship)
+
+            """Notification email"""
+            junior_notification_email(email, full_name, email, password)
+            junior_approval_mail(email, full_name)
+            send_notification.delay(INVITED_GUARDIAN, None, junior_data.auth.id, {})
+            send_notification.delay(APPROVED_JUNIOR, None, guardian_data.user.id, {})
+            return guardian_data
+
+class StartTaskSerializer(serializers.ModelSerializer):
+    """User task Serializer"""
+    task_duration = serializers.SerializerMethodField('get_task_duration')
+
+    def get_task_duration(self, obj):
+        """ remaining time to complete task"""
+        due_date = datetime.combine(obj.due_date, datetime.max.time())
+        # fetch real time
+        real_datetime = real_time()
+        # Perform the subtraction
+        if due_date > real_datetime:
+            time_difference = due_date - real_datetime
+            time_only = convert_timedelta_into_datetime(time_difference)
+            return str(time_difference.days) + ' days ' + str(time_only)
+        return str(NUMBER['zero']) + ' days ' + '00:00:00:00000'
+    class Meta(object):
+        """Meta class"""
+        model = JuniorTask
+        fields = ('id', 'task_duration')
+    def update(self, instance, validated_data):
+        instance.task_status = str(NUMBER['two'])
+        instance.save()
+        return instance

junior/urls.py

@@ -3,7 +3,8 @@
 from django.urls import path, include
 from .views import (UpdateJuniorProfile, ValidateGuardianCode, JuniorListAPIView, AddJuniorAPIView,
                     InvitedJuniorAPIView, FilterJuniorAPIView, RemoveJuniorAPIView, JuniorTaskListAPIView,
-                    CompleteJuniorTaskAPIView, JuniorPointsListAPIView)
+                    CompleteJuniorTaskAPIView, JuniorPointsListAPIView, ValidateReferralCode,
+                    InviteGuardianAPIView, StartTaskAPIView)
 """Third party import"""
 from rest_framework import routers
 
@@ -36,9 +37,14 @@ router.register('filter-junior', FilterJuniorAPIView, basename='filter-junior')
 router.register('junior-task-list', JuniorTaskListAPIView, basename='junior-task-list')
 # junior's task list API"""
 router.register('junior-points', JuniorPointsListAPIView, basename='junior-points')
+# validate referral code API"""
+router.register('validate-referral-code', ValidateReferralCode, basename='validate-referral-code')
+# invite guardian API"""
+router.register('invite-guardian', InviteGuardianAPIView, basename='invite-guardian')
 # Define url pattern"""
 urlpatterns = [
     path('api/v1/', include(router.urls)),
     path('api/v1/remove-junior/', RemoveJuniorAPIView.as_view()),
-    path('api/v1/complete-task/', CompleteJuniorTaskAPIView.as_view())
+    path('api/v1/complete-task/', CompleteJuniorTaskAPIView.as_view()),
+    path('api/v1/start-task/', StartTaskAPIView.as_view())
 ]

junior/utils.py

@@ -3,7 +3,8 @@
 from django.conf import settings
 """Third party Django app"""
 from templated_email import send_templated_mail
-
+from .models import JuniorPoints
+from django.db.models import F
 # junior notification
 # email for sending email
 # when guardian create junior profile
@@ -45,3 +46,15 @@ def junior_approval_mail(guardian, full_name):
         }
     )
     return full_name
+
+def update_positions_based_on_points():
+    """Update position of the junior"""
+    # First, retrieve all the JuniorPoints instances ordered by total_points in descending order.
+    juniors_points = JuniorPoints.objects.order_by('-total_points')
+
+    # Now, iterate through the queryset and update the position field based on the order.
+    position = 1
+    for junior_point in juniors_points:
+        junior_point.position = position
+        junior_point.save()
+        position += 1

junior/views.py

@@ -4,6 +4,10 @@ import os
 from rest_framework import viewsets, status, generics,views
 from rest_framework.permissions import IsAuthenticated
 from rest_framework.pagination import PageNumberPagination
+from django.contrib.auth.models import User
+from rest_framework.filters import SearchFilter
+
+import datetime
 import requests
 """Django app import"""
 
@@ -18,15 +22,24 @@ import requests
 # from utils file
 # Import account's serializer
 # Import account's task
-from junior.models import Junior
+# import junior serializer
+# Import update_positions_based_on_points
+# Import upload_image_to_alibaba
+# Import custom_response, custom_error_response
+# Import constants
+from junior.models import Junior, JuniorPoints
 from .serializers import (CreateJuniorSerializer, JuniorDetailListSerializer, AddJuniorSerializer,\
-                          RemoveJuniorSerializer, CompleteTaskSerializer, JuniorPointsSerializer)
+                          RemoveJuniorSerializer, CompleteTaskSerializer, JuniorPointsSerializer,
+                          AddGuardianSerializer, StartTaskSerializer)
 from guardian.models import Guardian, JuniorTask
 from guardian.serializers import TaskDetailsSerializer
 from base.messages import ERROR_CODE, SUCCESS_CODE
 from base.constants import NUMBER
 from account.utils import custom_response, custom_error_response
 from guardian.utils import upload_image_to_alibaba
+from .utils import update_positions_based_on_points
+from notifications.utils import send_notification
+from notifications.constants import REMOVE_JUNIOR
 
 """ Define APIs """
 # Define validate guardian code API,
@@ -37,7 +50,12 @@ from guardian.utils import upload_image_to_alibaba
 # search junior API
 # remove junior API,
 # approve junior API
-
+# create referral code
+# validation API
+# invite guardian API
+# by junior
+# Start task
+# by junior API
 # Create your views here.
 class UpdateJuniorProfile(viewsets.ViewSet):
     """Update junior profile"""
@@ -47,26 +65,31 @@ class UpdateJuniorProfile(viewsets.ViewSet):
 
     def create(self, request, *args, **kwargs):
         """Use CreateJuniorSerializer"""
-        request_data = request.data
-        image = request.data.get('image')
-        image_url = ''
-        if image:
-            if image.size == NUMBER['zero']:
-                return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
-            filename = f"images/{image.name}"
-            # upload image on ali baba
-            image_url = upload_image_to_alibaba(image, filename)
-            request_data = {"image": image_url}
-        serializer = CreateJuniorSerializer(context={"user":request.user, "image":image_url,
-                                                     "first_name": request.data.get('first_name'),
-                                                     "last_name": request.data.get('last_name')
-                                                     },
-                                            data=request_data)
-        if serializer.is_valid():
-            """save serializer"""
-            serializer.save()
-            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
-        return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            request_data = request.data
+            image = request.data.get('image')
+            image_url = ''
+            if image:
+                # check image size
+                if image.size == NUMBER['zero']:
+                    return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
+                # convert into file
+                filename = f"images/{image.name}"
+                # upload image on ali baba
+                image_url = upload_image_to_alibaba(image, filename)
+                request_data = {"image": image_url}
+            serializer = CreateJuniorSerializer(context={"user":request.user, "image":image_url,
+                                                         "first_name": request.data.get('first_name'),
+                                                         "last_name": request.data.get('last_name')
+                                                         },
+                                                data=request_data)
+            if serializer.is_valid():
+                """save serializer"""
+                serializer.save()
+                return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 class ValidateGuardianCode(viewsets.ViewSet):
     """Check guardian code exist or not"""
@@ -75,14 +98,18 @@ class ValidateGuardianCode(viewsets.ViewSet):
 
     def list(self, request, *args, **kwargs):
         """check guardian code"""
-        guardian_code = self.request.GET.get('guardian_code').split(',')
-        for code in guardian_code:
-            # fetch guardian object
-            guardian_data = Guardian.objects.filter(guardian_code=code).exists()
-            if guardian_data:
-                return custom_response(SUCCESS_CODE['3013'], response_status=status.HTTP_200_OK)
-            else:
-                return custom_error_response(ERROR_CODE["2022"], response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            guardian_code = self.request.GET.get('guardian_code').split(',')
+            for code in guardian_code:
+                # fetch guardian object
+                guardian_data = Guardian.objects.filter(guardian_code=code).exists()
+                if guardian_data:
+                    # successfully check guardian code
+                    return custom_response(SUCCESS_CODE['3013'], response_status=status.HTTP_200_OK)
+                else:
+                    return custom_error_response(ERROR_CODE["2022"], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 class JuniorListAPIView(viewsets.ModelViewSet):
     """Junior list of assosicated guardian"""
@@ -90,36 +117,63 @@ class JuniorListAPIView(viewsets.ModelViewSet):
     serializer_class = JuniorDetailListSerializer
     queryset = Junior.objects.all()
     permission_classes = [IsAuthenticated]
+    filter_backends = (SearchFilter,)
+    search_fields = ['auth__first_name', 'auth__last_name']
+    http_method_names = ('get',)
+
+    def get_queryset(self):
+        queryset = self.filter_queryset(self.queryset)
+        return queryset
 
     def list(self, request, *args, **kwargs):
         """ junior list"""
-        auth_token = self.request.META['HTTP_AUTHORIZATION']
-        headers_token = {
-            'Authorization': auth_token
-        }
-        requests.get(os.getenv('BASE_URL') + '/api/v1/top-junior/', headers=headers_token)
-        guardian_data = Guardian.objects.filter(user__email=request.user).last()
-        queryset = Junior.objects.filter(guardian_code__icontains=str(guardian_data.guardian_code))
-        # use JuniorDetailListSerializer serializer
-        serializer = JuniorDetailListSerializer(queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            update_positions_based_on_points()
+            guardian_data = Guardian.objects.filter(user__email=request.user).last()
+            # fetch junior object
+            if guardian_data:
+                queryset = self.get_queryset()
+                queryset = queryset.filter(guardian_code__icontains=str(guardian_data.guardian_code))
+                # use JuniorDetailListSerializer serializer
+                serializer = JuniorDetailListSerializer(queryset, many=True)
+                return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(ERROR_CODE['2045'], response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
 
 class AddJuniorAPIView(viewsets.ModelViewSet):
     """Add Junior by guardian"""
     queryset = Junior.objects.all()
     serializer_class = AddJuniorSerializer
     permission_classes = [IsAuthenticated]
+    http_method_names = ('post',)
+
     def create(self, request, *args, **kwargs):
         """ junior list"""
-        info = {'user': request.user, 'email': request.data['email'], 'first_name': request.data['first_name'],
-                'last_name': request.data['last_name']}
-        # use AddJuniorSerializer serializer
-        serializer = AddJuniorSerializer(data=request.data, context=info)
-        if serializer.is_valid():
-            # save serializer
-            serializer.save()
-            return custom_response(SUCCESS_CODE['3021'], serializer.data, response_status=status.HTTP_200_OK)
-        return custom_error_response(serializer.error, response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            info_data = {'user': request.user, 'relationship': str(request.data['relationship']), 'email': request.data['email'], 'first_name': request.data['first_name'],
+                         'last_name': request.data['last_name']}
+            if user := User.objects.filter(username=request.data['email']).first():
+                self.associate_guardian(user)
+                return custom_response(SUCCESS_CODE['3021'], response_status=status.HTTP_200_OK)
+            # use AddJuniorSerializer serializer
+            serializer = AddJuniorSerializer(data=request.data, context=info_data)
+            if serializer.is_valid():
+                # save serializer
+                serializer.save()
+                return custom_response(SUCCESS_CODE['3021'], serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(serializer.error, response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
+    def associate_guardian(self, user):
+        junior = Junior.objects.filter(auth=user).first()
+        guardian = Guardian.objects.filter(user=self.request.user).first()
+        junior.guardian_code = [guardian.guardian_code]
+        junior.save()
+        return True
+
 
 class InvitedJuniorAPIView(viewsets.ModelViewSet):
     """Junior list of assosicated guardian"""
@@ -128,21 +182,26 @@ class InvitedJuniorAPIView(viewsets.ModelViewSet):
     queryset = Junior.objects.all()
     permission_classes = [IsAuthenticated]
     pagination_class = PageNumberPagination
+    http_method_names = ('get',)
 
     def get_queryset(self):
         """Get the queryset for the view"""
         guardian = Guardian.objects.filter(user__email=self.request.user).last()
         junior_queryset = Junior.objects.filter(guardian_code__icontains=str(guardian.guardian_code),
-                                         is_invited=True)
+                                                is_invited=True)
         return junior_queryset
     def list(self, request, *args, **kwargs):
         """ junior list"""
-        queryset = self.get_queryset()
-        paginator = self.pagination_class()
-        paginated_queryset = paginator.paginate_queryset(queryset, request)
-        # use JuniorDetailListSerializer serializer
-        serializer = JuniorDetailListSerializer(paginated_queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            queryset = self.get_queryset()
+            paginator = self.pagination_class()
+            # pagination
+            paginated_queryset = paginator.paginate_queryset(queryset, request)
+            # use JuniorDetailListSerializer serializer
+            serializer = JuniorDetailListSerializer(paginated_queryset, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class FilterJuniorAPIView(viewsets.ModelViewSet):
@@ -151,24 +210,29 @@ class FilterJuniorAPIView(viewsets.ModelViewSet):
     permission_classes = [IsAuthenticated]
     pagination_class = PageNumberPagination
     queryset = Junior.objects.all()
+    http_method_names = ('get',)
 
     def get_queryset(self):
         """Get the queryset for the view"""
         title = self.request.GET.get('title')
         guardian_data = Guardian.objects.filter(user__email=self.request.user).last()
+        # fetch junior query
         queryset = Junior.objects.filter(guardian_code__icontains=str(guardian_data.guardian_code),
                                          is_invited=True, auth__first_name=title)
         return queryset
 
     def list(self, request, *args, **kwargs):
         """Create guardian profile"""
-        queryset = self.get_queryset()
-        paginator = self.pagination_class()
-        # use Pagination
-        paginated_queryset = paginator.paginate_queryset(queryset, request)
-        # use JuniorDetailListSerializer serializer
-        serializer = JuniorDetailListSerializer(paginated_queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            queryset = self.get_queryset()
+            paginator = self.pagination_class()
+            # use Pagination
+            paginated_queryset = paginator.paginate_queryset(queryset, request)
+            # use JuniorDetailListSerializer serializer
+            serializer = JuniorDetailListSerializer(paginated_queryset, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class RemoveJuniorAPIView(views.APIView):
@@ -178,21 +242,25 @@ class RemoveJuniorAPIView(views.APIView):
     permission_classes = [IsAuthenticated]
 
     def put(self, request, format=None):
-        junior_id = self.request.GET.get('id')
-        guardian = Guardian.objects.filter(user__email=self.request.user).last()
-        # fetch junior query
-        junior_queryset = Junior.objects.filter(id=junior_id, guardian_code__icontains=str(guardian.guardian_code),
-                                                is_invited=True).last()
-        if junior_queryset:
-            # use RemoveJuniorSerializer serializer
-            serializer = RemoveJuniorSerializer(junior_queryset, data=request.data, partial=True)
-            if serializer.is_valid():
-                # save serializer
-                serializer.save()
-                return custom_response(SUCCESS_CODE['3022'], serializer.data, response_status=status.HTTP_200_OK)
-            return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
-        else:
-            return custom_error_response(ERROR_CODE['2034'], response_status=status.HTTP_400_BAD_REQUEST)
+        try:
+            junior_id = self.request.GET.get('id')
+            guardian = Guardian.objects.filter(user__email=self.request.user).last()
+            # fetch junior query
+            junior_queryset = Junior.objects.filter(id=junior_id, guardian_code__icontains=str(guardian.guardian_code),
+                                                    is_invited=True).last()
+            if junior_queryset:
+                # use RemoveJuniorSerializer serializer
+                serializer = RemoveJuniorSerializer(junior_queryset, data=request.data, partial=True)
+                if serializer.is_valid():
+                    # save serializer
+                    serializer.save()
+                    send_notification.delay(REMOVE_JUNIOR, None, junior_queryset.auth.id, {})
+                    return custom_response(SUCCESS_CODE['3022'], serializer.data, response_status=status.HTTP_200_OK)
+                return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+            else:
+                return custom_error_response(ERROR_CODE['2034'], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class JuniorTaskListAPIView(viewsets.ModelViewSet):
@@ -201,28 +269,36 @@ class JuniorTaskListAPIView(viewsets.ModelViewSet):
     permission_classes = [IsAuthenticated]
     pagination_class = PageNumberPagination
     queryset = JuniorTask.objects.all()
+    http_method_names = ('get',)
 
     def list(self, request, *args, **kwargs):
         """Create guardian profile"""
-        status_value = self.request.GET.get('status')
-        search = self.request.GET.get('search')
-        if search and str(status_value) == '0':
-            queryset = JuniorTask.objects.filter(junior__auth=request.user,
-                                                 task_name__icontains=search).order_by('due_date', 'created_at')
-        elif search and str(status_value) != '0':
-            queryset = JuniorTask.objects.filter(junior__auth=request.user, task_name__icontains=search,
-                                                 task_status=status_value).order_by('due_date', 'created_at')
-        if search is None and str(status_value) == '0':
-            queryset = JuniorTask.objects.filter(junior__auth=request.user).order_by('due_date', 'created_at')
-        elif search is None and str(status_value) != '0':
-            queryset = JuniorTask.objects.filter(junior__auth=request.user,
-                                                 task_status=status_value).order_by('due_date','created_at')
-        paginator = self.pagination_class()
-        # use Pagination
-        paginated_queryset = paginator.paginate_queryset(queryset, request)
-        # use TaskDetailsSerializer serializer
-        serializer = TaskDetailsSerializer(paginated_queryset, many=True)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        try:
+            status_value = self.request.GET.get('status')
+            search = self.request.GET.get('search')
+            if search and str(status_value) == '0':
+                # search with title and for all task list
+                queryset = JuniorTask.objects.filter(junior__auth=request.user,
+                                                     task_name__icontains=search).order_by('due_date', 'created_at')
+            elif search and str(status_value) != '0':
+                # search with title and fetch task list with status wise
+                queryset = JuniorTask.objects.filter(junior__auth=request.user, task_name__icontains=search,
+                                                     task_status=status_value).order_by('due_date', 'created_at')
+            if search is None and str(status_value) == '0':
+                # fetch all task list
+                queryset = JuniorTask.objects.filter(junior__auth=request.user).order_by('due_date', 'created_at')
+            elif search is None and str(status_value) != '0':
+                # fetch task list with status wise
+                queryset = JuniorTask.objects.filter(junior__auth=request.user,
+                                                     task_status=status_value).order_by('due_date','created_at')
+            paginator = self.pagination_class()
+            # use Pagination
+            paginated_queryset = paginator.paginate_queryset(queryset, request)
+            # use TaskDetailsSerializer serializer
+            serializer = TaskDetailsSerializer(paginated_queryset, many=True)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
 
 
 class CompleteJuniorTaskAPIView(views.APIView):
@@ -237,12 +313,19 @@ class CompleteJuniorTaskAPIView(views.APIView):
             image = request.data['image']
             if image and image.size == NUMBER['zero']:
                 return custom_error_response(ERROR_CODE['2035'], response_status=status.HTTP_400_BAD_REQUEST)
+            # create file
             filename = f"images/{image.name}"
+            # upload image
+            filename = f"images/{image.name}"
+
             image_url = upload_image_to_alibaba(image, filename)
             # fetch junior query
             task_queryset = JuniorTask.objects.filter(id=task_id, junior__auth__email=self.request.user).last()
             if task_queryset:
-                # use RemoveJuniorSerializer serializer
+                # use CompleteTaskSerializer serializer
+                if task_queryset.task_status in [str(NUMBER['four']), str(NUMBER['five'])]:
+                    """Already request send """
+                    return custom_error_response(ERROR_CODE['2049'], response_status=status.HTTP_400_BAD_REQUEST)
                 serializer = CompleteTaskSerializer(task_queryset, data={'image': image_url}, partial=True)
                 if serializer.is_valid():
                     # save serializer
@@ -258,17 +341,96 @@ class JuniorPointsListAPIView(viewsets.ModelViewSet):
     """Junior Points viewset"""
     serializer_class = JuniorPointsSerializer
     permission_classes = [IsAuthenticated]
+    http_method_names = ('get',)
 
     def get_queryset(self):
         """get queryset"""
         return JuniorTask.objects.filter(junior__auth__email=self.request.user).last()
     def list(self, request, *args, **kwargs):
         """profile view"""
-        queryset = self.get_queryset()
-        token = self.request.META['HTTP_AUTHORIZATION']
-        headers = {
-            'Authorization': token
-        }
-        requests.get(os.getenv('BASE_URL') + '/api/v1/top-junior/', headers=headers)
-        serializer = JuniorPointsSerializer(queryset)
-        return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+
+        try:
+            queryset = self.get_queryset()
+            # update position of junior
+            update_positions_based_on_points()
+            serializer = JuniorPointsSerializer(queryset)
+            return custom_response(None, serializer.data, response_status=status.HTTP_200_OK)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
+
+class ValidateReferralCode(viewsets.ViewSet):
+    """Check guardian code exist or not"""
+    permission_classes = [IsAuthenticated]
+    http_method_names = ('get',)
+
+    def get_queryset(self):
+        """Get queryset based on referral_code."""
+        referral_code = self.request.GET.get('referral_code')
+        if referral_code:
+            # search referral code in guardian model
+            guardian_queryset = Guardian.objects.filter(referral_code=referral_code).last()
+            if guardian_queryset:
+                return guardian_queryset
+            else:
+                # search referral code in junior model
+                junior_queryset = Junior.objects.filter(referral_code=referral_code).last()
+                if junior_queryset:
+                    return junior_queryset
+        return None
+
+    def list(self, request, *args, **kwargs):
+        """check guardian code"""
+        try:
+            if self.get_queryset():
+                return custom_response(SUCCESS_CODE['3033'], response_status=status.HTTP_200_OK)
+            return custom_error_response(ERROR_CODE["2019"], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
+class InviteGuardianAPIView(viewsets.ModelViewSet):
+    """Invite guardian by junior"""
+    serializer_class = AddGuardianSerializer
+    permission_classes = [IsAuthenticated]
+    http_method_names = ('post',)
+    def create(self, request, *args, **kwargs):
+        """ junior list"""
+        try:
+            if request.data['email'] == '':
+                return custom_error_response(ERROR_CODE['2062'], response_status=status.HTTP_400_BAD_REQUEST)
+            info = {'user': request.user, 'email': request.data['email'], 'first_name': request.data['first_name'],
+                    'last_name': request.data['last_name'], 'relationship': str(request.data['relationship'])}
+            # use AddJuniorSerializer serializer
+            serializer = AddGuardianSerializer(data=request.data, context=info)
+            if serializer.is_valid():
+                # save serializer
+                serializer.save()
+                return custom_response(SUCCESS_CODE['3034'], serializer.data, response_status=status.HTTP_200_OK)
+            return custom_error_response(serializer.error, response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)
+
+
+class StartTaskAPIView(views.APIView):
+    """Update junior task API"""
+    serializer_class = StartTaskSerializer
+    model = JuniorTask
+    permission_classes = [IsAuthenticated]
+
+    def put(self, request, format=None):
+        try:
+            task_id = self.request.data.get('task_id')
+            task_queryset = JuniorTask.objects.filter(id=task_id, junior__auth__email=self.request.user).last()
+            if task_queryset and task_queryset.task_status == str(NUMBER['one']):
+                # use StartTaskSerializer serializer
+                serializer = StartTaskSerializer(task_queryset, data=request.data, partial=True)
+                if serializer.is_valid():
+                    # save serializer
+                    serializer.save()
+                    return custom_response(SUCCESS_CODE['3035'], serializer.data, response_status=status.HTTP_200_OK)
+                return custom_error_response(serializer.errors, response_status=status.HTTP_400_BAD_REQUEST)
+            else:
+                # task in another state
+                return custom_error_response(ERROR_CODE['2060'], response_status=status.HTTP_400_BAD_REQUEST)
+        except Exception as e:
+            return custom_error_response(str(e), response_status=status.HTTP_400_BAD_REQUEST)

notifications/constants.py

@@ -1,7 +1,19 @@
 """
 notification constants file
 """
-REGISTRATION = 1
+from base.constants import NUMBER
+REGISTRATION = NUMBER['one']
+TASK_CREATED = NUMBER['two']
+INVITED_GUARDIAN = NUMBER['three']
+APPROVED_JUNIOR = NUMBER['four']
+REFERRAL_POINTS = NUMBER['five']
+TASK_POINTS = NUMBER['six']
+TASK_REJECTED = NUMBER['seven']
+SKIPPED_PROFILE_SETUP = NUMBER['eight']
+TASK_SUBMITTED = NUMBER['nine']
+TASK_ACTION = NUMBER['ten']
+LEADERBOARD_RANKING = NUMBER['eleven']
+REMOVE_JUNIOR = NUMBER['twelve']
 TEST_NOTIFICATION = 99
 
 NOTIFICATION_DICT = {
@@ -9,6 +21,50 @@ NOTIFICATION_DICT = {
         "title": "Successfully registered!",
         "body": "You have registered successfully. Now login and complete your profile."
     },
+    TASK_CREATED: {
+        "title": "Task created!",
+        "body": "Task created successfully."
+    },
+    INVITED_GUARDIAN: {
+        "title": "Invite guardian",
+        "body": "Invite guardian successfully"
+    },
+    APPROVED_JUNIOR: {
+        "title": "Approve junior",
+        "body": "You have request from junior to associate with you"
+    },
+    REFERRAL_POINTS: {
+        "title": "Earn Referral points",
+        "body": "You earn 5 points for referral."
+    },
+    TASK_POINTS: {
+        "title": "Earn Task points!",
+        "body": "You earn 5 points for task."
+    },
+    TASK_REJECTED: {
+        "title": "Task rejected!",
+        "body": "Your task has been rejected."
+    },
+    SKIPPED_PROFILE_SETUP: {
+        "title": "Skipped profile setup!",
+        "body": "Your guardian has been setup your profile."
+    },
+    TASK_SUBMITTED: {
+        "title": "Task submitted!",
+        "body": "Your task has been submitted successfully."
+    },
+    TASK_ACTION: {
+        "title": "Task approval!",
+        "body": "You have request for task approval."
+    },
+    LEADERBOARD_RANKING: {
+        "title": "Leader board rank!",
+        "body": "Your rank is ."
+    },
+    REMOVE_JUNIOR: {
+        "title": "Disassociate by guardian!",
+        "body": "Your guardian disassociate you ."
+    },
     TEST_NOTIFICATION: {
         "title": "Test Notification",
         "body": "This notification is for testing purpose"

notifications/utils.py

@@ -52,7 +52,6 @@ def send_notification(notification_type, from_user_id, to_user_id, extra_data):
     """ used to send the push for the given notification type """
     (notification_data, from_user, to_user) = get_basic_detail(notification_type, from_user_id, to_user_id)
     user_notification_type = UserNotification.objects.filter(user=to_user).first()
-    # data = notification_data.data
     data = notification_data
     Notification.objects.create(notification_type=notification_type, notification_from=from_user,
                                 notification_to=to_user, data=data)

notifications/views.py

@@ -18,7 +18,7 @@ from notifications.utils import send_notification
 
 class NotificationViewSet(viewsets.GenericViewSet):
     """ used to do the notification actions """
-    serializer_class = None
+    serializer_class = RegisterDevice
     permission_classes = [IsAuthenticated, ]
 
     @action(methods=['post'], detail=False, url_path='device', url_name='device', serializer_class=RegisterDevice)
@@ -32,7 +32,7 @@ class NotificationViewSet(viewsets.GenericViewSet):
         serializer.save()
         return custom_response(SUCCESS_CODE["3000"])
 
-    @action(methods=['get'], detail=False, url_path='test', url_name='test', serializer_class=None)
+    @action(methods=['get'], detail=False, url_path='test', url_name='test')
     def send_test_notification(self, request):
         """
         to send test notification

requirements.txt

@@ -8,6 +8,7 @@ async-timeout==4.0.2
 billiard==4.1.0
 boto3==1.26.157
 botocore==1.29.157
+CacheControl==0.13.1
 cachetools==5.3.1
 celery==5.3.1
 certifi==2023.5.7
@@ -41,8 +42,22 @@ django-timezone-field==5.1
 djangorestframework==3.14.0
 djangorestframework-simplejwt==5.2.2
 drf-yasg==1.21.6
+fcm-django==2.0.0
+firebase-admin==6.2.0
+google-api-core==2.11.1
+google-api-python-client==2.93.0
 google-auth==2.21.0
+google-auth-httplib2==0.1.0
+google-cloud-core==2.3.3
+google-cloud-firestore==2.11.1
+google-cloud-storage==2.10.0
+google-crc32c==1.5.0
+google-resumable-media==2.5.0
+googleapis-common-protos==1.59.1
+grpcio==1.56.0
+grpcio-status==1.56.0
 gunicorn==20.1.0
+httplib2==0.22.0
 idna==3.4
 inflection==0.5.1
 itypes==1.2.0
@@ -58,12 +73,15 @@ packaging==23.1
 phonenumbers==8.13.15
 Pillow==9.5.0
 prompt-toolkit==3.0.38
+proto-plus==1.22.3
+protobuf==4.23.4
 psycopg==3.1.9
 pyasn1==0.5.0
 pyasn1-modules==0.3.0
 pycparser==2.21
 pycryptodome==3.18.0
 PyJWT==2.7.0
+pyparsing==3.1.0
 python-crontab==2.7.1
 python-dateutil==2.8.2
 python-dotenv==1.0.0
@@ -81,5 +99,3 @@ uritemplate==4.1.1
 urllib3==1.26.16
 vine==5.0.0
 wcwidth==0.2.6
-
-fcm-django==2.0.0

web_admin/admin.py

@@ -5,7 +5,7 @@ web_admin admin file
 from django.contrib import admin
 
 # local imports
-from web_admin.models import Article, ArticleCard, ArticleSurvey, SurveyOption
+from web_admin.models import Article, ArticleCard, ArticleSurvey, SurveyOption, DefaultArticleCardImage
 
 
 @admin.register(Article)
@@ -17,7 +17,7 @@ class ArticleAdmin(admin.ModelAdmin):
 @admin.register(ArticleCard)
 class ArticleCardAdmin(admin.ModelAdmin):
     """Article Card Admin"""
-    list_display = ['id', 'article', 'title', 'description', 'image']
+    list_display = ['id', 'article', 'title', 'description', 'image_url']
 
 
 @admin.register(ArticleSurvey)
@@ -30,3 +30,9 @@ class ArticleSurveyAdmin(admin.ModelAdmin):
 class SurveyOptionAdmin(admin.ModelAdmin):
     """Survey Option Admin"""
     list_display = ['id', 'survey', 'option', 'is_answer']
+
+
+@admin.register(DefaultArticleCardImage)
+class DefaultArticleCardImagesAdmin(admin.ModelAdmin):
+    """Default Article Card Images Option Admin"""
+    list_display = ['image_name', 'image_url']

web_admin/migrations/0003_defaultarticlecardimage_and_more.py

@@ -0,0 +1,28 @@
+# Generated by Django 4.2.2 on 2023-07-24 14:15
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('web_admin', '0002_alter_articlecard_image'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='DefaultArticleCardImage',
+            fields=[
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('image_name', models.CharField(max_length=20)),
+                ('image_url', models.URLField()),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('updated_at', models.DateTimeField(auto_now=True)),
+            ],
+        ),
+        migrations.RenameField(
+            model_name='articlecard',
+            old_name='image',
+            new_name='image_url',
+        ),
+    ]

web_admin/migrations/0004_alter_surveyoption_survey.py

@@ -0,0 +1,19 @@
+# Generated by Django 4.2.2 on 2023-08-01 07:35
+
+from django.db import migrations, models
+import django.db.models.deletion
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('web_admin', '0003_defaultarticlecardimage_and_more'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='surveyoption',
+            name='survey',
+            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='options', to='web_admin.articlesurvey'),
+        ),
+    ]

web_admin/models.py

@@ -28,7 +28,7 @@ class ArticleCard(models.Model):
     article = models.ForeignKey(Article, on_delete=models.CASCADE, related_name='article_cards')
     title = models.CharField(max_length=255)
     description = models.TextField()
-    image = models.URLField(null=True, blank=True, default=None)
+    image_url = models.URLField(null=True, blank=True, default=None)
     created_at = models.DateTimeField(auto_now_add=True)
     updated_at = models.DateTimeField(auto_now=True)
 
@@ -56,7 +56,7 @@ class SurveyOption(models.Model):
     """
     Survey Options model
     """
-    survey = models.ForeignKey(ArticleSurvey, on_delete=models.CASCADE, related_name='survey_options')
+    survey = models.ForeignKey(ArticleSurvey, on_delete=models.CASCADE, related_name='options')
     option = models.CharField(max_length=255)
     is_answer = models.BooleanField(default=False)
     created_at = models.DateTimeField(auto_now_add=True)
@@ -65,3 +65,17 @@ class SurveyOption(models.Model):
     def __str__(self):
         """Return title"""
         return f'{self.id} | {self.survey}'
+
+
+class DefaultArticleCardImage(models.Model):
+    """
+    Default images upload in oss bucket
+    """
+    image_name = models.CharField(max_length=20)
+    image_url = models.URLField()
+    created_at = models.DateTimeField(auto_now_add=True)
+    updated_at = models.DateTimeField(auto_now=True)
+
+    def __str__(self):
+        """return image_name as an object"""
+        return self.image_name

web_admin/serializers/article_serializer.py

@@ -3,13 +3,17 @@ web_admin serializers file
 """
 # django imports
 from rest_framework import serializers
+from django.contrib.auth import get_user_model
 
-from base.constants import ARTICLE_SURVEY_POINTS, MAX_ARTICLE_CARD, MIN_ARTICLE_SURVEY, MAX_ARTICLE_SURVEY
+from base.constants import (ARTICLE_SURVEY_POINTS, MAX_ARTICLE_CARD, MIN_ARTICLE_SURVEY, MAX_ARTICLE_SURVEY, NUMBER,
+                            USER_TYPE, ARTICLE_CARD_IMAGE_FOLDER)
 # local imports
 from base.messages import ERROR_CODE
 from guardian.utils import upload_image_to_alibaba
-from web_admin.models import Article, ArticleCard, SurveyOption, ArticleSurvey
-from web_admin.utils import pop_id
+from web_admin.models import Article, ArticleCard, SurveyOption, ArticleSurvey, DefaultArticleCardImage
+from web_admin.utils import pop_id, get_image_url
+
+USER = get_user_model()
 
 
 class ArticleCardSerializer(serializers.ModelSerializer):
@@ -18,23 +22,22 @@ class ArticleCardSerializer(serializers.ModelSerializer):
     """
     id = serializers.IntegerField(required=False)
     image = serializers.FileField(required=False)
+    image_url = serializers.URLField(required=False)
 
     class Meta:
         """
         meta class
         """
         model = ArticleCard
-        fields = ('id', 'title', 'description', 'image')
+        fields = ('id', 'title', 'description', 'image', 'image_url')
 
     def create(self, validated_data):
-        image = validated_data.get('image', '')
-        filename = f"article/{image.name}"
-        # upload image on ali baba
-        validated_data['image'] = upload_image_to_alibaba(image, filename)
-
-        article_card = ArticleCard.objects.create(article_id='1', **validated_data)
+        validated_data['image_url'] = get_image_url(validated_data)
+        article = Article.objects.all().first()
+        article_card = ArticleCard.objects.create(article=article, **validated_data)
         return article_card
 
+
 class SurveyOptionSerializer(serializers.ModelSerializer):
     """
     survey option serializer
@@ -54,14 +57,14 @@ class ArticleSurveySerializer(serializers.ModelSerializer):
     article survey serializer
     """
     id = serializers.IntegerField(required=False)
-    survey_options = SurveyOptionSerializer(many=True)
+    options = SurveyOptionSerializer(many=True)
 
     class Meta:
         """
         meta class
         """
         model = ArticleSurvey
-        fields = ('id', 'question', 'survey_options')
+        fields = ('id', 'question', 'options')
 
 
 class ArticleSerializer(serializers.ModelSerializer):
@@ -81,7 +84,6 @@ class ArticleSerializer(serializers.ModelSerializer):
     def validate(self, attrs):
         """
         to validate request data
-        :param attrs:
         :return: validated attrs
         """
         article_cards = attrs.get('article_cards', None)
@@ -97,7 +99,6 @@ class ArticleSerializer(serializers.ModelSerializer):
         """
         to create article.
         ID in post data dict is for update api.
-        :param validated_data:
         :return: article object
         """
         article_cards = validated_data.pop('article_cards')
@@ -107,11 +108,12 @@ class ArticleSerializer(serializers.ModelSerializer):
 
         for card in article_cards:
             card = pop_id(card)
+            card['image_url'] = get_image_url(card)
             ArticleCard.objects.create(article=article, **card)
 
         for survey in article_survey:
             survey = pop_id(survey)
-            options = survey.pop('survey_options')
+            options = survey.pop('options')
             survey_obj = ArticleSurvey.objects.create(article=article, points=ARTICLE_SURVEY_POINTS, **survey)
             for option in options:
                 option = pop_id(option)
@@ -122,8 +124,7 @@ class ArticleSerializer(serializers.ModelSerializer):
     def update(self, instance, validated_data):
         """
         to update article and related table
-        :param instance:
-        :param validated_data:
+        :param instance: article object,
         :return: article object
         """
         article_cards = validated_data.pop('article_cards')
@@ -131,31 +132,36 @@ class ArticleSerializer(serializers.ModelSerializer):
         instance.title = validated_data.get('title', instance.title)
         instance.description = validated_data.get('description', instance.description)
         instance.save()
-
+        prev_card = list(ArticleCard.objects.filter(article=instance).values_list('id', flat=True))
         # Update or create cards
         for card_data in article_cards:
             card_id = card_data.get('id', None)
             if card_id:
+                prev_card.remove(card_id)
                 card = ArticleCard.objects.get(id=card_id, article=instance)
                 card.title = card_data.get('title', card.title)
                 card.description = card_data.get('description', card.description)
-                card.image = card_data.get('image', card.image)
+                card.image_url = get_image_url(card_data)
                 card.save()
             else:
                 card_data = pop_id(card_data)
+                card_data['image_url'] = get_image_url(card_data)
                 ArticleCard.objects.create(article=instance, **card_data)
+        ArticleCard.objects.filter(id__in=prev_card, article=instance).delete()
 
+        prev_survey = list(ArticleSurvey.objects.filter(article=instance).values_list('id', flat=True))
         # Update or create survey sections
         for survey_data in article_survey:
             survey_id = survey_data.get('id', None)
-            options_data = survey_data.pop('survey_options')
+            options_data = survey_data.pop('options')
             if survey_id:
+                prev_survey.remove(survey_id)
                 survey = ArticleSurvey.objects.get(id=survey_id, article=instance)
                 survey.question = survey_data.get('question', survey.question)
                 survey.save()
             else:
                 survey_data = pop_id(survey_data)
-                survey = ArticleSurvey.objects.create(article=instance, **survey_data)
+                survey = ArticleSurvey.objects.create(article=instance, points=ARTICLE_SURVEY_POINTS, **survey_data)
 
             # Update or create survey options
             for option_data in options_data:
@@ -168,5 +174,93 @@ class ArticleSerializer(serializers.ModelSerializer):
                 else:
                     option_data = pop_id(option_data)
                     SurveyOption.objects.create(survey=survey, **option_data)
+        ArticleSurvey.objects.filter(id__in=prev_survey, article=instance).delete()
 
         return instance
+
+
+class DefaultArticleCardImageSerializer(serializers.ModelSerializer):
+    """
+    Article Card serializer
+    """
+    image = serializers.FileField(required=False)
+    image_url = serializers.URLField(required=False)
+
+    class Meta:
+        """
+        meta class
+        """
+        model = DefaultArticleCardImage
+        fields = ('image_name', 'image', 'image_url')
+
+    def validate(self, attrs):
+        """
+        to validate data
+        :return: validated data
+        """
+        if 'image' not in attrs and attrs.get('image') is None:
+            raise serializers.ValidationError({'details': ERROR_CODE['2061']})
+        image = attrs.get('image')
+        if image and image.size == NUMBER['zero']:
+            raise serializers.ValidationError(ERROR_CODE['2035'])
+        return attrs
+
+    def create(self, validated_data):
+        """
+        to create and upload image
+        :return: card_image object
+        """
+        validated_data['image_url'] = get_image_url(validated_data)
+
+        card_image = DefaultArticleCardImage.objects.create(**validated_data)
+        return card_image
+
+
+class UserManagementListSerializer(serializers.ModelSerializer):
+    """
+    user management serializer
+    """
+    name = serializers.SerializerMethodField()
+    phone_number = serializers.SerializerMethodField()
+    user_type = serializers.SerializerMethodField()
+
+    class Meta:
+        """
+        meta class
+        """
+        model = USER
+        fields = ('name', 'email', 'phone_number', 'user_type', 'is_active')
+
+    @staticmethod
+    def get_name(obj):
+        """
+        :param obj: user object
+        :return: full name
+        """
+        return (obj.first_name + obj.last_name) if obj.last_name else obj.first_name
+
+    @staticmethod
+    def get_phone_number(obj):
+        """
+        :param obj: user object
+        :return: user phone number
+        """
+        if profile := obj.guardian_profile.all().first():
+            return profile.phone
+        elif profile := obj.junior_profile.all().first():
+            return profile.phone
+        else:
+            return None
+
+    @staticmethod
+    def get_user_type(obj):
+        """
+        :param obj: user object
+        :return: user type
+        """
+        if obj.guardian_profile.all().first():
+            return dict(USER_TYPE).get('2')
+        elif obj.junior_profile.all().first():
+            return dict(USER_TYPE).get('1')
+        else:
+            return None

web_admin/serializers/auth_serializer.py

@@ -0,0 +1,134 @@
+"""
+web_admin auth serializers file
+"""
+# python imports
+from datetime import datetime
+
+# django imports
+from rest_framework import serializers
+from django.contrib.auth import get_user_model
+from django.utils import timezone
+
+# local imports
+from account.models import UserEmailOtp
+from base.constants import USER_TYPE
+from base.messages import ERROR_CODE
+from guardian.tasks import generate_otp
+from base.tasks import send_email_otp
+
+USER = get_user_model()
+
+
+class AdminOTPSerializer(serializers.ModelSerializer):
+    """
+    admin forgot password serializer
+    """
+    email = serializers.EmailField()
+
+    class Meta:
+        """
+        meta class
+        """
+        model = USER
+        fields = ('email',)
+
+    def validate(self, attrs):
+        """ used to validate the incoming data """
+        user = USER.objects.filter(email=attrs.get('email')).first()
+        if not user:
+            raise serializers.ValidationError({'details': ERROR_CODE['2004']})
+        elif not user.is_superuser:
+            raise serializers.ValidationError({'details': ERROR_CODE['2063']})
+        attrs.update({'user': user})
+        return attrs
+
+    def create(self, validated_data):
+        """
+        to send otp
+        :return: user_data
+        """
+        email = validated_data['email']
+
+        verification_code = generate_otp()
+
+        # Send the verification code to the user's email
+        send_email_otp.delay(email, verification_code)
+
+        expiry = timezone.now() + timezone.timedelta(days=1)
+        user_data, created = UserEmailOtp.objects.update_or_create(email=email,
+                                                                   defaults={
+                                                                       "otp": verification_code,
+                                                                       "expired_at": expiry,
+                                                                       "user_type": dict(USER_TYPE).get('3'),
+                                                                   })
+
+        return user_data
+
+
+class AdminVerifyOTPSerializer(serializers.Serializer):
+    """
+    admin verify otp serializer
+    """
+    email = serializers.EmailField()
+    otp = serializers.CharField(max_length=6, min_length=6)
+
+    class Meta:
+        """ meta class """
+        fields = ('email', 'otp',)
+
+    def validate(self, attrs):
+        """
+        to validate data
+        :return: validated data
+        """
+        email = attrs.get('email')
+        otp = attrs.get('otp')
+
+        # fetch email otp object of the user
+        user_otp_details = UserEmailOtp.objects.filter(email=email, otp=otp).last()
+        if not user_otp_details:
+            raise serializers.ValidationError({'details': ERROR_CODE['2064']})
+        if user_otp_details.user_type != dict(USER_TYPE).get('3'):
+            raise serializers.ValidationError({'details': ERROR_CODE['2063']})
+        if user_otp_details.expired_at.replace(tzinfo=None) < datetime.utcnow():
+            raise serializers.ValidationError({'details': ERROR_CODE['2029']})
+        user_otp_details.is_verified = True
+        user_otp_details.save()
+        return attrs
+
+
+class AdminCreatePasswordSerializer(serializers.ModelSerializer):
+    """
+    admin create new password serializer
+    """
+    email = serializers.EmailField()
+    new_password = serializers.CharField()
+    confirm_password = serializers.CharField()
+
+    class Meta:
+        """
+        meta class
+        """
+        model = USER
+        fields = ('email', 'new_password', 'confirm_password')
+
+    def validate(self, attrs):
+        """
+        to validate data
+        :return: validated data
+        """
+        email = attrs.get('email')
+        new_password = attrs.get('new_password')
+        confirm_password = attrs.get('confirm_password')
+
+        # matching password
+        if new_password != confirm_password:
+            raise serializers.ValidationError({'details': ERROR_CODE['2065']})
+
+        user_otp_details = UserEmailOtp.objects.filter(email=email, is_verified=True).last()
+        if not user_otp_details:
+            raise serializers.ValidationError({'details': ERROR_CODE['2064']})
+        if user_otp_details.user_type != dict(USER_TYPE).get('3'):
+            raise serializers.ValidationError({'details': ERROR_CODE['2063']})
+        user_otp_details.delete()
+        return attrs

web_admin/urls.py

@@ -6,12 +6,18 @@ from django.urls import path, include
 from rest_framework import routers
 
 # local imports
-from web_admin.views import ArticleViewSet
+from web_admin.views.article import ArticleViewSet, DefaultArticleCardImagesViewSet, UserManagementViewSet
+from web_admin.views.auth import ForgotAndResetPasswordViewSet
 
 # initiate router
 router = routers.SimpleRouter()
 
 router.register('article', ArticleViewSet, basename='article')
+router.register('default-card-images', DefaultArticleCardImagesViewSet, basename='default-card-images')
+router.register('user', UserManagementViewSet, basename='user')
+
+# forgot and reset password api for admin
+router.register('admin', ForgotAndResetPasswordViewSet, basename='admin')
 
 urlpatterns = [
     path('api/v1/', include(router.urls)),

web_admin/utils.py

@@ -1,6 +1,8 @@
 """
 web_utils file
 """
+from base.constants import ARTICLE_CARD_IMAGE_FOLDER
+from guardian.utils import upload_image_to_alibaba
 
 
 def pop_id(data):
@@ -11,3 +13,14 @@ def pop_id(data):
     """
     data.pop('id') if 'id' in data else data
     return data
+
+
+def get_image_url(data):
+    if 'image_url' in data:
+        return data['image_url']
+    elif 'image' in data and data['image'] is not None:
+        image = data.pop('image')
+        filename = f"{ARTICLE_CARD_IMAGE_FOLDER}/{image.name}"
+        # upload image on ali baba
+        image_url = upload_image_to_alibaba(image, filename)
+        return image_url

web_admin/views/article.py

@@ -3,18 +3,23 @@ web_admin views file
 """
 # django imports
 from rest_framework.viewsets import GenericViewSet, mixins
-from rest_framework.response import Response
 from rest_framework.filters import OrderingFilter, SearchFilter
 from rest_framework import status
 from rest_framework.decorators import action
-from rest_framework.permissions import IsAuthenticated
+from rest_framework.permissions import IsAuthenticated, AllowAny
+from django.contrib.auth import get_user_model
 
 # local imports
 from account.utils import custom_response, custom_error_response
+from base.constants import USER_TYPE
 from base.messages import SUCCESS_CODE, ERROR_CODE
-from web_admin.models import Article, ArticleCard, ArticleSurvey
+from web_admin.models import Article, ArticleCard, ArticleSurvey, DefaultArticleCardImage
 from web_admin.permission import AdminPermission
-from web_admin.serializers import ArticleSerializer, ArticleCardSerializer
+from web_admin.serializers.article_serializer import (ArticleSerializer, ArticleCardSerializer,
+                                                      DefaultArticleCardImageSerializer,
+                                                      UserManagementListSerializer)
+
+USER = get_user_model()
 
 
 class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModelMixin,
@@ -31,7 +36,7 @@ class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModel
 
     def get_queryset(self):
         article = self.queryset.objects.filter(is_deleted=False).prefetch_related(
-            'article_cards', 'article_survey', 'article_survey__survey_options'
+            'article_cards', 'article_survey', 'article_survey__options'
         ).order_by('-created_at')
         queryset = self.filter_queryset(article)
         return queryset
@@ -105,7 +110,7 @@ class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModel
         return custom_error_response(ERROR_CODE["2041"], status.HTTP_400_BAD_REQUEST)
 
     @action(methods=['get'], url_name='remove_card', url_path='remove_card',
-            detail=True, serializer_class=None)
+            detail=True)
     def remove_article_card(self, request, *args, **kwargs):
         """
         article card remove (delete) api method
@@ -121,7 +126,7 @@ class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModel
             return custom_error_response(ERROR_CODE["2042"], response_status=status.HTTP_400_BAD_REQUEST)
 
     @action(methods=['get'], url_name='remove_survey', url_path='remove_survey',
-            detail=True, serializer_class=None)
+            detail=True)
     def remove_article_survey(self, request, *args, **kwargs):
         """
         article survey remove (delete) api method
@@ -137,7 +142,7 @@ class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModel
             return custom_error_response(ERROR_CODE["2043"], response_status=status.HTTP_400_BAD_REQUEST)
 
     @action(methods=['post'], url_name='test-add-card', url_path='test-add-card',
-            detail=False, serializer_class=ArticleCardSerializer)
+            detail=False, serializer_class=ArticleCardSerializer, permission_classes=[AllowAny])
     def add_card(self, request):
         """
         :param request:
@@ -147,3 +152,73 @@ class ArticleViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.UpdateModel
         serializer.is_valid(raise_exception=True)
         serializer.save()
         return custom_response(SUCCESS_CODE["3000"])
+
+    @action(methods=['get'], url_name='test-list-card', url_path='test-list-card',
+            detail=False, serializer_class=ArticleCardSerializer, permission_classes=[AllowAny])
+    def list_card(self, request):
+        """
+        :param request:
+        :return:
+        """
+        queryset = ArticleCard.objects.all()
+        serializer = self.serializer_class(queryset, many=True)
+        return custom_response(None, serializer.data)
+
+
+class DefaultArticleCardImagesViewSet(GenericViewSet, mixins.CreateModelMixin, mixins.ListModelMixin):
+    """
+    api to upload and list default article card images
+    """
+    serializer_class = DefaultArticleCardImageSerializer
+    permission_classes = [IsAuthenticated, AdminPermission]
+    queryset = DefaultArticleCardImage.objects.all()
+
+    def create(self, request, *args, **kwargs):
+        """
+        api method to upload default article card images
+        :param request:
+        :return: success message
+        """
+        serializer = self.serializer_class(data=request.data)
+        serializer.is_valid(raise_exception=True)
+        serializer.save()
+        return custom_response(SUCCESS_CODE["3000"])
+
+    def list(self, request, *args, **kwargs):
+        """
+        api method to list default article card images
+        :param request:
+        :return: default article card images
+        """
+        queryset = self.queryset
+        serializer = self.serializer_class(queryset, many=True)
+        return custom_response(None, data=serializer.data)
+
+
+class UserManagementViewSet(GenericViewSet, mixins.ListModelMixin):
+    """
+    api to manage (list, view, edit) user
+    """
+    serializer_class = UserManagementListSerializer
+    permission_classes = []
+    queryset = USER.objects.prefetch_related(
+            'guardian_profile', 'junior_profile')
+
+    def get_queryset(self):
+        if self.request.query_params.get('user_type') == dict(USER_TYPE).get('2'):
+            return self.queryset.filter(junior_profile__isnull=True)
+        elif self.request.query_params.get('user_type') == dict(USER_TYPE).get('1'):
+            return self.queryset.filter(guardian_profile__isnull=True)
+        else:
+            return self.queryset
+
+    def list(self, request, *args, **kwargs):
+        """
+        api method to list all the user
+        :param request:
+        :return:
+        """
+        queryset = self.get_queryset()
+        serializer = self.serializer_class(queryset, many=True)
+        return custom_response(None, data=serializer.data)
+

web_admin/views/auth.py

@@ -0,0 +1,63 @@
+"""
+web_admin auth views file
+"""
+# django imports
+from rest_framework.viewsets import GenericViewSet
+from rest_framework.decorators import action
+from  rest_framework import status
+from django.contrib.auth import get_user_model
+
+# local imports
+from account.utils import custom_response, custom_error_response
+from base.messages import SUCCESS_CODE, ERROR_CODE
+from web_admin.serializers.auth_serializer import (AdminOTPSerializer, AdminVerifyOTPSerializer,
+                                                   AdminCreatePasswordSerializer)
+
+USER = get_user_model()
+
+
+class ForgotAndResetPasswordViewSet(GenericViewSet):
+    """
+    to reset admin password
+    """
+    queryset = None
+
+    @action(methods=['post'], url_name='otp', url_path='otp',
+            detail=False, serializer_class=AdminOTPSerializer)
+    def admin_otp(self, request):
+        """
+        api method to send otp
+        :return: success message
+        """
+        serializer = self.serializer_class(data=request.data)
+        if serializer.is_valid():
+            serializer.save()
+            return custom_response(SUCCESS_CODE['3015'])
+        return custom_error_response(ERROR_CODE['2063'], status.HTTP_400_BAD_REQUEST)
+
+    @action(methods=['post'], url_name='verify-otp', url_path='verify-otp',
+            detail=False, serializer_class=AdminVerifyOTPSerializer)
+    def admin_verify_otp(self, request):
+        """
+        api method to verify otp
+        :return: success message
+        """
+        serializer = self.serializer_class(data=request.data)
+        if serializer.is_valid():
+            return custom_response(SUCCESS_CODE['3011'])
+        return custom_error_response(ERROR_CODE['2063'], status.HTTP_400_BAD_REQUEST)
+
+    @action(methods=['post'], url_name='create-password', url_path='create-password',
+            detail=False, serializer_class=AdminCreatePasswordSerializer)
+    def admin_create_password(self, request):
+        """
+        api method to create new password
+        :return: success message
+        """
+        serializer = self.serializer_class(data=request.data)
+        if serializer.is_valid():
+            user = USER.objects.filter(email=serializer.validated_data.get('email')).first()
+            user.set_password(serializer.validated_data.get('new_password'))
+            user.save()
+            return custom_response(SUCCESS_CODE['3007'])
+        return custom_error_response(ERROR_CODE['2064'], status.HTTP_400_BAD_REQUEST)

zod_bank/celery.py

@@ -32,3 +32,14 @@ app.autodiscover_tasks()
 def debug_task(self):
     """ celery debug task """
     print(f'Request: {self.request!r}')
+
+
+"""cron task"""
+
+
+app.conf.beat_schedule = {
+    "expired_task": {
+            "task": "guardian.utils.update_expired_task_status",
+            "schedule": crontab(minute=0, hour=0),
+    },
+}

zod_bank/settings.py

@@ -61,6 +61,7 @@ INSTALLED_APPS = [
     'django.contrib.postgres',
     'rest_framework',
     'fcm_django',
+    'django_celery_beat',
     # Add your custom apps here.
     'django_ses',
     'account',
@@ -119,6 +120,7 @@ REST_FRAMEWORK = {
 SIMPLE_JWT = {
     'ACCESS_TOKEN_LIFETIME': timedelta(hours=2, minutes=59, seconds=59, microseconds=999999),
     'REFRESH_TOKEN_LIFETIME': timedelta(hours=71, minutes=59, seconds=59, microseconds=999999),
+
 }
 # Database
 # https://docs.djangoproject.com/en/3.0/ref/settings/#databases
@@ -257,6 +259,7 @@ DEFAULT_ADDRESS = os.getenv("DEFAULT_ADDRESS")
 
 
 # ali baba cloud settings
+
 ALIYUN_OSS_ACCESS_KEY_ID = os.getenv('ALIYUN_OSS_ACCESS_KEY_ID')
 ALIYUN_OSS_ACCESS_KEY_SECRET = os.getenv('ALIYUN_OSS_ACCESS_KEY_SECRET')
 ALIYUN_OSS_BUCKET_NAME = os.getenv('ALIYUN_OSS_BUCKET_NAME')