package jnpf.fileStorage.dms;

import jnpf.base.ActionResult;
import jnpf.base.ActionResultCode;
import jnpf.config.ConfigValueUtil;
import jnpf.constant.MsgCode;
import jnpf.dms.DmsResourceApi;
import jnpf.dmsEntity.storage.form.DmsFileRevisionRegisterForm;
import jnpf.dmsEntity.storage.form.DmsFileUploadRegisterForm;
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
import jnpf.exception.DataException;
import jnpf.util.OptimizeUtil;
import jnpf.util.StringUtil;
import jnpf.util.UpUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.x.file.storage.core.FileInfo;
import org.dromara.x.file.storage.core.FileStorageService;
import org.dromara.x.file.storage.core.hash.HashInfo;
import org.dromara.x.file.storage.core.platform.MinioFileStorage;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.nio.file.Paths;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Objects;
import java.util.Locale;
import java.util.Map;
import java.util.UUID;

@Slf4j
@Service
@RequiredArgsConstructor
public class DmsFileStorageService {
    static final String STORAGE_PLATFORM = "seaweedfs-1";
    static final String SERVICE_ID = "jnpf-file";

    private final FileStorageService fileStorageService;
    private final DmsResourceApi dmsResourceApi;
    private final ConfigValueUtil configValueUtil;

    @jnpf.audit.sdk.annotation.AuditLog(action = "DMS_WORKFLOW_CONTENT_STORE", bizCodeExpr = "''")
    public DmsFileUploadRegisterForm storeWorkflowContent(UUID documentId, UUID fileVersionId, MultipartFile file) {
        UUID fileObjectId = UuidV7Generator.generate();
        String originalFilename = safeFilename(file.getOriginalFilename());
        String extension = UpUtil.getFileType(file);
        if (file.isEmpty() || !OptimizeUtil.fileType(configValueUtil.getAllowUploadFileType(), extension)) {
            throw new DataException("批准文件为空或类型不允许");
        }
        FileInfo stored = fileStorageService.of(file).setPlatform(STORAGE_PLATFORM)
                .setPath(objectPath(documentId))
                // Repeated delivery must never overwrite bytes already registered for this version.
                .setSaveFilename(fileObjectId + (StringUtil.isEmpty(extension) ? "" : "." + extension))
                .setOriginalFilename(originalFilename).setHashCalculatorSha256().upload();
        if (stored == null || stored.getHashInfo() == null || StringUtil.isEmpty(stored.getHashInfo().getSha256())) {
            deleteQuietly(stored);
            throw new DataException("SeaweedFS 上传失败或未生成 SHA-256");
        }
        MinioFileStorage storage = fileStorageService.getFileStorage(STORAGE_PLATFORM);
        DmsFileUploadRegisterForm result = new DmsFileUploadRegisterForm();
        result.setDocumentId(documentId);
        result.setFileVersionId(fileVersionId);
        result.setFileObjectId(fileObjectId);
        result.setFileName(originalFilename);
        result.setDocumentType(StringUtil.isEmpty(extension) ? "FILE" : extension.toUpperCase(Locale.ROOT));
        result.setMimeType(trimToNull(stored.getContentType()));
        result.setSizeBytes(stored.getSize());
        result.setChecksumSha256(stored.getHashInfo().getSha256());
        result.setStoragePlatform(stored.getPlatform());
        result.setBucketName(storage.getBucketName());
        result.setBasePath(trimToEmpty(stored.getBasePath()));
        result.setObjectPath(stored.getPath());
        result.setObjectName(stored.getFilename());
        return result;
    }

    public DmsFileUploadVO upload(UUID folderId, String sourceId, String documentNo,
                                  String documentName, String documentType,
                                  String responsibleDeptId, String versionLabel,
                                  String preparedBy, LocalDate preparedOn,
                                  Map<String, Object> auditSignParameters, String auditBizSign,
                                  MultipartFile file) {
        validate(sourceId, documentNo, documentName, documentType, responsibleDeptId,
                versionLabel, preparedBy, preparedOn, file);
        String originalFilename = safeFilename(file.getOriginalFilename());
        String extension = UpUtil.getFileType(file);
        if (!OptimizeUtil.fileType(configValueUtil.getAllowUploadFileType(), extension)) {
            throw new DataException(MsgCode.FA017.get());
        }

        UUID documentId = UuidV7Generator.generate();
        UUID fileVersionId = UuidV7Generator.generate();
        UUID fileObjectId = UuidV7Generator.generate();
        String objectPath = objectPath(documentId);
        String objectName = fileVersionId + (StringUtil.isEmpty(extension) ? "" : "." + extension);

        FileInfo stored = fileStorageService.of(file)
                .setPlatform(STORAGE_PLATFORM)
                .setPath(objectPath)
                .setSaveFilename(objectName)
                .setOriginalFilename(originalFilename)
                .setHashCalculatorSha256()
                .upload();
        if (stored == null || stored.getHashInfo() == null
                || StringUtil.isEmpty(stored.getHashInfo().getSha256())) {
            deleteQuietly(stored);
            throw new DataException("SeaweedFS 上传失败或未生成 SHA-256");
        }

        DmsFileUploadRegisterForm form = registration(folderId, sourceId, documentNo,
                documentName, documentType, responsibleDeptId, versionLabel, preparedBy,
                preparedOn, originalFilename, documentId, fileVersionId, fileObjectId,
                auditSignParameters, stored);
        try {
            ActionResult<DmsFileUploadVO> result = dmsResourceApi.registerUpload(SERVICE_ID, auditBizSign, form);
            requireRegistrationResult(result, stored);
            if (!sameStoredObject(result.getData(), stored)) {
                deleteQuietly(stored);
            }
            return result.getData();
        } catch (RuntimeException exception) {
            logRegistrationFailure(stored, sourceId, exception);
            throw exception;
        }
    }

    public DmsFileUploadVO revise(UUID documentId, UUID baseFileVersionId, String sourceId,
                                  String versionLabel, String preparedBy, LocalDate preparedOn,
                                  String revisionReason, Map<String, Object> auditSignParameters,
                                  String auditBizSign, MultipartFile file) {
        validateRevision(documentId, baseFileVersionId, sourceId, versionLabel, preparedBy,
                preparedOn, revisionReason, file);
        String originalFilename = safeFilename(file.getOriginalFilename());
        String extension = UpUtil.getFileType(file);
        if (!OptimizeUtil.fileType(configValueUtil.getAllowUploadFileType(), extension)) {
            throw new DataException(MsgCode.FA017.get());
        }

        UUID fileVersionId = UuidV7Generator.generate();
        UUID fileObjectId = UuidV7Generator.generate();
        String objectPath = objectPath(documentId);
        String objectName = fileVersionId + (StringUtil.isEmpty(extension) ? "" : "." + extension);

        FileInfo stored = fileStorageService.of(file)
                .setPlatform(STORAGE_PLATFORM)
                .setPath(objectPath)
                .setSaveFilename(objectName)
                .setOriginalFilename(originalFilename)
                .setHashCalculatorSha256()
                .upload();
        if (stored == null || stored.getHashInfo() == null
                || StringUtil.isEmpty(stored.getHashInfo().getSha256())) {
            deleteQuietly(stored);
            throw new DataException("SeaweedFS 上传失败或未生成 SHA-256");
        }

        DmsFileRevisionRegisterForm form = revisionRegistration(documentId, baseFileVersionId,
                fileVersionId, fileObjectId, sourceId, versionLabel, preparedBy, preparedOn,
                revisionReason, originalFilename, auditSignParameters, stored);
        try {
            ActionResult<DmsFileUploadVO> result = dmsResourceApi.registerRevision(SERVICE_ID, auditBizSign, form);
            requireRegistrationResult(result, stored);
            if (!sameStoredObject(result.getData(), stored)) {
                deleteQuietly(stored);
            }
            return result.getData();
        } catch (RuntimeException exception) {
            logRegistrationFailure(stored, sourceId, exception);
            throw exception;
        }
    }

    private void requireRegistrationResult(ActionResult<DmsFileUploadVO> result, FileInfo stored) {
        if (result == null || result.getCode() == null) {
            throw new DataException("DMS登记结果未知，保留上传对象，请使用原请求重试");
        }
        if (!ActionResultCode.SUCCESS.getCode().equals(result.getCode())) {
            // 只对明确的请求拒绝补偿；服务端错误、超时和缺失数据不能证明事务未提交。
            if (result.getCode() >= 400 && result.getCode() < 500) {
                deleteQuietly(stored);
            }
            throw new DataException(result.getMsg());
        }
        if (result.getData() == null) {
            throw new DataException("DMS登记响应缺少数据，保留上传对象，请使用原请求重试");
        }
    }

    private void logRegistrationFailure(FileInfo stored, String sourceId, RuntimeException exception) {
        log.error("DMS登记未正常返回，需要核对登记与对象状态: sourceId={}, platform={}, path={}, filename={}",
                sourceId, stored.getPlatform(), stored.getPath(), stored.getFilename(), exception);
    }

    private DmsFileUploadRegisterForm registration(UUID folderId, String sourceId,
                                                   String documentNo, String documentName,
                                                   String documentType, String responsibleDeptId,
                                                   String versionLabel, String preparedBy,
                                                   LocalDate preparedOn, String originalFilename,
                                                   UUID documentId,
                                                   UUID fileVersionId, UUID fileObjectId,
                                                   Map<String, Object> auditSignParameters,
                                                   FileInfo stored) {
        MinioFileStorage storage = fileStorageService.getFileStorage(STORAGE_PLATFORM);
        HashInfo hashInfo = stored.getHashInfo();
        DmsFileUploadRegisterForm form = new DmsFileUploadRegisterForm();
        form.setDocumentId(documentId);
        form.setFileVersionId(fileVersionId);
        form.setFileObjectId(fileObjectId);
        form.setFolderId(folderId);
        form.setDocumentNo(documentNo.trim());
        form.setDocumentName(documentName.trim());
        form.setDocumentType(documentType.trim());
        form.setResponsibleDeptId(responsibleDeptId.trim());
        form.setVersionLabel(versionLabel.trim());
        form.setFileName(originalFilename);
        form.setMimeType(trimToNull(stored.getContentType()));
        form.setSizeBytes(stored.getSize());
        form.setChecksumSha256(hashInfo.getSha256());
        form.setPreparedBy(preparedBy.trim());
        form.setPreparedOn(preparedOn);
        form.setStoragePlatform(stored.getPlatform());
        form.setBucketName(storage.getBucketName());
        form.setBasePath(trimToEmpty(stored.getBasePath()));
        form.setObjectPath(stored.getPath());
        form.setObjectName(stored.getFilename());
        form.setSourceId(sourceId.trim());
        form.setAuditSignParameters(auditSignParameters);
        return form;
    }

    private DmsFileRevisionRegisterForm revisionRegistration(UUID documentId,
                                                              UUID baseFileVersionId,
                                                              UUID fileVersionId,
                                                              UUID fileObjectId,
                                                              String sourceId,
                                                              String versionLabel,
                                                              String preparedBy,
                                                              LocalDate preparedOn,
                                                              String revisionReason,
                                                              String originalFilename,
                                                              Map<String, Object> auditSignParameters,
                                                              FileInfo stored) {
        MinioFileStorage storage = fileStorageService.getFileStorage(STORAGE_PLATFORM);
        HashInfo hashInfo = stored.getHashInfo();
        DmsFileRevisionRegisterForm form = new DmsFileRevisionRegisterForm();
        form.setDocumentId(documentId);
        form.setBaseFileVersionId(baseFileVersionId);
        form.setFileVersionId(fileVersionId);
        form.setFileObjectId(fileObjectId);
        form.setVersionLabel(versionLabel.trim());
        form.setFileName(originalFilename);
        form.setMimeType(trimToNull(stored.getContentType()));
        form.setSizeBytes(stored.getSize());
        form.setChecksumSha256(hashInfo.getSha256());
        form.setPreparedBy(preparedBy.trim());
        form.setPreparedOn(preparedOn);
        form.setRevisionReason(revisionReason.trim());
        form.setStoragePlatform(stored.getPlatform());
        form.setBucketName(storage.getBucketName());
        form.setBasePath(trimToEmpty(stored.getBasePath()));
        form.setObjectPath(stored.getPath());
        form.setObjectName(stored.getFilename());
        form.setSourceId(sourceId.trim());
        form.setAuditSignParameters(auditSignParameters);
        return form;
    }

    private boolean sameStoredObject(DmsFileUploadVO registered, FileInfo stored) {
        return Objects.equals(registered.getStoragePlatform(), stored.getPlatform())
                && Objects.equals(registered.getBasePath(), trimToEmpty(stored.getBasePath()))
                && Objects.equals(registered.getObjectPath(), stored.getPath())
                && Objects.equals(registered.getObjectName(), stored.getFilename());
    }

    private String objectPath(UUID documentId) {
        return LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd/"))
                + documentId + "/";
    }

    private String safeFilename(String value) {
        if (value == null || value.trim().isEmpty()) {
            throw new DataException("文件名不能为空");
        }
        String normalized = value.replace('\\', '/');
        String filename = Paths.get(normalized).getFileName().toString().trim();
        if (filename.isEmpty() || filename.length() > 300) {
            throw new DataException("文件名长度必须在 1 到 300 之间");
        }
        return filename;
    }

    private void validate(String sourceId, String documentNo, String documentName,
                          String documentType, String responsibleDeptId, String versionLabel,
                          String preparedBy, LocalDate preparedOn, MultipartFile file) {
        if (file == null || file.isEmpty()) {
            throw new DataException("上传文件不能为空");
        }
        requireText(sourceId, "sourceId", 160);
        requireText(documentNo, "文件编号", 200);
        requireText(documentName, "文件名称", 300);
        requireText(documentType, "文件类型", 100);
        requireText(responsibleDeptId, "归属部门", 100);
        requireText(versionLabel, "版本号", 50);
        requireText(preparedBy, "制定人", 100);
        if (preparedOn == null) {
            throw new DataException("制定日期不能为空");
        }
        fileStorageService.getFileStorageVerify(STORAGE_PLATFORM);
    }

    private void validateRevision(UUID documentId, UUID baseFileVersionId, String sourceId,
                                  String versionLabel, String preparedBy, LocalDate preparedOn,
                                  String revisionReason, MultipartFile file) {
        if (documentId == null || baseFileVersionId == null) {
            throw new DataException("文件及当前版本不能为空");
        }
        if (file == null || file.isEmpty()) {
            throw new DataException("修订文件不能为空");
        }
        requireText(sourceId, "sourceId", 120);
        requireText(versionLabel, "新版本号", 50);
        requireText(preparedBy, "制定人", 100);
        requireText(revisionReason, "修订原因", 1000);
        if (preparedOn == null) {
            throw new DataException("制定日期不能为空");
        }
        fileStorageService.getFileStorageVerify(STORAGE_PLATFORM);
    }

    private void requireText(String value, String label, int maxLength) {
        if (value == null || value.trim().isEmpty() || value.trim().length() > maxLength) {
            throw new DataException(label + "长度必须在 1 到 " + maxLength + " 之间");
        }
    }

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

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

    private void deleteQuietly(FileInfo stored) {
        if (stored == null) {
            return;
        }
        try {
            if (!fileStorageService.delete(stored)) {
                log.error("DMS 上传补偿删除失败: platform={}, path={}, filename={}",
                        stored.getPlatform(), stored.getPath(), stored.getFilename());
            }
        } catch (Exception exception) {
            log.error("DMS 上传补偿删除异常: platform={}, path={}, filename={}",
                    stored.getPlatform(), stored.getPath(), stored.getFilename(), exception);
        }
    }
}