package jnpf.dmsService;
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.metadata.TableInfoHelper;
|
import jnpf.dmsEntity.DmsDanganCundangShenqingDanganheEntity;
|
import jnpf.dmsEntity.DmsDanganXiaohuiShenqingEntity;
|
import jnpf.dmsEntity.DmsDanganXiaohuiShenqingZixiangEntity;
|
import jnpf.dmsMapper.DmsDanganCundangShenqingDanganheMapper;
|
import jnpf.dmsMapper.DmsDanganXiaohuiShenqingMapper;
|
import jnpf.dmsMapper.DmsDanganXiaohuiShenqingZixiangMapper;
|
import jnpf.dmsService.impl.DmsDanganXiaohuiShenqingTongguoServiceImpl;
|
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.util.Arrays;
|
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
import static org.junit.jupiter.api.Assertions.assertThrows;
|
import static org.junit.jupiter.api.Assertions.assertTrue;
|
import static org.mockito.ArgumentMatchers.any;
|
import static org.mockito.ArgumentMatchers.isNull;
|
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 DmsDanganXiaohuiShenqingTongguoServiceTest {
|
|
@BeforeEach
|
void setUp() {
|
initialize(DmsDanganXiaohuiShenqingEntity.class);
|
initialize(DmsDanganXiaohuiShenqingZixiangEntity.class);
|
initialize(DmsDanganCundangShenqingDanganheEntity.class);
|
}
|
|
@Test
|
void assignsEverySelectedDanganheToTheApprovedApplication() throws Exception {
|
DmsDanganXiaohuiShenqingMapper shenqingMapper = mock(DmsDanganXiaohuiShenqingMapper.class);
|
DmsDanganXiaohuiShenqingZixiangMapper zixiangMapper = mock(DmsDanganXiaohuiShenqingZixiangMapper.class);
|
DmsDanganCundangShenqingDanganheMapper danganheMapper = mock(DmsDanganCundangShenqingDanganheMapper.class);
|
when(shenqingMapper.selectList(any())).thenReturn(Arrays.asList(application("destroy-1")));
|
when(zixiangMapper.selectList(any())).thenReturn(Arrays.asList(detail("box-1"), detail("box-2")));
|
when(danganheMapper.selectList(any())).thenReturn(Arrays.asList(sourceBox("box-1", null), sourceBox("box-2", "")));
|
when(danganheMapper.update(isNull(), any())).thenReturn(2);
|
|
service(shenqingMapper, zixiangMapper, danganheMapper).tongguo("flow-1", "task-1");
|
|
ArgumentCaptor<Wrapper<DmsDanganCundangShenqingDanganheEntity>> captor = ArgumentCaptor.forClass(Wrapper.class);
|
verify(danganheMapper).update(isNull(), captor.capture());
|
com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper<?> update =
|
(com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper<?>) captor.getValue();
|
assertTrue(update.getSqlSet().contains("xiaohui_id"));
|
assertTrue(update.getParamNameValuePairs().containsValue("destroy-1"));
|
}
|
|
@Test
|
void allowsAnIdempotentApprovalForTheSameApplication() throws Exception {
|
DmsDanganXiaohuiShenqingMapper shenqingMapper = mock(DmsDanganXiaohuiShenqingMapper.class);
|
DmsDanganXiaohuiShenqingZixiangMapper zixiangMapper = mock(DmsDanganXiaohuiShenqingZixiangMapper.class);
|
DmsDanganCundangShenqingDanganheMapper danganheMapper = mock(DmsDanganCundangShenqingDanganheMapper.class);
|
when(shenqingMapper.selectList(any())).thenReturn(Arrays.asList(application("destroy-1")));
|
when(zixiangMapper.selectList(any())).thenReturn(Arrays.asList(detail("box-1")));
|
when(danganheMapper.selectList(any())).thenReturn(Arrays.asList(sourceBox("box-1", "destroy-1")));
|
when(danganheMapper.update(isNull(), any())).thenReturn(1);
|
|
service(shenqingMapper, zixiangMapper, danganheMapper).tongguo("flow-1", "task-1");
|
|
verify(danganheMapper).update(isNull(), any());
|
}
|
|
@Test
|
void rejectsDanganheAssignedToAnotherDestructionApplication() {
|
DmsDanganXiaohuiShenqingMapper shenqingMapper = mock(DmsDanganXiaohuiShenqingMapper.class);
|
DmsDanganXiaohuiShenqingZixiangMapper zixiangMapper = mock(DmsDanganXiaohuiShenqingZixiangMapper.class);
|
DmsDanganCundangShenqingDanganheMapper danganheMapper = mock(DmsDanganCundangShenqingDanganheMapper.class);
|
when(shenqingMapper.selectList(any())).thenReturn(Arrays.asList(application("destroy-1")));
|
when(zixiangMapper.selectList(any())).thenReturn(Arrays.asList(detail("box-1")));
|
when(danganheMapper.selectList(any())).thenReturn(Arrays.asList(sourceBox("box-1", "destroy-other")));
|
|
DataException error = assertThrows(DataException.class,
|
() -> service(shenqingMapper, zixiangMapper, danganheMapper).tongguo("flow-1", "task-1"));
|
|
assertEquals("档案盒已关联其他销毁申请，无法重复通过", error.getMessage());
|
verify(danganheMapper, never()).update(any(), any());
|
}
|
|
@Test
|
void rejectsBlankDanganheIdBeforeUpdatingAnything() {
|
DmsDanganXiaohuiShenqingMapper shenqingMapper = mock(DmsDanganXiaohuiShenqingMapper.class);
|
DmsDanganXiaohuiShenqingZixiangMapper zixiangMapper = mock(DmsDanganXiaohuiShenqingZixiangMapper.class);
|
DmsDanganCundangShenqingDanganheMapper danganheMapper = mock(DmsDanganCundangShenqingDanganheMapper.class);
|
when(shenqingMapper.selectList(any())).thenReturn(Arrays.asList(application("destroy-1")));
|
when(zixiangMapper.selectList(any())).thenReturn(Arrays.asList(detail(" ")));
|
|
DataException error = assertThrows(DataException.class,
|
() -> service(shenqingMapper, zixiangMapper, danganheMapper).tongguo("flow-1", "task-1"));
|
|
assertEquals("档案销毁申请明细缺少档案盒ID(danganhe_id)", error.getMessage());
|
verify(danganheMapper, never()).selectList(any());
|
verify(danganheMapper, never()).update(any(), any());
|
}
|
|
private void initialize(Class<?> entityClass) {
|
if (TableInfoHelper.getTableInfo(entityClass) == null) {
|
TableInfoHelper.initTableInfo(new MapperBuilderAssistant(new Configuration(), ""), entityClass);
|
}
|
}
|
|
private DmsDanganXiaohuiShenqingTongguoService service(
|
DmsDanganXiaohuiShenqingMapper shenqingMapper,
|
DmsDanganXiaohuiShenqingZixiangMapper zixiangMapper,
|
DmsDanganCundangShenqingDanganheMapper danganheMapper) {
|
return new DmsDanganXiaohuiShenqingTongguoServiceImpl(shenqingMapper, zixiangMapper, danganheMapper);
|
}
|
|
private DmsDanganXiaohuiShenqingEntity application(String id) {
|
DmsDanganXiaohuiShenqingEntity application = new DmsDanganXiaohuiShenqingEntity();
|
application.setId(id);
|
application.setFlowId("flow-1");
|
application.setFlowTaskId("task-1");
|
return application;
|
}
|
|
private DmsDanganXiaohuiShenqingZixiangEntity detail(String danganheId) {
|
DmsDanganXiaohuiShenqingZixiangEntity detail = new DmsDanganXiaohuiShenqingZixiangEntity();
|
detail.setDanganheId(danganheId);
|
return detail;
|
}
|
|
private DmsDanganCundangShenqingDanganheEntity sourceBox(String id, String xiaohuiId) {
|
DmsDanganCundangShenqingDanganheEntity danganhe = new DmsDanganCundangShenqingDanganheEntity();
|
danganhe.setId(id);
|
danganhe.setXiaohuiId(xiaohuiId);
|
return danganhe;
|
}
|
}
|
