package jnpf.base.service;
|
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.VisualdevEntity;
|
import jnpf.base.mapper.UploadEditReadMapper;
|
import jnpf.base.model.uploadedit.UploadEditContext;
|
import jnpf.exception.DataException;
|
import jnpf.permissions.PermissionInterfaceImpl;
|
import jnpf.util.UserProvider;
|
import org.junit.*;
|
import org.mockito.MockedStatic;
|
import java.util.*;
|
import static org.junit.Assert.*;
|
import static org.mockito.Mockito.*;
|
import static org.mockito.ArgumentMatchers.*;
|
|
public class UploadEditReadServiceTest {
|
private UploadEditReadMapper mapper;
|
private UploadEditReadService service;
|
private VisualdevEntity model;
|
private UploadEditContext context;
|
private Map<String,Object> config;
|
private MockedStatic<UserProvider> users;
|
private static final String TABLE = "dms_wenjian_xinzeng_shenhe";
|
@Before public void setup() {
|
jnpf.util.context.SpringContext.setApplicationContext(mock(org.springframework.context.ApplicationContext.class));
|
mapper = mock(UploadEditReadMapper.class); service = new UploadEditReadService(mapper);
|
model = new VisualdevEntity(); model.setDbLinkId("0"); model.setColumnData("{}");
|
model.setFormData("{\"tableName\":\""+TABLE+"\",\"logicalDelete\":true,\"primaryKeyPolicy\":1}");
|
model.setVisualTables("[{\"table\":\""+TABLE+"\",\"typeId\":\"1\",\"fields\":[{\"field\":\"f_id\",\"primaryKey\":1}]},"
|
+"{\"table\":\""+TABLE+"_jilu_mingxi\",\"typeId\":\"0\",\"tableField\":\"f_foreign_id\",\"relationField\":\"f_id\",\"fields\":[{\"field\":\"f_id\",\"primaryKey\":1}]}]");
|
model.setVisualTables(model.getVisualTables().replace("\"primaryKey\":1}]", "\"primaryKey\":1},{\"field\":\"f_tenant_id\"},{\"field\":\"f_delete_mark\"},{\"field\":\"f_flow_task_id\"},{\"field\":\"wenjian\"},{\"field\":\"f_foreign_id\"},{\"field\":\"jilu_wenjian\"}]"));
|
context = new UploadEditContext(); context.setModelId("model"); context.setRecordId("alias"); context.setField("wenjian");
|
config = new HashMap<>(); config.put("tableName", TABLE);
|
users = mockStatic(UserProvider.class); UserInfo user = new UserInfo(); user.setTenantId("tenant");
|
users.when(UserProvider::getUser).thenReturn(user);
|
when(mapper.dmsAttachment(TABLE,"tenant","alias",null)).thenReturn(Map.of("id","record","flowTaskId","task","fileJson","[{\"fileId\":\"file\",\"name\":\"保留名称\",\"uploadReceipt\":\"receipt\"}]"));
|
}
|
@After public void cleanup() { users.close(); }
|
@Test public void projectionRetainsCanonicalMetadataAndTaskAlias() {
|
Map<String,Object> result = service.dmsAttachment(model,context,config);
|
assertEquals("record",result.get("id")); assertEquals("task",result.get("flowTaskId"));
|
assertEquals(Map.of("fileId","file","name","保留名称","uploadReceipt","receipt"), ((List<?>)result.get("wenjian")).get(0));
|
verify(mapper).dmsAttachment(TABLE,"tenant","alias",null);
|
}
|
@Test public void childProjectionContainsOnlyRequestedRow() {
|
child(); when(mapper.dmsAttachment(TABLE,"tenant","alias","row")).thenReturn(Map.of("id","record","flowTaskId","task","rowId","row","fileJson","[]"));
|
assertEquals(List.of(Map.of("id","row","jilu_wenjian",List.of())), service.dmsAttachment(model,context,config).get("jilu_mingxi"));
|
}
|
@Test public void missingOrWrongChildFailsRatherThanBecomingEmptyFiles() {
|
child(); when(mapper.dmsAttachment(TABLE,"tenant","alias","row")).thenReturn(Map.of("id","record","flowTaskId","task"));
|
assertThrows(DataException.class, () -> service.dmsAttachment(model,context,config));
|
context.setRowId(null); assertThrows(DataException.class, () -> service.dmsAttachment(model,context,config));
|
}
|
@Test public void databaseFailureAndMalformedFilesCannotFallBack() {
|
when(mapper.dmsAttachment(TABLE,"tenant","alias",null)).thenThrow(new IllegalStateException("offline"));
|
assertThrows(IllegalStateException.class, () -> service.dmsAttachment(model,context,config));
|
reset(mapper); when(mapper.dmsAttachment(TABLE,"tenant","alias",null)).thenReturn(Map.of("id","record","fileJson","{}"));
|
assertThrows(RuntimeException.class, () -> service.dmsAttachment(model,context,config));
|
}
|
@Test public void missingOrDeletedParentFails() {
|
when(mapper.dmsAttachment(TABLE,"tenant","alias",null)).thenReturn(null);
|
assertThrows(DataException.class, () -> service.dmsAttachment(model,context,config));
|
}
|
@Test public void changedSourceOrNativeRelationUsesOriginalReader() {
|
model.setDbLinkId("external"); assertNull(service.dmsAttachment(model,context,config));
|
model.setDbLinkId("0"); child(); model.setVisualTables(model.getVisualTables().replace("f_foreign_id","other_fk"));
|
assertNull(service.dmsAttachment(model,context,config)); verifyNoInteractions(mapper);
|
}
|
@Test public void changedPrimaryMappingOrVirtualFieldCannotUseFixedProjection() {
|
model.setVisualTables(model.getVisualTables().replace("f_id","custom_id"));
|
assertNull(service.dmsAttachment(model,context,config));
|
config.put("isVirtualField",true); assertNull(service.dmsAttachment(model,context,config)); verifyNoInteractions(mapper);
|
}
|
@Test public void nativeMenuFieldPermissionStillApplies() {
|
context.setMenuId("menu"); model.setColumnData("{\"useFormPermission\":true}");
|
try (MockedStatic<PermissionInterfaceImpl> permission = mockStatic(PermissionInterfaceImpl.class)) {
|
permission.when(PermissionInterfaceImpl::getFormMap).thenReturn(Map.of());
|
assertThrows(DataException.class, () -> service.dmsAttachment(model,context,config)); verifyNoInteractions(mapper);
|
permission.when(PermissionInterfaceImpl::getFormMap).thenReturn(Map.of("menu", List.of(Map.of("enCode","wenjian"))));
|
assertNotNull(service.dmsAttachment(model,context,config));
|
}
|
}
|
@Test public void publishedDefinitionReadIsFreshAndFallbackOnlyWhenAbsent() {
|
when(mapper.releasedModel("model")).thenReturn(model);
|
assertSame(model,service.model("model")); assertSame(model,service.model("model"));
|
verify(mapper,times(2)).releasedModel("model"); verify(mapper,never()).designModel(anyString());
|
when(mapper.releasedModel("model")).thenReturn(null); when(mapper.designModel("model")).thenReturn(model);
|
assertSame(model,service.model("model"));
|
}
|
private void child() { context.setParentField("jilu_mingxi"); context.setField("jilu_wenjian"); context.setRowId("row"); config.put("relationTable",TABLE+"_jilu_mingxi"); }
|
private static void assertThrows(Class<? extends RuntimeException> type, Runnable operation) {
|
try { operation.run(); } catch (RuntimeException failure) {
|
if (!type.isInstance(failure)) throw failure;
|
return;
|
}
|
fail("expected " + type.getSimpleName());
|
}
|
|
}
|
