baiyue-firstleg/lastleg-service/src/main/java/com/baiyue/lastleg/wallet/WalletCommandOutboxService.java

package com.baiyue.lastleg.wallet;

import com.baomidou.mybatisplus.core.toolkit.IdWorker;
import com.baiyue.common.event.EventEnvelope;
import com.baiyue.common.event.EventIdentifiers;
import com.baiyue.common.event.EventPayloadCanonicalizer;
import com.baiyue.common.event.EventPayloadHash;
import com.baiyue.common.event.EventTypes;
import com.baiyue.common.event.WalletCommandRequestedV1;
import com.baiyue.lastleg.entity.LastlegEventOutbox;
import com.baiyue.lastleg.mapper.LastlegEventOutboxMapper;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;

@Service
@RequiredArgsConstructor
public class WalletCommandOutboxService {
    private final LastlegEventOutboxMapper mapper;
    private final ObjectMapper objectMapper;

    public String publish(String operation, long customerId, String businessType, String businessNo,
                          BigDecimal amount, String remark, long aggregateVersion) {
        String eventKey = "WALLET_COMMAND:" + businessType + ':' + businessNo + ':' + operation + ':' + aggregateVersion;
        LastlegEventOutbox existing = mapper.findByEventKey(eventKey);
        if (existing != null) return eventId(existing.getPayloadJson());
        String idempotencyKey = businessType + ':' + businessNo + ':' + operation + ':' + aggregateVersion;
        WalletCommandRequestedV1 value = new WalletCommandRequestedV1(operation, customerId, businessType,
            businessNo, amount, remark, idempotencyKey, Instant.now());
        JsonNode payload = objectMapper.valueToTree(value);
        EventEnvelope envelope = new EventEnvelope(EventIdentifiers.newUuid(), EventTypes.WALLET_COMMAND_REQUESTED,
            WalletCommandRequestedV1.VERSION, Instant.now(),
            String.valueOf(customerId), businessType, businessNo, aggregateVersion, null,
            EventIdentifiers.newUuid(), eventKey, null, payload,
            EventPayloadHash.sha256(EventPayloadCanonicalizer.canonicalize(payload))).requireValid();
        LastlegEventOutbox row = new LastlegEventOutbox();
        row.setId(IdWorker.getId()); row.setCustomerId(String.valueOf(customerId));
        row.setAggregateType(businessType); row.setAggregateId(businessNo);
        row.setEventType(envelope.eventType()); row.setEventVersion(envelope.eventVersion());
        row.setEventKey(eventKey); row.setPayloadJson(json(envelope)); row.setStatus("PENDING");
        row.setRetryCount(0); row.setCreatedAt(LocalDateTime.now(ZoneOffset.UTC));
        mapper.insert(row);
        return envelope.eventId();
    }

    private String eventId(String json) {
        try { return objectMapper.readValue(json, EventEnvelope.class).eventId(); }
        catch (Exception exception) { throw new IllegalStateException("资金指令事件快照损坏", exception); }
    }
    private String json(Object value) {
        try { return objectMapper.writeValueAsString(value); }
        catch (Exception exception) { throw new IllegalStateException("资金指令事件序列化失败", exception); }
    }
}