annotate extract_ipm_date_interval.R @ 0:4dccc60b3525 draft

Uploaded
author greg
date Tue, 31 Jul 2018 14:36:56 -0400
parents
children 3126def1a8e9
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
4dccc60b3525 Uploaded
greg
parents:
diff changeset
1 #!/usr/bin/env Rscript
4dccc60b3525 Uploaded
greg
parents:
diff changeset
2
4dccc60b3525 Uploaded
greg
parents:
diff changeset
3 suppressPackageStartupMessages(library("data.table"))
4dccc60b3525 Uploaded
greg
parents:
diff changeset
4 suppressPackageStartupMessages(library("optparse"))
4dccc60b3525 Uploaded
greg
parents:
diff changeset
5
4dccc60b3525 Uploaded
greg
parents:
diff changeset
6 option_list <- list(
4dccc60b3525 Uploaded
greg
parents:
diff changeset
7 make_option(c("--input_dir"), action="store", dest="input_dir", help="Directory containing .csv outputs from insect_phenology_model"),
4dccc60b3525 Uploaded
greg
parents:
diff changeset
8 make_option(c("--start_date"), action="store", dest="start_date", default=NULL, help="Start date for custom date interval"),
4dccc60b3525 Uploaded
greg
parents:
diff changeset
9 make_option(c("--script_dir"), action="store", dest="script_dir", help="R script source directory")
4dccc60b3525 Uploaded
greg
parents:
diff changeset
10 )
4dccc60b3525 Uploaded
greg
parents:
diff changeset
11
4dccc60b3525 Uploaded
greg
parents:
diff changeset
12 parser <- OptionParser(usage="%prog [options] file", option_list=option_list);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
13 args <- parse_args(parser, positional_arguments=TRUE);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
14 opt <- args$options;
4dccc60b3525 Uploaded
greg
parents:
diff changeset
15
4dccc60b3525 Uploaded
greg
parents:
diff changeset
16 get_new_temperature_data_frame = function(input_file) {
4dccc60b3525 Uploaded
greg
parents:
diff changeset
17 temperature_data_frame = read.csv(file=input_file, header=T, strip.white=TRUE, stringsAsFactors=FALSE, sep=",");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
18 colnames(temperature_data_frame) = c("LATITUDE", "LONGITUDE", "DATE", "DOY", "TMIN", "TMAX");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
19 return(temperature_data_frame);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
20 }
4dccc60b3525 Uploaded
greg
parents:
diff changeset
21
4dccc60b3525 Uploaded
greg
parents:
diff changeset
22 # Import the shared utility functions.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
23 utils_path <- paste(opt$script_dir, "utils.R", sep="/");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
24 source(utils_path);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
25
4dccc60b3525 Uploaded
greg
parents:
diff changeset
26 # FIXME: currently custom date fields are free text, but
4dccc60b3525 Uploaded
greg
parents:
diff changeset
27 # Galaxy should soon include support for a date selector
4dccc60b3525 Uploaded
greg
parents:
diff changeset
28 # at which point this tool should be enhanced to use it.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
29 # Validate start_date.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
30
4dccc60b3525 Uploaded
greg
parents:
diff changeset
31 # Calaculate the number of days in the date interval.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
32 start_date = validate_date(opt$start_date);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
33 # Validate end_date.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
34 end_date = validate_date(opt$end_date);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
35 if (start_date >= end_date) {
4dccc60b3525 Uploaded
greg
parents:
diff changeset
36 stop_err("The start date must be between 1 and 50 days before the end date when setting date intervals for plots.");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
37 }
4dccc60b3525 Uploaded
greg
parents:
diff changeset
38 # Calculate the number of days in the date interval.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
39 num_days = difftime(end_date, start_date, units=c("days"));
4dccc60b3525 Uploaded
greg
parents:
diff changeset
40 # Add 1 to the number of days to make the dates inclusive. For
4dccc60b3525 Uploaded
greg
parents:
diff changeset
41 # example, if the user enters a date range of 2018-01-01 to
4dccc60b3525 Uploaded
greg
parents:
diff changeset
42 # 2018-01-31, they likely expect the end date to be included.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
43 num_days = num_days + 1;
4dccc60b3525 Uploaded
greg
parents:
diff changeset
44 if (num_days > 50) {
4dccc60b3525 Uploaded
greg
parents:
diff changeset
45 # We need to restrict date intervals since
4dccc60b3525 Uploaded
greg
parents:
diff changeset
46 # plots render tick marks for each day.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
47 stop_err("Date intervals for plotting cannot exceed 50 days.");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
48 }
4dccc60b3525 Uploaded
greg
parents:
diff changeset
49 # Display the total number of days in the Galaxy history item blurb.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
50 cat("Number of days in date interval: ", num_days, "\n");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
51
4dccc60b3525 Uploaded
greg
parents:
diff changeset
52 # Get the year from the start_date.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
53 year = get_year_from_date(start_date);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
54 # Get the DOY for start_date and end_date.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
55 start_date_doy = as.integer(strftime(start_date, format="%j"));
4dccc60b3525 Uploaded
greg
parents:
diff changeset
56 end_date_doy = as.integer(strftime(end_date, format="%j"));
4dccc60b3525 Uploaded
greg
parents:
diff changeset
57 # Get the ticks date labels for plots.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
58 ticks_and_labels = get_x_axis_ticks_and_labels(temperature_data_frame, prepend_end_doy_norm, append_start_doy_norm, date_interval=TRUE);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
59 ticks = c(unlist(ticks_and_labels[1]));
4dccc60b3525 Uploaded
greg
parents:
diff changeset
60 date_labels = c(unlist(ticks_and_labels[2]));
4dccc60b3525 Uploaded
greg
parents:
diff changeset
61 # All latitude values are the same, so get the value
4dccc60b3525 Uploaded
greg
parents:
diff changeset
62 # for plots from the first row.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
63 latitude = temperature_data_frame$LATITUDE[1];
4dccc60b3525 Uploaded
greg
parents:
diff changeset
64
4dccc60b3525 Uploaded
greg
parents:
diff changeset
65 input_files = list.files(path=input_dir, full.names=TRUE);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
66 for(input_file in input_files) {
4dccc60b3525 Uploaded
greg
parents:
diff changeset
67 temperature_data_frame = get_new_temperature_data_frame(input_file);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
68 start_date_row = which(temperature_data_frame$DATE==start_date);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
69 end_date_row = which(temperature_data_frame$DATE==end_date);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
70 # Extract the date interval.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
71 temperature_data_frame = temperature_data_frame[start_date_row:end_date_row,];
4dccc60b3525 Uploaded
greg
parents:
diff changeset
72 # Save the date interval data into an output file
4dccc60b3525 Uploaded
greg
parents:
diff changeset
73 # named the same as the input.
4dccc60b3525 Uploaded
greg
parents:
diff changeset
74 file_path = paste("output_data_dir", input_file, sep="/");
4dccc60b3525 Uploaded
greg
parents:
diff changeset
75 write.csv(temperature_data_frame, file=file_path, row.names=F);
4dccc60b3525 Uploaded
greg
parents:
diff changeset
76 # TODO: Save the dat interval plots...
4dccc60b3525 Uploaded
greg
parents:
diff changeset
77 }