Skip to content

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

指标计算承保字段调整

parent d5ccd8a1
Hide whitespace changes
Inline Side-by-side
Showing with 560 additions and 379 deletions
CK_DM/校验汇总/CK_DM_CKDMNOCARPOLICY.sql 0 → 100644
View file @ 40b1a747
-- CK_DM_CKDMNOCARPOLICY CK_DM_非车险保单校验汇总表
insert into CK_DM.CK_DM_MYSQL.CKDMPOLICY
select
MD5(ConcatObjUDF(s2.CHECK_RULE_NO,s2.USER_IDNO )) as PKID
, s2.CHECK_RULE_NO as CHECK_RULE_NO -- 规则代码
, cast(sum(1) as varchar) as CHECK_SUM -- 规则统计错误数量
, '' as CEECK_DETAILLIST -- 规则统计错误数据清单拼接
, s2.CHECK_MESSAGE as CHECK_MESSAGE -- 规则统计错误描述
, s2.USER_NAME as USER_NAME -- 联系人姓名
, s2.USER_IDNO as USER_IDNO -- 联系人身份证号
, DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
from CK_DWD.CK_DWD_MYSQL.CKDWDNOCARPOLICY s1
left join CK_ODS.CK_ODS_MYSQL.DATACHECK_USER_RELATION s2
on s1.ERRORMSG like CONCAT('%',s2.CHECK_RULE_NO,'%')
where s1.VALI_DATE = DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')
and s2.CHECK_RULE_NO is not null
group by
CHECK_RULE_NO
, CHECK_MESSAGE
, USER_NAME
, USER_IDNO
;
\ No newline at end of file
CK_DWD/DDL元数据/CKDWDNOCARPOLICY.sql 0 → 100644
View file @ 40b1a747
create table ck_dwd.ckdwdnocarpolicy
(
policyNo varchar(64) ,
businessNo varchar(64) ,
businessOffice varchar(64) ,
productCode varchar(64) ,
netPremium varchar(64) ,
premium varchar(64) ,
taxFee varchar(64) ,
amount varchar(64) ,
log_time varchar(32) null,
ERRORMSG varchar(1024) null,
AERRORMSG varchar(512) null,
BERRORMSG varchar(512) null,
CERRORMSG varchar(512) null,
DERRORMSG varchar(512) null,
EERRORMSG varchar(512) null,
RPTID varchar(32) null,
VALI_TIME varchar(32) null,
VALI_DATE varchar(32) null
);
\ No newline at end of file
CK_DWD/承保校验/CK_DWD_CKDWDNOCARPOLICY.sql 0 → 100644
View file @ 40b1a747
-- CK_DWD_保单非车业务数据
\ No newline at end of file
CK_ODS/DDL元数据/CKODSNOCARPOLICY.sql 0 → 100644
View file @ 40b1a747
create table CKODSNOCARPOLICY -- topic CKODSNOCARPOLICY
(
policyNo -- 保单号
businessNo -- 业务号
businessOffice -- 保单归属机构代码
productCode -- 险种代码
netPremium -- 保费（不含税）
premium -- 保费（含税）
taxFee -- 增值税税额
amount -- 保额
log_time -- 加工平台处理数据时间
)
CK_ODS/承保同步/CK_ODS_CKODSNOCARPOLICY.sql 0 → 100644
View file @ 40b1a747
-- CK_ODS_CKODSNOCARPOLICY CK_ODS_保单非车业务数据
insert into CK_ODS.CK_ODS_KAFKA.CKODSNOCARPOLICY -- topic CKODSNOCARPOLICY
select
s1.policyNo as policyNo -- 保单号
, s1.businessNo as businessNo -- 业务号
, s1.businessOffice as businessOffice -- 保单归属机构代码
, s1.productCode as productCode -- 险种代码
, s1.netPremium as netPremium -- 保费（不含税）
, s1.premium as premium -- 保费（含税）
, s1.taxFee as taxFee -- 增值税税额
, s1.amount as amount -- 保额
, DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 加工平台处理数据时间
from CK_ODS.CK_ODS_KAFKA.POLICY s1
where left( s1.productCode ,2) <> '05'
;
\ No newline at end of file
ODS/DDL元数据/ENDOR.sql
View file @ 40b1a747
...@@ -49,7 +49,9 @@ ENDOR_PLCBASIC ...@@ -49,7 +49,9 @@ ENDOR_PLCBASIC
endorseTypeCode Stirng , -- 质量校验_批改类型 endorseTypeCode Stirng , -- 质量校验_批改类型
endorseApplyTime String , -- 质量校验_批改申请时间 endorseApplyTime String , -- 质量校验_批改申请时间
endorseApplicantName String , -- 质量校验_批改申请人名称 endorseApplicantName String , -- 质量校验_批改申请人名称
uwConclueDate String -- 质量校验_核批通过时间 uwConclueDate String , -- 质量校验_核批通过时间
endorseCategoryCode String , -- 下发新增_批改类型编码
endorseCategoryName String , -- 下发新增_批改类型名称
), ),
recordClerkCode String , -- 14 归属业务员ID recordClerkCode String , -- 14 归属业务员ID
...@@ -99,7 +101,10 @@ ENDOR_PLCBASIC ...@@ -99,7 +101,10 @@ ENDOR_PLCBASIC
carUserNatureCode String , -- 新核心车险批单-车辆使用性质 carUserNatureCode String , -- 新核心车险批单-车辆使用性质
carKindCode String , -- 新核心车险批单-车辆种类 carKindCode String , -- 新核心车险批单-车辆种类
vehiclecode String , -- 新核心车险批单-车型(用这个) vehiclecode String , -- 新核心车险批单-车型(用这个)
newCarFlag String -- 新核心车险批单-新车标识(用这个) newCarFlag String , -- 新核心车险批单-新车标识(用这个)
energyTypesCode String , -- 下发新增_能源种类编码
energyTypes String , -- 下发新增_能源种类名称
secondhandcarflag String , -- 下发新增_是否二手车
), ),
plcApplicant array<row( plcApplicant array<row(
customerName String -- 新核心车险批单-投保人名称 customerName String -- 新核心车险批单-投保人名称
...@@ -134,7 +139,8 @@ ENDOR_PLCBASIC ...@@ -134,7 +139,8 @@ ENDOR_PLCBASIC
insurantIdentifyNumber -- 非车下发_被保人统一社会信用代码 insurantIdentifyNumber -- 非车下发_被保人统一社会信用代码
), ),
handlerCode String , -- 寿险销售人员代码 handlerCode String , -- 寿险销售人员代码
handlerName String -- 寿险销售人员名称 handlerName String , -- 寿险销售人员名称
amount String , -- 新增下发_保额
) )
......
ODS/DDL元数据/LPDATA.sql 0 → 100644
View file @ 40b1a747
-- LPDATA 理赔业务数据
业务对象命名：
LPDATA
LPDATA_ACTUALDATA
LPDATA_ACTUALDATA_PRPLCREGIST
LPDATA_ACTUALDATA_PRPLCREGIST_PRPLREPORTER
LPDATA_ACTUALDATA_PRPLCREGIST_PRPLLINKER
LPDATA_ACTUALDATA_PRPLPOLICY
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLREPAIRFACTORY
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCARCERTAIN
LPDATA_ACTUALDATA_PRPLCDAMAGE
LPDATA_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
LPDATA_ACTUALDATA_PRPLCCHECK
LPDATA_ACTUALDATA_PRPLCLAIM
LPDATA_ACTUALDATA_PRPLCCOMPENSATE
LPDATA_ACTUALDATA_PRPLENDCASE
LPDATA_ACTUALDATA_PRPLCRECASE
LPDATA_ACTUALDATA_PRPLCERTIFY
LPDATA_ACTUALDATA_PRPLACCIDENT
LPDATA_ACTUALDATA_PRPLFLAG
LPDATA_ACTUALDATA_PRPLPROPLOSSDETAIL
LPDATA_ACTUALDATA_PRPLPROPLOSSDETAIL_PRPLPROPLOSS
LPDATA_ACTUALDATA_PRPLPERSONDETAIL
LPDATA_ACTUALDATA_PRPLPERSONDETAIL_PRPLPERSON
LPDATA_ACTUALDATA_PRPLPERSONDETAIL_PRPLHOSPITAL
LPDATA_ACTUALDATA_PRPLPERSONDETAIL_PRPLSDISABILITYASSESS
LPDATA_ACTUALDATA_PRPLCREPLEVY
LPDATA_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM
LPDATA_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM_PRPLREPLEVYOBJECT
LPDATA_ACTUALDATA_PRPLCLAIM
{
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 -- 联系人电话
),
thridClaimComCode String ,
thridClaimComName String
)> ,
prplpolicy String , -- 该字段可能是对象或数组
-- prplpolicy array<row(
-- comCode String , -- 承保机构代码
-- comName String , -- 承保机构名称
-- riskCode String , -- 险种代码
-- riskName String , -- 险种名称
-- licenseNo String , -- 车牌号
-- isSelected String -- 是否选择
-- )> ,
prplcarlossdetail array<row(
prplcar row(
brandCode String , -- 品牌
carModelCode String -- 车型
) ,
indemnityDutyRate String , -- 车赔付比例
prplrepairfactory array<row(
repairFactoryName String -- 修理厂名称
)> ,
prplcarcertain row(
injurySiteCode String -- 受伤部位
) ,
verifyLoss String -- 车核定损失金额
)> ,
prplcdamage row(
prpldamageaddress row(
longitude String , -- 经度
latitude String -- 纬度
) ,
damageName String , -- 出险原因
damageCourse String -- 出险经过
) ,
prplccheck row(
checkDate String -- 查勘日期
) ,
prplclaim array<row(
claimDate String , -- 出险时间
sumclaim String -- 估损金额
)> ,
prplccompensate array<row(
compensateVericDate String , -- 核赔日期
sumThisPaid String , -- 总赔付金额
sumDutyPaid String -- 直接理赔费用总金额原币金额
)> ,
prplendcase array<row(
closeCaseDate String -- 结案时间
)> ,
prplcrecase array<row(
recaseDate String -- 案件重开时间
)> ,
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(
prplproploss row(
paidRate String -- 财赔付比例
) ,
verifyLoss String -- 财核定损失金额
)> ,
prplpersondetail array<row(
prplperson row(
originPaidRate String -- 人赔付比例
),
PrpLHospital row(
crippleDegreeOne String , -- 伤残等级、伤残代码、伤残程度代码
crippleDegreeOneName String , -- 伤残程度名称
treatedType String , -- 伤亡人员医疗类型
hospitalName String -- 医疗机构名称
) ,
prplsdisabilityassess row( -- miss
nonlocalIdentFlag String -- 异地鉴定标志
),
verifyLoss String -- 人核定损失金额
)> ,
prplcreplevy array<row(
prplreplevyclaim row(
prplreplevyobject array<row(
subjectTypeCode String , -- 被追偿方类型
subjectTypeName String -- 被追偿方名称
)>
)
)>
),
log_time String ,
nodeCode String
}
\ No newline at end of file
ODS/DDL元数据/POLICY.sql
View file @ 40b1a747
...@@ -52,6 +52,8 @@ POLICY_PLCBASIC ...@@ -52,6 +52,8 @@ POLICY_PLCBASIC
passengersNumber String , -- 质量校验_核定载客人数 passengersNumber String , -- 质量校验_核定载客人数
brandName String , -- 质量校验_车辆品牌名称 brandName String , -- 质量校验_车辆品牌名称
enrollDate String , -- 质量校验_车辆初次登记日期 enrollDate String , -- 质量校验_车辆初次登记日期
energyTypes String , -- 下发新增_能源种类名称
secondhandcarflag String , -- 下发新增_是否二手车
), ),
plcApplicant array<row( plcApplicant array<row(
customerName String , -- 18 投保人名称 customerName String , -- 18 投保人名称
......
ODS/数据同步/ODS_ENDOR.sql
View file @ 40b1a747
...@@ -45,6 +45,7 @@ select ...@@ -45,6 +45,7 @@ select
, plcBasic , plcBasic
, handlerCode -- 寿险销售人员代码 , handlerCode -- 寿险销售人员代码
, handlerName -- 寿险销售人员名称 , handlerName -- 寿险销售人员名称
, amount -- 新增下发_保额
from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR from ODS.SOURCE_RMQ_ENDOR_PRD.ENDOR
; ;
......
ODS/数据清洗/DUPLICK_ENDOR.sql
View file @ 40b1a747
...@@ -45,6 +45,7 @@ select ...@@ -45,6 +45,7 @@ select
, plcBasic , plcBasic
, handlerCode -- 寿险销售人员代码 , handlerCode -- 寿险销售人员代码
, handlerName -- 寿险销售人员名称 , handlerName -- 寿险销售人员名称
, amount -- 新增下发_保额
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
......
XF_DWD/XF_DWD_CAR_ENDOR.sql
View file @ 40b1a747
...@@ -42,12 +42,12 @@ select ...@@ -42,12 +42,12 @@ select
t1.LEVEL1COMCODE , -- 分公司代码 t1.LEVEL1COMCODE , -- 分公司代码
cast(cast(case when coinsLinkCode = '0' then 1 cast(cast(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 as decimal(18,4)) as varchar ) as coinsRate , -- 系数 end as decimal(18,4)) as varchar ) as coinsRate , -- 系数
s1.plcSales , s1.plcSales ,
s1.plcBasic, s1.plcBasic,
s1.handlerCode, -- 寿险销售人员代码 s1.handlerCode, -- 寿险销售人员代码
s1.handlerName -- 寿险销售人员名称 s1.handlerName , -- 寿险销售人员名称
s1.amount
from XF_ODS.XF_ODS_KAFKA.ENDOR s1 from XF_ODS.XF_ODS_KAFKA.ENDOR s1
left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE left join ODS.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'
......
XF_DWD/XF_DWD_FC_ENDOR.sql
View file @ 40b1a747
...@@ -58,7 +58,8 @@ select ...@@ -58,7 +58,8 @@ select
s1.plcSales , s1.plcSales ,
s1.plcBasic , s1.plcBasic ,
s1.handlerCode, -- 寿险销售人员代码 s1.handlerCode, -- 寿险销售人员代码
s1.handlerName -- 寿险销售人员名称 s1.handlerName , -- 寿险销售人员名称
s1.amount
from XF_ODS.XF_ODS_KAFKA.ENDOR s1 from XF_ODS.XF_ODS_KAFKA.ENDOR s1
left join ODS.ODS_MYSQL.CD_COM_ALL for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE left join ODS.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'
......
XF_DWD/新核心车险保单下发FM模板/00（新增）河南分公司车险保单全字段.ftl 0 → 100644
View file @ 40b1a747
{"systemName":"流计算平台","systemCode":"D030","sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}","msgCode":"carpolicy","msgName":"新核心车险保单信息","data":[{"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- 车架号 -->,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- 车牌号 -->,"endDate":"${endTime!}" <#-- 终保时间 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->,"policySort":"${policySort!}" <#-- 保单种类 -->,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifSelfPricesRat??><#if s1.PlcRation.artifSelfPricesRat=="">1</#if></#if>${s1.PlcRation.artifSelfPricesRat!"1"}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 自主定价系数 -->,"modelCode":"<#if plcCar05??>${plcCar05.vehicleId!}</#if>" <#-- 车型 -->,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->,"insuredName":"<#if plcPublicInsurant??><#assign a="0" /><#list plcPublicInsurant as s1><#if plcPublicInsurant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a=="1">|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 被保人名称 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->,"riskCode":"${productCode!}" <#-- 险种代码 -->,"agentNetFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentNetFee?? && item.agentNetFee!="" && a=="1">|</#if>${item.agentNetFee!}<#if item.agentNetFee?? && item.agentNetFee!=""><#assign a="1" /></#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- 车辆使用性质 -->,"appliName":"<#if plcApplicant??><#assign a="0" /><#list plcApplicant as s1><#if plcApplicant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a == "1" >|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 投保人名称 -->,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->,"startDate":"${startTime!}" <#-- 起保时间 -->}]}
{
"systemName":"流计算平台",
"systemCode":"D030",
"sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}",
"msgCode":"carpolicy",
"msgName":"新核心车险保单信息",
"data":[{
"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- 车架号 -->
,"agentComCode":"${saleaman!}" <#-- 代理机构代码 -->
,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- 车牌号 -->
,"endDate":"${endTime!}" <#-- 终保时间 -->
,"newPolicyFlag":"${newPolicyFlag!}" <#-- 新保标识 -->
,"policyNo":"<#if policyNo??>${policyNo!}<#else>${businessNo!}</#if>" <#-- 保单号 -->
,"policySort":"${policySort!}" <#-- 保单种类 -->
,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifSelfPricesRat??><#if s1.PlcRation.artifSelfPricesRat=="">1</#if></#if>${s1.PlcRation.artifSelfPricesRat!"1"}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- 自主定价系数 -->
,"modelCode":"<#if plcCar05??>${plcCar05.vehicleId!}</#if>" <#-- 车型 -->
,"comCode":"${businessOffice!}" <#-- 保单归属机构代码 -->
,"insuredName":"<#if plcPublicInsurant??><#assign a="0" /><#list plcPublicInsurant as s1><#if plcPublicInsurant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a=="1">|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 被保人名称 -->
,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- 转保标识 -->
,"riskCode":"${productCode!}" <#-- 险种代码 -->
,"agentNetFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentNetFee?? && item.agentNetFee!="" && a=="1">|</#if>${item.agentNetFee!}<#if item.agentNetFee?? && item.agentNetFee!=""><#assign a="1" /></#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->
,"agentComName":"${saleamanName!}" <#-- 代理机构名称 -->
,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->
,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- 车辆使用性质 -->
,"appliName":"<#if plcApplicant??><#assign a="0" /><#list plcApplicant as s1><#if plcApplicant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a == "1" >|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 投保人名称 -->
,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->
,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->
,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->
,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->
,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->
,"startDate":"${startTime!}" <#-- 起保时间 -->
,"ownerId":"${mainSalesmanCode!}" <#-- 归属业务员代码 -->
,"ownerName":"${mainSalesmanName!}" <#-- 归属业务员名称 -->
,"newVehicleFlag":"<#if plcCar05??>${plcCar05.newVehicleFlag!}</#if>" <#-- 新车标识 -->
,"energyCode":"<#if plcCar05??>${plcCar05.energyTypesCode!}</#if>" <#-- 能源种类编码 -->
,"fuelType":"<#if plcCar05??>${plcCar05.energyTypes!}</#if>" <#-- 能源种类名称 -->
,"secondHandCarFlag":"<#if plcCar05??>${plcCar05.secondhandcarflag!}</#if>" <#-- 是否二手车 -->
,"amount":"${amount!}" <#-- 保额 -->
,"coinsRate":"${coinsRate!}" <#-- 联保比例 -->
}]
}
[
{
"frameNo": "LFP83ACC8G1D78662",
"agentComCode": "410426198205053076",
"licenseNo": "豫A51TZ8",
"endDate": "1701705600000",
"newPolicyFlag": "0",
"policyNo": "6605072022411096012207",
"policySort": "0",
"artifSelfPricesRat": "1",
"modelCode": "HQABDD0243",
"comCode": "4110960010",
"insuredName": "陈圆",
"transferPolicyFlag": "0",
"riskCode": "0507",
"agentNetFee": "25.09",
"agentComName": "陈创西",
"businessNature": "1",
"useNatureCode": "8A",
"appliName": "陈圆",
"newChnlType": "14",
"carKindCode": "A0",
"sumPremium": "627.36",
"underWriteEndDate": "1668486703195",
"autoTransreNewFlag": "1",
"transreNewFlag": "1",
"comName": "许昌市示范区支公司数字渠道电子业务部",
"startDate": "1670169600000"
}
]
\ No newline at end of file
XF_DWD/新核心车险批单下发FM模板/00（新增）河南分公司车险批单全字段.ftl 0 → 100644
View file @ 40b1a747
{"systemName": "流计算平台","systemCode": "D030","msgName": "新核心车险批单信息","msgCode": "carEndorse","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}","data": [{"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- "xx",//车架号 -->,"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->,"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- "xx",//车牌号 -->,"endDate":"${endTime!}" <#-- "xx",//终保时间 -->,"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->,"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->,"policySort":"${policySort!}" <#-- "xx",//保单种类 -->,"agentFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentFee?? && item.agentFee!="" && a =="1">|</#if>${item.agentFee!}<#if item.agentFee?? && item.agentFee!=""><#assign a="1" /></#if></#list></#if></#list></#if>" <#-- 手续费含税金额 -->,"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifSelfPricesRat??><#if s1.PlcRation.artifSelfPricesRat=="">1</#if></#if>${s1.PlcRation.artifSelfPricesRat!"1"}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//自主定价系数 -->,"modelCode":"<#if plcCar05??>${plcCar05.vehiclecode!}</#if>" <#-- "xx",//车型 -->,"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->,"insuredName":"<#if plcPublicInsurant??><#assign a="0" /><#list plcPublicInsurant as s1><#if plcPublicInsurant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a=="1">|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 被保人名称 -->,"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->,"chgPremium":"<#if sigAndStaExchangeRate??><#if coinsRate??>${(plpEndorse.netPremiumVariation!?number * sigAndStaExchangeRate!?number * coinsRate!?number)?c}</#if></#if>" <#-- "xx",//保费变化量 -->,"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->,"agentNetFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentNetFee?? && item.agentNetFee!="" && a=="1">|</#if>${item.agentNetFee!}<#if item.agentNetFee?? && item.agentNetFee!=""><#assign a="1" /></#if></#list></#if></#list></#if>" <#-- 手续费不含税金额 -->,"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->,"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- "xx",//车辆使用性质 -->,"appliName":"<#if plcApplicant??><#assign a="0" /><#list plcApplicant as s1><#if plcApplicant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a == "1" >|</#if>${s1.customerName!}<#if s1.customerName?? && s1.customerName!=""><#assign a="1" /></#if></#list></#if>" <#-- 投保人名称 -->,"newChnlType":"${businessChannelCode!}" <#-- "xx",//清分后渠道 -->,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- "xx",//车辆种类 -->,"sumPremium":"${netPremium!}" <#-- "xx",//不含税保费 -->,"underWriteEndDate":"${uwConclueDate!}" <#-- "xx",//核保通过时间 -->,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->,"newVehicleFlag":"<#if plcCar05??>${plcCar05.newCarFlag!}</#if>" <#-- "xx",//新车标识 -->,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->,"startDate":"${startTime!}" <#-- "xx",//起保时间 -->}]}
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "新核心车险批单信息",
"msgCode": "carEndorse",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": [{
"frameNo":"<#if plcCar05??>${plcCar05.frameNo!}</#if>" <#-- "xx",//车架号 -->,
"agentComCode":"${saleaman!}" <#-- "xx",//代理机构代码 -->,
"licenseNo":"<#if plcCar05??>${plcCar05.licensePlateNo!}</#if>" <#-- "xx",//车牌号 -->,
"endDate":"${endTime!}" <#-- "xx",//终保时间 -->,
"newPolicyFlag":"${newPolicyFlag!}" <#-- "xx",//新保标识 -->,
"policyNo":"${policyNo!}" <#-- "xx",//保单号 -->,
"policySort":"${policySort!}" <#-- "xx",//保单种类 -->,
"agentFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentFee?? && item.agentFee!="" && a=="1">|</#if>${item.agentFee}<#assign a="1" /></#list></#if></#list></#if>" <#-- "xx",//手续费含税金额 -->,
"artifSelfPricesRat":"<#if plcSolution??><#list plcSolution as s1><#if s1.PlcRation.artifSelfPricesRat??><#if s1.PlcRation.artifSelfPricesRat=="">1</#if></#if>${s1.PlcRation.artifSelfPricesRat!"1"}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//自主定价系数 -->,
"modelCode":"<#if plcCar05??>${plcCar05.vehiclecode!}</#if>" <#-- "xx",//车型 -->,
"comCode":"${businessOffice!}" <#-- "xx",//归属机构 -->,
"insuredName":"<#if plcPublicInsurant??><#assign a="0" /><#list plcPublicInsurant as s1><#if plcPublicInsurant?size gt s1?index && s1.customerName?? && s1.customerName !="" && a=="1" >|</#if>${s1.customerName}<#assign a="1" /></#list></#if>" <#-- "xx",//被保人名称 -->,
"transferPolicyFlag":"${transferPolicyFlag!}" <#-- "xx",//转保标识 -->,
"chgPremium":"<#if sigAndStaExchangeRate??><#if coinsRate??>${(plpEndorse.netPremiumVariation!?number * sigAndStaExchangeRate!?number * coinsRate!?number)?c}</#if></#if>" <#-- "xx",//保费变化量 -->,
"endorseNo":"${endorseNo!}" <#-- "xx",//批单号 -->,
"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->,
"agentNetFee":"<#if plcSolution??><#assign a="0" /><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item><#if s1.plcCommissionDetail?size gt item?index && item.agentNetFee?? && item.agentNetFee!="" && a=="1" >|</#if>${item.agentNetFee}<#assign a="1" /></#list></#if></#list></#if>" <#-- "xx",//手续费不含税金额 -->,
"agentComName":"${saleamanName!}" <#-- "xx",//代理机构名称 -->,
"businessNature":"${businessNatureCode!}" <#-- 业务来源 -->,
"useNatureCode":"<#if plcCar05??>${plcCar05.carUserNatureCode!}</#if>" <#-- "xx",//车辆使用性质 -->,
"appliName":"<#if plcApplicant??><#assign a="0" /><#list plcApplicant as s1><#if plcApplicant?size gt s1?index && s1.customerName?? && s1.customerName!="" && a=="1">|</#if>${s1.customerName}<#assign a="1" /></#list></#if>"<#-- "xx",//投保人名称 -->,
"newChnlType":"${businessChannelCode!}" <#-- "xx",//清分后渠道 -->,
"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- "xx",//车辆种类 -->,
"sumPremium":"${netPremium!}" <#-- "xx",//不含税保费 -->,
"underWriteEndDate":"${uwConclueDate!}" <#-- "xx",//核保通过时间 -->,
"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 -->,
"newVehicleFlag":"<#if plcCar05??>${plcCar05.newVehicleFlag!}</#if>" <#-- "xx",//新车标识 -->,
"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->,
"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->,
"startDate":"${startTime!}" <#-- "xx",//起保时间 -->
,"ownerId":"${mainSalesmanCode!}" <#-- 归属业务员代码 -->
,"ownerName":"${mainSalesmanName!}" <#-- 归属业务员名称 -->
,"energyCode":"<#if plcCar05??>${plcCar05.energyTypesCode!}</#if>" <#-- 能源种类编码 -->
,"fuelType":"<#if plcCar05??>${plcCar05.energyTypes!}</#if>" <#-- 能源种类名称 -->
,"secondHandCarFlag":"<#if plcCar05??>${plcCar05.secondhandcarflag!}</#if>" <#-- 是否二手车 -->
,"amount":"${amount!}" <#-- 保额 -->
,"endorseCategoryCode":"<#if plpEndorse??>${plpEndorse.endorseCategoryCode!}</#if>" <#-- 批改类型编码 -->
,"endorseCategoryName":"<#if plpEndorse??>${plpEndorse.endorseCategoryName!}</#if>" <#-- 批改类型名称 -->
,"vaildDate":"<#if plpEndorse??>${plpEndorse.endorseEffectiveTime!}</#if>" <#-- 批单生效日期 -->
,"coinsRate":"${coinsRate!}" <#-- 联保比例 -->
}]
}
[
{
"frameNo": "LJDDAA2C0J0681983",
"agentComCode": "91440300MA5DMUNR74",
"licenseNo": "豫MTC697",
"endDate": "1670342400000",
"newPolicyFlag": "0",
"policyNo": "6605072022410106069663",
"policySort": "EAJ",
"agentFee": "0",
"artifSelfPricesRat": "1",
"modelCode": "BYDLSMUA0004",
"comCode": "4101060001",
"insuredName": "李许红",
"transferPolicyFlag": "0",
"chgPremium": -627.36,
"endorseNo": "6805072022410106069663001",
"riskCode": "0507",
"agentNetFee": "0",
"agentComName": "微民保险代理有限公司",
"businessNature": "207",
"useNatureCode": "8A",
"appliName": "李许红",
"newChnlType": "15",
"carKindCode": "A0",
"sumPremium": "0",
"underWriteEndDate": "1668488539766",
"autoTransreNewFlag": "1",
"newVehicleFlag": "0",
"transreNewFlag": "1",
"comName": "郑州市中心支公司上街区营销服务部创新电子渠道第一项目团队",
"startDate": "1670342400000"
}
]
\ No newline at end of file
XF_ODS/DDL元数据/ENDOR.sql
View file @ 40b1a747
...@@ -37,6 +37,8 @@ ENDOR_PLCBASIC ...@@ -37,6 +37,8 @@ ENDOR_PLCBASIC
endorsePolicyTime String , -- 指标新增_批单指标统计日期 endorsePolicyTime String , -- 指标新增_批单指标统计日期
amountVariation String , -- 指标新增_保额变化量 amountVariation String , -- 指标新增_保额变化量
premiumVariation String -- 指标新增_含税保费变化量 premiumVariation String -- 指标新增_含税保费变化量
endorseCategoryCode String , -- 下发新增_批改类型编码
endorseCategoryName String , -- 下发新增_批改类型名称
), ),
recordClerkCode String , -- 14 归属业务员ID recordClerkCode String , -- 14 归属业务员ID
...@@ -89,6 +91,9 @@ ENDOR_PLCBASIC ...@@ -89,6 +91,9 @@ ENDOR_PLCBASIC
carKindCode String , -- 新核心车险批单-车辆种类 carKindCode String , -- 新核心车险批单-车辆种类
vehiclecode String , -- 新核心车险批单-车型(用这个) vehiclecode String , -- 新核心车险批单-车型(用这个)
newCarFlag String -- 新核心车险批单-新车标识(用这个) newCarFlag String -- 新核心车险批单-新车标识(用这个)
energyTypesCode String , -- 下发新增_能源种类编码
energyTypes String , -- 下发新增_能源种类名称
secondhandcarflag String , -- 下发新增_是否二手车
), ),
plcApplicant array<row( plcApplicant array<row(
customerName String -- 新核心车险批单-投保人名称 customerName String -- 新核心车险批单-投保人名称
...@@ -127,6 +132,8 @@ ENDOR_PLCBASIC ...@@ -127,6 +132,8 @@ ENDOR_PLCBASIC
), ),
handlerCode String , -- 寿险销售人员代码 handlerCode String , -- 寿险销售人员代码
handlerName String -- 寿险销售人员名称 handlerName String -- 寿险销售人员名称
amount String , -- 新增下发_保额
) )
......
XF_ODS/DDL元数据/LPDATA.sql 0 → 100644
View file @ 40b1a747
-- LPDATA 理赔业务数据
业务对象命名：
LPDATA
LPDATA_ACTUALDATA
LPDATA_ACTUALDATA_PRPLCREGIST
LPDATA_ACTUALDATA_PRPLCREGIST_PRPLREPORTER
LPDATA_ACTUALDATA_PRPLCREGIST_PRPLLINKER
LPDATA_ACTUALDATA_PRPLPOLICY
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL
LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
LPDATA_ACTUALDATA_PRPLCDAMAGE
LPDATA_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 -- 联系人电话
),
thridClaimComCode String ,
thridClaimComName String
)> ,
prplpolicy 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 String ,
nodeCode String ,
comCode String , -- 取 prplpolicy selected=1得一条数据字段
comName String , -- 取 prplpolicy selected=1得一条数据字段
riskCode String , -- 取 prplpolicy selected=1得一条数据字段
riskName String , -- 取 prplpolicy selected=1得一条数据字段
licenseNo String , -- 取 prplpolicy selected=1得一条数据字段
LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构
}
\ No newline at end of file
XF_ODS/DDL元数据/POLICY.sql
View file @ 40b1a747
...@@ -40,6 +40,8 @@ POLICY_PLCBASIC ...@@ -40,6 +40,8 @@ POLICY_PLCBASIC
vehicleId String , -- 新核心车险保单-车型 vehicleId String , -- 新核心车险保单-车型
newVehicleFlag String , -- 新核心车险保单-新车标识 newVehicleFlag String , -- 新核心车险保单-新车标识
actualvalue String -- 新核心车险保单-实际价值 actualvalue String -- 新核心车险保单-实际价值
energyTypes String , -- 下发新增_能源种类名称
secondhandcarflag String , -- 下发新增_是否二手车
), ),
plcApplicant array<row( plcApplicant array<row(
customerName String -- 18 投保人名称 customerName String -- 18 投保人名称
......
ZB_ODS/承保同步/ZB_ODS_CBDATA.sql
View file @ 40b1a747
-- ZB_ODS_CBDATA ZB_ODS_指标加工承保业务数据 -- ZB_ODS_CBDATA ZB_ODS_指标加工承保业务数据
-- 保费计算 -- 保费计算
-- -- 车险非车都可能存在联保，非车也可能即共又联
-- 1、非车险共保我方保费系数 = 承保保费 * plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate(系数) -- 1、非车险共保我方保费系数 = 承保保费 * plcSolution[1].plcCoins.plcCoinsBasicInformation[1].coinsRate(系数)
-- coinsRate 有值 ，系数 = coinsRate -- coinsRate 有值 ，系数 = coinsRate
-- coinsRate 无值 ，系数 = 1 -- coinsRate 无值 ，系数 = 1
......
temp2.sql
View file @ 40b1a747
This source diff could not be displayed because it is too large. You can view the blob instead.
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 北京云端微服科技有限公司