指标计算（函数自增）sql脚本

ZB_DM/承保指标/方案四（函数自增）/今日签单/ZB_DM_今日签单今年待起保保费.sql

--- ZB_DM_JRQDJNQBBF ZB_DM_今日签单今年待起保保费
--- key:allqbbf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当年
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
-select
-    CONCAT(
-            'allqbbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provqbbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`LEVEL1COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL1COMCODE`
-;
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'cityqbbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL2COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countryqbbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL3COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamqbbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL4COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL4COMCODE`
-;

ZB_DM/承保指标/方案四（函数自增）/今日签单/ZB_DM_今日签单今日待起保保费.sql

--- ZB_DM_JRQDJRQBBF ZB_DM_今日签单今日待起保保费
--- key:alldayqdbf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当日
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
-select
-    CONCAT(
-            'alldayqdbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provdayqdbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`LEVEL1COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL1COMCODE`
-;
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'citydayqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL2COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countrydayqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL3COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamdayqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL4COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL4COMCODE`
-;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/今日签单/ZB_DM_今日签单保费.sql

--- ZB_DM_JRQDBF ZB_DM_今日签单保费
--- key:allqdbf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
-
--- 总公司 
-insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
-select
-    CONCAT(
-            'allqdbf/'
-        ,s1.`uwConclueDate`
-        )                                      as `key`
-     ,sum(cast(s1.`cost` 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')
-group by
-    s1.`uwConclueDate`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provqdbf/'
-        ,s1.`uwConclueDate`
-        )                                      as `key`
-     ,s1.`LEVEL1COMCODE`                    as `hkey`
-     ,sum(cast(s1.`cost` 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')
-group by
-    s1.`uwConclueDate`
-       ,s1.`LEVEL1COMCODE`
-;
-
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'cityqdbf/'
-        ,s1.`uwConclueDate`
-        )                                     as `key`
-     ,s1.`LEVEL2COMCODE`                      as `hkey`
-     ,sum(cast(s1.`cost` 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')
-group by
-    s1.`uwConclueDate`
-       ,s1.`LEVEL2COMCODE`
-;
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countryqdbf/'
-        ,s1.`uwConclueDate`
-        )                                     as `key`
-     ,s1.`LEVEL3COMCODE`                      as `hkey`
-     ,sum(cast(s1.`cost` 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')
-group by
-    s1.`uwConclueDate`
-       ,s1.`LEVEL3COMCODE`
-;
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL4COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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')
-group by
-    s1.`uwConclueDate`
-       ,s1.`LEVEL4COMCODE`
-;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/今日签单/ZB_DM_今日签单季度末待起保保费.sql

--- ZB_DM_JRQDJDMQBBF ZB_DM_今日签单季度末待起保保费
--- key:allquarterqdbf
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当季度
-
---  总公司
-insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
-select
-    CONCAT(
-            'allquarterqdbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-           WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-            END
-group by
-    s1.`uwConclueDate`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provquarterqdbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`LEVEL1COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-           WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-            END
-group by
-     s1.`uwConclueDate`
-    ,s1.`LEVEL1COMCODE`
-;
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'cityquarterqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL2COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-           WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-            END
-group by
-    s1.`uwConclueDate`
-    ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countyquarterqdbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL3COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-           WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-            END
-group by
-    s1.`uwConclueDate`
-    ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamquarterqdbf/'
-        ,s1.`uwConclueDate`
-        )                                     as `key`
-     ,s1.`LEVEL4COMCODE`                      as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-           WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-            END
-group by
-    s1.`uwConclueDate`
-   ,s1.`LEVEL4COMCODE`
-;

ZB_DM/承保指标/方案四（函数自增）/今日签单/ZB_DM_今日签单月底前起保保费.sql

--- ZB_DM_JRQDYDQQBBF ZB_DM_今日签单月底前起保保费
--- key:allmonthqbbf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当月
-
---  总公司
-insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
-select
-    CONCAT(
-            'allmonthqbbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provmonthqbbf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`LEVEL1COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL1COMCODE`
-;
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'citymonthqbbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL2COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countrymonthqbbf/'
-        ,s1.`uwConclueDate`
-        )                                    as `key`
-     ,s1.`LEVEL3COMCODE`                     as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teammonthqbbf/'
-        ,s1.`uwConclueDate`
-        )                                     as `key`
-     ,s1.`LEVEL4COMCODE`                      as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`LEVEL4COMCODE`
-;

ZB_DM/承保指标/方案四（函数自增）/分业务来源/ZB_DM_分业务来源季末前起保保费.sql

--- ZB_DM_FYWLYBFJMQQB ZB_DM_分业务来源季末前起保保费
--- key:allquarterywlybf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当季度
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'allquarterywlybf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-    WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-END
-group by 
-    s1.`uwConclueDate`
-    ,s1.`businessNatureCode`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provquarterywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL1COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-    WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-END
-group by 
-    s1.`uwConclueDate`
-    ,s1.`businessNatureCode`
-    ,s1.`LEVEL1COMCODE` 
-;
-
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'cityquarterywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL2COMCODE`
-        )                                        as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-    WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-END
-group by
-    s1.`uwConclueDate`
-    ,s1.`businessNatureCode`
-    ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countryquarterywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL3COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-    WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-END
-group by
-    s1.`uwConclueDate`
-    ,s1.`businessNatureCode`
-    ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamquarterywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL4COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                   as `hkey`
-     ,sum(cast(s1.`cost` 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 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 ('07','08','09') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'09')
-    WHEN DATE_FORMAT(LOCALTIMESTAMP,'MM') in ('10','11','12') THEN left(s1.`startTime`,6) <= CONCAT(DATE_FORMAT(LOCALTIMESTAMP,'yyyy'),'12')
-END
-group by
-    s1.`uwConclueDate`
-    ,s1.`businessNatureCode`
-    ,s1.`LEVEL4COMCODE`
-;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/分业务来源/ZB_DM_分业务来源年底前起保保费.sql

--- ZB_DM_FYWLYBFNDQQB ZB_DM_分业务来源年底前起保保费
--- key:allywlybf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当年
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'allywlybf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL1COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL1COMCODE`
-;
-
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'cityywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL2COMCODE`
-        )                                        as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countryywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL3COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL4COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                   as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL4COMCODE`
-;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/分业务来源/ZB_DM_分业务来源当日签单当日起保保费.sql

--- ZB_DM_FYWLYBFDRQDDRQB ZB_DM_分业务来源当日签单当日起保保费
--- key:alldayywlybf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间等于当日
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'alldayywlybf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provdayywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL1COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL1COMCODE`
-;
-
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'citydayywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL2COMCODE`
-        )                                        as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countrydayywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL3COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teamdayywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL4COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                   as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL4COMCODE`
-
-;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/分业务来源/ZB_DM_分业务来源月底前起保保费.sql

--- ZB_DM_FYWLYBFYDQQB ZB_DM_分业务来源月底前起保保费
--- key:allmonthywlybf/日期
--- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
--- 2、起保时间小于等于当月
-
--- 总公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'allmonthywlybf/'
-        ,s1.`uwConclueDate`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-;
-
--- 分公司
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'provmonthywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL1COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL1COMCODE`
-;
-
-
--- 中支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'citymonthywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL2COMCODE`
-        )                                        as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL2COMCODE`
-;
-
-
--- 县支
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'countrymonthywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL3COMCODE`
-        )                                    as `key`
-     ,s1.`businessNatureCode`                as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL3COMCODE`
-;
-
-
--- 团队
-insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select
-    CONCAT(
-            'teammonthywlybf/'
-        ,s1.`uwConclueDate`
-        ,'/'
-        ,s1.`LEVEL4COMCODE`
-        )                                       as `key`
-     ,s1.`businessNatureCode`                   as `hkey`
-     ,sum(cast(s1.`cost` 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.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
-group by
-    s1.`uwConclueDate`
-        ,s1.`businessNatureCode`
-        ,s1.`LEVEL4COMCODE`
-;

ZB_DM/承保指标/方案四（函数自增）/分险类渠道/ZB_DM_分险类渠道保费合并.sql

@@ -7,104 +7,84 @@
 -- 2、起保时间小于等于当年
 
 
-
 --总公司
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select 
-    CONCAT(
-        'allxlbf/'
-        ,s1.`uwConclueDate`
-    )                                       as `key` 
-    ,s1.`classcode`                         as `hkey`
-    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+select
+    CONCAT('allxlbf/',s1.`uwConclueDate`)   as `key`
+     ,s1.`classcode`                        as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('allxlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by 
-    s1.`uwConclueDate`
-    ,s1.`classcode`
-
 ;
 
--- 分公司
+-- 分公司  provxlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
-select 
-    CONCAT(
-        'provxlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL1COMCODE`
-    )                                       as `key`  
-    ,s1.`classcode`                         as `hkey` 
-    ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+select
+    CONCAT('provxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)   as `key`
+     ,s1.`classcode`                                                as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('provxlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by 
-    s1.`uwConclueDate`
-    ,s1.`classcode`
-    ,s1.`LEVEL1COMCODE`
 ;
 
--- 中支
+-- 中支  cityxlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'cityxlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL2COMCODE`
-        )                                    as `key`
-     ,s1.`classcode`                         as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('cityxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)   as `key`
+     ,s1.`classcode`                                                as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('cityxlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-    ,s1.`classcode`
-    ,s1.`LEVEL2COMCODE`
 ;
 
--- 县支
+-- 县支  countryxlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'countryxlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL3COMCODE`
-        )                                    as `key`
-     ,s1.`classcode`                         as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('countryxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)   as `key`
+     ,s1.`classcode`                                                   as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('countryxlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-    ,s1.`classcode`
-    ,s1.`LEVEL3COMCODE`
 ;
 
--- 团队
+-- 团队   teamxlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'teamxlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL4COMCODE`
-        )                               as `key`
-     ,s1.`classcode`                    as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('teamxlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)   as `key`
+     ,s1.`classcode`                                                as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('teamxlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-    ,s1.`classcode`
-    ,s1.`LEVEL4COMCODE`
 ;
 
 
@@ -117,104 +97,84 @@ group by
 -- 总公司
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'chnlbf/'
-        ,s1.`uwConclueDate`
-        ,'/00000000'
-        )                                       as `key`
-     ,s1.`chnl`                              as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('chnlbf/',s1.`uwConclueDate`,'/00000000') as `key`
+     ,s1.`chnl`                                      as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('chnlbf/',s1.`uwConclueDate`,'/00000000')
+    ,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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`chnl`
-
 ;
 
 -- 分公司
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'chnlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL1COMCODE`
-        )                                       as `key`
-     ,s1.`chnl`                              as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('chnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL1COMCODE`)   as `key`
+     ,s1.`chnl`                                                   as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('chnlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`chnl`
-        ,s1.`LEVEL1COMCODE`
 ;
 
 
--- 中支
+-- 中支  citychnlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'citychnlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL2COMCODE`
-        )                                    as `key`
-     ,s1.`chnl`                              as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('citychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL2COMCODE`)   as `key`
+     ,s1.`chnl`                                                       as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('citychnlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`chnl`
-        ,s1.`LEVEL2COMCODE`
 ;
 
 
 
--- 县支
+-- 县支  countrychnlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'countrychnlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL3COMCODE`
-        )                                    as `key`
-     ,s1.`chnl`                              as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('countrychnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL3COMCODE`)   as `key`
+     ,s1.`chnl`                                                          as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('countrychnlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`chnl`
-        ,s1.`LEVEL3COMCODE`
 ;
 
 
 
--- 团队
+-- 团队  teamchnlbf
 insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
 select
-    CONCAT(
-            'teamchnlbf/'
-        ,s1.`uwConclueDate`
-        ,'/',s1.`LEVEL4COMCODE`
-        )                                    as `key`
-     ,s1.`chnl`                              as `hkey`
-     ,sum(cast(s1.`cost` as DECIMAL(18,2)))  as `val`
+    CONCAT('teamchnlbf/',s1.`uwConclueDate`,'/',s1.`LEVEL4COMCODE`)   as `key`
+     ,s1.`chnl`                                                       as `hkey`
+     ,cast (sumZBUDF(
+        CONCAT('teamchnlbf/',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.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
-group by
-    s1.`uwConclueDate`
-        ,s1.`chnl`
-        ,s1.`LEVEL4COMCODE`
 ;
\ No newline at end of file