package jnpf.dmsService;
|
|
import jnpf.base.UserInfo;
|
import jnpf.dmsEntity.fenfa.DmsWenjianDayinRenwuEntity;
|
import jnpf.dmsEntity.print.DmsWenjianBufaPrintSource;
|
import jnpf.dmsEntity.wenjianbianhao.DmsFlowEventType;
|
import jnpf.dmsEntity.wenjianbianhao.form.DmsFlowEventForm;
|
import jnpf.dmsMapper.DmsWenjianBufaPrintMapper;
|
import jnpf.dmsMapper.DmsWenjianFenfaMapper;
|
import jnpf.dmsPermission.DmsCurrentIdentity;
|
import jnpf.exception.DataException;
|
import jnpf.flowable.WorkFlowApi;
|
import jnpf.flowable.entity.TaskEntity;
|
import org.junit.jupiter.api.BeforeEach;
|
import org.junit.jupiter.api.Test;
|
import org.mockito.ArgumentCaptor;
|
import java.util.*;
|
import static org.junit.jupiter.api.Assertions.*;
|
import static org.mockito.Mockito.*;
|
|
class DmsWenjianBufaPrintServiceTest {
|
private final DmsCurrentIdentity identity = mock(DmsCurrentIdentity.class);
|
private final WorkFlowApi workflow = mock(WorkFlowApi.class);
|
private final DmsWenjianBufaPrintMapper source = mock(DmsWenjianBufaPrintMapper.class);
|
private final DmsWenjianFenfaMapper tasks = mock(DmsWenjianFenfaMapper.class);
|
private final DmsWenjianBufaPrintService service = new DmsWenjianBufaPrintService(identity, workflow, source, tasks, mock(DmsWenjianDayinHaomaService.class));
|
private final DmsFlowEventForm form = new DmsFlowEventForm();
|
private final TaskEntity flow = new TaskEntity();
|
private final DmsWenjianBufaPrintSource request = new DmsWenjianBufaPrintSource();
|
private DmsWenjianBufaPrintSource.Detail detail;
|
|
@BeforeEach
|
void setup() {
|
UserInfo user = new UserInfo();
|
user.setUserId("approver");
|
when(identity.requireUser()).thenReturn(user);
|
when(identity.tenantId(user)).thenReturn("tenant-a");
|
form.setFlowId("flow"); form.setTaskId("flow-task"); form.setEventType(DmsFlowEventType.END);
|
flow.setId("flow-task"); flow.setFlowId("flow"); flow.setTemplateId("template");
|
flow.setStatus(2); flow.setEndTime(new Date(10000));
|
when(workflow.getInfoSubmit("flow-task")).thenReturn(flow);
|
request.setId("request"); request.setFlowId("flow"); request.setFlowState(2);
|
request.setApplicantId("applicant"); request.setDepartmentId("department"); request.setRemark("remark");
|
when(source.lockRequests("tenant-a", "flow-task")).thenReturn(Collections.singletonList(request));
|
detail = detail("detail");
|
when(source.selectDetails("tenant-a", "request")).thenReturn(Collections.singletonList(detail));
|
when(tasks.insertPrintTaskIfAbsent(any())).thenReturn(1);
|
}
|
|
@Test
|
void createsTaskFromApprovedPersistedRequestAndVersion() {
|
assertEquals(1, service.onFlowEnd(form));
|
ArgumentCaptor<DmsWenjianDayinRenwuEntity> captor = ArgumentCaptor.forClass(DmsWenjianDayinRenwuEntity.class);
|
verify(tasks).insertPrintTaskIfAbsent(captor.capture());
|
DmsWenjianDayinRenwuEntity task = captor.getValue();
|
assertEquals("tenant-a", task.getTenantId());
|
assertEquals("wenjian_bufa", task.getLaiyuanLeixing());
|
assertEquals("request", task.getLaiyuanDanjuId());
|
assertEquals("detail", task.getLaiyuanMingxiId());
|
assertEquals("file", task.getWenjianId());
|
assertEquals("V1", task.getBanbenhao());
|
assertEquals("department", task.getJieshouBumenId());
|
assertEquals(3, task.getDayinFenshu());
|
assertEquals("applicant", task.getCreatorUserId());
|
assertEquals(flow.getEndTime(), task.getShenheWanchengRiqi());
|
assertEquals(detail.getEffectiveDate(), task.getShengxiaoRiqi());
|
assertEquals("no", task.getShifouShoukong());
|
assertEquals("daidayin", task.getBizStatus());
|
}
|
|
@Test
|
void rejectsSubmissionAndRecallBeforeAnyQuery() {
|
for (DmsFlowEventType event : Arrays.asList(DmsFlowEventType.START, DmsFlowEventType.RECALL)) {
|
form.setEventType(event);
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
}
|
verifyNoInteractions(workflow, source, tasks);
|
}
|
|
@Test
|
void nonApprovedEndEventsGenerateNothing() {
|
for (int status : new int[]{0,1,3,4,5,6,7,8,9,10}) {
|
flow.setStatus(status);
|
assertEquals(0, service.onFlowEnd(form));
|
}
|
verifyNoInteractions(source, tasks);
|
}
|
|
@Test
|
void rejectsWrongWorkflowAndMissingEndTime() {
|
flow.setId("other");
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
flow.setId("flow-task"); flow.setFlowId("other"); flow.setTemplateId("other");
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
flow.setFlowId("flow"); flow.setEndTime(null);
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
verifyNoInteractions(source, tasks);
|
}
|
|
@Test
|
void scopesRequestToCurrentTenantAndRequiresUniqueApprovedMatch() {
|
when(source.lockRequests("tenant-a", "flow-task")).thenReturn(Collections.emptyList());
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
when(source.lockRequests("tenant-a", "flow-task")).thenReturn(Arrays.asList(request, request));
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
when(source.lockRequests("tenant-a", "flow-task")).thenReturn(Collections.singletonList(request));
|
request.setFlowState(1);
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
request.setFlowState(2); request.setFlowId("wrong");
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
verifyNoInteractions(tasks);
|
}
|
|
@Test
|
void validatesWholeBatchBeforeInsertingAnyTask() {
|
DmsWenjianBufaPrintSource.Detail invalid = detail("invalid");
|
invalid.setResolvedVersionId(null);
|
when(source.selectDetails("tenant-a", "request")).thenReturn(Arrays.asList(detail, invalid));
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
verifyNoInteractions(tasks);
|
}
|
|
@Test
|
void rejectsEmptyDetailsAndInvalidCopies() {
|
for (String count : Arrays.asList(null, "", "0", "-1", "1.5", "999999999999", "bad")) {
|
detail.setCopies(count);
|
assertThrows(DataException.class, () -> service.onFlowEnd(form), count);
|
}
|
when(source.selectDetails("tenant-a", "request")).thenReturn(Collections.emptyList());
|
assertThrows(DataException.class, () -> service.onFlowEnd(form));
|
verifyNoInteractions(tasks);
|
}
|
|
@Test
|
void replayKeepsSourceIdentityAndReportsOnlyNewRows() {
|
when(tasks.insertPrintTaskIfAbsent(any())).thenReturn(1, 0);
|
assertEquals(1, service.onFlowEnd(form));
|
assertEquals(0, service.onFlowEnd(form));
|
ArgumentCaptor<DmsWenjianDayinRenwuEntity> captor = ArgumentCaptor.forClass(DmsWenjianDayinRenwuEntity.class);
|
verify(tasks, times(2)).insertPrintTaskIfAbsent(captor.capture());
|
assertEquals(captor.getAllValues().get(0).getLaiyuanMingxiId(), captor.getAllValues().get(1).getLaiyuanMingxiId());
|
verify(source, times(2)).lockRequests("tenant-a", "flow-task");
|
}
|
|
@Test
|
void insertionFailurePropagatesForTransactionRollback() {
|
when(tasks.insertPrintTaskIfAbsent(any())).thenThrow(new IllegalStateException("db failure"));
|
assertThrows(IllegalStateException.class, () -> service.onFlowEnd(form));
|
}
|
|
private DmsWenjianBufaPrintSource.Detail detail(String id) {
|
DmsWenjianBufaPrintSource.Detail row = new DmsWenjianBufaPrintSource.Detail();
|
row.setId(id); row.setFileId("file"); row.setVersionId("version"); row.setResolvedVersionId("version");
|
row.setFileName("Document"); row.setFileNumber("DOC-01"); row.setVersionLabel("V1");
|
row.setCopies("3"); row.setControlled("no"); row.setEffectiveDate(new Date(5000));
|
return row;
|
}
|
}
|
