Skip to content

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

指标计算承保字段调整

parent edf6bbcb
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 295 additions and 73 deletions
ODS/DDL元数据/REGIST.sql 0 → 100644
View file @ 6d10aa2b
-- REGIST 车险报案
业务对象命名：
REGIST
REGIST_ACTUALDATA
REGIST_ACTUALDATA_PRPLCREGIST
REGIST_ACTUALDATA_PRPLCREGIST_PRPLREPORTER
REGIST_ACTUALDATA_PRPLCREGIST_PRPLLINKER
REGIST_ACTUALDATA_PRPLPOLICY
REGIST_ACTUALDATA_PRPLCARLOSSDETAIL
REGIST_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
REGIST_ACTUALDATA_PRPLCDAMAGE
REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
{
actualData row(
accidentNo String , -- 事故号
damageStartDate String , -- 出险时间 无需转码 2021-06-27 19:25:00
reportDate String , -- 报案时间 无需转码 2021-06-27 19:37:18
damageAddress String , -- 出险地点
prplcregist array<row(
policyNo String , -- 保单号
registNo String , -- 报案号
deptCode String , -- 理赔机构代码
deptName String , -- 理赔机构名称
prplreporter row(
reporterName String , -- 报案人名称
reporterMobileNo String -- 报案人电话
) ,
prpllinker row(
linkerName String , -- 联系人名称
linkerPhoneNo String -- 联系人电话
)
)> ,
prplpolicy array<row(
comCode String , -- 承保机构代码
comName String , -- 承保机构名称
riskCode String , -- 险种代码
riskName String , -- 险种名称
licenseNo String -- 车牌号
)> ,
prplcarlossdetail array<row(
prplcar row(
brandCode String , -- 品牌
carModelCode String -- 车型
)
)> ,
prplcdamage row(
prpldamageaddress row(
longitude String , -- 经度
latitude String -- 纬度
) ,
damageName String , -- 出险原因
damageCourse String -- 出险经过
)
)
log_time
}
\ No newline at end of file
ODS/DDL元数据/VIR.sql deleted 100644 → 0
View file @ edf6bbcb
-- VIR车险报案数据
VIR
VIR_ACTUALDATA
VIR_ACTUALDATA_PRPLCREGIST
VIR_ACTUALDATA_PRPLCREGIST_PRPLREPORZIQIMING
VIR_ACTUALDATA_PRPLCREGIST_PRPLREPORTER
VIR_ACTUALDATA_PRPLCREGIST_PRPLLINKER
VIR_ACTUALDATA_PRPLPOLICY
VIR_ACTUALDATA_PRPLCARLOSSDETAIL
VIR_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
VIR_ACTUALDATA_PRPLCDAMAGE
VIR_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
来源:
{
actualData: {
accidentNo String, --事故号
damageStartDate String, --出险时间
reportD String, --报案时间
damageAddress String, --出险地点
"prplcregist": [
{
policyNo String, --保单号
registNo String, --报案号
deptCode String, --理赔机构代码
deptName String, --理赔机构名称
},
"prplreporter": {
reporterName String, --报案人名称
reporterMobileNo String, --报案人电话
},
"prpllinker": {
linkerName String, --联系人名称
linkerPhon String, --联系人电话
}
],
"prplpolicy": [
{
comCode String, --承保机构代码
comName String, --承保机构名称
riskCode String, --险种代码
riskName String, --险种名称
licenseNo String, --车牌号
}
],
"prplcarlossdetail": [
"prplcar": {
brandCode String, --品牌
carModelCode String, --车型
}
],
"prplcdamage": {
"prpldamageaddress": {
longitude String, --经度
latitude String, --纬度
},
damageName String, --出险原因
damageCourse String, --出险经过
}
}
}
\ No newline at end of file
ODS/DDL元数据/VIR原始数据.sql deleted 100644 → 0
View file @ edf6bbcb
This diff is collapsed.
ODS/数据去重/DUPLICK_ENDOR.sql 0 → 100644
View file @ 6d10aa2b
-- DUPLICK_ENDOR DUPLICK_批单业务数据
insert into ODS.ODS_KAFKA.ENDOR -- topic ENDOR
select
endorseNo , -- 1 批单号
businessOffice , -- 新核心车险批单-保单归属机构代码
productCode , -- 新核心车险批单-险种代码
businessNatureCode , -- 新核心车险批单-业务来源
channelType , -- 5 渠道类型
uwConclueDate , -- 6 核批完成时间
plpEndorse ,
recordClerkCode , -- 14 归属业务员ID
recordClerkName , -- 15 归属业务员名称
businessChannelCode , -- 27 新核心车险批单-清分后渠道
businessChannelName , -- 28 业务渠道名
newPolicyFlag , -- 20 新核心车险批单-新保标识 1:是，0：否
autoTransrenewFlag , -- 21 新核心车险批单-自动续保标识 1:是，4：跨险种自动续保，0：否
transferPolicyFlag , -- 22 新核心车险批单-转保标识1:是，0：否
transrenewFlag , -- 23 新核心车险批单-续保标识 1:是，4：跨险种续保，0：否
policyCreatDate , -- 新核心车险批单-核保通过时间
plcSolution ,
policyNo , -- 新核心车险批单-保单号
businessOfficeName , -- 新核心车险批单-保单归属机构名称
startTime , -- 新核心车险批单-起保时间
endTime , -- 新核心车险批单-终保时间
netPremium , -- 新核心车险批单-不含税保费
premium , -- 新核心车险批单-含税保费
plcCar05 ,
plcApplicant ,
plcPublicInsurant ,
saleaman , -- 新核心车险批单-代理机构代码
saleamanName , -- 新核心车险批单-代理机构名称
policySort , -- 新核心车险批单-保单种类
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 , -- 指标新增_唯一标识需验证
businessNo -- 业务单号
from ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR
where DuplicateCheckingEndorUDF(MD5(ConcatObjUDF(COALESCE(endorseNo,businessNo),businessOffice,`netPremium`))) is not true
;
ODS/数据去重/DUPLICK_POLICY.sql 0 → 100644
View file @ 6d10aa2b
-- DUPLICK_POLICY DUPLICK_保单业务数据
insert into ODS.ODS_KAFKA.POLICY -- topic POLICY
select
policyNo , -- 2 保单号
businessNo , -- 3 业务号
uwConclueDate , -- 4 核保通过时间
businessOffice , -- 5 保单归属机构代码
businessOfficeName , -- 6 保单归属机构名称
productCode , -- 7 险种代码
businessNatureCode , -- 8 业务来源
startTime , -- 9 起保时间
endTime , -- 10 终保时间
netPremium , -- 11 不含税保费
premium , -- 12 含税保费
plcCar05 ,
plcApplicant ,
plcPublicInsurant ,
newPolicyFlag , -- 20 新保标识 1:是，0：否
autoTransrenewFlag , -- 21 自动续保标识 1:是，4：跨险种自动续保，0：否
transferPolicyFlag , -- 22 转保标识1:是，0：否
transrenewFlag , -- 23 续保标识 1:是，4：跨险种续保，0：否
plcSolution ,
saleaman , -- 25 代理机构代码
saleamanName , -- 26 代理机构名称
businessChannelCode , -- 27 业务渠道
businessChannelName , -- 28 业务渠道名
recordClerkCode , -- 34 归属业务员ID
recordClerkName , -- 35 归属业务员名称
staCurAmount , -- 38 保险金额
staCurTaxFee , -- 39 税
policyCreatDate , -- 保单创建时间
sigAndStaExchangeRate , -- 费率
policySort , -- 新核心车险保单-保单种类
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.ODS_KAFKA_FIRSTHAND.POLICY -- topic MQPOLICY
where DuplicateCheckingPolicyUDF(MD5(ConcatObjUDF(COALESCE(policyNo,businessNo),businessOffice,`netPremium`))) is not true
;
ODS/ODS_ENDOR.sql → ODS/数据同步/ODS_ENDOR.sql
View file @ 6d10aa2b
-- ODS_ENDOR ODS_批单业务数据
insert into ODS.ODS_KAFKA.ENDOR
insert into ODS.ODS_KAFKA_FIRSTHAND.ENDOR -- topic MQENDOR
select
endorseNo , -- 1 批单号
businessOffice , -- 新核心车险批单-保单归属机构代码
......@@ -45,7 +45,7 @@ from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
;
-- 记录消费数据总量
insert into ODS.ODS_REDIS.SET_VARCHAR
select
CONCAT('MQ_ENDOR/', LEFT(DataAccEndorUDF( date_time,'get'),10)) as `key` ,
......
ODS/ODS_POLICY.sql → ODS/数据同步/ODS_POLICY.sql
View file @ 6d10aa2b
-- ODS_POLICY ODS_保单业务数据
insert into ODS.ODS_KAFKA.POLICY
insert into ODS.ODS_KAFKA_FIRSTHAND.POLICY -- topic MQPOLICY
select
policyNo , -- 2 保单号
businessNo , -- 3 业务号
......@@ -46,7 +46,7 @@ select
from ODS.SOURCE_RMQ_POLICY_PRD.POLICY
;
-- 记录消费数据总量
insert into ODS.ODS_REDIS.SET_VARCHAR
select
CONCAT('MQ_POLICY/', LEFT(DataAccPolicyUDF( date_time,'get'),10)) as `key` ,
......
ODS/数据同步/ODS_REGIST.sql 0 → 100644
View file @ 6d10aa2b
-- ODS_REGIST ODS_报案业务数据
insert into ODS.ODS_KAFKA_FIRSTHAND.REGIST -- topic REGIST 无需去重
select
s1.actualData ,
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
from ODS.SOURCE_KAFKA_REGIST_PRD.REGIST s1
;
-- 记录消费数据总量
insert into ODS.ODS_REDIS.SET_VARCHAR
select
CONCAT('MQ_REGIST/', LEFT(DataAccRegistUDF( date_time,'get'),10)) as `key` ,
DataAccRegistUDF( date_time,'get') as val
from (
select
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as date_time -- 批单累加器 yyyy-MM-dd:num
from ODS.SOURCE_KAFKA_REGIST_PRD.REGIST
-- 在select与where条件中同时调用该参数 acc，会执行两次UDF函数 ,所以通过定义函数记录该参数 DataAccEndorLogUDF
where LEFT(DataAccRegistUDF( DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss'),'set'),10) <> 'xxxx-xx-xx' -- 将该参数保留
) s1
;
\ No newline at end of file
XF_ODS/DDL元数据/REGIST.sql
View file @ 6d10aa2b
......@@ -55,6 +55,7 @@ REGIST_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
)
)
log_time
LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构
}
\ No newline at end of file
ZB_DM/理赔指标/方案一（直接计算）/车险/ZB_DM_车险未决大单.sql
View file @ 6d10aa2b
......@@ -46,9 +46,9 @@ from (
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
and d1.`flag` in ('wj','yjwj')
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
) c1
where c1.rownum <= 20
) s1
......
ZB_DM/理赔指标/方案一（直接计算）/非车险/ZB_DM_非车险未决大单.sql
View file @ 6d10aa2b
......@@ -45,7 +45,7 @@ from (
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`settledamount` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and d1.`flag` in ('wj','yjwj')
and LEFT(d1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1
......
tmp.sql
View file @ 6d10aa2b
This diff is collapsed.
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 北京云端微服科技有限公司