From 1ce2fd4158f529316f841a0ebff6690d59d625c8 Mon Sep 17 00:00:00 2001
From: Lautaro Molina <lautaro.mlagos@gmail.com>
Date: Tue, 15 Nov 2022 09:11:42 -0300
Subject: [PATCH] feat(in): nuevo event para eventos nuevos en ejecucion

---
 .../plan-indicaciones-eventos.routes.ts       | 14 +++++-
 .../plan-indicaciones.hook.ts                 | 44 +++++++++++++++++++
 2 files changed, 56 insertions(+), 2 deletions(-)

diff --git a/modules/rup/internacion/plan-indicaciones/plan-indicaciones-eventos.routes.ts b/modules/rup/internacion/plan-indicaciones/plan-indicaciones-eventos.routes.ts
index 6d51741115..c7e2a779df 100644
--- a/modules/rup/internacion/plan-indicaciones/plan-indicaciones-eventos.routes.ts
+++ b/modules/rup/internacion/plan-indicaciones/plan-indicaciones-eventos.routes.ts
@@ -1,10 +1,12 @@
 import { MongoQuery, ResourceBase } from '@andes/core';
+import { EventCore } from '@andes/event-bus/index';
 import { Auth } from '../../../../auth/auth.class';
 import { PlanIndicacionesEventos } from './plan-indicaciones.schema';
 
 class PlanIndicacionesEventosController extends ResourceBase {
     Model = PlanIndicacionesEventos;
     resourceName = 'plan-indicaciones-eventos';
+    resourceModule = 'internacion';
     middlewares = [Auth.authenticate()];
     searchFileds = {
         fecha: MongoQuery.matchDate,
@@ -13,9 +15,17 @@ class PlanIndicacionesEventosController extends ResourceBase {
         indicacion: MongoQuery.equalMatch.withField('idIndicacion'),
         estado: MongoQuery.equalMatch
     };
+    eventBus = EventCore;
 
-    async deleteByIndicacion(idIndicacion: String) {
-        await PlanIndicacionesEventos.deleteMany({ idIndicacion });
+    async deleteByIndicacion(idIndicacion: String, desde?: Date, estado?: String) {
+        const query = PlanIndicacionesEventos.deleteMany({ idIndicacion });
+        if (desde) {
+            query.where({ fecha: { $gte: desde } });
+        }
+        if (estado) {
+            query.where({ estado });
+        }
+        await query;
     }
 }
 
diff --git a/modules/rup/internacion/plan-indicaciones/plan-indicaciones.hook.ts b/modules/rup/internacion/plan-indicaciones/plan-indicaciones.hook.ts
index 9a1bb338d5..de735f314a 100644
--- a/modules/rup/internacion/plan-indicaciones/plan-indicaciones.hook.ts
+++ b/modules/rup/internacion/plan-indicaciones/plan-indicaciones.hook.ts
@@ -36,6 +36,50 @@ EventCore.on('mapa-camas:plan-indicacion:create', async (prestacion) => {
     await Promise.all(savePromises);
 });
 
+EventCore.on('internacion:plan-indicaciones-eventos:create', async (evento) => {
+    if (evento.estado === 'realizado' && !evento.updatedAt) {
+        /*  Por cada nuevo evento NO PLANIFICADO en estado REALIZADO debe ajustarse el horario de los proximos.
+            Un evento es no planificado cuando es creado manualmente por el usuario en lugar de generarse automáticamente
+            al momento de guardar una nueva indicación.
+        */
+        const [indicacion, indicacionEventos] = await Promise.all([
+            PlanIndicacionesCtr.findById(evento.idIndicacion),
+            PlanIndicacionesEventosCtr.search({ indicacion: evento.idIndicacion })
+        ]);
+        const configOrganizacion = await getConfiguracion(indicacion.organizacion.id);
+        const horaInicioEfector = configOrganizacion.planIndicaciones.horaInicio;
+
+        if (indicacion.valor.unicaVez) {
+            return;
+        }
+        const eventos = indicacionEventos.sort((ev1, ev2) => moment(ev1.fecha).diff(moment(ev2.fecha)));
+        const index = eventos.findIndex(ev => ev.id === evento.id);
+        const eventosPosteriores = eventos.slice(index + 1, eventos.length);
+
+        if (!eventosPosteriores.some(ev => ev.estado !== 'on-hold')) {
+            const proximoEvento = eventosPosteriores.shift();
+            await PlanIndicacionesEventosCtr.deleteByIndicacion(indicacion.id, proximoEvento.fecha);
+
+            if (eventosPosteriores.length) {
+                /* Calculamos la diferencia en horas entre el nuevo evento y el siguiente planificado, luego restamos esta
+                diferencia a los eventos proximos para ajustar la planificacion.
+                */
+                const diferenciaAlProximo = moment(proximoEvento.fecha).diff(moment(evento.fecha), 'hours');
+                const nuevosHorarios = eventosPosteriores.map(ev => moment(ev.fecha).subtract(diferenciaAlProximo, 'hours'));
+
+                // Una indicacion puede tener mas de una frecuencia
+                const ultimaFrecuenciaIndicacion = indicacion.valor.frecuencias[indicacion.valor.frecuencias.length - 1].frecuencia.key; // ultima frecuencia
+                const ultimoHorario = nuevosHorarios[nuevosHorarios.length - 1];
+
+                // Si el adelanto de los horarios genera una franja horaria donde hay lugar para otra toma, se agrega.
+                if (moment(ultimoHorario).add(ultimaFrecuenciaIndicacion, 'hours').isBefore(moment().startOf('day').add(horaInicioEfector + 24, 'hours'))) {
+                    nuevosHorarios.push(moment(ultimoHorario).add(ultimaFrecuenciaIndicacion, 'hours'));
+                }
+                await crearEventos(nuevosHorarios, indicacion);
+            }
+        }
+    }
+});
 
 EventCore.on('internacion:plan-indicaciones:create', async (indicacion) => {
     await crearEventosSegunPrescripcion(indicacion);