Skip to content

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

指标计算承保字段调整

parent 46fb48b7
Show whitespace changes
Inline Side-by-side
Showing with 432 additions and 681 deletions
CK_ODS/码表同步/CK_ODS_CD_COM_ALL.sql
View file @ 2edca267
......@@ -49,7 +49,7 @@ from (
,COMLEVEL
,VALIDFLAG
)) AS MD5
from CK_ODS.CK_SOURCE_TD_PCDEVW.CD_COM_ALL
from CK_ODS.CK_SOURCE_ORACLE_ANAREPORT11.CD_COM_ALL
) s1
left join (
......
RZ_CK/数据同步/RZ_CK_DETAIL_RUNSTATUS.sql
View file @ 2edca267
......@@ -4,8 +4,8 @@
insert into RZ_CK.RZ_CK_MYSQL.DETAIL_RUNSTATUS_URL
select
`applicationname`
,`agentid`
,`endpoint`
-- ,`agentid`
-- ,`endpoint`
,`rpc`
,`time`
,`averageelapsed`
......@@ -15,6 +15,7 @@ select
,`createtime`
,DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time
from RZ_CK.RZ_CK_KAFKA.DETAIL_RUNSTATUS_URL -- topic RUNSTATUS_URL
where applicationname like 'a%'
;
......
RZ_CK/数据同步/RZ_CK_LXT_RUNSTATUS.sql
View file @ 2edca267
......@@ -4,8 +4,8 @@
insert into RZ_CK.RZ_CK_MYSQL.LXT_RUNSTATUS_URL
select
`applicationname`
,`agentid`
,`endpoint`
-- ,`agentid`
-- ,`endpoint`
,`rpc`
,`time`
,`averageelapsed`
......@@ -15,6 +15,8 @@ select
,`createtime`
,DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time
from RZ_CK.RZ_CK_KAFKA_LXT.LXT_RUNSTATUS_URL -- topic runstatus_url
where applicationname like 'a%'
;
......
RZ_DM/RZ_DM_QUANTILE.sql
View file @ 2edca267
......@@ -18,7 +18,7 @@ from (
,d1.`agentId` as `agentid`
,cast(DateTimeToLongUDF(tumble_end(d1.row_time, interval '1' minute)) as varchar) as `time`
,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接
,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime`
,cast(DateTimeToLongUDF(LOCALTIMESTAMP ) as varchar) as `createtime`
from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA d1
where
UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS')
......@@ -48,7 +48,7 @@ from (
d1.`applicationName` as `applicationname`
,cast(DateTimeToLongUDF(tumble_end(d1.row_time, interval '1' minute)) as varchar) as `time`
,CastToTagIndexUDF(LISTAGG(d1.`elapsed`,';') ) as `quantile` -- 拼接
,cast(DateTimeToLongUDF(tumble_start(d1.row_time, interval '1' minute)) as varchar) as `createtime`
,cast(DateTimeToLongUDF(LOCALTIMESTAMP ) as varchar) as `createtime`
from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA d1
where
UPPER(RIGHT(d1.`rpc`,3)) not in ('.JS')
......
RZ_DM/RZ_DM_RUNSTATUS.sql
View file @ 2edca267
......@@ -4,15 +4,15 @@
insert into RZ_DM.RZ_DM_KAFKA.RUNSTATUS_URL
select
s1.applicationName as `applicationname`
,s1.agentId as `agentid`
,s1.endPoint as `endpoint`
-- ,s1.agentId as `agentid`
-- ,s1.endPoint as `endpoint`
,s1.rpc as `rpc`
,cast(DateTimeToLongUDF(tumble_end(s1.row_time, interval '1' minute)) as varchar) as `time`
,cast(AVG(cast(s1.elapsed as decimal(18,2)) ) as varchar) as `averageelapsed`
,cast(sum(1) as varchar) as `total`
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute)) as varchar) as `createtime`
,cast(DateTimeToLongUDF(LOCALTIMESTAMP ) as varchar) as `createtime`
from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
where
UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS')
......@@ -21,8 +21,8 @@ where
and UPPER(RIGHT(s1.`rpc`,6)) not in ('.WOFF2')
group by
s1.applicationName
,s1.agentId
,s1.endPoint
-- ,s1.agentId
-- ,s1.endPoint
,s1.rpc
,tumble(s1.row_time, interval '1' minute)
;
......@@ -38,7 +38,7 @@ select
,cast(sum(1) as varchar) as `total`
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime`
,cast(DateTimeToLongUDF(LOCALTIMESTAMP ) as varchar) as `createtime`
from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
where
UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS')
......@@ -61,7 +61,7 @@ select
,cast(sum(1) as varchar) as `total`
,cast(sum(if(s1.status = '200',1,0)) as varchar) as `suctotal`
,cast(sum(if(s1.status = '200' is not true,1,0)) as varchar) as `errortotal`
,cast(DateTimeToLongUDF(tumble_start(s1.row_time, interval '1' minute) ) as varchar) as `createtime`
,cast(DateTimeToLongUDF(LOCALTIMESTAMP ) as varchar) as `createtime`
from RZ_ODS.RZ_SOURCE_KAFKA_RZ.RZDATA s1
where
UPPER(RIGHT(s1.`rpc`,3)) not in ('.JS')
......
ZB_CK/DDL通用元数据/mysql/CHECK_CBDATA.sql 0 → 100644
View file @ 2edca267
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')
;
\ No newline at end of file
ZB_CK/DDL通用元数据/mysql/CHECK_WEBSERVICE.sql 0 → 100644
View file @ 2edca267
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');
ZB_CK/DDL通用元数据/mysql/KAFKA_CBDATA.sql 0 → 100644
View file @ 2edca267
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')
;
\ No newline at end of file
ZB_CK/DDL通用元数据/mysql/WEB_REALTIME_BUSINESS_INFO.sql 0 → 100644
View file @ 2edca267
-- 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'
);
\ No newline at end of file
ZB_CK/DDL通用元数据/mysql/ZB_CK_DMMQWEBSERVICE.sql 0 → 100644
View file @ 2edca267
-- ZB_CK_MQ与WEBSERVICE清单比较结果汇总
create table zb_ck.ZB_CK_DMMQWEBSERVICE(
buss_time varchar(32) comment '业务时间'
, current_num varchar(32) comment '加工平台数据量'
, current_fc_num varchar(32) comment '加工平台非车数据量'
, current_car_num varchar(32) comment '加工平台车险数据量'
, current_qdbf varchar(32) comment '加工平台总公司今日签单保费和'
, actual_num varchar(32) comment '老系统数据量'
, actual_fc_num varchar(32) comment '老系统非车数据量'
, actual_car_num varchar(32) comment '老系统车险数据量'
, actual_qdbf varchar(32) comment '老系统总公司今日签单保费和'
, poor_num varchar(32) comment '数据量差值'
, poor_fc_num varchar(32) comment '非车数据量差值'
, poor_car_num varchar(32) comment '车险数据量差值'
, poor_qdbf varchar(32) comment '总公司今日签单保费和差值'
, log_time varchar(32) comment '核对时间'
, primary key(buss_time)
);
\ No newline at end of file
ZB_DM/测试生产数据核对/ZB_CK_RESULT.sql → ZB_CK/DDL通用元数据/mysql/ZB_CK_RESULT.sql
View file @ 2edca267
-- zb_ck 指标计算测试生产数据核对
-- 通过代码实现
create table ZB_CK_RESULT(
`id` varchar(256) ,
`current_key` varchar(256) ,
......
ZB_CK/数据存储/ZB_CK_WEB_REALTIME_BUSINESS_INFO.sql 0 → 100644
View file @ 2edca267
-- ZB_CK_WEB_REALTIME_BUSINESS_INFO ZB_CK_WEBSERVICE同步ORACLE
insert into ZB_CK.ZB_CK_MYSQL.WEB_REALTIME_BUSINESS_INFO
select
HOSTNAME
, COMCODE
, BUSINESSNO
, UNDERWRITEENDDATE
, VALIDDATE
, RISKCODE
, CHNLTYPE
, BAOFEI
, LOADDATE
, BUSINESSNATURE
, BUSINESSCHANNELCODE
from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
;
\ No newline at end of file
ZB_CK/数据存储差异清单导出/ZB_CK_CHECK_CBDATA.sql
View file @ 2edca267
-- 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 ZB_CK.ZB_CK_MYSQL.CHECK_CBDATA
select
s1.uwConclueDate ,
......@@ -120,14 +23,16 @@ select
from (
select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA
where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
and cast(cost as decimal(18,2)) <> 0
) s1
left join (
select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and LOADDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and cast(BAOFEI as decimal(18,2)) <> 0
) s2
on s1.`no` = s2.BUSINESSNO
and s1.COMCODE = s2.COMCODE
and cast(s1.cost as decimal(18,2)) - cast(s2.BAOFEI as decimal(18,2)) between -0.1 and 0.1
and cast(s1.cost as decimal(18,2)) - cast(s2.BAOFEI as decimal(18,2)) between -1.0 and 1.0
where s2.BUSINESSNO is null
;
\ No newline at end of file
ZB_CK/数据存储差异清单导出/ZB_CK_CHECK_WEBSERVICE.sql
View file @ 2edca267
-- 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 ZB_CK.ZB_CK_MYSQL.CHECK_WEBSERVICE
select
s2.HOSTNAME ,
......@@ -120,15 +16,16 @@ from (
select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and LOADDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and cast(BAOFEI as decimal(18,2)) <> 0
) s2
left join (
select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA
where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
and cast(cost as decimal(18,2)) <> 0
) s1
on s1.`no` = s2.BUSINESSNO
and s1.COMCODE = s2.COMCODE
and cast(s1.cost as decimal(18,2)) - cast(s2.BAOFEI as decimal(18,2)) between -0.1 and 0.1
and cast(s1.cost as decimal(18,2)) - cast(s2.BAOFEI as decimal(18,2)) between -1.0 and 1.0
where s1.`no` is null
and cast(s2.BAOFEI as decimal(18,2)) > 0
;
ZB_CK/数据汇总/ZB_CK_CHECK_REALTIME.sql
View file @ 2edca267
-- ZB_CK_CHECK_REALTIME ZB_CK_实时和统计日增量检验
-- ZB_CK_CHECK_REALTIME ZB_CK_实时和统计日增量检验MYSQL至ORACLE
insert into ZB_CK.ZB_CK_ORACLE_ANAQUERY.CHECK_REALTIME
select
......
ZB_CK/数据汇总/ZB_CK_DMMQWEBSERVICE.sql 0 → 100644
View file @ 2edca267
-- ZB_CK_DMMQWEBSERVICE ZB_CK_MQ与WEBSERVICE清单比较结果汇总
insert into ZB_CK.ZB_CK_MYSQL.ZB_CK_DMMQWEBSERVICE
select
DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd') as buss_time -- 业务时间
, cast(s1.current_num as varchar) as current_num -- 加工平台数据量
, cast(s1.current_fc_num as varchar) as current_fc_num -- 加工平台非车数据量
, cast(s1.current_car_num as varchar) as current_car_num -- 加工平台车险数据量
, cast(s1.current_qdbf as varchar) as current_qdbf -- 加工平台总公司今日签单保费和
, cast(s2.actual_num as varchar) as actual_num -- 老系统数据量
, cast(s2.actual_fc_num as varchar) as actual_fc_num -- 老系统非车数据量
, cast(s2.actual_car_num as varchar) as actual_car_num -- 老系统车险数据量
, cast(s2.actual_qdbf as varchar) as actual_qdbf -- 老系统总公司今日签单保费和
, cast(s1.current_num - s2.actual_num as varchar) as poor_num -- 数据量差值
, cast(s1.current_fc_num - s2.actual_fc_num as varchar) as poor_fc_num -- 非车数据量差值
, cast(s1.current_car_num - s2.actual_car_num as varchar) as poor_car_num -- 车险数据量差值
, cast(s1.current_qdbf - s2.actual_qdbf as varchar) as poor_qdbf -- 总公司今日签单保费和差值
, DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd HH:mm:ss') as log_time -- 核对时间
from (
select
sum(1) as current_num -- 加工平台数据量
, sum(if(left(risk,2) ='05',0,1)) as current_fc_num -- 加工平台非车数据量
, sum(if(left(risk,2) ='05',1,0)) as current_car_num -- 加工平台车险数据量
, sum(cast(cost as decimal(18,2))) as current_qdbf -- 加工平台总公司今日签单保费和
from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA
where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
and cast(cost as decimal(18,2)) <> 0
) s1
cross join (
select
sum(1) as actual_num -- 老系统数据量
, sum(if(left(RISKCODE,2) ='05',0,1)) as actual_fc_num -- 老系统非车数据量
, sum(if(left(RISKCODE,2) ='05',1,0)) as actual_car_num -- 老系统车险数据量
, sum(cast(BAOFEI as decimal(18,2))) as actual_qdbf -- 老系统总公司今日签单保费和
from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and LOADDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
and cast(BAOFEI as decimal(18,2)) <> 0
) s2
;
\ No newline at end of file
ZB_DM/测试生产数据核对/HSET_DECIMAL_CHECK.sql deleted 100644 → 0
View file @ 46fb48b7
-- HSET_DECIMAL_CHECK HSET格式DECIMAL数值存储核对
insert into ZB_DM.ZB_CK_RESULT.ZB_CK
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss')
end AS id
,s1.`key` AS current_key
,s1.`hkey` AS current_hkey
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`hkey` AS actual_hkey
,s2.`val` AS actual_val
,cast(cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2)) as varchar ) AS poorVal
,case when (cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2))) = 0 then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.HSET_DECIMAL s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.HSET_DECIMAL s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
when s1.`key` is not null then SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'allxlbf/|chnlbf/|alldayywlybf/|allmonthywlybf/|allquarterywlybf/|allywlybf/|xxzdaybf/|xxzmonthbf/|' ||
'xxzquarterbf/|xxzyearbf/|allyjxlbf/|chnlyjbf/|allwjxlbf/|chnlwjbf/|provqdbf/|provcarqdbf/|provnocarqdbf/|' ||
'provqbbf/|provmonthqbbf/|provdayqdbf/|provquarterqdbf/|provxlbf/|chnlbf/|provdayywlybf/|provdayywlybf/|provquarterywlybf/|provywlybf/|provxxzbf/|' ||
'provxxzdaybf/|provxxzmonthbf/|provxxzquarterbf/|provxxzyearbf/|provyjpk/|provyjxlbf/|chnlyjbf/|provwjpk/|provwjxlbf/|chnlwjbf/|cityqdbf/|citycarqdbf/|citynocarqdbf/|' ||
'cityqbbf/|citymonthqbbf/|citydayqdbf/|cityquarterqdbf/|cityxlbf/|citychnlbf/|citydayywlybf/|citymonthywlybf/|cityquarterywlybf/|cityywlybf/|cityxxzbf/|' ||
'cityxxzdaybf/|cityxxzmonthbf/|cityxxzquarterbf/|cityxxzyearbf/|cityyjpk/|cityyjxlbf/|citychnlyjbf/|citywjpk/|citywjxlbf/|citychnlwjbf/|countryqdbf/|' ||
'countycarqdbf/|countynocarqdbf/|countryqbbf/|countrymonthqbbf/|countrydayqdbf/|countyquarterqdbf/|countryxlbf/|countrychnlbf/|countrydayywlybf/|' ||
'countrymonthywlybf/|countryquarterywlybf/|countryywlybf/|countryxxzbf/|countryxxzdaybf/|countryxxzmonthbf/|countryxxzquarterbf/|countryxxzyearbf/|countyyjpk/|' ||
'countyyjxlbf/|countychnlyjbf/|countywjpk/|countywjxlbf/|countychnlwjbf/|teamqdbf/|teamcarqdbf/|teamnocarqdbf/|teamqbbf/|teammonthqbbf/|teamdayqdbf/|' ||
'teamquarterqdbf/|teamxlbf/|teamchnlbf/|teamdayywlybf/|teammonthywlybf/|teamquarterywlybf/|teamywlybf/|teamxxzbf/|teamxxzdaybf/|teamxxzmonthbf/|teamxxzquarterbf/' ||
'teamxxzyearbf/|teamyjpk/|teamyjxlbf/|teamchnlyjbf/|teamwjpk/|teamwjxlbf/|teamchnlwjbf/'
else s1.`key` regexp'allxlbf/|chnlbf/|alldayywlybf/|allmonthywlybf/|allquarterywlybf/|allywlybf/|xxzdaybf/|xxzmonthbf/|' ||
'xxzquarterbf/|xxzyearbf/|allyjxlbf/|chnlyjbf/|allwjxlbf/|chnlwjbf/|provqdbf/|provcarqdbf/|provnocarqdbf/|' ||
'provqbbf/|provmonthqbbf/|provdayqdbf/|provquarterqdbf/|provxlbf/|chnlbf/|provdayywlybf/|provdayywlybf/|provquarterywlybf/|provywlybf/|provxxzbf/|' ||
'provxxzdaybf/|provxxzmonthbf/|provxxzquarterbf/|provxxzyearbf/|provyjpk/|provyjxlbf/|chnlyjbf/|provwjpk/|provwjxlbf/|chnlwjbf/|cityqdbf/|citycarqdbf/|citynocarqdbf/|' ||
'cityqbbf/|citymonthqbbf/|citydayqdbf/|cityquarterqdbf/|cityxlbf/|citychnlbf/|citydayywlybf/|citymonthywlybf/|cityquarterywlybf/|cityywlybf/|cityxxzbf/|' ||
'cityxxzdaybf/|cityxxzmonthbf/|cityxxzquarterbf/|cityxxzyearbf/|cityyjpk/|cityyjxlbf/|citychnlyjbf/|citywjpk/|citywjxlbf/|citychnlwjbf/|countryqdbf/|' ||
'countycarqdbf/|countynocarqdbf/|countryqbbf/|countrymonthqbbf/|countrydayqdbf/|countyquarterqdbf/|countryxlbf/|countrychnlbf/|countrydayywlybf/|' ||
'countrymonthywlybf/|countryquarterywlybf/|countryywlybf/|countryxxzbf/|countryxxzdaybf/|countryxxzmonthbf/|countryxxzquarterbf/|countryxxzyearbf/|countyyjpk/|' ||
'countyyjxlbf/|countychnlyjbf/|countywjpk/|countywjxlbf/|countychnlwjbf/|teamqdbf/|teamcarqdbf/|teamnocarqdbf/|teamqbbf/|teammonthqbbf/|teamdayqdbf/|' ||
'teamquarterqdbf/|teamxlbf/|teamchnlbf/|teamdayywlybf/|teammonthywlybf/|teamquarterywlybf/|teamywlybf/|teamxxzbf/|teamxxzdaybf/|teamxxzmonthbf/|teamxxzquarterbf/' ||
'teamxxzyearbf/|teamyjpk/|teamyjxlbf/|teamchnlyjbf/|teamwjpk/|teamwjxlbf/|teamchnlwjbf/'
end
;
\ No newline at end of file
ZB_DM/测试生产数据核对/HSET_VARCHAR_CHECK.sql deleted 100644 → 0
View file @ 46fb48b7
-- HSET_VARCHAR_CHECK HSET格式VARCHAR字符存储核对
insert into ZB_DM.ZB_CK_RESULT.ZB_CK
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss')
end AS id
,s1.`key` AS current_key
,s1.`hkey` AS current_hkey
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`hkey` AS actual_hkey
,s2.`val` AS actual_val
,case when s1.`val` = s2.`val` then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS_SIT.HSET_VARCHAR SIT
full outer join ZB_ODS.ZB_DM_REDIS_PRD.HSET_VARCHAR PRD on SIT.`key` = PRD.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
when s1.`key` is not null then SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
;
\ No newline at end of file
ZB_DM/测试生产数据核对/SET_DECIMAL_CHECK.sql deleted 100644 → 0
View file @ 46fb48b7
-- SET_DECIMAL_CHECK SET格式DECIMAL数值存储核对
insert into ZB_DM.ZB_CK_RESULT.ZB_CK
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss')
end AS id
,s1.`key` AS current_key
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`val` AS actual_val
,cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2)) AS poorVal
,case when (cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2))) = 0 then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.SET_DECIMAL s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.SET_DECIMAL s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
when s1.`key` is not null then SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'allqdbf/|allcarqdbf/|allnocarqdbf/|allqbbf/|allmonthqbbf/|allmonthqbbf/|allquarterqdbf/|xxzbf/' ||
'xxzbf/|xxzbf/'
else s1.`key` regexp'allqdbf/|allcarqdbf/|allnocarqdbf/|allqbbf/|allmonthqbbf/|allmonthqbbf/|allquarterqdbf/|xxzbf/' ||
'xxzbf/|xxzbf/'
end
;
\ No newline at end of file
ZB_DM/测试生产数据核对/SET_VARCHAR_CHECK.sql deleted 100644 → 0
View file @ 46fb48b7
-- SET_VARCHAR_CHECK SET格式VARCHAR数值存储核对
insert into ZB_DM.ZB_CK_RESULT.ZB_CK
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss')
end AS id
,s1.`key` AS current_key
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`val` AS actual_val
,case when s1.`val` = s2.`val` then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.SET_VARCHAR s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.SET_VARCHAR s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
when s1.`key` is not null then SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'bigcbd/|bigfcbd/|allrybf/|bigclpbdt/|bigfclpbdt/|bigccitybd/|bigfccitybd/|provrybf/|bigcitylpbdt/|bigfcitylpbdt/' ||
'|bigfcitylpbdt/|bigfccountrybd/|cityrybf/|bigcountrylpbdt/|bigfcountrylpbdt/'
else s1.`key` regexp'bigcbd/|bigfcbd/|allrybf/|bigclpbdt/|bigfclpbdt/|bigccitybd/|bigfccitybd/|provrybf/|bigcitylpbdt/|bigfcitylpbdt/' ||
'|bigfcitylpbdt/|bigfccountrybd/|cityrybf/|bigcountrylpbdt/|bigfcountrylpbdt/'
end
;
\ No newline at end of file
ZB_DM/测试生产数据核对/ZB_CHECK_生产数据核对(合并).sql deleted 100644 → 0
View file @ 46fb48b7
-- ZB_CHECK_HB ZB_CHECK_生产数据核对
-- SET_DECIMAL_CHECK SET格式DECIMAL数值存储核对
insert into ZB_DM.ZB_CK_MYSQL.ZB_CK_RESULT
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
end AS id
,s1.`key` AS current_key
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`val` AS actual_val
,cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2)) AS poorVal
,case when (cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2))) = 0 then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.SET_DECIMAL s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.SET_DECIMAL s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
else SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'allqdbf/|allcarqdbf/|allnocarqdbf/|allqbbf/|allmonthqbbf/|allmonthqbbf/|allquarterqdbf/|xxzbf/' ||
'xxzbf/|xxzbf/'
else s1.`key` regexp'allqdbf/|allcarqdbf/|allnocarqdbf/|allqbbf/|allmonthqbbf/|allmonthqbbf/|allquarterqdbf/|xxzbf/' ||
'xxzbf/|xxzbf/'
end
;
-- SET_VARCHAR_CHECK SET格式VARCHAR数值存储核对
insert into ZB_DM.ZB_CK_MYSQL.ZB_CK_RESULT
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
end AS id
,s1.`key` AS current_key
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`val` AS actual_val
,case when MD5(s1.`val`) = MD5(s2.`val`) then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.SET_VARCHAR s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.SET_VARCHAR s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
else SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'bigcbd/|bigfcbd/|allrybf/|bigclpbdt/|bigfclpbdt/|bigccitybd/|bigfccitybd/|provrybf/|bigcitylpbdt/|bigfcitylpbdt/' ||
'|bigfcitylpbdt/|bigfccountrybd/|cityrybf/|bigcountrylpbdt/|bigfcountrylpbdt/'
else s1.`key` regexp'bigcbd/|bigfcbd/|allrybf/|bigclpbdt/|bigfclpbdt/|bigccitybd/|bigfccitybd/|provrybf/|bigcitylpbdt/|bigfcitylpbdt/' ||
'|bigfcitylpbdt/|bigfccountrybd/|cityrybf/|bigcountrylpbdt/|bigfcountrylpbdt/'
end
;
-- HSET_DECIMAL_CHECK HSET格式DECIMAL数值存储核对
insert into ZB_DM.ZB_CK_MYSQL.ZB_CK_RESULT
select
case when s1.`key` is null then concat(s2.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
else concat(s1.`key`,DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMddHHmmss'))
end AS id
,s1.`key` AS current_key
,s1.`hkey` AS current_hkey
,s1.`val` AS current_val
,s2.`key` AS actual_key
,s2.`hkey` AS actual_hkey
,s2.`val` AS actual_val
,cast(cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2)) as varchar ) AS poorVal
,case when (cast (s1.`val` as decimal (18,2)) - cast (s2.`val` as decimal (18,2))) = 0 then '是'
else '否'
end AS ifSign
from ZB_ODS.ZB_DM_REDIS.HSET_DECIMAL s1
full outer join ZB_ODS.ZB_DM_REDIS_PRD.HSET_DECIMAL s2 on s1.`key` = s2.`key`
where case when s1.`key` is null then SPLIT_INDEX(s2.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
else SPLIT_INDEX(s1.`key`,'/',1) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
end
AND case when s1.`key` is null then s2.`key` regexp'allxlbf/|chnlbf/|alldayywlybf/|allmonthywlybf/|allquarterywlybf/|allywlybf/|xxzdaybf/|xxzmonthbf/|' ||
'xxzquarterbf/|xxzyearbf/|allyjxlbf/|chnlyjbf/|allwjxlbf/|chnlwjbf/|provqdbf/|provcarqdbf/|provnocarqdbf/|' ||
'provqbbf/|provmonthqbbf/|provdayqdbf/|provquarterqdbf/|provxlbf/|chnlbf/|provdayywlybf/|provdayywlybf/|provquarterywlybf/|provywlybf/|provxxzbf/|' ||
'provxxzdaybf/|provxxzmonthbf/|provxxzquarterbf/|provxxzyearbf/|provyjpk/|provyjxlbf/|chnlyjbf/|provwjpk/|provwjxlbf/|chnlwjbf/|cityqdbf/|citycarqdbf/|citynocarqdbf/|' ||
'cityqbbf/|citymonthqbbf/|citydayqdbf/|cityquarterqdbf/|cityxlbf/|citychnlbf/|citydayywlybf/|citymonthywlybf/|cityquarterywlybf/|cityywlybf/|cityxxzbf/|' ||
'cityxxzdaybf/|cityxxzmonthbf/|cityxxzquarterbf/|cityxxzyearbf/|cityyjpk/|cityyjxlbf/|citychnlyjbf/|citywjpk/|citywjxlbf/|citychnlwjbf/|countryqdbf/|' ||
'countycarqdbf/|countynocarqdbf/|countryqbbf/|countrymonthqbbf/|countrydayqdbf/|countyquarterqdbf/|countryxlbf/|countrychnlbf/|countrydayywlybf/|' ||
'countrymonthywlybf/|countryquarterywlybf/|countryywlybf/|countryxxzbf/|countryxxzdaybf/|countryxxzmonthbf/|countryxxzquarterbf/|countryxxzyearbf/|countyyjpk/|' ||
'countyyjxlbf/|countychnlyjbf/|countywjpk/|countywjxlbf/|countychnlwjbf/|teamqdbf/|teamcarqdbf/|teamnocarqdbf/|teamqbbf/|teammonthqbbf/|teamdayqdbf/|' ||
'teamquarterqdbf/|teamxlbf/|teamchnlbf/|teamdayywlybf/|teammonthywlybf/|teamquarterywlybf/|teamywlybf/|teamxxzbf/|teamxxzdaybf/|teamxxzmonthbf/|teamxxzquarterbf/' ||
'teamxxzyearbf/|teamyjpk/|teamyjxlbf/|teamchnlyjbf/|teamwjpk/|teamwjxlbf/|teamchnlwjbf/'
else s1.`key` regexp'allxlbf/|chnlbf/|alldayywlybf/|allmonthywlybf/|allquarterywlybf/|allywlybf/|xxzdaybf/|xxzmonthbf/|' ||
'xxzquarterbf/|xxzyearbf/|allyjxlbf/|chnlyjbf/|allwjxlbf/|chnlwjbf/|provqdbf/|provcarqdbf/|provnocarqdbf/|' ||
'provqbbf/|provmonthqbbf/|provdayqdbf/|provquarterqdbf/|provxlbf/|chnlbf/|provdayywlybf/|provdayywlybf/|provquarterywlybf/|provywlybf/|provxxzbf/|' ||
'provxxzdaybf/|provxxzmonthbf/|provxxzquarterbf/|provxxzyearbf/|provyjpk/|provyjxlbf/|chnlyjbf/|provwjpk/|provwjxlbf/|chnlwjbf/|cityqdbf/|citycarqdbf/|citynocarqdbf/|' ||
'cityqbbf/|citymonthqbbf/|citydayqdbf/|cityquarterqdbf/|cityxlbf/|citychnlbf/|citydayywlybf/|citymonthywlybf/|cityquarterywlybf/|cityywlybf/|cityxxzbf/|' ||
'cityxxzdaybf/|cityxxzmonthbf/|cityxxzquarterbf/|cityxxzyearbf/|cityyjpk/|cityyjxlbf/|citychnlyjbf/|citywjpk/|citywjxlbf/|citychnlwjbf/|countryqdbf/|' ||
'countycarqdbf/|countynocarqdbf/|countryqbbf/|countrymonthqbbf/|countrydayqdbf/|countyquarterqdbf/|countryxlbf/|countrychnlbf/|countrydayywlybf/|' ||
'countrymonthywlybf/|countryquarterywlybf/|countryywlybf/|countryxxzbf/|countryxxzdaybf/|countryxxzmonthbf/|countryxxzquarterbf/|countryxxzyearbf/|countyyjpk/|' ||
'countyyjxlbf/|countychnlyjbf/|countywjpk/|countywjxlbf/|countychnlwjbf/|teamqdbf/|teamcarqdbf/|teamnocarqdbf/|teamqbbf/|teammonthqbbf/|teamdayqdbf/|' ||
'teamquarterqdbf/|teamxlbf/|teamchnlbf/|teamdayywlybf/|teammonthywlybf/|teamquarterywlybf/|teamywlybf/|teamxxzbf/|teamxxzdaybf/|teamxxzmonthbf/|teamxxzquarterbf/' ||
'teamxxzyearbf/|teamyjpk/|teamyjxlbf/|teamchnlyjbf/|teamwjpk/|teamwjxlbf/|teamchnlwjbf/'
end
;
\ No newline at end of file
temp3.ftl 0 → 100644
View file @ 2edca267
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
{"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!}"}
temp3.json deleted 100644 → 0
View file @ 46fb48b7
[
{
"schema":"zb_ck",
"tablename":"check_cbdata",
"option":"truncate",
"desc":"清理指标计算承保CBDATA不匹配清单数据"
},
{
"schema":"zb_ck",
"tablename":"check_webservice",
"option":"truncate",
"desc":"清理指标计算承保WEBSERVICE不匹配清单数据"
},
{
"schema":"zb_ck",
"tablename":"kafka_cbdata",
"option":"truncate",
"desc":"清理指标计算承保中间过程清单数据"
},
{
"schema":"zb_ck",
"tablename":"kafka_lpdata",
"option":"truncate",
"desc":"清理指标计算理赔中间过程清单数据"
},
{
"schema":"zb_ck",
"tablename":"kafka_policy",
"option":"truncate",
"desc":"清理指标计算保单清单数据"
},
{
"schema":"zb_ck",
"tablename":"kafka_endor",
"option":"truncate",
"desc":"清理指标计算批单清单数据"
},
{
"schema":"zb_ck",
"tablename":"web_realtime_business_info",
"option":"truncate",
"desc":"清理指标计算老系统清单数据"
},
{
"schema":"zb_ck",
"tablename":"zb_ck_result",
"option":"truncate",
"desc":"清理指标计算结果汇总结果对比数据"
},
{
"schema":"xf_ck",
"tablename":"detail_car_endor",
"option":"truncate",
"desc":"清理数据下发结果车险批单清单数据"
},
{
"schema":"xf_ck",
"tablename":"detail_car_policy",
"option":"truncate",
"desc":"清理数据下发结果车险保单清单数据"
},
{
"schema":"xf_ck",
"tablename":"detail_car_regist",
"option":"truncate",
"desc":"清理数据下发结果车险报案清单数据"
},
{
"schema":"xf_ck",
"tablename":"lxt_car_endor",
"option":"truncate",
"desc":"清理数据老系统下发结果车险批单清单数据"
},
{
"schema":"xf_ck",
"tablename":"lxt_car_policy",
"option":"truncate",
"desc":"清理数据老系统下发结果车险保单清单数据"
},
{
"schema":"xf_ck",
"tablename":"lxt_car_regist",
"option":"truncate",
"desc":"清理数据老系统下发结果车险报案清单数据"
},
{
"schema":"xf_ck",
"tablename":"tab_commen",
"option":"truncate",
"desc":"清理数据下发结果数据"
},
{
"schema":"ck_dwd",
"tablename":"ckdwdpolicy",
"option":"truncate",
"desc":"清理质量校验保单校验结果清单数据"
},
{
"schema":"ck_dwd",
"tablename":"ckdwdendor",
"option":"truncate",
"desc":"清理质量校验批单校验结果清单数据"
},
{
"schema":"ck_dwd",
"tablename":"ckdwdregist",
"option":"truncate",
"desc":"清理质量校验理赔校验结果清单数据"
},
{
"schema":"life_test",
"tablename":"kafka_cb_log",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
},
{
"schema":"life_test",
"tablename":"kafka_cb_sink",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
},
{
"schema":"life_test",
"tablename":"kafka_cb_error_log",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
},
{
"schema":"life_test",
"tablename":"kafka_lp_sink",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
},
{
"schema":"life_test",
"tablename":"kafka_lp_log",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
},
{
"schema":"life_test",
"tablename":"kafka_lp_error_log",
"option":"truncate",
"desc":"根据老系统下发数据进行质量校验的数据清单表"
}
]
\ No newline at end of file
tmp.json 0 → 100644
View file @ 2edca267
[
{
"com": "44030000",
"no": "6605212022440314004622",
"riskname": "0521-机动车综合商业险",
"cost": "72696.8600",
"chnlname": "个代",
"comname": "深圳分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "31000000",
"no": "6605212022310110020835",
"riskname": "0521-机动车综合商业险",
"cost": "51719.4900",
"chnlname": "网销",
"comname": "上海分公司",
"risk": "0521",
"chnl": "15"
},
{
"com": "44030000",
"no": "6605312022440311000668",
"riskname": "0531-新能源汽车商业保险",
"cost": "45809.1100",
"chnlname": "个代",
"comname": "深圳分公司",
"risk": "0531",
"chnl": "08"
},
{
"com": "31000000",
"no": "6605212022310061001503",
"riskname": "0521-机动车综合商业险",
"cost": "45086.0600",
"chnlname": "车行",
"comname": "上海分公司",
"risk": "0521",
"chnl": "06"
},
{
"com": "34000000",
"no": "6605212022340322008660",
"riskname": "0521-机动车综合商业险",
"cost": "44089.2800",
"chnlname": "互动",
"comname": "安徽省分公司",
"risk": "0521",
"chnl": "03"
},
{
"com": "34000000",
"no": "6605212022340322008661",
"riskname": "0521-机动车综合商业险",
"cost": "44089.2800",
"chnlname": "互动",
"comname": "安徽省分公司",
"risk": "0521",
"chnl": "03"
},
{
"com": "44030000",
"no": "6605212022440311007664",
"riskname": "0521-机动车综合商业险",
"cost": "43329.1400",
"chnlname": "个代",
"comname": "深圳分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "34000000",
"no": "6605212022341125005814",
"riskname": "0521-机动车综合商业险",
"cost": "39408.0000",
"chnlname": "个代",
"comname": "安徽省分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "31000000",
"no": "6605312022310105008999",
"riskname": "0531-新能源汽车商业保险",
"cost": "37797.9400",
"chnlname": "车行",
"comname": "上海分公司",
"risk": "0531",
"chnl": "06"
},
{
"com": "31000000",
"no": "6605312022310083001041",
"riskname": "0531-新能源汽车商业保险",
"cost": "36859.2300",
"chnlname": "车行",
"comname": "上海分公司",
"risk": "0531",
"chnl": "06"
},
{
"com": "31000000",
"no": "6605212022310083012898",
"riskname": "0521-机动车综合商业险",
"cost": "34986.8700",
"chnlname": "车行",
"comname": "上海分公司",
"risk": "0521",
"chnl": "06"
},
{
"com": "44000000",
"no": "6605212022440112002883",
"riskname": "0521-机动车综合商业险",
"cost": "34540.2400",
"chnlname": "银保",
"comname": "广东省分公司",
"risk": "0521",
"chnl": "07"
},
{
"com": "13000000",
"no": "6605212022130461003029",
"riskname": "0521-机动车综合商业险",
"cost": "32326.3500",
"chnlname": "个代",
"comname": "河北省分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "13000000",
"no": "6605212022130461003028",
"riskname": "0521-机动车综合商业险",
"cost": "32326.3500",
"chnlname": "个代",
"comname": "河北省分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "37000000",
"no": "6605212022370725006713",
"riskname": "0521-机动车综合商业险",
"cost": "31857.2300",
"chnlname": "互动",
"comname": "山东省分公司",
"risk": "0521",
"chnl": "03"
},
{
"com": "34000000",
"no": "6605212022340322008648",
"riskname": "0521-机动车综合商业险",
"cost": "31852.4000",
"chnlname": "互动",
"comname": "安徽省分公司",
"risk": "0521",
"chnl": "03"
},
{
"com": "37000000",
"no": "6605212022371524003793",
"riskname": "0521-机动车综合商业险",
"cost": "31580.9300",
"chnlname": "个代",
"comname": "山东省分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "35000000",
"no": "6605212022350195000840",
"riskname": "0521-机动车综合商业险",
"cost": "30649.7100",
"chnlname": "个代",
"comname": "福建分公司",
"risk": "0521",
"chnl": "08"
},
{
"com": "23000000",
"no": "6605212022230399004261",
"riskname": "0521-机动车综合商业险",
"cost": "30518.9100",
"chnlname": "银保",
"comname": "黑龙江分公司",
"risk": "0521",
"chnl": "07"
},
{
"com": "34000000",
"no": "6605212022341250006855",
"riskname": "0521-机动车综合商业险",
"cost": "30289.1500",
"chnlname": "互动",
"comname": "安徽省分公司",
"risk": "0521",
"chnl": "03"
}
]
\ No newline at end of file
tmp.sql deleted 100644 → 0
View file @ 46fb48b7
{"FLAG":false,"BATCHID":"447612078299382240","MESSAGE":"服务执行异常：日志号码:447612078299382240","EXCEPTION":"null:异常信息：NullPointerException null\r
com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.createDirectory(DpRunPlanSave.java:302)\r
com.ydwf.bridge.DATAPROCESS.dprunplan.v2.DpRunPlanSave.execServer(DpRunPlanSave.java:104)\r
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r
java.lang.reflect.Method.invoke(Method.java:498)\r
com.ydwf.component.baseserver.exec(baseserver.java:1086)\r
com.ydwf.component.baseserver.StartFlow(baseserver.java:883)\r
com.ydwf.cloud.service.ServiceObject.exec(ServiceObject.java:187)\r
com.ydwf.cloud.controller.ServiceController.baseService(ServiceController.java:322)\r
com.ydwf.cloud.controller.ServiceController.service(ServiceController.java:188)\r
sun.reflect.GeneratedMethodAccessor104.invoke(Unknown Source)\r
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r
java.lang.reflect.Method.invoke(Method.java:498)\r
org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)\r
org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)\r
org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105)\r
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:893)\r
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:798)\r
org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)\r
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040)\r
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943)\r
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)\r
org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)\r
javax.servlet.http.HttpServlet.service(HttpServlet.java:665)\r
org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)\r
javax.servlet.http.HttpServlet.service(HttpServlet.java:750)\r
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:755)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1617)\r
com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:123)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.boot.actuate.web.trace.servlet.HttpTraceFilter.doFilterInternal(HttpTraceFilter.java:88)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
com.ydwf.cloud.filter.ServiceAuthenticationFilter.doFilter(ServiceAuthenticationFilter.java:224)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:94)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.filterAndRecordMetrics(WebMvcMetricsFilter.java:114)\r
org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:104)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)\r
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)\r
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604)\r
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:545)\r
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)\r
org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:590)\r
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)\r
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1607)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)\r
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1297)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)\r
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:485)\r
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1577)\r
org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)\r
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1212)\r
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)\r
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)\r
org.eclipse.jetty.server.Server.handle(Server.java:500)\r
org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:383)\r
org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:547)\r
org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:375)\r
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:270)\r
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)\r
org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)\r
org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)\r
org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)\r
org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388)\r
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806)\r
org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938)\r
java.lang.Thread.run(Thread.java:748)\r
"}
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 北京云端微服科技有限公司