package jnpf.dmsController;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import jnpf.dmsEntity.wenjianbianhao.DmsFlowEventType;
|
import jnpf.dmsEntity.wenjianbianhao.form.DmsFlowEventForm;
|
import jnpf.dmsEntity.wenjianbianhao.vo.DmsWenjianBianhaoRuleVO;
|
import jnpf.dmsService.DmsWenjianBianhaoApplicationService;
|
import jnpf.exception.DataException;
|
import jnpf.flowable.WorkFlowApi;
|
import jnpf.flowable.entity.TaskEntity;
|
import org.junit.jupiter.api.Test;
|
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
import static org.junit.jupiter.api.Assertions.assertThrows;
|
import static org.mockito.Mockito.mock;
|
import static org.mockito.Mockito.verify;
|
import static org.mockito.Mockito.when;
|
|
class DmsWenjianBianhaoControllerTest {
|
|
private final DmsWenjianBianhaoApplicationService service =
|
mock(DmsWenjianBianhaoApplicationService.class);
|
private final WorkFlowApi workFlowApi = mock(WorkFlowApi.class);
|
private final DmsWenjianBianhaoController controller =
|
new DmsWenjianBianhaoController(service, workFlowApi);
|
|
@Test
|
void startEventReadsWorkflowStateBeforeCallingBusinessService() throws DataException {
|
DmsFlowEventForm form = form("flow-1", "task-1", DmsFlowEventType.START);
|
TaskEntity task = new TaskEntity();
|
task.setId("task-1");
|
task.setStatus(1);
|
when(workFlowApi.getInfoSubmit("task-1")).thenReturn(task);
|
|
controller.syncApplicationFlowEvent(form);
|
|
verify(service).syncApplicationFlow(
|
"flow-1", "task-1", 1, DmsFlowEventType.START);
|
}
|
|
@Test
|
void rejectsMissingWorkflowTask() {
|
DmsFlowEventForm form = form("flow-1", "task-1", DmsFlowEventType.END);
|
when(workFlowApi.getInfoSubmit("task-1")).thenReturn(null);
|
|
assertThrows(DataException.class, () -> controller.syncApplicationFlowEvent(form));
|
}
|
|
@Test
|
void acceptsJnpfSnakeCaseEventParameters() throws Exception {
|
DmsFlowEventForm form = new ObjectMapper().readValue(
|
"{\"flow_id\":\"flow-1\",\"task_id\":\"task-1\",\"event_type\":\"recall\"}",
|
DmsFlowEventForm.class);
|
|
assertEquals("flow-1", form.getFlowId());
|
assertEquals("task-1", form.getTaskId());
|
assertEquals(DmsFlowEventType.RECALL, form.getEventType());
|
}
|
|
@Test
|
void ruleOptionUsesJnpfInterfaceFieldNames() throws Exception {
|
DmsWenjianBianhaoRuleVO rule = new DmsWenjianBianhaoRuleVO();
|
rule.setId("rule-1");
|
rule.setGuizeMingcheng("QC-SOP规则");
|
rule.setYulanBianhao("QC-SOP-待审");
|
rule.setGuizeXianshi("QC-SOP规则 / QC-SOP-待审");
|
|
String json = new ObjectMapper().writeValueAsString(rule);
|
|
org.junit.jupiter.api.Assertions.assertTrue(json.contains("\"f_id\":\"rule-1\""));
|
org.junit.jupiter.api.Assertions.assertTrue(
|
json.contains("\"yulan_bianhao\":\"QC-SOP-待审\""));
|
org.junit.jupiter.api.Assertions.assertTrue(json.contains("\"guize_xianshi\""));
|
}
|
|
@Test
|
void nameChangeUsesItsIndependentBusinessService() throws DataException {
|
DmsFlowEventForm form = form("flow-2", "task-2", DmsFlowEventType.END);
|
TaskEntity task = new TaskEntity();
|
task.setId("task-2");
|
task.setStatus(2);
|
when(workFlowApi.getInfoSubmit("task-2")).thenReturn(task);
|
|
controller.syncNameChangeFlowEvent(form);
|
|
verify(service).syncNameChangeFlow(
|
"flow-2", "task-2", 2, DmsFlowEventType.END);
|
}
|
|
private DmsFlowEventForm form(String flowId, String taskId,
|
DmsFlowEventType eventType) {
|
DmsFlowEventForm form = new DmsFlowEventForm();
|
form.setFlowId(flowId);
|
form.setTaskId(taskId);
|
form.setEventType(eventType);
|
return form;
|
}
|
}
|
