CARGA masiva corregida

src/equipo-programa/entity/views/informacion-equipo-programa.view.ts

@@ -0,0 +1,22 @@
+import { DataSource, ViewEntity, ViewColumn } from 'typeorm';
+import { EquipoPrograma } from '../equipo-programa.entity';
+
+@ViewEntity({
+  expression: (dataSource: DataSource) =>
+    dataSource
+      .createQueryBuilder()
+      .select('ep.id_equipo_programa', 'id_equipo_programa')
+      .addSelect('ep.id_equipo', 'id_equipo')
+      .addSelect('ep.id_programa', 'id_programa')
+      .from(EquipoPrograma, 'ep'),
+})
+export class InformacionEquipoProgramaView {
+  @ViewColumn()
+  id_equipo_programa: number;
+
+  @ViewColumn()
+  id_equipo: number;
+
+  @ViewColumn()
+  id_programa: number;
+}

src/equipo-programa/equipo-programa.module.ts

@@ -4,6 +4,7 @@ import { TypeOrmModule } from '@nestjs/typeorm';
 import { EquipoProgramaController } from './equipo-programa.controller';
 import { EquipoProgramaService } from './equipo-programa.service';
 import { EquipoPrograma } from '../equipo-programa/entity/equipo-programa.entity';
+import { InformacionEquipoProgramaView } from './entity/views/informacion-equipo-programa.view';
 import { EquipoModule } from '../equipo/equipo.module';
 import { InstitucionProgramaModule } from '../institucion-programa/institucion-programa.module';
 
@@ -12,7 +13,7 @@ import { InstitucionProgramaModule } from '../institucion-programa/institucion-p
     forwardRef(() => EquipoModule),
     InstitucionProgramaModule,
     PassportModule.register({ defaultStrategy: 'jwt' }),
-    TypeOrmModule.forFeature([EquipoPrograma]),
+    TypeOrmModule.forFeature([EquipoPrograma, InformacionEquipoProgramaView]),
   ],
   controllers: [EquipoProgramaController],
   providers: [EquipoProgramaService],

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

@@ -10,6 +10,7 @@ import { Repository } from 'typeorm';
 import { Equipo } from '../equipo/entity/equipo.entity';
 import { EquipoPrograma } from './entity/equipo-programa.entity';
 import { Programa } from '../institucion-programa/entity/programa.entity';
+import { InformacionEquipoProgramaView } from './entity/views/informacion-equipo-programa.view';
 import { EquipoService } from '../equipo/equipo.service';
 import { InstitucionProgramaService } from '../institucion-programa/institucion-programa.service';
 import { Operador } from '../operador/entity/operador.entity';
@@ -19,6 +20,8 @@ export class EquipoProgramaService {
   constructor(
     @InjectRepository(EquipoPrograma)
     private repository: Repository<EquipoPrograma>,
+    @InjectRepository(InformacionEquipoProgramaView)
+    private informacionEquipoProgramaView: Repository<InformacionEquipoProgramaView>,
     @Inject(forwardRef(() => EquipoService))
     private equipoService: EquipoService,
     private institucionProgramaService: InstitucionProgramaService,
@@ -29,9 +32,6 @@ export class EquipoProgramaService {
     id_equipo: number | Equipo,
     id_programa: number | Programa,
   ) {
-    const sinPrograma = await this.institucionProgramaService.findProgramaById(
-      1,
-    );
     const equipo =
       typeof id_equipo === 'number'
         ? await this.equipoService.findById(id_equipo)
@@ -41,13 +41,39 @@ export class EquipoProgramaService {
         ? await this.institucionProgramaService.findProgramaById(id_programa)
         : id_programa;
 
-    return this.findEquipoProgramaByEquipoPrograma(equipo, programa)
-      .then((_) =>
-        this.findEquipoProgramaByEquipoPrograma(equipo, sinPrograma, false),
-      )
+    return this.informacionEquipoPrograma(
+      equipo.id_equipo,
+      programa.id_programa,
+    )
+      .then((existeEquipoPrograma) => {
+        if (existeEquipoPrograma)
+          throw new ConflictException(
+            'Este software ya fue asignado a este equipo.',
+          );
+        return this.informacionEquipoPrograma(equipo.id_equipo, 1);
+      })
       .then(async (existeEquipoSinPrograma) => {
         if (existeEquipoSinPrograma)
-          await this.repository.remove(existeEquipoSinPrograma);
+          await this.repository.delete({
+            id_equipo_programa: existeEquipoSinPrograma.id_equipo_programa,
+          });
+        return this.repository.save(
+          this.repository.create({ equipo, programa }),
+        );
+      })
+      .then((equipoPrograma) => ({
+        message: `Se asignó el software: ${equipoPrograma.programa.programa}, al equipo con número de inventario: ${equipo.numero_inventario}.`,
+        equipoPrograma,
+      }));
+  }
+
+  async createCargaMasiva(equipo: Equipo, programa: Programa) {
+    return this.informacionEquipoPrograma(equipo.id_equipo, 1)
+      .then(async (existeEquipoSinPrograma) => {
+        if (existeEquipoSinPrograma)
+          await this.repository.delete({
+            id_equipo_programa: existeEquipoSinPrograma.id_equipo_programa,
+          });
         return this.repository.save(
           this.repository.create({ equipo, programa }),
         );
@@ -120,4 +146,10 @@ export class EquipoProgramaService {
         return equipoPrograma;
       });
   }
+
+  informacionEquipoPrograma(id_equipo: number, id_programa: number) {
+    return this.informacionEquipoProgramaView.findOne({
+      where: { id_equipo, id_programa },
+    });
+  }
 }