transform.h

Go to the documentation of this file.

#ifndef PROGRAM_TRANSFORM_H
#define PROGRAM_TRANSFORM_H
 
#include <libpq-fe.h>
#include <stdio.h>
#include <stdlib.h>
#include <log.h>
 
#include "BOM/stations.h"
#include "FoodAuthority/harvest_area.h"
#include "WillyWeather/location.h"
#include "utils.h"
 
#define T_MAX_N_LOCATIONS           50
 
#define T_TIMESTAMP_SIZE            50
 
#define T_OUTLOOK_BUF_SIZE          200
 
#define T_EST_CLOSURE_BUF_SIZE      20
 
#define T_DATA_TYPE_SIZE            30
 
#define T_DATA_QUERY_LENGTH         15
#define T_DATA_WINDOW_SIZE          7
 
typedef struct {
    char last_updated[T_TIMESTAMP_SIZE]; 
    char fa_program_name[FA_MAX_BUFFER]; 
    char fa_program_id[FA_MAX_BUFFER]; 
    char ww_location[WW_LOCATION_BUF]; 
    char ww_location_id[WW_LOCATION_BUF]; 
    float ww_latitude; 
    float ww_longitude; 
    char bom_location[BOM_STATION_NAME_SIZE]; 
    char bom_location_id[BOM_STATION_ID_SIZE]; 
    float bom_latitude; 
    float bom_longitude; 
    float bom_distance; 
}T_LocationLookup_TypeDef;
 
typedef struct {
    uint16_t count; 
    T_LocationLookup_TypeDef locations[T_MAX_N_LOCATIONS]; 
}T_LocationsLookup_TypeDef;
 
typedef struct {
    char program_name[FA_MAX_BUFFER]; 
    int32_t ha_id; 
    char classification[FA_MAX_BUFFER]; 
    char status[FA_MAX_BUFFER]; 
    char time_processed[T_TIMESTAMP_SIZE]; 
    char status_reason[FA_MAX_BUFFER]; 
    bool closed; 
    bool to_close; 
    char closure_type[T_OUTLOOK_BUF_SIZE]; 
    char closure_reason[T_OUTLOOK_BUF_SIZE]; 
    char closure_date[T_TIMESTAMP_SIZE]; 
    float closure_severity_index; 
    char est_closure_time[T_EST_CLOSURE_BUF_SIZE]; 
}T_Outlook_Typedef;
 
typedef struct{
    char time_processed[T_TIMESTAMP_SIZE];
    char data_type[T_DATA_TYPE_SIZE];
    double precipitaiton;
} T_OutlookData_TypeDef;
 
typedef struct{
    int32_t count;
    T_OutlookData_TypeDef data[T_DATA_QUERY_LENGTH];
} T_OutlookDataset_TypeDef;
 
void T_BuildWeatherDB(T_LocationsLookup_TypeDef* locations,
                      PGconn* psql_conn);
 
void T_FloodPrediction(PGconn* psql_conn);
 
void T_WindowDataset(PGconn* psql_conn, int program_id);
 
void T_NormaliseWindowedPrecipitation(PGconn* psql_conn, int program_id);
 
#endif //PROGRAM_TRANSFORM_H