package jnpf.limsService.support;
|
|
import java.nio.charset.StandardCharsets;
|
import java.nio.file.Files;
|
import java.nio.file.Path;
|
import java.nio.file.Paths;
|
|
public class LimsSxtQuyangJihuaRenwuSchemaChecks {
|
|
public static void main(String[] args) throws Exception {
|
String renwu = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangJihuaRenwuEntity.java");
|
require(renwu, "@TableName(\"lims_sxt_quyang_jihua_renwu\")");
|
require(renwu, "@TableField(\"renwu_zhuangtai\")");
|
require(renwu, "private String renwuZhuangtai;");
|
require(renwu, "@TableField(\"quyangdian_id\")");
|
require(renwu, "@TableField(\"kuaizhao_haxi\")");
|
require(renwu, "@TableField(\"qingyandan_zhuangtai\")");
|
|
String qingyandan = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsQingyandanEntity.java");
|
require(qingyandan, "@TableField(\"laiyuan_renwu_id\")");
|
require(qingyandan, "@TableField(\"renwu_kuaizhao_haxi\")");
|
|
String jianyan = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsJianyanXiangEntity.java");
|
require(jianyan, "@TableField(\"laiyuan_renwu_id\")");
|
require(jianyan, "@TableField(\"renwu_jianyan_xiang_kuaizhao_id\")");
|
require(jianyan, "@TableField(\"biaozhun_shangxian\")");
|
require(jianyan, "@TableField(\"biaozhun_xiaxian\")");
|
|
String qingyandanService = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/impl/LimsQingyandanServiceImpl.java");
|
require(qingyandanService, "record.setBiaozhunShangxian(zixiang.getBiaozhunShangxian())");
|
require(qingyandanService, "record.setBiaozhunXiaxian(zixiang.getBiaozhunXiaxian())");
|
require(qingyandanService, "record.setBiaozhunShangxian(kuaizhao.getBiaozhunShangxian())");
|
require(qingyandanService, "record.setBiaozhunXiaxian(kuaizhao.getBiaozhunXiaxian())");
|
|
String qingyanZixiang = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQingyanXiangmuZixiangEntity.java");
|
require(qingyanZixiang, "@TableField(\"xiangmu_id\")");
|
|
String jihuaZixiang = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangJihuaZixiangEntity.java");
|
require(jihuaZixiang, "@TableField(\"quyangdian_id\")");
|
require(jihuaZixiang, "private String quyangdianId;");
|
|
String quyangdian = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangdianEntity.java");
|
require(quyangdian, "@TableField(value = \"f_creator_time\", fill = FieldFill.INSERT)");
|
require(quyangdian, "private Date creatorTime;");
|
require(quyangdian, "@TableField(value = \"f_creator_user_id\", fill = FieldFill.INSERT)");
|
require(quyangdian, "private String creatorUserId;");
|
require(quyangdian, "@TableField(value = \"f_last_modify_time\", fill = FieldFill.UPDATE)");
|
require(quyangdian, "private Date lastModifyTime;");
|
require(quyangdian, "@TableField(value = \"f_last_modify_user_id\", fill = FieldFill.UPDATE)");
|
require(quyangdian, "private String lastModifyUserId;");
|
|
String jianyanXiangmu = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/JianyanXiangmuGuanliEntity.java");
|
require(jianyanXiangmu, "@TableField(\"moren_danwei\")");
|
require(jianyanXiangmu, "@TableField(\"lilun_shangxian\")");
|
require(jianyanXiangmu, "@TableField(\"lilun_xiaxian\")");
|
require(jianyanXiangmu, "@TableField(\"f_flow_id\")");
|
require(jianyanXiangmu, "@TableField(\"f_delete_time\")");
|
|
String jianyanKuaizhao = read("jnpf-lims/jnpf-lims-entity/src/main/java/jnpf/limsEntity/LimsSxtQuyangJihuaRenwuJianyanXiangKuaizhaoEntity.java");
|
require(jianyanKuaizhao, "@TableField(\"jianyan_xiangmu_jieguo_leixing\")");
|
require(jianyanKuaizhao, "@TableField(\"lilun_shangxian\")");
|
require(jianyanKuaizhao, "@TableField(\"lilun_xiaxian\")");
|
|
String ddl = read("docs/pg-migration-ddl/alter_lims_sxt_quyang_jihua_renwu_jianyan_xiang_kuaizhao_20260724.sql");
|
require(ddl, "ADD COLUMN IF NOT EXISTS jianyan_xiangmu_jieguo_leixing");
|
require(ddl, "ADD COLUMN IF NOT EXISTS lilun_shangxian");
|
require(ddl, "ADD COLUMN IF NOT EXISTS lilun_xiaxian");
|
|
String quyangdianIdDdl = read("docs/pg-migration-ddl/update_lims_sxt_quyang_jihua_zixang_quyangdian_id_20260724.sql");
|
require(quyangdianIdDdl, "ALTER TABLE public.lims_sxt_quyang_jihua_zixang");
|
require(quyangdianIdDdl, "ADD COLUMN IF NOT EXISTS quyangdian_id varchar(50)");
|
|
String fullDdl = read("docs/pg-migration-ddl/self_built_tables_pg.sql");
|
require(fullDdl, "quyangdian_id varchar(50)");
|
require(fullDdl, "lims_sxt_quyang_jihua_zixang.quyangdian_id");
|
}
|
|
private static String read(String path) throws Exception {
|
Path root = Paths.get(System.getProperty("user.dir"));
|
return new String(Files.readAllBytes(root.resolve(path)), StandardCharsets.UTF_8);
|
}
|
|
private static void require(String content, String expected) {
|
if (!content.contains(expected)) {
|
throw new AssertionError("missing: " + expected);
|
}
|
}
|
}
|
