utils.Calibration.R 11.22 KiB
#' Create InputsCrit for De Lavenne regularization
#'
#' Internal function that run [airGR::CreateInputsCrit_Lavenne] on-the-fly with a priori upstream
#' sub-catchment parameters grabbed during network calibration process.
#'
#' @param id [character] the id of the current sub-catchment
#' @param OutputsModel \[GRiwrmOutputsModel\] object with simulation results of upstream sub-catchments run with calibrated parameters
#' @param InputsCrit \[InputsCritLavenneFunction\] object internally created by [CreateInputsCrit.GRiwrmInputsModel]
#'
#' @return \[InputsCrit\] object with De Lavenne regularization
#' @import airGR
#' @noRd
getInputsCrit_Lavenne <- function(id, OutputsModel, InputsCrit) {
  if (!inherits(InputsCrit[[id]], "InputsCritLavenneFunction")) {
    stop("'InputsCrit[[id]]' must be of class InputsCritLavenneFunction")
  AprioriId <- attr(InputsCrit[[id]], "AprioriId")
  AprCelerity <- attr(InputsCrit[[id]], "AprCelerity")
  Lavenne_FUN <- attr(InputsCrit[[id]], "Lavenne_FUN")
  AprParamR <- OutputsModel[[AprioriId]]$RunOptions$Param
  if (!inherits(OutputsModel[[AprioriId]], "SD")) {
    # Add Celerity parameter if apriori is an upstream node
    AprParamR <- c(AprCelerity, AprParamR)
  featMod <- attr(InputsCrit[[id]], "model")
  if (featMod$hasX4) {
    AprParamR[featMod$iX4] <- AprParamR[featMod$iX4] * featMod$X4Ratio
  AprParamR <- AprParamR[featMod$indexParamUngauged]
  message("Parameter regularization: get a priori parameters from node ", AprioriId, ": ", paste(round(AprParamR, 3), collapse = ", "))
  AprCrit <- ErrorCrit(InputsCrit[[AprioriId]], OutputsModel[[AprioriId]])$CritValue
  return(Lavenne_FUN(AprParamR, AprCrit))
#' Reduce a GRiwrm list object (InputsModel, RunOptions...) for a reduced network
#' @param griwrm See [CreateGRiwrm])
#' @param obj Either a *GRiwrmInputsModel*, *GRiwrmOptions*... object
#' @return The object containing only nodes of the reduced model
#' @noRd
reduceGRiwrmObj4Ungauged <- function(griwrm, obj) {
  objAttributes <- attributes(obj)
  obj <- lapply(obj, function(o) {
    if (o$id %in% griwrm$id && any(!is.na(griwrm$model[griwrm$id == o$id]))) {
    } else {
      NULL
  obj[sapply(obj, is.null)] <- NULL
  objAttributes$names <- names(obj)
  attributes(obj) <- objAttributes
  return(obj)
#' Set a reduced GRiwrm network for calibration of a sub-network with ungauged
#' hydrological nodes
#' @inheritParams Calibration
#' @param GaugedId [character] Id of the gauged node
#' @param OutputsModel *GRiwrmOutputsModel* of the complete network
#' @return A [list] containing the following items:
#' - `InputsModel`: a *GRiwrmInputsModel* of the reduced network
#' - `RunOptions`: a *GRiwrmRunOptions* of the reduced network
#' @noRd
#' @importFrom dplyr "%>%"
7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
#' @importFrom rlang .data #' updateParameters4Ungauged <- function(GaugedId, InputsModel, RunOptions, CalibOptions, OutputsModel, useUpstreamQsim) { g <- getUngaugedCluster(attr(InputsModel, "GRiwrm"), GaugedId) ### Modify InputsModel for the reduced network ### # Remove nodes outside of reduced network InputsModel <- reduceGRiwrmObj4Ungauged(g, InputsModel) # Copy fixed parameters for Reservoirs or other models for (id in names(InputsModel)) { if (id != GaugedId && InputsModel[[id]]$gaugedId == id) { if (any(is.na(CalibOptions[[id]]$FixedParam))) { stop("Node '", id, "' located inside the ungauged node cluster '", GaugedId, "' must have its parameters fixed.\n", "Fix its parameters by assigning values to :", " `CalibOptions[['", id, "']]$FixedParam`") } InputsModel[[id]]$FixedParam <- CalibOptions[[id]]$FixedParam } } # Update griwrm attr(InputsModel, "GRiwrm") <- g # Update Qupstream already modeled in the reduced network upstream nodes upIds <- attr(g, "upIds") idIM <- unique(g$down[g$id %in% upIds]) for (id in idIM) { if (useUpstreamQsim && any(InputsModel[[id]]$UpstreamIsModeled)) { # Temporarily switch off upstream nodes belonging to the donor basin UpIsModeledBackUp <- InputsModel[[id]]$UpstreamIsModeled ImUpIds <- InputsModel[[id]]$UpstreamNodes InputsModel[[id]]$UpstreamIsModeled[!ImUpIds %in% upIds] <- FALSE # Update InputsModel$Qupstream with simulated upstream flows InputsModel[[id]] <- UpdateQsimUpstream(InputsModel[[id]], RunOptions[[id]], OutputsModel) # Restore initial UpstreamIsModeled and switch off already modeled nodes InputsModel[[id]]$UpstreamIsModeled <- UpIsModeledBackUp InputsModel[[id]]$UpstreamIsModeled[ImUpIds %in% upIds] <- FALSE } } # Add class RunModel_Ungauged and InputsModel for preprocessind # and processing airGR::Calibration class(InputsModel) <- c("Ungauged", "InputsModel", class(InputsModel)) ### Modify RunOptions for the reduced network ### RunOptions <- reduceGRiwrmObj4Ungauged(g, RunOptions) return(list(InputsModel = InputsModel, RunOptions = RunOptions)) } #' Compute the area of downstream sub-basins #' #' @param IM *GRiwrmInputsModel* object (See [CreateInputsModel.GRiwrm]) #' #' @return [numeric] named [vector] of the area of the downstream sub-basins #' @noRd calcSubBasinAreas <- function(IM) { unlist( sapply(IM, function(x) { if (is.list(x)) as.numeric(x$BasinAreas[length(x$BasinAreas)])}) ) }