Skip to content

D
dataquality_doc
Commit a2049180 authored by 胡涛's avatar 胡涛
Browse files
Options

指标统计sql脚本

parent d3724e4a
Show whitespace changes
Inline Side-by-side
Showing with 1136 additions and 39 deletions
ZB_DM/承保指标/ZB_DM_今日签单今年待起保保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_今日签单今日待起保保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_今日签单保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_今日签单季度末待起保保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_今日签单月底前起保保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分业务来源季末前起保保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分业务来源年底前起保保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分业务来源当日签单当日起保保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分业务来源月底前起保保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分渠道保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_分险类保费.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_归属业务人员当日签单保费排名.sql
View file @ a2049180
......@@ -40,7 +40,7 @@ from (
,`id` as `id`
,`name` as `name`
,sum(`cost`) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -107,7 +107,7 @@ from (
,`id` as `id`
,`name` as `name`
,sum(`cost`) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -182,7 +182,7 @@ from (
,`id` as `id`
,`name` as `name`
,sum(`cost`) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA
from ZB_ODS.ZB_ODS_KAFKA.CBDATA
where
`COMNAME` is not null
and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_新续转保单保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_新续转保单保费季度末前起保.sql
View file @ a2049180
......@@ -15,7 +15,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_新续转保单保费年底前起保.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_新续转保单保费当日签单当日起保.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_新续转保单保费月底前起保.sql
View file @ a2049180
......@@ -14,7 +14,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_车险今日签单保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_车险承保大单.sql
View file @ a2049180
......@@ -36,7 +36,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -93,7 +93,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -154,7 +154,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
......
ZB_DM/承保指标/ZB_DM_非车险今日签单保费.sql
View file @ a2049180
......@@ -13,7 +13,7 @@ SELECT
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.CBATA s1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
where
s1.`COMNAME` is not null
and s1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......
ZB_DM/承保指标/ZB_DM_非车险承保大单.sql
View file @ a2049180
......@@ -37,7 +37,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -94,7 +94,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where
d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
......@@ -155,7 +155,7 @@ from (
,d1.`cost` as `cost`
,d1.`no` as `no`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.CBATA d1
from ZB_ODS.ZB_ODS_KAFKA.CBDATA d1
where d1.`COMNAME` is not null
and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
......
ZB_DM/理赔指标/ZB_DM_分渠道已决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_FQDYJPK ZB_DM_分渠道已决赔款
-- chnlyjbf/日期 渠道代码
-- 1、日期:已决立案日期 未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_FQDYJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`chnl` as `chnl`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'yj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
--总公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'chnlyjbf/'
,s1.`setdate`
,'/00000000'
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'chnlyjbf/'
,s1.`setdate`
,'/',s1.`LEVEL1COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'citychnlyjbf/'
,s1.`setdate`
,'/',s1.`LEVEL2COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countychnlyjbf/'
,s1.`setdate`
,'/',s1.`LEVEL3COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamchnlyjbf/'
,s1.`setdate`
,'/',s1.`LEVEL4COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_FQDYJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_分渠道未决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_FQDWJPK ZB_DM_分渠道未决赔款
-- chnlwjbf/日期 渠道代码
-- 1、日期:已决立案日期 未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_FQDWJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`chnl` as `chnl`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'wj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
--总公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'chnlwjbf/'
,s1.`setdate`
,'/00000000'
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'chnlwjbf/'
,s1.`setdate`
,'/',s1.`LEVEL1COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'citychnlwjbf/'
,s1.`setdate`
,'/',s1.`LEVEL2COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countychnlwjbf/'
,s1.`setdate`
,'/',s1.`LEVEL3COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FQDWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`chnl`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamchnlwjbf/'
,s1.`setdate`
,'/',s1.`LEVEL4COMCODE`
) as `key`
,s1.`chnl` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_FQDWJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_分险类已决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_FXLYJPK ZB_DM_分险类已决赔款
-- allyjxlbf/日期 险类代码
-- 1、日期:已决立案日期 未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_FXLYJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`risk` as `risk`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'yj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
--总公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'allyjxlbf/'
,s1.`setdate`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'provyjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL1COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'cityyjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL2COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countyyjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL3COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLYJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamyjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL4COMCODE`
) as `key`
,s1.`risk` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_FXLYJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_分险类未决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_FXLWJPK ZB_DM_分险类未决赔款
-- allwjxlbf/日期 险类代码
-- 1、日期:已决立案日期 未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_FXLWJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`risk` as `risk`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'wj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
--总公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'allwjxlbf/'
,s1.`setdate`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'provwjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL1COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'citywjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL2COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countywjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL3COMCODE`
) as `key`
,s1.`risk` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_FXLWJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`risk`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamwjxlbf/'
,s1.`setdate`
,'/',s1.`LEVEL4COMCODE`
) as `key`
,s1.`risk` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_FXLWJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_已决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_YJPK ZB_DM_已决赔款
-- key:allyjpk/日期
-- 1、日期:已决立案日期 未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_YJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'yj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT(
'allyjpk/'
,s1.`setdate`
) as `key`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_YJPK_TUANDUI s1
group by
s1.`setdate`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'provyjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_YJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'cityyjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_YJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countyyjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_YJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamyjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_YJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_未决赔款.sql 0 → 100644
View file @ a2049180
-- ZB_DM_WJPK ZB_DM_未决赔款
-- key:allwjpk/日期
-- 1、日期:未决估损调整日期(yyyyMMdd)
-- step1：
-- 团队汇总
CREATE TEMPORARY VIEW VIEW_ZB_DM_WJPK_TUANDUI AS
SELECT
s1.`setdate` as `setdate`
,s1.`LEVEL1COMCODE` as `LEVEL1COMCODE`
,s1.`LEVEL2COMCODE` as `LEVEL2COMCODE`
,s1.`LEVEL3COMCODE` as `LEVEL3COMCODE`
,s1.`LEVEL4COMCODE` as `LEVEL4COMCODE`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `cost`
from ZB_ODS.ZB_ODS_KAFKA.LPDATA s1
where
s1.`COMNAME` is not null
and s1.`flag`= 'wj'
and LEFT(s1.`setdate`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
group by
s1.`setdate`
,s1.`LEVEL1COMCODE`
,s1.`LEVEL2COMCODE`
,s1.`LEVEL3COMCODE`
,s1.`LEVEL4COMCODE`
;
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
select
CONCAT(
'allwjpk/'
,s1.`setdate`
) as `key`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_WJPK_TUANDUI s1
group by
s1.`setdate`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'provwjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL1COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_WJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL1COMCODE`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'citywjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL2COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_WJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL2COMCODE`
;
-- 县支
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'countywjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL3COMCODE` as `hkey`
,sum(cast(s1.`cost` as DECIMAL(18,2))) as `val`
from VIEW_ZB_DM_WJPK_TUANDUI s1
group by
s1.`setdate`
,s1.`LEVEL3COMCODE`
;
-- 团队
insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
select
CONCAT(
'teamwjpk/'
,s1.`setdate`
) as `key`
,s1.`LEVEL4COMCODE` as `hkey`
,cast(s1.`cost` as DECIMAL(18,2)) as `val`
from VIEW_ZB_DM_WJPK_TUANDUI s1
;
\ No newline at end of file
ZB_DM/理赔指标/ZB_DM_车险未决大单.sql 0 → 100644
View file @ a2049180
-- ZB_DM_CXWJDD ZB_DM_车险未决大单
-- bigclpbdt/日期
-- 估损调整日期在今天，按照估损金额排序，取前20，车险riskcode 05开头，其他为非车，
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigclpbdt/'
,s1.`setdate`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from(
select
d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigcitylpbdt/'
,s1.`setdate`
,'/',s1.`group_com`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from (
select
d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city`
,d1.`LEVEL2COMCODE` as `cityname`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
,s1.`group_com`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigcountrylpbdt/'
,s1.`setdate`
,'/',s1.`group_com`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,','
,'country' ,':' ,`country` ,','
,'countryname' ,':' ,`countryname` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from (
select
d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city`
,d1.`LEVEL2COMCODE` as `cityname`
,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) = '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
,s1.`group_com`
;
ZB_DM/理赔指标/ZB_DM_非车险未决大单.sql 0 → 100644
View file @ a2049180
-- ZB_DM_FCXWJDD ZB_DM_非车未决大单
-- bigfclpbdt/日期
-- 估损调整日期在今天，按照估损金额排序，取前20，车险riskcode 05开头，其他为非车，
-- 总公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigfclpbdt/'
,s1.`setdate`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from(
select
d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
;
-- 分公司
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigcitylpbdt/'
,s1.`setdate`
,'/',s1.`group_com`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from (
select
d1.`setdate` as `setdate`
,d1.`LEVEL1COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city`
,d1.`LEVEL2COMCODE` as `cityname`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL1COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
,s1.`group_com`
;
-- 中支
insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
select
CONCAT(
'bigcountrylpbdt/'
,s1.`setdate`
,'/',s1.`group_com`
) as `key`
,CastToJsonArrayUDF(
listagg(concat(
'com' ,':' ,`com` ,','
,'maincom' ,':' ,`maincom` ,','
,'city' ,':' ,`city` ,','
,'cityname' ,':' ,`cityname` ,','
,'country' ,':' ,`country` ,','
,'countryname' ,':' ,`countryname` ,','
,'no' ,':' ,`no` ,','
,'claimno' ,':' ,`claimno` ,','
,'cost' ,':' ,`cost` ,','
,'comname' ,':' ,`comname` ,','
,'chnl' ,':' ,`chnl` ,','
,'mainkey' ,':' ,`mainkey` ,','
,'riskname' ,':' ,`riskname` ,','
,'chnlname' ,':' ,`chnlname` ,','
,'risk' ,':' ,`risk`
),';')
) as `val`
from (
select
*
from (
select
d1.`setdate` as `setdate`
,d1.`LEVEL2COMCODE` as `group_com`
,d1.`LEVEL1COMCODE` as `com`
,d1.`LEVEL1COMDESC` as `comname`
,d1.`LEVEL1COMCODE` as `maincom`
,d1.`LEVEL2COMDESC` as `city`
,d1.`LEVEL2COMCODE` as `cityname`
,d1.`LEVEL3COMCODE` as `country`
,d1.`LEVEL3COMDESC` as `countryname`
,d1.`no` as `no`
,d1.`claimno` as `claimno`
,d1.`cost` as `cost`
,d1.`chnl` as `chnl`
,d1.`chnlname` as `chnlname`
,CAST(d1.`LEVEL1COMCODE`,d1.`claimno`,d1.`no`) as `mainkey`
,d1.`risk` as `risk`
,d1.`riskname` as `riskname`
,ROW_NUMBER() OVER(PARTITION BY d1.`LEVEL2COMCODE`,d1.`setdate` ORDER BY d1.`lossamout` DESC) as rownum
from ZB_ODS.ZB_ODS_KAFKA.LPDATA d1
where
d1.`COMNAME` is not null
and d1.`flag` = 'wj'
and LEFT(s1.`setdate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
and LEFT(d1.`risk`,2) <> '05'
) c1
where c1.rownum <= 20
ORDER by
c1.`cost`
asc
) s1
group by
s1.`setdate`
,s1.`group_com`
;
ZB_ODS/DDL元数据/CBDATA.sql
View file @ a2049180
-- CBATA 承保业务数据
-- CBDATA 承保业务数据
create table CBATA(
create table CBDATA(
`uwConclueDate` String ,-- 核保通过时间
`startTime` String ,-- 起保时间
`COMCODE` String ,-- 保单归属机构代码
......
ZB_ODS/DDL元数据/LPDATA.sql 0 → 100644
View file @ a2049180
-- LPDATA 理赔业务数据
create table LPDATA(
`COMCODE` String ,-- 保单归属机构代码
`COMNAME` String ,-- 保单归属机构名称
`LEVEL1COMCODE` String ,-- 一级代码
`LEVEL2COMCODE` String ,-- 二级代码
`LEVEL3COMCODE` String ,-- 三级代码
`LEVEL4COMCODE` String ,-- 四级代码
`LEVEL5COMCODE` String ,-- 五级代码
`LEVEL1COMDESC` String ,-- 一级名称
`LEVEL2COMDESC` String ,-- 二级名称
`LEVEL3COMDESC` String ,-- 三级名称
`LEVEL4COMDESC` String ,-- 四级名称
`LEVEL5COMDESC` String ,-- 五级名称
`risk` String ,-- 险种代码
`riskname` String ,-- 险种代码名称
`businessNatureCode` String ,-- 业务来源
`businessNatureName` String ,-- 业务来源名称
`chnl` String ,-- 业务渠道
`chnlname` String ,-- 业务渠道名称
`cladate` String ,-- 立案日期
`setdate` String ,-- 结案日期/估损调整日期
`cost` String ,-- 已决赔款金额/估损提转差
`lossamout` String ,-- 估损金额
`flag` String ,-- 类型
`claimno` String ,-- 赔案号
`no` String ,-- 保单号
)
;
\ No newline at end of file
ZB_ODS/DDL元数据/WJPK.sql 0 → 100644
View file @ a2049180
-- WJPK 理赔未决赔款
create table WJPK(
businessOffice String ,-- 机构
productCode String ,-- 险种
businessNatureCode String ,-- 业务来源
businessChannelCode String ,-- 渠道
cladate String ,-- 立案日期
setdate String ,-- 结案日期
cost String ,-- 已决赔款金额
lossamout String ,-- 估损金额
flag String ,-- 类型
claimno String ,-- 赔案号
no String ,-- 保单号
proctime String ,
)
;
\ No newline at end of file
ZB_ODS/DDL元数据/YJPK.sql 0 → 100644
View file @ a2049180
-- YJPK 理赔已决赔款
create table YJPK(
businessOffice String ,-- 机构
productCode String ,-- 险种
businessNatureCode String ,-- 业务来源
businessChannelCode String ,-- 渠道
cladate String ,-- 立案日期
setdate String ,-- 结案日期
cost String ,-- 已决赔款金额
lossamout String ,-- 估损金额
flag String ,-- 类型
claimno String ,-- 赔案号
no String ,-- 保单号
proctime String ,
)
;
\ No newline at end of file
ZB_ODS/ZB_ODS_LPDATA.sql
View file @ a2049180
......@@ -2,7 +2,7 @@
insert into ZB_ODS.ZB_ODS_KAFKA.LPDATA
select
,s1.businessOffice as `COMCODE` --
s1.businessOffice as `COMCODE` --
,t1.COMNAME as `COMNAME` --
,t1.LEVEL1COMCODE as `LEVEL1COMCODE` --
,t1.LEVEL2COMCODE as `LEVEL2COMCODE` --
......@@ -26,37 +26,37 @@ select
,s1.lossamout as `lossamout` -- 估损金额
,s1.flag as `flag` -- 类型
,s1.claimno as `claimno` -- 赔案号
,s1.no as `no` -- 保单号
,s1.`no` as `no` -- 保单号
from (
select
,businessOffice as businessOffice -- 机构
businessOffice as businessOffice -- 机构
,productCode as productCode -- 险种
,businessNatureCode as businessNatureCode -- 业务来源
,businessChannelCode as businessChannelCode -- 渠道
,cladate as cladate -- 立案日期
,setdate as setdate -- 结案日期
,left(replace(cladate,'-',''),6) as cladate -- 立案日期
,replace(setdate,'-','') as setdate -- 结案日期
,cost as cost -- 已决赔款金额
,lossamout as lossamout -- 估损金额
,flag as flag -- 类型
,claimno as claimno -- 赔案号
,no as no -- 保单号
,`no` as `no` -- 保单号
,proctime as proctime
from ZB_ODS.ZB_SOURCE_KAFKA_YJPK.YJPK -- 保单业务数据
union all
select
,businessOffice as businessOffice -- 机构
businessOffice as businessOffice -- 机构
,productCode as productCode -- 险种
,businessNatureCode as businessNatureCode -- 业务来源
,businessChannelCode as businessChannelCode -- 渠道
,cladate as cladate -- 立案日期
,setdate as setdate -- 估损调整日期
,left(replace(cladate,'-',''),6) as cladate -- 立案日期
,replace(setdate,'-','') as setdate -- 结案日期
,cost as cost -- 估损提转差
,lossamout as lossamout -- 估损金额
,flag as flag -- 类型
,claimno as claimno -- 赔案号
,no as no -- 保单号
,`no` as `no` -- 保单号
,proctime as proctime
from ZB_ODS.ZB_SOURCE_KAFKA_WJPK.WJPK -- 批单业务数据
......
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 北京云端微服科技有限公司