#include "DHT.h"
#include <ESP32Servo.h>
#include <ThingSpeak.h>
#include <WiFi.h>
#include <HTTPClient.h>

//wifi details
const char* WIFI_NAME = "Wokwi-GUEST";
const char* WIFI_PASS = "";
WiFiClient client;

//thingspeak details
const int myChannelNumber = 2544553;
const char* write_API_Key = "RJVPD5U00E5XJQHL";
const char* server = "api.thingspeak.com";
HTTPClient http;

// variables globales
float humd;
float temp;
int potValue;
float lux_a;

// Déclaration des constantes pour les seuils de luminosité
const int DARK = 200;
const int LIGHT = 500;
const int BRIGHT = 800;
const int VERY_BRIGHT = 1000;

// Déclaration des broches pour les composants
#define PIN_RED    12
#define PIN_GREEN  14
#define PIN_BLUE   27
#define digital_In 34
#define analog_In 35
#define POT_PIN 25
#define SERVO_PIN 32
#define DHT_PIN 13

//Seuil CO2 (Scenario 1)
const int CO2_UNDER_7500 = 45;
const int CO2_UNDER_10000 = 90;
const int CO2_UNDER_15000 = 135;

//Seuil humidité
const int HUMD_UNDER_50 = 45;
const int HUMD_UNDER_60 = 90;
const int HUMD_UNDER_70 = 135;

//Seuil temperature (Scenario 2)
const int SEUIL_TEMP = 23;

// Déclaration des objets
DHT dht(DHT_PIN, DHT22);
Servo servo;

// Déclaration du tableau de broches LED
const int ledCount = 10;
int ledPins[] = {23, 22, 21, 19, 18, 5, 17, 16, 4, 2};

// L'angle d'ouvertures courante du servo 
int CURRENT_ANGLE = 0;

void updateLampControlFields(int value, String fieldNum){

  // Construct the URL for updating the ThingSpeak field
  String url = "http://" + String(server) + "/update?api_key=" + write_API_Key + "&" + fieldNum + "=" + String(value);

  // Send HTTP GET request to update the field
  http.begin(client, url);
  int httpResponseCode = http.GET();
  
  if (httpResponseCode == 200) {
    Serial.println("Lamp control field updated successfully");
  } else {
    Serial.print("Error updating lamp control field. HTTP response code: ");
    Serial.println(httpResponseCode);
  }

  http.end();
}

void climatiseur(){

  temp = dht.readTemperature();

  if(isnan(temp)){
    Serial.println(F("Failed to read Temperature"));
  }else{

    Serial.print("Current temperature is ");
    Serial.print(temp);
    Serial.print(" °C, ");

    if(temp > SEUIL_TEMP){
      Serial.println("bigger then threshold (23 °C) => Cooling");
      analogWrite(PIN_RED,   0);
      analogWrite(PIN_GREEN, 0);
      analogWrite(PIN_BLUE,  255);
    }else{
      Serial.println("smaller then threshold (23 °C) => Heating");
      analogWrite(PIN_RED,   255);
      analogWrite(PIN_GREEN, 0);
      analogWrite(PIN_BLUE,  0);
    }

  }
}

void luminosite() {
  int analogValue = analogRead(analog_In);
  float voltage = analogValue / 4096.0 * 5.0;
  float resistance = 2000.0 * voltage / (1.0 - voltage / 5.0);
  lux_a = pow(50.0 * 1000.0 * pow(10.0, 0.7) / resistance, 1.0 / 0.7);
  Serial.print("Analog: Lux ");
  Serial.println(lux_a);

  // Allumer les LED en fonction de la luminosité
  if (lux_a <= DARK) {
    Serial.println("Dark");
    for (int i = 0; i < 4; i++) {
      digitalWrite(ledPins[0], HIGH);
      digitalWrite(ledPins[1], LOW);
      digitalWrite(ledPins[2], LOW);
      digitalWrite(ledPins[3], LOW);
    }
  } else if (lux_a <= LIGHT) {
    Serial.println("Light");
    for (int i = 0; i < 4; i++) {
      digitalWrite(ledPins[0], HIGH);
      digitalWrite(ledPins[1], HIGH);
      digitalWrite(ledPins[2], LOW);
      digitalWrite(ledPins[3], LOW);
    }
  } else if (lux_a <= BRIGHT) {
    Serial.println("Bright");
    for (int i = 0; i < 4; i++) {
      digitalWrite(ledPins[0], HIGH);
      digitalWrite(ledPins[1], HIGH);
      digitalWrite(ledPins[2], HIGH);
      digitalWrite(ledPins[3], LOW);
    }
  } else {
    Serial.println("Very Bright");
    for (int i = 0; i < 4; i++) {
      digitalWrite(ledPins[0], HIGH);
      digitalWrite(ledPins[1], HIGH);
      digitalWrite(ledPins[2], HIGH);
      digitalWrite(ledPins[3], HIGH);
    }
  }

}

int angleFromPot(){

  //lire valeur du potentiometre
  potValue = analogRead(POT_PIN);
  Serial.println(potValue);
  potValue = map(potValue, 0, 4095, 0, 17000);//concentration du CO2 (0ppm - 3000ppm)
  
  //choisir l'angle d'ouverture de la fenetre
  int angle = 0;
  if(potValue <400){
    angle = 0;
    Serial.println("CO2 concentration below 400ppm, close window");
  }else if(potValue < 7500){
    angle = CO2_UNDER_7500;
    Serial.print("CO2 concentration below 7500ppm, open window by ");
    Serial.println(CO2_UNDER_7500);
  }else if(potValue < 10000){
    angle = CO2_UNDER_10000;
    Serial.print("CO2 concentration below 10000ppm, open window by ");
    Serial.println(CO2_UNDER_10000);
  }else if(potValue < 15000){
    angle = CO2_UNDER_15000;
    Serial.print("CO2 concentration below 15000ppm, open window by ");
    Serial.println(CO2_UNDER_15000);
  }else{
    Serial.println("CO2 concentration over 15000ppm, open window fully");
    angle = 180;
  }

  return angle;

}

int angleFromDht(){

  humd = dht.readHumidity();

  //choisir l'angle d'ouverture de la fenetre
  int angle = 0;
  if(humd < 40){
    angle = 0;
    Serial.println("Humidity below 40%, close window");
  }else if(humd < 50){
    angle = HUMD_UNDER_50;
    Serial.print("Humidity below 50%, open window by ");
    Serial.println(HUMD_UNDER_50);
  }else if(humd < 60){
    angle = HUMD_UNDER_60;
    Serial.print("Humidity below 60%, open window by ");
    Serial.println(HUMD_UNDER_60);
  }else if(humd < 70){
    angle = HUMD_UNDER_70;
    Serial.print("Humidity below 70%, open window by ");
    Serial.println(HUMD_UNDER_70);
  }else{
    Serial.println("Humidity over 70%, open window fully");
    angle = 180;
  }

  return angle;
}

void fenetre(){

  //angle d'ouverture selon concentration CO2
  int firstAngle = angleFromPot();

  //angle d'ouverture selon l'humidite
  int secAngle = angleFromDht();
  int angle = max(firstAngle, secAngle);

  //changer l'angle d'ouverture du servo
  int difference = CURRENT_ANGLE - angle;
  if(difference < 0){
    ouvrirServo(abs(difference));
  }else{
    fermerServo(difference);
  }
  CURRENT_ANGLE = angle;
  
}

void ouvrirServo(int angle) {
  for (int i = 0; i <= angle; i++) {
    servo.write(CURRENT_ANGLE + i);
    delay(15);
  }
}

void fermerServo(int angle) {
  for (int i = 0; i <= angle; i++) {
    servo.write(CURRENT_ANGLE - i);
    delay(15);
  }
}

void setup() {
  Serial.begin(115200);

  // WiFi and ThingSpeak setup
  WiFi.begin(WIFI_NAME, WIFI_PASS);
  while (WiFi.status() != WL_CONNECTED){
    delay(1000);
    Serial.println("Wifi not connected");
  }
  Serial.println("Wifi connected !");
  Serial.println("Local IP: " + String(WiFi.localIP()));
  WiFi.mode(WIFI_STA);
  ThingSpeak.begin(client);

  //Initialisation des composants
  dht.begin();
  servo.attach(SERVO_PIN);
  servo.write(0);

  //Configuration des entrées et sorties
  pinMode(POT_PIN, INPUT);
  pinMode(PIN_RED, OUTPUT);
  pinMode(PIN_GREEN, OUTPUT);
  pinMode(PIN_BLUE, OUTPUT);
  pinMode(digital_In, INPUT);
  pinMode(analog_In, INPUT);

  for (int thisLed = 0; thisLed < ledCount; thisLed++) {
    pinMode(ledPins[thisLed], OUTPUT);
  }
  delay(2000);

}

void loop() {
  Serial.println(analogRead(POT_PIN));

  //2. Scénario : Température
  climatiseur();

  //3. Scénario : Luminosité 
  luminosite();

  //1. Scénario : CO2 élevé
  fenetre();

  Serial.println();
  
  sendDataToThingSpeak();

}

void sendDataToThingSpeak(){

  int dark = 0;
  int light = 0;
  int bright = 0;
  if (lux_a <= DARK) {
    dark = 1;
    light = 0;
    bright = 0;
  } else if (lux_a <= LIGHT) {
    dark = 0;
    light = 1;
    bright = 0;
  } else {
    dark = 0;
    light = 0;
    bright = 1;
  }

  ThingSpeak.setField(1,temp);
  delay(15000);
  ThingSpeak.setField(2,humd);
  delay(15000);
  ThingSpeak.setField(3, potValue);
  delay(15000);
  updateLampControlFields(dark, "field4");
  delay(15000);
  updateLampControlFields(light, "field5");
  delay(15000);
  updateLampControlFields(bright, "field6");
  delay(15000);
  
  int writeResult = ThingSpeak.writeFields(myChannelNumber,write_API_Key);
  
  if(writeResult == 200){
    Serial.println("Data pushed successfull");
  }else{
    Serial.println("Push error" + String(writeResult));
  }
  Serial.println("---");
}