指标统计sql脚本

ZB_CK/同步脚本/ZB_CK_KAFKA_ENDOR.sql

@@ -11,8 +11,8 @@ select
     ,sigAndStaExchangeRate                                 as sigAndStaExchangeRate
     ,coinsCode                                             as coinsCode
     ,coinsLinkCode                                         as coinsLinkCode
-    ,JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat     as varchar)) as LinkCoinsRate
-    ,JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as CoinsCoinsRate
+    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as varchar )     as LinkCoinsRate
+    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as varchar)  as CoinsCoinsRate
     ,endorseNo                                             as endorseNo                 -- 批单号
     ,newPolicyFlag                                         as newPolicyFlag
     ,autoTransrenewFlag                                    as autoTransrenewFlag

ZB_CK/同步脚本/ZB_CK_KAFKA_POLICY.sql

@@ -11,8 +11,8 @@ select
     ,sigAndStaExchangeRate                                 as sigAndStaExchangeRate
     ,coinsCode                                             as coinsCode
     ,coinsLinkCode                                         as coinsLinkCode
-    ,JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat     as varchar))  as LinkCoinsRate
-    ,JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar))  as CoinsCoinsRate
+    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat)as varchar)      as LinkCoinsRate
+    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation)as varchar)  as CoinsCoinsRate
     ,policyNo                                              as policyNo              -- 保单号
     ,newPolicyFlag                                         as newPolicyFlag
     ,autoTransrenewFlag                                    as autoTransrenewFlag

ZB_ODS/ZB_ODS_CBDATA.sql

@@ -56,16 +56,16 @@ from (
                         when coinsCode = '0' then (
                             case
                                 when coinsLinkCode = '0' then 1  -- 非共保非联保
-                                else cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as decimal(18,4)) /100    -- 纯联保
+                                else cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as decimal(18,4)) /100    -- 纯联保
                             end
                         )
                         else (
                             case
-                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as decimal(18,4)) /100 -- 纯共保
+                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as decimal(18,4)) /100 -- 纯共保
                                 else (
-                                        cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as decimal(18,4)) /100
                                      )* (
-                                        cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat ) as decimal(18,4)) /100
                                      )  -- 即联又共
                             end
                         )
@@ -100,16 +100,16 @@ from (
                         when coinsCode = '0' then (
                             case
                                 when coinsLinkCode = '0' then 1  -- 非共保非联保
-                                else cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as decimal(18,4)) /100    -- 纯联保
+                                else cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as decimal(18,4)) /100    -- 纯联保
                             end
                         )
                         else (
                             case
-                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as decimal(18,4)) /100 -- 纯共保
+                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation ) as decimal(18,4)) /100 -- 纯共保
                                 else (
-                                        cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation ) as decimal(18,4)) /100
                                      )* (
-                                        cast(JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat ) as decimal(18,4)) /100
                                      )  -- 即联又共
                             end
                         )
@@ -135,7 +135,7 @@ left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE for system_time as of s1.proctime a
 left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK for system_time as of s1.proctime as t3 on s1.productCode = t3.RISKCODE
 left join ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE for system_time as of s1.proctime as t4 on s1.businessNatureCode = t4.CODE
 -- 数据查重 入参：md5 出参：boolean 如果存在 返回true
-where DuplicateCheckingUDF(MD5(ConcatObjUDF(policyNo,businessOffice,netPremium))) is not true
+where DuplicateCheckingUDF(MD5(ConcatObjUDF(`no`,businessOffice,`cost`))) is not true
 
 ;