Add flag to desk review workbook for assessable permit in past 3 years

pipeline/07-export.R

@@ -16,7 +16,7 @@ suppressPackageStartupMessages({
 })
 
 # Establish Athena connection
-AWS_ATHENA_CONN_NOCTUA <- dbConnect(noctua::athena())
+AWS_ATHENA_CONN_NOCTUA <- dbConnect(noctua::athena(), rstudio_conn_tab = FALSE)
 
 
 
@@ -68,6 +68,15 @@ land <- dbGetQuery(
   ")
 )
 
+# Pull assessable permit flag
+flag_assessable_permits <- dbGetQuery(
+  conn = AWS_ATHENA_CONN_NOCTUA, glue("
+  SELECT pin, has_recent_assessable_permit
+  FROM default.vw_pin_status
+  WHERE year = '{params$assessment$data_year}'
+  ")
+)
+
 
 
 
@@ -105,6 +114,12 @@ assessment_pin_prepped <- assessment_pin %>%
     valuations_note = NA,
     sale_ratio = NA
   ) %>%
+  # Add assessable permit flag
+  left_join(flag_assessable_permits, by = c("meta_pin" = "pin")) %>%
+  mutate(
+    flag_has_recent_assessable_permit = as.numeric(has_recent_assessable_permit)
+  ) %>%
+  # Select fields for output to workbook
   select(
     township_code, meta_pin, meta_class, meta_nbhd_code,
     property_full_address, loc_tax_municipality_name, meta_pin10,
@@ -128,7 +143,8 @@ assessment_pin_prepped <- assessment_pin %>%
     flag_proration_sum_not_1,
     flag_pin_is_multiland, flag_land_gte_95_percentile,
     flag_land_value_capped, flag_prior_near_to_pred_unchanged,
-    flag_prior_near_yoy_inc_gt_50_pct, flag_prior_near_yoy_dec_gt_5_pct
+    flag_prior_near_yoy_inc_gt_50_pct, flag_prior_near_yoy_dec_gt_5_pct,
+    flag_has_recent_assessable_permit
   ) %>%
   mutate(
     across(starts_with("flag_"), as.numeric),
@@ -309,7 +325,7 @@ for (town in unique(assessment_pin_prepped$township_code)) {
     wb, pin_sheet_name,
     style = style_price,
     rows = pin_row_range,
-    cols = c(9:11, 15:18, 23, 28, 33, 41, 52, 53), gridExpand = TRUE
+    cols = c(9:11, 15:18, 23, 28, 33, 41, 53, 54), gridExpand = TRUE
   )
   addStyle(
     wb, pin_sheet_name,
@@ -434,18 +450,18 @@ for (town in unique(assessment_pin_prepped$township_code)) {
   writeFormula(
     wb, pin_sheet_name,
     assessment_pin_avs$total_av,
-    startCol = 52,
+    startCol = 53,
     startRow = 7
   )
   writeFormula(
     wb, pin_sheet_name,
     assessment_pin_avs$av_difference,
-    startCol = 53,
+    startCol = 54,
     startRow = 7
   )
   setColWidths(
     wb, pin_sheet_name,
-    c(52, 53),
+    c(53, 54),
     widths = 1,
     hidden = c(TRUE, TRUE), ignoreMergedCells = FALSE
   )