package jnpf.dmsService;
import jnpf.base.ActionResult;
import jnpf.dmsEntity.storage.DmsTemplateNotification;
import jnpf.dmsMapper.DmsTemplateNotificationMapper;
import jnpf.message.SentMessageApi;
import org.junit.jupiter.api.Test;
import java.util.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
class DmsTemplateNotificationServiceTest {
    DmsTemplateNotificationMapper mapper = mock(DmsTemplateNotificationMapper.class);
    SentMessageApi api = mock(SentMessageApi.class);
    DmsTemplateNotificationService service = new DmsTemplateNotificationService(mapper, api);
    private ActionResult<Boolean> response(int code, boolean data) { var r = new ActionResult<Boolean>(); r.setCode(code); r.setData(data); return r; }
    DmsTemplateNotification event() {
        var e = new DmsTemplateNotification(); e.setTenantId("tenant"); e.setTaskId("task"); e.setTemplateId("A"); return e;
    }
    @Test void retryReadsChangedDepartmentsAndRequiresPositiveAcknowledgement() {
        var e = event(); when(mapper.claim(eq(e),anyString())).thenReturn(1);
        when(mapper.template("tenant","A")).thenReturn(Map.of("departments","[\"one\"]","name","旧模板名称"),Map.of("departments","[\"two\"]","name","最新模板名称"));
        when(mapper.recipients("tenant",List.of("one"))).thenReturn(List.of("u1"));
        when(mapper.recipients("tenant",List.of("two"))).thenReturn(List.of("u2"));
        when(api.sendDmsUpgrade(any())).thenReturn(response(500, false),response(200, true));
        when(mapper.finish(eq(e),anyString(),any(),anyString())).thenReturn(1);
        service.deliver(e); service.deliver(e);
        verify(mapper).finish(eq(e),anyString(),contains("确认"),eq("RETRY"));
        verify(api).sendDmsUpgrade(argThat(m -> m.getToUserIds().equals(List.of("u2")) && "最新模板名称".equals(m.getParameters().get("TemplateName"))));
        verify(mapper).finish(eq(e),anyString(),isNull(),eq("SENT"));
    }
    @Test void emptyDepartmentsCompleteWithoutSendingAndMissingTemplateRetries() {
        var e=event(); when(mapper.claim(eq(e),anyString())).thenReturn(1);
        when(mapper.template("tenant","A")).thenReturn(Map.of("departments","[]"),null);
        when(mapper.finish(eq(e),anyString(),any(),anyString())).thenReturn(1);
        service.deliver(e); service.deliver(e);
        verifyNoInteractions(api); verify(mapper).finish(eq(e),anyString(),isNull(),eq("NO_RECIPIENTS"));
        verify(mapper).finish(eq(e),anyString(),contains("模板"),eq("RETRY"));
    }
    @Test void duplicateLeaseDoesNotSendAndMalformedDepartmentConfigurationFails() {
        service.deliver(event()); verifyNoInteractions(api);
        assertEquals(List.of("one"),DmsTemplateNotificationService.departmentIds("[\"one\",\"one\"]"));
        assertThrows(RuntimeException.class,()->DmsTemplateNotificationService.departmentIds("{}"));
    }
}