package jnpf.dmsService;
|
|
import jnpf.dmsEntity.center.DmsCenterVersionSnapshot;
|
import jnpf.dmsEntity.banben.DmsWenjianBanbenJiesuanModel;
|
import jnpf.dmsEntity.storage.approval.DmsApprovedItem;
|
import jnpf.dmsMapper.DmsApprovedBatchMapper;
|
import jnpf.dmsMapper.DmsApprovedMetadataMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
@RequiredArgsConstructor
|
public class DmsApprovedFileProjection {
|
private final DmsApprovedBatchMapper receipts;
|
private final jnpf.dmsService.center.DmsCenterQueryService center;
|
private final DmsApprovedMetadataMapper metadata;
|
|
public void enrich(DmsWenjianBanbenJiesuanModel model) {
|
DmsApprovedItem item = receipts.item(model.getTenantId(), model.getLaiyuanYewuJian());
|
if (item == null) throw new DataException("未找到完整的批准文件接收回执");
|
DmsCenterVersionSnapshot version = center.version(model.getTenantId(), item.getFileVersionId());
|
if (version == null || !"EFFECTIVE".equals(version.lifecycleStatus()) || version.effectiveFrom() == null)
|
throw new DataException("文件中心版本尚未生效，不能回写正式业务版本");
|
if (!item.getDocumentId().equals(version.documentId()))
|
throw new DataException("批准回执与中心版本所属文件不一致");
|
DmsWenjianBanbenJiesuanModel source = metadata.selectSource(model.getTenantId(),
|
model.getLaiyuanDanjuLeixing(), model.getLaiyuanDanjuId(), model.getLaiyuanZixiangId());
|
if (source == null || version.fileObjectId() == null)
|
throw new DataException("批准文件缺少原生来源或正式文件对象，不能回写资源");
|
if (!"yes".equals(item.getShifouShoukong()) && !"no".equals(item.getShifouShoukong()))
|
throw new DataException("推送任务缺少是否受控快照，不能回写资源");
|
if ((item.getSourceKey().endsWith(":zhuwenjian")
|
|| item.getSourceKey().endsWith(":wailaiWenjian")) && !"yes".equals(item.getShifouShoukong()))
|
throw new DataException("主文件推送任务的是否受控必须为yes");
|
model.setShifouShoukong(item.getShifouShoukong());
|
model.setBianhaoShiyongRenId(source.getBianhaoShiyongRenId());
|
model.setZhidingrenBumenId(source.getZhidingrenBumenId());
|
model.setShenheLiuchengId(source.getShenheLiuchengId());
|
model.setShenheLiuchengRenwuId(source.getShenheLiuchengRenwuId());
|
model.setWenjianDuixiangId(version.fileObjectId().toString());
|
model.setZhidingRenId(version.preparedBy());
|
model.setZhidingRiqi(version.preparedOn() == null ? null : java.sql.Date.valueOf(version.preparedOn()));
|
model.setCenterDocumentId(item.getDocumentId().toString());
|
model.setCenterVersionId(item.getFileVersionId().toString());
|
model.setCenterVersionLabel(version.versionLabel());
|
model.setEffectiveAt(version.effectiveFrom());
|
model.setEffectiveTo(version.effectiveTo());
|
}
|
}
|
