package jnpf.dmsMapper;
|
|
import jnpf.dmsDatabase.DmsUuidTypeHandler;
|
import org.apache.ibatis.mapping.BoundSql;
|
import org.apache.ibatis.mapping.MappedStatement;
|
import org.apache.ibatis.session.Configuration;
|
import org.junit.jupiter.api.Test;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.UUID;
|
|
import static org.junit.jupiter.api.Assertions.assertFalse;
|
import static org.junit.jupiter.api.Assertions.assertTrue;
|
|
class DmsVersionStateMapperSqlTest {
|
|
@Test
|
void expiryPreservesValidityFactsAndRequiresDueDeadlineForOneTenantVersion() {
|
Map<String, Object> parameters = revisionParameters();
|
parameters.put("effectiveFrom", new java.util.Date(1726329600000L));
|
parameters.put("effectiveTo", new java.util.Date(1757865600000L));
|
parameters.put("statusReason", "到期检查确认");
|
parameters.put("changedBy", "jnpf-file");
|
|
String sql = sql("expire", parameters);
|
|
assertTrue(sql.contains("lifecycle_status = 'EXPIRED'"));
|
assertFalse(sql.contains("effective_from ="));
|
assertFalse(sql.contains("effective_to ="));
|
assertTrue(sql.contains("effective_to <= statement_timestamp()"));
|
assertTrue(sql.contains("tenant_id = ?"));
|
assertTrue(sql.contains("file_version_id = ?"));
|
assertTrue(sql.contains("lifecycle_status = 'EFFECTIVE'"));
|
assertTrue(sql.contains("revision = revision + 1"));
|
}
|
|
@Test
|
void directUploadCreatesImmediatelyEffectiveLifecycleState() {
|
Configuration configuration = new Configuration();
|
configuration.getTypeHandlerRegistry().register(UUID.class, DmsUuidTypeHandler.class);
|
loadXml(configuration);
|
MappedStatement statement = configuration.getMappedStatement(
|
DmsVersionStateMapper.class.getName() + ".insertDirectEffective");
|
|
Map<String, Object> parameters = new HashMap<>();
|
parameters.put("tenantId", "tenant-1");
|
parameters.put("documentId", UUID.fromString("018f0000-0000-7000-8000-000000000301"));
|
parameters.put("fileVersionId", UUID.fromString("018f0000-0000-7000-8000-000000000302"));
|
parameters.put("userId", "user-1");
|
BoundSql boundSql = statement.getBoundSql(parameters);
|
String sql = boundSql.getSql().replaceAll("\\s+", " ").trim();
|
|
assertTrue(sql.startsWith("INSERT INTO public.dms_version_states"));
|
assertTrue(sql.contains("'EFFECTIVE'"));
|
assertTrue(sql.contains("'DIRECT'"));
|
assertTrue(sql.contains("CURRENT_TIMESTAMP"));
|
assertTrue(sql.contains("CAST(? AS TEXT)"));
|
assertFalse(sql.contains("SELECT *"));
|
}
|
|
@Test
|
void revisionSupersedesOnlyTheExpectedCurrentVersion() {
|
String sql = sql("supersedeCurrent", revisionParameters());
|
|
assertTrue(sql.startsWith("UPDATE public.dms_version_states"));
|
assertTrue(sql.contains("lifecycle_status = 'SUPERSEDED'"));
|
assertTrue(sql.contains("file_version_id = ?"));
|
assertTrue(sql.contains("lifecycle_status = 'EFFECTIVE'"));
|
assertTrue(sql.contains("effective_to = CURRENT_TIMESTAMP"));
|
assertTrue(sql.contains("revision = revision + 1"));
|
}
|
|
@Test
|
void revisionCreatesNewEffectiveStateWithIdempotencySource() {
|
String sql = sql("insertRevisionEffective", revisionParameters());
|
|
assertTrue(sql.startsWith("INSERT INTO public.dms_version_states"));
|
assertTrue(sql.contains("'EFFECTIVE'"));
|
assertTrue(sql.contains("CONCAT('revision:', CAST(? AS TEXT), ':', ?)"));
|
assertTrue(sql.contains("CURRENT_TIMESTAMP"));
|
assertFalse(sql.contains("SELECT *"));
|
}
|
|
@Test
|
void workflowUploadCreatesPendingApprovalState() {
|
Map<String, Object> parameters = revisionParameters();
|
parameters.put("approvalSourceId", "workflow:key");
|
parameters.put("flowId", "flow-1");
|
parameters.put("taskId", "task-1");
|
parameters.put("fileType", "CREATE");
|
String sql = sql("insertWorkflowPending", parameters);
|
|
assertTrue(sql.contains("'PENDING_APPROVAL'"));
|
assertTrue(sql.contains("'WORKFLOW'"));
|
assertTrue(sql.contains("workflow_flow_id"));
|
assertFalse(sql.contains("SELECT *"));
|
}
|
|
@Test
|
void activationOnlyUpdatesPendingApprovalState() {
|
String sql = sql("activateWorkflowPending", revisionParameters());
|
|
assertTrue(sql.contains("lifecycle_status = 'EFFECTIVE'"));
|
assertTrue(sql.contains("lifecycle_status = 'PENDING_APPROVAL'"));
|
assertTrue(sql.contains("workflow_flow_id = ?"));
|
assertTrue(sql.contains("workflow_task_id = ?"));
|
assertTrue(sql.contains("workflow_file_type = ?"));
|
assertTrue(sql.contains("revision = revision + 1"));
|
assertTrue(sql.contains("archived_at = CURRENT_TIMESTAMP"));
|
}
|
|
@Test
|
void readableVersionExcludesPendingAndNeverApprovedInvalidatedStates() {
|
Configuration configuration = new Configuration();
|
configuration.getTypeHandlerRegistry().register(UUID.class, DmsUuidTypeHandler.class);
|
configuration.addMapper(DmsFileVersionMapper.class);
|
MappedStatement statement = configuration.getMappedStatement(
|
DmsFileVersionMapper.class.getName() + ".selectReadableByTenantAndId");
|
Map<String, Object> parameters = revisionParameters();
|
parameters.put("id", parameters.get("fileVersionId"));
|
String sql = statement.getBoundSql(parameters).getSql().replaceAll("\\s+", " ").trim();
|
|
assertFalse(sql.contains("PENDING_APPROVAL"));
|
assertFalse(sql.contains("PENDING_EFFECTIVE"));
|
assertTrue(sql.contains("s.lifecycle_status = 'INVALIDATED' AND s.approved_at IS NOT NULL"));
|
}
|
|
private void loadXml(Configuration configuration) {
|
String resource = "mapper/DmsVersionStateMapper.xml";
|
try (java.io.InputStream input = org.apache.ibatis.io.Resources.getResourceAsStream(resource)) {
|
new org.apache.ibatis.builder.xml.XMLMapperBuilder(input, configuration, resource, configuration.getSqlFragments()).parse();
|
} catch (java.io.IOException e) { throw new IllegalStateException(e); }
|
}
|
|
private String sql(String method, Map<String, Object> parameters) {
|
Configuration configuration = new Configuration();
|
configuration.getTypeHandlerRegistry().register(UUID.class, DmsUuidTypeHandler.class);
|
loadXml(configuration);
|
MappedStatement statement = configuration.getMappedStatement(
|
DmsVersionStateMapper.class.getName() + "." + method);
|
return statement.getBoundSql(parameters).getSql().replaceAll("\\s+", " ").trim();
|
}
|
|
private Map<String, Object> revisionParameters() {
|
Map<String, Object> parameters = new HashMap<>();
|
parameters.put("tenantId", "tenant-1");
|
parameters.put("documentId", UUID.fromString("018f0000-0000-7000-8000-000000000301"));
|
parameters.put("baseFileVersionId", UUID.fromString("018f0000-0000-7000-8000-000000000302"));
|
parameters.put("fileVersionId", UUID.fromString("018f0000-0000-7000-8000-000000000303"));
|
parameters.put("sourceId", "revision-1");
|
parameters.put("revisionReason", "更新质量职责");
|
parameters.put("newVersionLabel", "D(01)");
|
parameters.put("userId", "user-1");
|
return parameters;
|
}
|
}
|
