Skip to content

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

指标计算承保字段调整

parent 0d34279d
Show whitespace changes
Inline Side-by-side
Showing with 341 additions and 27 deletions
XF_DWD/新核心车险保单-FM.sql
View file @ ef0c126e
......@@ -7,6 +7,58 @@
{ "systemName": "流计算平台", "systemCode": "D030", "sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}", "msgCode": "carpolicy" "msgName": "新核心车险保单信息", "data":[{ "policyNo" :"${policyNo!}" <#-- "xx",//保单号 --> ,"businessNo" :"${businessNo!}" <#-- "xx",//业务号 --> ,"underWriteEndDate" :"${policyCreatDate!}" <#-- "xx",//核保通过时间 --> ,"comCode" :"${businessOffice!}" <#-- "xx",//保单归属机构代码 --> ,"comName" :"${businessOfficeName!}" <#-- "xx",//保单归属机构名称 --> ,"riskCode" :"${productCode!}" <#-- "xx",//险种代码 --> ,"businessNature" :"${businessNatureCode!}" <#-- "xx",//业务来源 --> ,"startDate" :"${startTime!}" <#-- "xx",//起保时间 --> ,"endDate" :"${endTime!}" <#-- "xx",//终保时间 --> ,"sumPremium" :"${netPremium!}" <#-- "xx",//不含税保费 --> ,"premium" :"${premium!}" <#-- "xx",//含税保费 --> ,"licenseNo" :"${plcCar05.licensePlateNo!}" <#-- "xx",//车牌号 --> ,"frameNo" :"${plcCar05.frameNo!}" <#-- "xx",//车架号 --> ,"modelCode" :"${plcCar05.vehicleId!}" <#-- "xx",//车型 --> ,"newVehicleFlag" :"${plcCar05.newVehicleFlag!}" <#-- "xx",//新车标识 --> ,"newPolicyFlag" :"${newPolicyFlag!}" <#-- "xx",//新保标识 --> ,"autoTransreNewFlag" :"${autoTransrenewFlag!}" <#-- "xx",//自动续保标识 --> ,"transferPolicyFlag" :"${transferPolicyFlag!}" <#-- "xx",//转保标识 --> ,"transreNewFlag" : "${transrenewFlag!}" <#-- "xx",//续保标识 --> ,"artifSelfPricesRat" :"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifSelfPricesRat!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//自主定价系数 --> ,"artifReviewPrem" :"<#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifReviewPrem!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if>" <#-- "xx",//总保费 --> ,"agentFee" :"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- "xx",//手续费含税金额 --> ,"agentNetFee" :"<#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if>" <#-- "xx",//手续费不含税金额 --> ,"agentComCode" :"${saleaman!}" <#-- "xx",//代理机构代码 --> ,"agentComName" :"${saleamanName!}" <#-- "xx",//代理机构名称 --> ,"newChnlType" :"${businessChannelCode!}" <#-- "xx",//清分后渠道 --> ,"carKindCode" :"${plcCar05.carKindCode!}" <#-- "xx",//车辆种类 --> ,"useNatureCode" :"${plcCar05.carUserNatureCode!}" <#-- "xx",//车辆使用性质 --> ,"policySort" :"${policySort!}" <#-- "xx",//保单种类 --> ,"actualvalue" :"${plcCar05.actualvalue!}" <#-- "xx",//实际价值 --> ,"businessType" :"${businessType!}" <#-- "xx",//业务类型 --> }]}
{ "systemName": "流计算平台", "systemCode": "D030", "sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}", "msgCode": "carpolicy" "msgName": "新核心车险保单信息", "data":[{ "policyNo" : ${policyNo!} <#-- "xx",//保单号 --> ,"businessNo" : ${businessNo!} <#-- "xx",//业务号 --> ,"underWriteEndDate" : ${policyCreatDate!} <#-- "xx",//核保通过时间 --> ,"comCode" : ${businessOffice!} <#-- "xx",//保单归属机构代码 --> ,"comName" : ${businessOfficeName!} <#-- "xx",//保单归属机构名称 --> ,"riskCode" : ${productCode!} <#-- "xx",//险种代码 --> ,"businessNature" : ${businessNatureCode!} <#-- "xx",//业务来源 --> ,"startDate" : ${startTime!} <#-- "xx",//起保时间 --> ,"endDate" : ${endTime!} <#-- "xx",//终保时间 --> ,"sumPremium" : ${netPremium!} <#-- "xx",//不含税保费 --> ,"premium" : ${premium!} <#-- "xx",//含税保费 --> ,"licenseNo" : ${plcCar05.licensePlateNo!} <#-- "xx",//车牌号 --> ,"frameNo" : ${plcCar05.frameNo!} <#-- "xx",//车架号 --> ,"modelCode" : ${plcCar05.vehicleId!} <#-- "xx",//车型 --> ,"newVehicleFlag" : ${plcCar05.newVehicleFlag!} <#-- "xx",//新车标识 --> ,"appliName" : <#if plcApplicant??><#list plcApplicant as s1>${s1!}</#list></#if> <#-- "xx",//投保人名称 --> ,"newPolicyFlag" : ${newPolicyFlag!} <#-- "xx",//新保标识 --> ,"autoTransreNewFlag" : ${autoTransrenewFlag!} <#-- "xx",//自动续保标识 --> ,"transferPolicyFlag" : ${transferPolicyFlag!} <#-- "xx",//转保标识 --> ,"transreNewFlag" : ${transrenewFlag!} <#-- "xx",//续保标识 --> ,"artifSelfPricesRat" : ${plcSolution[0]!} <#-- "xx",//自主定价系数 --> ,"agentComCode" : ${saleaman!} <#-- "xx",//代理机构代码 --> ,"agentComName" : ${saleamanName!} <#-- "xx",//代理机构名称 --> ,"newChnlType" : ${businessChannelCode!} <#-- "xx",//清分后渠道 --> ,"carKindCode" : ${plcCar05.carKindCode!} <#-- "xx",//车辆种类 --> ,"useNatureCode" : ${plcCar05.carUserNatureCode!} <#-- "xx",//车辆使用性质 --> ,"policySort" : ${policySort!} <#-- "xx",//保单种类 --> ,"actualvalue" : ${plcCar05.actualvalue!} <#-- "xx",//实际价值 --> ,"businessType" : ${businessType!} <#-- "xx",//业务类型 --> }]}
{
"systemName": "流计算平台",
"systemCode": "D030",
"sendTime": "${.now?string("yyyy-MM-dd HH:mm:ss")}",
"msgCode": "carpolicy"
"msgName": "新核心车险保单信息",
"data":[{
"policyNo" : ${policyNo!""} <#-- "xx",//保单号 -->
,"businessNo" : ${businessNo!""} <#-- "xx",//业务号 -->
,"underWriteEndDate" : ${policyCreatDate!""} <#-- "xx",//核保通过时间 -->
,"comCode" : ${businessOffice!""} <#-- "xx",//保单归属机构代码 -->
,"comName" : ${businessOfficeName!""} <#-- "xx",//保单归属机构名称 -->
,"riskCode" : ${productCode!""} <#-- "xx",//险种代码 -->
,"businessNature" : ${businessNatureCode!""} <#-- "xx",//业务来源 -->
,"startDate" : ${startTime!""} <#-- "xx",//起保时间 -->
,"endDate" : ${endTime!""} <#-- "xx",//终保时间 -->
,"sumPremium" : ${netPremium!""} <#-- "xx",//不含税保费 -->
,"premium" : ${premium!""} <#-- "xx",//含税保费 -->
,"licenseNo" : ${plcCar05.licensePlateNo!""} <#-- "xx",//车牌号 -->
,"frameNo" : ${plcCar05.frameNo!""} <#-- "xx",//车架号 -->
,"modelCode" : ${plcCar05.vehicleId!""} <#-- "xx",//车型 -->
,"newVehicleFlag" : ${plcCar05.newVehicleFlag!""} <#-- "xx",//新车标识 -->
,"plcApplicant_size" : <#if plcApplicant??>${(plcApplicant?size)?c}</#if> <#-- "xx",//投保人名称 -->
,"plcApplicant_contxt" : <#if plcApplicant??>${(plcApplicant!}</#if> <#-- "xx",//投保人名称 -->
,"newPolicyFlag" : ${newPolicyFlag!""} <#-- "xx",//新保标识 -->
,"autoTransreNewFlag" : ${autoTransrenewFlag!""} <#-- "xx",//自动续保标识 -->
,"transferPolicyFlag" : ${transferPolicyFlag!""} <#-- "xx",//转保标识 -->
,"transreNewFlag" : ${transrenewFlag!""} <#-- "xx",//续保标识 -->
,"artifSelfPricesRat" : ${plcSolution!""} <#-- "xx",//自主定价系数 -->
,"agentComCode" : ${saleaman!""} <#-- "xx",//代理机构代码 -->
,"agentComName" : ${saleamanName!""} <#-- "xx",//代理机构名称 -->
,"newChnlType" : ${businessChannelCode!""} <#-- "xx",//清分后渠道 -->
,"carKindCode" : ${plcCar05.carKindCode!""} <#-- "xx",//车辆种类 -->
,"useNatureCode" : ${plcCar05.carUserNatureCode!""} <#-- "xx",//车辆使用性质 -->
,"policySort" : ${policySort!""} <#-- "xx",//保单种类 -->
,"actualvalue" : ${plcCar05.actualvalue!""} <#-- "xx",//实际价值 -->
,"businessType" : ${businessType!""} <#-- "xx",//业务类型 -->
}]
}
{
"systemName": "流计算平台",
"systemCode": "D030",
......@@ -14,39 +66,39 @@
"msgCode": "carpolicy"
"msgName": "新核心车险保单信息",
"data":[{
"policyNo" : ${policyNo!} <#-- "xx",//保单号 -->
,"businessNo" : ${businessNo!} <#-- "xx",//业务号 -->
,"underWriteEndDate" : ${policyCreatDate!} <#-- "xx",//核保通过时间 -->
,"comCode" : ${businessOffice!} <#-- "xx",//保单归属机构代码 -->
,"comName" : ${businessOfficeName!} <#-- "xx",//保单归属机构名称 -->
,"riskCode" : ${productCode!} <#-- "xx",//险种代码 -->
,"businessNature" : ${businessNatureCode!} <#-- "xx",//业务来源 -->
,"startDate" : ${startTime!} <#-- "xx",//起保时间 -->
,"endDate" : ${endTime!} <#-- "xx",//终保时间 -->
,"sumPremium" : ${netPremium!} <#-- "xx",//不含税保费 -->
,"premium" : ${premium!} <#-- "xx",//含税保费 -->
,"licenseNo" : ${plcCar05.licensePlateNo!} <#-- "xx",//车牌号 -->
,"frameNo" : ${plcCar05.frameNo!} <#-- "xx",//车架号 -->
,"modelCode" : ${plcCar05.vehicleId!} <#-- "xx",//车型 -->
,"newVehicleFlag" : ${plcCar05.newVehicleFlag!} <#-- "xx",//新车标识 -->
"policyNo" : ${policyNo!""} <#-- "xx",//保单号 -->
,"businessNo" : ${businessNo!""} <#-- "xx",//业务号 -->
,"underWriteEndDate" : ${policyCreatDate!""} <#-- "xx",//核保通过时间 -->
,"comCode" : ${businessOffice!""} <#-- "xx",//保单归属机构代码 -->
,"comName" : ${businessOfficeName!""} <#-- "xx",//保单归属机构名称 -->
,"riskCode" : ${productCode!""} <#-- "xx",//险种代码 -->
,"businessNature" : ${businessNatureCode!""} <#-- "xx",//业务来源 -->
,"startDate" : ${startTime!""} <#-- "xx",//起保时间 -->
,"endDate" : ${endTime!""} <#-- "xx",//终保时间 -->
,"sumPremium" : ${netPremium!""} <#-- "xx",//不含税保费 -->
,"premium" : ${premium!""} <#-- "xx",//含税保费 -->
,"licenseNo" : ${plcCar05.licensePlateNo!""} <#-- "xx",//车牌号 -->
,"frameNo" : ${plcCar05.frameNo!""} <#-- "xx",//车架号 -->
,"modelCode" : ${plcCar05.vehicleId!""} <#-- "xx",//车型 -->
,"newVehicleFlag" : ${plcCar05.newVehicleFlag!""} <#-- "xx",//新车标识 -->
,"appliName" : <#if plcApplicant??><#list plcApplicant as s1>${s1.customerName!}<#if plcApplicant?size-1 gt s1?index >|</#if></#list></#if> <#-- "xx",//投保人名称 -->
,"insuredName" : <#if plcPublicInsurant??><#list plcPublicInsurant as s1>${s1.customerName!}<#if plcPublicInsurant?size-1 gt s1?index >|</#if></#list></#if> <#-- "xx",//被保人名称 -->
,"newPolicyFlag" : ${newPolicyFlag!} <#-- "xx",//新保标识 -->
,"autoTransreNewFlag" : ${autoTransrenewFlag!} <#-- "xx",//自动续保标识 -->
,"transferPolicyFlag" : ${transferPolicyFlag!} <#-- "xx",//转保标识 -->
,"transreNewFlag" : ${transrenewFlag!} <#-- "xx",//续保标识 -->
,"newPolicyFlag" : ${newPolicyFlag!""} <#-- "xx",//新保标识 -->
,"autoTransreNewFlag" : ${autoTransrenewFlag!""} <#-- "xx",//自动续保标识 -->
,"transferPolicyFlag" : ${transferPolicyFlag!""} <#-- "xx",//转保标识 -->
,"transreNewFlag" : ${transrenewFlag!""} <#-- "xx",//续保标识 -->
,"artifSelfPricesRat" : <#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifSelfPricesRat!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if> <#-- "xx",//自主定价系数 -->
,"artifReviewPrem" : <#if plcSolution??><#list plcSolution as s1>${s1.PlcRation.artifReviewPrem!}<#if plcSolution?size-1 gt s1?index >|</#if></#list></#if> <#-- "xx",//总保费 -->
,"agentFee" : <#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if> <#-- "xx",//手续费含税金额 -->
,"agentNetFee" : <#if plcSolution??><#list plcSolution as s1><#if s1.plcCommissionDetail??><#list s1.plcCommissionDetail as item>${item.agentNetFee!}<#if s1.plcCommissionDetail?size-1 gt item?index >|</#if></#list></#if></#list></#if> <#-- "xx",//手续费不含税金额 -->
,"agentComCode" : ${saleaman!} <#-- "xx",//代理机构代码 -->
,"agentComName" : ${saleamanName!} <#-- "xx",//代理机构名称 -->
,"newChnlType" : ${businessChannelCode!} <#-- "xx",//清分后渠道 -->
,"carKindCode" : ${plcCar05.carKindCode!} <#-- "xx",//车辆种类 -->
,"useNatureCode" : ${plcCar05.carUserNatureCode!} <#-- "xx",//车辆使用性质 -->
,"policySort" : ${policySort!} <#-- "xx",//保单种类 -->
,"actualvalue" : ${plcCar05.actualvalue!} <#-- "xx",//实际价值 -->
,"businessType" : ${businessType!} <#-- "xx",//业务类型 -->
,"agentComCode" : ${saleaman!""} <#-- "xx",//代理机构代码 -->
,"agentComName" : ${saleamanName!""} <#-- "xx",//代理机构名称 -->
,"newChnlType" : ${businessChannelCode!""} <#-- "xx",//清分后渠道 -->
,"carKindCode" : ${plcCar05.carKindCode!""} <#-- "xx",//车辆种类 -->
,"useNatureCode" : ${plcCar05.carUserNatureCode!""} <#-- "xx",//车辆使用性质 -->
,"policySort" : ${policySort!""} <#-- "xx",//保单种类 -->
,"actualvalue" : ${plcCar05.actualvalue!""} <#-- "xx",//实际价值 -->
,"businessType" : ${businessType!""} <#-- "xx",//业务类型 -->
}]
}
......
ZB_CK/差异清单导出/ZB_CK_CHECK_CBDATA.sql 0 → 100644
View file @ ef0c126e
-- ZB_CK_CHECK_CBDATA ZB_CK_核对CBDATA不匹配清单
CREATE TABLE WEB_REALTIME_BUSINESS_INFO
(
HOSTNAME VARCHAR(20),
COMCODE VARCHAR(50),
BUSINESSNO VARCHAR(50),
UNDERWRITEENDDATE VARCHAR(50),
VALIDDATE VARCHAR(50),
RISKCODE VARCHAR(50),
CHNLTYPE VARCHAR(50),
BAOFEI VARCHAR(50),
LOADDATE VARCHAR(50),
BUSINESSNATURE VARCHAR(10),
BUSINESSCHANNELCODE VARCHAR(50)
)
WITH (
'connector' ='jdbc',
'url'='jdbc:oracle:thin:@9.1.64.3:1521:GPICDBTJ1',
'table-name' = 'anaquery.WEB_REALTIME_BUSINESS_INFO',
'username' = 'anaquery',
'password' = 'Anaquery!12chaXun',
'scan.fetch-size' = '1000',
'sink.buffer-flush.max-rows' = '100'
);
create table kafka_cbdata
(
uwConclueDate varchar(64) null,
startTime varchar(64) null,
COMCODE varchar(64) null,
COMNAME varchar(64) null,
LEVEL1COMCODE varchar(64) null,
LEVEL2COMCODE varchar(64) null,
LEVEL3COMCODE varchar(64) null,
LEVEL4COMCODE varchar(64) null,
LEVEL5COMCODE varchar(64) null,
risk varchar(64) null,
classcode varchar(64) null,
chnl varchar(64) null,
businessNatureCode varchar(64) null,
cost varchar(64) null,
`no` varchar(64) null,
xxzflag varchar(64) null,
`id` varchar(64) null,
`flag` varchar(64) null,
log_time varchar(64) null
)
WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'kafka_cbdata','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100')
;
-- 车型
create table check_webservice
(
HOSTNAME VARCHAR(20),
COMCODE VARCHAR(50),
BUSINESSNO VARCHAR(50),
UNDERWRITEENDDATE VARCHAR(50),
VALIDDATE VARCHAR(50),
RISKCODE VARCHAR(50),
CHNLTYPE VARCHAR(50),
BAOFEI VARCHAR(50),
LOADDATE VARCHAR(50),
BUSINESSNATURE VARCHAR(10),
BUSINESSCHANNELCODE VARCHAR(50)
)
WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'check_webservice','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100');
create table check_cbdata
(
uwConclueDate varchar(64) ,
startTime varchar(64) ,
COMCODE varchar(64) ,
COMNAME varchar(64) ,
LEVEL1COMCODE varchar(64) ,
LEVEL2COMCODE varchar(64) ,
LEVEL3COMCODE varchar(64) ,
LEVEL4COMCODE varchar(64) ,
LEVEL5COMCODE varchar(64) ,
risk varchar(64) ,
classcode varchar(64) ,
chnl varchar(64) ,
businessNatureCode varchar(64) ,
cost varchar(64) ,
`no` varchar(64) ,
xxzflag varchar(64) ,
`id` varchar(64) ,
`flag` varchar(64) ,
log_time varchar(64)
)
WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'check_cbdata','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100')
;
insert into check_cbdata
select
s1.uwConclueDate ,
s1.startTime ,
s1.COMCODE ,
s1.COMNAME ,
s1.LEVEL1COMCODE ,
s1.LEVEL2COMCODE ,
s1.LEVEL3COMCODE ,
s1.LEVEL4COMCODE ,
s1.LEVEL5COMCODE ,
s1.risk ,
s1.classcode ,
s1.chnl ,
s1.businessNatureCode ,
s1.cost ,
s1.`no` ,
s1.xxzflag ,
s1.`id` ,
s1.`flag` ,
s1.log_time
from (
select * from kafka_cbdata where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
) s1
left join (
select * from WEB_REALTIME_BUSINESS_INFO where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
) s2
on s1.`no` = s2.BUSINESSNO
and s1.COMCODE = s2.COMCODE
and cast(s1.cost as decimal(18,0)) = cast(s2.BAOFEI as decimal(18,0))
where s2.BUSINESSNO is null
;
\ No newline at end of file
ZB_CK/差异清单导出/ZB_CK_CHECK_WEBSERVICE.sql 0 → 100644
View file @ ef0c126e
-- ZB_CK_CHECK_WEBSERVICE ZB_CK_核对WEBSERVICE不匹配清单
CREATE TABLE WEB_REALTIME_BUSINESS_INFO
(
HOSTNAME VARCHAR(20),
COMCODE VARCHAR(50),
BUSINESSNO VARCHAR(50),
UNDERWRITEENDDATE VARCHAR(50),
VALIDDATE VARCHAR(50),
RISKCODE VARCHAR(50),
CHNLTYPE VARCHAR(50),
BAOFEI VARCHAR(50),
LOADDATE VARCHAR(50),
BUSINESSNATURE VARCHAR(10),
BUSINESSCHANNELCODE VARCHAR(50)
)
WITH (
'connector' ='jdbc',
'url'='jdbc:oracle:thin:@9.1.64.3:1521:GPICDBTJ1',
'table-name' = 'anaquery.WEB_REALTIME_BUSINESS_INFO',
'username' = 'anaquery',
'password' = 'Anaquery!12chaXun',
'scan.fetch-size' = '1000',
'sink.buffer-flush.max-rows' = '100'
);
create table kafka_cbdata
(
uwConclueDate varchar(64) null,
startTime varchar(64) null,
COMCODE varchar(64) null,
COMNAME varchar(64) null,
LEVEL1COMCODE varchar(64) null,
LEVEL2COMCODE varchar(64) null,
LEVEL3COMCODE varchar(64) null,
LEVEL4COMCODE varchar(64) null,
LEVEL5COMCODE varchar(64) null,
risk varchar(64) null,
classcode varchar(64) null,
chnl varchar(64) null,
businessNatureCode varchar(64) null,
cost varchar(64) null,
`no` varchar(64) null,
xxzflag varchar(64) null,
`id` varchar(64) null,
`flag` varchar(64) null,
log_time varchar(64) null
)
WITH (
'connector' ='jdbc',
'url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'kafka_cbdata',
'username' = 'service',
'password' = 'ydwf12356aA!',
'scan.fetch-size' = '1000',
'sink.buffer-flush.max-rows' = '100')
;
-- 车型
create table check_webservice
(
HOSTNAME VARCHAR(20),
COMCODE VARCHAR(50),
BUSINESSNO VARCHAR(50),
UNDERWRITEENDDATE VARCHAR(50),
VALIDDATE VARCHAR(50),
RISKCODE VARCHAR(50),
CHNLTYPE VARCHAR(50),
BAOFEI VARCHAR(50),
LOADDATE VARCHAR(50),
BUSINESSNATURE VARCHAR(10),
BUSINESSCHANNELCODE VARCHAR(50)
)
WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'check_webservice','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100');
create table check_cbdata
(
uwConclueDate varchar(64) ,
startTime varchar(64) ,
COMCODE varchar(64) ,
COMNAME varchar(64) ,
LEVEL1COMCODE varchar(64) ,
LEVEL2COMCODE varchar(64) ,
LEVEL3COMCODE varchar(64) ,
LEVEL4COMCODE varchar(64) ,
LEVEL5COMCODE varchar(64) ,
risk varchar(64) ,
classcode varchar(64) ,
chnl varchar(64) ,
businessNatureCode varchar(64) ,
cost varchar(64) ,
`no` varchar(64) ,
xxzflag varchar(64) ,
`id` varchar(64) ,
`flag` varchar(64) ,
log_time varchar(64)
)
WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false',
'table-name' = 'check_cbdata','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100')
;
insert into check_webservice
select
s2.HOSTNAME ,
s2.COMCODE ,
s2.BUSINESSNO ,
s2.UNDERWRITEENDDATE ,
s2.VALIDDATE ,
s2.RISKCODE ,
s2.CHNLTYPE ,
s2.BAOFEI ,
s2.LOADDATE ,
s2.BUSINESSNATURE ,
s2.BUSINESSCHANNELCODE
from (
select * from WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
) s2
left join (
select * from kafka_cbdata
where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
) s1
on s1.`no` = s2.BUSINESSNO
and s1.COMCODE = s2.COMCODE
and cast(s1.cost as decimal(18,0)) = cast(s2.BAOFEI as decimal(18,0))
where s1.`no` is null
;
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 北京云端微服科技有限公司