指标统计sql脚本

ZB_ODS/ZB_ODS_CBDATA.sql

 -- ZB_ODS_CBDATA ZB_ODS_指标加工承保业务数据
 -- 保费计算
 --
--- 1、非车险共保我方保费系数 = 承保保费 * plcSolution.plcCoins.plcCoinsBasicInformation.coinsRate(系数)
+-- 1、非车险共保我方保费系数 = 承保保费 * plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate(系数)
 --                    coinsRate 有值 ，系数 = coinsRate
 --                    coinsRate 无值 ，系数 = 1
 --        备注：只有在非车险共保我方保费时存在系数得字段
 -- 2、汇率换算 = 承保保费 * sigAndStaExchangeRate （汇率）
 --        备注：批单不用计算，sta开头得字段是被转过汇率得
--- 条件： 车险 或 （非车险 并且 plcSolution.plcCoins.plcCoinsBasicInformation.coinsIdentity(共保我方) =1）
+-- 条件： 车险 或 （非车险 并且 plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity(共保我方) =1）
 CREATE TEMPORARY VIEW VIEW_HIS_CBDATA AS
     select
           LongTimeToStringUDF(uwConclueDate,'yyyyMMdd')         as uwConclueDate        -- 核保通过时间
@@ -16,8 +16,8 @@ CREATE TEMPORARY VIEW VIEW_HIS_CBDATA AS
          ,productCode                                           as productCode          -- 险种代码
          ,businessChannelCode                                   as businessChannelCode  -- 业务渠道
          ,businessNatureCode                                    as businessNatureCode   -- 业务来源
-         ,cast(netPremium as decimal(18,2)) * cast(sigAndStaExchangeRate as decimal(18,2))*(case when JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsRate') is null then 1
-                                                                                                 else cast(JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsRate') AS decimal(18,2) )
+         ,cast(netPremium as decimal(18,2)) * cast(sigAndStaExchangeRate as decimal(18,2))*(case when JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsRate') is null then 1
+                                                                                                 else cast(JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsRate') AS decimal(18,2) )
                                                                                                   end  )
                                                                 as netPremium           -- 不含税保费
          ,policyNo                                              as policyNo             -- 保单号
@@ -31,7 +31,7 @@ CREATE TEMPORARY VIEW VIEW_HIS_CBDATA AS
          ,proctime                                              as proctime--         ,ROW_NUMBER() OVER(PARTITION BY policyNo,businessOffice,netPremium ORDER BY uwConclueDate DESC) as rownum
     from ZB_ODS.ZB_SOURCE_RMQ_POLICY_SIT.POLICY  -- 保单业务数据
     where `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-      and (LEFT(productCode,2)  = '05' or (LEFT(productCode,2) <> '05' and JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsIdentity') = '1'))
+      and (LEFT(productCode,2)  = '05' or (LEFT(productCode,2) <> '05' and JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsIdentity') = '1'))
     
     union all
     select
@@ -41,8 +41,8 @@ CREATE TEMPORARY VIEW VIEW_HIS_CBDATA AS
          ,productCode                                           as productCode          -- 险种代码
          ,businessChannelCode                                   as businessChannelCode  -- 业务渠道
          ,businessNatureCode                                    as businessNatureCode   -- 业务来源
-         ,cast(plpEndorse.staCurPremiumVariation as decimal(18,2))  *(case when JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsRate') is null then 1
-                                                                           else cast(JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsRate') AS decimal(18,2)  )
+         ,cast(plpEndorse.staCurPremiumVariation as decimal(18,2))  *(case when JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsRate') is null then 1
+                                                                           else cast(JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsRate') AS decimal(18,2)  )
                                                                             end  )      
                                                                 as netPremium           -- 不含税保费   ？？
          ,endorseNo                                             as policyNo             -- 批单号
@@ -57,7 +57,7 @@ CREATE TEMPORARY VIEW VIEW_HIS_CBDATA AS
     --         ,ROW_NUMBER() OVER(PARTITION BY endorseNo,businessOffice,plpEndorse.staCurPremiumVariation ORDER BY uwConclueDate DESC) as rownum
     from ZB_ODS.ZB_SOURCE_RMQ_ENDOR_SIT.ENDOR  -- 批单业务数据
     where `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-      and (LEFT(productCode,2)  = '05' or (LEFT(productCode,2) <> '05' and JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation.coinsIdentity') = '1'))
+      and (LEFT(productCode,2)  = '05' or (LEFT(productCode,2) <> '05' and JsonValueUDF(plcSolution[1].plcCoins,'plcCoinsBasicInformation[1].coinsIdentity') = '1'))
     ;
 
 insert into ZB_ODS.ZB_ODS_KAFKA.CBDATA
@@ -87,10 +87,7 @@ select
     ,s1.xxzflag                      as xxzflag                  -- 新续转标记 1是0否
     ,s1.recordClerkCode              as `id`                     -- 14 归属业务员ID
 	,s1.recordClerkName              as `name`                   -- 15 归属业务员名称
-    ,cast(s1.fcxgbwfbfxs as varchar) as fcxgbwfbfxs              -- 非车险共保我方保费系数
-from (
-    select * from VIEW_HIS_CBDATA
-) s1
+from VIEW_HIS_CBDATA s1
 left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE for system_time as of s1.proctime as t2 on s1.businessChannelCode = t2.NEWCHNLTYPE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK for system_time as of s1.proctime as t3 on s1.productCode = t3.RISKCODE
@@ -101,17 +98,3 @@ left join ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE for system_time as of s1.proctim
 
 
 
-
-uwConclueDate        
-startTime            
-businessOffice       
-productCode          
-businessChannelCode  
-businessNatureCode 
-netPremium
-policyNo             
-xxzflag              
-recordClerkCode     
-recordClerkName     
-flag			      
-proctime