package jnpf.dmsService;

import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.DmsWailaiWenjianXinzengShenheEntity;
import jnpf.dmsEntity.DmsWenjianBanbenEntity;
import jnpf.dmsEntity.banben.DmsWenjianBanbenJiesuanModel;
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
import jnpf.dmsMapper.DmsWailaiWenjianXinzengShenheMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.Objects;

@Service
@RequiredArgsConstructor
public class DmsExternalApprovedSettlementService {
    private final DmsWailaiWenjianXinzengShenheMapper audits;
    private final DmsApprovedFileProjection projection;
    private final DmsWenjianYewuBanbenService versions;

    @AuditLog(action = "DMS_APPLY_EXTERNAL_NEW_AUDIT", bizCodeExpr = "#batch.auditId", recordSuccess = false)
    @Transactional(propagation = Propagation.MANDATORY, rollbackFor = Exception.class)
    public void apply(DmsApprovedBatch batch) {
        List<DmsWailaiWenjianXinzengShenheEntity> rows = audits.selectByFlowForUpdate(
                batch.getTenantId(), batch.getFlowId(), batch.getTaskId());
        if (rows == null || rows.size() != 1 || !Integer.valueOf(2).equals(rows.get(0).getFlowState()))
            throw new DataException("未找到唯一已通过的外来文件审核单");
        DmsWailaiWenjianXinzengShenheEntity audit = rows.get(0);
        if (!Objects.equals(batch.getAuditId(), audit.getId()))
            throw new DataException("外来文件审核单与登记批次不一致");
        if (audit.getShengxiaoWenjianBanbenId() != null || audit.getWenjianId() != null)
            throw new DataException("外来文件审核单已回写其他业务资源");

        DmsWenjianBanbenJiesuanModel model = new DmsWenjianBanbenJiesuanModel();
        model.setTenantId(batch.getTenantId());
        model.setUserId(batch.getActorId());
        model.setWenjianLeixing(DmsWenjianYewuBanbenService.EXTERNAL_FILE);
        model.setLaiyuanDanjuLeixing("wailai_wenjian_xinzeng_shenhe");
        model.setLaiyuanDanjuId(audit.getId());
        model.setLaiyuanYewuJian("wailai_wenjian_xinzeng_shenhe:" + audit.getId() + ":wailaiWenjian");
        model.setWenjianBianhao(audit.getWailaiWenjianBianhao());
        model.setWenjianMingcheng(audit.getWenjianMingcheng());
        model.setWenjianMuluId(audit.getWenjianMuluId());
        model.setGuishuBumenId(audit.getBumenId());
        model.setWenjianNeirong(audit.getBizFiles());
        model.setWenjianFenlei(null);
        projection.enrich(model);
        if (!Objects.equals(audit.getBanbenhao(), model.getCenterVersionLabel()))
            throw new DataException("外来文件标准版本与中心正式版本不一致");
        DmsWenjianBanbenEntity version = versions.createInitialVersion(model);
        audit.setWenjianId(version.getWenjianId());
        audit.setShengxiaoWenjianBanbenId(version.getId());
        audit.setBanbenShengxiaoShijian(version.getShengxiaoShijian());
        if (audits.updateEffectiveVersion(audit) != 1)
            throw new DataException("回写外来文件审核生效版本失败");
    }
}