package jnpf.dmsMapper;
|
import org.apache.ibatis.builder.xml.XMLMapperBuilder;
|
import org.apache.ibatis.io.Resources;
|
import org.apache.ibatis.session.Configuration;
|
import org.junit.jupiter.api.Test;
|
import java.io.InputStream;
|
import java.util.*;
|
import static org.junit.jupiter.api.Assertions.*;
|
class DmsApprovedDisableMapperXmlTest {
|
@Test void nativeApplicationApplicantUsesEachFormsPersistedField() throws Exception {
|
Configuration c=parse("DmsDisableApplicationMapper");
|
for (String operation : List.of("yichexiao", "yishixiao")) {
|
String query=sql(c,"DmsDisableApplicationMapper","application",Map.of("operation",operation));
|
assertFalse(query.contains("f_creator_user_id"));
|
assertTrue(query.contains((operation.equals("yichexiao") ? "tiyi_ren_id" : "shenqing_ren_id") + " creator_user_id"));
|
assertTrue(c.getResultMap("jnpf.dmsMapper.DmsDisableApplicationMapper.Occupancy").getResultMappings().stream()
|
.anyMatch(r -> "creator_user_id".equals(r.getColumn()) && "creatorUserId".equals(r.getProperty())));
|
String fixtureDir=System.getProperty("dms.occupancySqlDir");
|
if (fixtureDir != null) {
|
java.nio.file.Path dir=java.nio.file.Paths.get(fixtureDir);
|
java.nio.file.Files.createDirectories(dir);
|
java.nio.file.Files.writeString(dir.resolve("application-"+operation+".sql"),query);
|
}
|
}
|
}
|
@Test void discoveryUsesStableTenantTaskOperationAndApplicationCursor() throws Exception {
|
Configuration c=parse("DmsApprovedDisableMapper");
|
Map<String,Object> args=new HashMap<>();args.put("limit",100);args.put("after",null);
|
String first=sql(c,"DmsApprovedDisableMapper","approvedApplications",args);
|
assertFalse(first.contains("OFFSET"));assertFalse(first.contains(">"));
|
assertTrue(first.contains("NOT EXISTS"));
|
assertTrue(first.contains("ORDER BY COALESCE(a.tenant_id,''),COALESCE(a.task_id,''),a.operation,a.application_id LIMIT ?"));
|
args.put("after",Map.of("tenantId","tenant","taskId","task","operation","yichexiao","applicationId","app"));
|
org.apache.ibatis.mapping.BoundSql bound=c.getMappedStatement("jnpf.dmsMapper.DmsApprovedDisableMapper.approvedApplications").getBoundSql(args);
|
assertTrue(bound.getSql().contains("> (COALESCE("));
|
assertEquals(List.of("after.tenantId","after.taskId","after.operation","after.applicationId","limit"),
|
bound.getParameterMappings().stream().map(org.apache.ibatis.mapping.ParameterMapping::getProperty).toList());
|
}
|
Configuration parse(String mapper) throws Exception {
|
Configuration c=new Configuration();String resource="mapper/"+mapper+".xml";
|
try(InputStream in=Resources.getResourceAsStream(resource)){new XMLMapperBuilder(in,c,resource,c.getSqlFragments()).parse();}return c;
|
}
|
String sql(Configuration c,String mapper,String method,Map<String,Object> args){
|
return c.getMappedStatement("jnpf.dmsMapper."+mapper+"."+method).getBoundSql(args).getSql().replaceAll("\\s+"," ");
|
}
|
@Test void bothNativeBranchesAreBoundWithoutRawTableSubstitution() throws Exception {
|
String name="DmsApprovedDisableMapper";Configuration c=parse(name);
|
for(String op:List.of("yichexiao","yishixiao")){
|
Map<String,Object> args=new HashMap<>();args.put("operation",op);
|
String s=sql(c,name,"nativeRows",args);
|
assertTrue(s.contains(op.equals("yichexiao")?"dms_wenjian_chexiao_tiyi":"dms_wenjian_shixiao_shenqing"));
|
assertTrue(s.contains("m.f_flow_state=2"));assertTrue(s.contains("FOR UPDATE OF m,c"));
|
}
|
assertTrue(c.getResultMap("jnpf.dmsMapper.DmsApprovedDisableMapper.Request").getResultMappings().stream()
|
.anyMatch(r->"business_version_id".equals(r.getColumn())&&"businessVersionId".equals(r.getProperty())));
|
String target=sql(c,name,"validateTarget",new HashMap<>());
|
assertTrue(target.contains("z.wenjian_leixing='zhuwenjian'"));assertTrue(target.contains("z.biz_status='effective'"));
|
String candidate=sql(c,name,"candidateExists",new HashMap<>());
|
assertTrue(candidate.contains("fresh.wenjian_leixing='zhuwenjian'"));assertTrue(candidate.contains("b.status='APPLIED'"));
|
assertTrue(candidate.contains("b.activated_at<=CURRENT_TIMESTAMP"));
|
}
|
@Test void fixedOccupancyRetainsReturnedAndRequiresRealUnsuccessfulEnd() throws Exception {
|
Configuration c=parse("DmsDisableApplicationMapper");
|
String s=sql(c,"DmsDisableApplicationMapper","pendingForFile",new HashMap<>());
|
assertTrue(s.contains("dms_file_operation_occupancies"));
|
assertFalse(s.contains("dms_wenjian_chexiao_tiyi")); assertFalse(s.contains("UNION ALL"));
|
assertTrue(s.contains("g.zhu_wenjian_id= o.file_id"));
|
assertTrue(s.contains("g.guanlian_wenjian_id=z.f_id"));
|
assertTrue(s.contains("g.guanxi_leixing='jilu'"));
|
assertFalse(s.contains("wenjian_mulu_id"));
|
assertTrue(s.contains("o.active=true"));
|
assertFalse(s.contains("workflow_task"));
|
for (String op:List.of("yichexiao","yishixiao")) {
|
String rows=sql(c,"DmsDisableApplicationMapper","applicationFiles",Map.of("operation",op));
|
assertTrue(rows.contains("z.wenjian_leixing='zhuwenjian'"));
|
}
|
for (String method:List.of("legacyApplicationsForFile","legacyApplicationsForDocument")) {
|
String legacy=sql(c,"DmsDisableApplicationMapper",method,new HashMap<>());
|
assertFalse(legacy.contains("workflow_task"));
|
assertTrue(legacy.contains("g.zhu_wenjian_id= a.file_id"));
|
assertFalse(legacy.contains("wenjian_mulu_id"));
|
}
|
String conflict=sql(c,"DmsDisableApplicationMapper","conflictingFiles",Map.of("fileIds",List.of("f1","f2")));
|
assertTrue(conflict.contains("o.task_id<>?"));assertFalse(conflict.contains("o.operation="));
|
String release=sql(c,"DmsDisableApplicationMapper","releaseFile",new HashMap<>());
|
assertTrue(release.contains("task_id=? AND operation=? AND file_id=?"));
|
String fixtureDir=System.getProperty("dms.occupancySqlDir");
|
if (fixtureDir!=null) {
|
Map<String,Object> args=new HashMap<>();args.put("tenantId","tenant");args.put("fileId","record");
|
args.put("taskId","own");args.put("operation","yichexiao");args.put("fileIds",List.of("main"));
|
args.put("applicationId","application");args.put("flowId","flow");args.put("folderId","folder");
|
args.put("documentId",UUID.fromString("00000000-0000-0000-0000-000000000001"));
|
java.nio.file.Path dir=java.nio.file.Paths.get(fixtureDir);java.nio.file.Files.createDirectories(dir);
|
for(String method:List.of("pendingForFile","pendingForDocument","conflictingFiles","selectedFiles","releaseFile","releaseTask","occupy","application","applicationFiles","legacyApplicationsForFile")) {
|
org.apache.ibatis.mapping.BoundSql bound=c.getMappedStatement("jnpf.dmsMapper.DmsDisableApplicationMapper."+method).getBoundSql(args);
|
String rendered=bound.getSql();
|
for(org.apache.ibatis.mapping.ParameterMapping mapping:bound.getParameterMappings()) {
|
String prop=mapping.getProperty();Object value=bound.hasAdditionalParameter(prop)?bound.getAdditionalParameter(prop):args.get(prop);
|
String literal=value==null?"NULL":"'"+value.toString().replace("'","''")+"'";
|
rendered=rendered.replaceFirst("\\?",java.util.regex.Matcher.quoteReplacement(literal));
|
}
|
java.nio.file.Files.writeString(dir.resolve(method+".sql"),rendered.replace("public.","pg_temp."));
|
}
|
}
|
}
|
@Test void unifiedProgressSqlUsesSharedItemsAndBatchLease() throws Exception {
|
Configuration c=parse("DmsApprovedDisableMapper"),b=parse("DmsApprovedBatchMapper");
|
String candidates=sql(b,"DmsApprovedBatchMapper","retryCandidates",Map.of("includeDisable",false));
|
assertTrue(candidates.contains("audit_type IN ('xinzeng_shenhe','xiuding_shenhe')"));
|
assertFalse(sql(b,"DmsApprovedBatchMapper","retryCandidates",Map.of("includeDisable",true)).contains("audit_type IN"));
|
String dirName=System.getProperty("dms.unifiedSqlDir");
|
Map<String,Object> args=new HashMap<>();
|
args.put("id","10000000-0000-0000-0000-000000000002");args.put("batchId","10000000-0000-0000-0000-000000000001");
|
args.put("tenantId","0");args.put("flowId","fixture-flow");args.put("taskId","fixture-task");
|
args.put("auditId","fixture-application");args.put("auditType","chexiao_shenqing");
|
args.put("operation","yichexiao");args.put("sourceRowId","fixture-row");args.put("fileId","fixture-file");
|
args.put("businessVersionId","fixture-version");args.put("sourceFileId","new-file");args.put("sourceVersionId","new-version");
|
args.put("documentId","10000000-0000-0000-0000-000000000003");args.put("fileVersionId","10000000-0000-0000-0000-000000000004");
|
args.put("folderId","10000000-0000-0000-0000-000000000005");args.put("actorId","fixture-actor");
|
args.put("scheduledAt","2020-01-01T00:00:00Z");args.put("approvedAt","2020-01-01T00:00:00Z");
|
args.put("sourceDigest","a".repeat(64));args.put("status","WAITING");args.put("leaseToken","fixture-lease");
|
args.put("token","fixture-lease");args.put("delay",60);args.put("includeDisable",false);
|
for (String method:List.of("enqueue","lock","dueItems","refreshProgress")) {
|
String query=sql(c,"DmsApprovedDisableMapper",method,args);
|
assertFalse(query.contains("dms_approved_file_disables"));
|
if(dirName!=null) {
|
Map<String,Object> values=new HashMap<>(args);
|
if(method.equals("refreshProgress"))values.put("id",args.get("batchId"));
|
dump(c,"DmsApprovedDisableMapper",method,values,dirName,method);
|
}
|
}
|
if(dirName!=null) {
|
args.put("id",args.get("batchId"));
|
for(String method:List.of("insertBatch","claim","finish","retryCandidates"))
|
dump(b,"DmsApprovedBatchMapper",method,args,dirName,method);
|
args.put("error","fixture-row-failed");dump(b,"DmsApprovedBatchMapper","finish",args,dirName,"finishError");
|
args.put("includeDisable",true);dump(b,"DmsApprovedBatchMapper","retryCandidates",args,dirName,"allCandidates");
|
}
|
}
|
void dump(Configuration c,String mapper,String method,Map<String,Object> args,String dir,String filename) throws Exception {
|
org.apache.ibatis.mapping.BoundSql bound=c.getMappedStatement("jnpf.dmsMapper."+mapper+"."+method).getBoundSql(args);
|
String rendered=bound.getSql();
|
for(org.apache.ibatis.mapping.ParameterMapping mapping:bound.getParameterMappings()) {
|
Object value=args.get(mapping.getProperty());
|
String literal=value==null?"NULL":value instanceof Number?value.toString():"'"+value.toString().replace("'","''")+"'";
|
rendered=rendered.replaceFirst("\\?",java.util.regex.Matcher.quoteReplacement(literal));
|
}
|
java.nio.file.Path path=java.nio.file.Paths.get(dir);java.nio.file.Files.createDirectories(path);
|
java.nio.file.Files.writeString(path.resolve(filename+".sql"),rendered.replace("public.","pg_temp."));
|
}
|
@Test void disableAndOccupancyMappersNeverAccessFileCenterTables() throws Exception {
|
for (String mapper:List.of("DmsApprovedDisableMapper","DmsDisableApplicationMapper")) {
|
try(InputStream in=Resources.getResourceAsStream("mapper/"+mapper+".xml")) {
|
String xml=new String(in.readAllBytes(), java.nio.charset.StandardCharsets.UTF_8);
|
for (String center:List.of("dms_documents","dms_folders","dms_file_versions","dms_version_states"))
|
assertFalse(xml.contains(center), mapper+" must use DMS center services, not "+center);
|
}
|
}
|
}
|
}
|
