package jnpf.dmsService;

import com.fasterxml.jackson.databind.ObjectMapper;
import jnpf.dmsEntity.DmsWenjianBanbenEntity;
import jnpf.dmsEntity.DmsWenjianXinzengShenheEntity;
import jnpf.dmsEntity.DmsWenjianXiudingShenheEntity;
import jnpf.dmsEntity.storage.DmsWorkflowSourceKey;
import jnpf.dmsEntity.storage.enums.DmsWorkflowFileType;
import jnpf.dmsEntity.storage.form.DmsWorkflowFilePrepareForm;
import jnpf.dmsMapper.DmsWenjianBanbenMapper;
import jnpf.dmsMapper.DmsWenjianXiudingShenqingZixiangMapper;
import jnpf.exception.DataException;
import org.junit.jupiter.api.Test;

import java.util.UUID;

import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;

class DmsWorkflowApprovalValidatorTest {
    private final DmsWenjianBanbenMapper versions = mock(DmsWenjianBanbenMapper.class);
    private final jnpf.dmsMapper.DmsFileObjectMapper objects = mock(jnpf.dmsMapper.DmsFileObjectMapper.class);
    private final jnpf.dmsMapper.DmsWenjianXinzengShenheMapper newAudits =
            mock(jnpf.dmsMapper.DmsWenjianXinzengShenheMapper.class);
    private final DmsWorkflowApprovalValidator validator = new DmsWorkflowApprovalValidator(
            new ObjectMapper(), versions, mock(DmsWenjianXiudingShenqingZixiangMapper.class),
            objects, newAudits,
            mock(jnpf.dmsMapper.DmsWenjianXiudingShenheMapper.class));
    private static final String URL = "/api/file/Image/annex/approved.docx";
    private static final String FILE = "{\"url\":\"" + URL + "\",\"name\":\"approved.docx\"}";

    @Test
    void sharedFlowIdHasIndependentTaskKeysAndStableRetries() {
        String first = DmsWorkflowSourceKey.of("flow", "task-1", DmsWorkflowFileType.CREATE);
        assertNotEquals(first, DmsWorkflowSourceKey.of("flow", "task-2", DmsWorkflowFileType.CREATE));
        assertNotEquals(first, DmsWorkflowSourceKey.of("flow", "task-1", DmsWorkflowFileType.REVISE));
        assertEquals(first, DmsWorkflowSourceKey.of(" flow ", " task-1 ", DmsWorkflowFileType.CREATE));
        assertTrue(DmsWorkflowSourceKey.of("f".repeat(120), "t".repeat(160),
                DmsWorkflowFileType.CREATE).length() <= 120);
    }

    @Test
    void rejectsReplacementAttachmentEvenWhenAuditHasPassed() {
        DmsWorkflowFilePrepareForm form = form();
        form.setUrl("/api/file/Image/annex/replacement.docx");
        assertThrows(DataException.class, () -> validator.validateNew(newAudit(), form));
    }

    @Test
    void usesApprovedAttachmentMetadataAndAllowsEquivalentAbsoluteUrl() {
        DmsWorkflowFilePrepareForm form = form();
        form.setUrl("https://files.example" + URL);
        assertEquals(FILE, validator.validateNew(newAudit(), form));
    }

    @Test
    void rejectsChangedDocumentMetadataAndMalformedApprovalAttachment() {
        DmsWorkflowFilePrepareForm form = form();
        form.setDocumentNo("OTHER");
        assertThrows(DataException.class, () -> validator.validateNew(newAudit(), form));
        assertThrows(DataException.class, () -> validator.approvedFile("not-json", URL));
        assertThrows(DataException.class, () -> validator.approvedFile(FILE,
                "/api/file/Image/annex/%2e%2e"));
    }

    @Test
    void revisionMustUseTheFileCenterVersionMappedFromTheApprovedBusinessVersion() {
        DmsWenjianXiudingShenheEntity audit = new DmsWenjianXiudingShenheEntity();
        audit.setWenjianId("business-file");
        audit.setYuanWenjianBanbenId("business-version");
        audit.setWenjianMingcheng("manual");
        audit.setWenjianMuluId("00000000-0000-0000-0000-000000000001");
        audit.setGuishuBumenId("quality");
        audit.setWenjian(FILE);
        DmsWenjianBanbenEntity version = new DmsWenjianBanbenEntity();
        version.setWenjianId("business-file");
        UUID approvedId = UUID.randomUUID();
        version.setWenjianZhongxinBanbenId(approvedId.toString());
        when(versions.selectById("tenant", "business-version")).thenReturn(version);
        DmsWorkflowFilePrepareForm form = form();
        form.setVersionId(UUID.randomUUID());
        assertThrows(DataException.class, () -> validator.validateRevision("tenant", audit, form));
        form.setVersionId(approvedId);
        assertEquals(FILE, validator.validateRevision("tenant", audit, form));
        version.setWenjianZhongxinBanbenId(null);
        assertThrows(DataException.class, () -> validator.validateRevision("tenant", audit, form));
        version.setLaiyuanDanjuLeixing("xinzeng_shenhe");
        version.setLaiyuanDanjuId("original-audit");
        DmsWenjianXinzengShenheEntity source = newAudit();
        source.setFlowId("shared-flow");
        source.setFlowTaskId("original-task");
        when(newAudits.selectOne(org.mockito.ArgumentMatchers.any())).thenReturn(source);
        jnpf.dmsEntity.storage.vo.DmsFileUploadVO registered = new jnpf.dmsEntity.storage.vo.DmsFileUploadVO();
        registered.setFileVersionId(approvedId);
        when(objects.selectUploadBySource("tenant", "jnpf-file",
                DmsWorkflowSourceKey.of("shared-flow", "original-task", DmsWorkflowFileType.CREATE)))
                .thenReturn(registered);
        assertEquals(FILE, validator.validateRevision("tenant", audit, form));
        form.setVersionId(UUID.randomUUID());
        assertThrows(DataException.class, () -> validator.validateRevision("tenant", audit, form));
    }

    private DmsWenjianXinzengShenheEntity newAudit() {
        DmsWenjianXinzengShenheEntity audit = new DmsWenjianXinzengShenheEntity();
        audit.setFlowState(2);
        audit.setWenjianBianhao("DOC-1");
        audit.setWenjianMingcheng("manual");
        audit.setWenjianMuluId("00000000-0000-0000-0000-000000000001");
        audit.setGuishuBumenId("quality");
        audit.setWenjian(FILE);
        return audit;
    }

    private DmsWorkflowFilePrepareForm form() {
        DmsWorkflowFilePrepareForm form = new DmsWorkflowFilePrepareForm();
        form.setDocumentNo("DOC-1");
        form.setFolderId(UUID.fromString("00000000-0000-0000-0000-000000000001"));
        form.setDocumentName("manual");
        form.setResponsibleDeptId("quality");
        form.setUrl(URL);
        return form;
    }
}