Skip to content

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

指标计算承保字段调整

parent 40b1a747
Expand all Show whitespace changes
Inline Side-by-side
Showing with 153 additions and 108 deletions
ODS/DDL元数据/LPDATA.sql
View file @ 138abde8
......@@ -15,6 +15,7 @@ LPDATA_ACTUALDATA_PRPLCDAMAGE
LPDATA_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
LPDATA_ACTUALDATA_PRPLCCHECK
LPDATA_ACTUALDATA_PRPLCLAIM
LPDATA_ACTUALDATA_PRPLCLAIM_PRPLCLAIMLOSS
LPDATA_ACTUALDATA_PRPLCCOMPENSATE
LPDATA_ACTUALDATA_PRPLENDCASE
LPDATA_ACTUALDATA_PRPLCRECASE
......@@ -30,7 +31,8 @@ LPDATA_ACTUALDATA_PRPLPERSONDETAIL_PRPLSDISABILITYASSESS
LPDATA_ACTUALDATA_PRPLCREPLEVY
LPDATA_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM
LPDATA_ACTUALDATA_PRPLCREPLEVY_PRPLREPLEVYCLAIM_PRPLREPLEVYOBJECT
LPDATA_ACTUALDATA_PRPLCLAIM
LPDATA_ACTUALDATA_PRPLCASEMODIFY
......@@ -65,16 +67,16 @@ LPDATA_ACTUALDATA_PRPLCLAIM
-- licenseNo String , -- 车牌号
-- isSelected String -- 是否选择
-- )> ,
prplcarlossdetail array<row(
prplcarlossdetail array<row( -- 2
prplcar row(
brandCode String , -- 品牌
carModelCode String -- 车型
) ,
indemnityDutyRate String , -- 车赔付比例
prplrepairfactory array<row(
prplrepairfactory array<row( -- [{}] 2
repairFactoryName String -- 修理厂名称
)> ,
prplcarcertain row(
prplcarcertain row( -- {} 1
injurySiteCode String -- 受伤部位
) ,
verifyLoss String -- 车核定损失金额
......@@ -91,8 +93,13 @@ LPDATA_ACTUALDATA_PRPLCLAIM
checkDate String -- 查勘日期
) ,
prplclaim array<row(
riskCode String , -- 险种
claimDate String , -- 出险时间
sumclaim String -- 估损金额
prplclaimloss array<row(
claimno String ,-- 立案号码
claimInputDate String -- 估损调整时间
)>
)> ,
prplccompensate array<row(
compensateVericDate String , -- 核赔日期
......@@ -148,7 +155,11 @@ LPDATA_ACTUALDATA_PRPLCLAIM
subjectTypeName String -- 被追偿方名称
)>
)
)> ,
prplcasemodify array<row (
sumChangeLoss String -- 估损提转差
)>
),
log_time String ,
......
ODS/DDL元数据/LPDATA原始数据.json 0 → 100644
View file @ 138abde8
This source diff could not be displayed because it is too large. You can view the blob instead.
XF_DWD/XF_DWD_CAR_CLAIM.sql 0 → 100644
View file @ 138abde8
-- XF_DWD_CAR_CLAIM XF_DWD_车险理赔立案业务数据
select
s1.actualData ,
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间
s1.nodeCode,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','comCode') as comCode ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','comName') as comName ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','riskCode') as riskCode ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','riskName') as riskName ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','licenseNo') as licenseNo ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','policyNo') as policyNo ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','insuredCode') as insuredCode ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','insuredName') as insuredName ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','businessNatureCode') as businessNatureCode ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','channelType') as channelType ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','applicantCode') as applicantCode ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','applicantName') as applicantName ,
t1.LEVEL1COMCODE -- 分公司代码
from XF_ODS.XF_ODS_KAFKA.LPDATA s1
left join XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM for system_time as of s1.proctime as t1 on s1.actualData.prplcregist[CARDINALITY(s1.actualData.prplcregist)].deptCode = t1.COMCODE
where
-- s1.nodeCode = 'ClaimCar' --
-- and
substring(s1.actualData.accidentNo,3,2) = '05'
XF_DWD/XF_DWD_CAR_REGIST.sql
View file @ 138abde8
-- XF_DWD_CAR_REGIST XF_DWD_车险理赔报案业务数据
-- XF_DWD_LPDATA XF_DWD_理赔业务数据
select
s1.actualData ,
DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time , -- 加工平台处理数据时间
......@@ -9,11 +9,11 @@ select
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','riskName') as riskName ,
JsonArrayConcatUDF(s1.actualData.prplpolicy,'isSelected','1','licenseNo') as licenseNo ,
t1.LEVEL1COMCODE -- 分公司代码
from XF_ODS.XF_ODS_KAFKA.REGIST s1
from XF_ODS.XF_ODS_KAFKA.LPDATA s1
left join XF_ODS.XF_ODS_MYSQL.CD_COM_CLAIM for system_time as of s1.proctime as t1 on s1.actualData.prplcregist[CARDINALITY(s1.actualData.prplcregist)].deptCode = t1.COMCODE
where
s1.nodeCode = 'RegistCar'
and
-- s1.nodeCode = 'RegistCar'
-- and
substring(s1.actualData.accidentNo,3,2) = '05'
XF_DWD/新核心车险理赔立案下发FM模板/00车险立案下发全字段.ftl 0 → 100644
View file @ 138abde8
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "车险理赔环节信息",
"msgCode": "ClaimCase-ClaimCar",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": {
"claimNo":"<#if actualData.prplclaim??><#list actualData.prplclaim as s1><#if s1.riskCode==riskCode><#if actualData.prplclaim.prplclaimloss??>${actualData.prplclaim.prplclaimloss.claimNo!}</#if></#if></#list></#if>" <#-- "xx",// 赔案号 -->
,"claimDate":"<#if actualData.prplclaim??>${actualData.prplclaim.claimDate!}</#if>" <#-- "xx",//立案日期 -->
,"policyNo":"${policyNo}" <#-- "xx",//保单号码 -->
,"riskCode":"${riskCode!}" <#-- "xx",//险种代码 -->
,"comCode":"${comCode!}" <#-- "xx",// -->
,"insuredCode":"${insuredCode}" <#-- "xx",// -->
,"insuredName":"${insuredName}" <#-- "xx",// -->
,"businessNatureCode":"${businessNatureCode}" <#-- "xx",//业务来源代码 -->
,"channelType":"${channelType}" <#-- "xx",//渠道 -->
,"applicantCode":"${applicantCode}" <#-- "xx",//纬度 -->
,"applicantName":"${applicantName}" <#-- "xx",//纬度 -->
,"sumclaim":"<#if actualData.prplclaim??>${actualData.prplclaim.sumclaim!}</#if>" <#-- "xx",//估损金额 -->
,"sumChangeLoss":"<#if actualData.prplcasemodify??>${actualData.prplcasemodify.sumChangeLoss!}</#if>" <#-- "xx",// -->
,"claimInputDate":"<#if actualData.prplclaim??><#if actualData.prplclaim.prplclaimloss??>${actualData.prplclaim.prplclaimloss.claimInputDate!}</#if></#if>" <#-- "xx",// -->
}}
{"systemName": "流计算平台","systemCode": "D030","msgName": "车险理赔环节信息","msgCode": "ClaimCase-ClaimCar","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}","data": {,"policyNo":"${policyNo}" <#-- "xx",//保单号码 -->,"riskCode":"${riskCode!}" <#-- "xx",//险种代码 -->,"comCode":"${comCode!}" <#-- "xx",// -->,"insuredCode":"${insuredCode}" <#-- "xx",// -->,"insuredName":"${insuredName}" <#-- "xx",// -->,"businessNatureCode":"${businessNatureCode}" <#-- "xx",//业务来源代码 -->,"channelType":"${channelType}" <#-- "xx",//渠道 -->,"applicantCode":"${applicantCode}" <#-- "xx",//纬度 -->,"applicantName":"${applicantName}" <#-- "xx",//纬度 -->}}
\ No newline at end of file
XF_ODS/DDL元数据/LPDATA.sql
View file @ 138abde8
......@@ -12,6 +12,10 @@ LPDATA_ACTUALDATA_PRPLCARLOSSDETAIL_PRPLCAR
LPDATA_ACTUALDATA_PRPLCDAMAGE
LPDATA_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
LPDATA_ACTUALDATA_PRPLCLAIM
LPDATA_ACTUALDATA_PRPLCLAIM_PRPLCLAIMLOSS
LPDATA_ACTUALDATA_PRPLCASEMODIFY
{
actualData row(
accidentNo String , -- 事故号
......@@ -55,7 +59,19 @@ LPDATA_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
) ,
damageName String , -- 出险原因
damageCourse String -- 出险经过
)
) ,
prplclaim array<row(
riskCode String , -- 险种
claimDate String , -- 出险时间
sumclaim String -- 估损金额
prplclaimloss array<row(
claimno String ,-- 立案号码
claimInputDate String -- 估损调整时间
)>
)> ,
prplcasemodify array<row (
sumChangeLoss String -- 估损提转差
)>
) ,
log_time String ,
......@@ -66,5 +82,12 @@ LPDATA_ACTUALDATA_PRPLCDAMAGE_PRPLDAMAGEADDRESS
riskName String , -- 取 prplpolicy selected=1得一条数据字段
licenseNo String , -- 取 prplpolicy selected=1得一条数据字段
LEVEL1COMCODE String -- 数据分发规则记录数据对应分公司机构
policyNo -- 保单号码
insuredCode -- 被保人代码
insuredName -- 被保人名称
businessNatureCode -- 业务来源
channelType -- 渠道类别
applicantCode -- 投保人代码
applicantName -- 投保人名称
}
\ No newline at end of file
temp2.sql
View file @ 138abde8
This diff is collapsed.
temp3.ftl
View file @ 138abde8
CONTRACTNO
POLICYNO
COMPANYCODE
APPLICANT_CUSTOMID
APPLICANT_CERD_TYPE
APPLICANT_CERD_NO
DRIVER_KIND
CARID
TEL
EMAIL
ADDRESS
CAR_RELATION
SALESID
AMOUNT
PREMIUM
SIGNDATE
APPLICATIONDATE
VALIDATE
EXPIRYDATE
STAT
CREAT_TIME
MODIFY_TIME
SYS_DATACREATETIME
SYS_DATAMODITYTIME
SYS_DATAPKMD5
SYS_DATAALLMD5
SYS_PARTI
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "车险理赔环节信息",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": {
"riskName":"${riskName!}" <#-- "xx",//险种名称 -->,
"deptName":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.deptName?? && s1.deptName!="" && a =="1">|</#if>${s1.deptName!}<#if s1.deptName?? && s1.deptName!=""><#assign a="1" /></#if></#list></#if>" <#-- "xx",//理赔机构名称 -->,
"licenseNo":"${licenseNo!}" <#-- "xx",//车牌号 -->,
"accidentNo":"${actualData.accidentNo!}" <#-- "xx",//事故号 -->,
"latitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.latitude!}</#if></#if>" <#-- "xx",//纬度 -->,
"policyNo":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.policyNo?? && s1.policyNo!="" && a=="1">|</#if>${s1.policyNo!}<#if s1.policyNo?? && s1.policyNo!=""><#assign a="1" /></#if></#list></#if>" <#-- "xx",//保单号 -->,
"thridClaimComCode":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.thridClaimComCode?? && s1.thridClaimComCode!="" && a=="1">|</#if>${s1.thridClaimComCode!}<#if s1.thridClaimComCode?? && s1.thridClaimComCode!=""><#assign a="1" /></#if></#list></#if>",
"registNo":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.registNo?? && s1.registNo!="" && a=="1">|</#if>${s1.registNo!}<#if s1.registNo?? && s1.registNo!=""><#assign a="1" /></#if></#list></#if>" <#-- "xx",//报案号 -->,
"claimComCode":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.deptCode?? && s1.deptCode!="" && a=="1">|</#if>${s1.deptCode!}<#if s1.deptCode?? && s1.deptCode!=""><#assign a="1" /></#if></#list></#if>" <#-- "xx",//理赔机构代码 -->,
"reportorName":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if s1.prplreporter??><#if actualData.prplcregist?size gt s1?index && s1.prplreporter.reporterName?? && s1.prplreporter.reporterName!="" && a=="1">|</#if>${s1.prplreporter.reporterName!}<#if s1.prplreporter.reporterName?? && s1.prplreporter.reporterName!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//报案人名称 -->,
"reportDate":"${actualData.reportDate!}" <#-- "xx",//报案时间 -->,
"modelCode":"<#if actualData.prplcarlossdetail??><#assign a="0" /><#list actualData.prplcarlossdetail as s1><#if s1.prplcar??><#if actualData.prplcarlossdetail?size gt s1?index && s1.prplcar.carModelCode?? && s1.prplcar.carModelCode!="" && a=="1">|</#if>${s1.prplcar.carModelCode!}<#if s1.prplcar.carModelCode?? && s1.prplcar.carModelCode!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//车型 -->,
"damageStartDate":"${actualData.damageStartDate!}" <#-- "xx",//出险时间 -->,
"damageTypeDesc":"<#if actualData.prplcdamage??>${actualData.prplcdamage.damageName!}</#if>" <#-- "xx",//出险原因 -->,
"reportorPhone":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if s1.prplreporter??><#if actualData.prplcregist?size gt s1?index && s1.prplreporter.reporterMobileNo?? && s1.prplreporter.reporterMobileNo!="" && a=="1">|</#if>${s1.prplreporter.reporterMobileNo!}<#if s1.prplreporter.reporterMobileNo?? && s1.prplreporter.reporterMobileNo!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//报案人电话 -->,
"linkerName":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if s1.prpllinker??><#if actualData.prplcregist?size gt s1?index && s1.prpllinker.linkerName?? && s1.prpllinker.linkerName!="" && a=="1">|</#if>${s1.prpllinker.linkerName!}<#if s1.prpllinker.linkerName?? && s1.prpllinker.linkerName!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//联系人名称 -->,
"comCode":"${comCode!}" <#-- "xx",//承保机构代码 -->,
"brandCode":"<#if actualData.prplcarlossdetail??><#assign a="0" /><#list actualData.prplcarlossdetail as s1><#if s1.prplcar??><#if actualData.prplcarlossdetail?size gt s1?index && s1.prplcar.brandCode?? && s1.prplcar.brandCode!="" && a=="1">|</#if>${s1.prplcar.brandCode!}<#if s1.prplcar.brandCode?? && s1.prplcar.brandCode!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//品牌 -->,
"longitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.longitude!}</#if></#if>" <#-- "xx",//经度 -->,
"damageAddress":"${actualData.damageAddress!?replace("\t","")?replace("","")}" <#-- "xx",//出险地点 -->,
"riskCode":"${riskCode!}" <#-- "xx",//险种代码 -->,
"thridClaimComName":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if actualData.prplcregist?size gt s1?index && s1.thridClaimComName?? && s1.thridClaimComName!="" && a=="1">|</#if>${s1.thridClaimComName!}<#if s1.thridClaimComName?? && s1.thridClaimComName!=""><#assign a="1" /></#if></#list></#if>","phoneNumber":"<#if actualData.prplcregist??><#assign a="0" /><#list actualData.prplcregist as s1><#if s1.prpllinker??><#if actualData.prplcregist?size-1 gt s1?index && s1.prpllinker.linkerPhoneNo?? && s1.prpllinker.linkerPhoneNo!="" && a=="1">|</#if>${s1.prpllinker.linkerPhoneNo!}<#if s1.prpllinker.linkerPhoneNo?? && s1.prpllinker.linkerPhoneNo!=""><#assign a="1" /></#if></#if></#list></#if>" <#-- "xx",//联系人电话 -->,
"comName":"${comName!}" <#-- "xx",//承保机构名称 -->,
"damageCourse":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.damageCourse??>${actualData.prplcdamage.damageCourse!?replace("","")?replace("\t","")}</#if></#if>" <#-- "xx",//出险经过 -->,
{"CONTRACTNO": "${CONTRACTNO!}","POLICYNO": "${POLICYNO!}","COMPANYCODE": "${COMPANYCODE!}","APPLICANT_CUSTOMID": "${APPLICANT_CUSTOMID!}","APPLICANT_CERD_TYPE": "${APPLICANT_CERD_TYPE!}","APPLICANT_CERD_NO": "${APPLICANT_CERD_NO!}","DRIVER_KIND": "${DRIVER_KIND!}","CARID": "${CARID!}","TEL": "${TEL!}","EMAIL": "${EMAIL!}","ADDRESS": "${ADDRESS!}","CAR_RELATION": "${CAR_RELATION!}","SALESID": "${SALESID!}","AMOUNT": "${AMOUNT!}","PREMIUM": "${PREMIUM!}","SIGNDATE": "${SIGNDATE!}","APPLICATIONDATE": "${APPLICATIONDATE!}","VALIDATE": "${VALIDATE!}","EXPIRYDATE": "${EXPIRYDATE!}","STAT": "${STAT!}","CREAT_TIME": "${CREAT_TIME!}","MODIFY_TIME": "${MODIFY_TIME!}","SYS_DATACREATETIME": "${SYS_DATACREATETIME!}","SYS_DATAMODITYTIME": "${SYS_DATAMODITYTIME!}","SYS_DATAPKMD5": "${SYS_DATAPKMD5!}","SYS_DATAALLMD5": "${SYS_DATAALLMD5!}","SYS_PARTI": "${SYS_PARTI!}"}
"claimNo":"<#if actualData.prplclaim??><#if actualData.prplclaim.prplclaimloss??>${actualData.prplclaim.prplclaimloss.claimNo!}</#if></#if>" <#-- "xx",// 赔案号 -->,
"claimDate":"<#if actualData.prplclaim??>${actualData.prplclaim.claimDate!}</#if>" <#-- "xx",//立案日期 -->,
"policyNo":"<#if actualData.prplpolicy??>${actualData.prplpolicy.policyNo!}</#if>" <#-- "xx",//保单号码 -->,
"comCode":"<#if actualData.prplpolicy??>${actualData.prplpolicy.comCode!}</#if>" <#-- "xx",// -->,
"insuredCode":"<#if actualData.prplpolicy??>${actualData.prplpolicy.insuredCode!}</#if>" <#-- "xx",// -->,
"insuredName":"<#if actualData.prplpolicy??>${actualData.prplpolicy.insuredName!}</#if>" <#-- "xx",// -->,
"businessNatureCode":"<#if actualData.prplpolicy??>${actualData.prplpolicy.businessNatureCode!}</#if>" <#-- "xx",//业务来源代码 -->,
"channelType":"<#if actualData.prplpolicy??>${actualData.prplpolicy.channelType!}</#if>" <#-- "xx",//渠道 -->,
"applicantCode":"<#if actualData.prplpolicy??>${actualData.prplpolicy.applicantCode!}</#if>" <#-- "xx",//纬度 -->,
"applicantName":"<#if actualData.prplpolicy??>${actualData.prplpolicy.applicantName!}</#if>" <#-- "xx",//纬度 -->,
"sumclaim":"<#if actualData.prplclaim??>${actualData.prplclaim.sumclaim!}</#if>" <#-- "xx",//估损金额 -->,
"sumChangeLoss":"<#if actualData.prplcasemodify??>${actualData.prplcasemodify.sumChangeLoss!}</#if>" <#-- "xx",// -->,
"claimInputDate":"<#if actualData.prplclaim??><#if actualData.prplclaim.prplclaimloss??>${actualData.prplclaim.prplclaimloss.claimInputDate!}</#if></#if>" <#-- "xx",// -->
}}
\ No newline at end of file
tmp.json
View file @ 138abde8
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('DataValid', '数据质量校验规则', null, 'com.ydwf.bridge.service.JobWorkExecutorEnginer', 'powerjob任务引擎通用入口', 'DATAPROCESS-DataCheckEnginer', '数据质量校验执行引擎', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-26 09:03:51', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('DATA_CHECK', '数据校验规则', null, 'com.ydwf.job.processor.DataCheckEngineProcessor', 'powerjob任务引擎数据校验引擎入口', 'FLINKSQL-DATACHECK', '数据校验引擎任务调度处理器', '', '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('DATA_DISTRIBUTION', '数据分发规则', null, 'com.ydwf.job.processor.DataDistributeEngineProcessor', 'powerjob任务引擎数据分发入口', 'FLINKSQL-DISTRIBUTE', '数据分发引擎任务调度处理器', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('DATA_EARLY_WARNING', '数据预警规则', null, 'com.ydwf.job.processor.DataAdvNoticeEngineProcessor', 'powerjob任务引擎数据预警入口', 'FLINKSQL-ADVNOTICE', '数据预警引擎任务调度处理器', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('DATA_PROCESSING', '数据加工规则', null, 'com.ydwf.job.processor.DataTransEngineProcessor', 'powerjob任务引擎数据加工入口', 'FLINKSQL-DATAPROCESS', '数据加工引擎任务调度处理器', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('FLOW', '工作流', null, '', '', '', '', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('RULE_END', '加工结束处理规则', null, 'com.ydwf.bridge.service.JobWorkExecutorEnginer', 'powerjob任务引擎通用入口', '', '事件处理引擎', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-26 09:04:39', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('SCRIPT_EXECUTION', '执行脚本规则', null, 'com.ydwf.job.processor.RuleScriptEngineProcessor', 'powerjob任务引擎脚本规则入口', 'SCRIPT-GROOVYEXEC', '数据执行脚本任务调度处理器', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('SQL', '数据转换规则', null, 'com.ydwf.bridge.service.JobWorkExecutorEnginer', 'powerjob任务引擎通用入口', 'DATAPROCESS-DataTransEnginer', '数据转换执行引擎', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-26 09:00:48', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('Text', '报送文件生成规则', null, 'com.ydwf.bridge.service.JobWorkExecutorEnginer', 'powerjob任务引擎通用入口', 'DATAPROCESS-DataExportEnginer', '文件生成执行引擎', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-26 09:02:17', '', '2021-06-16 17:27:53');
INSERT INTO db_dataprocess.tb_dp_rule_type (RULE_TYPE_ID, RULE_TYPE_DESC, JOBWORKER_CODE, JOBWOKER_CODE, JOBWORKER_DESC, RULE_ENGINER_CODE, RULE_ENGINER_DESC, RULE_ENGINER_TEMPLATE, PARTNERCODE, SYSTEM_ID, STATUS, CREATE_BY, CREATE_TIME, UPDATE_BY, UPDATE_TIME) VALUES ('Upload', '文件上传规则', null, 'com.ydwf.bridge.service.JobWorkExecutorEnginer', 'powerjob任务引擎通用入口', 'DATAPROCESS-DataUploadEnginer', '文件上传执行引擎', null, '4001', 'DATAQUALITY', '1', 'huanglei', '2021-05-28 11:41:24', '', '2021-06-16 17:27:53');
\ No newline at end of file
`actualData` row(
`prplcreplevy` array<row(
`prplreplevyclaim` row(
`prplreplevyobject` array<row( `subjectTypeName` STRING, `subjectTypeCode` STRING )> ) )>, `prplpersondetail` array<row( `verifyLoss` STRING, `prplsdisabilityassess` row( `nonlocalIdentFlag` STRING ), `PrpLHospital` row( `hospitalName` STRING, `treatedType` STRING, `crippleDegreeOneName` STRING, `crippleDegreeOne` STRING ), `prplperson` row( `originPaidRate` STRING ) )>, `prplproplossdetail` array<row( `verifyLoss` STRING, `prplproploss` row( `paidRate` STRING ) )>, `prplflag` row( `subCertiTypeName` STRING, `subCertiType` STRING ), `prplaccident` row( `accidentDealTypeName` STRING, `accidentDealType` STRING, `damageTypeName` STRING, `damageTypeCode` STRING ), `damageCode` STRING, `damageName` STRING, `prplcertify` row( `completeDate` STRING ), `prplcrecase` array<row( `recaseDate` STRING )>, `prplendcase` array<row( `closeCaseDate` STRING )>, `prplccompensate` array<row( `sumDutyPaid` STRING, `sumThisPaid` STRING, `compensateVericDate` STRING )>,
`prplclaim` array<row( `prplclaimloss` row( `claimNo` STRING, `claimInputDate` STRING ), `sumclaim` STRING, `claimDate` STRING )>, `prplccheck` row( `checkDate` STRING ), `prplcdamage` row( `damageCourse` STRING, `damageName` STRING, `prpldamageaddress` row( `latitude` STRING, `longitude` STRING ) ),
`prplcarlossdetail` array<row( `verifyLoss` STRING, `prplcarcertain` row( `injurySiteCode` STRING ), `prplrepairfactory` array<row( `repairFactoryName` STRING )>, `indemnityDutyRate` STRING, `prplcar` row( `carModelCode` STRING, `brandCode` STRING ) )>, `prplpolicy` STRING, `prplcregist` array<row( `thridClaimComName` STRING, `thridClaimComCode` STRING, `prpllinker` row( `linkerPhoneNo` STRING, `linkerName` STRING ), `prplreporter` row( `reporterMobileNo` STRING, `reporterName` STRING ), `deptName` STRING, `deptCode` STRING, `registNo` STRING, `policyNo` STRING )>, `damageAddress` STRING, `reportDate` STRING, `damageStartDate` STRING, `accidentNo` STRING ), `log_time` STRING, `nodeCode` STRING, proctime as PROCTIME()
\ No newline at end of file
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 北京云端微服科技有限公司