package jnpf.dmsService;

import jnpf.base.UserInfo;
import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.dmsEntity.fenfa.*;
import jnpf.dmsEntity.fenfa.vo.*;
import jnpf.dmsMapper.*;
import jnpf.dmsPermission.DmsCurrentIdentity;
import jnpf.exception.DataException;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.*;
import org.mockito.junit.jupiter.MockitoExtension;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
import static org.mockito.ArgumentMatchers.*;

@ExtendWith(MockitoExtension.class)
class DmsWenjianBupinghengServiceTest {
    @Mock jnpf.dmsIntegration.audit.DmsSystemAudit systemAudit;
    @Mock DmsCurrentIdentity identity;
    @Mock DmsWenjianFenfaMapper fenfa;
    @Mock DmsWenjianBupinghengMapper mapper;
    @Mock private jnpf.dmsService.DmsWenjianDayinHaomaService numbers;
    @Mock private jnpf.dmsService.DmsWenjianChongdaGuard reprintGuard;
    @InjectMocks DmsWenjianBupinghengService service;

    void user() throws Exception {
        UserInfo u=new UserInfo();u.setUserId("operator");u.setTenantId("tenant");
        when(identity.requireUser()).thenReturn(u);when(identity.tenantId(u)).thenReturn("tenant");
    }
    DmsWenjianBupinghengExecution document(String... measures) throws Exception {
        user();DmsWenjianBupinghengExecution doc=new DmsWenjianBupinghengExecution();doc.setId("doc");doc.setBizSign("signed");
        when(mapper.lockDocument("tenant","doc")).thenReturn(doc);
        List<DmsWenjianBupinghengExecution.Item> items=new ArrayList<>();
        for(int i=0;i<measures.length;i++){
            DmsWenjianBupinghengExecution.Item item=new DmsWenjianBupinghengExecution.Item();
            item.setId("detail-"+i);item.setDayinJiluId("copy-"+i);item.setCuoshi(measures[i]);item.setYuanyin("破损");items.add(item);
        }
        when(mapper.lockItems("tenant","doc")).thenReturn(items);return doc;
    }
    void copy(int index,String status){
        DmsWenjianDayinJiluEntity c=new DmsWenjianDayinJiluEntity();c.setId("copy-"+index);c.setDayinRenwuId("task");c.setBizStatus(status);
        when(fenfa.selectPrintForUpdate("tenant",c.getId(),null)).thenReturn(c);
    }
    void task(){
        DmsWenjianFenfaRenwuEntity d=new DmsWenjianFenfaRenwuEntity();d.setBizStatus("daifafang");
        when(fenfa.selectDistributionTaskByPrintTaskForUpdate("tenant","task")).thenReturn(d);
        DmsWenjianDayinRenwuEntity t=new DmsWenjianDayinRenwuEntity();t.setId("task");t.setTenantId("tenant");
        t.setWenjianId("file");t.setWenjianMingcheng("历史快照");t.setBanbenhao("D(04)");t.setJieshouBumenId("department");t.setDayinFenshu(9);t.setBizStatus("yidayin");
        when(fenfa.selectPrintTaskForUpdate("tenant","task")).thenReturn(t);
    }
    void success(){
        when(mapper.voidPrint(eq("tenant"),anyString(),eq("operator"),any())).thenReturn(1);
        when(mapper.completeDocument(eq("tenant"),eq("doc"),any())).thenReturn(1);
    }
    @Test void activeReprintStopsVoidBeforeSideEffects() throws Exception {
        document("cuoshi2");copy(0,"daifafang");
        doThrow(new DataException("locked")).when(reprintGuard).requireUnlocked("tenant","copy-0");
        assertThrows(DataException.class,()->service.execute("doc"));
        verify(mapper,never()).voidPrint(any(),any(),any(),any());
        verify(mapper,never()).completeDocument(any(),any(),any());
        verify(fenfa,never()).insertPrintTaskIfAbsent(any());
    }
    @Test void executesPersistedItemsAndLinksReplacementToNativeIds() throws Exception {
        document("cuoshi1","cuoshi2");copy(0,"daifafang");copy(1,"daiqianshou");task();success();
        when(fenfa.insertPrintTaskIfAbsent(any())).thenReturn(1);
        when(mapper.linkReplacement(eq("tenant"),eq("detail-0"),eq("doc"),anyString())).thenReturn(1);
        List<DmsWenjianBupinghengResultVO> r=service.execute("doc");
        ArgumentCaptor<DmsWenjianDayinRenwuEntity> cap=ArgumentCaptor.forClass(DmsWenjianDayinRenwuEntity.class);
        verify(fenfa).insertPrintTaskIfAbsent(cap.capture());DmsWenjianDayinRenwuEntity t=cap.getValue();
        assertEquals("doc",t.getLaiyuanDanjuId());assertEquals("detail-0",t.getLaiyuanMingxiId());assertEquals("wenjian_bupingheng",t.getLaiyuanLeixing());
        assertEquals(1,t.getDayinFenshu());assertEquals("daidayin",t.getBizStatus());assertEquals("历史快照",t.getWenjianMingcheng());assertEquals("D(04)",t.getBanbenhao());
        assertEquals(t.getId(),r.get(0).getXinDayinRenwuId());assertNull(r.get(1).getXinDayinRenwuId());
        verify(fenfa,never()).insertPrintRecord(any());verify(fenfa,never()).insertDistributionTaskIfAbsent(any());
        InOrder order=inOrder(mapper);order.verify(mapper).lockDocument("tenant","doc");order.verify(mapper).lockItems("tenant","doc");
        order.verify(mapper).voidPrint(eq("tenant"),eq("copy-0"),eq("operator"),any());
        order.verify(mapper).linkReplacement(eq("tenant"),eq("detail-0"),eq("doc"),eq(t.getId()));
        order.verify(mapper).voidPrint(eq("tenant"),eq("copy-1"),eq("operator"),any());
        order.verify(mapper).finishDistribution(eq("tenant"),eq("task"),eq("operator"),any());order.verify(mapper).completeDocument(eq("tenant"),eq("doc"),any());
    }
    @Test void measureTwoOnlyVoidsCopy() throws Exception {
        document("cuoshi2");copy(0,"daifafang");task();success();service.execute("doc");
        verify(fenfa,never()).insertPrintTaskIfAbsent(any());verify(mapper,never()).linkReplacement(any(),any(),any(),any());
    }
    @Test void repeatedCompletedDocumentDoesNotMutateBusinessObjects() throws Exception {
        DmsWenjianBupinghengExecution d=document("cuoshi1");d.setZhixingShijian(new Date());
        mapper.lockItems("tenant","doc").get(0).setXinDayinRenwuId("replacement");
        assertEquals("replacement",service.execute("doc").get(0).getXinDayinRenwuId());
        verifyNoInteractions(fenfa);verify(mapper,never()).voidPrint(any(),any(),any(),any());verify(mapper,never()).completeDocument(any(),any(),any());
    }
    @Test void missingOrCrossTenantDocumentCannotExecute() throws Exception {
        user();assertThrows(DataException.class,()->service.execute("doc"));verifyNoInteractions(fenfa);verify(mapper,never()).lockItems(any(),any());
    }
    @Test void unsignedNativeDocumentCannotExecute() throws Exception {
        user();DmsWenjianBupinghengExecution d=new DmsWenjianBupinghengExecution();
        when(mapper.lockDocument("tenant","doc")).thenReturn(d);
        assertThrows(DataException.class,()->service.execute("doc"));verifyNoInteractions(fenfa);
    }
    @Test void invalidStoredMeasureCannotExecute() throws Exception {
        document("unknown");assertThrows(DataException.class,()->service.execute("doc"));verifyNoInteractions(fenfa);
    }
    @Test void duplicateStoredCopiesCannotExecute() throws Exception {
        document("cuoshi1","cuoshi2");mapper.lockItems("tenant","doc").get(1).setDayinJiluId("copy-0");
        assertThrows(DataException.class,()->service.execute("doc"));verifyNoInteractions(fenfa);
    }
    @Test void staleCopyRejectsAllBeforeMutation() throws Exception {
        document("cuoshi1","cuoshi2");copy(0,"daifafang");copy(1,"yiguidang");
        assertThrows(DataException.class,()->service.execute("doc"));verify(mapper,never()).voidPrint(any(),any(),any(),any());
    }
    @Test void compareAndSetFailureDoesNotMarkExecuted() throws Exception {
        document("cuoshi2");copy(0,"daifafang");task();
        assertThrows(DataException.class,()->service.execute("doc"));verify(mapper,never()).completeDocument(any(),any(),any());
    }
    @Test void receiptFailureThrowsAndTransactionCoversAllBusinessEffects() throws Exception {
        document("cuoshi2");copy(0,"daifafang");task();when(mapper.voidPrint(any(),any(),any(),any())).thenReturn(1);
        assertThrows(DataException.class,()->service.execute("doc"));
        java.lang.reflect.Method method=DmsWenjianBupinghengService.class.getMethod("execute",String.class);
        assertTrue(Arrays.asList(method.getAnnotation(Transactional.class).rollbackFor()).contains(Exception.class));
        assertEquals("#p0",method.getAnnotation(AuditLog.class).targetIdExpr());
    }
    @Test void scheduledExecutionUsesSystemZeroAndOriginalTenantAndSignature() throws Exception {
        DmsWenjianBupinghengExecution d = new DmsWenjianBupinghengExecution();
        d.setId("doc"); d.setBizSign("signed"); d.setDengjiRenId("registrar"); d.setVersion(3L);
        when(mapper.lockDocument("tenant", "doc")).thenReturn(d);
        DmsWenjianBupinghengExecution.Item item = new DmsWenjianBupinghengExecution.Item();
        item.setId("detail-0"); item.setDayinJiluId("copy-0"); item.setCuoshi("cuoshi1"); item.setYuanyin("破损");
        when(mapper.lockItems("tenant", "doc")).thenReturn(List.of(item));
        copy(0, "daifafang"); task();
        when(mapper.voidPrint(eq("tenant"), eq("copy-0"), eq("0"), any())).thenReturn(1);
        when(mapper.completeDocument(eq("tenant"), eq("doc"), any())).thenReturn(1);
        when(fenfa.insertPrintTaskIfAbsent(any())).thenReturn(1);
        when(mapper.linkReplacement(eq("tenant"), eq("detail-0"), eq("doc"), any())).thenReturn(1);
        service.executeScheduled("tenant", "doc", 3L);
        verifyNoInteractions(identity);
        ArgumentCaptor<DmsWenjianDayinRenwuEntity> replacement = ArgumentCaptor.forClass(DmsWenjianDayinRenwuEntity.class);
        verify(fenfa).insertPrintTaskIfAbsent(replacement.capture());
        assertEquals("0", replacement.getValue().getCreatorUserId());
        assertEquals("tenant", replacement.getValue().getTenantId());
        ArgumentCaptor<jnpf.audit.model.AuditEventDTO> event = ArgumentCaptor.forClass(jnpf.audit.model.AuditEventDTO.class);
        verify(systemAudit).record(event.capture());
        assertEquals("0", event.getValue().getOperatorId());
        assertEquals("tenant", event.getValue().getTenantId());
        assertEquals("signed", event.getValue().getRelatedSigns().get(0).getSignId());
        assertTrue(event.getValue().getExtra().contains("registrar"));
    }
    @Test void scheduledExecutionRejectsChangedDocumentBeforeAnyEffects() throws Exception {
        DmsWenjianBupinghengExecution d = new DmsWenjianBupinghengExecution();
        d.setBizSign("signed"); d.setVersion(4L);
        when(mapper.lockDocument("tenant", "doc")).thenReturn(d);
        assertThrows(DataException.class, () -> service.executeScheduled("tenant", "doc", 3L));
        verifyNoInteractions(identity, fenfa, systemAudit);
        verify(mapper, never()).lockItems(any(), any());
    }
    @Test void scheduledExecutionRequiresExplicitTenantAndVersion() {
        assertThrows(DataException.class, () -> service.executeScheduled("", "doc", 0L));
        assertThrows(DataException.class, () -> service.executeScheduled("tenant", "doc", null));
        verifyNoInteractions(mapper, identity, fenfa, systemAudit);
    }

}