package jnpf.dmsService;

import com.baomidou.mybatisplus.core.metadata.TableInfoHelper;
import jnpf.dmsEntity.DmsWenjianFushenYanqiShenqingEntity;
import jnpf.dmsEntity.DmsWenjianFushenYanqiShenqingZixiangEntity;
import jnpf.dmsEntity.storage.form.DmsFileExtendValidityForm;
import jnpf.dmsMapper.DmsWenjianFushenYanqiShenqingMapper;
import jnpf.dmsMapper.DmsWenjianFushenYanqiShenqingZixiangMapper;
import jnpf.dmsMapper.DmsWenjianZiyuanMapper;
import jnpf.dmsService.impl.DmsWenjianFushenYanqiShenqingTongguoServiceImpl;
import jnpf.exception.DataException;
import org.apache.ibatis.builder.MapperBuilderAssistant;
import org.apache.ibatis.session.Configuration;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.ArgumentCaptor;

import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Collections;
import java.util.Date;
import java.util.TimeZone;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

class DmsWenjianFushenYanqiShenqingTongguoServiceTest {

    @BeforeEach
    void setUp() {
        initialize(DmsWenjianFushenYanqiShenqingEntity.class);
        initialize(DmsWenjianFushenYanqiShenqingZixiangEntity.class);
    }

    @Test
    void updatesEveryReferencedResourceForTheApprovedApplication() throws Exception {
        DmsWenjianFushenYanqiShenqingMapper shenqingMapper = mock(DmsWenjianFushenYanqiShenqingMapper.class);
        DmsWenjianFushenYanqiShenqingZixiangMapper zixiangMapper =
                mock(DmsWenjianFushenYanqiShenqingZixiangMapper.class);
        DmsWenjianZiyuanMapper ziyuanMapper = mock(DmsWenjianZiyuanMapper.class);
        DmsFileValidityService fileValidityService = mock(DmsFileValidityService.class);
        Date shenqingRiqi = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
                .parse("2026-09-14 12:30:45");
        Date yanqiZhi1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
                .parse("2027-01-01 00:00:00");
        Date yanqiZhi2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
                .parse("2027-02-01 00:00:00");
        when(shenqingMapper.selectList(any())).thenReturn(Collections.singletonList(application(shenqingRiqi)));
        when(zixiangMapper.selectList(any())).thenReturn(Arrays.asList(
                detail("file-1", yanqiZhi1), detail("file-2", yanqiZhi2)));
        when(ziyuanMapper.selectFileVersionIdByWenjianId("file-1"))
                .thenReturn("018f0000-0000-7000-8000-000000000801");
        when(ziyuanMapper.selectFileVersionIdByWenjianId("file-2"))
                .thenReturn("018f0000-0000-7000-8000-000000000802");
        when(ziyuanMapper.updateReviewExtension(any(), any(), any(), any())).thenReturn(1);

        String applicationId = service(shenqingMapper, zixiangMapper, ziyuanMapper, fileValidityService)
                .tongguo("flow-1", "task-1");

        assertEquals("apply-1", applicationId);
        verify(ziyuanMapper).updateReviewExtension(
                "file-1", yanqiZhi1, "apply-1", "2026-09-14 12:30:45");
        verify(ziyuanMapper).updateReviewExtension(
                "file-2", yanqiZhi2, "apply-1", "2026-09-14 12:30:45");
        ArgumentCaptor<DmsFileExtendValidityForm> formCaptor =
                ArgumentCaptor.forClass(DmsFileExtendValidityForm.class);
        verify(fileValidityService).extendValidity(formCaptor.capture());
        DmsFileExtendValidityForm form = formCaptor.getValue();
        assertEquals("flow-1", form.getSourceId());
        assertEquals("task-1", form.getTaskId());
        assertEquals(2, form.getFiles().size());
        assertEquals("018f0000-0000-7000-8000-000000000801",
                form.getFiles().get(0).getFileVersionId().toString());
        assertEquals("018f0000-0000-7000-8000-000000000802",
                form.getFiles().get(1).getFileVersionId().toString());
        SimpleDateFormat effectiveToFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        effectiveToFormat.setTimeZone(TimeZone.getTimeZone("Asia/Shanghai"));
        assertEquals("2027-01-02 00:00:00",
                effectiveToFormat.format(form.getFiles().get(0).getEffectiveTo()));
        assertEquals("2027-02-02 00:00:00",
                effectiveToFormat.format(form.getFiles().get(1).getEffectiveTo()));
    }

    @Test
    void rollsBackWhenAReferencedResourceCannotBeUpdated() throws Exception {
        DmsWenjianFushenYanqiShenqingMapper shenqingMapper = mock(DmsWenjianFushenYanqiShenqingMapper.class);
        DmsWenjianFushenYanqiShenqingZixiangMapper zixiangMapper =
                mock(DmsWenjianFushenYanqiShenqingZixiangMapper.class);
        DmsWenjianZiyuanMapper ziyuanMapper = mock(DmsWenjianZiyuanMapper.class);
        DmsFileValidityService fileValidityService = mock(DmsFileValidityService.class);
        when(shenqingMapper.selectList(any())).thenReturn(Collections.singletonList(application(new Date())));
        when(zixiangMapper.selectList(any())).thenReturn(Collections.singletonList(detail("missing-file", new Date())));
        when(ziyuanMapper.selectFileVersionIdByWenjianId("missing-file"))
                .thenReturn("018f0000-0000-7000-8000-000000000803");
        when(ziyuanMapper.updateReviewExtension(any(), any(), any(), any())).thenReturn(0);

        DataException error = assertThrows(DataException.class,
                () -> service(shenqingMapper, zixiangMapper, ziyuanMapper, fileValidityService)
                        .tongguo("flow-1", "task-1"));

        assertEquals("未找到可更新的文件资源：wenjian_id=missing-file", error.getMessage());
    }

    @Test
    void rejectsAnUnknownApprovalFlow() {
        DmsWenjianFushenYanqiShenqingMapper shenqingMapper = mock(DmsWenjianFushenYanqiShenqingMapper.class);
        DmsWenjianFushenYanqiShenqingZixiangMapper zixiangMapper =
                mock(DmsWenjianFushenYanqiShenqingZixiangMapper.class);
        DmsWenjianZiyuanMapper ziyuanMapper = mock(DmsWenjianZiyuanMapper.class);
        DmsFileValidityService fileValidityService = mock(DmsFileValidityService.class);
        when(shenqingMapper.selectList(any())).thenReturn(Collections.emptyList());

        DataException error = assertThrows(DataException.class,
                () -> service(shenqingMapper, zixiangMapper, ziyuanMapper, fileValidityService)
                        .tongguo("flow-1", "task-1"));

        assertEquals("未找到文件复审延期申请：flow_id=flow-1, task_id=task-1", error.getMessage());
        verify(zixiangMapper, never()).selectList(any());
        verify(ziyuanMapper, never()).updateReviewExtension(any(), any(), any(), any());
        verify(fileValidityService, never()).extendValidity(any());
    }

    @Test
    void executesFrozenVersionAndReleasesAfterResourceProjection() throws Exception {
        var main=mock(DmsWenjianFushenYanqiShenqingMapper.class);
        var details=mock(DmsWenjianFushenYanqiShenqingZixiangMapper.class);
        var resources=mock(DmsWenjianZiyuanMapper.class);
        var validity=mock(DmsFileValidityService.class);
        var guard=mock(DmsBusinessLifecycleGuard.class);
        var receipt=new jnpf.dmsBusinessOccupancy.BusinessFileOccupancy();
        receipt.setFileId("file-1");receipt.setCenterVersionId("018f0000-0000-7000-8000-000000000801");
        var receipts=java.util.List.of(receipt);
        when(main.selectList(any())).thenReturn(java.util.List.of(application(new Date())));
        when(details.selectList(any())).thenReturn(java.util.List.of(detail("file-1",new Date())));
        when(guard.requireCurrentUserExtension("task-1","apply-1",java.util.List.of("file-1"))).thenReturn(receipts);
        when(resources.updateReviewExtension(any(),any(),any(),any())).thenReturn(1);
        var service=new DmsWenjianFushenYanqiShenqingTongguoServiceImpl(main,details,resources,validity,guard);
        service.tongguo("flow-1","task-1");
        var capture=ArgumentCaptor.forClass(DmsFileExtendValidityForm.class);
        var order=org.mockito.Mockito.inOrder(validity,resources,guard);
        order.verify(validity).extendValidity(capture.capture());
        assertEquals(receipt.getCenterVersionId(),capture.getValue().getFiles().get(0).getFileVersionId().toString());
        order.verify(resources).updateReviewExtension(any(),any(),any(),any());
        order.verify(guard).completeExecution(receipts);
        verify(resources,never()).selectFileVersionIdByWenjianId(any());
    }

    private void initialize(Class<?> entityClass) {
        if (TableInfoHelper.getTableInfo(entityClass) == null) {
            TableInfoHelper.initTableInfo(new MapperBuilderAssistant(new Configuration(), ""), entityClass);
        }
    }

    private DmsWenjianFushenYanqiShenqingTongguoService service(
            DmsWenjianFushenYanqiShenqingMapper shenqingMapper,
            DmsWenjianFushenYanqiShenqingZixiangMapper zixiangMapper,
            DmsWenjianZiyuanMapper ziyuanMapper,
            DmsFileValidityService fileValidityService) {
        return new DmsWenjianFushenYanqiShenqingTongguoServiceImpl(
                shenqingMapper, zixiangMapper, ziyuanMapper, fileValidityService,
                new DmsBusinessLifecycleGuard(null,false));
    }

    private DmsWenjianFushenYanqiShenqingEntity application(Date shenqingRiqi) {
        DmsWenjianFushenYanqiShenqingEntity application = new DmsWenjianFushenYanqiShenqingEntity();
        application.setId("apply-1");
        application.setFlowId("flow-1");
        application.setFlowTaskId("task-1");
        application.setShenqingRiqi(shenqingRiqi);
        return application;
    }

    private DmsWenjianFushenYanqiShenqingZixiangEntity detail(String wenjianId, Date yanqiZhi) {
        DmsWenjianFushenYanqiShenqingZixiangEntity detail =
                new DmsWenjianFushenYanqiShenqingZixiangEntity();
        detail.setWenjianId(wenjianId);
        detail.setYanqiZhi(yanqiZhi);
        return detail;
    }
}