package jnpf.dmsService;

import jnpf.dmsEntity.DmsWenjianBanbenEntity;
import jnpf.dmsEntity.DmsWenjianGuanxiEntity;
import jnpf.dmsEntity.DmsWenjianZiyuanEntity;
import jnpf.dmsEntity.banben.DmsWenjianBanbenJiesuanModel;
import jnpf.dmsMapper.DmsWenjianBanbenMapper;
import jnpf.dmsMapper.DmsWenjianGuanxiMapper;
import jnpf.dmsMapper.DmsWenjianZiyuanMapper;
import jnpf.exception.DataException;
import jnpf.util.RandomUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.Objects;

@Service
@RequiredArgsConstructor
public class DmsWenjianYewuBanbenService {
    public static final String MAIN_FILE = "zhuwenjian";
    public static final String RECORD_FILE = "jilu";
    public static final String EXTERNAL_FILE = "wailaiWenjian";
    public static final String RELATION_RECORD = "jilu";

    private static final String EFFECTIVE = "effective";

    private final DmsWenjianZiyuanMapper resourceMapper;
    private final DmsWenjianBanbenMapper versionMapper;
    private final DmsWenjianGuanxiMapper relationMapper;

    @Transactional(rollbackFor = Exception.class)
    public DmsWenjianBanbenEntity createInitialVersion(DmsWenjianBanbenJiesuanModel model)
            throws DataException {
        validateCommon(model);
        validateInitial(model);
        DmsWenjianBanbenEntity repeated = versionMapper.selectBySourceBusinessKey(
                model.getTenantId(), model.getLaiyuanYewuJian());
        if (repeated != null) {
            validateRepeated(repeated, model, null);
            return repeated;
        }

        if (resourceMapper.selectByNumberForUpdate(
                model.getTenantId(), model.getWenjianBianhao().trim()) != null
                || (!blank(model.getWenjianBianhaoId())
                && resourceMapper.selectByNumberDetailForUpdate(
                model.getTenantId(), model.getWenjianBianhaoId().trim()) != null)) {
            throw new DataException("文件编号已被占用，历史编号不可复用");
        }

        Date now = new Date();
        String fileId = blank(model.getWenjianId()) ? RandomUtil.uuId() : model.getWenjianId();
        DmsWenjianZiyuanEntity resource = new DmsWenjianZiyuanEntity();
        resource.setId(fileId);
        resource.setTenantId(model.getTenantId());
        resource.setWenjianLeixing(model.getWenjianLeixing());
        resource.setWenjianBianhaoId(trimToNull(model.getWenjianBianhaoId()));
        resource.setWenjianBianhao(model.getWenjianBianhao().trim());
        resource.setWenjianMingcheng(model.getWenjianMingcheng().trim());
        resource.setJiluLeixing(trimToNull(model.getJiluLeixing()));
        resource.setDengji(trimToNull(model.getDengji()));
        resource.setWenjianMuluId(model.getWenjianMuluId());
        resource.setShifouShoukong(model.getShifouShoukong());
        resource.setJiluDengjiGuanliId(model.getJiluDengjiGuanliId());
        resource.setJiluDengjiGuanliBanben(model.getJiluDengjiGuanliBanben());
        resource.setGuishuBumenId(trimToNull(model.getGuishuBumenId()));
        resource.setWenjianZhongxinWenjianId(model.getCenterDocumentId());
        applyCenterValidity(resource, model);
        applyProjectionMetadata(resource, model);
        resource.setShouciShengxiaoShijian(model.getEffectiveAt() == null ? now : model.getEffectiveAt());
        resource.setBizStatus(EFFECTIVE);
        resource.setCreatorUserId(model.getUserId());
        resource.setCreatorTime(now);
        try {
            requireSingle(resourceMapper.insertResource(resource), "创建业务文件失败");
        } catch (DuplicateKeyException exception) {
            throw new DataException("文件资源或编号已被占用，历史编号不可复用");
        }

        DmsWenjianBanbenEntity version = buildVersion(model, fileId, null, 0, now);
        requireSingle(versionMapper.insertVersion(version), "创建文件初始版本失败");
        resource.setDangqianBanbenId(version.getId());
        resource.setDangqianBanbenhao(version.getBanbenhao());
        resource.setDangqianBanbenXuhao(version.getBanbenXuhao());
        resource.setLastModifyUserId(model.getUserId());
        resource.setLastModifyTime(now);
        requireSingle(resourceMapper.setInitialCurrentVersion(resource), "设置文件初始有效版本失败");
        return version;
    }

    @Transactional(rollbackFor = Exception.class)
    public DmsWenjianBanbenEntity createRevisionVersion(DmsWenjianBanbenJiesuanModel model)
            throws DataException {
        validateCommon(model);
        requireText(model.getWenjianId(), "待升级文件ID不能为空");
        String sourceVersionId = requireText(
                model.getYuanWenjianBanbenId(), "来源文件版本ID不能为空");
        DmsWenjianBanbenEntity repeated = versionMapper.selectBySourceBusinessKey(
                model.getTenantId(), model.getLaiyuanYewuJian());
        if (repeated != null) {
            validateRepeated(repeated, model, sourceVersionId);
            return repeated;
        }

        DmsWenjianZiyuanEntity resource = requireCurrentResource(model, sourceVersionId);
        DmsWenjianBanbenEntity current = versionMapper.selectById(
                model.getTenantId(), sourceVersionId);
        if (current == null || !EFFECTIVE.equals(current.getBizStatus())) {
            throw new DataException("来源文件版本不是当前有效版本");
        }
        int nextSequence;
        try {
            nextSequence = Math.addExact(current.getBanbenXuhao(), 1);
        } catch (ArithmeticException exception) {
            throw new DataException("文件版本序号已达到上限");
        }

        if (!Objects.equals(resource.getWenjianMuluId(), model.getWenjianMuluId())) {
            throw new DataException("普通修订不能改变文件目录");
        }
        model.setWenjianBianhaoId(resource.getWenjianBianhaoId());
        model.setWenjianBianhao(resource.getWenjianBianhao());
        model.setBianhaoShiyongRenId(resource.getBianhaoShiyongRenId());
        model.setWenjianFenlei(resource.getWenjianFenlei());
        if (blank(model.getWenjianMingcheng())) model.setWenjianMingcheng(resource.getWenjianMingcheng());
        if (blank(model.getGuishuBumenId())) model.setGuishuBumenId(resource.getGuishuBumenId());
        Date now = new Date();
        DmsWenjianBanbenEntity version = buildVersion(
                model, resource.getId(), sourceVersionId, nextSequence, now);
        requireSingle(versionMapper.markSuperseded(
                model.getTenantId(), sourceVersionId, model.getUserId(),
                "修订升版，由 " + version.getBanbenhao() + " 替代"), "来源文件版本已发生变化");
        requireSingle(versionMapper.insertVersion(version), "创建文件升级版本失败");

        applyMetadata(resource, model);
        resource.setWenjianZhongxinWenjianId(model.getCenterDocumentId());
        applyCenterValidity(resource, model);
        applyProjectionMetadata(resource, model);
        resource.setDangqianBanbenId(version.getId());
        resource.setDangqianBanbenhao(version.getBanbenhao());
        resource.setDangqianBanbenXuhao(version.getBanbenXuhao());
        resource.setLastModifyUserId(model.getUserId());
        resource.setLastModifyTime(now);
        requireSingle(resourceMapper.advanceCurrentVersion(
                resource, sourceVersionId), "更新文件当前有效版本失败");
        return version;
    }

    @Transactional(rollbackFor = Exception.class)
    public DmsWenjianBanbenEntity reuseCurrentVersion(String tenantId, String fileId,
                                                       String expectedVersionId)
            throws DataException {
        DmsWenjianBanbenJiesuanModel model = new DmsWenjianBanbenJiesuanModel();
        model.setTenantId(requireText(tenantId, "租户ID不能为空"));
        model.setWenjianId(requireText(fileId, "文件ID不能为空"));
        DmsWenjianZiyuanEntity resource = requireCurrentResource(
                model, requireText(expectedVersionId, "来源文件版本ID不能为空"));
        DmsWenjianBanbenEntity current = versionMapper.selectById(tenantId, resource.getDangqianBanbenId());
        if (current == null || !EFFECTIVE.equals(current.getBizStatus())) {
            throw new DataException("来源文件版本不是当前有效版本");
        }
        return current;
    }

    /** REUSE keeps the attachment identity; approved record metadata can still change. */
    @Transactional(rollbackFor = Exception.class)
    public DmsWenjianBanbenEntity updateReusedRecordMetadata(DmsWenjianBanbenJiesuanModel model) {
        if (!"xiuding_shenhe".equals(model.getLaiyuanDanjuLeixing())
                || !RECORD_FILE.equals(model.getWenjianLeixing()))
            throw new DataException("仅修订审核记录允许沿用附件更新信息");
        if (!"yes".equals(model.getShifouShoukong()) && !"no".equals(model.getShifouShoukong()))
            throw new DataException("记录方式缺失或无效");
        requireText(model.getWenjianMingcheng(), "记录名称不能为空");
        requireText(model.getGuishuBumenId(), "记录归属部门不能为空");
        DmsWenjianBanbenEntity current = reuseCurrentVersion(model.getTenantId(),
                model.getWenjianId(), model.getYuanWenjianBanbenId());
        if (!RECORD_FILE.equals(current.getWenjianLeixing())
                || !Objects.equals(current.getWenjianMuluId(), model.getWenjianMuluId())
                || !Objects.equals(current.getWenjianZhongxinBanbenId(), model.getCenterVersionId()))
            throw new DataException("沿用记录目录或附件版本已变化");
        requireSingle(versionMapper.updateReusedRecordMetadata(model), "更新沿用记录版本信息失败");
        requireSingle(resourceMapper.updateReusedRecordMetadata(model), "更新沿用记录资源信息失败");
        current.setShifouShoukong(model.getShifouShoukong());
        current.setWenjianMingcheng(model.getWenjianMingcheng());
        current.setGuishuBumenId(model.getGuishuBumenId());
        return current;
    }

    /** Called only after the unified revision batch has completed its center transaction. */
    @Transactional(rollbackFor = Exception.class)
    public void retireRecord(String tenantId, String mainFileId, String fileId,
                             String versionId, String userId) {
        DmsWenjianZiyuanEntity resource = resourceMapper.selectByIdForUpdate(tenantId, fileId);
        if (resource == null || !RECORD_FILE.equals(resource.getWenjianLeixing())
                || !EFFECTIVE.equals(resource.getBizStatus())
                || !Objects.equals(versionId, resource.getDangqianBanbenId())
                || relationMapper.selectEffective(tenantId, mainFileId, fileId, RELATION_RECORD) == null)
            throw new DataException("移除记录的当前版本或归属已改变");
        requireSingle(versionMapper.markSuperseded(tenantId, versionId, userId,
                "修订移除记录，保留历史"), "移除记录的业务版本已改变");
        requireSingle(resourceMapper.retireRecord(tenantId, fileId, versionId, userId), "回写移除记录失败");
        requireSingle(relationMapper.retireRecordRelation(tenantId, mainFileId, fileId, userId), "回写记录关系失败");
    }

    public DmsWenjianBanbenEntity resolveCurrentVersion(String tenantId, String fileId)
            throws DataException {
        String resolvedTenantId = requireText(tenantId, "租户ID不能为空");
        String resolvedFileId = requireText(fileId, "文件ID不能为空");
        DmsWenjianBanbenEntity current = versionMapper.selectCurrentByFileId(
                resolvedTenantId, resolvedFileId);
        if (current == null || !EFFECTIVE.equals(current.getBizStatus())) {
            throw new DataException("文件不存在当前有效版本");
        }
        return current;
    }

    @Transactional(rollbackFor = Exception.class)
    public DmsWenjianGuanxiEntity ensureRelation(String tenantId, String mainFileId,
                                                  String relatedFileId, String relationType,
                                                  String sourceAuditId, String userId)
            throws DataException {
        requireText(tenantId, "租户ID不能为空");
        requireText(mainFileId, "主文件ID不能为空");
        requireText(relatedFileId, "关联文件ID不能为空");
        if (mainFileId.equals(relatedFileId)) {
            throw new DataException("文件不能关联自身");
        }
        if (!RELATION_RECORD.equals(relationType) && !"guanlian_wenjian".equals(relationType)) {
            throw new DataException("文件关系类型无效");
        }
        DmsWenjianZiyuanEntity main = resourceMapper.selectByIdForUpdate(tenantId, mainFileId);
        DmsWenjianZiyuanEntity related = resourceMapper.selectByIdForUpdate(tenantId, relatedFileId);
        if (main == null || !EFFECTIVE.equals(main.getBizStatus())
                || !MAIN_FILE.equals(main.getWenjianLeixing())) {
            throw new DataException("主文件不存在或不是有效主文件");
        }
        if (related == null || !EFFECTIVE.equals(related.getBizStatus())) {
            throw new DataException("关联文件不存在或不是有效文件");
        }
        if (RELATION_RECORD.equals(relationType)
                && !RECORD_FILE.equals(related.getWenjianLeixing())) {
            throw new DataException("记录关系只能关联有效记录文件");
        }
        if (RELATION_RECORD.equals(relationType)
                && (blank(main.getWenjianMuluId()) || !Objects.equals(main.getWenjianMuluId(), related.getWenjianMuluId()))) {
            throw new DataException("记录必须与主文件在同一目录，不能跨目录复用");
        }
        DmsWenjianGuanxiEntity existing = relationMapper.selectEffective(
                tenantId, mainFileId, relatedFileId, relationType);
        if (existing != null) {
            return existing;
        }
        Date now = new Date();
        DmsWenjianGuanxiEntity relation = new DmsWenjianGuanxiEntity();
        relation.setId(RandomUtil.uuId());
        relation.setTenantId(tenantId);
        relation.setZhuWenjianId(mainFileId);
        relation.setGuanlianWenjianId(relatedFileId);
        relation.setGuanxiLeixing(relationType);
        relation.setLaiyuanDanjuId(requireText(sourceAuditId, "来源审核单ID不能为空"));
        relation.setBizStatus(EFFECTIVE);
        relation.setCreatorUserId(requireText(userId, "操作人ID不能为空"));
        relation.setCreatorTime(now);
        requireSingle(relationMapper.insertRelation(relation), "创建文件关系失败");
        return relation;
    }

    private DmsWenjianZiyuanEntity requireCurrentResource(
            DmsWenjianBanbenJiesuanModel model, String expectedVersionId) throws DataException {
        DmsWenjianZiyuanEntity resource = resourceMapper.selectByIdForUpdate(
                model.getTenantId(), model.getWenjianId());
        if (resource == null || !EFFECTIVE.equals(resource.getBizStatus())) {
            throw new DataException("待处理文件不存在或不是有效文件");
        }
        if (!Objects.equals(resource.getDangqianBanbenId(), expectedVersionId)) {
            throw new DataException("来源文件版本已不是当前有效版本，请重新发起申请");
        }
        if (!blank(model.getWenjianLeixing())
                && !Objects.equals(resource.getWenjianLeixing(), model.getWenjianLeixing())) {
            throw new DataException("待处理文件类型与审核内容不一致");
        }
        return resource;
    }

    private DmsWenjianBanbenEntity buildVersion(DmsWenjianBanbenJiesuanModel model,
                                                 String fileId, String sourceVersionId,
                                                 int sequence, Date now) {
        DmsWenjianBanbenEntity version = new DmsWenjianBanbenEntity();
        version.setId(RandomUtil.uuId());
        version.setTenantId(model.getTenantId());
        version.setWenjianId(fileId);
        version.setWenjianMuluId(model.getWenjianMuluId());
        version.setShifouShoukong(model.getShifouShoukong());
        version.setJiluDengjiGuanliId(model.getJiluDengjiGuanliId());
        version.setJiluDengjiGuanliBanben(model.getJiluDengjiGuanliBanben());
        version.setWenjianLeixing(model.getWenjianLeixing());
        version.setJiluLeixing(model.getJiluLeixing());
        version.setDengji(model.getDengji());
        version.setYuanWenjianBanbenId(sourceVersionId);
        version.setBanbenXuhao(sequence);
        if (model.getCenterVersionLabel() != null
                && !"wailai_wenjian_xinzeng_shenhe".equals(model.getLaiyuanDanjuLeixing())
                && !formatVersion(sequence).equals(model.getCenterVersionLabel()))
            throw new DataException("中心版本号与批准业务版本序号不一致");
        version.setBanbenhao(model.getCenterVersionLabel() == null ? formatVersion(sequence) : model.getCenterVersionLabel());
        version.setWenjianZhongxinBanbenId(model.getCenterVersionId());
        version.setWenjianNeirong(model.getWenjianNeirong().trim());
        version.setLaiyuanDanjuLeixing(model.getLaiyuanDanjuLeixing());
        version.setLaiyuanDanjuId(model.getLaiyuanDanjuId());
        version.setLaiyuanZixiangId(trimToNull(model.getLaiyuanZixiangId()));
        version.setLaiyuanYewuJian(model.getLaiyuanYewuJian());
        version.setShengxiaoShijian(model.getEffectiveAt() == null ? now : model.getEffectiveAt());
        version.setWenjianBianhaoId(model.getWenjianBianhaoId());
        version.setWenjianBianhao(model.getWenjianBianhao());
        version.setWenjianMingcheng(model.getWenjianMingcheng());
        version.setGuishuBumenId(model.getGuishuBumenId());
        version.setBianhaoShiyongRenId(model.getBianhaoShiyongRenId());
        version.setZhidingRenId(model.getZhidingRenId());
        version.setZhidingrenBumenId(model.getZhidingrenBumenId());
        version.setZhidingRiqi(model.getZhidingRiqi());
        version.setWenjianFenlei(model.getWenjianFenlei());
        version.setWenjianDuixiangId(model.getWenjianDuixiangId());
        version.setShenheLiuchengId(model.getShenheLiuchengId());
        version.setShenheLiuchengRenwuId(model.getShenheLiuchengRenwuId());
        version.setWenjianZhongxinWenjianId(model.getCenterDocumentId());
        version.setYouxiaoQiZhi(model.getEffectiveTo());
        if (model.getEffectiveAt() != null) {
            version.setYouxiaoqiFangshi(model.getEffectiveTo() == null ? "changqi" : "guding_riqi");
            version.setShengxiaoNianxian(null);
        }
        version.setBizStatus(EFFECTIVE);
        version.setCreatorUserId(model.getUserId());
        version.setCreatorTime(now);
        return version;
    }

    private void applyProjectionMetadata(DmsWenjianZiyuanEntity resource, DmsWenjianBanbenJiesuanModel model) {
        resource.setBianhaoShiyongRenId(model.getBianhaoShiyongRenId());
        resource.setZhidingRenId(model.getZhidingRenId());
        resource.setZhidingrenBumenId(model.getZhidingrenBumenId());
        resource.setZhidingRiqi(model.getZhidingRiqi());
        resource.setWenjianFenlei(model.getWenjianFenlei());
        resource.setWenjianDuixiangId(model.getWenjianDuixiangId());
        resource.setShenheLiuchengId(model.getShenheLiuchengId());
        resource.setShenheLiuchengRenwuId(model.getShenheLiuchengRenwuId());
        resource.setLaiyuanDanjuLeixing(model.getLaiyuanDanjuLeixing());
        resource.setLaiyuanDanjuId(model.getLaiyuanDanjuId());
        resource.setLaiyuanZixiangId(model.getLaiyuanZixiangId());
        resource.setWenjianZhongxinBanbenId(model.getCenterVersionId());
    }

    private void applyCenterValidity(DmsWenjianZiyuanEntity resource, DmsWenjianBanbenJiesuanModel model) {
        resource.setYouxiaoQiZhi(model.getEffectiveTo());
        if (model.getEffectiveAt() != null) {
            resource.setShengxiaoShijian(model.getEffectiveAt());
            // The center returns an explicit expiry boundary, never an inferred year duration.
            resource.setYouxiaoqiFangshi(model.getEffectiveTo() == null ? "changqi" : "guding_riqi");
            resource.setShengxiaoNianxian(null);
        }
    }

    private void validateCommon(DmsWenjianBanbenJiesuanModel model) throws DataException {
        if (model == null) {
            throw new DataException("文件版本结算参数不能为空");
        }
        requireText(model.getTenantId(), "租户ID不能为空");
        requireText(model.getWenjianNeirong(), "文件内容不能为空");
        requireText(model.getWenjianMuluId(), "文件目录不能为空，请在表单中选择有效来源");
        if (RECORD_FILE.equals(model.getWenjianLeixing())) {
            // This service only settles new/revision audits, whose control flag is selected directly.
            if (!"yes".equals(model.getShifouShoukong()) && !"no".equals(model.getShifouShoukong())) {
                throw new DataException("记录是否受控快照缺失或无效，请完善表单");
            }
        }
        requireText(model.getLaiyuanDanjuLeixing(), "来源单据类型不能为空");
        if (!"xinzeng_shenhe".equals(model.getLaiyuanDanjuLeixing())
                && !"xiuding_shenhe".equals(model.getLaiyuanDanjuLeixing())
                && !"wailai_wenjian_xinzeng_shenhe".equals(model.getLaiyuanDanjuLeixing())) {
            throw new DataException("来源单据类型无效");
        }
        requireText(model.getLaiyuanDanjuId(), "来源审核单ID不能为空");
        requireText(model.getLaiyuanYewuJian(), "来源业务键不能为空");
        requireText(model.getUserId(), "操作人ID不能为空");
    }

    private void validateInitial(DmsWenjianBanbenJiesuanModel model) throws DataException {
        boolean externalSource = "wailai_wenjian_xinzeng_shenhe".equals(model.getLaiyuanDanjuLeixing());
        if (externalSource != EXTERNAL_FILE.equals(model.getWenjianLeixing())
                || (!externalSource && !MAIN_FILE.equals(model.getWenjianLeixing())
                    && !RECORD_FILE.equals(model.getWenjianLeixing()))) {
            throw new DataException("文件类型无效");
        }
        requireText(model.getWenjianBianhao(), "文件编号不能为空");
        requireText(model.getWenjianMingcheng(), "文件名称不能为空");
        if (MAIN_FILE.equals(model.getWenjianLeixing())) {
            requireText(model.getWenjianBianhaoId(), "主文件编号申请明细ID不能为空");
        } else if (RECORD_FILE.equals(model.getWenjianLeixing())) {
            requireText(model.getJiluLeixing(), "记录类型不能为空");
            requireText(model.getDengji(), "记录等级不能为空");
        }
        if (!blank(model.getYuanWenjianBanbenId())) {
            throw new DataException("初始版本不能包含来源版本ID");
        }
    }

    private void validateRepeated(DmsWenjianBanbenEntity repeated,
                                  DmsWenjianBanbenJiesuanModel model,
                                  String sourceVersionId) throws DataException {
        if ((!blank(model.getWenjianId()) && !Objects.equals(repeated.getWenjianId(), model.getWenjianId()))
                || !Objects.equals(repeated.getYuanWenjianBanbenId(), sourceVersionId)
                || !Objects.equals(repeated.getWenjianNeirong(), model.getWenjianNeirong().trim())
                || !Objects.equals(repeated.getWenjianMuluId(), model.getWenjianMuluId())
                || !Objects.equals(repeated.getShifouShoukong(), model.getShifouShoukong())
                || !Objects.equals(repeated.getJiluDengjiGuanliId(), model.getJiluDengjiGuanliId())
                || !Objects.equals(repeated.getJiluDengjiGuanliBanben(), model.getJiluDengjiGuanliBanben())
                || !Objects.equals(repeated.getWenjianLeixing(), model.getWenjianLeixing())
                || !Objects.equals(repeated.getJiluLeixing(), model.getJiluLeixing())
                || !Objects.equals(repeated.getDengji(), model.getDengji())) {
            throw new DataException("来源业务键对应的文件版本与本次结算内容不一致");
        }
    }

    private void applyMetadata(DmsWenjianZiyuanEntity resource,
                               DmsWenjianBanbenJiesuanModel model) {
        resource.setWenjianMuluId(model.getWenjianMuluId());
        resource.setShifouShoukong(model.getShifouShoukong());
        resource.setJiluDengjiGuanliId(model.getJiluDengjiGuanliId());
        resource.setJiluDengjiGuanliBanben(model.getJiluDengjiGuanliBanben());
        if (!blank(model.getWenjianMingcheng())) {
            resource.setWenjianMingcheng(model.getWenjianMingcheng().trim());
        }
        if (!blank(model.getJiluLeixing())) {
            resource.setJiluLeixing(model.getJiluLeixing().trim());
        }
        if (!blank(model.getDengji())) {
            resource.setDengji(model.getDengji().trim());
        }
        if (!blank(model.getGuishuBumenId())) {
            resource.setGuishuBumenId(model.getGuishuBumenId().trim());
        }
    }

    public static String formatVersion(int sequence) {
        return String.format("D(%02d)", sequence);
    }

    private String requireText(String value, String message) throws DataException {
        if (blank(value)) {
            throw new DataException(message);
        }
        return value.trim();
    }

    private String trimToNull(String value) {
        return blank(value) ? null : value.trim();
    }

    private boolean blank(String value) {
        return value == null || value.trim().isEmpty();
    }

    private void requireSingle(int affected, String message) throws DataException {
        if (affected != 1) {
            throw new DataException(message);
        }
    }
}