package jnpf.dmsMapper;
|
|
import jnpf.dmsEntity.fenfa.DmsWenjianChongdaFasong;
|
import org.apache.ibatis.builder.xml.XMLMapperBuilder;
|
import org.apache.ibatis.mapping.Environment;
|
import org.apache.ibatis.session.*;
|
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
|
import org.junit.jupiter.api.*;
|
import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
|
import java.sql.*;
|
import java.util.Date;
|
import java.nio.charset.StandardCharsets;
|
import static org.junit.jupiter.api.Assertions.*;
|
|
/** 生产Mapper及迁移在连接内临时表验证；不写public业务表，关闭连接自动销毁。 */
|
@EnabledIfEnvironmentVariable(named="DMS_LEDGER_TEST_JDBC_URL", matches=".+")
|
class DmsWenjianChongdaMapperPostgresTest {
|
Connection connection;
|
SqlSession session;
|
DmsWenjianChongdaMapper mapper;
|
@BeforeEach void setup() throws Exception {
|
connection=DriverManager.getConnection(System.getenv("DMS_LEDGER_TEST_JDBC_URL"),System.getenv("DMS_LEDGER_TEST_DB_USER"),System.getenv("DMS_LEDGER_TEST_DB_PASSWORD"));
|
connection.setAutoCommit(false);
|
try(var s=connection.createStatement()) {
|
s.execute("SET LOCAL search_path TO pg_temp");
|
s.execute("CREATE TEMP TABLE dms_wenjian_bupingheng_dengji(f_id varchar(64),f_tenant_id varchar(64),f_delete_mark integer,zhixing_shijian timestamp,f_version integer)");
|
s.execute("CREATE TEMP TABLE lims_sign(f_id text,f_tenant_id text,f_creator_user_id text,f_delete_mark integer,meta_data text)");
|
try(var input=getClass().getResourceAsStream("/forms/original-serial-reprint/schema.sql")) {
|
String schema=new String(input.readAllBytes(),StandardCharsets.UTF_8).replace("CREATE TABLE IF NOT EXISTS dms_wenjian_chongda_fasong", "CREATE TEMP TABLE IF NOT EXISTS dms_wenjian_chongda_fasong");
|
s.execute(schema);
|
}
|
}
|
Configuration c=new Configuration();
|
c.setEnvironment(new Environment("test",new JdbcTransactionFactory(),new org.apache.ibatis.datasource.unpooled.UnpooledDataSource()));
|
try(var xml=getClass().getResourceAsStream("/mapper/DmsWenjianChongdaMapper.xml")) {
|
new XMLMapperBuilder(xml,c,"mapper/DmsWenjianChongdaMapper.xml",c.getSqlFragments()).parse();
|
}
|
session=new SqlSessionFactoryBuilder().build(c).openSession(connection);mapper=session.getMapper(DmsWenjianChongdaMapper.class);
|
}
|
@AfterEach void cleanup() throws Exception { if(connection!=null&&!connection.isClosed()) connection.rollback();if(session!=null)session.close();if(connection!=null)connection.close(); }
|
DmsWenjianChongdaFasong attempt(String id) {
|
var a=new DmsWenjianChongdaFasong();a.setId(id);a.setTenantId("test");a.setPrintRecordId("copy");a.setTaskId("task");a.setFileVersionId("version");a.setUserId("actor");a.setCopies(1);a.setState("OPEN");a.setBatchesJson("[]");a.setNumbersJson("[{\"serialNumber\":\"original\"}]");a.setReason("reason");a.setBizSign("sign-"+id);a.setCreatedAt(new Date());return a;
|
}
|
@Test void persistsAndMapsFrozenAttemptThenCompletesNativeDocument() throws Exception {
|
var a=attempt("request");assertEquals(1,mapper.insertAttempt(a));
|
var read=mapper.selectActive("test","copy");assertEquals("actor",read.getUserId());assertEquals(a.getNumbersJson(),read.getNumbersJson());assertEquals(1,read.getCopies());
|
try(var s=connection.createStatement()) {s.execute("INSERT INTO dms_wenjian_bupingheng_dengji(f_id,f_tenant_id,chongda_fasong_id) VALUES ('doc','test','request')");}
|
a.setSubmittedAt(new Date());a.setDocumentId(mapper.findDocument("test","request").getDocumentId());
|
assertEquals(1,mapper.completeDocument(a));assertEquals(0,mapper.completeDocument(a));a.setState("CLOSED");assertEquals(1,mapper.updateAttempt(a));
|
assertNull(mapper.selectActive("test","copy"));assertEquals("doc",mapper.selectAttempt("test","request").getDocumentId());
|
assertEquals(1,mapper.insertAttempt(attempt("request2")));
|
}
|
@Test void cancellationPersistsAndReleasesActiveSlot() {
|
var a=attempt("cancelled");mapper.insertAttempt(a);a.setPageCount(8);a.setState("CANCELLED");a.setCancelledAt(new Date());mapper.updateAttempt(a);
|
var read=mapper.selectAttempt("test","cancelled");assertEquals(8,read.getPageCount());assertNotNull(read.getCancelledAt());assertNull(mapper.selectActive("test","copy"));
|
assertEquals(1,mapper.insertAttempt(attempt("next")));
|
}
|
@Test void activeAttemptUniquenessRejectsParallelRequests() {mapper.insertAttempt(attempt("one"));assertThrows(Exception.class,()->mapper.insertAttempt(attempt("two")));}
|
@Test void nativeAssociationRemainsUniqueAfterSoftDelete() throws Exception {
|
try(var s=connection.createStatement()) {
|
s.execute("INSERT INTO dms_wenjian_bupingheng_dengji(f_id,f_tenant_id,chongda_fasong_id,f_delete_mark) VALUES ('deleted','test','request',1)");
|
assertThrows(SQLException.class,()->s.execute("INSERT INTO dms_wenjian_bupingheng_dengji(f_id,f_tenant_id,chongda_fasong_id) VALUES ('second','test','request')"));
|
}
|
}
|
@Test void signatureBindsActorRequestCopyReasonAndMeasure() throws Exception {
|
String data="{\"biz_form_id\":\"37a318b30d7c4daf9670d141b33ed1b7\",\"biz_data\":[{\"chongda_fasong_id\":\"request\",\"bupingheng_mingxi\":[{\"dayin_jilu_id\":\"copy\",\"cuoshi\":\"cuoshi3\",\"yuanyin\":\" reason \"}]}]}";
|
try(var s=connection.prepareStatement("INSERT INTO lims_sign VALUES ('sign','test','actor',NULL,?)")) {s.setString(1,data);s.executeUpdate();}
|
assertNotNull(mapper.validSignature("test","actor","sign","copy","request","reason"));
|
assertNull(mapper.validSignature("test","other","sign","copy","request","reason"));
|
assertNull(mapper.validSignature("test","actor","sign","copy","another","reason"));
|
assertNull(mapper.validSignature("test","actor","sign","copy","request","changed"));
|
assertNull(mapper.validSignature("test","actor","sign","other","request","reason"));
|
}
|
}
|
