指标统计sql脚本

ODS/DDL元数据/REGIST.sql

@@ -37,7 +37,8 @@ REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
             comName         String , -- 承保机构名称
             riskCode        String , -- 险种代码
             riskName        String , -- 险种名称
-            licenseNo       String   -- 车牌号
+            licenseNo       String , -- 车牌号
+            isSelected      String   -- 是否选择
         )> ,
         prplcarlossdetail array<row(
             prplcar row(
@@ -53,8 +54,8 @@ REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
             damageName      String , -- 出险原因
             damageCourse    String   -- 出险经过
         )
-    )
-
-    log_time
+    ),
+    log_time,
+    nodeCode
 
 }
\ No newline at end of file

XF_DWD/XF_DWD_ENDOR.sql

@@ -46,5 +46,5 @@ select
               end  as varchar )   as  coinsrate            -- 系数
 from  XF_ODS.XF_ODS_KAFKA.ENDOR s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
-where left(s1.productCode,2) ='05'
+
 

XF_DWD/XF_DWD_POLICY.sql

@@ -46,7 +46,7 @@ select
     t1.LEVEL1COMCODE  -- 分公司代码
 from  XF_ODS.XF_ODS_KAFKA.POLICY s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
-where left(s1.productCode,2) ='05'
+
 
 
 

XF_DWD/XF_DWD_REGIST.sql

@@ -2,10 +2,11 @@
 select
     s1.actualData  ,
     DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss')      as log_time , -- 加工平台处理数据时间
-
+    s1.nodecode,
     t1.LEVEL1COMCODE  -- 分公司代码
 from  XF_ODS.XF_ODS_KAFKA.REGIST s1
-left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.actualData.prpPlcMainEOS[1].businessOffice = t1.COMCODE
-where left(s1.productCode,2) ='05'
+left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.actualData.prplcregist[CARDINALITY(s1.actualData.prplcregist)].deptCode = t1.COMCODE
+where s1.nodecode = 'RegistCar'
+  and substring(s1.actualData.accidentNo,3,2) = '05'