Gaia cache

anagrafica/models.py

@@ -3,6 +3,7 @@
 import codicefiscale
 import phonenumbers
 import mptt
+from compressor.cache import cache
 from mptt.querysets import TreeQuerySet
 from autoslug import AutoSlugField
 
@@ -498,6 +499,10 @@ def sostenitore(self, **kwargs):
     @property
     def applicazioni_disponibili(self):
         from formazione.models import CorsoBase
+        from django.core.cache import cache
+
+        if cache.get('persona_{}_items_to_display'.format(self.id)):
+            return cache.get('persona_{}_items_to_display'.format(self.id))
 
         # Personalizzare il menu "Utente" secondo il suo ruolo
         utente_url, utente_label, utente_count = ('/utente/', 'Volontario', None)
@@ -528,6 +533,7 @@ def applicazioni_disponibili(self):
 
         filter_items_to_display = filter(lambda x: x[1] == True, all_menus)
         items_to_display = [item[0] for item in filter_items_to_display]
+        cache.set('persona_{}_items_to_display'.format(self.id), items_to_display)
         return items_to_display
 
     def oggetti_permesso(self, permesso, al_giorno=None,

anagrafica/tasks.py

@@ -0,0 +1,24 @@
+from celery import shared_task
+from celery.utils.log import get_task_logger
+
+from anagrafica.models import Persona
+from django.core.cache import cache
+
+logger = get_task_logger(__name__)
+
+
+@shared_task(bind=True)
+def prefetch_onlogin(self, pk):
+    from ufficio_soci.viste import prepare_us
+
+    persona = Persona.objects.get(pk=pk)
+    us_data = prepare_us(persona)
+
+    cache.set('{}_us_sedi'.format(pk), [s.id for s in us_data.get('sedi')])
+    cache.set('{}_us_persone'.format(pk), us_data.get('persone'))
+    cache.set('{}_us_attivi'.format(pk), us_data.get('attivi'))
+    cache.set('{}_trasferimenti_automatici'.format(pk), us_data.get('trasferimenti_automatici'))
+    cache.set('{}_trasferimenti_manuali'.format(pk), us_data.get('trasferimenti_manuali'))
+    cache.set('{}_estensioni_da_autorizzare'.format(pk), us_data.get('estensioni_da_autorizzare'))
+
+    print(cache.get('{}_us_sedi'.format(pk)))

anagrafica/viste.py

@@ -329,6 +329,10 @@ def registrati_conferma(request, tipo):
 
 @pagina_privata
 def utente(request, me):
+    from anagrafica.tasks import prefetch_onlogin
+
+    prefetch_onlogin.apply_async((me.id,))
+
     articoli = get_articoli(me)
     contesto = {
         "articoli": articoli[:5],

base/menu.py

@@ -190,15 +190,19 @@ def documenti(self):
 
     def get_menu(self):
         from .utils import remove_none
+        from django.core.cache import cache
 
         path = self.request.path
+        if cache.get('menu_{}_get_menu'.format(path)):
+            return cache.get('menu_{}_get_menu'.format(path))
 
         # La ricerca del menu viene per inizio del url che chiama utente
         for i in self.mapping():
             for url in i['urls']:
                 if path.startswith(url):
                     menu = remove_none(getattr(self, i['method']))
                     name_for_template = i['name_for_template']
+                    cache.set('menu_{}_get_menu'.format(path), {name_for_template: menu})
                     return {name_for_template: menu}
 
         # Non restituisce nulla. Il menu sarè vuoto.

docker-compose.yml

@@ -45,7 +45,7 @@ services:
     environment:
       - "SKIP_DJANGO_COLLECSTATIC=1"
       - "SKIP_DJANGO_MIGRATE=1"
-    command: "celery worker -b redis://broker -A jorvik -l info -Q queue_monitoraggio,queue_formazione,coda_email_rischedula,coda_email_invio,queue_monitoraggio,periodic_ufficio_soci,shared_ufficio_soci -B"
+    command: "celery worker -b redis://broker -A jorvik -l info -Q queue_monitoraggio,queue_formazione,coda_email_rischedula,coda_email_invio,queue_monitoraggio,periodic_ufficio_soci,shared_ufficio_soci,prefetch_onlogin -B"
 
   pdf:
     build: https://github.com/CroceRossaItaliana/gaia-dompdf.git#master

jorvik/settings.py

@@ -413,3 +413,14 @@
 COUNTRIES_OVERRIDE = {
     'KS': _('Kosovo'),
 }
+
+CACHES = {
+    "default": {
+        "BACKEND": "django_redis.cache.RedisCache",
+        "LOCATION": "redis://{}/1".format(CELERY_CONF.get('celery', 'broker_url')),
+        "OPTIONS": {
+            "CLIENT_CLASS": "django_redis.client.DefaultClient"
+        },
+        "KEY_PREFIX": "jorvik_"
+    }
+}

requirements.txt

@@ -56,3 +56,5 @@ xlrd
 WeasyPrint
 https://github.com/emfcamp/python-barcode/archive/0.7.zip # pyBarcode==0.7
 https://github.com/nephila/django-filer/archive/296fa6170a3749532b85ceb033eeae0fb839e9a6.zip
+django-redis==4.10.0
+redis==3.3.8

ufficio_soci/templates/us.html

@@ -24,19 +24,18 @@ <h4><i class="fa fa-info-circle"></i> Benvenuto nella sezione dedicata all'Uffic
     </div>
 
     <div class="row ">
-
         <div class="col-md-2 allinea-centro">
             <h3>{{ sedi.count }}</h3>
             <p class="grassetto">Sedi CRI</p>
         </div>
 
         <div class="col-md-2 allinea-centro">
-            <h3>{{ persone.count }}</h3>
+            <h3>{{ persone }}</h3>
             <p class="grassetto">Persone</p>
         </div>
 
         <div class="col-md-2 allinea-centro">
-            <h3>{{ attivi.count }}</h3>
+            <h3>{{ attivi }}</h3>
             <p class="grassetto">Soci attivi</p>
         </div>
 
@@ -48,25 +47,24 @@ <h3>{{ attivi.count }}</h3>
                 {% endfor %}
             </ul>
         </div>
-
     </div>
 
-    {% if me.trasferimenti_automatici.exists %}
+    {% if trasferimenti_automatici %}
     <div class="alert alert-warning">
         <i class="fa fa-fw fa-warning"></i> Hai {{ me.trasferimenti_automatici|length }} richiest{{ me.trasferimenti_automatici|pluralize:"a,e" }} di trasferimento in attesa di approvazione che sar{{ me.trasferimenti_automatici|pluralize:"à,nno" }} automaticamente approvat{{ me.trasferimenti_automatici|pluralize:"a,e" }} entro 30 giorni dalla data di ciascuna richiesta.<br>
         Vai nella <a href="/autorizzazioni/">Sezione Richieste</a> per approvarl{{ me.trasferimenti_automatici|pluralize:"a,e" }} o negarl{{ me.trasferimenti_automatici|pluralize:"a,e" }}.
     </div>
     {% endif %}
 
-    {% if me.trasferimenti_manuali.exists %}
+    {% if trasferimenti_manuali %}
     <div class="alert alert-warning">
         <i class="fa fa-fw fa-warning"></i> Hai {{ me.trasferimenti_manuali|length }} richiest{{ me.trasferimenti_automatici|pluralize:"a,e" }} di trasferimento.<br>
         Per ragioni tecniche -risolte a partire dal {{ SETTINGS.DATA_AVVIO_TRASFERIMENTI_AUTO|date:"SHORT_DATE_FORMAT" }}- non è possibile approvarl{{ me.trasferimenti_automatici|pluralize:"a,e" }} in automatico.<br>
         Vai nella <a href="/autorizzazioni/">Sezione Richieste</a> per approvarl{{ me.trasferimenti_automatici|pluralize:"a,e" }} o negarl{{ me.trasferimenti_automatici|pluralize:"a,e" }}.
     </div>
     {% endif %}
 
-    {% if me.estensioni_da_autorizzare.exists %}
+    {% if estensioni_da_autorizzare %}
     <div class="alert alert-warning">
         <i class="fa fa-fw fa-warning"></i> Hai {{ me.estensioni_da_autorizzare|length }} richiest{{ me.estensioni_da_autorizzare|pluralize:"a,e" }} di estensione.<br>
         E' necessaria una tua azione per approvare o negare l{{ me.estensioni_da_autorizzare|pluralize:"a,e" }} richiest{{ me.estensioni_da_autorizzare|pluralize:"a,e" }}.<br>

ufficio_soci/viste.py

@@ -9,7 +9,7 @@
 
 from django.db import transaction, IntegrityError
 from django.db.models import Sum, Q
-from django.core.urlresolvers import reverse
+from django.core.cache import cache
 from django.core.paginator import Paginator
 from django.shortcuts import redirect, get_object_or_404
 from django.core.urlresolvers import reverse
@@ -38,26 +38,43 @@
     ModuloNuovaRicevuta, ModuloFiltraEmissioneTesserini, ModuloLavoraTesserini,
     ModuloScaricaTesserini, ModuloDimissioniSostenitore)
 
+from anagrafica.tasks import prefetch_onlogin
 
-@pagina_privata(permessi=(GESTIONE_SOCI,))
-def us(request, me):
-    """ Ritorna la home page per la gestione dei soci. """
 
-    sedi = me.oggetti_permesso(GESTIONE_SOCI)
+def prepare_us(me):
 
+    sedi = me.oggetti_permesso(GESTIONE_SOCI)
     persone = Persona.objects.filter(
         Appartenenza.query_attuale(sede__in=sedi).via("appartenenze")
-    ).distinct('cognome', 'nome', 'codice_fiscale')
+    ).distinct('cognome', 'nome', 'codice_fiscale').count()
     attivi = Persona.objects.filter(
         Appartenenza.query_attuale(sede__in=sedi, membro=Appartenenza.VOLONTARIO).via("appartenenze")
-    ).distinct('cognome', 'nome', 'codice_fiscale')
+    ).distinct('cognome', 'nome', 'codice_fiscale').count()
 
     contesto = {
         "sedi": sedi,
         "persone": persone,
         "attivi": attivi,
+        "trasferimenti_automatici": me.trasferimenti_automatici.count(),
+        "trasferimenti_manuali": me.trasferimenti_manuali.count(),
+        "estensioni_da_autorizzare": me.estensioni_da_autorizzare.count()
     }
 
+    return contesto
+
+
+@pagina_privata(permessi=(GESTIONE_SOCI,))
+def us(request, me):
+    """ Ritorna la home page per la gestione dei soci. """
+
+    if cache.get('{}_us_sedi'.format(me.id)):
+        contesto = dict()
+        contesto['sedi'] = Sede.objects.filter(id__in=cache.get('{}_us_sedi'.format(me.id)))
+        contesto['persone'] = cache.get('{}_us_persone'.format(me.id))
+        contesto['attivi'] = cache.get('{}_us_attivi'.format(me.id))
+    else:
+        contesto = prepare_us(me)
+
     return 'us.html', contesto
 
 
@@ -451,6 +468,8 @@ def us_estensione(request, me):
         "modulo": modulo,
     }
 
+    prefetch_onlogin.apply_async((me.id,))
+
     return 'us_estensione.html', contesto
 
 
@@ -525,6 +544,8 @@ def us_trasferimento(request, me):
         "modulo": modulo,
     }
 
+    prefetch_onlogin.apply_async((me.id,))
+
     return 'us_trasferimento.html', contesto