指标计算承保字段调整

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

@@ -4,14 +4,14 @@
 -- 团队汇总
 CREATE TEMPORARY VIEW VIEW_ZB_DM_JRQDBF_HB_TUANDUI AS
 select
-    a1.`uwConclueDate`                            as `uwConclueDate`
-    ,a1.`LEVEL1COMCODE`                           as `LEVEL1COMCODE`
-    ,a1.`LEVEL2COMCODE`                           as `LEVEL2COMCODE`
-    ,a1.`LEVEL3COMCODE`                           as `LEVEL3COMCODE`
-    ,a1.`LEVEL4COMCODE`                           as `LEVEL4COMCODE`
-    ,a1.`startTime`                               as `startTime`
-    ,a1.`risk`                                    as `risk`
-    ,a1.`cost` + if(t1.cost is null ,0,cast(t1.cost as decimal(18,2)))  as `cost`
+     a1.`uwConclueDate`                                                as `uwConclueDate`
+    ,a1.`LEVEL1COMCODE`                                                as `LEVEL1COMCODE`
+    ,a1.`LEVEL2COMCODE`                                                as `LEVEL2COMCODE`
+    ,a1.`LEVEL3COMCODE`                                                as `LEVEL3COMCODE`
+    ,a1.`LEVEL4COMCODE`                                                as `LEVEL4COMCODE`
+    ,a1.`startTime`                                                    as `startTime`
+    ,a1.`risk`                                                         as `risk`
+    ,a1.`cost` + if(t1.cost is null ,0,cast(t1.cost as decimal(18,2))) as `cost`
 from (
     SELECT
            s1.`uwConclueDate`                     as `uwConclueDate`
@@ -45,7 +45,7 @@ left join ZB_DM.ZB_DM_MYSQL.TEAM_RISK for system_time as of a1.proctime as t1
               and a1.`LEVEL4COMCODE`  = t1.`LEVEL4COMCODE`
               and a1.`startTime`      = t1.`startTime`
               and a1.`risk`           = t1.`risk`
-              and LongTimeToStringUDF(t1.log_time,'yyyyMMdd HH') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd HH')
+              and LongTimeToStringUDF(t1.log_time,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
 
 ;
 

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

@@ -5,35 +5,52 @@
 -- step1：
 -- 团队汇总
 INSERT INTO ZB_DM.ZB_DM_MYSQL.TEAM_RISK
-SELECT
-       s1.`uwConclueDate`                                                               as `uwConclueDate`
-     , s1.`LEVEL1COMCODE`                                                               as `LEVEL1COMCODE`
-     , s1.`LEVEL2COMCODE`                                                               as `LEVEL2COMCODE`
-     , s1.`LEVEL3COMCODE`                                                               as `LEVEL3COMCODE`
-     , s1.`LEVEL4COMCODE`                                                               as `LEVEL4COMCODE`
-     , s1.`startTime`                                                                   as `startTime`
-     , s1.`risk`                                                                        as `risk`
-     , cast (sum(cast(s1.`cost` as DECIMAL(18, 2))) as varchar )                        as `cost`
-     , cast (DateTimeToLongUDF(hop_end(s1.row_time, interval '1' hour , interval '24' hour) ) as varchar ) as `log_time`
+select
+    a1.`uwConclueDate`                                                    as `uwConclueDate`
+    , a1.`LEVEL1COMCODE`                                                  as `LEVEL1COMCODE`
+    , a1.`LEVEL2COMCODE`                                                  as `LEVEL2COMCODE`
+    , a1.`LEVEL3COMCODE`                                                  as `LEVEL3COMCODE`
+    , a1.`LEVEL4COMCODE`                                                  as `LEVEL4COMCODE`
+    , a1.`startTime`                                                      as `startTime`
+    , a1.`risk`                                                           as `risk`
+    , a1.`cost`+ if(t1.cost is null ,0,cast(t1.cost as decimal(18,2)))    as `cost`
+    , a1.`log_time`                                                       as `log_time`
+
 from (
-         select
-             *
---               ,ROW_NUMBER() OVER(PARTITION BY `no`,`COMCODE`,`cost` ORDER BY `uwConclueDate` DESC) as rownum
-         from ZB_ODS.ZB_ODS_KAFKA.CBDATA
-         where
-             `COMNAME` is not null
-           and LEFT(`uwConclueDate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
-     ) s1
--- where s1.rownum = 1
-group by
-    s1.`uwConclueDate`
-    , s1.`LEVEL1COMCODE`
-    , s1.`LEVEL2COMCODE`
-    , s1.`LEVEL3COMCODE`
-    , s1.`LEVEL4COMCODE`
-    , s1.`startTime`
-    , s1.`risk`
-    , hop(s1.row_time, interval '1' hour, interval '24' hour)
+    SELECT
+           s1.`uwConclueDate`                                                               as `uwConclueDate`
+         , s1.`LEVEL1COMCODE`                                                               as `LEVEL1COMCODE`
+         , s1.`LEVEL2COMCODE`                                                               as `LEVEL2COMCODE`
+         , s1.`LEVEL3COMCODE`                                                               as `LEVEL3COMCODE`
+         , s1.`LEVEL4COMCODE`                                                               as `LEVEL4COMCODE`
+         , s1.`startTime`                                                                   as `startTime`
+         , s1.`risk`                                                                        as `risk`
+         , cast (sum(cast(s1.`cost` as DECIMAL(18, 2))) as varchar )                        as `cost`
+         , cast (DateTimeToLongUDF(tumble_end(s1.row_time, interval '1' hour) ) as varchar) as `log_time`
+         , max(s1.proctime)                                                                 as proctime
+    from ZB_ODS.ZB_ODS_KAFKA.CBDATA
+    where
+          `COMNAME` is not null
+        and LEFT(`uwConclueDate`,8) = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
+    group by
+        s1.`uwConclueDate`
+        , s1.`LEVEL1COMCODE`
+        , s1.`LEVEL2COMCODE`
+        , s1.`LEVEL3COMCODE`
+        , s1.`LEVEL4COMCODE`
+        , s1.`startTime`
+        , s1.`risk`
+        , tumble(s1.row_time, interval '1' hour)
+)a1
+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`
+              and s1.`LEVEL3COMCODE`  = t1.`LEVEL3COMCODE`
+              and s1.`LEVEL4COMCODE`  = t1.`LEVEL4COMCODE`
+              and s1.`startTime`      = t1.`startTime`
+              and s1.`risk`           = t1.`risk`
+              and LongTimeToStringUDF(t1.log_time,'yyyyMMdd') = DATE_FORMAT(LOCALTIMESTAMP,'yyyyMMdd')
 
 ;