add fangan_day report codes

7d452b9e · yindanlei · f9f54c57 · 7d452b9e
Commit 7d452b9e authored Aug 10, 2020 by yindanlei
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 2 deletions

fangan_day.sql pm/fangan_day/etl/fangan_day.sql +4 -2

No files found.
--- a/pm/fangan_day/etl/fangan_day.sql
+++ b/pm/fangan_day/etl/fangan_day.sql
@@ -182,7 +182,8 @@ LEFT JOIN
                WHERE partition_day=regexp_replace(date_sub(current_date(),1),'-','')
                AND REGEXP_REPLACE(SUBSTR(call_time,0,10), '-', '')>='20200701'
                AND REGEXP_REPLACE(SUBSTR(call_time,0,10), '-', '')<=regexp_replace(date_sub(current_date(),1),'-','')
-                AND start_time+ interval 30 second <= release_time --通话时长大于30秒
+                --AND start_time+ interval 30 second <= release_time --通话时长大于30秒
+                AND unix_timestamp(substr(start_time,1,19))+30<=unix_timestamp(substr(release_time,1,19))
            )a
            LEFT JOIN
            (
@@ -298,7 +299,8 @@ LEFT JOIN
                WHERE partition_day=regexp_replace(date_sub(current_date(),1),'-','')
                AND REGEXP_REPLACE(SUBSTR(call_time,0,10), '-', '')>='20200701'
                AND REGEXP_REPLACE(SUBSTR(call_time,0,10), '-', '')<=regexp_replace(date_sub(current_date(),1),'-','')
-                AND start_time+ interval 30 second <= release_time --通话时长大于30秒
+                --AND start_time+ interval 30 second <= release_time --通话时长大于30秒
+                AND unix_timestamp(substr(start_time,1,19))+30<=unix_timestamp(substr(release_time,1,19))
            )a
            LEFT JOIN
            (