Fx dashboard

.env-example

@@ -21,4 +21,7 @@ DATABASE_URL='postgres://mfl_testing:mfl_testing@localhost:5432/mfl_testing'
 FRONTEND_URL='http://localhost:8062'
 REALTIME_INDEX = true
 HTTPS_ENABLED = false
-ALLOWED_HOSTS=".localhost, .health.go.ke"
+ALLOWED_HOSTS=".localhost, .health.go.ke"
+
+# Toggle synchronization of the facilities to KHIS Tracker
+PUSH_TO_TRACKER=false

after_disaster_scripts.py

@@ -78,14 +78,13 @@ def load_wards_and_sub_counties_json_file():
             try:
                 county_obj = County.objects.get(name__contains=county_name)
             except:
-                import pdb
-                pdb.set_trace()
+
             try:
                 constituency_obj = Constituency.objects.get(
                     name=constituency_name, county=county_obj)
             except:
-                import pdb
-                pdb.set_trace()
+
+
             try:
                 sub = SubCounty.objects.get(
                     name=sub_county_name.lower(), county=county_obj)
@@ -105,8 +104,8 @@ def load_wards_and_sub_counties_json_file():
                     county_name, constituency_name,
                     sub_county_name, ward_name)
             except:
-                import pdb
-                pdb.set_trace()
+
+
 
 
 def delete_unwanted_facilities():
@@ -126,8 +125,8 @@ def delete_unwanted_facilities():
         for fc in FacilityContact.everything.filter(facility=facility):
             for con in Contact.objects.filter(contact=fc.contact):
                 con.delete()
-            import pdb
-            pdb.set_trace()
+
+
             fc.delete()
 
         for unit in FacilityUnit.objects.filter(facility=facility):

chul/models.py

@@ -226,6 +226,15 @@ def pending_updates(self):
             return chu.updates
         except ChuUpdateBuffer.DoesNotExist:
             return {}
+        except ChuUpdateBuffer.MultipleObjectsReturned:
+
+            latest_chu = ChuUpdateBuffer.objects.filter(
+                is_approved=False,
+                is_rejected=False,
+                health_unit=self
+            ).order_by('-updated').first()
+            return latest_chu.updates
+
 
     @property
     def latest_update(self):
@@ -283,6 +292,7 @@ def push_chu_to_dhis2(self):
             },
             "openingDate": self.date_operational.strftime("%Y-%m-%d"),
         }
+
         metadata_payload = {
             "keph": 'axUnguN4QDh'
         }
@@ -484,19 +494,23 @@ def validate_atleast_one_attribute_updated(self):
             raise ValidationError({"__all__": ["Nothing was edited"]})
 
     def update_basic_details(self):
-        basic_details = json.loads(self.basic)
-        if 'status' in basic_details:
-            basic_details['status_id'] = basic_details.get(
-                'status').get('status_id')
-            basic_details.pop('status')
-        if 'facility' in basic_details:
-            basic_details['facility_id'] = basic_details.get(
-                'facility').get('facility_id')
-            basic_details.pop('facility')
-
-        for key, value in basic_details.iteritems():
-            setattr(self.health_unit, key, value)
-        self.health_unit.save()
+        if self.basic:
+            basic_details = json.loads(self.basic)
+            if 'status' in basic_details:
+                basic_details['status_id'] = basic_details.get(
+                    'status').get('status_id')
+                basic_details.pop('status')
+            if 'facility' in basic_details:
+                basic_details['facility_id'] = basic_details.get(
+                    'facility').get('facility_id')
+                basic_details.pop('facility')
+
+
+            for key, value in basic_details.iteritems():
+                setattr(self.health_unit, key, value)
+            if 'basic' in basic_details:
+                setattr(self.health_unit, 'facility_id', basic_details.get('basic').get('facility'))
+            self.health_unit.save()
 
     def update_workers(self):
         chews = json.loads(self.workers)

chul/serializers.py

@@ -341,3 +341,8 @@ class CHURatingSerializer(AbstractFieldsMixin, serializers.ModelSerializer):
 
     class Meta(AbstractFieldsMixin.Meta):
         model = CHURating
+class ChulSummarySerializer(serializers.ModelSerializer):
+    # count=serializers.IntegerField()
+    class Meta:
+        model = None
+        fields = '__all__'

chul/urls.py

@@ -48,6 +48,10 @@
     url(r'^units/(?P<pk>[^/]+)/$',
         views.CommunityHealthUnitDetailView.as_view(),
         name='community_health_unit_detail'),
+    url(r'^summary/$',
+        views.CommunityHealthUnitSummaryView.as_view(),
+        name='community_health_unit_summary'),
+
 
     url(r'^chu_ratings/$',
         views.CHURatingListView.as_view(), name='chu_ratings'),

chul/views.py

@@ -1,7 +1,11 @@
+from django.http import JsonResponse
 from django.template import loader, Context
 from django.utils import timezone
 from django.views.decorators.cache import never_cache
 from rest_framework import generics
+from django.db.models import Count
+from django.db import connection
+from django.apps import apps
 from common.views import AuditableDetailViewMixin, DownloadPDFMixin
 from common.models import UserConstituency, UserCounty, UserSubCounty
 from .models import (
@@ -17,6 +21,7 @@
 
 from .serializers import (
     CommunityHealthUnitSerializer,
+    ChulSummarySerializer,
     CommunityHealthWorkerSerializer,
     CommunityHealthWorkerContactSerializer,
     StatusSerializer,
@@ -40,61 +45,94 @@
 
 class FilterCommunityUnitsMixin(object):
 
-    def get_queryset(self, *args, **kwargs):
-        custom_queryset = kwargs.pop('custom_queryset', None)
-        if hasattr(custom_queryset, 'count'):
-            self.queryset = custom_queryset
-
-        if not self.request.user.has_perm(
-                "facilities.view_unpublished_facilities"):
-            self.queryset = self.queryset.filter(facility__approved=True)
-
-        if not self.request.user.has_perm(
-                "chul.view_rejected_chus"):
-            self.queryset = self.queryset.filter(is_approved=True)
-
+    def filter_approved_chus(self):
+        if self.request.user.has_perm(
+            "chul.view_unapproved_facilities") \
+            is False and 'approved' in [
+                field.name for field in
+                self.queryset.model._meta.get_fields()]:
+
+            # filter both facilities and facilities materialized view
+            try:
+                self.queryset = self.queryset.filter(approved=True, operation_status__is_public_visible=True)
+            except:
+                self.queryset = self.queryset.filter(approved=True, is_public_visible=True)
+
+    def filter_rejected_chus(self):
+        if self.request.user.has_perm("chul.view_rejected_chus") \
+            is False and ('rejected' in [
+                field.name for field in
+                self.queryset.model._meta.get_fields()]):
+            self.queryset = self.queryset.filter(rejected=False)
+
+    def filter_for_national_users(self):
         if self.request.user.is_national:
             self.queryset = self.queryset
 
+
+    def filter_for_county_users(self):
         if self.request.user.county:
             self.queryset = self.queryset.filter(
                 facility__ward__constituency__county__in=[
                     uc.county for uc in UserCounty.objects.filter(
                         user=self.request.user)
                 ])
 
-        if self.request.user.constituency:
+    def filter_for_sub_county_users(self):
+        if self.request.user.sub_county:
             self.queryset = self.queryset.filter(
-                facility__ward__constituency__in=[
-                    uc.constituency for uc in UserConstituency.objects.filter(
+                facility__ward__sub_county__in=[
+                    us.sub_county for us in UserSubCounty.objects.filter(
                         user=self.request.user)
                 ])
 
-        if self.request.user.sub_county:
+    def filter_for_consituency_users(self):
+        if self.request.user.constituency:
             self.queryset = self.queryset.filter(
-                facility__ward__sub_county__in=[
-                    us.sub_county for us in UserSubCounty.objects.filter(
+                facility__ward__constituency__in=[
+                    uc.constituency for uc in UserConstituency.objects.filter(
                         user=self.request.user)
                 ])
 
+
+
+    def get_queryset(self, *args, **kwargs):
+        custom_queryset = kwargs.pop('custom_queryset', None)
+        if hasattr(custom_queryset, 'count'):
+            self.queryset = custom_queryset
+
+        self.filter_for_county_users()
+        self.filter_for_consituency_users()  
+        self.filter_for_sub_county_users()
+        self.filter_rejected_chus()
+
+        # if not self.request.user.has_perm(
+        #         "facilities.view_unpublished_facilities"):
+        #     self.queryset = self.queryset.filter(facility__approved=True)
+
+        # if not self.request.user.has_perm(
+        #         "chul.view_rejected_chus"):
+        #     self.queryset = self.queryset.filter(is_approved=True)
+
         return self.queryset
 
     def filter_queryset(self, queryset):
         """
         Overridden in order to constrain search results to what a user should
         see.
         """
-        if 'search' in self.request.query_params:
-            search_term = self.request.query_params.get('search')
-            if search_term.isdigit():
-                queryset = self.queryset.filter(code=search_term)
-            else:
-                queryset = super(
-                    FilterCommunityUnitsMixin, self).filter_queryset(queryset)
-        else:
-            queryset = super(
-                FilterCommunityUnitsMixin, self).filter_queryset(queryset)
-
+        # if 'search' in self.request.query_params:
+        #     search_term = self.request.query_params.get('search')
+        #     if search_term.isdigit():
+        #         queryset = self.queryset.filter(code=search_term)
+        #     else:
+        #         queryset = super(
+        #             FilterCommunityUnitsMixin, self).filter_queryset(queryset)
+        # else:
+        #     queryset = super(
+        #         FilterCommunityUnitsMixin, self).filter_queryset(queryset)
+
+        queryset = super(FilterCommunityUnitsMixin, self).filter_queryset(queryset)
         return self.get_queryset(custom_queryset=queryset)
 
 
@@ -176,6 +214,7 @@ class CommunityHealthUnitContactListView(generics.ListCreateAPIView):
     ordering_fields = ('health_unit', 'contact', )
 
 
+
 class CommunityHealthUnitContactDetailView(
         AuditableDetailViewMixin,
         generics.RetrieveUpdateDestroyAPIView):
@@ -215,6 +254,20 @@ class CommunityHealthUnitDetailView(
     queryset = CommunityHealthUnit.objects.all()
     serializer_class = CommunityHealthUnitSerializer
 
+class CommunityHealthUnitSummaryView(generics.ListAPIView):
+    def get_queryset(self):
+        with connection.cursor() as cursor:
+            cursor.execute("SELECT chul_status.name, COUNT(chul_communityhealthunit.status_id) As counts FROM chul_communityhealthunit INNER JOIN chul_status ON chul_communityhealthunit.status_id = chul_status.id GROUP BY chul_status.name")
+            rows = cursor.fetchall()
+            return rows
+
+    def list(self, request, *args, **kwargs):
+        queryset = self.get_queryset()
+        data = []
+        for row in queryset:
+            data.append({"name": row[0], "count": row[1]})
+        return JsonResponse(data, safe=False)
+
 
 class CommunityHealthWorkerListView(generics.ListCreateAPIView):
 
@@ -312,6 +365,7 @@ class ChuUpdateBufferListView(
     serializer_class = ChuUpdateBufferSerializer
     filter_class = ChuUpdateBufferFilter
     ordering_fields = ('health_unit', )
+    # print(queryset)
 
 
 class ChuUpdateBufferDetailView(

common/migrations/0020_auto_20221205_0904.py

@@ -0,0 +1,35 @@
+# -*- coding: utf-8 -*-
+# Generated by Django 1.11.27 on 2022-12-05 09:04
+from __future__ import unicode_literals
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('common', '0019_auto_20191021_1227'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='apiauthentication',
+            name='client_secret',
+            field=models.CharField(default=b'', max_length=255),
+        ),
+        migrations.AlterField(
+            model_name='apiauthentication',
+            name='password',
+            field=models.CharField(default=b'', max_length=255),
+        ),
+        migrations.AlterField(
+            model_name='apiauthentication',
+            name='server',
+            field=models.CharField(default=b'http://testhis.uonbi.ac.ke/', max_length=255),
+        ),
+        migrations.AlterField(
+            model_name='apiauthentication',
+            name='username',
+            field=models.CharField(default=b'kmhfl_integration', max_length=255),
+        ),
+    ]

common/migrations/0021_auto_20230302_0642.py

@@ -0,0 +1,20 @@
+# -*- coding: utf-8 -*-
+# Generated by Django 1.11.27 on 2023-03-02 06:42
+from __future__ import unicode_literals
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('common', '0020_auto_20221205_0904'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='apiauthentication',
+            name='server',
+            field=models.CharField(default=b'https://test.hiskenya.org/', max_length=255),
+        ),
+    ]