Cosmos.Contabilidad.Mensajeria 0.0.3

Cosmos.Contabilidad.Mensajeria

Extensiones de Wolverine para integrarse con el sub-dominio de Contabilidad del ERP Cosmos. Configura la publicación de hechos económicos y la recepción de resultados de contabilización sobre RabbitMQ.

Si solo necesitas los contratos (sin Wolverine), usa el paquete Cosmos.Contabilidad.Contratos.

Instalación

dotnet add package Cosmos.Contabilidad.Mensajeria

Configuración

En las WolverineOptions del servicio productor (OXP, CXC, Tesorería, etc.):

options.HabilitarContabilidad("MiServicio-From-Contabilidad");

Esto configura:

1. La publicación de HechoEconomicoCreado a la cola de Contabilidad (Contabilidad-HechosEconomicos) con Outbox durable. Se publica directo a la cola —no al exchange— para evitar el echo hacia la propia cola de resultados.
2. La suscripción al exchange de Contabilidad para recibir HechoEconomicoContabilizado y HechoEconomicoRechazado.

Ejemplo de uso

// Program.cs del sub-dominio productor
builder.Host.UsarWolverineParaComandos(
    typeof(IDominioAssemblyMarker).Assembly,
    connectionString, "MiSchema",
    builder.Environment.IsDevelopment(),
    options =>
    {
        options.HabilitarRabbitMq("RabbitMQ");
        options.HabilitarOutbox(serviceName, typeof(IContratosAssemblyMarker).Assembly);
        options.HabilitarInbox();

        // Una línea para conectarse con Contabilidad
        options.HabilitarContabilidad("MiServicio-From-Contabilidad");
    }
);

// En el handler que causa el hecho económico
using Cosmos.Contabilidad.Contratos.ServicioDeTraduccion.Eventos;
using Cosmos.Contabilidad.Contratos.ServicioDeTraduccion.Modelos;
using Cosmos.Types;

var origen = new Origen(
    ReferenciaOrigen: "oxp-comercio-123/causada",
    SubDominioOrigen: "OXP",
    DocumentoFuente: "FAC-5678",
    ReferenciaHechoRelacionado: null);

var transaccion = new ContextoTransaccion(
    TipoTransaccion: "causacion_gasto",
    Empresa: new Empresa("31", "900123456", "Cosmos SAS"),
    Moneda: Moneda.COP,
    Fecha: DateTime.UtcNow);

var lineas = new List<LineaTraduccion>
{
    new(
        new ConceptoEconomico("gasto", "HONORARIOS", 1_000_000m),
        new DatosTercero("Nike", "NIT", "900123456"),
        UnidadOrganizacional: "VTA-001")
};

await publicEventSender.PublishAsync(new HechoEconomicoCreado(origen, transaccion, lineas));

// Consumer para recibir el resultado de contabilización [R17]
public class HechoContabilizadoConsumer
    : ICommandHandlerAsync<HechoEconomicoContabilizado>
{
    public Task HandleAsync(HechoEconomicoContabilizado evento, CancellationToken ct)
    {
        // evento.Origen.ReferenciaOrigen → identifica la transacción de origen
        // evento.ReferenciaDestino       → consecutivo del asiento en SincoA&F
        // evento.Destino                 → libro/sistema destino donde quedó el asiento
        return Task.CompletedTask;
    }
}

Métodos de extensión

Dependencias

Licencia

Software propietario © 2026 Sincosoft. Todos los derechos reservados.