package jnpf.dmsService;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.wenjianbianhao.DmsFlowEventType;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/** Records issuance failure only after the native business transaction has rolled back. */
@Slf4j
@Service
@RequiredArgsConstructor
public class DmsWenjianBianhaoFlowService {
    private final DmsWenjianBianhaoApplicationService applications;

    @AuditLog(action = "DMS_NUMBER_FLOW_SYNC", failureAction = "DMS_NUMBER_FLOW_SYNC_FAILED",
            label = "同步文件编号申请流程", bizModule = "DMS", bizType = "DMS_NUMBER_APPLICATION",
            bizCodeExpr = "#p1", bizCodeRequired = false, targetTable = "dms_wenjian_bianhao_shenqing", targetIdExpr = "#p1")
    public void sync(String flowId, String taskId, Integer flowState, DmsFlowEventType eventType)
            throws DataException {
        try {
            applications.syncApplicationFlow(flowId, taskId, flowState, eventType);
        } catch (Exception failure) {
            if (Integer.valueOf(2).equals(flowState) && eventType == DmsFlowEventType.END) {
                try {
                    applications.markIssuanceFailed(flowId, taskId);
                } catch (Exception markingFailure) {
                    failure.addSuppressed(markingFailure);
                    log.error("文件编号发放失败，且失败标志回写失败 taskId={}", taskId, failure);
                }
            }
            throw failure;
        }
    }
}