Conjunto de cambios e9477bd en seiven para economico

Fecha y hora:

08/12/2016 17:14:04 (hace 7 años)

Autor:

Ing. Roldan D. Vargas G <rvargas@…>

Branches:

master, carga

Children:

2b509cc

Parents:

dc618c3

Mensaje:

carga de datos en el modelo de precios. se agrega función lambda para chequear el dato numérico de un campo. Se agrega plantilla de correo con información de la carga de datos. Instrucciones javascript para descargar y cargar archivos

Ubicación:

economico

Ficheros:

• models.py (modificado) (11 diferencias)
• templates/economico.precios.html (modificado) (2 diferencias)

economico/models.py

@@ -15 +15 @@
 from django.db import models
 from django.utils import six
+from django.conf import settings
 from django.utils.encoding import python_2_unicode_compatible
 from django.utils.translation import ugettext_lazy as _
 
-from base.constant import DOMINIO, PERIOCIDAD, TRIMESTRES, MESES, ECONOMICO_SUB_AREA
+from base.constant import (
+    DOMINIO, PERIOCIDAD, TRIMESTRES, MESES, ECONOMICO_SUB_AREA, CONVERT_MES, EMAIL_SUBJECT_LOAD_DATA
+)
+from base.functions import enviar_correo, check_val_data
 
 import pyexcel
@@ -26 +30 @@
 __docstring__ = "DoxyGen"
 
+administrador, admin_email = '', ''
+if settings.ADMINS:
+    administrador = settings.ADMINS[0][0]
+    admin_email = settings.ADMINS[0][1]
+
 
 @python_2_unicode_compatible
@@ -42 +51 @@
 
     ## Ciudad del registro. La información registrada es solo para el tipo de dominio por ciudad
-    ciudad = models.CharField(max_length=3, choices=DOMINIO[1:], null=True, verbose_name=_("Ciudad"))
+    ciudad = models.CharField(max_length=3, choices=DOMINIO[1:], null=True, default=None, verbose_name=_("Ciudad"))
+
+    class Meta:
+        unique_together = ("anho", "mes")
 
     def gestion_init(self, *args, **kwargs): #ciudad=None, anho_base=None, mes_ini=None, mes_fin=None, anho_ini=None, anho_fin=None
 
         grupo_label = str(PreciosGrupo._meta.verbose_name)
-        grupo_count_fields = PreciosGrupo._meta.get_fields()[:-3].__len__()
+        grupo_count_fields = PreciosGrupo._meta.get_fields()[:-4].__len__()
         sector_label = str(PreciosSector._meta.verbose_name)
-        sector_count_fields = PreciosSector._meta.get_fields()[:-3].__len__()
+        sector_count_fields = PreciosSector._meta.get_fields()[:-4].__len__()
         naturaleza_label = str(PreciosNaturaleza._meta.verbose_name)
-        naturaleza_count_fields = PreciosNaturaleza._meta.get_fields()[:-3].__len__()
+        naturaleza_count_fields = PreciosNaturaleza._meta.get_fields()[:-4].__len__()
         servicios_label = str(PreciosServicios._meta.verbose_name)
-        servicios_count_fields = PreciosServicios._meta.get_fields()[:-3].__len__()
+        servicios_count_fields = PreciosServicios._meta.get_fields()[:-4].__len__()
         inflacionario_label = str(PreciosInflacionario._meta.verbose_name)
-        inflacionario_count_fields = PreciosInflacionario._meta.get_fields()[:-3].__len__()
+        inflacionario_count_fields = PreciosInflacionario._meta.get_fields()[:-4].__len__()
         productos_label = str(PreciosProductos._meta.verbose_name)
-        productos_count_fields = PreciosProductos._meta.get_fields()[:-3].__len__()
+        productos_count_fields = PreciosProductos._meta.get_fields()[:-4].__len__()
         fields = [
             [
@@ -72 +84 @@
             []
         ]
-        relations, data, exclude_fields = [], [], ['id', 'anho_base', 'real_precios_id']
+        relations, data, exclude_fields = [], [], ['id', 'anho_base', 'real_precios_id', 'base']
 
         if not 'dominio' in kwargs or not kwargs['dominio'] == 'C':
@@ -149 +161 @@
         return {'cabecera': fields, 'relations': relations, 'data': data, 'output': 'precios'}
 
-    def gestion_process(self, file, *args, **kwargs):
-        print(file)
+    def gestion_process(self, file, user, *args, **kwargs):
         load_file = pyexcel.get_sheet(file_name=file)
-        print(load_file.content)
-        return {'result': True, 'message': str(_("archivo correcto"))}
+        anho_base, i, col_ini, errors, result, message = '', 0, 2, '', True, ''
+        load_data_msg = str(_("Datos Cargados"))
+
+        for row in load_file.row[2:]:
+            try:
+                # Asigna el año base del registro
+                anho_b = anho_base = row[0] if i == 0 else anho_base
+
+                # Asigna el año de la fila que se esta procesando
+                anho = row[0]
+
+                # Asigna el número de mes
+                mes = [CONVERT_MES[m] for m in CONVERT_MES if m.find(row[1]) >= 0][0]
+
+                # Asigna la ciudad si el dominio no es nacional
+                ciudad = row[2] if 'dominio' in kwargs and kwargs['dominio'] == 'C' else None
+
+                # Asigna el INPC total para el año base
+                inpc = row[3] if self.ciudad else row[2]
+
+                # Condición que indica si el registro corresponde al año base
+                base = True if i == 0 else False
+
+                # Gestión para los datos básicos de precios
+                real_p, created = Precios.objects.update_or_create(anho=anho, mes=mes, ciudad=ciudad, defaults={
+                    'anho_base': anho_b, 'inpc': inpc
+                })
+
+
+                # Gestión de datos para el Índice por Grupos
+                PreciosGrupo.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'alimento_bebida': check_val_data(row[4] if self.ciudad else row[3]),
+                    'bebida_tabaco': check_val_data(row[5] if self.ciudad else row[4]),
+                    'vestido_calzado': check_val_data(row[6] if self.ciudad else row[5]),
+                    'alquiler_vivienda': check_val_data(row[7] if self.ciudad else row[6]),
+                    'servicio_vivienda': check_val_data(row[8] if self.ciudad else row[7]),
+                    'equipamiento_hogar': check_val_data(row[9] if self.ciudad else row[8]),
+                    'salud': check_val_data(row[10] if self.ciudad else row[9]),
+                    'transporte': check_val_data(row[11] if self.ciudad else row[10]),
+                    'comunicaciones': check_val_data(row[12] if self.ciudad else row[11]),
+                    'esparcimiento': check_val_data(row[13] if self.ciudad else row[12]),
+                    'educacion': check_val_data(row[14] if self.ciudad else row[13]),
+                    'restaurant_hotel': check_val_data(row[15] if self.ciudad else row[14]),
+                    'bienes_servicios': check_val_data(row[16] if self.ciudad else row[15])
+                })
+
+                # Gestión de datos para el Índice por Sector de Origen
+                PreciosSector.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'durables': check_val_data(row[17] if self.ciudad else row[16]),
+                    'semi_durables': check_val_data(row[18] if self.ciudad else row[17]),
+                    'no_durables': check_val_data(row[19] if self.ciudad else row[18])
+                })
+
+                # Gestión de datos para el Índice por Naturaleza y Durabilidad
+                PreciosNaturaleza.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'bienes': check_val_data(row[20] if self.ciudad else row[19]),
+                    'agricolas': check_val_data(row[21] if self.ciudad else row[20]),
+                    'pesquero': check_val_data(row[22] if self.ciudad else row[21]),
+                    'agroindustrial': check_val_data(row[23] if self.ciudad else row[22]),
+                    'otros': check_val_data(row[24] if self.ciudad else row[23])
+                })
+
+                # Gestión de datos para el Índice por Servicios
+                PreciosServicios.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'total': check_val_data(row[25] if self.ciudad else row[24]),
+                    'basicos': check_val_data(row[26] if self.ciudad else row[25]),
+                    'otros': check_val_data(row[27] if self.ciudad else row[26])
+                })
+
+                # Gestion de datos para el Índice por Núcleo Inflacionario
+                PreciosInflacionario.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'nucleo': check_val_data(row[28] if self.ciudad else row[27]),
+                    'alimentos': check_val_data(row[29] if self.ciudad else row[28]),
+                    'textiles': check_val_data(row[30] if self.ciudad else row[29]),
+                    'bienes': check_val_data(row[31] if self.ciudad else row[30]),
+                    'servicios': check_val_data(row[32] if self.ciudad else row[31])
+                })
+
+                # Gestión de datos para el Índice de Productos Controlados y No Controlados
+                PreciosProductos.objects.update_or_create(real_precios=real_p, defaults={
+                    'base': base,
+                    'controlados': check_val_data(row[33] if self.ciudad else row[32]),
+                    'no_controlados': check_val_data(row[34] if self.ciudad else row[33])
+                })
+
+            except Exception as e:
+                errors = errors + "<li>%s</li>" % str(e)
+
+            i += 1
+
+        if errors:
+            message = str(_("Error procesando datos. Verifique su correo para detalles del error"))
+            load_data_msg = str(_("Error al procesar datos"))
+
+
+        ## Envia correo electronico al usuario indicando el estatus de la carga de datos
+        enviar_correo(user.email, 'gestion.informacion.load.mail', EMAIL_SUBJECT_LOAD_DATA, {
+            'load_data_msg': load_data_msg, 'administrador': administrador, 'admin_email': admin_email,
+            'errors': errors
+        })
+
+        return {'result': result, 'message': message}
 
 
@@ -211 +327 @@
     )
 
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
+
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))
 
@@ -232 +350 @@
     )
 
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
+
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))
 
@@ -260 +380 @@
         max_digits=18, decimal_places=2, default=0.0, verbose_name=_("Otros manufacturados")
     )
+
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
 
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))
@@ -281 +403 @@
     )
 
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
+
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))
 
@@ -308 +432 @@
     )
 
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
+
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))
 
@@ -322 +448 @@
         max_digits=18, decimal_places=2, default=0.0, verbose_name=_("No Controlados")
     )
+
+    base = models.BooleanField(default=False, verbose_name=_("Indicador base"))
 
     real_precios = models.ForeignKey(Precios, verbose_name=_("Sector Real"))

economico/templates/economico.precios.html

@@ -66 +66 @@
 {% block extra_footer %}
     <script>
+        /**
+         * Función que configura los filtros de acuerdo a la selección del usuario
+         */
         function set_filters() {
             var filters = $("#filters"), json_filter = '';
@@ -99 +102 @@
             }
         }
-        $(document).ready(function() {
-            $('#{{ form.dominio.auto_id }}').on('change', function() {
-                $(this).val().split('dominio: ' + $(this).val() + ",").join("");
-                if ($(this).val() != "") {
-                    var filters = $("#filters");
-                    filters.val(filters.val() + 'dominio: ' + $(this).val() + ',');
-                }
-            });
-
-            $('.download-file').on('click', function(e) {
-                e.preventDefault();
-                set_filters();
-            });
-
-            $('.upload-file').on('click', function(e) {
-                e.preventDefault();
-
-                var file = $("#file"), form_upload = $('#form-upload-file');
-                file.click();
-                file.on('change', function(e) {
-                    e.preventDefault();
-                    form_upload.ajaxForm({
-                        beforeSubmit: function(arr, $form, options) {
-                            set_filters();
-                        },
-                        type: 'post',
-                        dataType: 'json',
-                        success: function(response) {
-                            if (response.result) {
-                                bootbox.alert(response.message);
-                            }
-                            else {
-                                bootbox.alert(response.message);
-                            }
-                        },
-                        error: function(jqxhr, textStatus, error) {
-                            var err = textStatus + ", " + error;
-                            bootbox.alert( MSG_PETICION_AJAX_FALLIDA + err );
-                            console.log(MSG_PETICION_AJAX_FALLIDA + err);
-                        }
-                    });
-
-                    form_upload.submit();
-                });
-
-            });
-        });
     </script>
 {% endblock %}