package jnpf.dmsService;

import jnpf.dmsEntity.storage.approval.DmsDisableOccupancy;
import jnpf.dmsEntity.storage.form.DmsDisableSubmitValidationForm;
import jnpf.dmsMapper.DmsDisableApplicationMapper;
import jnpf.exception.DataException;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import org.junit.jupiter.api.*;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import org.springframework.test.util.ReflectionTestUtils;
import java.util.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;

class DmsDisableOccupancyServiceTest {
    DmsDisableApplicationMapper mapper=mock(DmsDisableApplicationMapper.class);
    WorkFlowApi workflow=mock(WorkFlowApi.class);
    DmsDisableOccupancyService service=new DmsDisableOccupancyService(mapper,workflow);
    TaskEntity task; DmsDisableOccupancy application;
    @BeforeEach void init() {
        ReflectionTestUtils.setField(service,"enabled",true);
        task=new TaskEntity();task.setId("task");task.setFlowId("flow");task.setTemplateId("template");
        application=new DmsDisableOccupancy();application.setApplicationId("app");application.setFlowId("template");application.setCreatorUserId("applicant");
        when(workflow.getInfoSubmit("task")).thenReturn(task);
        when(mapper.application("tenant","task","yichexiao")).thenReturn(application);
    }
    void state(int status, boolean ended) {task.setStatus(status);task.setEndTime(ended?new Date():null);application.setFlowState(status);}
    DmsDisableOccupancy file(String id) {DmsDisableOccupancy r=new DmsDisableOccupancy();r.setFileId(id);r.setFolderId("folder-"+id);return r;}
    boolean event(String type) {return service.onEvent("tenant","flow","task","yichexiao",type);}
    @Test void submittedRowsProduceTenantTaskAndDirectorySnapshot() {
        state(1,false);DmsDisableOccupancy row=file("main");
        when(mapper.applicationFiles("tenant","app","yichexiao")).thenReturn(List.of(row));
        when(mapper.selectedFiles("tenant",List.of("main"))).thenReturn(List.of(row));
        assertFalse(event("start"));
        verify(mapper).conflictingFiles("tenant",List.of("main"),"task");
        verify(mapper).releaseTask("tenant","task","yichexiao");verify(mapper).occupy(row);
        assertEquals("tenant",row.getTenantId());assertEquals("task",row.getTaskId());assertEquals("app",row.getApplicationId());
        assertEquals("folder-main",row.getFolderId());
    }
    @Test void resubmitReplacesOnlyOwnSnapshotAfterCheckingLatestSelection() {
        state(1,false);DmsDisableOccupancy current=file("replacement");
        when(mapper.applicationFiles("tenant","app","yichexiao")).thenReturn(List.of(current));
        when(mapper.selectedFiles("tenant",List.of("replacement"))).thenReturn(List.of(current));
        event("start");
        org.mockito.InOrder order=inOrder(mapper);
        order.verify(mapper).application("tenant","task","yichexiao");
        order.verify(mapper).applicationFiles("tenant","app","yichexiao");
        order.verify(mapper).selectedFiles("tenant",List.of("replacement"));
        order.verify(mapper).conflictingFiles("tenant",List.of("replacement"),"task");
        order.verify(mapper).releaseTask("tenant","task","yichexiao");
        order.verify(mapper).occupy(current);
    }
    @ParameterizedTest @ValueSource(ints={0,1,3,4,5,6,7,8,9,10})
    void noReleaseWithoutTrueEndEvenForReturnAndReject(int status) {
        state(status,false);assertFalse(event(status==8?"back":"reject"));
        verify(mapper,never()).releaseTask(any(),any(),any());verify(mapper,never()).occupy(any());
    }
    @ParameterizedTest @ValueSource(ints={3,4,7,9})
    void trueUnsuccessfulEndReleasesOwnTaskOnly(int status) {
        state(status,true);assertFalse(event("end"));verify(mapper).releaseTask("tenant","task","yichexiao");
        verify(mapper,never()).applicationFiles(any(),any(),any());
    }
    @Test void approvedEndDispatchesDisableAndKeepsOccupancyUntilProjection() {
        state(2,true);assertTrue(event("end"));verify(mapper,never()).releaseTask(any(),any(),any());
    }
    @Test void lateStartCannotReoccupyFinishedApprovedFile() {
        state(2,true);assertFalse(event("start"));verify(mapper,never()).occupy(any());
    }
    @Test void eventCannotChangeAnotherNativeApplication() {
        state(1,false);application.setFlowId("another");assertThrows(DataException.class,()->event("start"));
        verify(mapper,never()).releaseTask(any(),any(),any());
    }
    DmsDisableSubmitValidationForm form(String taskId) {
        DmsDisableSubmitValidationForm f=new DmsDisableSubmitValidationForm();f.setFlowId("flow");f.setTaskId(taskId);f.setFileIds(List.of("main"));
        when(mapper.selectedFiles("tenant",List.of("main"))).thenReturn(List.of(file("main")));return f;
    }
    @Test void crossOperationConflictBlocksBeforeNativeSubmit() {
        DmsDisableSubmitValidationForm f=form(null);when(mapper.conflictingFiles("tenant",List.of("main"),null)).thenReturn(1);
        assertThrows(DataException.class,()->service.validateSubmission("tenant","applicant","yishixiao",f));
        verify(mapper,never()).occupy(any());
    }
    @ParameterizedTest @ValueSource(ints={0,8,9})
    void ownDraftReturnedOrRecalledApplicationUsesNativeCreatorWhenWorkflowOmitsIt(int status) {
        state(status,false);service.validateSubmission("tenant","applicant","yichexiao",form("task"));
        verify(mapper).conflictingFiles("tenant",List.of("main"),"task");verify(mapper,never()).releaseTask(any(),any(),any());
    }
    @Test void cannotExcludeAnotherApplicantsOccupancy() {
        state(8,false);assertThrows(DataException.class,()->service.validateSubmission("tenant","other","yichexiao",form("task")));
        verify(mapper,never()).conflictingFiles(any(),any(),any());
    }
    @Test void activeChangedOrFinishedTaskCannotBeUsedAsNewSubmissionExclusion() {
        state(1,false);assertThrows(DataException.class,()->service.validateSubmission("tenant","applicant","yichexiao",form("task")));
        state(3,true);assertThrows(DataException.class,()->service.validateSubmission("tenant","applicant","yichexiao",form("task")));
    }
    @Test void nativeApprovalPreflightAllowsUnchangedOwnApplicationForReviewer() {
        state(1,false);when(mapper.applicationFiles("tenant","app","yichexiao")).thenReturn(List.of(file("main")));
        service.validateSubmission("tenant","reviewer","yichexiao",form("task"));
        verify(mapper).conflictingFiles("tenant",List.of("main"),"task");
        verify(mapper,never()).occupy(any());
    }
    @Test void startConflictDoesNotClearExistingSnapshot() {
        state(1,false);DmsDisableOccupancy row=file("main");when(mapper.applicationFiles("tenant","app","yichexiao")).thenReturn(List.of(row));
        when(mapper.selectedFiles("tenant",List.of("main"))).thenReturn(List.of(row));
        when(mapper.conflictingFiles("tenant",List.of("main"),"task")).thenReturn(1);
        assertThrows(DataException.class,()->event("start"));verify(mapper,never()).releaseTask(any(),any(),any());
    }
    @Test void disabledFeatureKeepsExistingEndCallbackUsableWithoutTechnicalTable() {
        ReflectionTestUtils.setField(service,"enabled",false);state(3,true);assertFalse(event("end"));
        state(2,true);assertTrue(event("end"));verify(mapper,never()).releaseTask(any(),any(),any());
        assertThrows(DataException.class,()->event("start"));
    }
}