formato correcto de cuestionario por verificar
This commit is contained in:
Your Name
@@ -4,14 +4,22 @@ import { PreguntaController } from './pregunta.controller';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { Pregunta } from './entities/pregunta.entity';
|
||||
import { TipoPreguntaModule } from '../tipo_pregunta/tipo_pregunta.module';
|
||||
import { TipoPregunta } from '../tipo_pregunta/entities/tipo_pregunta.entity';
|
||||
import { Opcion } from '../opcion/entities/opcion.entity';
|
||||
import { PreguntaOpcion } from '../pregunta_opcion/entities/pregunta_opcion.entity';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
TypeOrmModule.forFeature([Pregunta]),
|
||||
TypeOrmModule.forFeature([
|
||||
Pregunta,
|
||||
TipoPregunta,
|
||||
Opcion,
|
||||
PreguntaOpcion
|
||||
]),
|
||||
TipoPreguntaModule
|
||||
],
|
||||
controllers: [PreguntaController],
|
||||
providers: [PreguntaService],
|
||||
exports: [TypeOrmModule]
|
||||
exports: [TypeOrmModule, PreguntaService]
|
||||
})
|
||||
export class PreguntaModule {}
|
||||
|
||||
@@ -1,26 +1,254 @@
|
||||
import { Injectable } from '@nestjs/common';
|
||||
import { CreatePreguntaDto } from './dto/create-pregunta.dto';
|
||||
import { Injectable, NotFoundException } from '@nestjs/common';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { Repository, DataSource } from 'typeorm';
|
||||
import { CreatePreguntaDto, OpcionDto } from './dto/create-pregunta.dto';
|
||||
import { UpdatePreguntaDto } from './dto/update-pregunta.dto';
|
||||
import { Pregunta } from './entities/pregunta.entity';
|
||||
import { TipoPregunta } from '../tipo_pregunta/entities/tipo_pregunta.entity';
|
||||
import { Opcion } from '../opcion/entities/opcion.entity';
|
||||
import { PreguntaOpcion } from '../pregunta_opcion/entities/pregunta_opcion.entity';
|
||||
|
||||
@Injectable()
|
||||
export class PreguntaService {
|
||||
create(createPreguntaDto: CreatePreguntaDto) {
|
||||
return 'This action adds a new pregunta';
|
||||
constructor(
|
||||
@InjectRepository(Pregunta)
|
||||
private preguntaRepository: Repository<Pregunta>,
|
||||
@InjectRepository(TipoPregunta)
|
||||
private tipoPreguntaRepository: Repository<TipoPregunta>,
|
||||
@InjectRepository(Opcion)
|
||||
private opcionRepository: Repository<Opcion>,
|
||||
@InjectRepository(PreguntaOpcion)
|
||||
private preguntaOpcionRepository: Repository<PreguntaOpcion>,
|
||||
private dataSource: DataSource
|
||||
) {}
|
||||
|
||||
async create(createPreguntaDto: CreatePreguntaDto) {
|
||||
const queryRunner = this.dataSource.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
await queryRunner.startTransaction();
|
||||
|
||||
try {
|
||||
// Obtener el tipo de pregunta por su nombre
|
||||
const tipoPregunta = await this.tipoPreguntaRepository.findOne({
|
||||
where: { tipo_pregunta: createPreguntaDto.tipo }
|
||||
});
|
||||
|
||||
if (!tipoPregunta) {
|
||||
throw new Error(`Tipo de pregunta '${createPreguntaDto.tipo}' no encontrado`);
|
||||
}
|
||||
|
||||
// Crear pregunta
|
||||
const pregunta = new Pregunta();
|
||||
pregunta.pregunta = createPreguntaDto.titulo;
|
||||
pregunta.obligatoria = createPreguntaDto.obligatoria || false;
|
||||
pregunta.id_tipo_pregunta = tipoPregunta.id_tipo;
|
||||
pregunta.id_opcion_dependiente = createPreguntaDto.id_opcion_dependiente || undefined;
|
||||
pregunta.contador_opcion = createPreguntaDto.opciones?.length || 0;
|
||||
|
||||
const savedPregunta = await queryRunner.manager.save(pregunta);
|
||||
|
||||
// Crear opciones para preguntas de tipo multiple/radio
|
||||
if (createPreguntaDto.opciones && createPreguntaDto.opciones.length > 0) {
|
||||
await this.createOpciones(
|
||||
queryRunner,
|
||||
savedPregunta.id_pregunta,
|
||||
createPreguntaDto.opciones
|
||||
);
|
||||
}
|
||||
|
||||
await queryRunner.commitTransaction();
|
||||
|
||||
return {
|
||||
success: true,
|
||||
pregunta: savedPregunta
|
||||
};
|
||||
} catch (error) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
throw error;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
}
|
||||
}
|
||||
|
||||
findAll() {
|
||||
return `This action returns all pregunta`;
|
||||
private async createOpciones(
|
||||
queryRunner: any,
|
||||
preguntaId: number,
|
||||
opciones: OpcionDto[]
|
||||
) {
|
||||
for (let i = 0; i < opciones.length; i++) {
|
||||
const opcionDto = opciones[i];
|
||||
|
||||
// Crear opción
|
||||
const opcion = new Opcion();
|
||||
opcion.opcion = opcionDto.valor;
|
||||
|
||||
const savedOpcion = await queryRunner.manager.save(opcion);
|
||||
|
||||
// Vincular opción con pregunta
|
||||
const preguntaOpcion = new PreguntaOpcion();
|
||||
preguntaOpcion.id_pregunta = preguntaId;
|
||||
preguntaOpcion.opcion = savedOpcion;
|
||||
preguntaOpcion.posicion = i + 1;
|
||||
|
||||
await queryRunner.manager.save(preguntaOpcion);
|
||||
}
|
||||
}
|
||||
|
||||
findOne(id: number) {
|
||||
return `This action returns a #${id} pregunta`;
|
||||
async findAll() {
|
||||
return this.preguntaRepository.find();
|
||||
}
|
||||
|
||||
update(id: number, updatePreguntaDto: UpdatePreguntaDto) {
|
||||
return `This action updates a #${id} pregunta`;
|
||||
async findOne(id: number) {
|
||||
const pregunta = await this.preguntaRepository.findOne({
|
||||
where: { id_pregunta: id }
|
||||
});
|
||||
|
||||
if (!pregunta) {
|
||||
throw new NotFoundException(`Pregunta con ID ${id} no encontrada`);
|
||||
}
|
||||
|
||||
return pregunta;
|
||||
}
|
||||
|
||||
remove(id: number) {
|
||||
return `This action removes a #${id} pregunta`;
|
||||
async findWithOptions(id: number) {
|
||||
const pregunta = await this.preguntaRepository.findOne({
|
||||
where: { id_pregunta: id },
|
||||
relations: ['tipoPregunta']
|
||||
});
|
||||
|
||||
if (!pregunta) {
|
||||
throw new NotFoundException(`Pregunta con ID ${id} no encontrada`);
|
||||
}
|
||||
|
||||
// Obtener las opciones para esta pregunta
|
||||
const preguntaOpciones = await this.preguntaOpcionRepository.find({
|
||||
where: { id_pregunta: id },
|
||||
relations: ['opcion'],
|
||||
order: { posicion: 'ASC' }
|
||||
});
|
||||
|
||||
const opciones = preguntaOpciones.map(po => ({
|
||||
id: po.opcion.id_opcion,
|
||||
valor: po.opcion.opcion,
|
||||
posicion: po.posicion
|
||||
}));
|
||||
|
||||
return {
|
||||
...pregunta,
|
||||
tipo: pregunta.tipoPregunta?.tipo_pregunta,
|
||||
opciones
|
||||
};
|
||||
}
|
||||
|
||||
async update(id: number, updatePreguntaDto: UpdatePreguntaDto) {
|
||||
const queryRunner = this.dataSource.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
await queryRunner.startTransaction();
|
||||
|
||||
try {
|
||||
const pregunta = await this.preguntaRepository.findOne({
|
||||
where: { id_pregunta: id }
|
||||
});
|
||||
|
||||
if (!pregunta) {
|
||||
throw new NotFoundException(`Pregunta con ID ${id} no encontrada`);
|
||||
}
|
||||
|
||||
// Actualizar los campos básicos de la pregunta
|
||||
if (updatePreguntaDto.titulo) pregunta.pregunta = updatePreguntaDto.titulo;
|
||||
if (updatePreguntaDto.obligatoria !== undefined) pregunta.obligatoria = updatePreguntaDto.obligatoria;
|
||||
if (updatePreguntaDto.id_opcion_dependiente !== undefined) pregunta.id_opcion_dependiente = updatePreguntaDto.id_opcion_dependiente;
|
||||
|
||||
// Si se proporciona un nuevo tipo de pregunta, actualizarlo
|
||||
if (updatePreguntaDto.tipo) {
|
||||
const tipoPregunta = await this.tipoPreguntaRepository.findOne({
|
||||
where: { tipo_pregunta: updatePreguntaDto.tipo }
|
||||
});
|
||||
|
||||
if (!tipoPregunta) {
|
||||
throw new Error(`Tipo de pregunta '${updatePreguntaDto.tipo}' no encontrado`);
|
||||
}
|
||||
|
||||
pregunta.id_tipo_pregunta = tipoPregunta.id_tipo;
|
||||
}
|
||||
|
||||
// Actualizar la pregunta
|
||||
const updatedPregunta = await queryRunner.manager.save(pregunta);
|
||||
|
||||
// Si se proporcionan nuevas opciones, actualizarlas
|
||||
if (updatePreguntaDto.opciones && updatePreguntaDto.opciones.length > 0) {
|
||||
// Eliminar las opciones existentes
|
||||
const existingOptions = await this.preguntaOpcionRepository.find({
|
||||
where: { id_pregunta: id }
|
||||
});
|
||||
|
||||
for (const option of existingOptions) {
|
||||
await queryRunner.manager.remove(option);
|
||||
}
|
||||
|
||||
// Crear las nuevas opciones
|
||||
await this.createOpciones(
|
||||
queryRunner,
|
||||
id,
|
||||
updatePreguntaDto.opciones
|
||||
);
|
||||
|
||||
// Actualizar el contador de opciones
|
||||
updatedPregunta.contador_opcion = updatePreguntaDto.opciones.length;
|
||||
await queryRunner.manager.save(updatedPregunta);
|
||||
}
|
||||
|
||||
await queryRunner.commitTransaction();
|
||||
|
||||
return {
|
||||
success: true,
|
||||
pregunta: updatedPregunta
|
||||
};
|
||||
} catch (error) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
throw error;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
}
|
||||
}
|
||||
|
||||
async remove(id: number) {
|
||||
const queryRunner = this.dataSource.createQueryRunner();
|
||||
await queryRunner.connect();
|
||||
await queryRunner.startTransaction();
|
||||
|
||||
try {
|
||||
const pregunta = await this.preguntaRepository.findOne({
|
||||
where: { id_pregunta: id }
|
||||
});
|
||||
|
||||
if (!pregunta) {
|
||||
throw new NotFoundException(`Pregunta con ID ${id} no encontrada`);
|
||||
}
|
||||
|
||||
// Eliminar las relaciones con opciones
|
||||
const preguntaOpciones = await this.preguntaOpcionRepository.find({
|
||||
where: { id_pregunta: id }
|
||||
});
|
||||
|
||||
for (const po of preguntaOpciones) {
|
||||
await queryRunner.manager.remove(po);
|
||||
}
|
||||
|
||||
// Eliminar la pregunta
|
||||
await queryRunner.manager.remove(pregunta);
|
||||
|
||||
await queryRunner.commitTransaction();
|
||||
|
||||
return {
|
||||
success: true,
|
||||
message: `Pregunta con ID ${id} eliminada correctamente`
|
||||
};
|
||||
} catch (error) {
|
||||
await queryRunner.rollbackTransaction();
|
||||
throw error;
|
||||
} finally {
|
||||
await queryRunner.release();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user