指标计算承保字段调整

ZB_DM/承保指标/方案一（直接计算）/今日签单/ZB_DM_今日签单(合并).sql

@@ -6,6 +6,8 @@
 -- key:allqdbf/日期
 -- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
 
+sumUDF('key','val')
+
 -- 总公司 
 insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
 select

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

+-- ZB_DM_FXLQDBF_HB ZB_DM_分险类渠道保费合并
+
+
+-- ZB_DM_FXLBF ZB_DM_分险类保费
+-- allxlbf/日期	险类代码
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 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`
+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`
+
+;
+
+-- 分公司
+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`
+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`
+;
+
+-- 中支
+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`
+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`
+;
+
+-- 县支
+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`
+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`
+;
+
+-- 团队
+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`
+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`
+;
+
+
+-- ZB_DM_FQDBF ZB_DM_分渠道保费
+-- chnlbf/日期/00000000	渠道代码
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、起保时间小于等于当年
+
+
+-- 总公司
+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`
+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`
+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`
+;
+
+
+-- 中支
+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`
+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`
+;
+
+
+
+-- 县支
+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`
+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`
+;
+
+
+
+-- 团队
+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`
+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

ZB_DM/承保指标/方案四（函数自增）/归属业务人员/ZB_DM_归属业务人员当日签单保费排名.sql

+-- ZB_DM_GSYWRNQNBFPM ZB_DM_归属业务人员当日签单保费排名
+
+-- allrybf/日期
+-- 取TOP20 按代理人当天出单保费和排序
+
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'allrybf/'
+        ,s1.`uwConclueDate`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                     'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'id'       ,':'  ,`id`       ,','
+                    ,'name'     ,':'  ,`name`     ,','
+                    ,'cost'     ,':'  ,cast(s1.`cost` AS VARCHAR )
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                     as `uwConclueDate`
+                      ,d1.`LEVEL1COMCODE`                     as `group_com`
+                      ,d1.`LEVEL1COMCODE`                     as `com`
+                      ,d1.`LEVEL1COMDESC`                     as `comname`
+                      ,d1.`id`                                as `id`
+                      ,d1.`name`                              as `name`
+                      ,d1.`cost`                              as `cost`
+                      ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate` ORDER BY d1.`cost` DESC) as rownum
+                 from (
+                          select
+                              `uwConclueDate`                            as `uwConclueDate`
+                               ,`LEVEL1COMCODE`                           as `LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`                           as `LEVEL1COMDESC`
+                               ,`id`                                      as `id`
+                               ,`name`                                    as `name`
+                               ,sum(cast(`cost` as DECIMAL(18,2)))        as `cost`
+                          from ZB_ODS.ZB_ODS_KAFKA.CBDATA 
+                          where `COMNAME` is not null
+                            and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                          group by
+                              `uwConclueDate`
+                               ,`LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`
+                               ,`id`
+                               ,`name`
+                      ) d1
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+;
+
+
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'provrybf/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                     'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'city'     ,':'  ,`city`     ,','
+                    ,'cityname' ,':'  ,`cityname` ,','
+                    ,'id'       ,':'  ,`id`       ,','
+                    ,'name'     ,':'  ,`name`     ,','
+                    ,'cost'     ,':'  ,cast(s1.`cost` AS VARCHAR )
+                    ),';')
+       )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                  as `uwConclueDate`
+                      ,d1.`LEVEL1COMCODE`                  as `group_com`
+                      ,d1.`LEVEL1COMCODE`                  as `com`
+                      ,d1.`LEVEL1COMDESC`                  as `comname`
+                      ,d1.`LEVEL2COMCODE`                  as `city`
+                      ,d1.`LEVEL2COMDESC`                  as `cityname`
+                      ,d1.`id`                             as `id`
+                      ,d1.`name`                           as `name`
+                      ,d1.`cost`                           as `cost`
+                      ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL1COMCODE` ORDER BY d1.`cost` DESC) as rownum
+                 from (
+                          select
+                              `uwConclueDate`                      as `uwConclueDate`
+                               ,`LEVEL1COMCODE`                     as `LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`                     as `LEVEL1COMDESC`
+                               ,`LEVEL2COMCODE`                     as `LEVEL2COMCODE`
+                               ,`LEVEL2COMDESC`                     as `LEVEL2COMDESC`
+                               ,`id`                                as `id`
+                               ,`name`                              as `name`
+                               ,sum(cast(`cost` as DECIMAL(18,2)))  as `cost`
+                          from ZB_ODS.ZB_ODS_KAFKA.CBDATA
+                          where `COMNAME` is not null
+                            and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                          group by
+                              `uwConclueDate`
+                               ,`LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`
+                               ,`LEVEL2COMCODE`
+                               ,`LEVEL2COMDESC`
+                               ,`id`
+                               ,`name`
+                      ) d1
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
+
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'cityrybf/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'         ,':'  ,`com`         ,','
+                    ,'comname'     ,':'  ,`comname`     ,','
+                    ,'city'        ,':'  ,`city`        ,','
+                    ,'cityname'    ,':'  ,`cityname`    ,','
+                    ,'country'     ,':'  ,`country`     ,','
+                    ,'countryname' ,':'  ,`countryname` ,','
+                    ,'id'          ,':'  ,`id`          ,','
+                    ,'name'        ,':'  ,`name`        ,','
+                    ,'cost'        ,':'  ,cast(s1.`cost` AS VARCHAR )
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                  as `uwConclueDate`
+                      ,d1.`LEVEL2COMCODE`                  as `group_com`
+                      ,d1.`LEVEL1COMCODE`                  as `com`
+                      ,d1.`LEVEL1COMDESC`                  as `comname`
+                      ,d1.`LEVEL2COMCODE`                  as `city`
+                      ,d1.`LEVEL2COMDESC`                  as `cityname`
+                      ,d1.`LEVEL3COMCODE`                  as `country`
+                      ,d1.`LEVEL3COMDESC`                  as `countryname`
+                      ,d1.`id`                             as `id`
+                      ,d1.`name`                           as `name`
+                      ,d1.`cost`                           as `cost`
+                      ,ROW_NUMBER() OVER(PARTITION BY d1.`uwConclueDate`,d1.`LEVEL2COMCODE` ORDER BY d1.`cost` DESC) as rownum
+                 from (
+                          select
+                              `uwConclueDate`                      as `uwConclueDate`
+                               ,`LEVEL1COMCODE`                     as `LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`                     as `LEVEL1COMDESC`
+                               ,`LEVEL2COMCODE`                     as `LEVEL2COMCODE`
+                               ,`LEVEL2COMDESC`                     as `LEVEL2COMDESC`
+                               ,`LEVEL3COMCODE`                     as `LEVEL3COMCODE`
+                               ,`LEVEL3COMDESC`                     as `LEVEL3COMDESC`
+                               ,`id`                                as `id`
+                               ,`name`                              as `name`
+                               ,sum(cast(`cost` as DECIMAL(18,2)))  as `cost`
+                          from ZB_ODS.ZB_ODS_KAFKA.CBDATA
+                          where `COMNAME` is not null
+                            and `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                          group by
+                              `uwConclueDate`
+                               ,`LEVEL1COMCODE`
+                               ,`LEVEL1COMDESC`
+                               ,`LEVEL2COMCODE`
+                               ,`LEVEL2COMDESC`
+                               ,`LEVEL3COMCODE`
+                               ,`LEVEL3COMDESC`
+                               ,`id`
+                               ,`name`
+                      ) d1
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
+

ZB_DM/承保指标/方案四（函数自增）/新续转/ZB_DM_新续转保单保费.sql

+-- ZB_DM_XXZBDBF ZB_DM_新续转保单保费
+-- key:xxzbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、新续转保得保单
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'xxzbf/'
+        ,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 s1.`xxzflag` = '1'
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provxxzbf/'
+        ,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 s1.`xxzflag` = '1'
+group by
+    s1.`uwConclueDate`
+       ,s1.`LEVEL1COMCODE`
+;
+
+
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'cityxxzbf/'
+        ,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 s1.`xxzflag` = '1'
+group by
+    s1.`uwConclueDate`
+       ,s1.`LEVEL2COMCODE`
+;
+
+-- 县支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'countryxxzbf/'
+        ,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 s1.`xxzflag` = '1'
+group by
+    s1.`uwConclueDate`
+       ,s1.`LEVEL3COMCODE`
+;
+
+-- 团队
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'teamxxzbf/'
+        ,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 s1.`xxzflag` = '1'
+group by
+    s1.`uwConclueDate`
+       ,s1.`LEVEL4COMCODE`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/新续转/ZB_DM_新续转保单保费季度末前起保.sql

+-- ZB_DM_XXZBDBFJDMQQB ZB_DM_新续转保单保费季度末前起保
+-- key:xxzquarterbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、新续转保得保单
+-- 2、起保时间的季度小于等于当前季度
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+        'xxzquarterbf/'
+        ,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 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')
+           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(
+        'provxxzquarterbf/'
+        ,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 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')
+           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(
+            'cityxxzquarterbf/'
+        ,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 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')
+           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(
+            'countryxxzquarterbf/'
+        ,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 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')
+           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(
+            'teamxxzquarterbf/'
+        ,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 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')
+           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`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/新续转/ZB_DM_新续转保单保费年底前起保.sql

+-- ZB_DM_XXZBDBFNDQQB ZB_DM_新续转保单保费年底前起保
+-- key:xxzyearbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、新续转保得保单
+-- 3、起保时间小于等于今年
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'xxzyearbf/'
+        ,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 s1.`xxzflag` = '1'
+  and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provxxzyearbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'cityxxzyearbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'countryxxzyearbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'teamxxzyearbf/'
+        ,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 s1.`xxzflag` = '1'
+  and left(s1.`startTime`,4) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyy')
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL4COMCODE`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/新续转/ZB_DM_新续转保单保费当日签单当日起保.sql

+-- ZB_DM_XXZBDBFDRQDDRQB ZB_DM_新续转保单保费当日签单当日起保
+-- key:xxzdaybf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、新续转保得保单
+-- 3、起保时间等于今天
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'xxzdaybf/'
+        ,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 s1.`xxzflag` = '1'
+  and left(s1.`startTime`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provxxzdaybf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'cityxxzdaybf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'countryxxzdaybf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'teamxxzdaybf/'
+        ,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 s1.`xxzflag` = '1'
+  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_XXZBDBFYDQQBYDQQB ZB_DM_新续转保单保费月底前起保
+-- key:xxzmonthbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、新续转保得保单
+-- 3、起保时间小于等于当月
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'xxzmonthbf/'
+        ,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 s1.`xxzflag` = '1'
+  and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provxxzmonthbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'cityxxzmonthbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'countryxxzmonthbf/'
+        ,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 s1.`xxzflag` = '1'
+  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(
+            'teamxxzmonthbf/'
+        ,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 s1.`xxzflag` = '1'
+  and left(s1.`startTime`,6) <= DATE_FORMAT(LOCALTIMESTAMP,'yyyyMM')
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL4COMCODE`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/车险/ZB_DM_承保车险(合并).sql

+-- ZB_DM_CAR_HB  ZB_DM_承保车险合并
+
+
+
+-- ZB_DM_QDBF_CAR/ZB_DM_车险今日签单保费
+-- key:allcarqbbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、车险
+
+--  总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+        'allcarqdbf/'
+        ,s1.`uwConclueDate`
+    )                                       as `key`
+    ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+        'provcarqdbf/'
+        ,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.risk,2) ='05'
+group by
+     s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`
+;
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'citycarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL2COMCODE`
+;
+
+
+-- 县支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'countycarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL3COMCODE`
+;
+
+
+-- 团队
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'teamcarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL4COMCODE`
+;
+
+
+-- ZB_DM_CXCBDD ZB_DM_车险承保大单
+-- bigcbd/日期
+-- 核保或者核批时间在今天，按照保费或者未决赔款排序，取前10，车险riskcode 05开头，其他为非车，
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigcbd/'
+        ,s1.`uwConclueDate`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  ,`cost`     ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                      as `uwConclueDate`
+                      ,d1.`LEVEL1COMCODE`                     as `com`
+                      ,d1.`LEVEL1COMDESC`                     as `comname`
+                      ,d1.`risk`                              as `risk`
+                      ,d1.`riskname`                          as `riskname`
+                      ,d1.`chnl`                              as `chnl`
+                      ,d1.`chnlname`                          as `chnlname`
+                      ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                 where d1.`COMNAME` is not null
+                   and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                   and left(d1.risk,2) ='05'
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+;
+
+
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigccitybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'city'     ,':'  ,`city`     ,','
+                    ,'cityname' ,':'  ,`cityname` ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  , `cost`    ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL1COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) ='05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
+
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigccountrybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'         ,':'  ,`com`         ,','
+                    ,'comname'     ,':'  ,`comname`     ,','
+                    ,'city'        ,':'  ,`city`        ,','
+                    ,'cityname'    ,':'  ,`cityname`    ,','
+                    ,'country'     ,':'  ,`country`     ,','
+                    ,'countryname' ,':'  ,`countryname` ,','
+                    ,'risk'        ,':'  ,`risk`        ,','
+                    ,'riskname'    ,':'  ,`riskname`    ,','
+                    ,'chnl'        ,':'  ,`chnl`        ,','
+                    ,'chnlname'    ,':'  ,`chnlname`    ,','
+                    ,'cost'        ,':'  ,cast(`cost` as varchar) ,','
+                    ,'no'          ,':'  ,`no`
+                    ),';')
+    )                         as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL2COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`LEVEL3COMCODE`                     as `country`
+                       ,d1.`LEVEL3COMDESC`                     as `countryname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) ='05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
\ No newline at end of file

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

+-- ZB_DM_QDBF_CAR/ZB_DM_车险今日签单保费
+-- key:allcarqbbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、车险
+
+--  总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'allcarqdbf/'
+        ,s1.`uwConclueDate`
+        )                                       as `key`
+     ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provcarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL1COMCODE`
+;
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'citycarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL2COMCODE`
+;
+
+
+-- 县支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'countycarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL3COMCODE`
+;
+
+
+-- 团队
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'teamcarqdbf/'
+        ,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.risk,2) ='05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL4COMCODE`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/非车险/ZB_DM_承保非车险(合并).sql

+-- ZB_DM_NOCAR_HB  ZB_DM_承保非车险合并
+
+
+
+-- ZB_DM_QDBF_NOCAR/ZB_DM_非车险今日签单保费
+-- key:allnocarqbbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、非车险
+
+--  总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'allnocarqdbf/'
+        ,s1.`uwConclueDate`
+        )                                       as `key`
+     ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provnocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL1COMCODE`
+;
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'citynocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL2COMCODE`
+;
+
+
+-- 县支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'countynocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+    ,s1.`LEVEL3COMCODE`
+;
+
+
+-- 团队
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'teamnocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+   ,s1.`LEVEL4COMCODE`
+;
+
+
+-- ZB_DM_FCXCBDD ZB_DM_非车险承保大单
+-- bigfcbd/日期
+-- 核保或者核批时间在今天，按照保费或者未决赔款排序，取前10，车险riskcode 05开头，其他为非车，
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfcbd/'
+        ,s1.`uwConclueDate`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                     'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  ,`cost`     ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                      as `uwConclueDate`
+                      ,d1.`LEVEL1COMCODE`                     as `com`
+                      ,d1.`LEVEL1COMDESC`                     as `comname`
+                      ,d1.`risk`                              as `risk`
+                      ,d1.`riskname`                          as `riskname`
+                      ,d1.`chnl`                              as `chnl`
+                      ,d1.`chnlname`                          as `chnlname`
+                      ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                 where d1.`COMNAME` is not null
+                   and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                   and left(d1.risk,2) <>'05'
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+;
+
+
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfccitybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'city'     ,':'  ,`city`     ,','
+                    ,'cityname' ,':'  ,`cityname` ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  ,`cost`     ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL1COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) <>'05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
+
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfccountrybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'         ,':'  ,`com`         ,','
+                    ,'comname'     ,':'  ,`comname`     ,','
+                    ,'city'        ,':'  ,`city`        ,','
+                    ,'cityname'    ,':'  ,`cityname`    ,','
+                    ,'country'     ,':'  ,`country`     ,','
+                    ,'countryname' ,':'  ,`countryname` ,','
+                    ,'risk'        ,':'  ,`risk`        ,','
+                    ,'riskname'    ,':'  ,`riskname`    ,','
+                    ,'chnl'        ,':'  ,`chnl`        ,','
+                    ,'chnlname'    ,':'  ,`chnlname`    ,','
+                    ,'cost'        ,':'  ,`cost`        ,','
+                    ,'no'          ,':'  ,`no`
+                    ),';')
+    )                         as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL2COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`LEVEL3COMCODE`                     as `country`
+                       ,d1.`LEVEL3COMDESC`                     as `countryname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) <>'05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+   ,s1.`group_com`
+;
\ No newline at end of file

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

+-- ZB_DM_QDBF_NOCAR/ZB_DM_非车险今日签单保费
+-- key:allnocarqbbf/日期
+-- 1、日期:核保日期或者核批完成日期(yyyyMMdd)
+-- 2、非车险
+
+--  总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_DECIMAL
+select
+    CONCAT(
+            'allnocarqdbf/'
+        ,s1.`uwConclueDate`
+        )                                       as `key`
+     ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+;
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'provnocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL1COMCODE`
+;
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'citynocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL2COMCODE`
+;
+
+
+-- 县支
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'countynocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL3COMCODE`
+;
+
+
+-- 团队
+insert into ZB_DM.ZB_DM_REDIS.HSET_DECIMAL
+select
+    CONCAT(
+            'teamnocarqdbf/'
+        ,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.risk,2) <> '05'
+group by
+    s1.`uwConclueDate`
+        ,s1.`LEVEL4COMCODE`
+;
\ No newline at end of file

ZB_DM/承保指标/方案四（函数自增）/非车险/ZB_DM_非车险承保大单.sql

+-- ZB_DM_FCXCBDD ZB_DM_非车险承保大单
+-- bigfcbd/日期
+-- 核保或者核批时间在今天，按照保费或者未决赔款排序，取前10，车险riskcode 05开头，其他为非车，
+
+-- 总公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfcbd/'
+        ,s1.`uwConclueDate`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  ,`cost`     ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from(
+                 select
+                     d1.`uwConclueDate`                      as `uwConclueDate`
+                      ,d1.`LEVEL1COMCODE`                     as `com`
+                      ,d1.`LEVEL1COMDESC`                     as `comname`
+                      ,d1.`risk`                              as `risk`
+                      ,d1.`riskname`                          as `riskname`
+                      ,d1.`chnl`                              as `chnl`
+                      ,d1.`chnlname`                          as `chnlname`
+                      ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                 where d1.`COMNAME` is not null
+                   and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                   and left(d1.risk,2) <>'05'
+             ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+;
+
+
+
+-- 分公司
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfccitybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'      ,':'  ,`com`      ,','
+                    ,'comname'  ,':'  ,`comname`  ,','
+                    ,'city'     ,':'  ,`city`     ,','
+                    ,'cityname' ,':'  ,`cityname` ,','
+                    ,'risk'     ,':'  ,`risk`     ,','
+                    ,'riskname' ,':'  ,`riskname` ,','
+                    ,'chnl'     ,':'  ,`chnl`     ,','
+                    ,'chnlname' ,':'  ,`chnlname` ,','
+                    ,'cost'     ,':'  ,`cost`     ,','
+                    ,'no'       ,':'  ,`no`
+                    ),';')
+    )                      as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL1COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) <>'05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
+
+
+-- 中支
+insert into ZB_DM.ZB_DM_REDIS.SET_VARCHAR
+select
+    CONCAT(
+            'bigfccountrybd/'
+        ,s1.`uwConclueDate`
+        ,'/',s1.`group_com`
+        )                      as `key`
+     ,CastToJsonArrayUDF(
+        listagg(concat(
+                        'com'         ,':'  ,`com`         ,','
+                    ,'comname'     ,':'  ,`comname`     ,','
+                    ,'city'        ,':'  ,`city`        ,','
+                    ,'cityname'    ,':'  ,`cityname`    ,','
+                    ,'country'     ,':'  ,`country`     ,','
+                    ,'countryname' ,':'  ,`countryname` ,','
+                    ,'risk'        ,':'  ,`risk`        ,','
+                    ,'riskname'    ,':'  ,`riskname`    ,','
+                    ,'chnl'        ,':'  ,`chnl`        ,','
+                    ,'chnlname'    ,':'  ,`chnlname`    ,','
+                    ,'cost'        ,':'  ,`cost`        ,','
+                    ,'no'          ,':'  ,`no`
+                    ),';')
+    )                         as `val`
+from (
+         select
+             *
+         from (
+                  select
+                      d1.`uwConclueDate`                     as `uwConclueDate`
+                       ,d1.`LEVEL2COMCODE`                     as `group_com`
+                       ,d1.`LEVEL1COMCODE`                     as `com`
+                       ,d1.`LEVEL1COMDESC`                     as `comname`
+                       ,d1.`LEVEL2COMCODE`                     as `city`
+                       ,d1.`LEVEL2COMDESC`                     as `cityname`
+                       ,d1.`LEVEL3COMCODE`                     as `country`
+                       ,d1.`LEVEL3COMDESC`                     as `countryname`
+                       ,d1.`risk`                              as `risk`
+                       ,d1.`riskname`                          as `riskname`
+                       ,d1.`chnl`                              as `chnl`
+                       ,d1.`chnlname`                          as `chnlname`
+                       ,cast(d1.`cost` as varchar)             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.CBDATA d1
+                  where d1.`COMNAME` is not null
+                    and d1.`uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+                    and left(d1.risk,2) <>'05'
+              ) c1
+         where c1.rownum <= 20
+     ) s1
+group by
+    s1.`uwConclueDate`
+       ,s1.`group_com`
+;
\ No newline at end of file