Commit d8e1a640 authored by 胡涛's avatar 胡涛

指标计算(函数自增)sql脚本

parent d9aa22fb
......@@ -117,95 +117,10 @@ from (
) s1
;
-- ZB_DM_CAR_HB ZB_DM_承保车险合并
-- ZB_DM_QDBF_CAR/ZB_DM_车险今日签单保费
-- key:allcarqbbf/日期
-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
-- 2、车险
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT('allcarqdbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('allcarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('provcarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provcarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('citycarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citycarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('countycarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countycarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('teamcarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countycarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- ZB_DM_CXCBDD ZB_DM_车险承保大单
......@@ -344,96 +259,6 @@ from (
;
-- ZB_DM_NOCAR_HB ZB_DM_承保非车险合并
-- ZB_DM_QDBF_NOCAR/ZB_DM_非车险今日签单保费
-- key:allnocarqbbf/日期
-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
-- 2、非车险
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT('allnocarqdbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('allnocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('provnocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provnocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('citynocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citynocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('countynocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countynocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('teamnocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countynocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- ZB_DM_FCXCBDD ZB_DM_非车险承保大单
-- bigfcbd/日期
......
......@@ -30,7 +30,7 @@ select
CONCAT('provqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provqdbf/',s1.`uwConclueDate`)
CONCAT('provqdbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -47,7 +47,7 @@ select
CONCAT('cityqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityqdbf/',s1.`uwConclueDate`)
CONCAT('cityqdbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -63,7 +63,7 @@ select
CONCAT('countryqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryqdbf/',s1.`uwConclueDate`)
CONCAT('countryqdbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -79,7 +79,7 @@ select
CONCAT('teamqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast(sumZBUDF(
CONCAT('teamqdbf/',s1.`uwConclueDate`)
CONCAT('teamqdbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -119,7 +119,7 @@ select
CONCAT('provqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provqbbf/',s1.`uwConclueDate`)
CONCAT('provqbbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -135,7 +135,7 @@ select
CONCAT('cityqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityqbbf/',s1.`uwConclueDate`)
CONCAT('cityqbbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -152,7 +152,7 @@ select
CONCAT('countryqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryqbbf/',s1.`uwConclueDate`)
CONCAT('countryqbbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -169,7 +169,7 @@ select
CONCAT('teamqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamqbbf/',s1.`uwConclueDate`)
CONCAT('teamqbbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -212,7 +212,7 @@ select
CONCAT('provquarterqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provquarterqdbf/',s1.`uwConclueDate`)
CONCAT('provquarterqdbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -233,7 +233,7 @@ select
CONCAT('cityquarterqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityquarterqdbf/',s1.`uwConclueDate`)
CONCAT('cityquarterqdbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -255,7 +255,7 @@ select
CONCAT('countyquarterqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countyquarterqdbf/',s1.`uwConclueDate`)
CONCAT('countyquarterqdbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -277,7 +277,7 @@ select
CONCAT('teamquarterqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamquarterqdbf/',s1.`uwConclueDate`)
CONCAT('teamquarterqdbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -306,8 +306,8 @@ select
CONCAT('allmonthqbbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('allmonthqbbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
......@@ -323,7 +323,7 @@ select
CONCAT('provmonthqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provmonthqbbf/',s1.`uwConclueDate`)
CONCAT('provmonthqbbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -339,7 +339,7 @@ select
CONCAT('citymonthqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citymonthqbbf/',s1.`uwConclueDate`)
CONCAT('citymonthqbbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -356,7 +356,7 @@ select
CONCAT('countrymonthqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countrymonthqbbf/',s1.`uwConclueDate`)
CONCAT('countrymonthqbbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -373,7 +373,7 @@ select
CONCAT('teammonthqbbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teammonthqbbf/',s1.`uwConclueDate`)
CONCAT('teammonthqbbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -396,10 +396,10 @@ insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT('alldayqdbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('alldayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
CONCAT('alldayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -412,10 +412,10 @@ select
CONCAT('provdayqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provdayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
CONCAT('provdayqdbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -428,10 +428,10 @@ select
CONCAT('citydayqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citydayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
CONCAT('citydayqdbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -445,10 +445,10 @@ select
CONCAT('countrydayqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countrydayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
CONCAT('countrydayqdbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -462,10 +462,10 @@ select
CONCAT('teamdayqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamdayqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
CONCAT('teamdayqdbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -487,7 +487,7 @@ select
CONCAT('allywlybf/',s1.`uwConclueDate`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('allywlybf/',s1.`uwConclueDate`)
CONCAT('allywlybf/',s1.`uwConclueDate`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -503,7 +503,7 @@ select
CONCAT('provywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('provywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -520,7 +520,7 @@ select
CONCAT('cityywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('cityywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('cityywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -537,7 +537,7 @@ select
CONCAT('countryywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('countryywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countryywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -554,7 +554,7 @@ select
CONCAT('teamywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -577,7 +577,7 @@ select
CONCAT('allquarterywlybf/',s1.`uwConclueDate`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('allquarterywlybf/',s1.`uwConclueDate`)
CONCAT('allquarterywlybf/',s1.`uwConclueDate`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -597,7 +597,7 @@ select
CONCAT('provquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('provquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -618,7 +618,7 @@ select
CONCAT('cityquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('cityquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('cityquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -639,7 +639,7 @@ select
CONCAT('countryquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('countryquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countryquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -660,7 +660,7 @@ select
CONCAT('teamquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamquarterywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -688,7 +688,7 @@ select
CONCAT('allmonthywlybf/',s1.`uwConclueDate`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('allmonthywlybf/',s1.`uwConclueDate`)
CONCAT('allmonthywlybf/',s1.`uwConclueDate`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -704,7 +704,7 @@ select
CONCAT('provmonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('provmonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provmonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -721,7 +721,7 @@ select
CONCAT('citymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('citymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -738,7 +738,7 @@ select
CONCAT('countrymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('countrymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countrymonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -755,7 +755,7 @@ select
CONCAT('teammonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('teammonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teammonthywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -778,7 +778,7 @@ select
CONCAT('alldayywlybf/',s1.`uwConclueDate`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('alldayywlybf/',s1.`uwConclueDate`)
CONCAT('alldayywlybf/',s1.`uwConclueDate`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -794,7 +794,7 @@ select
CONCAT('provdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('provdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -811,7 +811,7 @@ select
CONCAT('citydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('citydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -828,7 +828,7 @@ select
CONCAT('countrydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('countrydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countrydayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -845,7 +845,7 @@ select
CONCAT('teamdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`businessNatureCode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamdayywlybf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`businessNatureCode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -872,7 +872,7 @@ select
CONCAT('allxlbf/',s1.`uwConclueDate`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('allxlbf/',s1.`uwConclueDate`)
CONCAT('allxlbf/',s1.`uwConclueDate`,s1.`classcode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -888,7 +888,7 @@ select
CONCAT('provxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('provxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`classcode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -904,7 +904,7 @@ select
CONCAT('cityxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('cityxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`classcode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -920,7 +920,7 @@ select
CONCAT('countryxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countryxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`classcode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -936,7 +936,7 @@ select
CONCAT('teamxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`classcode`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -959,7 +959,7 @@ select
CONCAT('chnlbf/',s1.`uwConclueDate`,'/00000000') as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlbf/',s1.`uwConclueDate`,'/00000000')
CONCAT('chnlbf/',s1.`uwConclueDate`,'/00000000',s1.`chnl`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -975,7 +975,7 @@ select
CONCAT('chnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('chnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`,s1.`chnl`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -992,7 +992,7 @@ select
CONCAT('citychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('citychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`,s1.`chnl`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1010,7 +1010,7 @@ select
CONCAT('countrychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('countrychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countrychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`,s1.`chnl`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1028,7 +1028,7 @@ select
CONCAT('teamchnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('teamchnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamchnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`,s1.`chnl`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1067,7 +1067,7 @@ select
CONCAT('provxxzbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provxxzbf/',s1.`uwConclueDate`)
CONCAT('provxxzbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1085,7 +1085,7 @@ select
CONCAT('cityxxzbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxxzbf/',s1.`uwConclueDate`)
CONCAT('cityxxzbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1101,7 +1101,7 @@ select
CONCAT('countryxxzbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxxzbf/',s1.`uwConclueDate`)
CONCAT('countryxxzbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1117,7 +1117,7 @@ select
CONCAT('teamxxzbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxxzbf/',s1.`uwConclueDate`)
CONCAT('teamxxzbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE` )
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1156,7 +1156,7 @@ select
CONCAT('provxxzyearbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provxxzyearbf/',s1.`uwConclueDate`)
CONCAT('provxxzyearbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1174,7 +1174,7 @@ select
CONCAT('cityxxzyearbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxxzyearbf/',s1.`uwConclueDate`)
CONCAT('cityxxzyearbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1191,7 +1191,7 @@ select
CONCAT('countryxxzyearbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxxzyearbf/',s1.`uwConclueDate`)
CONCAT('countryxxzyearbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1208,7 +1208,7 @@ select
CONCAT('teamxxzyearbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxxzyearbf/',s1.`uwConclueDate`)
CONCAT('teamxxzyearbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1252,7 +1252,7 @@ select
CONCAT('provxxzquarterbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provxxzquarterbf/',s1.`uwConclueDate`)
CONCAT('provxxzquarterbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1275,7 +1275,7 @@ select
CONCAT('cityxxzquarterbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxxzquarterbf/',s1.`uwConclueDate`)
CONCAT('cityxxzquarterbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1297,7 +1297,7 @@ select
CONCAT('countryxxzquarterbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxxzquarterbf/',s1.`uwConclueDate`)
CONCAT('countryxxzquarterbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1319,7 +1319,7 @@ select
CONCAT('teamxxzquarterbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxxzquarterbf/',s1.`uwConclueDate`)
CONCAT('teamxxzquarterbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1366,7 +1366,7 @@ select
CONCAT('provxxzmonthbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provxxzmonthbf/',s1.`uwConclueDate`)
CONCAT('provxxzmonthbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1384,7 +1384,7 @@ select
CONCAT('cityxxzmonthbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxxzmonthbf/',s1.`uwConclueDate`)
CONCAT('cityxxzmonthbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1401,7 +1401,7 @@ select
CONCAT('countryxxzmonthbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxxzmonthbf/',s1.`uwConclueDate`)
CONCAT('countryxxzmonthbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1418,7 +1418,7 @@ select
CONCAT('teamxxzmonthbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxxzmonthbf/',s1.`uwConclueDate`)
CONCAT('teamxxzmonthbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1459,7 +1459,7 @@ select
CONCAT('provxxzdaybf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provxxzdaybf/',s1.`uwConclueDate`)
CONCAT('provxxzdaybf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1477,7 +1477,7 @@ select
CONCAT('cityxxzdaybf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityxxzdaybf/',s1.`uwConclueDate`)
CONCAT('cityxxzdaybf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1494,7 +1494,7 @@ select
CONCAT('countryxxzdaybf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countryxxzdaybf/',s1.`uwConclueDate`)
CONCAT('countryxxzdaybf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1511,7 +1511,7 @@ select
CONCAT('teamxxzdaybf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamxxzdaybf/',s1.`uwConclueDate`)
CONCAT('teamxxzdaybf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
......@@ -1522,3 +1522,175 @@ where s1.`COMNAME` is not null
and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
;
-- ZB_DM_QDBF_CAR/ZB_DM_车险今日签单保费
-- key:allcarqbbf/日期
-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
-- 2、车险
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT('allcarqdbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('allcarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('provcarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provcarqdbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('citycarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citycarqdbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('countycarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countycarqdbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('teamcarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countycarqdbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) ='05'
;
-- ZB_DM_QDBF_NOCAR/ZB_DM_非车险今日签单保费
-- key:allnocarqbbf/日期
-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
-- 2、非车险
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT('allnocarqdbf/',s1.`uwConclueDate`) as `key`
,cast (sumZBUDF(
CONCAT('allnocarqdbf/',s1.`uwConclueDate`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('provnocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provnocarqdbf/',s1.`uwConclueDate`,s1.`LEVEL1COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('citynocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citynocarqdbf/',s1.`uwConclueDate`,s1.`LEVEL2COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('countynocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countynocarqdbf/',s1.`uwConclueDate`,s1.`LEVEL3COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT('teamnocarqdbf/',s1.`uwConclueDate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countynocarqdbf/',s1.`uwConclueDate`,s1.`LEVEL4COMCODE`)
,s1.`cost`
,s1.`uwConclueDate`
) as decimal (18,2)) as `val`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and left(s1.risk,2) <> '05'
;
\ No newline at end of file
......@@ -28,7 +28,7 @@ select
CONCAT('provyjpk/',s1.`setdate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provyjpk/',s1.`setdate`)
CONCAT('provyjpk/',s1.`setdate`,s1.`LEVEL1COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -44,7 +44,7 @@ select
CONCAT('cityyjpk/',s1.`setdate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('cityyjpk/',s1.`setdate`)
CONCAT('cityyjpk/',s1.`setdate`,s1.`LEVEL2COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -61,7 +61,7 @@ select
CONCAT('countyyjpk/',s1.`setdate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countyyjpk/',s1.`setdate`)
CONCAT('countyyjpk/',s1.`setdate`,s1.`LEVEL3COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -78,7 +78,7 @@ select
CONCAT('teamyjpk/',s1.`setdate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamyjpk/',s1.`setdate`)
CONCAT('teamyjpk/',s1.`setdate`,s1.`LEVEL4COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -101,7 +101,7 @@ select
CONCAT('allyjxlbf/',s1.`setdate`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('allyjxlbf/',s1.`setdate`)
CONCAT('allyjxlbf/',s1.`setdate`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -118,7 +118,7 @@ select
CONCAT('provyjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('provyjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provyjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -135,7 +135,7 @@ select
CONCAT('cityyjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('cityyjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('cityyjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`,s1.`classcode` )
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -152,7 +152,7 @@ select
CONCAT('countyyjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('countyyjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countyyjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -169,7 +169,7 @@ select
CONCAT('teamyjxlbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamyjxlbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamyjxlbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -193,7 +193,7 @@ select
CONCAT('chnlyjbf/',s1.`setdate`,'/00000000') as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlyjbf/',s1.`setdate`,'/00000000')
CONCAT('chnlyjbf/',s1.`setdate`,'/00000000',s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -210,7 +210,7 @@ select
CONCAT('chnlyjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlyjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('chnlyjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -227,7 +227,7 @@ select
CONCAT('citychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('citychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -244,7 +244,7 @@ select
CONCAT('countychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('countychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countychnlyjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -261,7 +261,7 @@ select
CONCAT('teamchnlyjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('teamchnlyjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamchnlyjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`,s1.`chnl` )
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -303,7 +303,7 @@ select
CONCAT('provwjpk/',s1.`setdate`) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('provwjpk/',s1.`setdate`)
CONCAT('provwjpk/',s1.`setdate`,s1.`LEVEL1COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -319,7 +319,7 @@ select
CONCAT('citywjpk/',s1.`setdate`) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('citywjpk/',s1.`setdate`)
CONCAT('citywjpk/',s1.`setdate`,s1.`LEVEL2COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -336,7 +336,7 @@ select
CONCAT('countywjpk/',s1.`setdate`) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('countywjpk/',s1.`setdate`)
CONCAT('countywjpk/',s1.`setdate`,s1.`LEVEL3COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -353,7 +353,7 @@ select
CONCAT('teamwjpk/',s1.`setdate`) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast (sumZBUDF(
CONCAT('teamwjpk/',s1.`setdate`)
CONCAT('teamwjpk/',s1.`setdate`,s1.`LEVEL4COMCODE`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -375,7 +375,7 @@ select
CONCAT('allwjxlbf/',s1.`setdate`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('allwjxlbf/',s1.`setdate`)
CONCAT('allwjxlbf/',s1.`setdate`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -392,7 +392,7 @@ select
CONCAT('provwjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('provwjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('provwjxlbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -409,7 +409,7 @@ select
CONCAT('citywjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('citywjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citywjxlbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -426,7 +426,7 @@ select
CONCAT('countywjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('countywjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countywjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -443,7 +443,7 @@ select
CONCAT('teamwjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`classcode` as `hkey`
,cast (sumZBUDF(
CONCAT('teamwjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('teamwjxlbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`,s1.`classcode`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -467,7 +467,7 @@ select
CONCAT('chnlwjbf/',s1.`setdate`,'/00000000') as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlwjbf/',s1.`setdate`,'/00000000')
CONCAT('chnlwjbf/',s1.`setdate`,'/00000000',s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -484,7 +484,7 @@ select
CONCAT('chnlwjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('chnlwjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`)
CONCAT('chnlwjbf/',s1.`setdate`,'/',s1.`LEVEL1COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -501,7 +501,7 @@ select
CONCAT('citychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('citychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`)
CONCAT('citychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL2COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -518,7 +518,7 @@ select
CONCAT('countychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('countychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`)
CONCAT('countychnlwjbf/',s1.`setdate`,'/',s1.`LEVEL3COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......@@ -535,7 +535,7 @@ select
CONCAT('teamchnlwjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`) as `key`
,s1.`chnl` as `hkey`
,cast (sumZBUDF(
CONCAT('teamchnlwjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`)
CONCAT('teamchnlwjbf/',s1.`setdate`,'/',s1.`LEVEL4COMCODE`,s1.`chnl`)
,s1.`settledamount`
,s1.`setdate`
) as decimal (18,2)) as `val`
......
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