package jnpf.dmsService;

import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
import jnpf.dmsEntity.storage.DmsWorkflowSourceKey;
import jnpf.dmsEntity.storage.enums.DmsWorkflowFileType;
import jnpf.dmsEntity.storage.vo.DmsFileUploadVO;
import jnpf.dmsIntegration.audit.DmsVersionStateAuditRow;
import jnpf.dmsMapper.DmsDocumentMapper;
import jnpf.dmsMapper.DmsFileObjectMapper;
import jnpf.dmsMapper.DmsFileVersionMapper;
import jnpf.dmsMapper.DmsVersionStateMapper;
import jnpf.dmsService.search.DmsSearchIndexJobService;
import jnpf.exception.DataException;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import jnpf.flowable.enums.TaskStatusEnum;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import java.util.UUID;

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

class DmsWorkflowFileActivationServiceTest {
    private static final String TENANT = "tenant-1";
    private static final String FLOW = "flow-1";
    private static final String TASK = "task-1";
    private static final UUID DOCUMENT = UUID.fromString("018f0000-0000-7000-8000-000000000801");
    private static final UUID BASE = UUID.fromString("018f0000-0000-7000-8000-000000000802");
    private static final UUID VERSION = UUID.fromString("018f0000-0000-7000-8000-000000000803");

    private final WorkFlowApi workflowApi = mock(WorkFlowApi.class);
    private final DmsFileObjectMapper objectMapper = mock(DmsFileObjectMapper.class);
    private final DmsDocumentMapper documentMapper = mock(DmsDocumentMapper.class);
    private final DmsFileVersionMapper versionMapper = mock(DmsFileVersionMapper.class);
    private final DmsVersionStateMapper stateMapper = mock(DmsVersionStateMapper.class);
    private final DmsSearchIndexJobService searchJobs = mock(DmsSearchIndexJobService.class);
    private final DmsBusinessLifecycleGuard businessOccupancy = mock(DmsBusinessLifecycleGuard.class);
    private final DmsWorkflowFileActivationService service = new DmsWorkflowFileActivationService(
            workflowApi, objectMapper, documentMapper, versionMapper, stateMapper, searchJobs, businessOccupancy);

    @BeforeEach
    void setUp() {
        TaskEntity task = new TaskEntity();
        task.setId(TASK);
        task.setFlowId(FLOW);
        task.setStatus(TaskStatusEnum.PASSED.getCode());
        when(workflowApi.getInfoSubmit(TASK)).thenReturn(task);
        when(documentMapper.selectByTenantAndIdForUpdate(TENANT, DOCUMENT))
                .thenReturn(new DmsDocumentEntity());
        DmsVersionStateAuditRow pending = new DmsVersionStateAuditRow();
        pending.setLifecycleStatus("PENDING_APPROVAL");
        when(stateMapper.selectAuditState(TENANT, VERSION)).thenReturn(pending);
        when(stateMapper.activateWorkflowPending(TENANT, VERSION, FLOW, TASK,
                DmsWorkflowFileType.CREATE.name(), "approver-1")).thenReturn(1);
        when(stateMapper.activateWorkflowPending(TENANT, VERSION, FLOW, TASK,
                DmsWorkflowFileType.REVISE.name(), "approver-1")).thenReturn(1);
    }

    @Test
    void activatesStagedNewFileAndEnqueuesIndex() {
        DmsFileUploadVO staged = staged(DmsWorkflowFileType.CREATE);
        when(objectMapper.selectUploadBySource(TENANT, "jnpf-file",
                DmsWorkflowSourceKey.of(FLOW, TASK, DmsWorkflowFileType.CREATE))).thenReturn(staged);

        DmsFileUploadVO result = service.activate(
                TENANT, FLOW, TASK, DmsWorkflowFileType.CREATE, "approver-1");

        assertSame(staged, result);
        assertEquals("EFFECTIVE", result.getLifecycleStatus());
        verify(stateMapper).activateWorkflowPending(TENANT, VERSION, FLOW, TASK,
                DmsWorkflowFileType.CREATE.name(), "approver-1");
        verify(searchJobs).enqueueContentUpsert(TENANT, DOCUMENT, VERSION, "abc");
    }

    @Test
    void businessGuardRejectsBeforeAnyCenterMutationOrRowLock() {
        when(objectMapper.selectUploadBySource(TENANT, "jnpf-file",
                DmsWorkflowSourceKey.of(FLOW,TASK,DmsWorkflowFileType.CREATE))).thenReturn(staged(DmsWorkflowFileType.CREATE));
        doThrow(new DataException("业务文件必须走完整批准批次")).when(businessOccupancy)
                .guardStandaloneActivation(TENANT,VERSION);
        assertThrows(DataException.class,()->service.activate(TENANT,FLOW,TASK,DmsWorkflowFileType.CREATE,"approver-1"));
        verifyNoInteractions(documentMapper,versionMapper,stateMapper,searchJobs);
    }

    @Test
    void revisionSupersedesBaseAndActivatesNewVersionInOrder() {
        DmsFileUploadVO staged = staged(DmsWorkflowFileType.REVISE);
        staged.setBaseFileVersionId(BASE);
        when(objectMapper.selectUploadBySource(TENANT, "jnpf-file",
                DmsWorkflowSourceKey.of(FLOW, TASK, DmsWorkflowFileType.REVISE))).thenReturn(staged);
        DmsFileVersionEntity current = new DmsFileVersionEntity();
        current.setId(BASE);
        when(versionMapper.selectCurrentEffective(TENANT, DOCUMENT)).thenReturn(current);
        when(stateMapper.supersedeCurrent(TENANT, DOCUMENT, BASE, "D(01)", "approver-1"))
                .thenReturn(1);

        service.activate(TENANT, FLOW, TASK, DmsWorkflowFileType.REVISE, "approver-1");

        org.mockito.InOrder ordered = inOrder(stateMapper);
        ordered.verify(stateMapper).supersedeCurrent(TENANT, DOCUMENT, BASE, "D(01)", "approver-1");
        ordered.verify(stateMapper).activateWorkflowPending(TENANT, VERSION, FLOW, TASK,
                DmsWorkflowFileType.REVISE.name(), "approver-1");
    }

    @Test
    void runningTaskCannotActivate() {
        TaskEntity running = new TaskEntity();
        running.setId(TASK);
        running.setFlowId(FLOW);
        running.setStatus(TaskStatusEnum.RUNNING.getCode());
        when(workflowApi.getInfoSubmit(TASK)).thenReturn(running);

        assertThrows(DataException.class, () -> service.activate(
                TENANT, FLOW, TASK, DmsWorkflowFileType.CREATE, "approver-1"));
        verifyNoInteractions(objectMapper);
    }

    private DmsFileUploadVO staged(DmsWorkflowFileType type) {
        DmsFileUploadVO value = new DmsFileUploadVO();
        value.setDocumentId(DOCUMENT);
        value.setFileVersionId(VERSION);
        value.setVersionLabel(type == DmsWorkflowFileType.CREATE ? "D(00)" : "D(01)");
        value.setChecksumSha256("abc");
        value.setLifecycleStatus("PENDING_APPROVAL");
        return value;
    }
}