#define BLYNK_TEMPLATE_ID "TMPLwToQUqRw"
#define BLYNK_TEMPLATE_NAME "Air Quality Monitoring"
#define BLYNK_AUTH_TOKEN "C8Y7T0Fr54QF8pdfQ5dZsdfhhSdiQBFLj8mYe"

#define BLYNK_PRINT Serial
#include <WiFi.h> 
#include <BlynkSimpleEsp32.h>

#include <DHT.h>
 
#include <LiquidCrystal_I2C.h>
#include<ThingSpeak.h>

LiquidCrystal_I2C lcd(0x27, 16, 2);


  byte degree_symbol[8] = 
              {
                0b00111,
                0b00101,
                0b00111,
                0b00000,
                0b00000,
                0b00000,
                0b00000,
                0b00000
              };
              
char auth[] = BLYNK_AUTH_TOKEN;

char ssid[] = "Redmi Note 10S";  // type your wifi name
char pass[] = "ABCDEFGH";  // type your wifi password
const unsigned long channelId = 2320618;
const char *apiKey = "Z6S83YE9TGT1O329";

WiFiClient client;


BlynkTimer timer;

int gas = 32;
int sensorThreshold = 100;

#define DHTPIN 2 //Connect Out pin to D2 in NODE MCU
#define DHTTYPE DHT11  
DHT dht(DHTPIN, DHTTYPE);


void sendSensor()
{

  float h = dht.readHumidity();
  float t = dht.readTemperature(); // or dht.readTemperature(true) for Fahrenheit
 

     if (isnan(h) || isnan(t)) {
    Serial.println("Failed to read from DHT sensor!");
    return;
  }
   int analogSensor = analogRead(gas);
  Blynk.virtualWrite(V2, analogSensor);
  Serial.print("Gas Value: ");
    Serial.println(analogSensor);
  // You can send any value at any time.
  // Please don't send more that 10 values per second.
    Blynk.virtualWrite(V0, t);
    Blynk.virtualWrite(V1, h);
   
    Serial.print("Temperature : ");
    Serial.print(t);
    Serial.print("    Humidity : ");
    Serial.println(h);
    
 
}
void setup()
{   
   WiFi.begin(ssid, pass);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Connecting to WiFi...");
  }
  Serial.println("Connected to WiFi");

  // Initialize ThingSpeak with the Wi-Fi client
  ThingSpeak.begin(client);
  Serial.begin(115200);
  
 //pinMode(gas, INPUT);
  Blynk.begin(auth, ssid, pass);
  dht.begin();
  timer.setInterval(30000L, sendSensor);

 //Wire.begin();
   lcd.begin(16,2);


//  lcd.backlight();
 // lcd.clear();
  lcd.setCursor(3,0);
  lcd.print("Air Quality");
  lcd.setCursor(3,1);
  lcd.print("Monitoring");
  delay(2000);
  lcd.clear();
  int response = ThingSpeak.writeFields(channelId,apiKey);
  if (response == 200) {
    Serial.println("Data sent to ThingSpeak successfully!");
  } else {
    Serial.println("Error sending data to ThingSpeak. HTTP error code " + String(response));
  }

  }

void loop()
{
  Blynk.run();
  timer.run();
 float h = dht.readHumidity();
  float t = dht.readTemperature(); // or dht.readTemperature(true) for Fahrenheit
    int gasValue = analogRead(gas);
  lcd.setCursor(0,0);
  lcd.print("Temperature "); 
  lcd.setCursor(0,1);
  lcd.print(t);
  lcd.setCursor(6,1);
  lcd.write(1);
  lcd.createChar(1, degree_symbol);
  lcd.setCursor(7,1);
  lcd.print("C");
  delay(4000);
  lcd.clear();
  lcd.setCursor(0, 0);
  lcd.print("Humidity ");
  lcd.print(h);
  lcd.print("%");
  delay(4000);
  lcd.clear();
  //lcd.setCursor(0,0);
 // lcd.print(gasValue);
 // lcd.clear();
  Serial.println("Gas Value");
 Serial.println(gasValue);
  if(gasValue<1200)
  {
    lcd.setCursor(0,0);
    lcd.print("Gas Value: ");
    lcd.print(gasValue);
    lcd.setCursor(0, 1);
    lcd.print("Fresh Air");
    Serial.println("Fresh Air");
    delay(4000);
    lcd.clear();
  }
  else if(gasValue>1200)
  {
    lcd.setCursor(0,0);
    lcd.print(gasValue);
    lcd.setCursor(0, 1);
    lcd.print("Bad Air");
    Serial.println("Bad Air");
    delay(4000);
    lcd.clear();
  }

   if(gasValue > 1200){
    //Blynk.email("[email protected]", "Alert", "Bad Air!");
    Blynk.logEvent("pollution_alert","Bad Air");
    
  }
  ThingSpeak.setField(1, t); // Field 1 is for temperature
    ThingSpeak.setField(2, h);    // Field 2 is for humidity

  // Write data to ThingSpeak

  
  // Wait for a few seconds before sending the next set of data
  delay(15000);
 }