Commit 261c373f authored by 王东's avatar 王东

指标计算承保字段调整

parent d8e1a640
...@@ -14,6 +14,8 @@ ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL ...@@ -14,6 +14,8 @@ ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL
ENDOR_PLCCAR05 ENDOR_PLCCAR05
ENDOR_PLCAPPLICANT ENDOR_PLCAPPLICANT
ENDOR_PLCPUBLICINSURANT ENDOR_PLCPUBLICINSURANT
ENDOR_PLCSALES
来源: 来源:
( (
...@@ -116,7 +118,13 @@ ENDOR_PLCPUBLICINSURANT ...@@ -116,7 +118,13 @@ ENDOR_PLCPUBLICINSURANT
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保 coinsCode String , -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保
coinsLinkCode String , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联 coinsLinkCode String , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联
actualId String , -- 指标新增_唯一标识需验证 actualId String , -- 指标新增_唯一标识需验证
businessNo String -- 业务单号 businessNo String , -- 业务单号
plcSales array<row(
handlerCode String , -- 寿险销售人员代码
handlerName String , -- 寿险销售人员名称
salesmanCode String , -- 归属业务员代码
salesmanCodeName String -- 归属业务员名称
)>
) )
......
...@@ -12,6 +12,7 @@ POLICY_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT ...@@ -12,6 +12,7 @@ POLICY_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT
POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
POLICY_PLCCAROWNERS POLICY_PLCCAROWNERS
POLICY_PLCCARSHIPTAX POLICY_PLCCARSHIPTAX
POLICY_PLCSALES
-- 来源: -- 来源:
...@@ -129,6 +130,12 @@ POLICY_PLCCARSHIPTAX ...@@ -129,6 +130,12 @@ POLICY_PLCCARSHIPTAX
-- ) , -- ) ,
plcCarShipTax row( plcCarShipTax row(
delayPayTax String -- 质量校验_滞纳金总额 delayPayTax String -- 质量校验_滞纳金总额
) ),
plcSales array<row(
handlerCode String , -- 寿险销售人员代码
handlerName String , -- 寿险销售人员名称
salesmanCode String , -- 归属业务员代码
salesmanCodeName String -- 归属业务员名称
)>
) )
\ No newline at end of file
-- ODS_ENDOR ODS_批单业务数据 -- ODS_ENDOR ODS_批单业务数据
insert into ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR insert into ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR
select select
endorseNo , -- 1 批单号 endorseNo -- 1 批单号
businessOffice , -- 新核心车险批单-保单归属机构代码 , businessOffice -- 新核心车险批单-保单归属机构代码
productCode , -- 新核心车险批单-险种代码 , productCode -- 新核心车险批单-险种代码
businessNatureCode , -- 新核心车险批单-业务来源 , businessNatureCode -- 新核心车险批单-业务来源
channelType , -- 5 渠道类型 , channelType -- 5 渠道类型
uwConclueDate , -- 6 核批完成时间 , uwConclueDate -- 6 核批完成时间
plpEndorse , , plpEndorse
recordClerkCode , -- 14 归属业务员ID , recordClerkCode -- 14 归属业务员ID
recordClerkName , -- 15 归属业务员名称 , recordClerkName -- 15 归属业务员名称
businessChannelCode , -- 27 新核心车险批单-清分后渠道 , businessChannelCode -- 27 新核心车险批单-清分后渠道
businessChannelName , -- 28 业务渠道名 , businessChannelName -- 28 业务渠道名
newPolicyFlag , -- 20 新核心车险批单-新保标识 1:是,0:否 , newPolicyFlag -- 20 新核心车险批单-新保标识 1:是,0:否
autoTransrenewFlag , -- 21 新核心车险批单-自动续保标识 1:是,4:跨险种自动续保,0:否 , autoTransrenewFlag -- 21 新核心车险批单-自动续保标识 1:是,4:跨险种自动续保,0:否
transferPolicyFlag , -- 22 新核心车险批单-转保标识1:是,0:否 , transferPolicyFlag -- 22 新核心车险批单-转保标识1:是,0:否
transrenewFlag , -- 23 新核心车险批单-续保标识 1:是,4:跨险种续保,0:否 , transrenewFlag -- 23 新核心车险批单-续保标识 1:是,4:跨险种续保,0:否
policyCreatDate , -- 新核心车险批单-核保通过时间 , policyCreatDate -- 新核心车险批单-核保通过时间
plcSolution , , plcSolution
policyNo , -- 新核心车险批单-保单号 , policyNo -- 新核心车险批单-保单号
businessOfficeName , -- 新核心车险批单-保单归属机构名称 , businessOfficeName -- 新核心车险批单-保单归属机构名称
startTime , -- 新核心车险批单-起保时间 , startTime -- 新核心车险批单-起保时间
endTime , -- 新核心车险批单-终保时间 , endTime -- 新核心车险批单-终保时间
netPremium , -- 新核心车险批单-不含税保费 , netPremium -- 新核心车险批单-不含税保费
premium , -- 新核心车险批单-含税保费 , premium -- 新核心车险批单-含税保费
plcCar05 , , plcCar05
plcApplicant , , plcApplicant
plcPublicInsurant , , plcPublicInsurant
saleaman , -- 新核心车险批单-代理机构代码 , saleaman -- 新核心车险批单-代理机构代码
saleamanName , -- 新核心车险批单-代理机构名称 , saleamanName -- 新核心车险批单-代理机构名称
policySort , -- 新核心车险批单-保单种类 , policySort -- 新核心车险批单-保单种类
sigAndStaExchangeRate , -- 8 到人民币汇率 除了粤港车,车险没有存汇率,模型默认0 , sigAndStaExchangeRate -- 8 到人民币汇率 除了粤港车,车险没有存汇率,模型默认0
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间 , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
signDate , -- 指标新增_保单统计日期 , signDate -- 指标新增_保单统计日期
endorseTime , -- 指标新增_批单计算起保时间 , endorseTime -- 指标新增_批单计算起保时间
mainSalesmanCode , -- 指标新增_归属业务员ID , mainSalesmanCode -- 指标新增_归属业务员ID
mainSalesmanName , -- 指标新增_归属业务员名称 , mainSalesmanName -- 指标新增_归属业务员名称
coinsCode , -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保 , coinsCode -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保
coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联 , coinsLinkCode -- 指标新增_联保标志代码 0 非联保 3,主联,4从联
actualId , -- 指标新增_唯一标识需验证 , actualId -- 指标新增_唯一标识需验证
businessNo -- 业务单号 , businessNo -- 业务单号
, plcSales
from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
; ;
......
...@@ -50,7 +50,7 @@ select ...@@ -50,7 +50,7 @@ select
, conTerReasons -- 质量校验_保单终止原因代码 , conTerReasons -- 质量校验_保单终止原因代码
-- , plcCarowners -- , plcCarowners
, plcCarShipTax , plcCarShipTax
, plcSales
from ODS.SOURCE_RMQ_POLICY_PRD.POLICY from ODS.SOURCE_RMQ_POLICY_PRD.POLICY
; ;
-- --
......
-- DUPLICK_ENDOR DUPLICK_批单业务数据 -- DUPLICK_ENDOR DUPLICK_批单业务数据
insert into ODS.ODS_KAFKA.ENDOR -- topic ENDOR insert into ODS.ODS_KAFKA.ENDOR -- topic ENDOR
select select
endorseNo , -- 1 批单号 endorseNo -- 1 批单号
businessOffice , -- 新核心车险批单-保单归属机构代码 , businessOffice -- 新核心车险批单-保单归属机构代码
productCode , -- 新核心车险批单-险种代码 , productCode -- 新核心车险批单-险种代码
businessNatureCode , -- 新核心车险批单-业务来源 , businessNatureCode -- 新核心车险批单-业务来源
channelType , -- 5 渠道类型 , channelType -- 5 渠道类型
uwConclueDate , -- 6 核批完成时间 , uwConclueDate -- 6 核批完成时间
plpEndorse , , plpEndorse
recordClerkCode , -- 14 归属业务员ID , recordClerkCode -- 14 归属业务员ID
recordClerkName , -- 15 归属业务员名称 , recordClerkName -- 15 归属业务员名称
businessChannelCode , -- 27 新核心车险批单-清分后渠道 , businessChannelCode -- 27 新核心车险批单-清分后渠道
businessChannelName , -- 28 业务渠道名 , businessChannelName -- 28 业务渠道名
newPolicyFlag , -- 20 新核心车险批单-新保标识 1:是,0:否 , newPolicyFlag -- 20 新核心车险批单-新保标识 1:是,0:否
autoTransrenewFlag , -- 21 新核心车险批单-自动续保标识 1:是,4:跨险种自动续保,0:否 , autoTransrenewFlag -- 21 新核心车险批单-自动续保标识 1:是,4:跨险种自动续保,0:否
transferPolicyFlag , -- 22 新核心车险批单-转保标识1:是,0:否 , transferPolicyFlag -- 22 新核心车险批单-转保标识1:是,0:否
transrenewFlag , -- 23 新核心车险批单-续保标识 1:是,4:跨险种续保,0:否 , transrenewFlag -- 23 新核心车险批单-续保标识 1:是,4:跨险种续保,0:否
policyCreatDate , -- 新核心车险批单-核保通过时间 , policyCreatDate -- 新核心车险批单-核保通过时间
plcSolution , , plcSolution
policyNo , -- 新核心车险批单-保单号 , policyNo -- 新核心车险批单-保单号
businessOfficeName , -- 新核心车险批单-保单归属机构名称 , businessOfficeName -- 新核心车险批单-保单归属机构名称
startTime , -- 新核心车险批单-起保时间 , startTime -- 新核心车险批单-起保时间
endTime , -- 新核心车险批单-终保时间 , endTime -- 新核心车险批单-终保时间
netPremium , -- 新核心车险批单-不含税保费 , netPremium -- 新核心车险批单-不含税保费
premium , -- 新核心车险批单-含税保费 , premium -- 新核心车险批单-含税保费
plcCar05 , , plcCar05
plcApplicant , , plcApplicant
plcPublicInsurant , , plcPublicInsurant
saleaman , -- 新核心车险批单-代理机构代码 , saleaman -- 新核心车险批单-代理机构代码
saleamanName , -- 新核心车险批单-代理机构名称 , saleamanName -- 新核心车险批单-代理机构名称
policySort , -- 新核心车险批单-保单种类 , policySort -- 新核心车险批单-保单种类
sigAndStaExchangeRate , -- 8 到人民币汇率 除了粤港车,车险没有存汇率,模型默认0 , sigAndStaExchangeRate -- 8 到人民币汇率 除了粤港车,车险没有存汇率,模型默认0
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间 , DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
signDate , -- 指标新增_保单统计日期 , signDate -- 指标新增_保单统计日期
endorseTime , -- 指标新增_批单计算起保时间 , endorseTime -- 指标新增_批单计算起保时间
mainSalesmanCode , -- 指标新增_归属业务员ID , mainSalesmanCode -- 指标新增_归属业务员ID
mainSalesmanName , -- 指标新增_归属业务员名称 , mainSalesmanName -- 指标新增_归属业务员名称
coinsCode , -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保 , coinsCode -- 指标新增_共保标识代码 0 非共保 1,主共,2从共,车险无共保,仅有联保
coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联 , coinsLinkCode -- 指标新增_联保标志代码 0 非联保 3,主联,4从联
actualId , -- 指标新增_唯一标识需验证 , actualId -- 指标新增_唯一标识需验证
businessNo -- 业务单号 , businessNo -- 业务单号
, plcSales
from ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR from ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR
where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,plpEndorse.netPremiumVariation))) is not true where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,plpEndorse.netPremiumVariation))) is not true
......
...@@ -50,7 +50,7 @@ select ...@@ -50,7 +50,7 @@ select
, conTerReasons -- 质量校验_保单终止原因代码 , conTerReasons -- 质量校验_保单终止原因代码
-- , plcCarowners -- , plcCarowners
, plcCarShipTax , plcCarShipTax
, plcSales
from ODS.ODS_KAFKA_FIRSTHAND.POLICY -- topic MQPOLICY from ODS.ODS_KAFKA_FIRSTHAND.POLICY -- topic MQPOLICY
where DuplicateCheckingPolicyUDF(MD5(ConcatObjUDF(COALESCE(policyNo,businessNo),businessOffice,`netPremium`))) is not true where DuplicateCheckingPolicyUDF(MD5(ConcatObjUDF(COALESCE(policyNo,businessNo),businessOffice,`netPremium`))) is not true
; ;
......
...@@ -19,7 +19,7 @@ from ( ...@@ -19,7 +19,7 @@ from (
,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss') as `time` ,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss') as `time`
,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接 ,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接
,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime` ,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime`
from RZ_ODS.RZ_ODS_KAFKA.RZDATA d1 from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA d1
where where
UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS') UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS')
and UPPER(RIGHT(d1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR') and UPPER(RIGHT(d1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR')
...@@ -49,7 +49,7 @@ from ( ...@@ -49,7 +49,7 @@ from (
,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss') as `time` ,DATE_FORMAT(tumble_end(d1.row_time, interval '1' minute) ,'yyyy-MM-dd HH:mm:ss') as `time`
,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接 ,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接
,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime` ,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime`
from RZ_ODS.RZ_ODS_KAFKA.RZDATA d1 from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA d1
where where
UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS') UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS')
and UPPER(RIGHT(d1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR') and UPPER(RIGHT(d1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR')
......
...@@ -13,7 +13,7 @@ select ...@@ -13,7 +13,7 @@ select
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal` ,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal` ,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime` ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime`
from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1 from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
where where
UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS') UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS')
and UPPER(RIGHT(s1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR') and UPPER(RIGHT(s1.`rpc`,4)) not in ('.JPG','.ICO','.CSS','.TTF','.PNG','.PNG','.JPG','.TXT','.MP4','.MP3','.PDF','.DWR')
...@@ -39,7 +39,7 @@ select ...@@ -39,7 +39,7 @@ select
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal` ,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal` ,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime` ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime`
from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1 from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
group by group by
s1.applicationName s1.applicationName
,s1.agentId ,s1.agentId
...@@ -57,7 +57,7 @@ select ...@@ -57,7 +57,7 @@ select
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal` ,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal` ,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime` ,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime`
from RZ_ODS.RZ_ODS_KAFKA.RZDATA s1 from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
group by group by
s1.applicationName s1.applicationName
,tumble(s1.row_time, interval '1' minute) ,tumble(s1.row_time, interval '1' minute)
......
...@@ -41,7 +41,7 @@ select ...@@ -41,7 +41,7 @@ select
s1.businessNo , -- 业务单号 s1.businessNo , -- 业务单号
t1.LEVEL1COMCODE , -- 分公司代码 t1.LEVEL1COMCODE , -- 分公司代码
cast((case when coinsCode = '0' then ( cast(cast((case when coinsCode = '0' then (
case when coinsLinkCode = '0' then 1 case when coinsLinkCode = '0' then 1
else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100 else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100
end ) end )
...@@ -54,7 +54,8 @@ select ...@@ -54,7 +54,8 @@ select
) -- 即联又共 ) -- 即联又共
end end
) )
end) as varchar ) as coinsRate -- 系数 end) as decimal(18,4)) as varchar ) as coinsRate , -- 系数
s1.plcSales
from XF_ODS.XF_ODS_KAFKA.ENDOR s1 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 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' where left(s1.productCode,2) <>'05'
......
...@@ -40,7 +40,7 @@ select ...@@ -40,7 +40,7 @@ select
s1.coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联 s1.coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3,主联,4从联
s1.amount , -- 指标新增_保额 s1.amount , -- 指标新增_保额
s1.actualId , -- 指标新增_唯一标识需验证 s1.actualId , -- 指标新增_唯一标识需验证
cast((case when coinsCode = '0' then ( cast(cast((case when coinsCode = '0' then (
case when coinsLinkCode = '0' then 1 case when coinsLinkCode = '0' then 1
else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100 else cast(JsonGetCoinsRateUDF(plcSolution[1].plcCoins.plcLinkBasicInformat,'coinsLinkCode',coinsLinkCode) as decimal(30,4)) /100
end ) end )
...@@ -53,8 +53,9 @@ select ...@@ -53,8 +53,9 @@ select
) -- 即联又共 ) -- 即联又共
end end
) )
end) as varchar ) as coinsRate , -- 系数 end) as decimal(18,4)) as varchar ) as coinsRate , -- 系数
t1.LEVEL1COMCODE -- 分公司代码 t1.LEVEL1COMCODE , -- 分公司代码
s1.plcSales
from XF_ODS.XF_ODS_KAFKA.POLICY s1 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 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' where left(s1.productCode,2) <>'05'
......
...@@ -8,8 +8,7 @@ ...@@ -8,8 +8,7 @@
"msgCode":"carpolicy", "msgCode":"carpolicy",
"msgName":"新核心车险保单信息", "msgName":"新核心车险保单信息",
"data":[{ "data":[{
"policyNo":"${policyNo!}" <#-- 保单号 --> "policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->
,"businessNo":"${businessNo!}" <#-- 业务号 -->
,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 --> ,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->
,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 --> ,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->
,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 --> ,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->
......
<#-- 去除暂时不配置的 --> {"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 plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#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!}" <#-- 续保标识 -->,"classcode":"${classcode!}" <#-- 险类 -->,"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 plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#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":"${policyNo!}" <#-- 保单号 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->}]}
{ {
...@@ -9,8 +8,7 @@ ...@@ -9,8 +8,7 @@
"msgCode":"fcPolicy", "msgCode":"fcPolicy",
"msgName":"新核心非车险保单信息", "msgName":"新核心非车险保单信息",
"data":[{ "data":[{
"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 --> "transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
,"classcode":"${classcode!}" <#-- 险类 -->
,"signDate":"${signDate!}" <#-- 签单日期 --> ,"signDate":"${signDate!}" <#-- 签单日期 -->
,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 --> ,"uwConclueDate":"${uwConclueDate!}" <#-- 核保通过时间 -->
,"channelType":"${channelType!}" <#-- 清分后渠道 --> ,"channelType":"${channelType!}" <#-- 清分后渠道 -->
...@@ -31,12 +29,11 @@ ...@@ -31,12 +29,11 @@
,"sumPremium":"${netPremium!}" <#-- 不含税保费 --> ,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->
,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***--> ,"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>" <#-- 手续费不含税金额 --> ,"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":"${policyNo!}" <#-- 保单号 --> ,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->
,"salesmanCode":"${PlcSales.salesmanCode!}" <#-- 保单号 归属业务员代码 *** 新增可暂时不配置 *** --> ,"salesmanCode":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>" <#-- 归属业务员代码 -->
,"salesmanCodeName":"${PlcSales.salesmanCodeName!}" <#-- 保单号 归属业务员名称 *** 新增可暂时不配置 *** --> ,"salesmanCodeName":"<#if plcSales??><#list plcSales as s1>${s1.salesmanCodeName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>" <#-- 归属业务员名称 -->
,"handlerCode":"${PlcSales.handlerCode!}" <#-- 保单号 寿险销售人员代码 *** 新增可暂时不配置 *** --> ,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>" <#-- 寿险销售人员代码 -->
,"handlerName":"${PlcSales.handlerName!}" <#-- 保单号 寿险销售人员名称 *** 新增可暂时不配置 *** --> ,"handlerName":"<#if plcSales??><#list plcSales as s1>${s1.handlerName!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>" <#-- 寿险销售人员名称 -->
,"riskCode":"${productCode!}" <#-- "xx",//险种代码 --> ,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
}] }]
} }
<#-- 去除暂时不配置的 --> {"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!}" <#-- 归属业务员名称 -->,"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": "流计算平台", "systemName": "流计算平台",
...@@ -8,7 +7,7 @@ ...@@ -8,7 +7,7 @@
"msgCode": "fcEndorse", "msgCode": "fcEndorse",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}", "sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": [{ "data": [{
"policyNo":"${policyNo!}" <#-- "xx",//保单号 --> "policyNo":"${policyNo!}" <#-- "xx",//保单号 -->
,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 --> ,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->
,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 --> ,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->
,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 --> ,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->
...@@ -21,8 +20,8 @@ ...@@ -21,8 +20,8 @@
,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 --> ,"endorseEffectiveTime":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- "xx",//核批完成时间 -->
,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID --> ,"recordClerkCode":"${recordClerkCode!}" <#-- 归属业务员ID -->
,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 --> ,"recordClerkName":"${recordClerkName!}" <#-- 归属业务员名称 -->
,"handlerCode":"${PlcSales.handlerCode!}" <#-- 保单号 寿险销售人员代码 *** 新增可暂时不配置 *** --> ,"handlerCode":"<#if plcSales??><#list plcSales as s1>${s1.handlerCode!}<#if plcSales?size-1 gt s1?index >|</#if></#list></#if>" <#-- 寿险销售人员代码 -->
,"handlerName":"${PlcSales.handlerName!}" <#-- 保单号 寿险销售人员名称 *** 新增可暂时不配置 *** --> ,"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>" <#-- 不含税保费变化量 --> ,"netPremiumVariation":"<#if plpEndorse??>${plpEndorse.netPremiumVariation!}</#if>" <#-- 不含税保费变化量 -->
,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***--> ,"coinsRate":"${coinsRate!}" <#-- 联共保比例 *** 特殊处理 ***-->
,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 --> ,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->
......
...@@ -12,6 +12,7 @@ ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL ...@@ -12,6 +12,7 @@ ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL
ENDOR_PLCCAR05 ENDOR_PLCCAR05
ENDOR_PLCAPPLICANT ENDOR_PLCAPPLICANT
ENDOR_PLCPUBLICINSURANT ENDOR_PLCPUBLICINSURANT
ENDOR_PLCSALES
来源: 来源:
( (
...@@ -109,6 +110,13 @@ ENDOR_PLCPUBLICINSURANT ...@@ -109,6 +110,13 @@ ENDOR_PLCPUBLICINSURANT
businessNo String -- 业务单号 businessNo String -- 业务单号
LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构 LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构
coinsRate String -- 联共保系数
plcSales array<row(
handlerCode String , -- 寿险销售人员代码
handlerName String , -- 寿险销售人员名称
salesmanCode String , -- 归属业务员代码
salesmanCodeName String -- 归属业务员名称
)>
) )
......
...@@ -10,7 +10,7 @@ POLICY_PLCSOLUTION_PLCCOINS ...@@ -10,7 +10,7 @@ POLICY_PLCSOLUTION_PLCCOINS
-- POLICY_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION -- POLICY_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION
-- POLICY_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT -- POLICY_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT
POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
POLICY_PLCSALES
-- 来源: -- 来源:
( (
...@@ -101,5 +101,11 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL ...@@ -101,5 +101,11 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
actualId String -- 指标新增_唯一标识需验证 actualId String -- 指标新增_唯一标识需验证
LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构 LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构
coinsRate String -- 联共保系数
plcSales array<row(
handlerCode String , -- 寿险销售人员代码
handlerName String , -- 寿险销售人员名称
salesmanCode String , -- 归属业务员代码
salesmanCodeName String -- 归属业务员名称
)>
) )
\ No newline at end of file
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "新核心非车险批单信息",
"msgCode": "fcEndorse",
"sendTime": "2022-10-27 17:46:28",
"data": [
{
"policyNo": "6615212022110104000319",
"endorseNo": "6815212022110104000907",
"comCode": "1101048008",
"comName": "宣武支公司业务二部咨服团队",
"agentComCode": "370802196507090322",
"agentComName": "包翠兰",
"riskCode": "15210001",
"businessNature": "v",
"channelType": "08",
"uwConclueDate": "1666865520000",
"endorseEffectiveTime": "1666800000000",
"recordClerkCode": "370802198905230035",
"recordClerkName": "高翔",
"handlerCode": "",
"handlerName": "",
"netPremiumVariation": "0",
"coinsRate": "1.0000",
"newPolicyFlag": "0",
"autoTransreNewFlag": "0",
"transferPolicyFlag": "0",
"transreNewFlag": "0",
"premiumVariation": "0",
"sigAndStaExchangeRate": "1"
}
]
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment