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, 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); } /** * Construye una factura issue a partir de una proforma. * * @param companyId - Identificador de la empresa a la que pertenece la factura. * @param issueInvoiceId - Identificador UUID de la factura (opcional). * @param proforma - La proforma de la cual se generará la issue * @param pathcProps - otros props personalizados que se trasladarán a la issue * @returns Result - El agregado construido o un error si falla la creación. */ buildIssueInvoiceInCompany( companyId: UniqueID, proforma: CustomerInvoice, patchProps: CustomerInvoicePatchProps ): Result { const proformaProps = proforma.getIssuedInvoiceProps(); return CustomerInvoice.create({ ...proformaProps, ...patchProps, companyId, }); } /** * 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); } }