Skip to content

D
dataquality_doc
Commit 0c38fa62 authored by 胡涛's avatar 胡涛
Browse files
Options

质量校验理赔sql脚本

parent 99a9a600
Show whitespace changes
Inline Side-by-side
Showing with 82 additions and 24 deletions
CK_DWD/DDL元数据/CKODSREGIST.sql 0 → 100644
View file @ 0c38fa62
-- 理赔业务数据
create table CKODSREGIST(
checkDate varchar(64) -- 勘察日期
,linkerPhoneNo varchar(64) -- 联系人手机
,damageStartDate varchar(64) -- 出险时间
,claimDate varchar(64) -- 立案日期
,sumclaim varchar(64) -- 估损金额
,compensateVericDate varchar(64) -- 核赔日期
,closeCaseDate varchar(64) -- 结案时间
,sumThisPaid varchar(64) -- 总赔付金额
,sumDutyPaid varchar(64) -- 直接理赔费用总金额原币金额
,recaseDate varchar(64) -- 案件重开时间
,completeDate varchar(64) -- 资料接收齐全时间
,indemnityDutyRate varchar(32) -- 车赔付比例
,paidRate varchar(32) -- 财赔付比例
,originPaidRate varchar(32) -- 人赔付比例
,crippleDegreeOne varchar(64) -- 伤残等级、伤残代码
,damageName varchar(64) -- 出险原因名称
,damageTypeCode varchar(64) -- 事故分类代码
,damageTypeName varchar(64) -- 事故分类名称
,accidentDealType varchar(64) -- 处理方式代码
,accidentDealTypeName varchar(64) -- 处理方式名称
,repairFactoryName varchar(128) -- 修理厂名称
,damageCode varchar(64) -- 出险原因码值
,injurySiteCode varchar(64) -- 受伤部位
,crippleDegreeOneCode varchar(64) -- 伤残程度代码
,crippleDegreeOneName varchar(64) -- 伤残程度名称
,treatedType varchar(64) -- 伤亡人员医疗类型
,hospitalName varchar(128) -- 医疗机构名称
,nonlocalIdentFlag varchar(64) -- 异地鉴定标志
,subCertiType varchar(64) -- 责任认定书类型代码
,subCertiTypeName varchar(64) -- 责任认定书类型名称
,verifyLossCar varchar(64) -- 车核定损失金额
,verifyLossWealth varchar(64) -- 财核定损失金额
,verifyLossPeople varchar(64) -- 人核定损失金额
,subjectTypeCode varchar(64) -- 被追偿方类型
,subjectTypeName varchar(64) -- 被追偿方名称
,log_time varchar(32) -- 加工平台处理数据时间
,ERRORMSG varchar(1024)
,AERRORMSG varchar(512)
,BERRORMSG varchar(512)
,CERRORMSG varchar(512)
,DERRORMSG varchar(512)
,EERRORMSG varchar(512)
,VALI_TIME varchar(32)
,VALI_DATE varchar(32)
) ;
\ No newline at end of file
CK_DWD/承保校验/CK_DWD_CKDWDREGIST.sql 0 → 100644
View file @ 0c38fa62
-- CK_DWD_CKDWDREGIST
\ No newline at end of file
CK_ODS/DDL元数据/CKODSREGIST.sql
View file @ 0c38fa62
......@@ -23,16 +23,16 @@ create table CKODSREGIST(
,repairFactoryName varchar(128) -- 修理厂名称
,damageCode varchar(64) -- 出险原因码值
,injurySiteCode varchar(64) -- 受伤部位
,crippleDegreeOne varchar(64) -- 伤残程度代码
,crippleDegreeOneCode varchar(64) -- 伤残程度代码
,crippleDegreeOneName varchar(64) -- 伤残程度名称
,treatedType varchar(64) -- 伤亡人员医疗类型
,hospitalName varchar(128) -- 医疗机构名称
,nonlocalIdentFlag varchar(64) -- 异地鉴定标志
,subCertiType varchar(64) -- 责任认定书类型代码
,subCertiTypeName varchar(64) -- 责任认定书类型名称
,verifyLoss varchar(64) -- 车核定损失金额
,verifyLoss varchar(64) -- 财核定损失金额
,verifyLoss varchar(64) -- 人核定损失金额
,verifyLossCar varchar(64) -- 车核定损失金额
,verifyLossWealth varchar(64) -- 财核定损失金额
,verifyLossPeople varchar(64) -- 人核定损失金额
,subjectTypeCode varchar(64) -- 被追偿方类型
,subjectTypeName varchar(64) -- 被追偿方名称
,log_time varchar(32) -- 加工平台处理数据时间
......
CK_ODS/承保同步/CK_ODS_CKODSREGIST.sql
View file @ 0c38fa62
-- CK_ODS_CKODSPOLICY CK_ODS_保单业务数据
insert into CK_ODS.CK_ODS_KAFKA.CKODSREGIST -- topic CKODSPOLICY
-- CK_ODS_CKODSREGIST CK_ODS_理赔业务数据
insert into CK_ODS.CK_ODS_KAFKA.CKODSREGIST -- topic CKODSREGIST
select
s1.actualData.prplccheck.checkDate as checkDate -- 勘察日期
,s1.actualData.prplcregist.prpllinker.linkerPhoneNo as linkerPhoneNo -- 联系人手机
......@@ -24,22 +24,21 @@ select
,s1.actualData.prplcarlossdetail[1].prplrepairfactory[1].repairFactoryName as repairFactoryName -- 修理厂名称
,s1.actualData.damageCode as damageCode -- 出险原因码值
,s1.actualData.prplcarlossdetail[1].prplcarcertain.injurySiteCode as injurySiteCode -- 受伤部位
,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOne as crippleDegreeOne -- 伤残程度代码
,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOne as crippleDegreeOneCode -- 伤残程度代码
,s1.actualData.prplpersondetail[1].PrpLHospital[1].crippleDegreeOneName as crippleDegreeOneName -- 伤残程度名称
,s1.actualData.prplpersondetail[1].PrpLHospital[1].treatedType as treatedType -- 伤亡人员医疗类型
,s1.actualData.prplpersondetail[1].PrpLHospital[1].hospitalName as hospitalName -- 医疗机构名称
,s1.actualData.prplpersondetail[1].prplsdisabilityassess[1].nonlocalIdentFlag as nonlocalIdentFlag -- 异地鉴定标志
,s1.actualData.prplflag.subCertiType as subCertiType -- 责任认定书类型代码
,s1.actualData.prplflag.subCertiTypeName as subCertiTypeName -- 责任认定书类型名称
,s1.actualData.prplcarlossdetail[1].verifyLoss as verifyLoss -- 车核定损失金额
,s1.actualData.prplproplossdetail[1].verifyLoss as verifyLoss -- 财核定损失金额
,s1.actualData.prplpersondetail[1].verifyLoss as verifyLoss -- 人核定损失金额
,s1.actualData.prplcarlossdetail[1].verifyLoss as verifyLossCar -- 车核定损失金额
,s1.actualData.prplproplossdetail[1].verifyLoss as verifyLossWealth -- 财核定损失金额
,s1.actualData.prplpersondetail[1].verifyLoss as verifyLossPeople -- 人核定损失金额
,s1.actualData.prplcreplevy[1].prplreplevyclaim[1].prplreplevyobject[1].subjectTypeCode as subjectTypeCode -- 被追偿方类型
,s1.actualData.prplcreplevy[1].prplreplevyclaim[1].prplreplevyobject[1].subjectTypeName as subjectTypeName -- 被追偿方名称
, DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
from ODS.ODS_KAFKA.REGIST s1
cross join unnest(s1.plcApplicant) as u1 (customerName,identifyNumber,identifyType)
where substring(s1.actualData.accidentNo,3,2) = '05'
;
ODS/DDL元数据/REGIST.sql
View file @ 0c38fa62
......@@ -21,6 +21,15 @@ REGIST_ACTUALDATA_PRPLCRECASE
REGIST_ACTUALDATA_PRPLCERTIFY
REGIST_ACTUALDATA_PRPLACCIDENT
REGIST_ACTUALDATA_PRPLFLAG
REGIST_ACTUALDATA_PRPLPROPLOSSDETAIL
REGIST_ACTUALDATA_PRPLPROPLOSSDETAIL_PRPLPROPLOSS
REGIST_ACTUALDATA_PRPLPERSONDETAIL
REGIST_ACTUALDATA_PRPLPERSONDETAIL_PRPLPERSON
REGIST_ACTUALDATA_PRPLPERSONDETAIL_PRPLHOSPITAL
REGIST_ACTUALDATA_PRPLPERSONDETAIL_PRPLSDISABILITYASSESS
REGIST_ACTUALDATA_PRPLCREPLEVY
REGIST_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM
REGIST_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM_PRPLREPLEVYOBJECT
{
......@@ -95,6 +104,18 @@ REGIST_ACTUALDATA_PRPLFLAG
prplcertify row(
completeDate String -- 资料接收齐全时间
) ,
damageName String , -- 出险原因名称
damageCode String , -- 出险原因码值
prplaccident row(
damageTypeCode String , -- 事故分类代码
damageTypeName String , -- 事故分类名称
accidentDealType String , -- 处理方式代码
accidentDealTypeName String -- 处理方式名称
) ,
prplflag row(
subCertiType String , -- 责任认定书类型代码
subCertiTypeName String -- 责任认定书类型名称
) ,
prplproplossdetail array<row( -- miss
prplproploss array<row( -- miss
paidRate String -- 财赔付比例
......@@ -116,18 +137,6 @@ REGIST_ACTUALDATA_PRPLFLAG
)>,
verifyLoss String -- 人核定损失金额
)> ,
damageName String , -- 出险原因名称
damageCode String , -- 出险原因码值
prplaccident row(
damageTypeCode String , -- 事故分类代码
damageTypeName String , -- 事故分类名称
accidentDealType String , -- 处理方式代码
accidentDealTypeName String -- 处理方式名称
) ,
prplflag row(
subCertiType String , -- 责任认定书类型代码
subCertiTypeName String -- 责任认定书类型名称
) ,
prplcreplevy array<row( -- miss
prplreplevyclaim array<row( -- miss
prplreplevyobject array<row( -- miss
......@@ -135,7 +144,7 @@ REGIST_ACTUALDATA_PRPLFLAG
subjectTypeName String -- 被追偿方名称
)>
)>
)> ,
)>
),
log_time String ,
......
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 北京云端微服科技有限公司