Skip to content

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

指标计算承保字段调整

parent d11bed2f
Hide whitespace changes
Inline Side-by-side
Showing with 800 additions and 87 deletions
XF_CK/数据同步/XF_CK_TAB_COMMEN.sql
View file @ 4b661429
-- XF_CK_TAB_COMMEN XF_CK_下发结果表
insert into XF_CK.XF_CK_MYSQL.TAB_COMMEN -- 动态调整TOPIC
select
'江苏' as comname ,
'陕西' as comname ,
systemName ,
systemCode ,
sendTime ,
......
XF_DWD/新核心车险保单下发FM模板/广西壮族自治区车险保单下发全字段.ftl 0 → 100644
View file @ 4b661429
{
"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!}<#assign a="1" /></#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!}<#assign a="1" /></#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!}<#assign a="1" /></#list></#if>" <#-- 投保人名称 -->
,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->
,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->
,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->
,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->
,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->
,"startDate":"${startTime!}" <#-- 起保时间 -->
}]
}
[
{
"frameNo": "LZWADAGA3HB117596",
"agentComCode": "89914904-8",
"licenseNo": "桂DM6970",
"endDate": "1700496000000",
"newPolicyFlag": "0",
"policyNo": "6605072022450422002749",
"policySort": "0",
"artifSelfPricesRat": "1",
"modelCode": "BJGADD0024",
"comCode": "4504223601",
"insuredName": "黄定志",
"transferPolicyFlag": "0",
"riskCode": "0507",
"agentNetFee": "22.83",
"agentComName": "中国人寿保险股份有限公司梧州分公司",
"businessNature": "b",
"useNatureCode": "8A",
"appliName": "黄定志",
"newChnlType": "03",
"carKindCode": "A0",
"sumPremium": "570.75",
"underWriteEndDate": "1667892507448",
"autoTransreNewFlag": "1",
"transreNewFlag": "1",
"comName": "梧州藤县县支公司互动渠道藤县一部",
"startDate": "1668960000000"
}
]
\ No newline at end of file
XF_DWD/新核心车险保单下发FM模板/河南分公司车险保单全字段.ftl 0 → 100644
View file @ 4b661429
{
"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!}<#assign a="1" /></#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!}<#assign a="1" /></#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!}<#assign a="1" /></#list></#if>" <#-- 投保人名称 -->
,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->
,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->
,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->
,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->
,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->
,"startDate":"${startTime!}" <#-- 起保时间 -->
}]
}
[
{
"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模板/老系统实际下发车险保单数据/广西壮族自治区分公司.json 0 → 100644
View file @ 4b661429
[
{
"frameNo": "LZWADAGA3HB117596",
"agentComCode": "89914904-8",
"licenseNo": "桂DM6970",
"endDate": "1700496000000",
"newPolicyFlag": "0",
"policyNo": "6605072022450422002749",
"policySort": "0",
"artifSelfPricesRat": "1",
"modelCode": "BJGADD0024",
"comCode": "4504223601",
"insuredName": "黄定志",
"transferPolicyFlag": "0",
"riskCode": "0507",
"agentNetFee": "22.83",
"agentComName": "中国人寿保险股份有限公司梧州分公司",
"businessNature": "b",
"useNatureCode": "8A",
"appliName": "黄定志",
"newChnlType": "03",
"carKindCode": "A0",
"sumPremium": "570.75",
"underWriteEndDate": "1667892507448",
"autoTransreNewFlag": "1",
"transreNewFlag": "1",
"comName": "梧州藤县县支公司互动渠道藤县一部",
"startDate": "1668960000000"
}
]
\ No newline at end of file
XF_DWD/新核心车险保单下发FM模板/老系统实际下发车险保单数据/河南分公司.json 0 → 100644
View file @ 4b661429
[
{
"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模板/老系统实际下发车险保单数据/贵州分公司.json 0 → 100644
View file @ 4b661429
[
{
"frameNo": "LS5A2DEE6KA402643",
"agentComCode": "91520103MA6HEMQQ80-06",
"licenseNo": "贵H68A29",
"endDate": "1700928000000",
"newPolicyFlag": "0",
"policyNo": "6605212022522694003236",
"policySort": "0",
"artifSelfPricesRat": "0.85",
"modelCode": "CAADSD0039",
"comCode": "5226946001",
"insuredName": "吴传友",
"transferPolicyFlag": "0",
"riskCode": "0521",
"agentNetFee": "58.07",
"agentComName": "车车保险销售服务有限公司贵州分公司",
"businessNature": "2",
"useNatureCode": "8A",
"appliName": "吴传友",
"newChnlType": "09",
"carKindCode": "A0",
"sumPremium": "446.68",
"underWriteEndDate": "1668492791580",
"autoTransreNewFlag": "1",
"transreNewFlag": "1",
"comName": "黔东南州中心支公司营业四部车行业务一分部",
"startDate": "1669392000000"
}
]
\ No newline at end of file
XF_DWD/新核心车险保单下发FM模板/贵州分公司车险保单全字段.ftl 0 → 100644
View file @ 4b661429
{
"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!}<#assign a="1" /></#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!}<#assign a="1" /></#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!}<#assign a="1" /></#list></#if>" <#-- 投保人名称 -->
,"newChnlType":"${businessChannelCode!}" <#-- 清分后渠道 -->
,"carKindCode":"<#if plcCar05??>${plcCar05.carKindCode!}</#if>" <#-- 车辆种类 -->
,"sumPremium":"${netPremium!}" <#-- 不含税保费 -->
,"underWriteEndDate":"${policyCreatDate!}" <#-- 核保通过时间 -->
,"autoTransreNewFlag":"${autoTransrenewFlag!}" <#-- 自动续保标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- 续保标识 -->
,"comName":"${businessOfficeName!}" <#-- 保单归属机构名称 -->
,"startDate":"${startTime!}" <#-- 起保时间 -->
}]
}
[
{
"frameNo": "LS5A2DEE6KA402643",
"agentComCode": "91520103MA6HEMQQ80-06",
"licenseNo": "贵H68A29",
"endDate": "1700928000000",
"newPolicyFlag": "0",
"policyNo": "6605212022522694003236",
"policySort": "0",
"artifSelfPricesRat": "0.85",
"modelCode": "CAADSD0039",
"comCode": "5226946001",
"insuredName": "吴传友",
"transferPolicyFlag": "0",
"riskCode": "0521",
"agentNetFee": "58.07",
"agentComName": "车车保险销售服务有限公司贵州分公司",
"businessNature": "2",
"useNatureCode": "8A",
"appliName": "吴传友",
"newChnlType": "09",
"carKindCode": "A0",
"sumPremium": "446.68",
"underWriteEndDate": "1668492791580",
"autoTransreNewFlag": "1",
"transreNewFlag": "1",
"comName": "黔东南州中心支公司营业四部车行业务一分部",
"startDate": "1669392000000"
}
]]
\ No newline at end of file
XF_DWD/新核心车险批单下发FM模板/河南分公司车险批单全字段.ftl 0 → 100644
View file @ 4b661429
{
"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}</#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.newCarFlag!}</#if>" <#-- "xx",//新车标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->
,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->
,"startDate":"${startTime!}" <#-- "xx",//起保时间 -->
}]
}
[
{
"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_DWD/新核心车险批单下发FM模板/老系统实际下发车险批单数据/河南分公司.json 0 → 100644
View file @ 4b661429
[
{
"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_DWD/新核心车险批单下发FM模板/老系统实际下发车险批单数据/贵州分公司.json 0 → 100644
View file @ 4b661429
[
{
"frameNo": "LJ11RBBD1K1900596",
"agentComCode": "522725198409090060",
"licenseNo": "贵CY657Q",
"endDate": "1668528000000",
"newPolicyFlag": "0",
"policyNo": "6605212022520116002834",
"policySort": "0",
"agentFee": "79.86",
"artifSelfPricesRat": "1.35",
"modelCode": "BJHASMUB0071",
"comCode": "5201160001",
"insuredName": "赵兰兰",
"transferPolicyFlag": "1",
"chgPremium": -2408.1,
"endorseNo": "6805212022520116002834001",
"riskCode": "0521",
"agentNetFee": "79.86",
"agentComName": "苟雪姣",
"businessNature": "1",
"useNatureCode": "8D",
"appliName": "赵兰兰",
"newChnlType": "12",
"carKindCode": "H0",
"sumPremium": "2218.4",
"underWriteEndDate": "1668495399011",
"autoTransreNewFlag": " ",
"newVehicleFlag": "0",
"transreNewFlag": "0",
"comName": "贵阳市高新区支公司政保团队",
"startDate": "1653408000000"
}
]
\ No newline at end of file
XF_DWD/新核心车险批单下发FM模板/贵州分公司车险批单全字段.ftl 0 → 100644
View file @ 4b661429
{
"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}</#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.newCarFlag!}</#if>" <#-- "xx",//新车标识 -->
,"transreNewFlag":"${transrenewFlag!}" <#-- "xx",//续保标识 -->
,"comName":"${businessOfficeName!}" <#-- "xx",//归属机构名称 -->
,"startDate":"${startTime!}" <#-- "xx",//起保时间 -->
}]
}
[
{
"frameNo": "LJ11RBBD1K1900596",
"agentComCode": "522725198409090060",
"licenseNo": "贵CY657Q",
"endDate": "1668528000000",
"newPolicyFlag": "0",
"policyNo": "6605212022520116002834",
"policySort": "0",
"agentFee": "79.86",
"artifSelfPricesRat": "1.35",
"modelCode": "BJHASMUB0071",
"comCode": "5201160001",
"insuredName": "赵兰兰",
"transferPolicyFlag": "1",
"chgPremium": -2408.1,
"endorseNo": "6805212022520116002834001",
"riskCode": "0521",
"agentNetFee": "79.86",
"agentComName": "苟雪姣",
"businessNature": "1",
"useNatureCode": "8D",
"appliName": "赵兰兰",
"newChnlType": "12",
"carKindCode": "H0",
"sumPremium": "2218.4",
"underWriteEndDate": "1668495399011",
"autoTransreNewFlag": " ",
"newVehicleFlag": "0",
"transreNewFlag": "0",
"comName": "贵阳市高新区支公司政保团队",
"startDate": "1653408000000"
}
]
\ No newline at end of file
XF_DWD/新核心车险报案下发FM模板/00车险报案全字段.ftl 0 → 100644
View file @ 4b661429
{"systemName": "流计算平台","systemCode": "D030","msgName": "车险报案环节信息","msgCode": "ClaimCase-RegistCar","sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}","data": {"reportDate":"${actualData.reportDate!}" <#-- "xx",//报案时间 -->,"damageAddress":"${actualData.damageAddress!?replace("\t","")?replace("\n","")}" <#-- "xx",//出险地点 -->,"accidentNo":"${actualData.accidentNo!}" <#-- "xx",//事故号 -->,"damageStartDate":"${actualData.damageStartDate!}" <#-- "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!}<#assign a="1" /></#if></#list></#if>" <#-- "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!}<#assign a="1" /></#if></#list></#if>" <#-- "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!}<#assign a="1" /></#list></#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!}<#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!}<#assign a="1" /></#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!}<#assign a="1" /></#if></#list></#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!}<#assign a="1" /></#list></#if>" <#-- "xx",//保单号 -->,"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!}<#assign a="1" /></#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!}<#assign a="1" /></#list></#if>" <#-- "xx",//理赔机构代码 -->,"riskName":"${riskName!}" <#-- "xx",//险种名称 -->,"licenseNo":"${licenseNo!}" <#-- "xx",//车牌号 -->,"riskCode":"${riskCode!}" <#-- "xx",//险种代码 -->,"comCode":"${comCode!}" <#-- "xx",//承保机构代码 -->,"comName":"${comName!}" <#-- "xx",//承保机构名称 -->,"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!}<#assign a="1" /></#if></#list></#if>" <#-- "xx",//联系人电话 -->,"longitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.longitude!}</#if></#if>" <#-- "xx",//经度 -->,"latitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.latitude!}</#if></#if>" <#-- "xx",//纬度 -->,"damageTypeDesc":"<#if actualData.prplcdamage??>${actualData.prplcdamage.damageName!}</#if>" <#-- "xx",//出险原因 -->,"damageCourse":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.damageCourse??>${actualData.prplcdamage.damageCourse!?replace("\n","")?replace("\t","")}</#if></#if>" <#-- "xx",//出险经过 -->}}
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "车险报案环节信息",
"msgCode": "ClaimCase-RegistCar",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": {
"reportDate":"${actualData.reportDate!}" <#-- "xx",//报案时间 -->
,"damageAddress":"${actualData.damageAddress!?replace("\t","")?replace("\n","")}" <#-- "xx",//出险地点 -->
,"accidentNo":"${actualData.accidentNo!}" <#-- "xx",//事故号 -->
,"damageStartDate":"${actualData.damageStartDate!}" <#-- "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!}<#assign a="1" /></#if></#list></#if>" <#-- "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!}<#assign a="1" /></#if></#list></#if>" <#-- "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!}<#assign a="1" /></#list></#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!}<#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!}<#assign a="1" /></#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!}<#assign a="1" /></#if></#list></#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!}<#assign a="1" /></#list></#if>" <#-- "xx",//保单号 -->
,"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!}<#assign a="1" /></#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!}<#assign a="1" /></#list></#if>" <#-- "xx",//理赔机构代码 -->
,"riskName":"${riskName!}" <#-- "xx",//险种名称 -->
,"licenseNo":"${licenseNo!}" <#-- "xx",//车牌号 -->
,"riskCode":"${riskCode!}" <#-- "xx",//险种代码 -->
,"comCode":"${comCode!}" <#-- "xx",//承保机构代码 -->
,"comName":"${comName!}" <#-- "xx",//承保机构名称 -->
,"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!}<#assign a="1" /></#if></#list></#if>" <#-- "xx",//联系人电话 -->
,"longitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.longitude!}</#if></#if>" <#-- "xx",//经度 -->
,"latitude":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.prpldamageaddress??>${actualData.prplcdamage.prpldamageaddress.latitude!}</#if></#if>" <#-- "xx",//纬度 -->
,"damageTypeDesc":"<#if actualData.prplcdamage??>${actualData.prplcdamage.damageName!}</#if>" <#-- "xx",//出险原因 -->
,"damageCourse":"<#if actualData.prplcdamage??><#if actualData.prplcdamage.damageCourse??>${actualData.prplcdamage.damageCourse!?replace("\n","")?replace("\t","")}</#if></#if>" <#-- "xx",//出险经过 -->
}
}
{
"actualData": {
"accidentNo":"123",
"damageStartDate":1642141803000,
"reportD":1642141803000,
"damageAddress":"12321312",
"prplcregist": [
{
"policyNo":"12321312",
"registNo":"12321312",
"deptCode":"12321312",
"deptName":"12321312",
"prplreporter": {
"reporterName":"12321312",
"reporterMobileNo":"12321312"
},
"prpllinker": {
"linkerName":"12321312",
"linkerPhon":"12321312"
}
}
],
"prplpolicy": [
{
"comCode":"12321312",
"comName":"12321312",
"riskCode":"12321312",
"riskName":"12321312",
"licenseNo":"12321312"
}
],
"prplcarlossdetail": [
{
"prplcar": {
"brandCode":"12321312",
"carModelCode":"12321312"
}
}
],
"prplcdamage": {
"prpldamageaddress": {
"longitude":"12321312",
"latitude":"12321312"
},
"damageName":"12321312",
"damageCourse":"12321312"
}
}
}
======================================SQL=============================================
INSERT INTO TABLE_NAME
SELECT
FROM TABLE_NAME
\ No newline at end of file
XF_DWD/新核心非车险保单-FM.ftl
View file @ 4b661429
......@@ -37,3 +37,42 @@
,"riskCode":"${productCode!}" <#-- "xx",//险种代码 -->
}]
}
"systemName":"流计算平台",
"systemCode":"D030",
"sendTime":"${.now?string("yyyy-MM-dd HH:mm:ss")}",
"msgCode":"carpolicy",
"msgName":"新核心车险保单信息",
"data":[{
"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.ftl
View file @ 4b661429
......@@ -31,4 +31,48 @@
,"premiumVariation":"<#if plpEndorse??>${plpEndorse.premiumVariation!}</#if>" <#-- 保费变化量 -->
,"sigAndStaExchangeRate":"${sigAndStaExchangeRate!}" <#-- 汇率 -->
}]
}
\ No newline at end of file
}
{
"systemName": "流计算平台",
"systemCode": "D030",
"msgName": "新核心非车险批单信息",
"msgCode": "fcEndorse",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"data": [{
"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"
}
temp2.sql
View file @ 4b661429
EXCEPTION: "null:异常信息：NullPointerException nullLEFT(com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.createDirectory(DpRunPlanSave.java:302)
com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.execServer(DpRunPlanSave.java:104)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
com.ydwf.component.baseserver.exec(baseserver.java:1086)
com.ydwf.component.baseserver.StartFlow(baseserver.java:883)
com.ydwf.cloud.service.ServiceObject.exec(ServiceObject.java:187)
com.ydwf.cloud.controller.ServiceController.baseService(ServiceController.java:322)
com.ydwf.cloud.controller.ServiceController.service(ServiceController.java:188)
sun.reflect.GeneratedMethodAccessor105.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)
org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)
org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105)
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:893)
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:798)
org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040)
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943)
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)
javax.servlet.http.HttpServlet.service(HttpServlet.java:665)
org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
javax.servlet.http.HttpServlet.service(HttpServlet.java:750)
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:755)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1617)
com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:123)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.boot.actuate.web.trace.servlet.HttpTraceFilter.doFilterInternal(HttpTraceFilter.java:88)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
com.ydwf.cloud.filter.ServiceAuthenticationFilter.doFilter(ServiceAuthenticationFilter.java:224)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:94)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.filterAndRecordMetrics(WebMvcMetricsFilter.java:114)
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:104)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:545)
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:590)
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1607)
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1297)
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:485)
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1577)
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1212)
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
org.eclipse.jetty.server.Server.handle(Server.java:500)
org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:383)
org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:547)
org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:375)
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:270)
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806)
org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938)
java.lang.Thread.run(Thread.java:748)
"
-- 引擎: 脚本由Flink SQL 数据加工引擎[FLINKSQL-DATAPROCESS]合成
-- 规则: ZB_ODS_指标加工理赔业务数据(ZB_ODS_LPDATA) 执行脚本
-- 运行模式: STREAM
-- 系统标识: DATAQUALITY
-- 合成时间: Nov 22, 2022 11:08:43 AM
-- 创建catalog
CREATE CATALOG ZB_ODS WITH ( 'type'='generic_in_memory' );
-- 创建数据库
CREATE DATABASE IF NOT EXISTS ZB_ODS.ZB_ODS_MYSQL;
CREATE DATABASE IF NOT EXISTS ZB_ODS.ZB_SOURCE_KAFKA_YJPK;
CREATE DATABASE IF NOT EXISTS ZB_ODS.ZB_SOURCE_KAFKA_WJPK;
CREATE DATABASE IF NOT EXISTS ZB_ODS.ZB_ODS_KAFKA;
-- 创建source数据库表
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL_0X0OTORQ9P7 ( `COMCODE` STRING, `COMNAME` STRING, `LEVEL1COMCODE` STRING, `LEVEL2COMCODE` STRING, `LEVEL3COMCODE` STRING, `LEVEL4COMCODE` STRING, `LEVEL5COMCODE` STRING, `LEVEL1COMDESC` STRING, `LEVEL2COMDESC` STRING, `LEVEL3COMDESC` STRING, `LEVEL4COMDESC` STRING, `LEVEL5COMDESC` STRING, `COMLEVEL` DECIMAL(18,2), `VALIDFLAG` STRING, PRIMARY KEY (`COMCODE`) NOT ENFORCED ) WITH ('url'='jdbc:mysql://9.1.200.87:3306/zb_ods?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false','table-name' = 'CD_COM_ALL','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '4000','connector' ='jdbc');
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_SOURCE_KAFKA_YJPK.YJPK_0X0OTORQ9P7 (
`businessOffice` STRING,
`productCode` STRING,
`businessNatureCode` STRING,
`businessChannelCode` STRING,
`cladate` STRING,
`setdate` STRING,
`settledamount` STRING,
`lossamout` STRING,
`flag` STRING,
`claimno` STRING, `no` STRING,proctime as PROCTIME()
) WITH (
'properties.bootstrap.servers' = '9.1.187.190:9092,9.1.187.189:9092,9.1.187.188:9092,9.1.187.187:9092,9.1.187.186:9092',
'scan.startup.mode' = 'group-offsets',
'properties.sasl.mechanism'='SCRAM-SHA-256',
'properties.sasl.kerberos.service.name'='kafka',
'properties.sasl.jaas.config'='org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="admin_chinaLife&!";',
'properties.security.protocol'='SASL_PLAINTEXT',
'topic'='realYjPk',
'format'='csv','scan.startup.mode'='group-offsets','properties.group.id'='ZB_ODS_LPDATA','connector' ='kafka');
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK_0X0OTORQ9P7 ( `RISKCODE` STRING, `RISKNAME` STRING, `CLASSCODE` STRING, `CLASSNAME` STRING, PRIMARY KEY (`RISKCODE`) NOT ENFORCED ) WITH ('url'='jdbc:mysql://9.1.200.87:3306/zb_ods?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false','table-name' = 'CD_REALTIME_RISK','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '4000','connector' ='jdbc');
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE_0X0OTORQ9P7 ( `CODE` STRING, `CODEDESC` STRING, PRIMARY KEY (`CODE`) NOT ENFORCED ) WITH ('url'='jdbc:mysql://9.1.200.87:3306/zb_ods?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false','table-name' = 'CD_BUSINESSNATURE','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '4000','connector' ='jdbc');
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_SOURCE_KAFKA_WJPK.WJPK_0X0OTORQ9P7 ( `businessOffice` STRING, `productCode` STRING, `businessNatureCode` STRING, `businessChannelCode` STRING, `cladate` STRING, `setdate` STRING, `settledamount` STRING, `lossamout` STRING, `flag` STRING, `claimno` STRING, `no` STRING,proctime as PROCTIME()) WITH (
'properties.bootstrap.servers' = '9.1.187.190:9092,9.1.187.189:9092,9.1.187.188:9092,9.1.187.187:9092,9.1.187.186:9092','scan.startup.mode' = 'group-offsets','topic'='realWjPk','properties.sasl.mechanism'='SCRAM-SHA-256','properties.sasl.kerberos.service.name'='kafka','properties.sasl.jaas.config'='org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="admin_chinaLife&!";','properties.security.protocol'='SASL_PLAINTEXT','format'='csv','scan.startup.mode'='group-offsets','properties.group.id'='ZB_ODS_LPDATA','connector' ='kafka');
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE_0X0OTORQ9P7 ( `NEWCHNLTYPE` STRING, `NEWCHNLTYPEDESC` STRING, PRIMARY KEY (`NEWCHNLTYPE`) NOT ENFORCED ) WITH ('url'='jdbc:mysql://9.1.200.87:3306/zb_ods?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false','table-name' = 'CD_NEWCHNLTYPE','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '4000','connector' ='jdbc');
-- flink 参数配置信息
set pipeline.name=ZB_ODS_指标加工理赔业务数据-[ZB_ODS_LPDATA]-[41482649ba2a4ca9a5e727b933b73152]-[Flink SQL 数据加工引擎];
set table.dynamic-table-options.enabled=true;
-- 创建sink数据库表
CREATE TABLE IF NOT EXISTS ZB_ODS.ZB_ODS_KAFKA.LPDATA_0X0OTORQ9P7 ( `COMCODE` STRING, `COMNAME` STRING, `LEVEL1COMCODE` STRING, `LEVEL2COMCODE` STRING, `LEVEL3COMCODE` STRING, `LEVEL4COMCODE` STRING, `LEVEL5COMCODE` STRING, `LEVEL1COMDESC` STRING, `LEVEL2COMDESC` STRING, `LEVEL3COMDESC` STRING, `LEVEL4COMDESC` STRING, `LEVEL5COMDESC` STRING, `risk` STRING, `riskname` STRING, `classcode` STRING, `classname` STRING, `businessNatureCode` STRING, `businessNatureName` STRING, `chnl` STRING, `chnlname` STRING, `cladate` STRING, `setdate` STRING, `settledamount` STRING, `lossamout` STRING, `flag` STRING, `claimno` STRING, `no` STRING, `log_time` STRING,proctime as PROCTIME()) 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' = 'group-offsets','scan.startup.mode'='latest-offset','topic'='LPDATA','format'='json','properties.group.id'='ZB_ODS_LPDATA','connector' ='kafka');
-- 执行Sql语句
insert into ZB_ODS.ZB_ODS_KAFKA.LPDATA_0X0OTORQ9P7
select
s1.businessOffice as `COMCODE` ,t1.COMNAME as `COMNAME` ,t1.LEVEL1COMCODE as `LEVEL1COMCODE` ,t1.LEVEL2COMCODE as `LEVEL2COMCODE` ,t1.LEVEL3COMCODE as `LEVEL3COMCODE` ,t1.LEVEL4COMCODE as `LEVEL4COMCODE` ,t1.LEVEL5COMCODE as `LEVEL5COMCODE` ,t1.LEVEL1COMDESC as `LEVEL1COMDESC` ,t1.LEVEL2COMDESC as `LEVEL2COMDESC` ,t1.LEVEL3COMDESC as `LEVEL3COMDESC` ,t1.LEVEL4COMDESC as `LEVEL4COMDESC` ,t1.LEVEL5COMDESC as `LEVEL5COMDESC` ,s1.productCode as `risk` ,t3.RISKNAME as `riskname` ,t3.CLASSCODE as `classcode` ,t3.CLASSNAME as `classname` ,s1.businessNatureCode as `businessNatureCode` ,t4.CODEDESC as `businessNatureName` ,s1.businessChannelCode as `chnl` ,t2.NEWCHNLTYPEDESC as `chnlname` ,s1.cladate as `cladate` ,s1.setdate as `setdate` ,s1.settledamount as `settledamount` ,s1.lossamout as `lossamout` ,s1.flag as `flag` ,s1.claimno as `claimno` ,s1.`no` as `no` ,DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time
from (
select
businessOffice as businessOffice ,productCode as productCode ,businessNatureCode as businessNatureCode ,businessChannelCode as businessChannelCode ,left(replace(cladate,'-',''),6) as cladate ,replace(setdate,'-','') as setdate ,settledamount as settledamount ,lossamout as lossamout ,'yj' as flag ,claimno as claimno ,`no` as `no` ,proctime as proctime
from ZB_ODS.ZB_SOURCE_KAFKA_YJPK.YJPK_0X0OTORQ9P7
union all
select
businessOffice as businessOffice ,productCode as productCode ,businessNatureCode as businessNatureCode ,businessChannelCode as businessChannelCode ,left(replace(cladate,'-',''),6) as cladate ,replace(setdate,'-','') as setdate ,settledamount as settledamount ,lossamout as lossamout ,flag as flag ,claimno as claimno ,`no` as `no` ,proctime as proctime
from ZB_ODS.ZB_SOURCE_KAFKA_WJPK.WJPK_0X0OTORQ9P7
) s1
left join ZB_ODS.ZB_ODS_MYSQL.CD_COM_ALL_0X0OTORQ9P7 for system_time as of s1.proctime as t1 on s1.businessOffice = t1.COMCODE
left join ZB_ODS.ZB_ODS_MYSQL.CD_NEWCHNLTYPE_0X0OTORQ9P7 for system_time as of s1.proctime as t2 on s1.businessChannelCode = t2.NEWCHNLTYPE
left join ZB_ODS.ZB_ODS_MYSQL.CD_REALTIME_RISK_0X0OTORQ9P7 for system_time as of s1.proctime as t3 on s1.productCode = t3.RISKCODE
left join ZB_ODS.ZB_ODS_MYSQL.CD_BUSINESSNATURE_0X0OTORQ9P7 for system_time as of s1.proctime as t4 on s1.businessNatureCode = t4.CODE;
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 北京云端微服科技有限公司