carga masiva equipo listo

src/equipo-programa/equipo-programa.service.ts

@@ -16,15 +16,24 @@ export class EquipoProgramaService {
     private institucionProgramaService: InstitucionProgramaService,
   ) {}
 
-  async create(id_equipo: number, id_programa: number) {
-    const equipo = await this.equipoService.findById(id_equipo);
-    const programa = await this.institucionProgramaService.findProgramaById(
-      id_programa,
-    );
+  async create(id_equipo: number | Equipo, id_programa: number | Programa) {
+    const equipo =
+      typeof id_equipo === 'number'
+        ? await this.equipoService.findById(id_equipo)
+        : id_equipo;
+    const programa =
+      typeof id_programa === 'number'
+        ? await this.institucionProgramaService.findProgramaById(id_programa)
+        : id_programa;
 
-    return this.existeEquipoPrograma(equipo, programa).then(() =>
-      this.repository.save(this.repository.create({ equipo, programa })),
-    );
+    return this.existeEquipoPrograma(equipo, programa)
+      .then(() =>
+        this.repository.save(this.repository.create({ equipo, programa })),
+      )
+      .then((equipoPrograma) => ({
+        message: `Se agrego el programa: ${equipoPrograma.programa}, al equipo con número de inventario: ${equipo.numero_inventario}}`,
+        equipoPrograma,
+      }));
   }
 
   delete(id_equipo_programa: number) {
@@ -33,14 +42,19 @@ export class EquipoProgramaService {
     );
   }
 
-  existeEquipoPrograma(equipo: Equipo, programa: Programa) {
+  existeEquipoPrograma(
+    equipo: Equipo,
+    programa: Programa,
+    validarExistencia = true,
+  ) {
     return this.repository
       .findOne({ equipo, programa })
       .then((equipoPrograma) => {
-        if (equipoPrograma)
+        if (validarExistencia && equipoPrograma)
           throw new ConflictException(
             'Ya existe un equipo programa con este equipo y este programa.',
           );
+        return equipoPrograma;
       });
   }