质量校验sql脚本

CK_DM/DDL元数据/CKDMENDOR.sql

+-- CKDMENDOR  批单校验汇总表
+
+create table CKDMENDOR (
+     PKID              varchar(64)  PRIMARY KEY
+    ,CHECK_RULE_NO     varchar(64)    -- 规则代码
+    ,CHECK_SUM         varchar(64)    -- 规则统计错误数量
+    ,CEECK_DETAILLIST  longtext       -- 规则统计错误数据清单
+    ,CHECK_MESSAGE     varchar(1000)  -- 规则统计错误描述
+    ,USER_NAME         varchar(64)    -- 联系人姓名
+    ,USER_IDNO         varchar(64)    -- 联系人身份证号
+    ,LOG_TIME          varchar(32)    -- 数据记录时间
+);

CK_DM/DDL元数据/CKDMPOLICY.sql

+-- CKDMPOLICY  保单校验汇总表
+
+create table CKDMPOLICY (
+     PKID              varchar(64)  PRIMARY KEY
+    ,CHECK_RULE_NO     varchar(64)    -- 规则代码
+    ,CHECK_SUM         varchar(64)    -- 规则统计错误数量
+    ,CEECK_DETAILLIST  longtext       -- 规则统计错误数据清单
+    ,CHECK_MESSAGE     varchar(1000)  -- 规则统计错误描述
+    ,USER_NAME         varchar(64)    -- 联系人姓名
+    ,USER_IDNO         varchar(64)    -- 联系人身份证号
+    ,LOG_TIME          varchar(32)    -- 数据记录时间
+);

CK_DM/DDL元数据/CKDMREGIST.sql

+-- CKDMREGIST  理赔校验汇总表
+
+create table CKDMREGIST (
+     PKID              varchar(64)  PRIMARY KEY
+    ,CHECK_RULE_NO     varchar(64)    -- 规则代码
+    ,CHECK_SUM         varchar(64)    -- 规则统计错误数量
+    ,CEECK_DETAILLIST  longtext       -- 规则统计错误数据清单
+    ,CHECK_MESSAGE     varchar(1000)  -- 规则统计错误描述
+    ,USER_NAME         varchar(64)    -- 联系人姓名
+    ,USER_IDNO         varchar(64)    -- 联系人身份证号
+    ,LOG_TIME          varchar(32)    -- 数据记录时间
+);

CK_DM/校验汇总/CK_DM_保单校验汇总.sql

+-- CK_DM_CKDMPOLICY CK_DM_保单校验汇总表
+
+insert into CK_DM.CK_DM_MYSQL.CKDMPOLICY
+select
+    MD5(ConcatObjUDF(s2.CHECK_RULE_NO,s2.USER_IDNO )) as PKID
+     , s2.CHECK_RULE_NO              as CHECK_RULE_NO        -- 规则代码
+     , cast(sum(1) as varchar)       as CHECK_SUM            -- 规则统计错误数量
+     , ''                            as CEECK_DETAILLIST     -- 规则统计错误数据清单拼接
+     , s2.CHECK_MESSAGE              as CHECK_MESSAGE        -- 规则统计错误描述
+     , s2.USER_NAME                  as USER_NAME            -- 联系人姓名
+     , s2.USER_IDNO                  as USER_IDNO            -- 联系人身份证号
+     , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
+from CK_DWD.CK_DWD_MYSQL.CKDWDPOLICY s1
+         left join CK_ODS.CK_ODS_MYSQL.DATACHECK_USER_RELATION s2
+                   on s1.ERRORMSG like CONCAT('%',s2.CHECK_RULE_NO,'%')
+where s1.VALI_DATE = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+  and s2.CHECK_RULE_NO is not null
+group by
+    CHECK_RULE_NO
+       , CHECK_MESSAGE
+       , USER_NAME
+       , USER_IDNO
+
+;
\ No newline at end of file

CK_DM/校验汇总/CK_DM_批单校验汇总.sql

+-- CK_DM_CKDMENDOR CK_DM_批单校验汇总表
+
+insert into CK_DM.CK_DM_MYSQL.CKDMENDOR
+select
+    MD5(ConcatObjUDF(s2.CHECK_RULE_NO,s2.USER_IDNO )) as PKID
+     , s2.CHECK_RULE_NO              as CHECK_RULE_NO        -- 规则代码
+     , cast(sum(1) as varchar)       as CHECK_SUM            -- 规则统计错误数量
+     , ''                            as CEECK_DETAILLIST     -- 规则统计错误数据清单拼接
+     , s2.CHECK_MESSAGE              as CHECK_MESSAGE        -- 规则统计错误描述
+     , s2.USER_NAME                  as USER_NAME            -- 联系人姓名
+     , s2.USER_IDNO                  as USER_IDNO            -- 联系人身份证号
+     , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
+from CK_DWD.CK_DWD_MYSQL.CKDWDENDOR s1
+         left join CK_ODS.CK_ODS_MYSQL.DATACHECK_USER_RELATION s2
+                   on s1.ERRORMSG like CONCAT('%',s2.CHECK_RULE_NO,'%')
+where s1.VALI_DATE = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+  and s2.CHECK_RULE_NO is not null
+group by
+    CHECK_RULE_NO
+       , CHECK_MESSAGE
+       , USER_NAME
+       , USER_IDNO
+
+;
\ No newline at end of file

CK_DM/校验汇总/CK_DM_理赔校验汇总.sql

+-- CK_DM_CKDMREGIST CK_DM_理赔校验汇总表
+
+insert into CK_DM.CK_DM_MYSQL.CKDMREGIST
+select
+    MD5(ConcatObjUDF(s2.CHECK_RULE_NO,s2.USER_IDNO )) as PKID
+     , s2.CHECK_RULE_NO              as CHECK_RULE_NO        -- 规则代码
+     , cast(sum(1) as varchar)       as CHECK_SUM            -- 规则统计错误数量
+     , ''                            as CEECK_DETAILLIST     -- 规则统计错误数据清单拼接
+     , s2.CHECK_MESSAGE              as CHECK_MESSAGE        -- 规则统计错误描述
+     , s2.USER_NAME                  as USER_NAME            -- 联系人姓名
+     , s2.USER_IDNO                  as USER_IDNO            -- 联系人身份证号
+     , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
+from CK_DWD.CK_DWD_MYSQL.CKDWDREGIST s1
+         left join CK_ODS.CK_ODS_MYSQL.DATACHECK_USER_RELATION s2
+                   on s1.ERRORMSG like CONCAT('%',s2.CHECK_RULE_NO,'%')
+where s1.VALI_DATE = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+  and s2.CHECK_RULE_NO is not null
+group by
+    CHECK_RULE_NO
+       , CHECK_MESSAGE
+       , USER_NAME
+       , USER_IDNO
+
+;
\ No newline at end of file

CK_TS/数据推送/CK_TS_保单数据.sql

+-- CK_TS_POLICY CK_TS_保单数据
+SELECT
+    PKID                AS PKID              --pk
+     ,CHECK_RULE_NO       AS CHECK_RULE_NO     --规则代码
+     ,CHECK_SUM           AS CHECK_SUM         --规则统计错误数量
+     ,CEECK_DETAILLIST    AS CEECK_DETAILLIST  --规则统计错误数据清单
+     ,CHECK_MESSAGE       AS CHECK_MESSAGE     --规则统计错误描述
+     ,USER_NAME           AS USER_NAME         --联系人姓名
+     ,USER_IDNO           AS USER_IDNO         --联系人身份证号
+     ,LOG_TIME            AS LOG_TIME          --数据记录时间
+
+FROM CK_DM.CK_DM_MYSQL.CKDMPOLICY
+WHERE LEFT(LOG_TIME,10) = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+;
\ No newline at end of file

CK_TS/数据推送/CK_TS_批单数据.sql

+-- CK_TS_ENDOR CK_TS_批单数据
+SELECT
+    PKID                AS PKID              --pk
+     ,CHECK_RULE_NO       AS CHECK_RULE_NO     --规则代码
+     ,CHECK_SUM           AS CHECK_SUM         --规则统计错误数量
+     ,CEECK_DETAILLIST    AS CEECK_DETAILLIST  --规则统计错误数据清单
+     ,CHECK_MESSAGE       AS CHECK_MESSAGE     --规则统计错误描述
+     ,USER_NAME           AS USER_NAME         --联系人姓名
+     ,USER_IDNO           AS USER_IDNO         --联系人身份证号
+     ,LOG_TIME            AS LOG_TIME          --数据记录时间
+
+FROM CK_DM.CK_DM_MYSQL.CKDMENDOR
+WHERE LEFT(LOG_TIME,10) = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+;
\ No newline at end of file

CK_TS/数据推送/CK_TS_理赔数据.sql

+-- CK_TS_REGIST CK_TS_理赔数据
+SELECT
+    PKID                AS PKID              --pk
+     ,CHECK_RULE_NO       AS CHECK_RULE_NO     --规则代码
+     ,CHECK_SUM           AS CHECK_SUM         --规则统计错误数量
+     ,CEECK_DETAILLIST    AS CEECK_DETAILLIST  --规则统计错误数据清单
+     ,CHECK_MESSAGE       AS CHECK_MESSAGE     --规则统计错误描述
+     ,USER_NAME           AS USER_NAME         --联系人姓名
+     ,USER_IDNO           AS USER_IDNO         --联系人身份证号
+     ,LOG_TIME            AS LOG_TIME          --数据记录时间
+
+FROM CK_DM.CK_DM_MYSQL.CKDMREGIST
+WHERE LEFT(LOG_TIME,10) = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+;
\ No newline at end of file