package jnpf.dmsService;

import jnpf.dmsEntity.storage.approval.DmsDisableRequest;
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
import jnpf.dmsMapper.*;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import jnpf.exception.DataException;
import org.junit.jupiter.api.*;
import java.util.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
import org.springframework.test.util.ReflectionTestUtils;

class DmsApprovedDisableServiceTest {
    DmsApprovedDisableMapper mapper=mock(DmsApprovedDisableMapper.class);
    DmsWenjianZiyuanMapper resources=mock(DmsWenjianZiyuanMapper.class);
    WorkFlowApi workflow=mock(WorkFlowApi.class);
    DmsApprovedBatchMapper batches=mock(DmsApprovedBatchMapper.class);
    DmsApprovedDisableService service=new DmsApprovedDisableService(mapper,resources,workflow,batches);
    Date approvedAt=new Date(System.currentTimeMillis()-60000);
    @BeforeEach void enable(){ReflectionTestUtils.setField(service,"enabled",true);}
    DmsDisableRequest row() {
        DmsDisableRequest r=new DmsDisableRequest(); r.setId(UUID.randomUUID());r.setTenantId("tenant");
        r.setFlowId("flow");r.setTaskId("task");r.setOperation("yishixiao");r.setApplicationId("application");
        r.setSourceRowId("child");r.setFileId("main");r.setBusinessVersionId("version");
        r.setDocumentId(UUID.randomUUID());r.setFileVersionId(UUID.randomUUID());r.setFolderId(UUID.randomUUID());
        r.setSourceFileId("new");r.setSourceVersionId("newVersion");r.setApprovedAt(approvedAt);
        r.setActorId("persisted-actor");r.setScheduledAt(approvedAt);r.setStatus("WAITING");r.setLeaseToken("lease");return r;
    }
    void approved() {
        TaskEntity task=new TaskEntity();task.setId("task");task.setFlowId("flow");task.setStatus(2);
        task.setEndTime(approvedAt);when(workflow.getInfoSubmit("task")).thenReturn(task);
    }
    @Test void noReceiptWithoutRealApproval() {
        assertThrows(DataException.class,()->service.enqueue("tenant","flow","task","yishixiao"));
        verifyNoInteractions(mapper,resources);
    }
    @Test void enqueueUsesPersistedActorWhenWorkflowProjectionOmitsActor() {
        approved();
        for (String operation : List.of("yichexiao", "yishixiao")) {
            DmsDisableRequest r=row();r.setOperation(operation);
            when(mapper.nativeRows("tenant","flow","task",operation)).thenReturn(List.of(r));
            when(mapper.validateTarget(r)).thenReturn(1);when(mapper.candidateExists(r)).thenReturn(1);
            DmsApprovedBatch batch=service.enqueue("tenant","flow","task",operation);
            assertEquals("persisted-actor",batch.getActorId());
            assertEquals("persisted-actor",r.getActorId());verify(mapper).enqueue(r);
        }
    }
    @Test void missingPersistedActorFailsBeforeWritingAnyProgress() {
        approved();DmsDisableRequest r=row();r.setActorId(null);
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(r));
        assertThrows(DataException.class,()->service.enqueue("tenant","flow","task","yishixiao"));
        verifyNoInteractions(batches,resources);verify(mapper,never()).enqueue(any());
    }
    @Test void datesAreIndependentAndNeverEarlierThanApproval() {
        approved();DmsDisableRequest a=row(),b=row();b.setSourceRowId("child2");b.setFileId("main2");
        b.setRequestedAt(new Date(approvedAt.getTime()+3*86400000L));
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(a,b));
        when(mapper.validateTarget(any())).thenReturn(1);when(mapper.candidateExists(any())).thenReturn(1);
        DmsApprovedBatch batch=service.enqueue("tenant","flow","task","yishixiao");
        assertEquals(batch.getId(),a.getBatchId());assertEquals(batch.getId(),b.getBatchId());
        assertEquals(approvedAt,batch.getScheduledAt());verify(batches).insertBatch(batch);
        assertEquals(approvedAt,a.getScheduledAt());assertTrue(b.getScheduledAt().after(approvedAt));
        verify(mapper).enqueue(a);verify(mapper).enqueue(b);
    }
    @Test void duplicateCallbackReusesTaskButChangedOrRemovedRowsAreRejected() {
        approved();DmsDisableRequest a=row(),b=row();b.setSourceRowId("child2");b.setFileId("main2");
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(a,b));
        when(mapper.validateTarget(any())).thenReturn(1);when(mapper.candidateExists(any())).thenReturn(1);
        DmsApprovedBatch batch=service.enqueue("tenant","flow","task","yishixiao");
        when(batches.find("tenant","task","shixiao_shenqing")).thenReturn(batch);
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(b,a));
        assertSame(batch,service.enqueue("tenant","flow","task","yishixiao"));
        verify(batches,times(1)).insertBatch(any());verify(mapper,times(2)).validateTarget(any());
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(a));
        assertThrows(DataException.class,()->service.enqueue("tenant","flow","task","yishixiao"));
    }
    @Test void changedDateRejectsDuplicateCallback() {
        approved();DmsDisableRequest a=row();
        when(mapper.nativeRows("tenant","flow","task","yishixiao")).thenReturn(List.of(a));
        when(mapper.validateTarget(any())).thenReturn(1);when(mapper.candidateExists(any())).thenReturn(1);
        DmsApprovedBatch batch=service.enqueue("tenant","flow","task","yishixiao");
        when(batches.find("tenant","task","shixiao_shenqing")).thenReturn(batch);
        a.setRequestedAt(new Date());
        assertThrows(DataException.class,()->service.enqueue("tenant","flow","task","yishixiao"));
    }
}