指标统计sql脚本

XF_DWD/XF_DWD_REGIST.sql

@@ -5,7 +5,7 @@ select
     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.prplcregist[CARDINALITY(s1.actualData.prplcregist)].deptCode = t1.COMCODE
+left join XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM 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'
 

XF_ODS/DDL元数据/CD_COM_CLAIM.sql

+-- CD_COM_CLAIM	车险报案机构码表
+-- oracle
+CREATE TABLE CD_COM_CLAIM (
+	COMCODE VARCHAR(10) primary key,
+	COMNAME VARCHAR(128),
+	LEVEL1COMCODE VARCHAR(10),
+	LEVEL1COMDESC VARCHAR(128)
+);

XF_ODS/DDL元数据/CD_REALTIME_KAFKA_CLAIMTOPIC.sql

+-- CD_REALTIME_KAFKA_CLAIMTOPIC 车险报案机构代码与topic关系表
+create table CD_REALTIME_KAFKA_CLAIMTOPIC
+(
+    COMCODE   varchar(20) not null,
+    TOPICNAME varchar(50) null,
+    USERNAME  varchar(50) null,
+    PWD       varchar(50) null,
+    COMNAME   varchar(50) null,
+    STATUS    varchar(2)  not null,
+    ISDOCK    varchar(2)  null,
+    primary key (COMCODE, STATUS)
+);

XF_ODS/码表/XF_ODS_CD_COM_CLAIM.sql

+-- XF_ODS_CD_COM_CLAIM XF_ODS_车险报案机构
+insert into XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM
+select
+s1.COMCODE        
+,s1.COMNAME        
+,s1.LEVEL1COMCODE    
+,s1.LEVEL1COMDESC          
+from (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE   
+		,LEVEL1COMDESC  
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE   
+			,LEVEL1COMDESC  
+		))    AS MD5
+	from XF_ODS.XF_SOURCE_ORACLE_ANAREPORT11.CD_COM_CLAIM	
+) s1
+left join (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE  
+		,LEVEL1COMDESC  
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE   
+			,LEVEL1COMDESC  
+		))    AS MD5
+	from XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM
+    ) s2 on s1.COMCODE = s2.COMCODE and s1.MD5 = s2.MD5
+where s2.COMCODE is null
\ No newline at end of file

XF_ODS/码表/XF_ODS_CD_REALTIME_KAFKA_CLAIMTOPIC.sql

+-- XF_ODS_CD_REALTIME_KAFKA_CLAIMTOPIC XF_ODS_车险报案机构代码与topic关系表
+insert into XF_ODS.XF_ODS_MYSQL.CD_REALTIME_KAFKA_CLAIMTOPIC
+select
+    COMCODE   ,
+    TOPICNAME ,
+    USERNAME  ,
+    PWD       ,
+    COMNAME   ,
+    STATUS    ,
+    ISDOCK
+from XF_ODS.XF_SOURCE_ORACLE_MOBILEBI.CD_REALTIME_KAFKA_CLAIMTOPIC
\ No newline at end of file