package jnpf.dmsService;

import jnpf.base.UserInfo;
import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
import jnpf.dmsEntity.permission.entity.DmsPermissionResourceEntity;
import jnpf.dmsEntity.permission.enums.DmsPermissionAction;
import jnpf.dmsEntity.permission.enums.DmsResourceType;
import jnpf.dmsEntity.storage.entity.DmsFileObjectEntity;
import jnpf.dmsEntity.storage.form.DmsFileRevisionRegisterForm;
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
import jnpf.dmsIntegration.audit.DmsAuditAdapter;
import jnpf.dmsIntegration.audit.DmsAuditRequestSignResolver;
import jnpf.dmsIntegration.audit.DmsFileAuditEvent;
import jnpf.dmsIntegration.audit.DmsFileAuditSnapshot;
import jnpf.dmsIntegration.audit.DmsFileVersionAuditSnapshot;
import jnpf.dmsIntegration.audit.DmsVersionStateAuditRow;
import jnpf.dmsMapper.DmsDocumentMapper;
import jnpf.dmsMapper.DmsFolderMapper;
import jnpf.dmsMapper.DmsFileObjectMapper;
import jnpf.dmsMapper.DmsFileVersionMapper;
import jnpf.dmsMapper.DmsPermissionResourceMapper;
import jnpf.dmsMapper.DmsVersionStateMapper;
import jnpf.dmsPermission.DmsCurrentIdentity;
import jnpf.dmsPermission.DmsPermissionError;
import jnpf.dmsPermission.DmsPermissionException;
import jnpf.dmsService.search.DmsSearchIndexJobService;
import jnpf.dmsService.pdf.DmsPdfGenerationTaskService;
import lombok.RequiredArgsConstructor;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Locale;
import java.util.Objects;

@Service
@RequiredArgsConstructor
public class DmsFileRevisionService {
    private final DmsVersionPropertiesService versionProperties;
    private static final String SOURCE_PREFIX = "revision:";

    private final DmsCurrentIdentity currentIdentity;
    private final DmsPermissionDecisionService decisionService;
    private final DmsDocumentMapper documentMapper;
    private final DmsFolderMapper folderMapper;
    private final DmsFileVersionMapper fileVersionMapper;
    private final DmsPermissionResourceMapper resourceMapper;
    private final DmsFileObjectMapper fileObjectMapper;
    private final DmsVersionStateMapper versionStateMapper;
    private final DmsAuditAdapter auditAdapter;
    private final DmsFileOperationLogService operationLogService;
    private final DmsSearchIndexJobService searchIndexJobService;
    private final DmsPdfGenerationTaskService pdfGenerationTaskService;
    private final DmsBusinessLifecycleGuard businessOccupancy;

    @Transactional
    public DmsFileUploadVO register(DmsFileRevisionRegisterForm form, String serviceId) {
        return register(form, serviceId, false, null, null);
    }

    @Transactional
    public DmsFileUploadVO registerWorkflowPending(DmsFileRevisionRegisterForm form, String serviceId,
                                                   String flowId, String taskId) {
        return register(form, serviceId, true, flowId, taskId);
    }

    /** Java-only entry: caller has locked and verified the complete approved batch. */
    @Transactional
    public DmsFileUploadVO registerApproved(DmsFileRevisionRegisterForm form, String serviceId,
                                            String flowId, String taskId, UserInfo actor) {
        if (!"jnpf-file".equals(serviceId) || actor == null || actor.getUserId() == null
                || actor.getTenantId() == null || flowId == null || taskId == null)
            throw new jnpf.exception.DataException("批准登记缺少可信来源");
        return register(form, serviceId, true, flowId, taskId, actor);
    }

    private DmsFileUploadVO register(DmsFileRevisionRegisterForm form, String serviceId,
                                     boolean workflowPending, String flowId, String taskId) {
        return register(form, serviceId, workflowPending, flowId, taskId, null);
    }

    private DmsFileUploadVO register(DmsFileRevisionRegisterForm form, String serviceId,
                                     boolean workflowPending, String flowId, String taskId, UserInfo approvedActor) {
        UserInfo user = approvedActor == null ? currentIdentity.requireUser() : approvedActor;
        String tenantId = currentIdentity.tenantId(user);
        String sourceId = form.getSourceId().trim();
        if (approvedActor == null) decisionService.requireAllowed(DmsResourceType.DOCUMENT, form.getDocumentId(),
                DmsPermissionAction.UPDATE);
        if (approvedActor == null) businessOccupancy.guardStandaloneActivation(tenantId,form.getBaseFileVersionId());

        fileObjectMapper.lockSource(tenantId, serviceId, sourceId);
        DmsFileUploadVO existing = fileObjectMapper.selectUploadBySource(tenantId, serviceId, sourceId);
        if (existing != null) {
            versionProperties.verifyRetry(tenantId, existing.getFileVersionId(), form.getExtendedProperties());
            validateRetry(existing, form, retryControlFlag(tenantId, form, approvedActor != null));
            pdfGenerationTaskService.enqueueEligible(tenantId, form.getFileVersionId(),
                    form.getFileName(), form.getChecksumSha256());
            if (!workflowPending) {
                searchIndexJobService.enqueueContentUpsert(tenantId, existing.getDocumentId(),
                        existing.getFileVersionId(), existing.getChecksumSha256());
            }
            operationLogService.recordRevision(user, tenantId, existing.getDocumentId(),
                    existing.getFileVersionId(), existing.getFileName(), serviceId, sourceId);
            return existing;
        }

        DmsDocumentEntity document = documentMapper.selectByTenantAndIdForUpdate(tenantId,
                form.getDocumentId());
        if (document == null) {
            throw DmsPermissionException.of(DmsPermissionError.RESOURCE_NOT_FOUND, "待修订文件不存在");
        }
        DmsFileVersionEntity current = fileVersionMapper.selectCurrentEffective(tenantId,
                form.getDocumentId());
        if (current == null || !Objects.equals(current.getId(), form.getBaseFileVersionId())) {
            throw DmsPermissionException.of(DmsPermissionError.REVISION_CONFLICT,
                    "待修订版本已不是现行有效版本，请刷新后重试");
        }
        DmsVersionStateAuditRow currentState = versionStateMapper.selectAuditState(
                tenantId, current.getId());
        String folderPath = folderMapper.selectPath(tenantId, document.getFolderId());
        DmsFileAuditSnapshot before = snapshot(document, current, currentState, folderPath);

        long nextVersionNo = fileVersionMapper.selectNextVersionNo(tenantId, form.getDocumentId());
        try {
            DmsFileVersionEntity newVersion = insertFileVersion(form, tenantId, user.getUserId(), nextVersionNo,
                    approvedActor == null
                            ? inheritedControlFlag(current.getShifouShoukong())
                            : requireApprovedControlFlag(form.getShifouShoukong()));
            insertRegistry(form, tenantId, serviceId, sourceId);
            insertFileObject(form, tenantId, user.getUserId(), serviceId, sourceId);
            pdfGenerationTaskService.enqueueEligible(tenantId, form.getFileVersionId(),
                    form.getFileName(), form.getChecksumSha256());
            if (workflowPending) {
                versionStateMapper.insertWorkflowPending(tenantId, form.getDocumentId(),
                        form.getFileVersionId(), SOURCE_PREFIX + form.getBaseFileVersionId() + ":" + sourceId,
                        flowId, taskId, "REVISE", user.getUserId());
            } else {
                int superseded = versionStateMapper.supersedeCurrent(tenantId, form.getDocumentId(),
                        form.getBaseFileVersionId(), form.getVersionLabel().trim(), user.getUserId());
                if (superseded != 1) {
                    throw DmsPermissionException.of(DmsPermissionError.REVISION_CONFLICT,
                            "现行有效版本已发生变化，请刷新后重试");
                }
                versionStateMapper.insertRevisionEffective(tenantId, form.getDocumentId(),
                        form.getBaseFileVersionId(), form.getFileVersionId(), sourceId,
                        form.getRevisionReason().trim(), user.getUserId());
                searchIndexJobService.enqueueContentUpsert(tenantId, form.getDocumentId(),
                        form.getFileVersionId(), form.getChecksumSha256());
            }
            DmsVersionStateAuditRow previousAfter = versionStateMapper.selectAuditState(
                    tenantId, current.getId());
            DmsVersionStateAuditRow newState = versionStateMapper.selectAuditState(
                    tenantId, newVersion.getId());
            auditAdapter.fileChange(DmsFileAuditEvent.builder()
                    .documentId(form.getDocumentId())
                    .actionCode("UPDATE")
                    .actionLabel(workflowPending ? "暂存待审批 DMS 修订" : "修订 DMS 文件")
                    .before(before)
                    .after(snapshot(document, newVersion, newState, folderPath))
                    .previousVersionAfter(versionSnapshot(current, previousAfter,
                            workflowPending ? "EFFECTIVE" : "SUPERSEDED"))
                    .reason(form.getRevisionReason().trim())
                    .sourceServiceId(serviceId)
                    .sourceId(sourceId)
                    .relatedSigns(DmsAuditRequestSignResolver.resolve(form.getAuditSignParameters()))
                    .build());
        } catch (DuplicateKeyException exception) {
            throw conflict("修订登记的资源 ID、source_id、版本号、版本标签或对象键已被占用", exception);
        }

        operationLogService.recordRevision(user, tenantId, form.getDocumentId(),
                form.getFileVersionId(), form.getFileName(), serviceId, sourceId);
        return fileObjectMapper.selectUploadBySource(tenantId, serviceId, sourceId);
    }

    private DmsFileVersionEntity insertFileVersion(DmsFileRevisionRegisterForm form, String tenantId,
                                                   String userId, long versionNo, String shifouShoukong) {
        DmsFileVersionEntity version = new DmsFileVersionEntity();
        version.setId(form.getFileVersionId());
        version.setTenantId(tenantId);
        version.setDocumentId(form.getDocumentId());
        version.setVersionNo(versionNo);
        version.setVersionLabel(form.getVersionLabel().trim());
        version.setFileName(form.getFileName().trim());
        version.setMimeType(trimToNull(form.getMimeType()));
        version.setSizeBytes(form.getSizeBytes());
        version.setChecksumSha256(form.getChecksumSha256().toLowerCase(Locale.ROOT));
        version.setPreparedBy(form.getPreparedBy().trim());
        version.setPreparedOn(form.getPreparedOn());
        version.setShifouShoukong(shifouShoukong);
        version.setCreatedBy(userId);
        versionProperties.insertVersion(version, form.getExtendedProperties());
        return version;
    }

    private void insertRegistry(DmsFileRevisionRegisterForm form, String tenantId,
                                String serviceId, String sourceId) {
        DmsPermissionResourceEntity registry = new DmsPermissionResourceEntity();
        registry.setId(form.getFileVersionId());
        registry.setTenantId(tenantId);
        registry.setResourceType(DmsResourceType.FILE_VERSION.name());
        registry.setSourceType("SYSTEM");
        registry.setSourceId(SOURCE_PREFIX + sourceId + ":version");
        registry.setRegisteredBy(serviceId);
        resourceMapper.insert(registry);
    }

    private void insertFileObject(DmsFileRevisionRegisterForm form, String tenantId, String userId,
                                  String serviceId, String sourceId) {
        DmsFileObjectEntity object = new DmsFileObjectEntity();
        object.setId(form.getFileObjectId());
        object.setTenantId(tenantId);
        object.setFileVersionId(form.getFileVersionId());
        object.setStoragePlatform(form.getStoragePlatform().trim());
        object.setBucketName(form.getBucketName().trim());
        object.setBasePath(trimToEmpty(form.getBasePath()));
        object.setObjectPath(form.getObjectPath().trim());
        object.setObjectName(form.getObjectName().trim());
        object.setSourceServiceId(serviceId);
        object.setSourceId(sourceId);
        object.setCreatedBy(userId);
        fileObjectMapper.insert(object);
    }

    private void validateRetry(DmsFileUploadVO existing, DmsFileRevisionRegisterForm form,
                               String shifouShoukong) {
        if (!Objects.equals(existing.getDocumentId(), form.getDocumentId())
                || !Objects.equals(existing.getBaseFileVersionId(), form.getBaseFileVersionId())
                || !Objects.equals(existing.getVersionLabel(), form.getVersionLabel().trim())
                || !Objects.equals(existing.getFileName(), form.getFileName().trim())
                || !Objects.equals(existing.getMimeType(), trimToNull(form.getMimeType()))
                || !Objects.equals(existing.getSizeBytes(), form.getSizeBytes())
                || !equalsIgnoreCase(existing.getChecksumSha256(), form.getChecksumSha256())
                || !Objects.equals(existing.getPreparedBy(), form.getPreparedBy().trim())
                || !Objects.equals(existing.getPreparedOn(), form.getPreparedOn())
                || !Objects.equals(existing.getShifouShoukong(), shifouShoukong)
                || !Objects.equals(existing.getRevisionReason(), form.getRevisionReason().trim())) {
            throw DmsPermissionException.of(DmsPermissionError.IDEMPOTENCY_CONFLICT,
                    "source_id 对应的修订内容与本次请求不一致");
        }
    }

    private String trimToNull(String value) {
        return value == null || value.trim().isEmpty() ? null : value.trim();
    }

    private String trimToEmpty(String value) {
        return value == null ? "" : value.trim();
    }

    private String retryControlFlag(String tenantId, DmsFileRevisionRegisterForm form, boolean approved) {
        if (approved) return requireApprovedControlFlag(form.getShifouShoukong());
        DmsFileVersionEntity base = fileVersionMapper.selectByTenantAndId(tenantId,
                form.getBaseFileVersionId());
        if (base == null || !Objects.equals(base.getDocumentId(), form.getDocumentId())) {
            throw DmsPermissionException.of(DmsPermissionError.REVISION_CONFLICT,
                    "修订基准版本不存在或不属于目标文件");
        }
        return inheritedControlFlag(base.getShifouShoukong());
    }

    private String inheritedControlFlag(String inherited) {
        return "no".equals(inherited) ? "no" : "yes";
    }

    private String requireApprovedControlFlag(String value) {
        if ("yes".equals(value) || "no".equals(value)) return value;
        throw new jnpf.exception.DataException("批准文件受控属性必须为 yes 或 no");
    }

    private boolean equalsIgnoreCase(String left, String right) {
        return left == null ? right == null : right != null && left.equalsIgnoreCase(right);
    }

    private DmsFileAuditSnapshot snapshot(DmsDocumentEntity document, DmsFileVersionEntity version,
                                          DmsVersionStateAuditRow state, String folderPath) {
        return DmsFileAuditSnapshot.builder()
                .documentId(document.getId())
                .documentNo(document.getDocumentNo())
                .documentName(document.getName())
                .documentType(document.getDocumentType())
                .folderId(document.getFolderId())
                .folderPath(folderPath)
                .responsibleDeptId(document.getResponsibleDeptId())
                .currentVersion(versionSnapshot(version, state, "EFFECTIVE"))
                .build();
    }

    private DmsFileVersionAuditSnapshot versionSnapshot(DmsFileVersionEntity version,
                                                        DmsVersionStateAuditRow state,
                                                        String fallbackStatus) {
        return DmsFileVersionAuditSnapshot.builder()
                .fileVersionId(version.getId())
                .versionNo(version.getVersionNo())
                .versionLabel(version.getVersionLabel())
                .fileName(version.getFileName())
                .mimeType(version.getMimeType())
                .sizeBytes(version.getSizeBytes())
                .checksumSha256(version.getChecksumSha256())
                .preparedBy(version.getPreparedBy())
                .preparedOn(version.getPreparedOn())
                .lifecycleStatus(state == null ? fallbackStatus : state.getLifecycleStatus())
                .effectiveFrom(state == null ? null : state.getEffectiveFrom())
                .effectiveTo(state == null ? null : state.getEffectiveTo())
                .statusReason(state == null ? null : state.getStatusReason())
                .build();
    }

    private DmsPermissionException conflict(String message, Throwable cause) {
        DmsPermissionException exception = DmsPermissionException.of(DmsPermissionError.SOURCE_CONFLICT, message);
        exception.initCause(cause);
        return exception;
    }
}