质量校验理赔sql脚本

CK_DWD/DDL元数据/CKODSREGIST.sql → CK_DWD/DDL元数据/CKDWDREGIST.sql

 -- 理赔业务数据
-create table CKODSREGIST(
+create table CKDWDREGIST(
      checkDate                  varchar(64) -- 勘察日期
     ,linkerPhoneNo              varchar(64)  -- 联系人手机
     ,damageStartDate            varchar(64)  -- 出险时间

CK_ODS/承保同步/CK_ODS_CKODSREGIST.sql

@@ -2,7 +2,7 @@
 insert into CK_ODS.CK_ODS_KAFKA.CKODSREGIST -- topic CKODSREGIST
 select
     s1.actualData.prplccheck.checkDate                                  as checkDate            -- 勘察日期
-    ,s1.actualData.prplcregist.prpllinker.linkerPhoneNo                 as linkerPhoneNo        -- 联系人手机
+    ,s1.actualData.prplcregist[1].prpllinker.linkerPhoneNo              as linkerPhoneNo        -- 联系人手机
     ,s1.actualData.damageStartDate                                      as damageStartDate      -- 出险时间
     ,s1.actualData.prplclaim[1].claimDate                               as claimDate            -- 立案日期
     ,s1.actualData.prplclaim[1].sumclaim                                as sumclaim             -- 估损金额
@@ -13,9 +13,9 @@ select
     ,s1.actualData.prplcrecase[1].recaseDate                            as recaseDate           -- 案件重开时间
     ,s1.actualData.prplcertify.completeDate                             as completeDate         -- 资料接收齐全时间
     ,s1.actualData.prplcarlossdetail[1].indemnityDutyRate               as indemnityDutyRate    -- 车赔付比例
-    ,s1.actualData.prplproplossdetail[1].prplproploss[1].paidRate       as paidRate             -- 财赔付比例
-    ,s1.actualData.prplpersondetail[1].prplperson[1].originPaidRate     as originPaidRate       -- 人赔付比例
-    ,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOne as crippleDegreeOne     -- 伤残等级、伤残代码
+    ,s1.actualData.prplproplossdetail[1].prplproploss.paidRate          as paidRate             -- 财赔付比例
+    ,s1.actualData.prplpersondetail[1].prplperson.originPaidRate        as originPaidRate       -- 人赔付比例
+    ,s1.actualData.prplpersondetail[1].PrpLHospital.crippleDegreeOne    as crippleDegreeOne     -- 伤残等级、伤残代码
     ,s1.actualData.damageName                                           as damageName           -- 出险原因名称
     ,s1.actualData.prplaccident.damageTypeCode                          as damageTypeCode       -- 事故分类代码
     ,s1.actualData.prplaccident.damageTypeName                          as damageTypeName       -- 事故分类名称
@@ -24,20 +24,20 @@ select
     ,s1.actualData.prplcarlossdetail[1].prplrepairfactory[1].repairFactoryName              as repairFactoryName    -- 修理厂名称
     ,s1.actualData.damageCode                                                               as damageCode           -- 出险原因码值
     ,s1.actualData.prplcarlossdetail[1].prplcarcertain.injurySiteCode                       as injurySiteCode       -- 受伤部位
-    ,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOne                     as crippleDegreeOneCode -- 伤残程度代码
-    ,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOneName                 as crippleDegreeOneName -- 伤残程度名称
-    ,s1.actualData.prplpersondetail[1].PrpLHospital[1].treatedType                          as treatedType          -- 伤亡人员医疗类型
-    ,s1.actualData.prplpersondetail[1].PrpLHospital[1].hospitalName                         as hospitalName         -- 医疗机构名称
-    ,s1.actualData.prplpersondetail[1].prplsdisabilityassess[1].nonlocalIdentFlag           as nonlocalIdentFlag    -- 异地鉴定标志
+    ,s1.actualData.prplpersondetail[1].PrpLHospital.crippleDegreeOne                        as crippleDegreeOneCode -- 伤残程度代码
+    ,s1.actualData.prplpersondetail[1].PrpLHospital.crippleDegreeOneName                    as crippleDegreeOneName -- 伤残程度名称
+    ,s1.actualData.prplpersondetail[1].PrpLHospital.treatedType                             as treatedType          -- 伤亡人员医疗类型
+    ,s1.actualData.prplpersondetail[1].PrpLHospital.hospitalName                            as hospitalName         -- 医疗机构名称
+    ,s1.actualData.prplpersondetail[1].prplsdisabilityassess.nonlocalIdentFlag           as nonlocalIdentFlag    -- 异地鉴定标志
     ,s1.actualData.prplflag.subCertiType                                                    as subCertiType         -- 责任认定书类型代码
     ,s1.actualData.prplflag.subCertiTypeName                                                as subCertiTypeName     -- 责任认定书类型名称
     ,s1.actualData.prplcarlossdetail[1].verifyLoss                                          as verifyLossCar        -- 车核定损失金额
     ,s1.actualData.prplproplossdetail[1].verifyLoss                                         as verifyLossWealth     -- 财核定损失金额
     ,s1.actualData.prplpersondetail[1].verifyLoss                                           as verifyLossPeople     -- 人核定损失金额
-    ,s1.actualData.prplcreplevy[1].prplreplevyclaim[1].prplreplevyobject[1].subjectTypeCode as subjectTypeCode  -- 被追偿方类型
-    ,s1.actualData.prplcreplevy[1].prplreplevyclaim[1].prplreplevyobject[1].subjectTypeName as subjectTypeName  -- 被追偿方名称
+    ,s1.actualData.prplcreplevy[1].prplreplevyclaim.prplreplevyobject[1].subjectTypeCode as subjectTypeCode  -- 被追偿方类型
+    ,s1.actualData.prplcreplevy[1].prplreplevyclaim.prplreplevyobject[1].subjectTypeName as subjectTypeName  -- 被追偿方名称
 
-    , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
+    ,DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time  -- 加工平台处理数据时间
 
 from ODS.ODS_KAFKA.REGIST s1
 where substring(s1.actualData.accidentNo,3,2) = '05'

ODS/DDL元数据/REGIST.sql

@@ -86,10 +86,10 @@ REGIST_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM_PRPLREPLEVYOBJECT
         prplccheck row(
             checkDate       String  -- 查勘日期
         ) ,
-        prplclaim row(
+        prplclaim array<row(
             claimDate   String , -- 出险时间
             sumclaim    String   -- 估损金额
-        ) ,
+        )> ,
         prplccompensate array<row(
             compensateVericDate     String , --  核赔日期
             sumThisPaid             String , --  总赔付金额
@@ -116,34 +116,34 @@ REGIST_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM_PRPLREPLEVYOBJECT
             subCertiType        String ,   -- 责任认定书类型代码
             subCertiTypeName    String     -- 责任认定书类型名称
         ) ,
-        prplproplossdetail array<row(  -- miss
-            prplproploss  array<row(   -- miss
+        prplproplossdetail array<row(  
+            prplproploss  row(   
                 paidRate    String   -- 财赔付比例
-            )> ,
+            ) ,
             verifyLoss String -- 财核定损失金额
         )> ,
-        prplpersondetail array<row( -- miss
-            prplperson array<row(   -- miss
+        prplpersondetail array<row( 
+            prplperson row(   
                 originPaidRate  String   -- 人赔付比例
-            )>,
-            PrpLHospital array<row(   -- miss
+            ),
+            PrpLHospital row(   
                 crippleDegreeOne       String  , -- 伤残等级、伤残代码、伤残程度代码
                 crippleDegreeOneName   String  , -- 伤残程度名称
                 treatedType            String  , -- 伤亡人员医疗类型
                 hospitalName           String    -- 医疗机构名称
-            )> ,
-            prplsdisabilityassess array<row(   -- miss
+            ) ,
+            prplsdisabilityassess row(   -- miss
                 nonlocalIdentFlag       String   -- 异地鉴定标志
-            )>,
+            ),
             verifyLoss String -- 人核定损失金额
         )> ,
-        prplcreplevy array<row(  -- miss
-            prplreplevyclaim  array<row(   -- miss
-                prplreplevyobject  array<row(   -- miss
+        prplcreplevy array<row(  
+            prplreplevyclaim  row(   
+                prplreplevyobject  array<row(   
                     subjectTypeCode  String , -- 被追偿方类型
                     subjectTypeName  String   -- 被追偿方名称
                 )> 
-            )> 
+            )
         )> 
     ),
     log_time   String         ,