指标计算承保字段调整

ZB_DM/承保指标/new今日签单/ZB_DM_今日签单(合并).sql → ZB_DM/承保指标/new今日签单/ZB_DM_今日签单合并_NEW.sql

--- ZB_DM_JRQDBF_HB ZB_DM_今日签单合并
+-- ZB_DM_JRQDBF_HB_NEW ZB_DM_今日签单合并_NEW
 
 -- step1：
 -- 团队汇总
@@ -11,31 +11,9 @@ SELECT
      , s1.`LEVEL4COMCODE`                     as `LEVEL4COMCODE`
      , s1.`startTime`                         as `startTime`
      , s1.`risk`                              as `risk`
-     , sum(cast(s1.`cost` as DECIMAL(18, 2))) + t1.`cost` as `cost`
+     , sum(cast(s1.`cost` as DECIMAL(18, 2)))  as `cost`
 from ZB_ODS.ZB_ODS_KAFKA.CBDATA s1
-left join (
-    select
-         `uwConclueDate`       as `uwConclueDate`
-        ,`LEVEL1COMCODE`       as `LEVEL1COMCODE`
-        ,`LEVEL2COMCODE`       as `LEVEL2COMCODE`
-        ,`LEVEL3COMCODE`       as `LEVEL3COMCODE`
-        ,`LEVEL4COMCODE`       as `LEVEL4COMCODE`
-        ,`startTime`           as `startTime`
-        ,`risk`                as `risk`
-        ,left(t1.log_time,8)   as log_time
-        ,sum(cast(cost as decimal(18,2))) as `cost`
-    from ZB_DM.ZB_DM_MYSQL.TEAM
-    where `uwConclueDate` = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-    group by
-         `uwConclueDate`
-        ,`LEVEL1COMCODE`
-        ,`LEVEL2COMCODE`
-        ,`LEVEL3COMCODE`
-        ,`LEVEL4COMCODE`
-        ,`startTime`
-        ,`risk`
-        ,left(t1.log_time,8)
-) for system_time as of s1.proctime as t1
+left join ZB_DM.ZB_DM_MYSQL.TEAM_RISK for system_time as of s1.proctime as t1
               on  s1.`uwConclueDate`  = t1.`uwConclueDate`
               and s1.`LEVEL1COMCODE`  = t1.`LEVEL1COMCODE`
               and s1.`LEVEL2COMCODE`  = t1.`LEVEL2COMCODE`

ZB_DM/承保指标/new团队汇总结果/ZB_DM_团队汇总结果.sql → ZB_DM/承保指标/new团队汇总结果/ZB_DM_团队汇总结果_险种.sql

--- ZB_DM_TDHZJG ZB_DM_团队汇总结果
+-- ZB_DM_TDHZJG_RISK ZB_DM_团队汇总结果_险种
 
 
 
 -- step1：
 -- 团队汇总
-INSERT INTO ZB_DM.ZB_DM_MYSQL.TEAM 
+INSERT INTO ZB_DM.ZB_DM_MYSQL.TEAM_RISK
 SELECT
        s1.`uwConclueDate`                                                               as `uwConclueDate`
      , s1.`LEVEL1COMCODE`                                                               as `LEVEL1COMCODE`
@@ -16,7 +16,7 @@ SELECT
      , s1.`chnl`                                                                        as `chnl`
      , s1.`businessNatureCode`                                                          as `businessNatureCode`
      , cast (sum(cast(s1.`cost` as DECIMAL(18, 2))) as varchar )                        as `cost`
-     , DATE_FORMAT(tumble_end(s1.row_time, interval '1' hour ) ,'yyyy-MM-dd HH:mm:ss')   as `log_time`
+     , DATE_FORMAT(top_end(s1.row_time, interval '1' hour ) ,'yyyy-MM-dd HH:mm:ss')   as `log_time`
 from (
          select
              *
@@ -37,7 +37,7 @@ group by
     , s1.`risk`
     , s1.`chnl`
     , s1.`businessNatureCode`
-    , tumble(s1.row_time, interval '1' hour)
+    , top(s1.row_time, interval '1' hour)
 
 ;