package jnpf.dmsService;

import jnpf.base.ActionResult;
import jnpf.dmsEntity.storage.approval.DmsApprovedItem;
import com.fasterxml.jackson.databind.ObjectMapper;
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
import jnpf.dmsEntity.storage.form.*;
import jnpf.dmsMapper.DmsApprovedBatchMapper;
import jnpf.exception.DataException;
import jnpf.file.FileContentApi;
import jnpf.model.filecontent.*;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

/** Business orchestration: physical API -> durable task receipt -> in-module center registration. */
@Service
@RequiredArgsConstructor
public class DmsApprovedContentService {
    private final FileContentApi files;
    private final DmsApprovedBatchMapper progress;
    private final DmsApprovedFileAcceptanceService acceptance;
    private final ObjectMapper json;

    public DmsApprovedBatch register(DmsApprovedBatch batch) {
        DmsApprovedRegistrationCallback result = new DmsApprovedRegistrationCallback();
        result.setTenantId(batch.getTenantId()); result.setBatchId(batch.getId());
        result.setAttemptToken(batch.getLeaseToken()); result.setSourceDigest(batch.getSourceDigest());
        for (DmsApprovedItem item : batch.getItems()) {
            if (!item.requiresContentRegistration()) continue;
            FileContentReceipt physical;
            try {
                if (item.getStorageReceipt() != null) {
                    physical = json.readValue(item.getStorageReceipt(), FileContentReceipt.class);
                } else {
                    FileContentImportForm request = new FileContentImportForm();
                    request.setRemoveDocxComments("xinzeng_shenhe".equals(batch.getAuditType())
                            || "xiuding_shenhe".equals(batch.getAuditType()));
                    request.setDocumentId(item.getDocumentId()); request.setFileVersionId(item.getFileVersionId());
                    request.setFileJson(item.getFileJson()); request.setFileName(item.getDocumentName());
                    request.setSignaturePageId(item.getQianpiyeId());
                    request.setSignaturePageFiles(approvalPageFiles(item));
                    request.setSignaturePageValues(item.getApprovalValuesByTag());
                    request.setApprovalFlowVersionId(item.getApprovalFlowVersionId());
                    ActionResult<FileContentReceipt> response = files.importContent("jnpf-dms", request);
                    if (response == null || !Integer.valueOf(200).equals(response.getCode()) || response.getData() == null)
                        throw new DataException(response == null ? "物理存储接口无响应" : response.getMsg());
                    physical = response.getData();
                    requireReceipt(physical);
                    String serialized = json.writeValueAsString(physical);
                    if (progress.storePhysicalReceipt(batch.getTenantId(), batch.getId(), item.getSourceKey(),
                            batch.getLeaseToken(), serialized) != 1)
                        throw new DataException("物理存储结果未写入当前任务租约，停止中心登记");
                    item.setStorageReceipt(serialized);
                }
            } catch (java.io.IOException e) { throw new DataException("物理存储回执解析失败"); }
            requireReceipt(physical);
            DmsApprovedRegistrationCallback.StoredFile stored = new DmsApprovedRegistrationCallback.StoredFile();
            stored.setSourceKey(item.getSourceKey()); stored.setFileJson(item.getFileJson());
            DmsFileUploadRegisterForm content = new DmsFileUploadRegisterForm();
            BeanUtils.copyProperties(physical, content);
            content.setDocumentId(item.getDocumentId()); content.setFileVersionId(item.getFileVersionId());
            stored.setContent(content); result.getFiles().add(stored);
        }
        return acceptance.acceptStoredContent(result);
    }

    private String approvalPageFiles(DmsApprovedItem item) {
        if (item.getQianpiyeFiles() != null && !item.getQianpiyeFiles().isBlank()) {
            return item.getQianpiyeFiles();
        }
        return item.getApprovalPageFileJson();
    }

    private void requireReceipt(FileContentReceipt value) {
        if (value == null || value.getFileObjectId() == null || value.getChecksumSha256() == null
                || !value.getChecksumSha256().matches("[0-9a-fA-F]{64}")
                || value.getSizeBytes() == null || value.getSizeBytes() <= 0
                || value.getStoragePlatform() == null || value.getStoragePlatform().isBlank()
                || value.getBucketName() == null || value.getBucketName().isBlank()
                || value.getObjectPath() == null || value.getObjectPath().isBlank()
                || value.getObjectName() == null || value.getObjectName().isBlank())
            throw new DataException("物理存储回执不完整，不能登记中心文件");
    }
}