初始化

CK_ODS/CK_ODS_CD_COM_ALL.sql

+-- 承保机构信息表
+-- CK_ODS_CD_COM_ALL 
+-- CK_ODS_承保机构码表
+insert into CK_ODS.CK_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 CK_ODS.CK_SOURCE_TD_PCDEVW.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 CK_ODS.CK_ODS_MYSQL.CD_COM_ALL
+
+) s2 on s1.COMCODE = s2.COMCODE and s1.MD5 = s2.MD5
+where s2.COMCODE is null
+
+;

CK_ODS/CK_ODS_CD_NEWCHNLTYPE.sql

+-- 承保分清后渠道码表
+-- CK_ODS_CD_NEWCHNLTYPE 
+-- CK_ODS_承保分清后渠道码表
+insert into CK_ODS.CK_ODS_MYSQL.CD_NEWCHNLTYPE
+select 
+NEWCHNLTYPE   ,
+NEWCHNLTYPEDESC
+from CK_ODS.CK_SOURCE_ORACLE_MOBILEBI.CD_NEWCHNLTYPE

RZ_DM/RZ_DM_QUANTILE.sql

+-- RZ_DM_QUANTILE ZB_DM_单位时间内访问时间排序
+
+
+-- 视图
+-- step1：
+-- 排序
+CREATE TEMPORARY VIEW VIEW_RZ_DM_QUANTILE AS 
+SELECT
+    d1.`applicationname`                                                 as `applicationname`
+    ,d1.`agentid`                                                        as `agentid`        
+    ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )   as `time`            
+    ,d1.`elapsed`                                                        as `elapsed`
+    ,ROW_NUMBER() OVER(PARTITION BY 
+                                d1.`applicationname`
+                                ,d1.`agentid`
+                                ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )  
+                                ORDER BY d1.`elapsed` ASC
+                )                                                      AS rownum 
+from RZ_ODS.RZ_ODS_KAFKA_RZ.RZDATA d1
+where 
+    LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm:ss') > DATEFORMAT(TIMESTAMPADD(HOUR,-1,LOCALTIMESTAMP),'yyyy-MM-dd HH:mm:ss')
+
+;
+
+
+
+-- RZ_DM_QUANTILE_AGENTID ZB_DM_单位时间内访问时间排序按应用统计
+
+insert into RZ_DM_QUANTILE_AGENTID
+SELECT
+    s1.`applicationname`    as `applicationname`
+    ,s1.`agentid`           as `agentid`        
+    ,s1.`time`              as `time`           
+    ,s1.`quantile50`        as `quantile50`     
+    ,s1.`quantile75`        as `quantile75`     
+    ,s1.`quantile95`        as `quantile95`     
+    ,s1.`quantile99`        as `quantile99`     
+    ,DateTimeToLongUDF()        as `createtime`     
+
+from(
+
+    select 
+        c1.`applicationname` as   `applicationname`                
+        ,c1.`agentid`         as   `agentid`                        
+        ,c1.`time`            as   `time`               
+        ,v1.`elapsed`         as   `quantile50`             
+        ,v2.`elapsed`         as   `quantile75`             
+        ,v3.`elapsed`         as   `quantile95`             
+        ,v4.`elapsed`         as   `quantile99`                      
+    from (
+        select 
+            d1.`applicationname`                                                    as `applicationname`
+            ,d1.`agentid`                                                           as `agentid`        
+            ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )      as `time`   
+            ,CEIL(count(1)*0.5   )                                                  as `num50`
+            ,CEIL(count(1)*0.75  )                                                  as `num75`
+            ,CEIL(count(1)*0.95  )                                                  as `num95`
+            ,CEIL(count(1)*0.99  )                                                  as `num99`
+        from RZ_ODS.RZ_ODS_KAFKA_RZ.RZDATA d1
+        where 
+            LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm:ss') > DATEFORMAT(TIMESTAMPADD(HOUR,-1,LOCALTIMESTAMP),'yyyy-MM-dd HH:mm:ss')
+        group by 
+             d1.`applicationname`                                                as `applicationname`
+            ,d1.`agentid`                                                        as `agentid`        
+            ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )   as `time`                                                                         
+    ) c1
+    left join VIEW_RZ_DM_QUANTILE v1 
+            on c1.`applicationname` = c2.`applicationname` 
+            and c1.`agentid`=c2.`agentid` 
+            and c1.`time`  = c2.`time` 
+            and c1.`num50` = c2.rownum 
+    left join VIEW_RZ_DM_QUANTILE v2 
+            on c1.`applicationname` = c2.`applicationname` 
+            and c1.`agentid`=c2.`agentid` 
+            and c1.`time`  = c2.`time` 
+            and c1.`num75` = c2.rownum     
+    left join VIEW_RZ_DM_QUANTILE v3 
+            on c1.`applicationname` = c2.`applicationname` 
+            and c1.`agentid`=c2.`agentid` 
+            and c1.`time`  = c2.`time` 
+            and c1.`num95` = c2.rownum 
+    left join VIEW_RZ_DM_QUANTILE v4 
+            on c1.`applicationname` = c2.`applicationname` 
+            and c1.`agentid`=c2.`agentid` 
+            and c1.`time`  = c2.`time` 
+            and c1.`num99` = c2.rownum 
+) s1
+;
+
+
+
+
+
+
+

RZ_DM/RZ_DM_RUNSTATUS.sql

+-- RZ_DM_RUNSTATUS RZ_DM_访问次数
+
+-- 视图
+-- step1：
+-- 接口汇总
+CREATE TEMPORARY VIEW VIEW_RZ_DM_RUNSTATUS AS 
+     s1.applicationname                                                      as `applicationname`        
+    ,s1.agentid                                                              as `agentid`                
+    ,s1.endpoint                                                             as `endpoint`               
+    ,s1.rpc                                                                  as `rpc`             
+    ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )       as `time`            
+    ,AVG(s1.elapsed   )                                                      as `averageelapsed`     
+    ,sum(1)                                                                  as `total`              
+    ,sum(if(s1.status = '200',1,0))                                          as `suctotal`           
+    ,sum(if(s1.status = '200' is not true,1,0))                              as `errortotal`         
+    ,DateTimeToLongUDF()                                                     as `createtime`       
+from RZ_ODS.RZ_ODS_KAFKA_RZ.RZDATA s1
+where 
+    LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm:ss') > DATEFORMAT(TIMESTAMPADD(HOUR,-1,LOCALTIMESTAMP),'yyyy-MM-dd HH:mm:ss')
+group by 
+     s1.applicationname  
+    ,s1.agentid          
+    ,s1.endpoint         
+    ,s1.rpc              
+    ,concat(LongTimeToStringUDF(s1.endTime,'yyyy-MM-dd HH:mm'),":00" )     
+
+-- RZ_DM_RUNSTATUS_URL RZ_DM_访问次数按地址统计
+insert into RZ_DM.RZ_DM_MYSQL.RZDATARZ_DM_RUNSTATUS_URL
+select
+     s1.`applicationname`
+    ,s1.`agentid`        
+    ,s1.`endpoint`       
+    ,s1.`rpc`            
+    ,s1.`time`           
+    ,s1.`averageelapsed` 
+    ,s1.`total`          
+    ,s1.`suctotal`       
+    ,s1.`errortotal`     
+    ,s1.`createtime`     
+from VIEW_RZ_DM_RUNSTATUS s1 
+;
+
+
+-- RZ_DM_RUNSTATUS_AGENTID RZ_DM_访问次数按应用统计
+insert into RZ_DM.RZ_DM_MYSQL.RZ_DM_RUNSTATUS_AGENTID
+select
+     s1.`applicationname`
+    ,s1.`agentid`                   
+    ,s1.`time`           
+    ,s1.`averageelapsed` 
+    ,s1.`total`          
+    ,s1.`suctotal`       
+    ,s1.`errortotal`     
+    ,s1.`createtime`     
+from VIEW_RZ_DM_RUNSTATUS s1 
+group by
+     s1.`applicationname`
+    ,s1.`agentid`                   
+    ,s1.`time`           
+    ,s1.`averageelapsed` 
+    ,s1.`total`          
+    ,s1.`suctotal`       
+    ,s1.`errortotal`     
+    ,s1.`createtime`  
+;
+
+
+-- RZ_DM_RUNSTATUS_APP RZ_DM_访问次数按集群统计
+insert into RZ_DM.RZ_DM_MYSQL.RZ_DM_RUNSTATUS_APP
+select
+     s1.`applicationname`         
+    ,s1.`time`           
+    ,s1.`averageelapsed` 
+    ,s1.`total`          
+    ,s1.`suctotal`       
+    ,s1.`errortotal`     
+    ,s1.`createtime`     
+from VIEW_RZ_DM_RUNSTATUS s1 
+group by 
+     s1.`applicationname`         
+    ,s1.`time`           
+    ,s1.`averageelapsed` 
+    ,s1.`total`          
+    ,s1.`suctotal`       
+    ,s1.`errortotal`     
+    ,s1.`createtime`  
+;

RZ_DM/元数据DDL/RZ_DM_QUANTILE_AGENTID.sql

+-- RZ_DM_QUANTILE_AGENTID ZB_DM_单位时间内访问时间排序按应用统计
+
+create table RZ_DM_QUANTILE_AGENTID(
+`applicationname`      String ,     -- 部署集群 tag 
+`agentid`              String ,     -- 应用系统 
+`time`                 String ,     -- 接口访问结束时间 主键 来源为源数据
+`quantile50`           String ,     -- 分位值50 
+`quantile75`           String ,     -- 分位值75 
+`quantile95`           String ,     -- 分位值95 
+`quantile99`           String ,     -- 分位值99 
+`createtime`           Long         -- 创建时间 
+
+)
\ No newline at end of file

RZ_DM/元数据DDL/RZ_DM_QUANTILE_APP.sql

+-- RZ_DM_QUANTILE_APP ZB_DM_单位时间内访问时间排序按集群统计
+
+create table RZ_DM_QUANTILE_APP(
+`applicationname`      String ,     -- 部署集群 tag 
+`time`                 String ,     -- 接口访问结束时间 主键 来源为源数据
+`quantile50`           String ,     -- 分位值50 
+`quantile75`           String ,     -- 分位值75 
+`quantile95`           String ,     -- 分位值95 
+`quantile99`           String ,     -- 分位值99 
+`createtime`           Long         -- 创建时间 
+
+)
\ No newline at end of file

RZ_DM/元数据DDL/RZ_DM_RUNSTATUS_AGENTID.sql

+-- RZ_DM_RUNSTATUS_AGENTID RZ_DM_访问次数按应用统计
+
+create table RZ_DM_RUNSTATUS_AGENTID(
+
+`applicationname` String ,  --  部署集群 
+`agentid`         String ,  --  应用系统 
+`time`            String ,  --  接口访问结束时间 主键 来源为源数据endTime精确到分的值 
+`averageelapsed`  String ,  --  接口平均响应时间
+`total`           String ,  --  接口访问总计
+`suctotal`        String ,  --  访问成功统计
+`errortotal`      String ,  --  访问失败统计
+`createtime`      Long      --  创建时间
+
+)
+;
\ No newline at end of file

RZ_DM/元数据DDL/RZ_DM_RUNSTATUS_APP.sql

+-- RZ_DM_RUNSTATUS_APP RZ_DM_访问次数按集群统计
+
+create table RZ_DM_RUNSTATUS_APP(
+
+`applicationname` String ,  --  部署集群 
+`time`            String ,  --  接口访问结束时间 主键 来源为源数据endTime精确到分的值 
+`averageelapsed`  String ,  --  接口平均响应时间
+`total`           String ,  --  接口访问总计
+`suctotal`        String ,  --  访问成功统计
+`errortotal`      String ,  --  访问失败统计
+`createtime`      Long      --  创建时间
+
+)
+;
\ No newline at end of file

RZ_DM/元数据DDL/RZ_DM_RUNSTATUS_URL.sql

+-- RZ_DM_RUNSTATUS_URL RZ_DM_访问次数按地址统计
+
+create table RZ_DM_RUNSTATUS_URL(
+
+applicationname  String ,  --  部署集群 
+agentid          String ,  --  应用系统 
+endpoint         String ,  --  服务地址
+rpc              String ,  --  接口地址
+time             String ,  --  接口访问结束时间 主键 来源为源数据endTime精确到分的值 
+averageelapsed   String ,  --  接口平均响应时间
+total            String ,  --  接口访问总计
+suctotal         String ,  --  访问成功统计
+errortotal       String ,  --  访问失败统计
+createtime       Long      --  创建时间
+
+)
+;
\ No newline at end of file

RZ_ODS/元数据DDL/RZ_ODS_ZRDATA.sql

+-- RZ_ODS_RZDATA RZ_ODS_日志来源业务数据
+
+create table RZDATA(
+    `applicationName`  String ,   部署集群 
+    `agentId`          String ,   应用系统 
+    `endPoint`         String ,   服务地址（ip+port） 
+    `rpc`              String ,   接口地址 
+    `startTime`        String ,   接口访问开始时间 
+    `endTime`          String ,   接口访问结束时间 
+    `elapsed`          String ,   接口响应时间 单位是ms 
+    `status`           String     接口访问状态
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司今日签单今年起保保费.sql

+-- ZB_DM_PROVQBBF ZB_DM_分公司今日签单今年起保保费
+create table ZB_DM_PROVQBBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256) ,
+    `val` decimal(18,2) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司今日签单保费.sql

+-- ZB_DM_PROVQDBF ZB_DM_分公司今日签单保费
+create table ZB_DM_PROVQDBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256) ,
+    `val` decimal(18,2) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司今日签单月底前起保保费.sql

+-- ZB_DM_PROVMONTHQBBF ZB_DM_分公司今日签单月底前起保保费
+create table ZB_DM_PROVMONTHQBBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256) ,
+    `val` decimal(18,2) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司分渠道保费.sql

+-- ZB_DM_CHNLBF_FEN ZB_DM_分公司分渠道保费
+create table ZB_DM_CHNLBF_FEN(
+    `key` varchar(256) ,
+    `hkey` varchar(256) ,
+    `val` decimal(18,2) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司分险类保费.sql

+-- ZB_DM_PROVXLBF ZB_DM_分公司分险类保费
+create table ZB_DM_PROVXLBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256) ,
+    `val` decimal(18,2) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司车险承保大单.sql

+-- ZB_DM_BIGCCITYBD ZB_DM_分公司车险承保大单
+create table ZB_DM_BIGCCITYBD (
+    `key` varchar(256) ,
+    `val` varchar(1000) ,
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_分公司非车险承保大单.sql

+-- ZB_DM_BIGFCCITYBD ZB_DM_分公司非车险承保大单
+create table ZB_DM_BIGFCCITYBD(
+    `key` varchar(256) ,
+    `val` varchar(1000) ,
+    primary key (`key`)
+
+);
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司今日签单今年起保保费.sql

+-- ZB_DM_ALLQBBF ZB_DM_总公司今日签单今年起保保费
+create table ZB_DM_ALLQBBF(
+    `key` varchar(256) ,
+    `val` decimal(18,2),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司今日签单保费.sql

+-- ZB_DM_ALLQDBF ZB_DM_总公司今日签单保费
+create table ZB_DM_ALLQDBF(
+    `key` varchar(256) ,
+    `val` decimal(18,2),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司今日签单月底前起保保费.sql

+-- ZB_DM_ALLMONTHQBBF ZB_DM_总公司今日签单月底前起保保费
+create table ZB_DM_ALLMONTHQBBF(
+    `key` varchar(256) ,
+    `val` decimal(18,2),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司分渠道保费.sql

+-- ZB_DM_CHNLBF ZB_DM_总公司分渠道保费
+create table ZB_DM_CHNLBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256),
+    `val` decimal(18,2),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司分险类保费.sql

+-- ZB_DM_ALLXLBF ZB_DM_总公司分险类保费
+create table ZB_DM_ALLXLBF(
+    `key` varchar(256) ,
+    `hkey` varchar(256),
+    `val` decimal(18,2),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司车险承保大单.sql

+-- ZB_DM_BIGCBD ZB_DM_总公司车险承保大单
+create table ZB_DM_BIGCBD(
+    `key` varchar(256) ,
+    `val` varchar(1000),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/DDL元数据/ZB_DM_总公司非车险承保大单.sql

+-- ZB_DM_BIGFCBD ZB_DM_总公司非车险承保大单
+create table ZB_DM_BIGCBD(
+    `key` varchar(256) ,
+    `val` varchar(1000),
+    primary key (`key`)
+)
+;
\ No newline at end of file

ZB_DM/ZB_DM_今日签单今年起保保费.sql

+-- ZB_DM_JRQDJNQBBF ZB_DM_今日签单今年起保保费
+-- key:allqbbf/日期
+-- 1.	保单的时间口径为： 核保时间在今天并且起保时间的年份小于等于今年
+-- 2.	批单的时间口径为： 核批通过时间在今天并且核批生效时间的年份小于等于今年。
+
+
+-- step1：
+-- 团队汇总
+CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDJNQBBF_TUANDUI AS 
+SELECT 
+     s1.`uwConclueDate`                    as `uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                    as `LEVEL1COMCODE`                 
+    ,s1.`LEVEL2COMCODE`                    as `LEVEL2COMCODE`                 
+    ,s1.`LEVEL3COMCODE`                    as `LEVEL3COMCODE`                 
+    ,s1.`LEVEL4COMCODE`                    as `LEVEL4COMCODE`                 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
+from ZB_ODS.ZB_ODS_KAFKA.ZBDATA s1
+where 
+    s1.`COMNAME` is not null
+    and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+    -- 起保时间的年份小于等于今年
+    and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
+group by 
+    s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                     
+    ,s1.`LEVEL2COMCODE`                     
+    ,s1.`LEVEL3COMCODE`                     
+    ,s1.`LEVEL4COMCODE`                     
+;
+
+
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_ALLQBBF
+select 
+    CONCAT(
+        'allqbbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_JRQDJNQBBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_PROVQBBF
+select 
+    CONCAT(
+        'provqbbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key`
+    ,s1.`LEVEL1COMCODE`                     as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_JRQDJNQBBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate` 
+    ,s1.`LEVEL1COMCODE` 
+;
\ No newline at end of file

ZB_DM/ZB_DM_今日签单保费.sql

+-- ZB_DM_JRQDBF ZB_DM_今日签单保费
+-- key:allqdbf/日期
+-- 1.	保单的时间口径为： 核保时间在今天  。
+-- 2.	批单的时间口径为： 核批通过时间在今天 。
+
+
+-- step1：
+-- 团队汇总
+CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDBF_TUANDUI AS 
+SELECT 
+     s1.`uwConclueDate`                    as `uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                    as `LEVEL1COMCODE`                 
+    ,s1.`LEVEL2COMCODE`                    as `LEVEL2COMCODE`                 
+    ,s1.`LEVEL3COMCODE`                    as `LEVEL3COMCODE`                 
+    ,s1.`LEVEL4COMCODE`                    as `LEVEL4COMCODE`                 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
+from ZB_ODS.ZB_ODS_KAFKA.ZBDATA s1
+where     
+    s1.`COMNAME` is not null
+    and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+group by 
+    s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                     
+    ,s1.`LEVEL2COMCODE`                     
+    ,s1.`LEVEL3COMCODE`                     
+    ,s1.`LEVEL4COMCODE`                     
+;
+
+-- 总公司 
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_ALLQDBF
+select 
+    CONCAT(
+        'allqdbf/'
+        ,s1.`uwConclueDate`
+    )                                      as `key`
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` 
+from VIEW_ZB_DM_JRQDBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_PROVQDBF
+select 
+    CONCAT(
+        'provqdbf/'
+        ,s1.`uwConclueDate`
+    )                                      as `key`
+    ,s1.`LEVEL1COMCODE`                    as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` 
+from VIEW_ZB_DM_JRQDBF_TUANDUI s1
+group by 
+     s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`
+;
+
+

ZB_DM/ZB_DM_今日签单月底前起保保费.sql

+-- ZB_DM_JRQDYDQQBBF ZB_DM_今日签单月底前起保保费
+-- key:allmonthqbbf/日期
+-- 1.	保单的时间口径为： 核保时间在今天并且起保时间的月份小于等于当月。
+-- 2.	批单的时间口径为： 核批通过时间在今天并且核批生效时间的月份小于等于当月。
+
+
+-- step1：
+-- 团队汇总
+CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDYDQQBBF_TUANDUI AS 
+SELECT 
+     s1.`uwConclueDate`                    as `uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                    as `LEVEL1COMCODE`                 
+    ,s1.`LEVEL2COMCODE`                    as `LEVEL2COMCODE`                 
+    ,s1.`LEVEL3COMCODE`                    as `LEVEL3COMCODE`                 
+    ,s1.`LEVEL4COMCODE`                    as `LEVEL4COMCODE`                 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
+from ZB_ODS.ZB_ODS_KAFKA.ZBDATA s1
+where 
+    s1.`COMNAME` is not null
+    and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+    -- 核保时间在今天并且起保时间的月份小于等于当月。
+    and left(s1.`startTime`,7) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM')
+group by 
+    s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`                     
+    ,s1.`LEVEL2COMCODE`                     
+    ,s1.`LEVEL3COMCODE`                     
+    ,s1.`LEVEL4COMCODE`                     
+;
+
+
+--  总公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_ALLMONTHQBBF
+select 
+    CONCAT(
+        'allmonthqbbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key`
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_JRQDYDQQBBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_PROVMONTHQBBF
+select 
+    CONCAT(
+        'provmonthqbbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key` 
+    ,s1.`LEVEL1COMCODE`                     as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_JRQDYDQQBBF_TUANDUI s1
+group by 
+     s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`
+;
+
+
+
+
+
+
+

ZB_DM/ZB_DM_分渠道保费.sql

+-- ZB_DM_FQDBF ZB_DM_分渠道保费
+-- chnlbf/日期/00000000	渠道代码
+-- 1.	保单的时间口径为： 核保时间在今天并且起保时间的年份小于等于今年
+-- 2.	批单的时间口径为： 核批通过时间在今天并且核批生效时间的年份小于等于今年。
+
+-- step1：
+-- 团队汇总
+CREATE TEMPORARY VIEW VIEW_ZB_DM_FQDBF_TUANDUI AS 
+SELECT 
+     s1.`uwConclueDate`                    as `uwConclueDate`
+    ,s1.`chnl`                             as `chnl`
+    ,s1.`LEVEL1COMCODE`                    as `LEVEL1COMCODE`                 
+    ,s1.`LEVEL2COMCODE`                    as `LEVEL2COMCODE`                 
+    ,s1.`LEVEL3COMCODE`                    as `LEVEL3COMCODE`                 
+    ,s1.`LEVEL4COMCODE`                    as `LEVEL4COMCODE`                 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
+from ZB_ODS.ZB_ODS_KAFKA.ZBDATA s1
+where 
+    s1.`COMNAME` is not null
+    and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+    -- 起保时间的年份小于等于今年
+    and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
+group by 
+    s1.`uwConclueDate`
+    ,s1.`chnl`
+    ,s1.`LEVEL1COMCODE`                     
+    ,s1.`LEVEL2COMCODE`                     
+    ,s1.`LEVEL3COMCODE`                     
+    ,s1.`LEVEL4COMCODE`                     
+;
+
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_CHNLBF
+select 
+    CONCAT(
+        'chnlbf/'
+        ,s1.`uwConclueDate`
+        ,'/00000000'
+    )                                       as `key` 
+    ,s1.`chnl`                              as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_FQDBF_TUANDUI s1
+group by 
+     s1.`uwConclueDate` 
+     ,s1.`chnl`
+
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_CHNLBF_FEN
+select 
+    CONCAT(
+        'chnlbf/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`LEVEL1COMCODE`
+    )                                       as `key`   
+    ,s1.`chnl`                              as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_FQDBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate` 
+    ,s1.`chnl`
+    ,s1.`LEVEL1COMCODE`
+;
\ No newline at end of file

ZB_DM/ZB_DM_分险类保费.sql

+-- ZB_DM_FXLBF ZB_DM_分险类保费
+-- allxlbf/日期	险类代码
+-- 1.	保单的时间口径为： 核保时间在今天并且起保时间的年份小于等于今年
+-- 2.	批单的时间口径为： 核批通过时间在今天并且核批生效时间的年份小于
+
+
+-- step1：
+-- 团队汇总
+CREATE TEMPORARY VIEW VIEW_ZB_DM_FXLBF_TUANDUI AS 
+SELECT 
+     s1.`uwConclueDate`                    as `uwConclueDate`
+    ,s1.`risk`                             as `risk`
+    ,s1.`LEVEL1COMCODE`                    as `LEVEL1COMCODE`                 
+    ,s1.`LEVEL2COMCODE`                    as `LEVEL2COMCODE`                 
+    ,s1.`LEVEL3COMCODE`                    as `LEVEL3COMCODE`                 
+    ,s1.`LEVEL4COMCODE`                    as `LEVEL4COMCODE`                 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
+from ZB_ODS.ZB_ODS_KAFKA.ZBDATA s1
+where     
+    s1.`COMNAME` is not null
+    and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
+    -- 起保时间的年份小于等于今年
+    and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
+group by 
+    s1.`uwConclueDate`
+    ,s1.`risk`
+    ,s1.`LEVEL1COMCODE`                     
+    ,s1.`LEVEL2COMCODE`                     
+    ,s1.`LEVEL3COMCODE`                     
+    ,s1.`LEVEL4COMCODE`                     
+;
+
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_ALLXLBF
+select 
+    CONCAT(
+        'allxlbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key` 
+    ,s1.`risk`                              as `hkey`
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_FXLBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate`
+    ,s1.`risk`
+
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_PROVXLBF
+select 
+    CONCAT(
+        'provxlbf/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`LEVEL1COMCODE`
+    )                                       as `key`  
+    ,s1.`risk`                              as `hkey` 
+    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val` 
+from VIEW_ZB_DM_FXLBF_TUANDUI s1
+group by 
+    s1.`uwConclueDate`
+    ,s1.`risk`
+    ,s1.`LEVEL1COMCODE`
+
+;
\ No newline at end of file

ZB_DM/ZB_DM_车险承保大单.sql

+-- ZB_DM_CXCBDD ZB_DM_车险承保大单
+-- bigcbd/日期
+-- 核保或者核批时间在今天，按照保费或者未决赔款排序，取前10，车险riskcode 05开头，其他为非车，
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_BIGCBD
+select 
+    CONCAT(
+        'bigcbd/'
+        ,s1.`uwConclueDate`
+    )                      as `key` 
+    ,CastToJsonArrayUDF(
+        listagg(concat(
+             'com'      ,':'  ,`com`      ,','
+            ,'comname'  ,':'  ,`comname`  ,','
+            ,'risk'     ,':'  ,`risk`     ,','
+            ,'riskname' ,':'  ,`riskname` ,','
+            ,'chnl'     ,':'  ,`chnl`     ,','
+            ,'chnlname' ,':'  ,`chnlname` ,','
+            ,'cost'     ,':'  ,`cost`     ,','
+            ,'no'       ,':'  ,`no`
+        ),';')
+    )                      as `val` 
+from (
+    select
+        *
+    from(
+        select
+            d1.`uwConclueDate`                      as `uwConclueDate`
+            ,d1.`LEVEL1COMCODE`                     as `com`
+            ,d1.`LEVEL1COMDESC`                     as `comname`
+            ,d1.`risk`                              as `risk`
+            ,d1.`riskname`                          as `riskname`
+            ,d1.`chnl`                              as `chnl`
+            ,d1.`chnlname`                          as `chnlname`
+            ,d1.`cost`                              as `cost`
+            ,d1.`no`                                as `no`
+            ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum 
+        from ZB_ODS.ZB_ODS_KAFKA.ZBDATA d1
+        where 
+            d1.`COMNAME` is not null
+            and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') 
+            and LEFT(d1.`risk`,2) = '05'
+    ) c1
+    where c1.rownum <= 20 
+    ORDER by 
+        c1.`cost`
+        asc
+) s1
+group by 
+    s1.`uwConclueDate`
+
+
+;
+
+
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_BIGCCITYBD
+select 
+    CONCAT(
+        'bigccitybd/' 
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+    )                      as `key` 
+    ,CastToJsonArrayUDF(
+        listagg(concat(
+             'com'      ,':'  ,`com`      ,','
+            ,'comname'  ,':'  ,`comname`  ,','
+            ,'risk'     ,':'  ,`risk`     ,','
+            ,'riskname' ,':'  ,`riskname` ,','
+            ,'chnl'     ,':'  ,`chnl`     ,','
+            ,'chnlname' ,':'  ,`chnlname` ,','
+            ,'cost'     ,':'  ,`cost`     ,','
+            ,'no'       ,':'  ,`no`
+        ),';')
+    )                      as `val` 
+from (
+    select
+        *
+    from (
+        select
+             d1.`uwConclueDate`                     as `uwConclueDate`
+            ,d1.`LEVEL1COMCODE`                     as `group_com`
+            ,d1.`LEVEL2COMCODE`                     as `com`
+            ,d1.`LEVEL2COMDESC`                     as `comname`
+            ,d1.`risk`                              as `risk`
+            ,d1.`riskname`                          as `riskname`
+            ,d1.`chnl`                              as `chnl`
+            ,d1.`chnlname`                          as `chnlname`
+            ,d1.`cost`                              as `cost`
+            ,d1.`no`                                as `no`
+            ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum 
+        from ZB_ODS.ZB_ODS_KAFKA.ZBDATA d1
+        where 
+            d1.`COMNAME` is not null
+            and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') 
+            and LEFT(d1.`risk`,2) = '05'
+    ) c1
+    where c1.rownum <= 20 
+    ORDER by 
+        c1.`cost`
+        asc
+) s1
+group by 
+    s1.`uwConclueDate`
+    ,s1.`group_com`
+
+
+;
+

ZB_DM/ZB_DM_非车险承保大单.sql

+-- ZB_DM_FCXCBDD ZB_DM_非车险承保大单
+-- bigfcbd/日期
+-- 核保或者核批时间在今天，按照保费或者未决赔款排序，取前10，车险riskcode 05开头，其他为非车，
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_BIGFCBD
+select 
+    CONCAT(
+        'bigfcbd/'
+        ,s1.`uwConclueDate`
+    )                      as `key` 
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+             'com'      ,':'  ,`com`      ,','
+            ,'comname'  ,':'  ,`comname`  ,','
+            ,'risk'     ,':'  ,`risk`     ,','
+            ,'riskname' ,':'  ,`riskname` ,','
+            ,'chnl'     ,':'  ,`chnl`     ,','
+            ,'chnlname' ,':'  ,`chnlname` ,','
+            ,'cost'     ,':'  ,`cost`     ,','
+            ,'no'       ,':'  ,`no`
+        ),';')
+    )                      as `val` 
+from (
+    select
+        *
+    from(
+        select
+            d1.`uwConclueDate`                     as `uwConclueDate`
+            ,d1.`LEVEL1COMCODE`                     as `com`
+            ,d1.`LEVEL1COMDESC`                     as `comname`
+            ,d1.`risk`                              as `risk`
+            ,d1.`riskname`                          as `riskname`
+            ,d1.`chnl`                              as `chnl`
+            ,d1.`chnlname`                          as `chnlname`
+            ,d1.`cost`                              as `cost`
+            ,d1.`no`                                as `no`
+            ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) AS rownum 
+        from ZB_ODS.ZB_ODS_KAFKA.ZBDATA d1
+        where 
+            d1.`COMNAME` is not null
+            and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') 
+            and LEFT(d1.`risk`,2) <> '05'
+    ) c1
+    where c1.rownum <= 20 
+    ORDER by 
+        c1.`cost`
+        asc
+) s1
+group by 
+    s1.`uwConclueDate`
+
+
+;
+
+-- 分公司 
+insert into ZB_DM.ZB_DM_REDIS.ZB_DM_BIGFCCITYBD
+select 
+    CONCAT(
+        'bigfccitybd/' 
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+    )                      as `key` 
+    ,CastToJsonArrayUDF(
+        listagg(concat(
+             'com'      ,':'  ,`com`      ,','
+            ,'comname'  ,':'  ,`comname`  ,','
+            ,'risk'     ,':'  ,`risk`     ,','
+            ,'riskname' ,':'  ,`riskname` ,','
+            ,'chnl'     ,':'  ,`chnl`     ,','
+            ,'chnlname' ,':'  ,`chnlname` ,','
+            ,'cost'     ,':'  ,`cost`     ,','
+            ,'no'       ,':'  ,`no`
+        ),';')
+    )                      as `val` 
+from (
+    select
+        *
+    from(
+        select
+            d1.`uwConclueDate`                     as `uwConclueDate`
+            ,d1.`LEVEL1COMCODE`                     as `group_com`
+            ,d1.`LEVEL2COMCODE`                     as `com`
+            ,d1.`LEVEL2COMDESC`                     as `comname`
+            ,d1.`risk`                              as `risk`
+            ,d1.`riskname`                          as `riskname`
+            ,d1.`chnl`                              as `chnl`
+            ,d1.`chnlname`                          as `chnlname`
+            ,d1.`cost`                              as `cost`
+            ,d1.`no`                                as `no`
+            ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum 
+        from ZB_ODS.ZB_ODS_KAFKA.ZBDATA d1
+        where
+            d1.`COMNAME` is not null
+            and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') 
+            and LEFT(d1.`risk`,2) <> '05'
+    ) c1
+    where c1.rownum <= 20 
+    ORDER by 
+        c1.`cost`
+        asc
+) s1
+group by 
+    s1.`uwConclueDate`
+    ,s1.`group_com`
+
+;
\ No newline at end of file

ZB_ODS/DDL元数据/CD_COM_ALL.sql

+-- CD_COM_ALL	承保机构码表
+
+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)
+);

ZB_ODS/DDL元数据/CD_NEWCHNLTYPE.sql

+-- CD_NEWCHNLTYPE	承保分清后渠道码表
+
+create table CD_NEWCHNLTYPE
+(
+    NEWCHNLTYPE     varchar(256) not null comment '渠道代码'
+        primary key,
+    NEWCHNLTYPEDESC varchar(256) null comment '渠道名称'
+);
+

ZB_ODS/DDL元数据/CD_REALTIME_RISK.sql

+-- CD_REALTIME_RISK	承保险种码表
+
+create table CD_REALTIME_RISK
+(
+    RISKCODE  varchar(256) not null comment '险种代码'
+        primary key,
+    RISKNAME  varchar(256) null comment '险种名称',
+    CLASSCODE varchar(256) null comment '险类代码',
+    CLASSNAME varchar(256) null comment '险类名称'
+)
+;

ZB_ODS/DDL元数据/ENDOR.sql

+-- ENDOR 批单业务数据
+
+ENDOR
+ENDOR_PLPENDORSE
+ENDOR_PLPENDORSE_PLPCOMMISSIONDETAIL
+
+来源：
+{
+	"endorseNo": "6805212021411283003730001",                    -- 1 批单号
+	"businessOffice": "4112833803",                              -- 2 机构代码
+	"productCode": "0521",                                       -- 3 险种代码
+    "businessNatureCode": "b",                                   -- 4 业务来源
+	"channelType": "03",										 -- 5 渠道类型
+	"uwConclueDate": 1655346164000,                              -- 6 核批完成时间
+	"plpEndorse": {
+	    "endorseEffectiveTime": 1655395200000,					 -- 7 批单生效日期
+	    "sigAndStaExchangeRate": 0,							     -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0
+		"staCurAmountVariation": 0,                              -- 10 变化保险金额
+		"staCurPremiumVariation": 20.66,                         -- 11 不含税变化保险费
+	    "staCurNetPremiumVariation": 19.49,                      -- 12 含税变化保险费
+		"staCurTaxFeeVariation": 1.17,                           -- 13 税
+		"plpCommissionDetail": [{                                      
+		    "agentFeeVariation": 2.34,                           -- 16 份额含税手续费变化量
+			"agentNetFeeVariation": 2.34                         -- 17 份额不含税手续费变化量
+		}]                                                             
+	},                                                                 
+--	"plcSolution": [{                                                  
+--		"plcCoins": {                                                  
+--		    "coinsCalculationPercent": null                       -- 9  共保比例 车险不支持共保出单，模型有字段，但是里面没有值
+--		}                                                              
+--    }],                                                              
+	"recordClerkCode": "411422198909123920",                      -- 14 归属业务员ID
+	"recordClerkName": "李琳琳"     ,                             -- 15 归属业务员名称
+	"businessChannelCode": "03",                                  -- 27 业务渠道
+	"businessChannelName": "互动渠道"                             -- 28 业务渠道名
+}
+
+
+
+
+

ZB_ODS/DDL元数据/POLICY.sql

+-- POLICY 保单业务数据
+
+POLICY
+POLICY_PLCCAR05
+POLICY_PLCAPPLICANT
+POLICY_PLCPUBLICINSURANT
+POLICY_PLCSOLUTION
+POLICY_PLCSOLUTION_PLCRATION
+POLICY_PLCSOLUTION_PLCCOINS
+POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
+
+
+来源：
+{
+	"endorseNo": null ,                                           -- 1 批单号
+	"policyNo": "6605212022411424000406",                         -- 2 保单号
+	"businessNo": "6605212022411424000406",                       -- 3 业务号
+	"uwConclueDate": 1642141803000,                               -- 4 核保通过时间
+	"businessOffice": "4114243001",                               -- 5 保单归属机构代码
+	"businessOfficeName": "商丘市柘城县营销服务部互动业务一部",   -- 6 保单归属机构名称			
+    "productCode": "0521",                                        -- 7 险种代码
+    "businessNatureCode": "b",                                    -- 8 业务来源
+    "startTime": 1643817600000,                                   -- 9 起保时间
+    "endTime": 1675353600000,                                     -- 10 终保时间
+    "netPremium": 313.32,                                         -- 11 不含税保费
+    "premium": 332.12,                                            -- 12 含税保费
+    "plcCar05": {                                                       
+        "licensePlateNo": "豫N96A12",	                          -- 13 车牌号
+    	"frameNo": "LMVAFLFD5GA070602",                           -- 14 车架号
+    	"vehiclecode": "BHMEHAUE0001",                            -- 15 行业车型代码
+        "carBrandCode": "海马HMA7160DA4CW轿车",                   -- 16 厂牌型号
+        "newCarFlag": "0",                                        -- 17 新车标识 1:新车，0：旧车
+		"carKindCode": "A0",                                      -- 29 车辆种类代码
+		"carKindName": "客车",                                    -- 30 车辆种类名称
+		"carUserNatureCode": "8A",                                -- 31 车辆使用性质代码
+		"carUserNature": "家庭自用"                               -- 32 车辆使用性质名称
+		
+    },                                                                  
+    "plcApplicant": [
+		{                                                  
+        "customerName": "李志强"                                  -- 18 投保人名称 
+		}
+	],                                                                 
+    "plcPublicInsurant": [
+		{                                             
+        "customerName": "李强"                                  -- 19 被保人名称
+		}
+	],                                                                 
+    "newPolicyFlag": "0",                                         -- 20 新保标识 1:是，0：否
+	"autoTransrenewFlag": "0",                                    -- 21 自动续保标识 1:是，4：跨险种自动续保，0：否
+	"transferPolicyFlag": "1",                                    -- 22 转保标识1:是，0：否
+	"transrenewFlag": "0",                                        -- 23 续保标识 1:是，4：跨险种续保，0：否                            
+    "plcSolution": [{                                                   
+        "PlcRation": {                                                  
+            "artifSelfPricesRat": 0.8801                          -- 24 自主定价系数
+        },                                                              
+		"plcCoins": {                                                   
+		    "coinsCalculationPercent": null                       -- 33 共保比例 车险不支持共保出单，模型有字段，但是里面没有值
+		},                                                              
+		"plcCommissionDetail": [{                                       
+		    "agentFee": 28.2,                                     -- 36 份额含税手续费
+			"agentNetFee": 28.2                                   -- 37 份额不含税手续费
+																	    
+		}]                                                              
+    }],                                                                 
+	"saleaman": "87503064-0",                                     -- 25 代理机构代码
+	"saleamanName": "中国人寿保险股份有限公司商丘分公司",         -- 26 代理机构名称
+	"businessChannelCode": "03",                                  -- 27 业务渠道
+	"businessChannelName": "互动渠道",                            -- 28 业务渠道名
+	"recordClerkCode": "411424199510110033",					  -- 34 归属业务员ID
+    "recordClerkName": "王昊",                                    -- 35 归属业务员名称
+    "staCurAmount": 1000000,                                      -- 38 保险金额
+	"staCurTaxFee": 18.8                                          -- 39 税
+		
+}
\ No newline at end of file

ZB_ODS/DDL元数据/ZBDATA.sql

+-- ZBDATA 指标加工来源数据
+create table ZBDATA(
+ `uwConclueDate` String ,-- 核保通过时间
+ `startTime`     String ,-- 起保时间
+ `COMCODE`       String ,-- 保单归属机构代码
+ `COMNAME`       String ,-- 保单归属机构名称
+ `LEVEL1COMCODE` String ,-- 一级代码                   
+ `LEVEL2COMCODE` String ,-- 二级代码                      
+ `LEVEL3COMCODE` String ,-- 三级代码                      
+ `LEVEL4COMCODE` String ,-- 四级代码                      
+ `LEVEL5COMCODE` String ,-- 五级代码                      
+ `LEVEL1COMDESC` String ,-- 一级名称                      
+ `LEVEL2COMDESC` String ,-- 二级名称                       
+ `LEVEL3COMDESC` String ,-- 三级名称   
+ `LEVEL4COMDESC` String ,-- 四级名称 
+ `LEVEL5COMDESC` String ,-- 五级名称 
+ `risk`          String ,-- 险种代码           
+ `riskname`      String ,-- 险种代码名称                
+ `chnl`          String ,-- 业务渠道           
+ `chnlname`      String ,-- 业务渠道名称                
+ `cost`          String ,-- 含税保费            
+ `no`            String  -- 保单号       
+
+)
+;
\ No newline at end of file

ZB_ODS/ZB_ODS_CD_COM_ALL.sql

+-- ZB_ODS_CD_COM_ALL ZB_ODS_承保机构
+insert into ZB_ODS.ZB_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 ZB_ODS.ZB_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 ZB_ODS.ZB_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

ZB_ODS/ZB_ODS_CD_NEWCHNLTYPE.sql

+-- ZB_ODS_CD_NEWCHNLTYPE ZB_ODS_承保分清后渠道码表
+insert into ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE
+select 
+NEWCHNLTYPE   ,
+NEWCHNLTYPEDESC
+from ZB_ODS.ZB_SOURCE_ORACLE_MOBILEBI.CD_NEWCHNLTYPE
\ No newline at end of file

ZB_ODS/ZB_ODS_CD_REALTIME_CLASS_DEPT.sql

+-- ZB_ODS_CD_REALTIME_CLASS_DEPT ZB_ODS_险类大类码表
+insert into ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_CLASS_DEPT
+select 
+COMCODE   ,
+CLASSCODE ,
+CLASSNAME ,
+DEPTCODE  ,
+DEPTNAME  
+from ZB_ODS.ZB_SOURCE_ORACLE_MOBILEBI.CD_REALTIME_CLASS_DEPT

ZB_ODS/ZB_ODS_CD_REALTIME_RISK.sql

+-- ZB_ODS_CD_REALTIME_RISK ZB_ODS_承保险种码表
+insert into ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK
+select 
+RISKCODE    ,      
+RISKNAME    ,
+CLASSCODE   ,
+CLASSNAME
+from ZB_ODS.ZB_SOURCE_ORACLE_MOBILEBI.CD_REALTIME_RISK
\ No newline at end of file

ZB_ODS/ZB_ODS_ENDOR.sql

+-- ZB_ODS_ENDOR ZB_ODS_批单业务数据
+insert into ZB_ODS.ZB_ODS_MYSQL.TEST_ENDOR
+select
+endorseNo            as endorseNo     ,
+uwConclueDate        as uwConclueDate ,
+plpEndorse.plpCommissionDetail[1].agentNetFeeVariation as agentNetFeeVariation
+from ZB_ODS.ZB_SOURCE_RMQ_ENDOR_SIT.ENDOR
+;
\ No newline at end of file

ZB_ODS/ZB_ODS_POLICY.sql

+-- ZB_ODS_POLICY ZB_ODS_保单业务数据
+insert into ZB_ODS.ZB_ODS_MYSQL.TEST_POLICY
+select
+policyNo as policyNo ,
+plcCar05.licensePlateNo as licensePlateNo ,
+plcSolution[1].PlcRation.artifSelfPricesRat as artifSelfPricesRat
+from ZB_ODS.ZB_SOURCE_RMQ_POLICY_SIT.POLICY
+
+
+
+

ZB_ODS/ZB_ODS_ZBDATA.sql

+-- ZB_ODS_ZBDATA ZB_ODS_指标加工来源数据
+
+insert into ZB_ODS.ZB_ODS_KAFKA.ZBDATA
+select
+     e1.uwConclueDate                as `uwConclueDate`                 
+    ,e1.startTime                    as `startTime`                 
+    ,e1.businessOffice               as `COMCODE`                 
+    ,t1.COMNAME                      as `COMNAME`                 
+    ,t1.LEVEL1COMCODE                as `LEVEL1COMCODE`                 
+    ,t1.LEVEL2COMCODE                as `LEVEL2COMCODE`                 
+    ,t1.LEVEL3COMCODE                as `LEVEL3COMCODE`                 
+    ,t1.LEVEL4COMCODE                as `LEVEL4COMCODE`                 
+    ,t1.LEVEL5COMCODE                as `LEVEL5COMCODE`                 
+    ,t1.LEVEL1COMDESC                as `LEVEL1COMDESC`                 
+    ,t1.LEVEL2COMDESC                as `LEVEL2COMDESC`                 
+    ,t1.LEVEL3COMDESC                as `LEVEL3COMDESC`                  
+    ,t1.LEVEL4COMDESC                as `LEVEL4COMDESC`                  
+    ,t1.LEVEL5COMDESC                as `LEVEL5COMDESC`                  
+    ,e1.productCode                  as `risk`                 
+    ,t3.RISKNAME                     as `riskname`                 
+    ,e1.businessChannelCode          as `chnl`                 
+    ,t2.NEWCHNLTYPEDESC              as `chnlname`                 
+    ,e1.premium                      as `cost`                 
+    ,e1.policyNo                     as `no`                 
+from (
+    select
+         LongTimeToStringUDF(uwConclueDate,'yyyy-MM-dd')       as uwConclueDate        -- 核保通过时间
+        ,LongTimeToStringUDF(startTime,'yyyy-MM-dd')           as startTime            -- 起保时间
+        ,businessOffice                                        as businessOffice       -- 保单归属机构代码
+        ,productCode                                           as productCode          -- 险种代码
+        ,businessChannelCode                                   as businessChannelCode  -- 业务渠道
+        ,premium                                               as premium              -- 含税保费
+        ,policyNo                                              as policyNo             -- 保单号
+        ,'bd'                                                  as flag			       -- 保单或批单标记	
+        ,proctime                                              as proctime	 
+    from ZB_ODS.ZB_SOURCE_RMQ_POLICY_SIT.POLICY 
+    union all
+    select
+         LongTimeToStringUDF(uwConclueDate,'yyyy-MM-dd')       as uwConclueDate        -- 核保通过时间
+        ,LongTimeToStringUDF(endorseEffectiveTime,'yyyy-MM-dd')as startTime            -- 起保时间
+        ,businessOffice                                        as businessOffice       -- 保单归属机构代码
+        ,productCode                                           as productCode          -- 险种代码
+        ,businessChannelCode                                   as businessChannelCode  -- 业务渠道
+        ,plpEndorse.staCurNetPremiumVariation                  as premium              -- 含税保费
+        ,endorseNo                                             as policyNo             -- 保单号
+        ,'pd'                                                  as flag			       -- 保单或批单标记	
+        ,proctime                                              as proctime
+    from ZB_ODS.ZB_SOURCE_RMQ_ENDOR_SIT.ENDOR
+) e1
+left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL for system_time as of e1.proctime as t1 on e1.businessOffice = t1.COMCODE
+left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE for system_time as of e1.proctime as t2 on e1.businessChannelCode = t2.NEWCHNLTYPE
+left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK for system_time as of e1.proctime as t3 on e1.productCode = t3.RISKCODE
+
+
+;
+
+
+