112 lines
4.3 KiB
R
112 lines
4.3 KiB
R
# ============================================================================
|
|
# BATCH PIPELINE RUNNER: Scripts 40, 80, 90 for Multiple Dates
|
|
# ============================================================================
|
|
# Purpose: Run weekly reporting pipeline for multiple dates (Dec 3, 2025 - Feb 4, 2026)
|
|
# Project: aura
|
|
# Usage: source("r_app/batch_pipeline_aura.R")
|
|
# ============================================================================
|
|
|
|
suppressPackageStartupMessages({
|
|
library(lubridate)
|
|
library(rmarkdown)
|
|
})
|
|
|
|
# Configuration
|
|
PROJECT <- "aura"
|
|
START_DATE <- as.Date("2025-12-03")
|
|
END_DATE <- as.Date("2026-02-04")
|
|
OFFSET <- 7
|
|
|
|
# Generate date sequence (every 7 days)
|
|
date_sequence <- seq(START_DATE, END_DATE, by = "7 days")
|
|
|
|
cat("\n========================================================\n")
|
|
cat("BATCH PIPELINE RUNNER for AURA Project\n")
|
|
cat("========================================================\n")
|
|
cat(sprintf("Project: %s\n", PROJECT))
|
|
cat(sprintf("Date range: %s to %s\n", format(START_DATE), format(END_DATE)))
|
|
cat(sprintf("Interval: Every %d days\n", OFFSET))
|
|
cat(sprintf("Total dates to process: %d\n", length(date_sequence)))
|
|
cat(sprintf("Dates: %s\n", paste(format(date_sequence), collapse = ", ")))
|
|
cat("========================================================\n\n")
|
|
|
|
# Process each date
|
|
for (i in seq_along(date_sequence)) {
|
|
current_date <- date_sequence[i]
|
|
date_str <- format(current_date, "%Y-%m-%d")
|
|
|
|
cat("\n")
|
|
cat(strrep("=", 70), "\n")
|
|
cat(sprintf("PROCESSING DATE: %s (%d of %d)\n", date_str, i, length(date_sequence)))
|
|
cat(strrep("=", 70), "\n\n")
|
|
|
|
# ==== SCRIPT 40: Create Weekly Mosaic ====
|
|
cat(sprintf("[%s] Running Script 40: Weekly Mosaic Creation\n", Sys.time()))
|
|
tryCatch({
|
|
r_path <- "C:\\Program Files\\R\\R-4.4.3\\bin\\x64\\Rscript.exe"
|
|
script_40 <- "r_app/40_mosaic_creation_per_field.R"
|
|
cmd_40 <- c(script_40, date_str, as.character(OFFSET), PROJECT)
|
|
|
|
result_40 <- system2(r_path, args = cmd_40)
|
|
|
|
if (result_40 == 0) {
|
|
cat(sprintf("[%s] ✓ Script 40 completed successfully\n\n", Sys.time()))
|
|
} else {
|
|
cat(sprintf("[%s] ✗ Script 40 failed with exit code %d (continuing anyway)\n\n", Sys.time(), result_40))
|
|
}
|
|
}, error = function(e) {
|
|
cat(sprintf("[ERROR] Script 40 error: %s (continuing anyway)\n\n", e$message))
|
|
})
|
|
|
|
# ==== SCRIPT 80: Calculate KPIs ====
|
|
cat(sprintf("[%s] Running Script 80: Calculate KPIs\n", Sys.time()))
|
|
tryCatch({
|
|
r_path <- "C:\\Program Files\\R\\R-4.4.3\\bin\\x64\\Rscript.exe"
|
|
script_80 <- "r_app/80_calculate_kpis.R"
|
|
# Note: R80 argument order is [END_DATE] [PROJECT] [OFFSET]
|
|
cmd_80 <- c(script_80, date_str, PROJECT, as.character(OFFSET))
|
|
|
|
result_80 <- system2(r_path, args = cmd_80)
|
|
|
|
if (result_80 == 0) {
|
|
cat(sprintf("[%s] ✓ Script 80 completed successfully\n\n", Sys.time()))
|
|
} else {
|
|
cat(sprintf("[%s] ✗ Script 80 failed with exit code %d (continuing anyway)\n\n", Sys.time(), result_80))
|
|
}
|
|
}, error = function(e) {
|
|
cat(sprintf("[ERROR] Script 80 error: %s (continuing anyway)\n\n", e$message))
|
|
})
|
|
|
|
# ==== SCRIPT 90: Generate Report ====
|
|
cat(sprintf("[%s] Running Script 90: Generate Agronomic Support Report\n", Sys.time()))
|
|
tryCatch({
|
|
output_filename <- sprintf("SmartCane_Report_agronomic_support_%s_%s.docx", PROJECT, date_str)
|
|
|
|
render(
|
|
"r_app/90_CI_report_with_kpis_agronomic_support.Rmd",
|
|
params = list(data_dir = PROJECT, report_date = as.Date(date_str)),
|
|
output_file = output_filename,
|
|
output_dir = file.path("laravel_app/storage/app", PROJECT, "reports"),
|
|
quiet = FALSE
|
|
)
|
|
|
|
cat(sprintf("[%s] ✓ Script 90 completed successfully\n", Sys.time()))
|
|
cat(sprintf(" Output: laravel_app/storage/app/%s/reports/%s\n\n", PROJECT, output_filename))
|
|
}, error = function(e) {
|
|
cat(sprintf("[%s] ✗ Script 90 failed: %s (continuing anyway)\n\n", Sys.time(), e$message))
|
|
})
|
|
}
|
|
|
|
# Summary
|
|
cat("\n")
|
|
cat(strrep("=", 70), "\n")
|
|
cat("BATCH PROCESSING COMPLETE\n")
|
|
cat(strrep("=", 70), "\n")
|
|
cat(sprintf("Processed %d dates from %s to %s\n",
|
|
length(date_sequence),
|
|
format(START_DATE),
|
|
format(END_DATE)))
|
|
cat("Check output directory for generated reports\n")
|
|
cat(sprintf("Reports location: laravel_app/storage/app/%s/reports/\n", PROJECT))
|
|
cat(strrep("=", 70), "\n\n")
|