Handling of nodata with wind_2min_timestamp

uace-azmet · Jul 29, 2023 · cd866fa · cd866fa
1 parent db866c4
commit cd866fa
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 5 deletions.
diff --git a/R/az_daily.R b/R/az_daily.R
@@ -86,13 +86,26 @@ az_daily <- function(station_id = NULL, start_date = NULL, end_date = NULL) {
     )) %>%
     dplyr::filter(.data$meta_station_id != "az99") %>%
     dplyr::mutate(datetime = lubridate::ymd(.data$datetime)) %>%
-    dplyr::mutate(wind_2min_timestamp = lubridate::with_tz(lubridate::parse_date_time(.data$wind_2min_timestamp, orders = "ymdHMSz"), tzone = "America/Phoenix")) %>%
     #convert NAs
     dplyr::mutate(
       dplyr::across(
-        tidyselect::where(is.numeric),
+        c(tidyselect::where(is.numeric)),
         function(x)
-          dplyr::if_else(x %in% c(-999, -9999, -99999, -7999, 999, 999.9, 9999), NA_real_, x))
+          dplyr::if_else(x %in% c(-999, -9999, -99999, -7999, 999, 999.9, 9999), NA_real_, x)
+      )
+    ) %>%
+    dplyr::mutate(
+      dplyr::across(
+        wind_2min_timestamp,
+        function(x)
+          dplyr::if_else(x == as.character(-99999), NA_character_, x)
+      )
+    ) %>%
+    dplyr::mutate(
+      wind_2min_timestamp = lubridate::with_tz(
+        lubridate::parse_date_time(.data$wind_2min_timestamp, orders = "ymdHMSz"),
+        tzone = "America/Phoenix"
+        )
     )
   return(out)
 }
diff --git a/R/az_hourly.R b/R/az_hourly.R
@@ -91,14 +91,33 @@ az_hourly <- function(station_id = NULL, start_date_time = NULL, end_date_time =
       as.numeric
     )) %>%
     dplyr::filter(.data$meta_station_id != "az99") %>%
-    dplyr::mutate(date_datetime = lubridate::force_tz(lubridate::ymd_hms(.data$date_datetime), tzone = "America/Phoenix")) %>%
-    dplyr::mutate(wind_2min_timestamp = lubridate::with_tz(lubridate::parse_date_time(.data$wind_2min_timestamp, orders = "ymdHMSz"), tzone = "America/Phoenix")) %>%
+    dplyr::mutate(
+      date_datetime =
+        lubridate::force_tz(
+          lubridate::ymd_hms(.data$date_datetime),
+          tzone = "America/Phoenix"
+        )
+    ) %>%
     #convert NAs
     dplyr::mutate(
       dplyr::across(
         tidyselect::where(is.numeric),
         function(x)
           dplyr::if_else(x %in% c(-999, -9999, -99999, -7999, 999, 999.9, 9999), NA_real_, x))
+    ) %>%
+    dplyr::mutate(
+      dplyr::across(
+        wind_2min_timestamp,
+        function(x)
+          dplyr::if_else(x == as.character(-99999), NA_character_, x)
+      )
+    ) %>%
+    dplyr::mutate(
+      wind_2min_timestamp =
+        lubridate::with_tz(
+          lubridate::parse_date_time(.data$wind_2min_timestamp, orders = "ymdHMSz"),
+          tzone = "America/Phoenix"
+        )
     )
   return(out)
 }