数据下发非车，修改两个取数字段，保单批单新增两个字段

ODS/DDL元数据/ENDOR.sql

@@ -132,7 +132,9 @@ ENDOR_PLCBASIC
         insurantName                , -- 非车下发_被保人名称
         insurantIdentifyType        , -- 非车下发_证件类型
         insurantIdentifyNumber        -- 非车下发_被保人统一社会信用代码
-    )
+    ),
+    handlerCode String ,        -- 寿险销售人员代码
+    handlerName String          -- 寿险销售人员名称
 )
 
 

ODS/DDL元数据/POLICY.sql

@@ -142,6 +142,8 @@ POLICY_PLCBASIC
         insurantName                , -- 非车下发_被保人名称
         insurantIdentifyType        , -- 非车下发_被保人统一社会信用代码
         insurantIdentifyNumber        -- 非车下发_证件类型
-    )
+    ),
+    handlerCode String ,        -- 寿险销售人员代码
+    handlerName String          -- 寿险销售人员名称
 
 )
\ No newline at end of file

ODS/数据同步/ODS_ENDOR.sql

@@ -43,6 +43,8 @@ select
     , businessNo                                          -- 业务单号
     , plcSales
     , plcBasic
+    , handlerCode                                            -- 寿险销售人员代码
+    , handlerName                                             -- 寿险销售人员名称
 from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
 ;
 

ODS/数据同步/ODS_POLICY.sql

@@ -52,6 +52,8 @@ select
     , plcCarShipTax
     , plcSales
     , plcBasic
+    , handlerCode                                            -- 寿险销售人员代码
+    , handlerName                                             -- 寿险销售人员名称
 from ODS.SOURCE_RMQ_POLICY_PRD.POLICY
 ;
 --

ODS/数据清洗/DUPLICK_ENDOR.sql

@@ -43,6 +43,8 @@ select
     , businessNo                                          -- 业务单号
     , plcSales
     , plcBasic
+    , handlerCode                                            -- 寿险销售人员代码
+    , handlerName                                             -- 寿险销售人员名称
 from ODS.ODS_KAFKA_FIRSTHAND.ENDOR   -- topic MQENDOR
 where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,plpEndorse.netPremiumVariation))) is not true
 

ODS/数据清洗/DUPLICK_POLICY.sql

@@ -52,6 +52,8 @@ select
     , plcCarShipTax
     , plcSales
     , plcBasic
+    , handlerCode                                            -- 寿险销售人员代码
+    , handlerName                                             -- 寿险销售人员名称
 from ODS.ODS_KAFKA_FIRSTHAND.POLICY -- topic MQPOLICY
 where DuplicateCheckingPolicyUDF(MD5(ConcatObjUDF(COALESCE(policyNo,businessNo),businessOffice,`netPremium`))) is not true
 ;

XF_DWD/XF_DWD_CAR_ENDOR.sql

@@ -44,7 +44,9 @@ select
               else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100
               end as decimal(18,4)) as varchar )   as  coinsRate      ,      -- 系数
     s1.plcSales  ,
-    s1.plcBasic
+    s1.plcBasic,
+    s1.handlerCode,                                            -- 寿险销售人员代码
+    s1.handlerName                                             -- 寿险销售人员名称
 
 from  XF_ODS.XF_ODS_KAFKA.ENDOR s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE

XF_DWD/XF_DWD_CAR_POLICY.sql

@@ -45,7 +45,9 @@ select
               else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100
               end as decimal(18,4))  as varchar )   as  coinsRate    ,        -- 系数
     s1.plcSales  ,
-    s1.plcBasic
+    s1.plcBasic,
+    s1.handlerCode,                                            -- 寿险销售人员代码
+    s1.handlerName                                             -- 寿险销售人员名称
 
 from  XF_ODS.XF_ODS_KAFKA.POLICY s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE

XF_DWD/XF_DWD_FC_ENDOR.sql

@@ -56,7 +56,9 @@ select
                   )
                end) as decimal(18,4)) as varchar )   as  coinsRate        ,    -- 系数
     s1.plcSales   ,
-    s1.plcBasic
+    s1.plcBasic ,
+    s1.handlerCode,                                            -- 寿险销售人员代码
+    s1.handlerName                                             -- 寿险销售人员名称
 from  XF_ODS.XF_ODS_KAFKA.ENDOR s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) <>'05'

XF_DWD/XF_DWD_FC_POLICY.sql

@@ -56,7 +56,9 @@ select
                     )
                end) as decimal(18,4)) as varchar )   as  coinsRate     ,       -- 系数
     s1.plcSales  ,
-    s1.plcBasic
+    s1.plcBasic ,
+    s1.handlerCode,                                            -- 寿险销售人员代码
+    s1.handlerName                                             -- 寿险销售人员名称
 from  XF_ODS.XF_ODS_KAFKA.POLICY s1
 left join XF_ODS.XF_ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
 where left(s1.productCode,2) <>'05'

XF_DWD/新核心非车险保单-FM.ftl

-{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"fcPolicy","msgName":"新核心非车险保单信息","data":[{"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"signDate":"${signDate!}" <#-- 签单日期 -->,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcBasic??>${plcBasic.insurantName!}</#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->,"amount":"${amount!}" <#-- 保额 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员代码 -->,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员名称 -->,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员代码 -->,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->}]}
+{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"fcPolicy","msgName":"新核心非车险保单信息","data":[{"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"signDate":"${signDate!}" <#-- 签单日期 -->,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"startDate":"${startTime!}" <#-- 起保时间 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"comName":"${businessOfficeName!}"  <#-- 保单归属机构名称 -->,"appliName":"<#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"insuredName":"<#if plcBasic??>${plcBasic.insurantName!}</#if>"  <#-- 被保人名称 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->,"amount":"${amount!}" <#-- 保额 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费  -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"agentNetFee":"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员代码 -->,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员名称 -->,"handlerCode":"${handlerCode!}"  <#-- 寿险销售人员代码 -->,"handlerName":"${handlerName!}"  <#-- 寿险销售人员名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->}]}
 
 
 {
@@ -32,8 +32,8 @@
 ,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->
 ,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员代码 -->
 ,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 归属业务员名称 -->
-,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员代码 -->
-,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员名称 -->
+,"handlerCode":"${handlerCode!}"  <#-- 寿险销售人员代码 -->
+,"handlerName":"${handlerName!}"  <#-- 寿险销售人员名称 -->
 ,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
 }]
 }

XF_DWD/新核心非车险批单-FM.ftl

-{"systemName": "流计算平台","systemCode": "D030","msgName": "新核心非车险批单信息","msgCode": "fcEndorse","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}","data": [{"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->,"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"uwConclueDate":"${uwConclueDate!}" <#-- "xx",//核批通过时间 -->,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 -->,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID -->,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 -->,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 投保人名称 -->,"netPremiumVariation":"<#if plpEndorse??>${plpEndorse.netPremiumVariation!}</#if>" <#-- 不含税保费变化量 -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->,"premiumVariation":"<#if plpEndorse??>${plpEndorse.premiumVariation!}</#if>" <#-- 保费变化量 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->}]}
+{"systemName": "流计算平台","systemCode": "D030","msgName": "新核心非车险批单信息","msgCode": "fcEndorse","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}","data": [{"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->,"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->,"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"channelType":"${channelType!}" <#-- 清分后渠道 -->,"uwConclueDate":"${uwConclueDate!}" <#-- "xx",//核批通过时间 -->,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 -->,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID -->,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 -->,"handlerCode":"${handlerCode!}"  <#-- 投保人名称 -->,"handlerName":"${handlerName!}"  <#-- 投保人名称 -->,"netPremiumVariation":"<#if plpEndorse??>${plpEndorse.netPremiumVariation!}</#if>" <#-- 不含税保费变化量 -->,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->,"premiumVariation":"<#if plpEndorse??>${plpEndorse.premiumVariation!}</#if>" <#-- 保费变化量 -->,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->}]}
 
 {
 "systemName": "流计算平台",
@@ -20,8 +20,8 @@
 ,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 -->
 ,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID -->
 ,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 -->
-,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员代码 -->
-,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>"  <#-- 寿险销售人员名称 -->
+,"handlerCode":"${handlerCode!}"  <#-- 寿险销售人员代码 -->
+,"handlerName":"${handlerName!}"  <#-- 寿险销售人员名称 -->
 ,"netPremiumVariation":"<#if plpEndorse??>${plpEndorse.netPremiumVariation!}</#if>" <#-- 不含税保费变化量 -->
 ,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->
 ,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->

XF_ODS/DDL元数据/ENDOR.sql

@@ -124,7 +124,9 @@ ENDOR_PLCBASIC
         insurantName                , -- 非车下发_被保人名称
         insurantIdentifyType        , -- 非车下发_被保人统一社会信用代码
         insurantIdentifyNumber        -- 非车下发_证件类型
-    )
+    ),
+    handlerCode String ,        -- 寿险销售人员代码
+    handlerName String          -- 寿险销售人员名称
 )
 
 

XF_ODS/DDL元数据/POLICY.sql

@@ -114,5 +114,7 @@ POLICY_PLCBASIC
         insurantName                , -- 非车下发_被保人名称
         insurantIdentifyType        , -- 非车下发_被保人统一社会信用代码
         insurantIdentifyNumber        -- 非车下发_证件类型
-    )
+    ),
+    handlerCode String ,        -- 寿险销售人员代码
+    handlerName String          -- 寿险销售人员名称
 )
\ No newline at end of file