指标计算承保字段调整

ODS/webservice代码/大屏对应字段.java

@@ -44,7 +44,7 @@
 //                }
             } else { // 纯联保
 
-                // plcCoinsBasicInformation
+                //
                 for (PlcCoinsinformationEO plcCoinsinformationEO : plcCoinsInformation) {
                     if ("1".equals(plcCoinsinformationEO.getCoinsIdentity())  **
                             && plcMain.getCoinsLinkCode().equals(plcCoinsinformationEO.getCoinsLinkCode())) { ++

ZB_CK/同步脚本/ZB_CK_KAFKA_ENDOR.sql

@@ -11,8 +11,8 @@ select
     ,sigAndStaExchangeRate                                 as sigAndStaExchangeRate
     ,coinsCode                                             as coinsCode
     ,coinsLinkCode                                         as coinsLinkCode
-    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as varchar )     as LinkCoinsRate
-    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as varchar)  as CoinsCoinsRate
+    ,JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode)    as LinkCoinsRate
+    ,sonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode',coinsCode)         as CoinsCoinsRate
     ,endorseNo                                             as endorseNo                 -- 批单号
     ,newPolicyFlag                                         as newPolicyFlag
     ,autoTransrenewFlag                                    as autoTransrenewFlag
@@ -23,5 +23,6 @@ select
     ,log_time                                              as log_time
     ,endorsePolicyTime                                     as long_endorsePolicyTime
     ,endorseTime                                           as long_endorseTime
+    ,plcSolution[1].plcCoins            as plcSolution_plcCoins
 from ODS.ODS_KAFKA.ENDOR
 -- where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd')   between '20220831' and '20220902'
\ No newline at end of file

ZB_CK/同步脚本/ZB_CK_KAFKA_POLICY.sql

@@ -11,8 +11,8 @@ select
     ,sigAndStaExchangeRate                                 as sigAndStaExchangeRate
     ,coinsCode                                             as coinsCode
     ,coinsLinkCode                                         as coinsLinkCode
-    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat)as varchar)      as LinkCoinsRate
-    ,cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation)as varchar)  as CoinsCoinsRate
+    ,JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode)    as LinkCoinsRate
+    ,sonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode',coinsCode)         as CoinsCoinsRate
     ,policyNo                                              as policyNo              -- 保单号
     ,newPolicyFlag                                         as newPolicyFlag
     ,autoTransrenewFlag                                    as autoTransrenewFlag
@@ -23,6 +23,8 @@ select
     ,log_time                                              as log_time
     ,signDate                                              as long_signDate
     ,startTime                                             as long_startTime
+    ,plcSolution[1].plcCoins            as plcSolution_plcCoins
+
 from ODS.ODS_KAFKA.POLICY -- 保单业务数据
 ;
 

ZB_ODS/ZB_ODS_CBDATA.sql

@@ -56,16 +56,16 @@ from (
                         when coinsCode = '0' then (
                             case
                                 when coinsLinkCode = '0' then 1  -- 非共保非联保
-                                else cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as decimal(18,4)) /100    -- 纯联保
+                                else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(18,4)) /100    -- 纯联保
                             end
                         )
                         else (
                             case
-                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as decimal(18,4)) /100 -- 纯共保
+                                when coinsLinkCode = '0' then cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode',coinsCode) as decimal(18,4)) /100 -- 纯共保
                                 else (
-                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode' ,coinsCode) as decimal(18,4)) /100
                                      )* (
-                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat ) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode' ,coinsLinkCode) as decimal(18,4)) /100
                                      )  -- 即联又共
                             end
                         )
@@ -100,16 +100,16 @@ from (
                         when coinsCode = '0' then (
                             case
                                 when coinsLinkCode = '0' then 1  -- 非共保非联保
-                                else cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat) as decimal(18,4)) /100    -- 纯联保
+                                else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(18,4)) /100    -- 纯联保
                             end
                         )
                         else (
                             case
-                                when coinsLinkCode = '0' then cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation ) as decimal(18,4)) /100 -- 纯共保
+                                when coinsLinkCode = '0' then cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode',coinsCode) as decimal(18,4)) /100 -- 纯共保
                                 else (
-                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcCoinsBasicInformation ) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcCoinsBasicInformation,'coinsCode' ,coinsCode) as decimal(18,4)) /100
                                      )* (
-                                        cast(JsonGetCoinsRate(plcSolution[1].plcCoins.plcLinkBasicInformat ) as decimal(18,4)) /100
+                                        cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode' ,coinsLinkCode) as decimal(18,4)) /100
                                      )  -- 即联又共
                             end
                         )