Commit 9c6e3688 authored by 胡涛's avatar 胡涛

指标统计sql脚本

parent d32251d3
...@@ -13,11 +13,17 @@ SELECT ...@@ -13,11 +13,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
......
...@@ -13,10 +13,16 @@ SELECT ...@@ -13,10 +13,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and left(s1.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
......
...@@ -7,23 +7,28 @@ ...@@ -7,23 +7,28 @@
-- step1: -- step1:
-- 团队汇总 -- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDBF_TUANDUI AS CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDBF_TUANDUI AS
SELECT SELECT s1.`uwConclueDate` as `uwConclueDate`
s1.`uwConclueDate` as `uwConclueDate` , s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE` , s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE` , s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` , s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` , sum(cast(s1.`cost` as DECIMAL(18, 2))) as `cost`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` from (
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 select
where *
s1.`COMNAME` is not null ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
group by where
s1.`uwConclueDate` `COMNAME` is not null
,s1.`LEVEL1COMCODE` and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
,s1.`LEVEL2COMCODE` ) s1
,s1.`LEVEL3COMCODE` where s1.rownum = 1
,s1.`LEVEL4COMCODE` group by
s1.`uwConclueDate`
, s1.`LEVEL1COMCODE`
, s1.`LEVEL2COMCODE`
, s1.`LEVEL3COMCODE`
, s1.`LEVEL4COMCODE`
; ;
-- 总公司 -- 总公司
......
...@@ -13,10 +13,16 @@ SELECT ...@@ -13,10 +13,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
-- 核保时间在今天并且起保时间的月份小于等于季度。 -- 核保时间在今天并且起保时间的月份小于等于季度。
and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03') and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03')
WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('04','05','06') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'06') WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('04','05','06') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'06')
...@@ -99,7 +105,7 @@ select ...@@ -99,7 +105,7 @@ select
'teamquarterqdbf/' 'teamquarterqdbf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,s1.`LEVEL1COMCODE` as `hkey` ,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val` ,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_JRQDJDMQBBF_TUANDUI s1 from VIEW_ZB_DM_JRQDJDMQBBF_TUANDUI s1
; ;
......
...@@ -13,11 +13,17 @@ SELECT ...@@ -13,11 +13,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
...@@ -94,7 +100,7 @@ select ...@@ -94,7 +100,7 @@ select
'teammonthqbbf/' 'teammonthqbbf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,s1.`LEVEL1COMCODE` as `hkey` ,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val` ,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_JRQDYDQQBBF_TUANDUI s1 from VIEW_ZB_DM_JRQDYDQQBBF_TUANDUI s1
; ;
......
...@@ -14,10 +14,16 @@ SELECT ...@@ -14,10 +14,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03') and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03')
WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('04','05','06') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'06') WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('04','05','06') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'06')
WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09') WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
......
...@@ -14,11 +14,17 @@ SELECT ...@@ -14,11 +14,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`businessNatureCode` ,s1.`businessNatureCode`
......
...@@ -14,11 +14,17 @@ SELECT ...@@ -14,11 +14,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`businessNatureCode` ,s1.`businessNatureCode`
......
...@@ -14,11 +14,17 @@ SELECT ...@@ -14,11 +14,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`businessNatureCode` ,s1.`businessNatureCode`
......
...@@ -14,11 +14,17 @@ SELECT ...@@ -14,11 +14,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
......
...@@ -8,21 +8,27 @@ ...@@ -8,21 +8,27 @@
CREATE TEMPORARY VIEW VIEW_ZB_DM_FXLBF_TUANDUI AS CREATE TEMPORARY VIEW VIEW_ZB_DM_FXLBF_TUANDUI AS
SELECT SELECT
s1.`uwConclueDate` as `uwConclueDate` s1.`uwConclueDate` as `uwConclueDate`
,s1.`risk` as `risk` ,s1.`classcode` as `classcode`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE` ,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE` ,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy') from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`risk` ,s1.`classcode`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` ,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` ,s1.`LEVEL3COMCODE`
...@@ -36,12 +42,12 @@ select ...@@ -36,12 +42,12 @@ select
'allxlbf/' 'allxlbf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,s1.`risk` as `hkey` ,s1.`classcode` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLBF_TUANDUI s1 from VIEW_ZB_DM_FXLBF_TUANDUI s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`risk` ,s1.`classcode`
; ;
...@@ -53,12 +59,12 @@ select ...@@ -53,12 +59,12 @@ select
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`LEVEL1COMCODE` ,'/',s1.`LEVEL1COMCODE`
) as `key` ) as `key`
,s1.`risk` as `hkey` ,s1.`classcode` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLBF_TUANDUI s1 from VIEW_ZB_DM_FXLBF_TUANDUI s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`risk` ,s1.`classcode`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
; ;
...@@ -70,12 +76,12 @@ select ...@@ -70,12 +76,12 @@ select
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`LEVEL2COMCODE` ,'/',s1.`LEVEL2COMCODE`
) as `key` ) as `key`
,s1.`risk` as `hkey` ,s1.`classcode` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLBF_TUANDUI s1 from VIEW_ZB_DM_FXLBF_TUANDUI s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`risk` ,s1.`classcode`
,s1.`LEVEL2COMCODE` ,s1.`LEVEL2COMCODE`
; ;
...@@ -87,12 +93,12 @@ select ...@@ -87,12 +93,12 @@ select
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`LEVEL3COMCODE` ,'/',s1.`LEVEL3COMCODE`
) as `key` ) as `key`
,s1.`risk` as `hkey` ,s1.`classcode` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLBF_TUANDUI s1 from VIEW_ZB_DM_FXLBF_TUANDUI s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`risk` ,s1.`classcode`
,s1.`LEVEL3COMCODE` ,s1.`LEVEL3COMCODE`
; ;
...@@ -104,7 +110,7 @@ select ...@@ -104,7 +110,7 @@ select
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`LEVEL4COMCODE` ,'/',s1.`LEVEL4COMCODE`
) as `key` ) as `key`
,s1.`risk` as `hkey` ,s1.`classcode` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val` ,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_FXLBF_TUANDUI s1 from VIEW_ZB_DM_FXLBF_TUANDUI s1
; ;
\ No newline at end of file
...@@ -3,60 +3,82 @@ ...@@ -3,60 +3,82 @@
-- allrybf/日期 -- allrybf/日期
-- 取TOP20 -- 取TOP20
-- step1:
-- 去重
CREATE TEMPORARY VIEW VIEW_ZB_DM_GSYWRNQNBFPM AS
select
*
from (
select
d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,d1.`LEVEL1COMDESC` as `LEVEL1COMDESC`
,d1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,d1.`LEVEL2COMDESC` as `LEVEL2COMDESC`
,d1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,d1.`LEVEL3COMDESC` as `LEVEL3COMDESC`
,d1.`id` as `id`
,d1.`name` as `name`
,d1.`cost` as `cost`
,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
;
-- 总公司 -- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT( CONCAT(
'allrybf/' 'allrybf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'id' ,':' ,`id` ,',' ,'id' ,':' ,`id` ,','
,'name' ,':' ,`name` ,',' ,'name' ,':' ,`name` ,','
,'cost' ,':' ,`cost` ,'cost' ,':' ,cast(s1.`cost` AS VARCHAR )
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from( from(
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`id` as `id` ,d1.`id` as `id`
,d1.`name` as `name` ,d1.`name` as `name`
,cast(d1.`cost` AS VARCHAR ) as `cost` ,d1.`cost` as `cost`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ( from (
select select
`uwConclueDate` as `uwConclueDate` `uwConclueDate` as `uwConclueDate`
,`LEVEL1COMCODE` as `LEVEL1COMCODE` ,`LEVEL1COMCODE` as `LEVEL1COMCODE`
,`LEVEL1COMDESC` as `LEVEL1COMDESC` ,`LEVEL1COMDESC` as `LEVEL1COMDESC`
,`id` as `id` ,`id` as `id`
,`name` as `name` ,`name` as `name`
,sum(cast(`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA from VIEW_ZB_DM_GSYWRNQNBFPM
where group by
`COMNAME` is not null `uwConclueDate`
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,`LEVEL1COMCODE`
group by ,`LEVEL1COMDESC`
`uwConclueDate` ,`id`
,`LEVEL1COMCODE` ,`name`
,`LEVEL1COMDESC` ) d1
,`id` ) c1
,`name` where c1.rownum <= 20
) d1 ) s1
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
; ;
...@@ -64,147 +86,135 @@ group by ...@@ -64,147 +86,135 @@ group by
-- 分公司 -- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT( CONCAT(
'provrybf/' 'provrybf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`group_com` ,'/',s1.`group_com`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'city' ,':' ,`city` ,',' ,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,',' ,'cityname' ,':' ,`cityname` ,','
,'id' ,':' ,`id` ,',' ,'id' ,':' ,`id` ,','
,'name' ,':' ,`name` ,',' ,'name' ,':' ,`name` ,','
,'cost' ,':' ,`cost` ,'cost' ,':' ,cast(s1.`cost` AS VARCHAR )
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from( from(
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`id` as `id` ,d1.`id` as `id`
,d1.`name` as `name` ,d1.`name` as `name`
,cast(d1.`cost` AS VARCHAR ) as `cost` ,d1.`cost` as `cost`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL1COMCODE` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL1COMCODE` ORDER BY d1.`cost` DESC) as rownum
from ( from (
select select
`uwConclueDate` as `uwConclueDate` `uwConclueDate` as `uwConclueDate`
,`LEVEL1COMCODE` as `LEVEL1COMCODE` ,`LEVEL1COMCODE` as `LEVEL1COMCODE`
,`LEVEL1COMDESC` as `LEVEL1COMDESC` ,`LEVEL1COMDESC` as `LEVEL1COMDESC`
,`LEVEL2COMCODE` as `LEVEL2COMCODE` ,`LEVEL2COMCODE` as `LEVEL2COMCODE`
,`LEVEL2COMDESC` as `LEVEL2COMDESC` ,`LEVEL2COMDESC` as `LEVEL2COMDESC`
,`id` as `id` ,`id` as `id`
,`name` as `name` ,`name` as `name`
,sum(cast(`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA from VIEW_ZB_DM_GSYWRNQNBFPM a1
where group by
`COMNAME` is not null `uwConclueDate`
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,`LEVEL1COMCODE`
group by ,`LEVEL1COMDESC`
`uwConclueDate` ,`LEVEL2COMCODE`
,`LEVEL1COMCODE` ,`LEVEL2COMDESC`
,`LEVEL1COMDESC` ,`id`
,`LEVEL2COMCODE` ,`name`
,`LEVEL2COMDESC` ) d1
,`id` ) c1
,`name` where c1.rownum <= 20
) d1 ) s1
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`group_com` ,s1.`group_com`
; ;
-- 中支 -- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT( CONCAT(
'cityrybf/' 'cityrybf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`group_com` ,'/',s1.`group_com`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'city' ,':' ,`city` ,',' ,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,',' ,'cityname' ,':' ,`cityname` ,','
,'country' ,':' ,`country` ,',' ,'country' ,':' ,`country` ,','
,'countryname' ,':' ,`countryname` ,',' ,'countryname' ,':' ,`countryname` ,','
,'id' ,':' ,`id` ,',' ,'id' ,':' ,`id` ,','
,'name' ,':' ,`name` ,',' ,'name' ,':' ,`name` ,','
,'cost' ,':' ,`cost` ,'cost' ,':' ,cast(s1.`cost` AS VARCHAR )
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from( from(
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`id` as `id` ,d1.`id` as `id`
,d1.`name` as `name` ,d1.`name` as `name`
,cast(d1.`cost` AS VARCHAR ) as `cost` ,d1.`cost` as `cost`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL2COMCODE` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL2COMCODE` ORDER BY d1.`cost` DESC) as rownum
from ( from (
select select
`uwConclueDate` as `uwConclueDate` `uwConclueDate` as `uwConclueDate`
,`LEVEL1COMCODE` as `LEVEL1COMCODE` ,`LEVEL1COMCODE` as `LEVEL1COMCODE`
,`LEVEL1COMDESC` as `LEVEL1COMDESC` ,`LEVEL1COMDESC` as `LEVEL1COMDESC`
,`LEVEL2COMCODE` as `LEVEL2COMCODE` ,`LEVEL2COMCODE` as `LEVEL2COMCODE`
,`LEVEL2COMDESC` as `LEVEL2COMDESC` ,`LEVEL2COMDESC` as `LEVEL2COMDESC`
,`LEVEL3COMCODE` as `LEVEL3COMCODE` ,`LEVEL3COMCODE` as `LEVEL3COMCODE`
,`LEVEL3COMDESC` as `LEVEL3COMDESC` ,`LEVEL3COMDESC` as `LEVEL3COMDESC`
,`id` as `id` ,`id` as `id`
,`name` as `name` ,`name` as `name`
,sum(cast(`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA from VIEW_ZB_DM_GSYWRNQNBFPM a1
where group by
`COMNAME` is not null `uwConclueDate`
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,`LEVEL1COMCODE`
group by ,`LEVEL1COMDESC`
`uwConclueDate` ,`LEVEL2COMCODE`
,`LEVEL1COMCODE` ,`LEVEL2COMDESC`
,`LEVEL1COMDESC` ,`LEVEL3COMCODE`
,`LEVEL2COMCODE` ,`LEVEL3COMDESC`
,`LEVEL2COMDESC` ,`id`
,`LEVEL3COMCODE` ,`name`
,`LEVEL3COMDESC` ) d1
,`id` ) c1
,`name` where c1.rownum <= 20
) d1 ) s1
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`group_com` ,s1.`group_com`
; ;
...@@ -13,11 +13,17 @@ SELECT ...@@ -13,11 +13,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and s1.`xxzflag` = '1' from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and s1.`xxzflag` = '1'
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
......
...@@ -15,10 +15,16 @@ SELECT ...@@ -15,10 +15,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and s1.`xxzflag` = '1' and s1.`xxzflag` = '1'
-- 起保时间的季度小于等于当前季度 -- 起保时间的季度小于等于当前季度
and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03') and CASE WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('01','02','03') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'03')
......
...@@ -14,10 +14,16 @@ SELECT ...@@ -14,10 +14,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and s1.`xxzflag` = '1' and s1.`xxzflag` = '1'
and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy') and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
......
...@@ -14,10 +14,16 @@ SELECT ...@@ -14,10 +14,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and s1.`xxzflag` = '1' and s1.`xxzflag` = '1'
and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
...@@ -14,10 +14,16 @@ SELECT ...@@ -14,10 +14,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and s1.`xxzflag` = '1' and s1.`xxzflag` = '1'
and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM') and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
......
...@@ -13,10 +13,16 @@ SELECT ...@@ -13,10 +13,16 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.risk,2) ='05' and left(s1.risk,2) ='05'
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
...@@ -94,7 +100,7 @@ select ...@@ -94,7 +100,7 @@ select
'teamcarqdbf/' 'teamcarqdbf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,s1.`LEVEL1COMCODE` as `hkey` ,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val` ,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_QDBF_CAR_TUANDUI s1 from VIEW_ZB_DM_QDBF_CAR_TUANDUI s1
; ;
\ No newline at end of file
...@@ -2,52 +2,77 @@ ...@@ -2,52 +2,77 @@
-- bigcbd/日期 -- bigcbd/日期
-- 核保或者核批时间在今天,按照保费或者未决赔款排序,取前10,车险riskcode 05开头,其他为非车, -- 核保或者核批时间在今天,按照保费或者未决赔款排序,取前10,车险riskcode 05开头,其他为非车,
-- 车险去重
CREATE TEMPORARY VIEW VIEW_ZB_DM_CXCBDD AS
select
*
from (
select
`uwConclueDate` as `uwConclueDate`
,`LEVEL1COMCODE` as `LEVEL1COMCODE`
,`LEVEL1COMDESC` as `LEVEL1COMDESC`
,`LEVEL2COMCODE` as `LEVEL2COMCODE`
,`LEVEL2COMDESC` as `LEVEL2COMDESC`
,`LEVEL3COMCODE` as `LEVEL3COMCODE`
,`LEVEL3COMDESC` as `LEVEL3COMDESC`
,`risk` as `risk`
,`riskname` as `riskname`
,`chnl` as `chnl`
,`chnlname` as `chnlname`
,cast(`cost` as decimal(18,2)) as `cost`
,`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and LEFT(s1.`risk`,2) = '05'
;
-- 总公司 -- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT( CONCAT(
'bigcbd/' 'bigcbd/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'risk' ,':' ,`risk` ,',' ,'risk' ,':' ,`risk` ,','
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from( from(
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_CXCBDD d1
where ) c1
d1.`COMNAME` is not null where c1.rownum <= 20
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ) s1
and LEFT(d1.`risk`,2) = '05' group by
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`uwConclueDate` s1.`uwConclueDate`
; ;
...@@ -55,58 +80,51 @@ group by ...@@ -55,58 +80,51 @@ group by
-- 分公司 -- 分公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
CONCAT( CONCAT(
'bigccitybd/' 'bigccitybd/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`group_com` ,'/',s1.`group_com`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'city' ,':' ,`city` ,',' ,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,',' ,'cityname' ,':' ,`cityname` ,','
,'risk' ,':' ,`risk` ,',' ,'risk' ,':' ,`risk` ,','
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from ( from (
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL1COMCODE` as `group_com` ,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_CXCBDD d1
where ) c1
d1.`COMNAME` is not null where c1.rownum <= 20
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ) s1
and LEFT(d1.`risk`,2) = '05' group by
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`group_com` ,s1.`group_com`
; ;
...@@ -118,54 +136,48 @@ select ...@@ -118,54 +136,48 @@ select
,s1.`uwConclueDate` ,s1.`uwConclueDate`
,'/',s1.`group_com` ,'/',s1.`group_com`
) as `key` ) as `key`
,CastToJsonArrayUDF( ,CastToJsonArrayUDF(
listagg(concat( listagg(concat(
'com' ,':' ,`com` ,',' 'com' ,':' ,`com` ,','
,'comname' ,':' ,`comname` ,',' ,'comname' ,':' ,`comname` ,','
,'city' ,':' ,`city` ,',' ,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,',' ,'cityname' ,':' ,`cityname` ,','
,'country' ,':' ,`country` ,',' ,'country' ,':' ,`country` ,','
,'countryname' ,':' ,`countryname` ,',' ,'countryname' ,':' ,`countryname` ,','
,'risk' ,':' ,`risk` ,',' ,'risk' ,':' ,`risk` ,','
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
from ( from (
select select
* *
from ( from (
select select
d1.`uwConclueDate` as `uwConclueDate` d1.`uwConclueDate` as `uwConclueDate`
,d1.`LEVEL2COMCODE` as `group_com` ,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com` ,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname` ,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL2COMCODE` as `city` ,d1.`LEVEL2COMCODE` as `city`
,d1.`LEVEL2COMDESC` as `cityname` ,d1.`LEVEL2COMDESC` as `cityname`
,d1.`LEVEL3COMCODE` as `country` ,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname` ,d1.`LEVEL3COMDESC` as `countryname`
,d1.`risk` as `risk` ,d1.`risk` as `risk`
,d1.`riskname` as `riskname` ,d1.`riskname` as `riskname`
,d1.`chnl` as `chnl` ,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname` ,d1.`chnlname` as `chnlname`
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_CXCBDD d1
where d1.`COMNAME` is not null ) c1
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') where c1.rownum <= 20
and LEFT(d1.`risk`,2) = '05' ) s1
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`group_com` ,s1.`group_com`
; ;
...@@ -13,11 +13,17 @@ SELECT ...@@ -13,11 +13,17 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE` ,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE` ,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost` ,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1 from (
where select
s1.`COMNAME` is not null *
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd') ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
and left(s1.risk,2) <>'05' from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and left(s1.risk,2) <>'05'
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
,s1.`LEVEL1COMCODE` ,s1.`LEVEL1COMCODE`
...@@ -94,7 +100,7 @@ select ...@@ -94,7 +100,7 @@ select
'teamnocarqdbf/' 'teamnocarqdbf/'
,s1.`uwConclueDate` ,s1.`uwConclueDate`
) as `key` ) as `key`
,s1.`LEVEL1COMCODE` as `hkey` ,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val` ,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_QDBF_NOCAR_TUANDUI s1 from VIEW_ZB_DM_QDBF_NOCAR_TUANDUI s1
; ;
\ No newline at end of file
...@@ -3,6 +3,38 @@ ...@@ -3,6 +3,38 @@
-- 核保或者核批时间在今天,按照保费或者未决赔款排序,取前10,车险riskcode 05开头,其他为非车, -- 核保或者核批时间在今天,按照保费或者未决赔款排序,取前10,车险riskcode 05开头,其他为非车,
-- 非车险去重
CREATE TEMPORARY VIEW VIEW_ZB_DM_FCXCBDD AS
select
*
from (
select
`uwConclueDate` as `uwConclueDate`
,`LEVEL1COMCODE` as `LEVEL1COMCODE`
,`LEVEL1COMDESC` as `LEVEL1COMDESC`
,`LEVEL2COMCODE` as `LEVEL2COMCODE`
,`LEVEL2COMDESC` as `LEVEL2COMDESC`
,`LEVEL3COMCODE` as `LEVEL3COMCODE`
,`LEVEL3COMDESC` as `LEVEL3COMDESC`
,`risk` as `risk`
,`riskname` as `riskname`
,`chnl` as `chnl`
,`chnlname` as `chnlname`
,cast(`cost` as decimal(18,2)) as `cost`
,`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
) s1
where s1.rownum = 1
and LEFT(s1.`risk`,2) <> '05'
;
-- 总公司 -- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select select
...@@ -18,7 +50,7 @@ select ...@@ -18,7 +50,7 @@ select
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
...@@ -37,16 +69,9 @@ from ( ...@@ -37,16 +69,9 @@ from (
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_FCXCBDD d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1 ) c1
where c1.rownum <= 20 where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1 ) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
...@@ -72,7 +97,7 @@ select ...@@ -72,7 +97,7 @@ select
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
...@@ -94,16 +119,9 @@ from ( ...@@ -94,16 +119,9 @@ from (
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_FCXCBDD d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1 ) c1
where c1.rownum <= 20 where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1 ) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
...@@ -131,7 +149,7 @@ select ...@@ -131,7 +149,7 @@ select
,'riskname' ,':' ,`riskname` ,',' ,'riskname' ,':' ,`riskname` ,','
,'chnl' ,':' ,`chnl` ,',' ,'chnl' ,':' ,`chnl` ,','
,'chnlname' ,':' ,`chnlname` ,',' ,'chnlname' ,':' ,`chnlname` ,','
,'cost' ,':' ,`cost` ,',' ,'cost' ,':' ,cast(`cost` as varchar) ,','
,'no' ,':' ,`no` ,'no' ,':' ,`no`
),';') ),';')
) as `val` ) as `val`
...@@ -155,15 +173,9 @@ from ( ...@@ -155,15 +173,9 @@ from (
,d1.`cost` as `cost` ,d1.`cost` as `cost`
,d1.`no` as `no` ,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum ,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1 from VIEW_ZB_DM_FCXCBDD d1
where d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1 ) c1
where c1.rownum <= 20 where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1 ) s1
group by group by
s1.`uwConclueDate` s1.`uwConclueDate`
......
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