Cosmos.Contabilidad.Mensajeria 0.0.1

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 HechoEconomicoRecibido al exchange de Contabilidad con Outbox durable.
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;

var lineas = new List<LineaTraduccion>
{
    new(
        new ConceptoEconomico("gasto", "HONORARIOS", 1_000_000m),
        new DatosTercero("Nike", "NIT", "900123456"),
        new ContextoTransaccion("causacion_gasto", "COSMOS-SAS", Moneda.COP, DateTime.UtcNow),
        new Origen("oxp-comercio-123/causada", "OXP", "FAC-5678", null),
        "VTA-001")
};

await publicEventSender.PublishAsync(new HechoEconomicoRecibido(lineas));

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

Método de extensión

Dependencias

Licencia

Software propietario © 2026 Sincosoft. Todos los derechos reservados.