Skip to content

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

指标计算承保字段调整

parent 1f38a64e
Hide whitespace changes
Inline Side-by-side
Showing with 342 additions and 8 deletions
ODS/DDL元数据/ENDOR.sql
View file @ d06c2b43
...@@ -21,7 +21,7 @@ ENDOR_PLCPUBLICINSURANT ...@@ -21,7 +21,7 @@ ENDOR_PLCPUBLICINSURANT
channelType String , -- 5 渠道类型 channelType String , -- 5 渠道类型
uwConclueDate String , -- 6 核批完成时间 uwConclueDate String , -- 6 核批完成时间
plpEndorse row( plpEndorse row(
endorseEffectiveTime Stirng , -- 7 批单生效日期 endorseEffectiveTime String , -- 7 批单生效日期
staCurAmountVariation String , -- 10 变化保险金额 staCurAmountVariation String , -- 10 变化保险金额
staCurPremiumVariation String , -- 11 不含税变化保险费 staCurPremiumVariation String , -- 11 不含税变化保险费
staCurNetPremiumVariation String , -- 12 含税变化保险费 staCurNetPremiumVariation String , -- 12 含税变化保险费
...@@ -29,7 +29,7 @@ ENDOR_PLCPUBLICINSURANT ...@@ -29,7 +29,7 @@ ENDOR_PLCPUBLICINSURANT
plpCommissionDetail array<row( plpCommissionDetail array<row(
agentFeeVariation String , -- 16 份额含税手续费变化量 agentFeeVariation String , -- 16 份额含税手续费变化量
agentNetFeeVariation String -- 17 份额不含税手续费变化量 agentNetFeeVariation String -- 17 份额不含税手续费变化量
)> )>,
netPremiumVariation String -- 保费变化量 netPremiumVariation String -- 保费变化量
), ),
recordClerkCode String , -- 14 归属业务员ID recordClerkCode String , -- 14 归属业务员ID
...@@ -44,17 +44,17 @@ ENDOR_PLCPUBLICINSURANT ...@@ -44,17 +44,17 @@ ENDOR_PLCPUBLICINSURANT
plcSolution array<row( plcSolution array<row(
plcCoins row( plcCoins row(
plcCoinsBasicInformation array<row( plcCoinsBasicInformation array<row(
coinsRate -- 非车险共保比例 coinsRate String , -- 非车险共保比例
coinsIdentity -- 共保我方标记 = 1 时共保我方 coinsIdentity String -- 共保我方标记 = 1 时共保我方
)> )>
), ),
PlcRation row( PlcRation row(
artifSelfPricesRat String , -- 新核心车险批单-自主定价系数 artifSelfPricesRat String , -- 新核心车险批单-自主定价系数
artifReviewPrem String -- 新核心车险批单-总保费 artifReviewPrem String -- 新核心车险批单-总保费
), ),
plcCommissionDetail array<row( plcCommissionDetail array<row(
agentFee String , -- 新核心车险批单-手续费含税金额 agentFee String , -- 新核心车险批单-手续费含税金额
agentNetFee String -- 新核心车险批单-手续费不含税金额 agentNetFee String -- 新核心车险批单-手续费不含税金额
)> )>
)>, )>,
policyNo String , -- 新核心车险批单-保单号 policyNo String , -- 新核心车险批单-保单号
...@@ -69,11 +69,11 @@ ENDOR_PLCPUBLICINSURANT ...@@ -69,11 +69,11 @@ ENDOR_PLCPUBLICINSURANT
vehicleId String , -- 新核心车险批单-车型 vehicleId String , -- 新核心车险批单-车型
newVehicleFlag String , -- 新核心车险批单-新车标识 newVehicleFlag String , -- 新核心车险批单-新车标识
carUserNatureCode String , -- 新核心车险批单-车辆使用性质 carUserNatureCode String , -- 新核心车险批单-车辆使用性质
carKindCode String , -- 新核心车险批单-车辆种类 carKindCode String -- 新核心车险批单-车辆种类
), ),
plcApplicant array<row( plcApplicant array<row(
customerName String -- 新核心车险批单-投保人名称 customerName String -- 新核心车险批单-投保人名称
)>, )>,
plcPublicInsurant array<row( plcPublicInsurant array<row(
customerName String -- 新核心车险批单-被保人名称 customerName String -- 新核心车险批单-被保人名称
)>, )>,
......
XF_DWD/XF_DWD_POLICY.sql
View file @ d06c2b43
-- ODS_POLICY ODS_保单业务数据 -- ODS_POLICY ODS_保单业务数据
-- XF_DWD.XF_DWD_KAFKA.分公司TOPIC
select select
s1.endorseNo , -- 1 批单号 s1.endorseNo , -- 1 批单号
s1.policyNo , -- 2 保单号 s1.policyNo , -- 2 保单号
......
ZB_CK/同步脚本/test_dataquery_zb_cbdata.sql 0 → 100644
View file @ d06c2b43
create table cbdata(
uwConclueDate varchar(256) ,
startTime varchar(256) ,
COMCODE varchar(256) ,
LEVEL1COMCODE varchar(256) ,
LEVEL2COMCODE varchar(256) ,
LEVEL3COMCODE varchar(256) ,
LEVEL4COMCODE varchar(256) ,
LEVEL5COMCODE varchar(256) ,
risk varchar(256) ,
classcode varchar(256) ,
chnl varchar(256) ,
businessNatureCode varchar(256) ,
cost varchar(256) ,
`no` varchar(256) ,
xxzflag varchar(256) ,
id varchar(256) ,
log_time varchar(256)
)WITH (
'properties.bootstrap.servers' = '9.23.23.75:9092,9.23.23.76:9092,9.23.23.77:9092,9.23.23.78:9092',
'scan.startup.mode'='earliest-offset',
'topic'='CBDATA',
'format'='json',
'properties.group.id'='20220818',
'connector' ='kafka'
);
create table test_cbdata(
uwConclueDate varchar(256) ,
startTime varchar(256) ,
COMCODE varchar(256) ,
LEVEL1COMCODE varchar(256) ,
LEVEL2COMCODE varchar(256) ,
LEVEL3COMCODE varchar(256) ,
LEVEL4COMCODE varchar(256) ,
LEVEL5COMCODE varchar(256) ,
risk varchar(256) ,
classcode varchar(256) ,
chnl varchar(256) ,
businessNatureCode varchar(256) ,
cost varchar(256) ,
`no` varchar(256) ,
xxzflag varchar(256) ,
id varchar(256) ,
log_time varchar(256)
)WITH(
'url'='jdbc:mysql://9.1.200.87:3306/life_test?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'test_cbdata','username' = 'service','password' = 'ydwf12356aA!',
'scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '200','connector' ='jdbc'
);
insert into test_cbdata select * from cbdata where uwConclueDate between '20220830' and '20220901' -- and COMCODE = '54000000';
\ No newline at end of file
ZB_CK/同步脚本/test_dataquery_zb_endor_trans.sql 0 → 100644
View file @ d06c2b43
create table mq_test_endor(
endorseNo String , -- 1 批单号
businessOffice String , -- 新核心车险批单-保单归属机构代码
productCode String , -- 新核心车险批单-险种代码
businessNatureCode String , -- 新核心车险批单-业务来源
channelType String , -- 5 渠道类型
uwConclueDate String , -- 6 核批完成时间
plpEndorse row(
endorseEffectiveTime String , -- 7 批单生效日期
staCurAmountVariation String , -- 10 变化保险金额
staCurPremiumVariation String , -- 11 不含税变化保险费
staCurNetPremiumVariation String , -- 12 含税变化保险费
staCurTaxFeeVariation String , -- 13 税
plpCommissionDetail array<row(
agentFeeVariation String , -- 16 份额含税手续费变化量
agentNetFeeVariation String -- 17 份额不含税手续费变化量
)>,
netPremiumVariation String -- 保费变化量
),
recordClerkCode String , -- 14 归属业务员ID
recordClerkName String , -- 15 归属业务员名称
businessChannelCode String , -- 27 新核心车险批单-清分后渠道
businessChannelName String , -- 28 业务渠道名
newPolicyFlag String , -- 20 新核心车险批单-新保标识 1:是，0：否
autoTransrenewFlag String , -- 21 新核心车险批单-自动续保标识 1:是，4：跨险种自动续保，0：否
transferPolicyFlag String , -- 22 新核心车险批单-转保标识1:是，0：否
transrenewFlag String , -- 23 新核心车险批单-续保标识 1:是，4：跨险种续保，0：否
policyCreatDate String , -- 新核心车险批单-核保通过时间
plcSolution array<row(
plcCoins row(
plcCoinsBasicInformation array<row(
coinsRate String , -- 非车险共保比例
coinsIdentity String -- 共保我方标记 = 1 时共保我方
)>
),
PlcRation row(
artifSelfPricesRat String , -- 新核心车险批单-自主定价系数
artifReviewPrem String -- 新核心车险批单-总保费
),
plcCommissionDetail array<row(
agentFee String , -- 新核心车险批单-手续费含税金额
agentNetFee String -- 新核心车险批单-手续费不含税金额
)>
)>,
policyNo String , -- 新核心车险批单-保单号
businessOfficeName String , -- 新核心车险批单-保单归属机构名称
startTime String , -- 新核心车险批单-起保时间
endTime String , -- 新核心车险批单-终保时间
netPremium String , -- 新核心车险批单-不含税保费
premium String , -- 新核心车险批单-含税保费
plcCar05 row(
licensePlateNo String , -- 新核心车险批单-车牌号
frameNo String , -- 新核心车险批单-车架号
vehicleId String , -- 新核心车险批单-车型
newVehicleFlag String , -- 新核心车险批单-新车标识
carUserNatureCode String , -- 新核心车险批单-车辆使用性质
carKindCode String -- 新核心车险批单-车辆种类
),
plcApplicant array<row(
customerName String -- 新核心车险批单-投保人名称
)>,
plcPublicInsurant array<row(
customerName String -- 新核心车险批单-被保人名称
)>,
saleaman String, -- 新核心车险批单-代理机构代码
saleamanName String, -- 新核心车险批单-代理机构名称
policySort String, -- 新核心车险批单-保单种类
sigAndStaExchangeRate String -- 8 到人民币汇率 除了粤港车，车险没有存汇率，模型默认0
)WITH(
-- 'host' = '9.23.28.35',
-- 'port' = '5672',
-- 'user' = 'test',
-- 'password' = 'cG9saWN5LVJhYmJpdE1R',
-- 'vhost' = '/',
-- 'queue' = 'ENDOR_GENERATE_FANOUT_MESSAGE_QUEUE_D030',
-- 'durable'='true',
-- 'format'='json',
-- 'connector' = 'rabbitmq-ddl'
-- earliest-offset/latest-offset/group-offsets/specific-offsets/timestamp
'scan.startup.mode'='earliest-offset' ,
'connector'='kafka',
'topic'='ENDOR',
'properties.bootstrap.servers'='9.23.23.75:9092,9.23.23.76:9092,9.23.23.77:9092,9.23.23.78:9092',
'format'='json',
'json.ignore-parse-errors' = 'false',
-- 消费
'properties.group.id'='testGroup_2022040201'
);
CREATE TABLE test_endor_trans(
endorseNo varchar(64) ,
uwConclueDate varchar(64) ,
endorseEffectiveTime varchar(64) ,
businessOffice varchar(64) ,
productCode varchar(64) ,
businessChannelCode varchar(64) ,
businessNatureCode varchar(64) ,
netPremiumVariation varchar(64) ,
sigAndStaExchangeRate varchar(64) ,
staCurPremiumVariation varchar(64) ,
coinsIdentity varchar(64) ,
coinsRate varchar(64) ,
newPolicyFlag varchar(64) ,
autoTransrenewFlag varchar(64) ,
transferPolicyFlag varchar(64) ,
transrenewFlag varchar(64) ,
recordClerkCode varchar(64)
) WITH ('url'='jdbc:mysql://9.1.200.87:3306/life_test?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'test_endor_trans','username' = 'service','password' = 'ydwf12356aA!',
'scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '200','connector' ='jdbc');
insert into test_endor_trans
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
from mq_test_endor
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') between '20220830' and '20220901'
\ No newline at end of file
ZB_CK/同步脚本/test_dataquery_zb_plicy_trans.sql 0 → 100644
View file @ d06c2b43
create table mq_test_policy(
endorseNo String , -- 1 批单号
policyNo String , -- 2 保单号
businessNo String , -- 3 业务号
uwConclueDate String , -- 4 核保通过时间
businessOffice String , -- 5 保单归属机构代码
businessOfficeName String , -- 6 保单归属机构名称
productCode String , -- 7 险种代码
businessNatureCode String , -- 8 业务来源
startTime String , -- 9 起保时间
endTime String , -- 10 终保时间
netPremium String , -- 11 不含税保费
premium String , -- 12 含税保费
plcCar05 row(
licensePlateNo String , -- 13 车牌号
frameNo String , -- 14 车架号
vehiclecode String , -- 15 行业车型代码
carBrandCode String , -- 16 厂牌型号
newCarFlag String , -- 17 新车标识 1:新车，0：旧车
carKindCode String , -- 29 车辆种类代码
carKindName String , -- 30 车辆种类名称
carUserNatureCode String , -- 31 车辆使用性质代码
carUserNature String , -- 32 车辆使用性质名称
vehicleId String , -- 新核心车险保单-车型
newVehicleFlag String , -- 新核心车险保单-新车标识
actualvalue String -- 新核心车险保单-实际价值
),
plcApplicant array<row(
customerName String -- 18 投保人名称
)>,
plcPublicInsurant array<row(
customerName String -- 19 被保人名称
)>,
newPolicyFlag String , -- 20 新保标识 1:是，0：否
autoTransrenewFlag String , -- 21 自动续保标识 1:是，4：跨险种自动续保，0：否
transferPolicyFlag String , -- 22 转保标识1:是，0：否
transrenewFlag String , -- 23 续保标识 1:是，4：跨险种续保，0：否
plcSolution array<row(
PlcRation row(
artifSelfPricesRat String, -- 24 自主定价系数
artifReviewPrem String -- 新核心车险保单-总保费
),
plcCoins row( --String类型 该对象部分参数在某些数据中可能不存在 自定义函数 JsonValuUDF读取
plcCoinsBasicInformation array<row(
coinsRate String , -- 非车险共保比例
coinsIdentity String -- 共保我方标记 = 1 时共保我方
)>
),
plcCommissionDetail array<row(
agentFee String , -- 36 份额含税手续费
agentNetFee String -- 37 份额不含税手续费
)>
)>,
saleaman String , -- 25 代理机构代码
saleamanName String , -- 26 代理机构名称
businessChannelCode String , -- 27 业务渠道
businessChannelName String , -- 28 业务渠道名
recordClerkCode String , -- 34 归属业务员ID
recordClerkName String , -- 35 归属业务员名称
staCurAmount String , -- 38 保险金额
staCurTaxFee String , -- 39 税
policyCreatDate String , -- 保单创建时间
sigAndStaExchangeRate String , -- 费率
policySort String , -- 新核心车险保单-保单种类
businessType String -- 新核心车险保单-业务类型
)WITH (
-- earliest-offset/latest-offset/group-offsets/specific-offsets/timestamp
'scan.startup.mode'='earliest-offset' ,
'connector'='kafka',
'topic'='POLICY',
'properties.bootstrap.servers'='9.23.23.75:9092,9.23.23.76:9092,9.23.23.77:9092,9.23.23.78:9092',
'format'='json',
'json.ignore-parse-errors' = 'false',
-- 消费
'properties.group.id'='testGroup_2022040201'
);
CREATE TABLE test_policy_trans(
policyNo varchar(64) ,
uwConclueDate varchar(64) ,
startTime varchar(64) ,
businessOffice varchar(64) ,
productCode varchar(64) ,
businessChannelCode varchar(64) ,
businessNatureCode varchar(64) ,
netPremium varchar(64) ,
sigAndStaExchangeRate varchar(64) ,
coinsIdentity varchar(64) ,
coinsRate varchar(64) ,
newPolicyFlag varchar(64) ,
autoTransrenewFlag varchar(64) ,
transferPolicyFlag varchar(64) ,
transrenewFlag varchar(64) ,
recordClerkCode varchar(64)
) WITH (
'url'='jdbc:mysql://9.1.200.87:3306/life_test?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'test_policy_trans','username' = 'service','password' = 'ydwf12356aA!',
'scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '200','connector' ='jdbc'
);
insert into test_policy_trans
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
from mq_test_policy -- 保单业务数据
where LongTimeToStringUDF(uwConclueDate,'yyyyMMdd') between '20220830' and '20220901'
;
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 北京云端微服科技有限公司