import { Criteria } from "@repo/rdx-criteria/server"; import { UniqueID } from "@repo/rdx-ddd"; import { Collection, Maybe, Result } from "@repo/rdx-utils"; import { Transaction } from "sequelize"; import { CustomerInvoiceNumber, CustomerInvoiceSerie, CustomerInvoiceStatus, ICustomerInvoiceNumberGenerator, } from "../../domain"; import { CustomerInvoice, CustomerInvoicePatchProps, CustomerInvoiceProps, } from "../../domain/aggregates"; import { ICustomerInvoiceRepository } from "../../domain/repositories"; import { CustomerInvoiceListDTO } from "../../infrastructure"; export class CustomerInvoiceApplicationService { constructor( private readonly repository: ICustomerInvoiceRepository, private readonly numberGenerator: ICustomerInvoiceNumberGenerator ) {} /** * Devuelve el siguiente nº para proformas * * @param companyId - Identificador de la empresa a la que pertenece la proforma. * @param transaction - Transacción activa para la operación. * @returns Result - El agregado construido o un error si falla la creación. */ async getNextProformaNumber( companyId: UniqueID, transaction: Transaction ): Promise> { return await this.numberGenerator.nextForCompany(companyId, Maybe.none(), transaction); } /** * Devuelve el siguiente nº para facturas (issue) * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param series - Serie por la que buscar la última factura * @param transaction - Transacción activa para la operación. * @returns Result - El agregado construido o un error si falla la creación. */ async getNextIssueInvoiceNumber( companyId: UniqueID, series: Maybe, transaction: Transaction ): Promise> { return await this.numberGenerator.nextForCompany(companyId, series, transaction); } /** * Construye una proforma a partir de props validadas. * * @param companyId - Identificador de la empresa a la que pertenece la proforma. * @param props - Las propiedades ya validadas para crear la proforma. * @param invoiceId - Identificador UUID de la proforma (opcional). * @returns Result - El agregado construido o un error si falla la creación. */ buildProformaInCompany( companyId: UniqueID, props: Omit, invoiceId?: UniqueID ): Result { return CustomerInvoice.create({ ...props, companyId }, invoiceId); } /** * Guarda una nueva factura y devuelve la factura guardada. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param invoice - El agregado a guardar. * @param transaction - Transacción activa para la operación. * @returns Result - El agregado guardado o un error si falla la operación. */ async createInvoiceInCompany( companyId: UniqueID, invoice: CustomerInvoice, transaction: Transaction ): Promise> { const result = await this.repository.create(invoice, transaction); if (result.isFailure) { return Result.fail(result.error); } return this.getInvoiceByIdInCompany(companyId, invoice.id, transaction); } /** * Actualiza una factura existente y devuelve la factura actualizada. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param invoice - El agregado a guardar. * @param transaction - Transacción activa para la operación. * @returns Result - El agregado guardado o un error si falla la operación. */ async updateInvoiceInCompany( companyId: UniqueID, invoice: CustomerInvoice, transaction: Transaction ): Promise> { const result = await this.repository.update(invoice, transaction); if (result.isFailure) { return Result.fail(result.error); } return this.getInvoiceByIdInCompany(companyId, invoice.id, transaction); } /** * * Comprueba si existe o no en persistencia una factura con el ID proporcionado * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param invoiceId - Identificador UUID de la factura. * @param transaction - Transacción activa para la operación. * @returns Result - Existe la factura o no. */ async existsByIdInCompany( companyId: UniqueID, invoiceId: UniqueID, transaction?: Transaction ): Promise> { return this.repository.existsByIdInCompany(companyId, invoiceId, transaction); } /** * Obtiene una colección de facturas que cumplen con los filtros definidos en un objeto Criteria. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param criteria - Objeto con condiciones de filtro, paginación y orden. * @param transaction - Transacción activa para la operación. * @returns Result, Error> - Colección de facturas o error. */ async findInvoiceByCriteriaInCompany( companyId: UniqueID, criteria: Criteria, transaction?: Transaction ): Promise, Error>> { return this.repository.findByCriteriaInCompany(companyId, criteria, transaction); } /** * Recupera una factura por su identificador único. * * @param invoiceId - Identificador UUID de la factura. * @param transaction - Transacción activa para la operación. * @returns Result - Factura encontrada o error. */ async getInvoiceByIdInCompany( companyId: UniqueID, invoiceId: UniqueID, transaction?: Transaction ): Promise> { return await this.repository.getByIdInCompany(companyId, invoiceId, transaction); } /** * Actualiza parcialmente una factura existente con nuevos datos. * No lo guarda en el repositorio. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param invoiceId - Identificador de la factura a actualizar. * @param changes - Subconjunto de props válidas para aplicar. * @param transaction - Transacción activa para la operación. * @returns Result - Factura actualizada o error. */ async patchInvoiceByIdInCompany( companyId: UniqueID, invoiceId: UniqueID, changes: CustomerInvoicePatchProps, transaction?: Transaction ): Promise> { const invoiceResult = await this.getInvoiceByIdInCompany(companyId, invoiceId, transaction); if (invoiceResult.isFailure) { return Result.fail(invoiceResult.error); } const updated = invoiceResult.data.update(changes); if (updated.isFailure) { return Result.fail(updated.error); } return Result.ok(updated.data); } /** * Elimina (o marca como eliminada) una factura según su ID. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param invoiceId - Identificador UUID de la factura. * @param transaction - Transacción activa para la operación. * @returns Result - Resultado de la operación. */ async deleteInvoiceByIdInCompany( companyId: UniqueID, invoiceId: UniqueID, transaction?: Transaction ): Promise> { return this.repository.deleteByIdInCompany(companyId, invoiceId, transaction); } /** * * Actualiza el "status" de una proforma * * @param companyId - Identificador UUID de la empresa a la que pertenece el cliente. * @param proformaId - UUID de la factura a eliminar. * @param newStatus - nuevo estado * @param transaction - Transacción activa para la operación. * @returns Result */ async updateProformaStatusByIdInCompany( companyId: UniqueID, proformaId: UniqueID, newStatus: CustomerInvoiceStatus, transaction?: Transaction ): Promise> { return this.repository.updateProformaStatusByIdInCompany( companyId, proformaId, newStatus, transaction ); } }