init

sql/external_tables.sql

@@ -10,6 +10,7 @@ CREATE TABLE cert_info
     id         BIGINT PRIMARY KEY, -- 主键
     fileId     BIGINT,             -- 文件ID
     sheetId    BIGINT,             -- 页签ID
+    personName VARCHAR,            -- 身份证号
     cid        VARCHAR,            -- 身份证号
     birth      VARCHAR,            -- 出生日期
     certType   VARCHAR,            -- 证件类型
@@ -30,24 +31,25 @@ CREATE TABLE cert_info
 DROP TABLE IF EXISTS entry_rec;
 CREATE TABLE entry_rec
 (
-    id        BIGINT PRIMARY KEY, -- 主键
-    fileId    BIGINT,             -- 文件ID
-    sheetId   BIGINT,             -- 页签ID
-    certType  VARCHAR,            -- 证件类别
-    certNo    VARCHAR,            -- 证件号码
-    gender    VARCHAR,            -- 性别
-    nation    VARCHAR,            -- 国籍
-    visaType  VARCHAR,            -- 签证种类
-    cid       VARCHAR,            -- 身份证号
-    birth     VARCHAR,            -- 出生日期
-    ioDate    VARCHAR,            -- 出入日期
-    ioTime    VARCHAR,            -- 出入时间
-    port      VARCHAR,            -- 出入口岸
-    transport VARCHAR,            -- 交通方式
-    vehicle   VARCHAR,            -- 交通工具
-    visaNo    VARCHAR,            -- 签证号码
-    country   VARCHAR,            -- 前往/归来国家
-    photo     VARCHAR             -- 照片
+    id         BIGINT PRIMARY KEY, -- 主键
+    fileId     BIGINT,             -- 文件ID
+    sheetId    BIGINT,             -- 页签ID
+    personName VARCHAR,            -- 证件类别
+    certType   VARCHAR,            -- 证件类别
+    certNo     VARCHAR,            -- 证件号码
+    gender     VARCHAR,            -- 性别
+    nation     VARCHAR,            -- 国籍
+    visaType   VARCHAR,            -- 签证种类
+    cid        VARCHAR,            -- 身份证号
+    birth      VARCHAR,            -- 出生日期
+    ioDate     VARCHAR,            -- 出入日期
+    ioTime     VARCHAR,            -- 出入时间
+    port       VARCHAR,            -- 出入口岸
+    transport  VARCHAR,            -- 交通方式
+    vehicle    VARCHAR,            -- 交通工具
+    visaNo     VARCHAR,            -- 签证号码
+    country    VARCHAR,            -- 前往/归来国家
+    photo      VARCHAR             -- 照片
 );
 
 -- 3. 机动车信息

src/main/java/com/qingjian/common/model/external/entity/CertInfo.java

@@ -29,6 +29,9 @@ public class CertInfo extends Cleaned implements Serializable {
     @TableField("cid")
     private String cid;
 
+    @TableField("personName")
+    private String personName;
+
     /**
      * 出生日期
      */

src/main/java/com/qingjian/common/model/external/entity/EntryRec.java

@@ -23,6 +23,8 @@ public class EntryRec extends Cleaned implements Serializable {
     @Serial
     private static final long serialVersionUID = -3904912588350373271L;
 
+    @TableField("personName")
+    private String personName;
     /**
      * 证件类别
      */

src/main/java/com/qingjian/module/dm/clean/impl/loader/ExternalCertInfoLoader.java

@@ -25,6 +25,7 @@ public class ExternalCertInfoLoader extends AbstractDataLoader<CertInfo, CertInf
             duckDBAppender.append(coi.getId());
             duckDBAppender.append(coi.getFileId());
             duckDBAppender.append(coi.getSheetId());
+            duckDBAppender.append(coi.getPersonName());
             duckDBAppender.append(coi.getCid());
             duckDBAppender.append(coi.getBirth());
             duckDBAppender.append(coi.getCertType());

src/main/java/com/qingjian/module/dm/clean/impl/loader/ExternalEntryRecLoader.java

@@ -25,6 +25,7 @@ public class ExternalEntryRecLoader extends AbstractDataLoader<EntryRec, EntryRe
             duckDBAppender.append(coi.getId());
             duckDBAppender.append(coi.getFileId());
             duckDBAppender.append(coi.getSheetId());
+            duckDBAppender.append(coi.getPersonName());
             duckDBAppender.append(coi.getCertType());
             duckDBAppender.append(coi.getCertNo());
             duckDBAppender.append(coi.getGender());