#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <math.h>
#include <postgresql/libpq-fe.h>
#include <unistd.h>

#define NSENSORS 5

#define OUTDOOR 2
#define HOME 3
#define GARDEN 1

const char *conn = "host='db.fe.up.pt' user='sinfe32' password='UgeVMoBA'";
static PGconn *dbconn;

long GATE=0,IRRSYS=0,FLOOR=0,LUZ_HOME=0,TEMP_HOME=0;

float temperatureSensors[NSENSORS];
float humiditySensors[NSENSORS];
float lightSensors[NSENSORS];
float irlightSensors[NSENSORS];

double voltage(int pos1, int pos2)
{
	double v;
	v = pos1*16*16+pos2;
	v = (v/4096)*1.5;
	return v;
}

double vlight(int pos1, int pos2)
{
	double v;
	v = pos1*16*16+pos2;
	v = (0.625*pow(10,6)*(v/4096)*1.5)/100;
	return v;
}

double infra(int pos1, int pos2)
{
	double i;
	i = pos1*16*16+pos2;
	i = (0.769*pow(10,5)*(i/4096)*1.5)/100;
	return i;
}

double temperature(int pos1, int pos2)
{
	double t;
	t = pos1*16*16+pos2;
	t = -39.6+0.01*t;
	return t;
}

double relhumi(int pos1, int pos2)
{
	double r;
	r = pos1*16*16+pos2;
	r = -2.0468+.0367*r-1.5955*pow(10,-6)*r*r;
	return r;
}

double comphumi(int pos1, int pos2, int temptfunc, int relahumifunc)
{
	double h;
	h = pos1*16*16+pos2;
	h = (temptfunc-25)*(0.01+0.00008*h)+relahumifunc;
	return h;
}

void sql_init(){

	dbconn = PQconnectdb(conn);

	if (PQstatus(dbconn) == CONNECTION_BAD){
		printf("Unable to connect\n");
		exit(-1);
	}
	else{
		printf("Able to connect!\n");
	}
}

void print_db(){
	char q[500];
	PGresult *query;
	sprintf(q,"SELECT nome,medicao FROM has.sensores");
	query = PQexec(dbconn,q);
	printf("------- SENSORES -------\n");
	for(int i = 0; i < PQntuples(query);i++){
		printf("%10s: %s \n", PQgetvalue(query,i,0),PQgetvalue(query,i,1));
	}
	printf("\n");
	sprintf(q,"SELECT nome,estado FROM has.atuadores");
	query = PQexec(dbconn,q);
	printf("------- ATUADORES -------\n");
	for(int i = 0; i < PQntuples(query);i++){
		printf("%10s: %s \n", PQgetvalue(query,i,0),PQgetvalue(query,i,1));
	}
	printf("\n");
}

void update_state(int id){
	char q[500];
	int value;
	sprintf(q,"SELECT sensor,sinal,valor,atuador,estado FROM has.regras WHERE divisoes_id = %d", id);
	PGresult *query = PQexec(dbconn,q);
	for(int i = 0; i < PQntuples(query);i++){
		sprintf(q,"SELECT estado FROM has.atuadores WHERE nome=\'%s\'", PQgetvalue(query,i,3));
		value = atoi(PQgetvalue(PQexec(dbconn,q),0,0));
		sprintf(q,"UPDATE has.atuadores SET estado = CASE  WHEN (SELECT medicao FROM has.sensores WHERE nome=\'%s\') %s %s THEN %s ELSE %d END WHERE nome = \'%s\'", PQgetvalue(query,i,0),PQgetvalue(query,i,1),PQgetvalue(query,i,2),PQgetvalue(query,i,4),value,PQgetvalue(query,i,3));
		//printf("%s\n",q);
		PQexec(dbconn,q);
	}


}

void sql_update(int id){
	char q[500];

	sprintf(q,"UPDATE has.sensores SET medicao= %5f, timestamp = now() WHERE mote_id=%d AND nome=\'temp1\' OR nome=\'temp3\'",temperatureSensors[id],id);
	PQexec(dbconn,q);
	sprintf(q,"UPDATE has.sensores SET medicao= %5f, timestamp = now() WHERE mote_id=%d AND nome=\'luz\'",lightSensors[id],id);
	PQexec(dbconn,q);
	sprintf(q,"UPDATE has.sensores SET medicao= %5f, timestamp = now() WHERE mote_id=%d AND nome=\'hum\'",humiditySensors[id],id);
	PQexec(dbconn,q);
	sprintf(q,"UPDATE has.sensores SET medicao= %5f, timestamp = now() WHERE mote_id=%d AND nome=\'irr\'",irlightSensors[id],id);
	PQexec(dbconn,q);

}

void print_rules(){
	char q[500];
	printf("------- REGRAS -------\n");
	sprintf(q,"SELECT sensor,sinal,valor,atuador,estado FROM has.regras");
	PGresult *query = PQexec(dbconn,q);
	for(int i = 0; i < PQntuples(query);i++){
		sprintf(q,"%s %s %s : %s = %s ", PQgetvalue(query,i,0),PQgetvalue(query,i,1),PQgetvalue(query,i,2),PQgetvalue(query,i,3),PQgetvalue(query,i,4));
		printf("%s\n",q);
	}
	printf("\n");
}

int main(){

	int str[23] = {0};
	char *token;
	char message[255];
	double volt;
	unsigned long id;

	sql_init();
	print_rules();

	while(1){

		int i = 0;

		fgets(message, 255, stdin);
		//printf("%s\n", message);
		token = strtok(message, " ");

		while(token != NULL)
		{
			str[i] = strtol(token,NULL,16);
			//printf("%d ",str[i]);
			token = strtok(NULL, " ");
			i++;
		}

		id = str[5]<<8 | str[6];

		temperatureSensors[id] = temperature(str[16],str[17]);
		humiditySensors[id] = relhumi(str[18],str[19]);

		lightSensors[id] = vlight(str[12],str[13]);
		irlightSensors[id] = infra(str[14],str[15]);

		//printf("\n Temperatura: %fºC\n Humidade rel: %f%% \n Voltage: %fV\n Visible light: %flux \n Infrared light: %flux \n\n", temperatureSensors[id], humiditySensors[id], volt, lightSensors[id],irlightSensors[id]);

		sql_update(id);
		update_state(id);
		print_db();

	}

	return 0;

}