指标计算承保字段调整

ODS/DDL元数据/POLICY.sql

@@ -13,8 +13,7 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
 
 -- 来源：
 (
-    sigAndStaExchangeRate       String ,                         -- 费率
-    policyCreatDate             String ,
+
 	endorseNo                   String ,                         -- 1 批单号
 	policyNo                    String ,                         -- 2 保单号
 	businessNo                  String ,                         -- 3 业务号
@@ -30,7 +29,6 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
     plcCar05  row(
          licensePlateNo              String ,                         -- 13 车牌号
     	 frameNo                     String ,                         -- 14 车架号
-    	 vehicleId                   String ,                         -- 新核心车险保单-车型
     	 vehiclecode                 String ,                         -- 15 行业车型代码
          carBrandCode                String ,                         -- 16 厂牌型号
          newCarFlag                  String ,                         -- 17 新车标识 1:新车，0：旧车
@@ -38,6 +36,7 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
 		 carKindName                 String ,                         -- 30 车辆种类名称
 		 carUserNatureCode           String ,                         -- 31 车辆使用性质代码
 		 carUserNature               String                           -- 32 车辆使用性质名称
+    	 vehicleId                   String ,                         -- 新核心车险保单-车型
 		 newVehicleFlag              String                           -- 新核心车险保单-新车标识
 		 actualvalue                 String                           -- 新核心车险保单-实际价值
     ),                                                                  
@@ -76,7 +75,9 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
     recordClerkName             String ,                         -- 35 归属业务员名称
     staCurAmount                String ,                         -- 38 保险金额
 	staCurTaxFee                String                           -- 39 税
+    policyCreatDate             String ,                         -- 保单创建时间
+    sigAndStaExchangeRate       String ,                         -- 费率
 	policySort                  String                           -- 新核心车险保单-保单种类
 	businessType                String                           -- 新核心车险保单-业务类型
-		
+
 )
\ No newline at end of file

XF_ODS/DDL元数据/CD_COM_ALL.sql

+-- CD_COM_ALL	承保机构码表
+-- oracle
+CREATE TABLE CD_COM_ALL (
+	COMCODE VARCHAR(10) primary key,
+	COMNAME VARCHAR(128),
+	LEVEL1COMCODE VARCHAR(10),
+	LEVEL2COMCODE VARCHAR(10),
+	LEVEL3COMCODE VARCHAR(10),
+	LEVEL4COMCODE VARCHAR(10),
+	LEVEL5COMCODE VARCHAR(10),
+	LEVEL1COMDESC VARCHAR(128),
+	LEVEL2COMDESC VARCHAR(128),
+	LEVEL3COMDESC VARCHAR(128),
+	LEVEL4COMDESC VARCHAR(128),
+	LEVEL5COMDESC VARCHAR(128),
+	COMLEVEL  decimal(38,0),
+	VALIDFLAG VARCHAR(1)
+);

XF_ODS/DDL元数据/CD_REALTIME_KAFKA_NEWTOPIC.sql

+-- CD_REALTIME_KAFKA_NEWTOPIC 新核心车险机构代码与topic关系表
+create table CD_REALTIME_KAFKA_NEWTOPIC
+(
+    COMCODE   varchar(20) not null,
+    TOPICNAME varchar(20) 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_ALL.sql

+-- XF_ODS_CD_COM_ALL XF_ODS_承保机构
+insert into XF_ODS.XF_ODS_MYSQL.CD_COM_ALL
+select
+s1.COMCODE        
+,s1.COMNAME        
+,s1.LEVEL1COMCODE  
+,s1.LEVEL2COMCODE  
+,s1.LEVEL3COMCODE  
+,s1.LEVEL4COMCODE  
+,s1.LEVEL5COMCODE  
+,s1.LEVEL1COMDESC  
+,s1.LEVEL2COMDESC  
+,s1.LEVEL3COMDESC  
+,s1.LEVEL4COMDESC  
+,s1.LEVEL5COMDESC  
+,s1.COMLEVEL       
+,s1.VALIDFLAG          
+from (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE  
+		,LEVEL2COMCODE  
+		,LEVEL3COMCODE  
+		,LEVEL4COMCODE  
+		,LEVEL5COMCODE  
+		,LEVEL1COMDESC  
+		,LEVEL2COMDESC  
+		,LEVEL3COMDESC  
+		,LEVEL4COMDESC  
+		,LEVEL5COMDESC  
+		,COMLEVEL       
+		,VALIDFLAG
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE  
+			,LEVEL2COMCODE  
+			,LEVEL3COMCODE  
+			,LEVEL4COMCODE  
+			,LEVEL5COMCODE  
+			,LEVEL1COMDESC  
+			,LEVEL2COMDESC  
+			,LEVEL3COMDESC  
+			,LEVEL4COMDESC  
+			,LEVEL5COMDESC  
+			,COMLEVEL       
+			,VALIDFLAG
+		))    AS MD5
+	from XF_ODS.XF_SOURCE_ORACLE_ANAREPORT11.CD_COM_ALL
+	
+) s1
+left join (
+	select
+		 COMCODE        
+		,COMNAME        
+		,LEVEL1COMCODE  
+		,LEVEL2COMCODE  
+		,LEVEL3COMCODE  
+		,LEVEL4COMCODE  
+		,LEVEL5COMCODE  
+		,LEVEL1COMDESC  
+		,LEVEL2COMDESC  
+		,LEVEL3COMDESC  
+		,LEVEL4COMDESC  
+		,LEVEL5COMDESC  
+		,COMLEVEL       
+		,VALIDFLAG
+		,MD5(ConcatObjUDF(
+			 COMCODE        
+			,COMNAME        
+			,LEVEL1COMCODE  
+			,LEVEL2COMCODE  
+			,LEVEL3COMCODE  
+			,LEVEL4COMCODE  
+			,LEVEL5COMCODE  
+			,LEVEL1COMDESC  
+			,LEVEL2COMDESC  
+			,LEVEL3COMDESC  
+			,LEVEL4COMDESC  
+			,LEVEL5COMDESC  
+			,COMLEVEL       
+			,VALIDFLAG
+		))    AS MD5
+	from XF_ODS.XF_ODS_MYSQL.CD_COM_ALL
+
+) 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_NEWTOPIC.sql

+-- XF_ODS_CD_REALTIME_KAFKA_NEWTOPIC XF_ODS_新核心车险机构代码与topic关系表
+insert into XF_ODS.XF_ODS_MYSQL.XF_ODS_CD_REALTIME_KAFKA_NEWTOPIC
+select
+    COMCODE   ,
+    TOPICNAME ,
+    USERNAME  ,
+    PWD       ,
+    COMNAME   ,
+    STATUS    ,
+    ISDOCK
+from XF_ODS.XF_SOURCE_ORACLE_MOBILEBI.CD_REALTIME_KAFKA_NEWTOPIC