R/data_server.R

In james-ferguson/servicedenergymanagement: What the Package Does (One Line, Title Case)

#' @export
data_server <- function(id){

  moduleServer(
    id,
    function(input, output, session) {

      session$userData$selected_meter <- reactiveVal()

      #  Session Global ####
      meters <-  reactive({
        ms <- meter_statistics(req(session$userData$oid()), req(session$userData$utility()))
        isolate(session$userData$selected_meter(NULL))
        ms
      })

      session$userData$owner_utility_meter_days <- reactive({
        meter_days_for_owner_utility(req(session$userData$oid()), req(session$userData$utility()))
      })

      session$userData$owner_consolidation <- reactive({
        req(session$userData$owner_utility_meter_days() %>%
        consolidate_owner_utility_meter_days() %>%
          mutate(dow = factor(weekdays(ts), levels = c("Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday", "Sunday"))))

        #read_owner_utility_consolidation(req(session$userData$oid()), req(session$userData$utility()))  # Can be much faster
      })

      session$userData$selected_meter_history <- reactive({
        meter <- session$userData$selected_meter()
        if(!is.null(meter)){
          shinyjs::show(id= "smd_panel", asis = TRUE)
          req(session$userData$owner_utility_meter_days()) %>%
            filter(mid ==meter$mid) %>%
            mutate(
              dow = factor(weekdays(ts), levels = c("Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday", "Sunday")),
              waste = kw - expected
              )
        } else{
          shinyjs::hide(id= "smd_panel", asis = TRUE)
          NULL
        }
      })

      observe({
        session$userData$owner_consolidation()
      }, priority = 11)

      observe({
        session$userData$selected_meter_history()
      }, priority = 10)

      meters

    }
  )
}


work_list <- function(universe){

  filt <- function(universe, type, case, aka, status_colour, help){

    meters = dplyr::filter(universe, update_status == type)

    n = nrow(meters)

    pc = round(100 * n / nrow(universe), 1)

    icon_name = icon_name_for_state(type)

    tibble::tibble_row (type = type, case = case, meters = list(meters), aka = aka , n = n, percent = pc , status_colour = status_colour, icon_name=icon_name, help = help)
  }

  my_keys <- bind_rows(

    # Service
    #1 Other / Mystery
    filt(universe, "ND", case = 'service',"No Readings",  "danger",  "No AMR data received."),
    filt(universe, "NP", case = 'service',"No Energy",    "danger",  "No Consumption"),

    # User Maintain
    filt(universe, "NL", case = 'user',   "Lost", "danger",  "Location allows us to provide weather services."),
    filt(universe, "NC", case = 'service',"Non Comm.",     "warning",  "Meter recently silent"),
    filt(universe, "PF", case = 'user',   "Possibly Flat", "primary", 'Suspicious Zeroes received recently, can be an AMR faiure'), #7

    #  User Imporve
    filt(universe, "W", case =  'user',    "Overspend", 'danger',  'Excess energy consumption'), # 8
    filt(universe, "NT", case = 'user',    "No Trend", "primary",'Neutral trend - with enhancements possible'), # 9

    #  Self-correct
    filt(universe, "NW", case = 'kWIQly', "No Weather",  "warning",   "Weather source failure."), # 6
    filt(universe, "ID", case = 'user',   "Learning",    "primary",  'System is learning with insufficient data so far.'), #5
    filt(universe, "S", case =  'user',    "Underspend", 'success', 'Reduced energy consumption'), #10

  )

  others <- universe[!universe$update_status %in% my_keys$type,]

  bind_rows(
    tibble::tibble_row (type = "O", case = 'kWIQly',
                        meters =list(others),
                        aka = "Unclassified",
                        n = nrow(others), percent = round(100 * n / nrow(universe), 1), status_colour = 'danger',iconName = icon_name_for_state("O"), help = "Meters not automatically recognised"),
    my_keys
  )
}