指标统计sql脚本

ODS/DDL元数据/HISREGIST.sql

+-- HISREGIST 车险报案
+
+业务对象命名：
+HISREGIST
+HISREGIST_ACTUALDATA
+REGIST_ACTUALDATA_PRPLCREGIST
+REGIST_ACTUALDATA_PRPLCREGIST_PRPLREPORTER
+REGIST_ACTUALDATA_PRPLCREGIST_PRPLLINKER
+REGIST_ACTUALDATA_PRPLPOLICY
+REGIST_ACTUALDATA_PRPLCARLOSSDETAIL
+REGIST_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
+REGIST_ACTUALDATA_PRPLCDAMAGE
+REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
+
+{
+    actualData row(
+        accidentNo          String , -- 事故号
+        damageStartDate     String , -- 出险时间 无需转码 2021-06-27 19:25:00
+        reportDate          String , -- 报案时间 无需转码 2021-06-27 19:37:18
+        damageAddress       String , -- 出险地点
+        prplcregist array<row(
+            policyNo        String , -- 保单号
+            registNo        String , -- 报案号
+            deptCode        String , -- 理赔机构代码
+            deptName        String , -- 理赔机构名称
+            prplreporter row(
+                reporterName            String , -- 报案人名称
+                reporterMobileNo        String   -- 报案人电话
+            ) ,
+            prpllinker row(
+                linkerName          String , -- 联系人名称
+                linkerPhoneNo       String   -- 联系人电话
+            )
+        )> ,
+        prplpolicy String         ,
+        prplcarlossdetail array<row(
+            prplcar row(
+                brandCode           String , -- 品牌
+                carModelCode        String   -- 车型
+            )
+        )> ,
+        prplcdamage row(
+            prpldamageaddress row(
+                longitude     String , -- 经度
+                latitude      String   -- 纬度
+            ) ,
+            damageName      String , -- 出险原因
+            damageCourse    String   -- 出险经过
+        )
+    ),
+    log_time   String         ,
+
+    nodeCode   String
+
+}
\ No newline at end of file

ODS/数据同步/ODS_REGIST.sql

 -- ODS_REGIST ODS_报案业务数据
-insert into ODS.ODS_KAFKA_FIRSTHAND.REGIST -- topic REGIST 无需去重
+insert into ODS.ODS_KAFKA_FIRSTHAND.HISREGIST -- topic HISREGIST 无需去重
 select
     s1.actualData  ,
-    DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
     nodeCode
-
-from  ODS.SOURCE_KAFKA_REGIST_PRD.REGIST s1
+from  ODS.SOURCE_KAFKA_REGIST_PRD.HISREGIST s1 -- topic ClaimCase
+where s1.nodeCode = 'RegistCar'
 ;
 
 
@@ -16,10 +15,10 @@ select
     CONCAT('MQ_REGIST/', LEFT(DataAccRegistUDF( date_time,'get'),10)) as `key` ,
     DataAccRegistUDF( date_time,'get')         as val
 from (
-    select
-        DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')   as date_time -- 批单累加器 yyyy-MM-dd:num
-    from ODS.SOURCE_KAFKA_REGIST_PRD.REGIST
-    -- 在select与where条件中同时调用该参数 acc，会执行两次UDF函数 ,所以通过定义函数记录该参数 DataAccEndorLogUDF
-    where LEFT(DataAccRegistUDF( DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss'),'set'),10) <> 'xxxx-xx-xx' -- 将该参数保留
-) s1
+         select
+             DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')   as date_time -- 批单累加器 yyyy-MM-dd:num
+         from ODS.SOURCE_KAFKA_REGIST_PRD.HISREGIST
+              -- 在select与where条件中同时调用该参数 acc，会执行两次UDF函数 ,所以通过定义函数记录该参数 DataAccEndorLogUDF
+         where LEFT(DataAccRegistUDF( DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss'),'set'),10) <> 'xxxx-xx-xx' -- 将该参数保留
+     ) s1
 ;
\ No newline at end of file

ODS/数据清洗/DUPLICK_REGIST.sql

+-- DUPLICK_REGIST DUPLICK_报案业务数据
+insert into ODS.ODS_KAFKA.REGIST -- topic REGIST 无需去重
+select
+    s1.actualData  ,
+    DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
+    nodeCode
+
+from  ODS.ODS_KAFKA_FIRSTHAND.REGIST s1  -- topic HISREGIST
+;
+
+
+

ZB_CK/数据存储/ZB_CK_KAFKA_LPDATA.sql

+-- ZB_CK_KAFKA_LPDATA ZB_CK_理赔清单KAFKA
+insert into ZB_CK.ZB_CK_MYSQL.KAFKA_LPDATA
+select
+    `COMCODE`
+    ,`LEVEL1COMCODE`         
+    ,`LEVEL2COMCODE`         
+    ,`LEVEL3COMCODE`         
+    ,`LEVEL4COMCODE`         
+    ,`LEVEL5COMCODE`                 
+    ,`risk`                               
+    ,`classcode`                       
+    ,`businessNatureCode`      
+    ,`chnl`                               
+    ,`cladate`               
+    ,`setdate`               
+    ,`settledamount`         
+    ,`lossamout`             
+    ,`flag`                  
+    ,`claimno`               
+    ,`no`                    
+    ,`log_time`
+from ZB_ODS.ZB_ODS_KAFKA.LPDATA