package jnpf.dmsService;

import jnpf.dmsEntity.fenfa.DmsBupinghengRetry;
import jnpf.dmsMapper.DmsBupinghengRetryMapper;
import jnpf.exception.DataException;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
import java.util.List;
import static org.mockito.Mockito.*;
import static org.mockito.ArgumentMatchers.*;

@ExtendWith(MockitoExtension.class)
class DmsBupinghengRetryJobTest {
    @Mock DmsBupinghengRetryMapper mapper;
    @Mock DmsWenjianBupinghengService service;
    @InjectMocks DmsBupinghengRetryJob job;

    DmsBupinghengRetry task(int attempts) {
        DmsBupinghengRetry task = new DmsBupinghengRetry();
        task.setTenantId("tenant"); task.setDocumentId("doc"); task.setVersion(2L); task.setAttempts(attempts);
        when(mapper.selectPending(100, 5)).thenReturn(List.of(task));
        return task;
    }
    void claimed(DmsBupinghengRetry task) {
        when(mapper.claim(eq(task), anyString(), eq(5))).thenReturn(1);
        when(mapper.selectClaim(eq(task), anyString())).thenReturn(task);
    }
    @Test void losingClaimDoesNotExecute() {
        task(1); job.retryPending(); verifyNoInteractions(service);
        verify(mapper, never()).finish(any(), any(), anyBoolean(), any(), anyInt());
    }
    @Test void successfulRetryClosesPersistentTask() throws Exception {
        DmsBupinghengRetry task = task(1); claimed(task); job.retryPending();
        verify(service).executeScheduled("tenant", "doc", 2L);
        verify(mapper).finish(eq(task), anyString(), eq(true), isNull(), eq(0));
    }
    @Test void transientFailureIsRetriedWithBackoff() throws Exception {
        DmsBupinghengRetry task = task(2); claimed(task);
        when(service.executeScheduled(any(), any(), any())).thenThrow(new IllegalStateException("connection unavailable"));
        job.retryPending();
        verify(mapper).finish(eq(task), anyString(), eq(false), eq("connection unavailable"), eq(600));
    }
    @Test void businessConflictRequiresManualCorrection() throws Exception {
        DmsBupinghengRetry task = task(1); claimed(task);
        when(service.executeScheduled(any(), any(), any())).thenThrow(new DataException("副本状态冲突"));
        job.retryPending();
        verify(mapper).finish(eq(task), anyString(), eq(true), eq("副本状态冲突"), eq(300));
    }
    @Test void retryLimitStopsTransientFailure() throws Exception {
        DmsBupinghengRetry task = task(5); claimed(task);
        when(service.executeScheduled(any(), any(), any())).thenThrow(new IllegalStateException("timeout"));
        job.retryPending();
        verify(mapper).finish(eq(task), anyString(), eq(true), eq("timeout"), eq(3600));
    }
}