Skip to content

D
dataquality_doc
Commit 2803c5b7 authored by 王东's avatar 王东
Browse files
Options

指标计算承保字段调整

parent 9fe7f44d
Hide whitespace changes
Inline Side-by-side
Showing with 372 additions and 185 deletions
ODS/DDL元数据/ENDOR.sql
View file @ 2803c5b7
...@@ -6,6 +6,7 @@ ENDOR_PLPENDORSE_PLPCOMMISSIONDETAIL ...@@ -6,6 +6,7 @@ ENDOR_PLPENDORSE_PLPCOMMISSIONDETAIL
ENDOR_PLCSOLUTION ENDOR_PLCSOLUTION
ENDOR_PLCSOLUTION_PLCCOINS ENDOR_PLCSOLUTION_PLCCOINS
ENDOR_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION ENDOR_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION
ENDOR_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT
ENDOR_PLCSOLUTION_PLCRATION ENDOR_PLCSOLUTION_PLCRATION
ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL ENDOR_PLCSOLUTION_PLCCOMMISSIONDETAIL
ENDOR_PLCCAR05 ENDOR_PLCCAR05
...@@ -21,16 +22,20 @@ ENDOR_PLCPUBLICINSURANT ...@@ -21,16 +22,20 @@ ENDOR_PLCPUBLICINSURANT
channelType String , -- 5 渠道类型 channelType String , -- 5 渠道类型
uwConclueDate String , -- 6 核批完成时间 uwConclueDate String , -- 6 核批完成时间
plpEndorse row( plpEndorse row(
endorseEffectiveTime String , -- 7 批单生效日期 endorseEffectiveTime String , -- 7 批单生效日期
staCurAmountVariation String , -- 10 变化保险金额 staCurAmountVariation String , -- 10 变化保险金额
staCurPremiumVariation String , -- 11 不含税变化保险费 staCurPremiumVariation String , -- 11 不含税变化保险费
staCurNetPremiumVariation String , -- 12 含税变化保险费 staCurNetPremiumVariation String , -- 12 含税变化保险费
staCurTaxFeeVariation String , -- 13 税 staCurTaxFeeVariation String , -- 13 税
plpCommissionDetail array<row( plpCommissionDetail array<row(
agentFeeVariation String , -- 16 份额含税手续费变化量 agentFeeVariation String , -- 16 份额含税手续费变化量
agentNetFeeVariation String -- 17 份额不含税手续费变化量 agentNetFeeVariation String -- 17 份额不含税手续费变化量
)>, )>,
netPremiumVariation String -- 保费变化量 netPremiumVariation String , -- 不含税保费变化量
endorsePolicyTime String , -- 指标新增_批单指标统计日期
amountVariation String , -- 指标新增_保额变化量
premiumVariation String -- 指标新增_含税保费变化量
), ),
recordClerkCode String , -- 14 归属业务员ID recordClerkCode String , -- 14 归属业务员ID
recordClerkName String , -- 15 归属业务员名称 recordClerkName String , -- 15 归属业务员名称
...@@ -43,9 +48,17 @@ ENDOR_PLCPUBLICINSURANT ...@@ -43,9 +48,17 @@ ENDOR_PLCPUBLICINSURANT
policyCreatDate String , -- 新核心车险批单-核保通过时间 policyCreatDate String , -- 新核心车险批单-核保通过时间
plcSolution array<row( plcSolution array<row(
plcCoins row( plcCoins row(
plcCoinsBasicInformation array<row( plcCoinsBasicInformation array<row( -- 共保信息
coinsRate String , -- 非车险共保比例 coinsRate String , -- 非车险共保比例
coinsIdentity String -- 共保我方标记 = 1 时共保我方 coinsIdentity String , -- 共保我方标记 = 1 时共保我方
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
)>,
plcLinkBasicInformat array<row( -- 联保信息
coinsRate String , -- 非车险共保比例
coinsIdentity String , -- 共保我方标记 = 1 时共保我方
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
)> )>
), ),
PlcRation row( PlcRation row(
...@@ -80,8 +93,17 @@ ENDOR_PLCPUBLICINSURANT ...@@ -80,8 +93,17 @@ ENDOR_PLCPUBLICINSURANT
saleaman String, -- 新核心车险批单-代理机构代码 saleaman String, -- 新核心车险批单-代理机构代码
saleamanName String, -- 新核心车险批单-代理机构名称 saleamanName String, -- 新核心车险批单-代理机构名称
policySort String, -- 新核心车险批单-保单种类 policySort String, -- 新核心车险批单-保单种类
sigAndStaExchangeRate String -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0 sigAndStaExchangeRate String , -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0
log_time -- 加工平台处理数据时间 非json本身字段
signDate String , -- 指标新增_保单统计日期
endorseTime String , -- 指标新增_批单计算起保时间
mainSalesmanCode String , -- 指标新增_归属业务员ID
mainSalesmanName String , -- 指标新增_归属业务员名称
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String , -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
actualId String -- 指标新增_唯一标识需验证
) )
......
ODS/DDL元数据/POLICY.sql
View file @ 2803c5b7
...@@ -8,13 +8,12 @@ POLICY_PLCSOLUTION ...@@ -8,13 +8,12 @@ POLICY_PLCSOLUTION
POLICY_PLCSOLUTION_PLCRATION POLICY_PLCSOLUTION_PLCRATION
POLICY_PLCSOLUTION_PLCCOINS POLICY_PLCSOLUTION_PLCCOINS
POLICY_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION POLICY_PLCSOLUTION_PLCCOINS_PLCCOINSBASICINFORMATION
POLICY_PLCSOLUTION_PLCCOINS_PLCLINKBASICINFORMAT
POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
-- 来源： -- 来源：
( (
endorseNo String , -- 1 批单号
policyNo String , -- 2 保单号 policyNo String , -- 2 保单号
businessNo String , -- 3 业务号 businessNo String , -- 3 业务号
uwConclueDate String , -- 4 核保通过时间 uwConclueDate String , -- 4 核保通过时间
...@@ -24,8 +23,8 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL ...@@ -24,8 +23,8 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
businessNatureCode String , -- 8 业务来源 businessNatureCode String , -- 8 业务来源
startTime String , -- 9 起保时间 startTime String , -- 9 起保时间
endTime String , -- 10 终保时间 endTime String , -- 10 终保时间
netPremium String , -- 11 不含税保费 netPremium String , -- 11 不含税保费 为空时取 premium
premium String , -- 12 含税保费 premium String , -- 12 含税保费 为空时取 0
plcCar05 row( plcCar05 row(
licensePlateNo String , -- 13 车牌号 licensePlateNo String , -- 13 车牌号
frameNo String , -- 14 车架号 frameNo String , -- 14 车架号
...@@ -56,28 +55,48 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL ...@@ -56,28 +55,48 @@ POLICY_PLCSOLUTION_PLCCOMMISSIONDETAIL
artifReviewPrem String -- 新核心车险保单-总保费 artifReviewPrem String -- 新核心车险保单-总保费
), ),
plcCoins row( plcCoins row(
plcCoinsBasicInformation array<row( plcCoinsBasicInformation array<row( -- 共保信息
coinsRate String , -- 非车险共保比例
coinsIdentity String , -- 共保我方标记 = 1 时共保我方
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
)> ,
plcLinkBasicInformat array<row( -- 联保信息
coinsRate String , -- 非车险共保比例 coinsRate String , -- 非车险共保比例
coinsIdentity String -- 共保我方标记 = 1 时共保我方 coinsIdentity String , -- 共保我方标记 = 1 时共保我方
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
)> )>
), ),
plcCommissionDetail array<row( plcCommissionDetail array<row(
agentFee String , -- 36 份额含税手续费 agentFee String , -- 36 份额含税手续费
agentNetFee String -- 37 份额不含税手续费 agentNetFee String -- 37 份额不含税手续费
)> )> ,
)>, )>,
saleaman String , -- 25 代理机构代码 saleaman String , -- 25 代理机构代码
saleamanName String , -- 26 代理机构名称 saleamanName String , -- 26 代理机构名称
businessChannelCode String , -- 27 业务渠道 businessChannelCode String , -- 27 业务渠道
businessChannelName String , -- 28 业务渠道名 businessChannelName String , -- 28 业务渠道名
recordClerkCode String , -- 34 归属业务员ID recordClerkCode String , -- 34 归属业务员ID
recordClerkName String , -- 35 归属业务员名称 recordClerkName String , -- 35 归属业务员名称
staCurAmount String , -- 38 保险金额 staCurAmount String , -- 38 保险金额
staCurTaxFee String , -- 39 税 staCurTaxFee String , -- 39 税
policyCreatDate String , -- 保单创建时间 policyCreatDate String , -- 保单创建时间
sigAndStaExchangeRate String , -- 费率 sigAndStaExchangeRate String , -- 费率
policySort String , -- 新核心车险保单-保单种类 policySort String , -- 新核心车险保单-保单种类
businessType String -- 新核心车险保单-业务类型 businessType String , -- 新核心车险保单-业务类型
log_time -- 加工平台处理数据时间 非json本身字段
channelType String , -- 指标新增_渠道类型
signDate String , -- 指标新增_保单统计日期
mainSalesmanCode String , -- 指标新增_归属业务员ID
mainSalesmanName String , -- 指标新增_归属业务员名称
coinsCode String , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode String , -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
amount String , -- 指标新增_保额
actualId String -- 指标新增_唯一标识需验证
) )
\ No newline at end of file
ODS/DDL元数据/POLICY原始数据.sql
View file @ 2803c5b7
This source diff could not be displayed because it is too large. You can view the blob instead.
ODS/DDL元数据/POLICY原始数据（联保）.sql 0 → 100644
View file @ 2803c5b7
This source diff could not be displayed because it is too large. You can view the blob instead.
ODS/ODS_ENDOR.sql
View file @ 2803c5b7
...@@ -30,37 +30,20 @@ select ...@@ -30,37 +30,20 @@ select
saleaman , -- 新核心车险批单-代理机构代码 saleaman , -- 新核心车险批单-代理机构代码
saleamanName , -- 新核心车险批单-代理机构名称 saleamanName , -- 新核心车险批单-代理机构名称
policySort , -- 新核心车险批单-保单种类 policySort , -- 新核心车险批单-保单种类
sigAndStaExchangeRate -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0 sigAndStaExchangeRate , -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间
signDate , -- 指标新增_保单统计日期
endorseTime , -- 指标新增_批单计算起保时间
mainSalesmanCode , -- 指标新增_归属业务员ID
mainSalesmanName , -- 指标新增_归属业务员名称
coinsCode , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
actualId -- 指标新增_唯一标识需验证
from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
; ;
-- 批单清单MQ
insert into ODS.ODS_MYSQL.MQ_ENDOR
select
endorseNo as endorseNo --0 批单号
,LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate --1 核保通过时间 ？？
,LongTimeToStringUDF(plpEndorse.endorseEffectiveTime,'yyyyMMdd') as endorseEffectiveTime --2 起保时间
,businessOffice as businessOffice --3 保单归属机构代码
,productCode as productCode --4 险种代码
,businessChannelCode as businessChannelCode --5 业务渠道
,businessNatureCode as businessNatureCode --6 业务来源
,plpEndorse.netPremiumVariation as netPremiumVariation --7 9月2日生效 保费变化量
,sigAndStaExchangeRate as sigAndStaExchangeRate --8
,plpEndorse.staCurPremiumVariation as staCurPremiumVariation --9
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity as coinsIdentity --0
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate as coinsRate --1
,newPolicyFlag as newPolicyFlag --2
,autoTransrenewFlag as autoTransrenewFlag --3
,transferPolicyFlag as transferPolicyFlag --4
,transrenewFlag as transrenewFlag --5
,recordClerkCode as recordClerkCode --6
,LongTimeToStringUDF(policyCreatDate,'yyyyMMdd') as policyCreatDate
,uwConclueDate as long_uwConclueDate
,policyCreatDate as long_policyCreatDate
from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
ODS/ODS_POLICY.sql
View file @ 2803c5b7
-- ODS_POLICY ODS_保单业务数据 -- ODS_POLICY ODS_保单业务数据
insert into ODS.ODS_KAFKA.POLICY insert into ODS.ODS_KAFKA.POLICY
select select
endorseNo , -- 1 批单号
policyNo , -- 2 保单号 policyNo , -- 2 保单号
businessNo , -- 3 业务号 businessNo , -- 3 业务号
uwConclueDate , -- 4 核保通过时间 uwConclueDate , -- 4 核保通过时间
...@@ -32,37 +31,23 @@ select ...@@ -32,37 +31,23 @@ select
policyCreatDate , -- 保单创建时间 policyCreatDate , -- 保单创建时间
sigAndStaExchangeRate , -- 费率 sigAndStaExchangeRate , -- 费率
policySort , -- 新核心车险保单-保单种类 policySort , -- 新核心车险保单-保单种类
businessType -- 新核心车险保单-业务类型 businessType , -- 新核心车险保单-业务类型
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间
channelType , -- 指标新增_渠道类型
signDate , -- 指标新增_保单统计日期
mainSalesmanCode , -- 指标新增_归属业务员ID
mainSalesmanName , -- 指标新增_归属业务员名称
coinsCode , -- 指标新增_共保标识代码 0 非共保 1，主共，2从共,车险无共保，仅有联保
coinsLinkCode , -- 指标新增_联保标志代码 0 非联保 3，主联，4从联
amount , -- 指标新增_保额
actualId -- 指标新增_唯一标识需验证
from ODS.SOURCE_RMQ_POLICY_PRD.POLICY from ODS.SOURCE_RMQ_POLICY_PRD.POLICY
; ;
-- 保单清单MQ
insert into ODS.ODS_MYSQL.MQ_POLICY
select
policyNo as policyNo -- 0
,LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate -- 1
,LongTimeToStringUDF(startTime,'yyyyMMdd') as startTime -- 2
,businessOffice as businessOffice -- 3
,productCode as productCode -- 4
,businessChannelCode as businessChannelCode -- 5
,businessNatureCode as businessNatureCode -- 6
,netPremium as netPremium -- 7
,sigAndStaExchangeRate as sigAndStaExchangeRate -- 8
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity as coinsIdentity -- 9
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate as coinsRate -- 0
,newPolicyFlag as newPolicyFlag -- 1
,autoTransrenewFlag as autoTransrenewFlag -- 2
,transferPolicyFlag as transferPolicyFlag -- 3
,transrenewFlag as transrenewFlag -- 4
,recordClerkCode as recordClerkCode -- 5
,LongTimeToStringUDF(policyCreatDate,'yyyyMMdd') as policyCreatDate
,uwConclueDate as long_uwConclueDate
,policyCreatDate as long_policyCreatDate
from ODS.SOURCE_RMQ_POLICY_PRD.POLICY -- 保单业务数据
;
......
ODS/webservice代码/ContractBusinessEntity.java 0 → 100644
View file @ 2803c5b7
This source diff could not be displayed because it is too large. You can view the blob instead.
ODS/webservice代码/大屏对应字段.java 0 → 100644
View file @ 2803c5b7
content.put("comcode", plcMain.get BusinessOffice()); *
content.put("RiskCode", plcMain.get ProductCode()); *
content.put("BusinessNature", plcMain.get BusinessNatureCode());*
content.put("ChannelType", plcMain.get ChannelType());++
if (1 == msgType) {
content.put("UnderWriteEndDate", DateUtils.formatDate(plcMain.get SignDate(), "yyyy-MM-dd HH:mm:ss")); ++
content.put("StartDate", DateUtils.formatDate(plcMain.get StartTime(), "yyyy-MM-dd HH:mm:ss")); **
content.put("EndDate", DateUtils.formatDate(plcMain.get EndTime(), "yyyy-MM-dd HH:mm:ss")); **
} else {
// content.put("UnderWriteEndDate", DateUtils
// .formatDate((Date) plpEndorse.getProperty().get("endorseResultTime"), "yyyy-MM-dd HH:mm:ss"));
//content.put("UnderWriteEndDate", DateUtils.formatDate(plcMain.getSignDate(), "yyyy-MM-dd HH:mm:ss"));
content.put("UnderWriteEndDate", DateUtils.formatDate((Date) plpEndorse.getProperty().get("endorsePolicyTime"), "yyyy-MM-dd HH:mm:ss")); ++
content.put("ValidDate", DateUtils.formatDate(plcMain.getEndorseTime(), "yyyy-MM-dd HH:mm:ss")); ++
}
content.put("ExchangeRate", plcMain.getSigAndStaExchangeRate().toString()); **
BusinessEntity businessEntity = businessEntityService.getCachedBusinessEntity("", plcMain.getActualId()); ??
ContractBusinessEntity contractBusinessEntity = new ContractBusinessEntity(businessEntity);
// 车险非车都可能存在联保，非车可能存在共保 ，非车也可能即共又联
// 联保从 plcLinkBasicInformat 非车共保 plcCoinsBasicInformation
// 同时联保共保 plcLinkBasicInformat 拼接 plcCoinsBasicInformation
x List<PlcCoinsinformationEO> plcCoinsInformation = contractBusinessEntity.getPlcCoinsInformation();
批单 List<PlpCommissiondetailEO> plpCommissiondetailEOList = contractBusinessEntity.getPlpCommissionDetailList();
x List<PlpCoinsinformationEO> plpCoinsinformationEOList = contractBusinessEntity.getplpCoinsInformation();
x List<PlcCoinscommissionEO> plcCoinscommissionEOList = contractBusinessEntity.getCoinscommissions();
//归属业务员ID 归属业务员名称
content.put("handlercode", plcMain.getMainSalesmanCode()); ++
content.put("handlername", plcMain.getMainSalesmanName()); ++
// 份额含税手续费变化量
BigDecimal chgShareAgentFee = BigDecimal.ZERO;
BigDecimal shareAgentFee = BigDecimal.ZERO;
//纯联保则送联保比例，即共又联时送：共保比例*联保比例
if ("0".equals(plcMain.getCoinsCode())) { ++
if ("0".equals(plcMain.getCoinsLinkCode())) { ++
content.put("CoinsRate", "1");
// if (1 == msgType) {
// shareAgentFee = plcMain.getAgentFee(); ++
// } else {
// for (PlpCommissiondetailEO plpCommissiondetailEO : plpCommissiondetailEOList) {
// chgShareAgentFee = chgShareAgentFee.add(plpCommissiondetailEO.getAgentFeeVariation()); **
// }
// }
} else { // 纯联保
// plcCoinsBasicInformation
for (PlcCoinsinformationEO plcCoinsinformationEO : plcCoinsInformation) {
if ("1".equals(plcCoinsinformationEO.getCoinsIdentity()) **
&& plcMain.getCoinsLinkCode().equals(plcCoinsinformationEO.getCoinsLinkCode())) { ++
content.put("CoinsRate", (plcCoinsinformationEO.getCoinsRate().divide(BigDecimal.valueOf(100L))).toString());
// if (1 == msgType) {
// // PlcCoinscommissionEO的linkno
// // 与plcCoinsinformationEO 的SerialNo 查找关系
// for (PlcCoinscommissionEO plcCoinscommissionEO : plcCoinscommissionEOList) {
// if (plcCoinsinformationEO.getLinkNo() ++
// .equals(plcCoinscommissionEO.getLinkNo())) { ??
// shareAgentFee = plcCoinscommissionEO.getAgentFee(); **
// break;
// }
// }
// } else {
//
// for (PlpCoinsinformationEO plpCoinsinformationEO : plpCoinsinformationEOList) {
// if (plcCoinsinformationEO.getLinkNo().equals(plpCoinsinformationEO.getLinkNo())) {
// chgShareAgentFee = plpCoinsinformationEO.getAgentFeeVariation();
// break;
// }
// }
// }
}
}
}
} else {
//FIXME 联共保业务怎么传共保比例 如果有共保的话则取我方比例
if ("0".equals(plcMain.getCoinsLinkCode())) { //纯共保
for (PlcCoinsinformationEO plcCoinsinformationEO : plcCoinsInformation) {
if ("1".equals(plcCoinsinformationEO.getCoinsIdentity()) && plcMain.getCoinsCode().equals(plcCoinsinformationEO.getCoinsCode())) {
content.put("CoinsRate", (plcCoinsinformationEO.getCoinsRate().divide(BigDecimal.valueOf(100L))).toString());
// if (1 == msgType) {
// // PlcCoinscommissionEO的linkno
// // 与plcCoinsinformationEO 的SerialNo 查找关系
// for (PlcCoinscommissionEO plcCoinscommissionEO : plcCoinscommissionEOList) {
// if (plcCoinsinformationEO.getLinkNo().equals(plcCoinscommissionEO.getLinkNo())) {
// shareAgentFee = plcCoinscommissionEO.getAgentFee();
// break;
// }
// }
// } else {
//
// for (PlpCoinsinformationEO plpCoinsinformationEO : plpCoinsinformationEOList) {
// if (plcCoinsinformationEO.getLinkNo().equals(plpCoinsinformationEO.getLinkNo())) {
// chgShareAgentFee = plpCoinsinformationEO.getAgentFeeVariation();
// break;
// }
// }
// }
}
}
} else { //即联又共
BigDecimal coinsRate = null; //共保比例
BigDecimal coinsLinkRate = null; //联保比例
for (PlcCoinsinformationEO plcCoinsinformationEO : plcCoinsInformation) {
if ("1".equals(plcCoinsinformationEO.getCoinsIdentity()) && plcMain.getCoinsCode().equals(plcCoinsinformationEO.getCoinsCode())) {
coinsRate = (plcCoinsinformationEO.getCoinsRate()).divide(BigDecimal.valueOf(100L));
} else if ("1".equals(plcCoinsinformationEO.getCoinsIdentity()) && plcMain.getCoinsLinkCode().equals(plcCoinsinformationEO.getCoinsLinkCode())) {
coinsLinkRate = (plcCoinsinformationEO.getCoinsRate()).divide(BigDecimal.valueOf(100L));
// if (1 == msgType) {
// //PlcCoinscommissionEO的linkno 与plcCoinsinformationEO 的SerialNo 查找关系
// for (PlcCoinscommissionEO plcCoinscommissionEO : plcCoinscommissionEOList) {
// if (plcCoinsinformationEO.getLinkNo().equals(plcCoinscommissionEO.getLinkNo())) {
// shareAgentFee = plcCoinscommissionEO.getAgentFee();
// break;
// }
// }
// } else {
// for (PlpCoinsinformationEO plpCoinsinformationEO : plpCoinsinformationEOList) {
// if (plcCoinsinformationEO.getLinkNo().equals(plpCoinsinformationEO.getLinkNo())) {
// chgShareAgentFee = plpCoinsinformationEO.getAgentFeeVariation();
// break;
// }
// }
// }
}
}
content.put("CoinsRate", coinsRate.multiply(coinsLinkRate).toString());
}
}
if (1 == msgType) {
content.put("SumAmount", String.valueOf(plcMain.getAmount())); ++
BigDecimal premium = plcMain.getPremium(); **
if (premium == null) {
premium = BigDecimal.ZERO;
}
BigDecimal netPremium = plcMain.getNetPremium(); **
if (netPremium == null) {
netPremium = premium;
}
content.put("SumPremium", String.valueOf(netPremium));
content.put("TaxSumPremium", String.valueOf(premium));
content.put("Tax", String.valueOf(premium.subtract(netPremium)));
// 份额含税手续费 = 总手续费* 我方占有份额
content.put("shareAgentFee", shareAgentFee.toString());
} else {
// 保额变化量
BigDecimal amountVariation = (BigDecimal) plpEndorse.getProperty().get("amountVariation");
// 含税保费变化量
BigDecimal premiumVariation = (BigDecimal) plpEndorse.getProperty().get("premiumVariation");
// 不含税保费变化量
BigDecimal netPremiumVariation = (BigDecimal) plpEndorse.getProperty().get("netPremiumVariation");
if (amountVariation == null) {
amountVariation = new BigDecimal(0);
}
if (premiumVariation == null) {
premiumVariation = new BigDecimal(0);
}
if (netPremiumVariation == null) {
netPremiumVariation = premiumVariation;
}
content.put("ChgAmount", String.valueOf(amountVariation));
content.put("ChgPremium", String.valueOf(netPremiumVariation));
content.put("TaxChgPremium", String.valueOf(premiumVariation));
content.put("Tax", String.valueOf(premiumVariation.subtract(netPremiumVariation)));
content.put("chgShareAgentFee", chgShareAgentFee.toString());
}
content.put("businessChannelCode",plcMain.getBusinessChannelCode());
//存储报文太大了，不进行报文存储
//infoEO.setRequestPacket(JsonUtils.toJsonString(content,false));
infoEO.setReqTranno(plcMain.getBusinessNo());
LOGGER.error("[调用大屏实时显示系统], bs actualId[{}], 保单号[{}], 业务类型[{}], content[{}]",
plcMain.getTopId(), plcMain.getPolicyNo(), plcMain.getBusinessType(), content.toString());
\ No newline at end of file
ZB_CK/同步脚本/ZB_CK_KAFKA_CBDATA.sql
View file @ 2803c5b7
...@@ -17,7 +17,8 @@ select ...@@ -17,7 +17,8 @@ select
`cost` , `cost` ,
`no` , `no` ,
`xxzflag` , `xxzflag` ,
`id` , `id` ,
`flag` , -- 保单批单标记
log_time log_time
from ZB_ODS.ZB_ODS_KAFKA.CBDATA from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where uwConclueDate between '20220831' and '20220902' -- and COMCODE = '54000000'; -- where uwConclueDate between '20220831' and '20220902' -- and COMCODE = '54000000';
\ No newline at end of file \ No newline at end of file
ZB_CK/同步脚本/ZB_CK_KAFKA_ENDOR.sql
View file @ 2803c5b7
-- ZB_CK_KAFKA_ENDOR 批单清单KAFKA -- ZB_CK_KAFKA_ENDOR 批单清单KAFKA
insert into ZB_CK.ZB_CK_MYSQL.KAFKA_ENDOR insert into ZB_CK.ZB_CK_MYSQL.KAFKA_ENDOR
select select
endorseNo as endorseNo --0 批单号 LongTimeToStringUDF(endorsePolicyTime,'yyyyMMdd') as endorsePolicyTime -- 标记时间 endorsePolicyTime
,LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate --1 核保通过时间 ？？ ,LongTimeToStringUDF(endorseTime,'yyyyMMdd') as endorseTime -- 起保时间
,LongTimeToStringUDF(plpEndorse.endorseEffectiveTime,'yyyyMMdd') as endorseEffectiveTime --2 起保时间 ,businessOffice as businessOffice -- 保单归属机构代码
,businessOffice as businessOffice --3 保单归属机构代码 ,productCode as productCode -- 险种代码
,productCode as productCode --4 险种代码 ,businessChannelCode as businessChannelCode -- 业务渠道
,businessChannelCode as businessChannelCode --5 业务渠道 ,businessNatureCode as businessNatureCode -- 业务来源
,businessNatureCode as businessNatureCode --6 业务来源 ,plpEndorse.netPremiumVariation as netPremiumVariation
,plpEndorse.netPremiumVariation as netPremiumVariation --7 9月2日生效 保费变化量 ,sigAndStaExchangeRate as sigAndStaExchangeRate
,sigAndStaExchangeRate as sigAndStaExchangeRate --8 ,coinsCode as coinsCode
,plpEndorse.staCurPremiumVariation as staCurPremiumVariation --9 ,coinsLinkCode as coinsLinkCode
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity as coinsIdentity --0 ,cast( JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as varchar) as LinkCoinsRate
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate as coinsRate --1 ,cast( JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as varchar) as CoinsCoinsRate
,newPolicyFlag as newPolicyFlag --2 ,endorseNo as endorseNo -- 批单号
,autoTransrenewFlag as autoTransrenewFlag --3 ,newPolicyFlag as newPolicyFlag
,transferPolicyFlag as transferPolicyFlag --4 ,autoTransrenewFlag as autoTransrenewFlag
,transrenewFlag as transrenewFlag --5 ,transferPolicyFlag as transferPolicyFlag
,recordClerkCode as recordClerkCode --6 ,transrenewFlag as transrenewFlag
,LongTimeToStringUDF(policyCreatDate,'yyyyMMdd') as policyCreatDate ,mainSalesmanCode as mainSalesmanCode -- 14 归属业务员ID
,uwConclueDate as long_uwConclueDate ,mainSalesmanName as mainSalesmanName -- 15 归属业务员名称
,policyCreatDate as long_policyCreatDate ,log_time as log_time
,endorsePolicyTime as long_endorsePolicyTime
,endorseTime as long_endorseTime
from ODS.ODS_KAFKA.ENDOR from ODS.ODS_KAFKA.ENDOR
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') between '20220831' and '20220902' -- where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') between '20220831' and '20220902'
\ No newline at end of file \ No newline at end of file
ZB_CK/同步脚本/ZB_CK_KAFKA_POLICY.sql
View file @ 2803c5b7
-- ZB_CK_KAFKA_POLICY 保单清单kafka -- ZB_CK_KAFKA_POLICY 保单清单kafka
insert into ZB_CK.ZB_CK_MYSQL.KAFKA_POLICY insert into ZB_CK.ZB_CK_MYSQL.KAFKA_POLICY
select select
policyNo as policyNo -- 0 LongTimeToStringUDF(signDate,'yyyyMMdd') as signDate -- 标记时间 UnderWriteEndDate
,LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate -- 1 ,LongTimeToStringUDF(startTime,'yyyyMMdd') as startTime -- 起保时间
,LongTimeToStringUDF(startTime,'yyyyMMdd') as startTime -- 2 ,businessOffice as businessOffice -- 保单归属机构代码
,businessOffice as businessOffice -- 3 ,productCode as productCode -- 险种代码
,productCode as productCode -- 4 ,businessChannelCode as businessChannelCode -- 业务渠道
,businessChannelCode as businessChannelCode -- 5 ,businessNatureCode as businessNatureCode -- 业务来源
,businessNatureCode as businessNatureCode -- 6 ,netPremium as netPremium
,netPremium as netPremium -- 7 ,sigAndStaExchangeRate as sigAndStaExchangeRate
,sigAndStaExchangeRate as sigAndStaExchangeRate -- 8 ,coinsCode as coinsCode
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity as coinsIdentity -- 9 ,coinsLinkCode as coinsLinkCode
,plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate as coinsRate -- 0 ,cast( JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) as varchar) as LinkCoinsRate
,newPolicyFlag as newPolicyFlag -- 1 ,cast( JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) as varchar) as CoinsCoinsRate
,autoTransrenewFlag as autoTransrenewFlag -- 2 ,policyNo as policyNo -- 保单号
,transferPolicyFlag as transferPolicyFlag -- 3 ,newPolicyFlag as newPolicyFlag
,transrenewFlag as transrenewFlag -- 4 ,autoTransrenewFlag as autoTransrenewFlag
,recordClerkCode as recordClerkCode -- 5 ,transferPolicyFlag as transferPolicyFlag
,LongTimeToStringUDF(policyCreatDate,'yyyyMMdd') as policyCreatDate ,transrenewFlag as transrenewFlag
,uwConclueDate as long_uwConclueDate ,mainSalesmanCode as mainSalesmanCode -- 14 归属业务员ID
,policyCreatDate as long_policyCreatDate ,mainSalesmanName as mainSalesmanName -- 15 归属业务员名称
,log_time as log_time
,signDate as long_signDate
,startTime as long_startTime
from ODS.ODS_KAFKA.POLICY -- 保单业务数据 from ODS.ODS_KAFKA.POLICY -- 保单业务数据
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') between '20220831' and '20220902'
; ;
ZB_ODS/DDL元数据/CBDATA.sql
View file @ 2803c5b7
...@@ -28,6 +28,7 @@ create table CBDATA( ...@@ -28,6 +28,7 @@ create table CBDATA(
`xxzflag` String , -- 新续转标记 1是0否 `xxzflag` String , -- 新续转标记 1是0否
`id` String , -- 14 归属业务员ID `id` String , -- 14 归属业务员ID
`name` String ,-- 15 归属业务员名称 `name` String ,-- 15 归属业务员名称
`flag` -- 保单批单标记
log_time String log_time String
) )
; ;
\ No newline at end of file
ZB_ODS/ZB_ODS_CBDATA.sql
View file @ 2803c5b7
...@@ -12,7 +12,7 @@ ...@@ -12,7 +12,7 @@
insert into ZB_ODS.ZB_ODS_KAFKA.CBDATA insert into ZB_ODS.ZB_ODS_KAFKA.CBDATA
select select
s1.uwConclueDate as `uwConclueDate` -- 核保通过时间 s1.uwConclueDate as `uwConclueDate` -- 标记时间
,s1.startTime as `startTime` -- 起保时间 ,s1.startTime as `startTime` -- 起保时间
,s1.businessOffice as `COMCODE` -- ,s1.businessOffice as `COMCODE` --
,t1.COMNAME as `COMNAME` -- ,t1.COMNAME as `COMNAME` --
...@@ -34,83 +34,78 @@ select ...@@ -34,83 +34,78 @@ select
,t2.NEWCHNLTYPEDESC as `chnlname` -- ,t2.NEWCHNLTYPEDESC as `chnlname` --
,s1.businessNatureCode as `businessNatureCode` -- 业务来源 ,s1.businessNatureCode as `businessNatureCode` -- 业务来源
,t4.CODEDESC as `businessNatureName` -- ,t4.CODEDESC as `businessNatureName` --
,cast(s1.netPremium as varchar) as `cost` -- 不含税保费 ,cast(s1.`cost` as varchar) as `cost` -- 不含税保费
,s1.policyNo as `no` -- 保单号 ,s1.`no` as `no` -- 保单号
,s1.xxzflag as xxzflag -- 新续转标记 1是0否 ,s1.`xxzflag` as `xxzflag` -- 新续转标记 1是0否
,s1.recordClerkCode as `id` -- 14 归属业务员ID ,s1.`id` as `id` -- 14 归属业务员ID
,s1.recordClerkName as `name` -- 15 归属业务员名称 ,s1.`name` as `name` -- 15 归属业务员名称
,s1.log_time as log_time ,s1.`flag` as `flag` -- 保单批单标记
,DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time
from ( from (
select select
LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate -- 核保通过时间 LongTimeToStringUDF(signDate,'yyyyMMdd') as uwConclueDate -- 标记时间 UnderWriteEndDate
,LongTimeToStringUDF(startTime,'yyyyMMdd') as startTime -- 起保时间 ,LongTimeToStringUDF(startTime,'yyyyMMdd') as `startTime` -- 起保时间
,businessOffice as businessOffice -- 保单归属机构代码 ,businessOffice as businessOffice -- 保单归属机构代码
,productCode as productCode -- 险种代码 ,productCode as productCode -- 险种代码
,businessChannelCode as businessChannelCode -- 业务渠道 ,businessChannelCode as businessChannelCode -- 业务渠道
,businessNatureCode as businessNatureCode -- 业务来源 ,businessNatureCode as businessNatureCode -- 业务来源
,cast(netPremium as decimal(18,2)) * cast(sigAndStaExchangeRate as decimal(18,2))*( ,cast(netPremium as decimal(18,4))
case * cast(sigAndStaExchangeRate as decimal(18,4))
when plcSolution[1].plcCoins.plcCoinsBasicInformation is null then 1 *(
else cast(plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate AS decimal(18,2) ) case
end when coinsCode = '0' and coinsLinkCode = '0' then 1 -- 非共保非联保
) when coinsCode = '0' and coinsLinkCode <> '0' then JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) /100 -- 纯联保
as netPremium -- 不含税保费 when coinsLinkCode = '0' then JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) /100 -- 纯共保
,policyNo as policyNo -- 保单号 else (JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar) ) /100)
* (JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) /100) -- 即联又共
end
) as `cost` -- 不含税保费
,policyNo as `no` -- 保单号
,case ,case
when LEFT(productCode,2) = '05' and (newPolicyFlag = '1' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '1' or transrenewFlag = '1' or transrenewFlag ='4') then '1' when LEFT(productCode,2) = '05' and (newPolicyFlag = '1' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '1' or transrenewFlag = '1' or transrenewFlag ='4') then '1'
when LEFT(productCode,2) <> '05' and (newPolicyFlag = '0' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '2' or transrenewFlag = '1' ) then '1' when LEFT(productCode,2) <> '05' and (newPolicyFlag = '0' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '2' or transrenewFlag = '1' ) then '1'
else '0' end as xxzflag -- 新续转标记 1是0否 else '0' end as `xxzflag` -- 新续转标记 1是0否
,recordClerkCode as recordClerkCode -- 14 归属业务员ID ,mainSalesmanCode as `id` -- 14 归属业务员ID
,recordClerkName as recordClerkName -- 15 归属业务员名称 ,mainSalesmanName as `name` -- 15 归属业务员名称
,'bd' as flag -- 保单或批单标记 ,'bd' as `flag` -- 保单或批单标记
,proctime as proctime ,proctime as proctime
,uwConclueDate as log_time
from ODS.ODS_KAFKA.POLICY -- 保单业务数据 from ODS.ODS_KAFKA.POLICY -- 保单业务数据
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') where LongTimeToStringUDF(signDate,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and ( and cast(netPremium as decimal(18,2)) <> 0
LEFT(productCode,2) = '05'
or (
LEFT(productCode,2) <> '05'
and plcSolution[1].plcCoins.plcCoinsBasicInformation is not null
and plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity = '1'
)
)
union all union all
select select
LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') as uwConclueDate -- 核保通过时间 ？？ LongTimeToStringUDF(endorsePolicyTime,'yyyyMMdd') as uwConclueDate -- 标记时间 endorsePolicyTime
,LongTimeToStringUDF(plpEndorse.endorseEffectiveTime,'yyyyMMdd') as startTime -- 起保时间 ,LongTimeToStringUDF(endorseTime,'yyyyMMdd') as `startTime` -- 起保时间
,businessOffice as businessOffice -- 保单归属机构代码 ,businessOffice as businessOffice -- 保单归属机构代码
,productCode as productCode -- 险种代码 ,productCode as productCode -- 险种代码
,businessChannelCode as businessChannelCode -- 业务渠道 ,businessChannelCode as businessChannelCode -- 业务渠道
,businessNatureCode as businessNatureCode -- 业务来源 ,businessNatureCode as businessNatureCode -- 业务来源
,cast(plpEndorse.staCurPremiumVariation as decimal(18,2)) *( ,cast(plpEndorse.netPremiumVariation as decimal(18,4))
case * cast(sigAndStaExchangeRate as decimal(18,4))
when plcSolution[1].plcCoins.plcCoinsBasicInformation is null then 1 *(
else cast(plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate AS decimal(18,2) ) case
end when coinsCode = '0' and coinsLinkCode = '0' then 1 -- 非共保非联保
) when coinsCode = '0' and coinsLinkCode <> '0' then JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar)) /100 -- 纯联保
as netPremium -- 不含税保费 ？？ when coinsLinkCode = '0' then JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar)) /100 -- 纯共保
,endorseNo as policyNo -- 批单号 else (JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcCoinsBasicInformation as varchar) ) /100)
* (JsonGetCoinsRate(cast(plcSolution[1].plcCoins.plcLinkBasicInformat as varchar) ) /100) -- 即联又共
end
) as `cost` -- 不含税保费
,endorseNo as `no` -- 批单号
,case ,case
when LEFT(productCode,2) = '05' and (newPolicyFlag = '1' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '1' or transrenewFlag = '1' or transrenewFlag ='4') then '1' when LEFT(productCode,2) = '05' and (newPolicyFlag = '1' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '1' or transrenewFlag = '1' or transrenewFlag ='4') then '1'
when LEFT(productCode,2) <> '05' and (newPolicyFlag = '0' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '2' or transrenewFlag = '1' ) then '1' when LEFT(productCode,2) <> '05' and (newPolicyFlag = '0' or autoTransrenewFlag = '1' or autoTransrenewFlag = '4' or transferPolicyFlag = '2' or transrenewFlag = '1' ) then '1'
else '0' end as xxzflag -- 新续转标记 1是0否 else '0' end as `xxzflag` -- 新续转标记 1是0否
,recordClerkCode as recordClerkCode -- 14 归属业务员ID ,mainSalesmanCode as `id` -- 14 归属业务员ID
,recordClerkName as recordClerkName -- 15 归属业务员名称 ,mainSalesmanName as `name` -- 15 归属业务员名称
,'pd' as flag -- 保单或批单标记 ,'pd' as `flag` -- 保单或批单标记
,proctime as proctime ,proctime as proctime
,uwConclueDate as log_time
from ODS.ODS_KAFKA.ENDOR -- 批单业务数据 from ODS.ODS_KAFKA.ENDOR -- 批单业务数据
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') where LongTimeToStringUDF(endorsePolicyTime,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and ( and cast(plpEndorse.netPremiumVariation as decimal(18,4)) <> 0
LEFT(productCode,2) = '05'
or (
LEFT(productCode,2) <> '05'
and plcSolution[1].plcCoins.plcCoinsBasicInformation is not null
and plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsIdentity = '1'
)
)
) s1 ) 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_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
......
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

版权所有@2016-2024 北京云端微服科技有限公司