i4a
/
IAQ2000DHT11

#include <SPI.h>
#include <Ethernet.h>
#include <EthernetUdp.h>
#include <Wire.h>
#include "I2Cdev.h"
#include "IAQ2000.h"
#include <dht.h>


#define dht_apin 5

IAQ2000 iaq;

DHT dht(dht_apin, DHT11);


uint16_t airQuality;
int val = 0;
float Temperatur;
float Humidity;

// Netzwerk-Einstellungen
// MAC-Adresse darf nur einmal im Netz vohanden sein
// Fuer jedes Geraet aendern!!
byte mac[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0x1A };

// Port fur Daten-Empfang
unsigned int localPort = 5010;

// IP Adresse Loxone-MiniServer
IPAddress RecipientIP;

// Port Loxone-MiniServer... An diesen Port werden die Daten gesendet
unsigned int RecipientPort = 5010;

// Buffer fuer Daten-Empfang
char packetBuffer[UDP_TX_PACKET_MAX_SIZE];

// Start der UDP-Instanz
EthernetUDP Udp;


// Initialize the Ethernet server library
// with the IP address and port you want to use
// (port 80 is default for HTTP):
EthernetServer server(80);


void setup() {
  Wire.begin();
  Serial.begin(9600);
  //serset w5100
  Ethernet.begin(mac);
  if (!Ethernet.localIP()) {
    Serial.println("dhcp failed");
    Serial.println(Ethernet.linkStatus());
  }
  else {
    Serial.print("IP is ");
    Serial.println(Ethernet.localIP());
  }
  Udp.begin(localPort); // Start UDP
  SPI.begin();
  sendUDP("Raumluft - aktiv"); // send UDP Ready


  // start the Ethernet connection and the server:
  server.begin();
  Serial.print("server is at ");
  Serial.println(Ethernet.localIP());

  // initialize device
  Serial.println("Initialisierung des Sensor...");
  iaq.initialize();

  // verify connection
  Serial.println("Verbindung zum Sensor testen...");
  Serial.println(iaq.testConnection() ? "iAQ-2000 erfolgreich verbunden" : "iAQ-2000 Fehler bei der Verbindung");


  dht.begin(); //DHT11 Sensor starten

  //Serial leeren
  clearAll();

  Serial.println("Warte auf UDP-Befehl");

}

void loop() {
  String aq = String (airQuality);
  String temp = String (Temperatur, 2);
  String hum = String (Humidity, 2);

  dht.read(); //read data from pin 5 (DHT11)

  airQuality = iaq.getIaqpred();
  Temperatur = dht.readTemperature();
  Humidity = dht.readHumidity();


  // schaut on ein UDP Befehl empfangen wurde
  checkUDP();

  if (!strcmp(packetBuffer, "000"))
  {
    Serial.print("CO2 = ");
    Serial.print(airQuality);
    Serial.print(" ");
    Serial.println("[ppm]");


    // Wert wird auf 3000ppm begrnezt
    if (airQuality > 3000)
    {
      aq = "3000";
    }
    else
    {
      aq = airQuality;
    }
    sendUDP(aq);
  }

  if (!strcmp(packetBuffer, "001"))
  {
    sendUDP (temp);
  }


  if (!strcmp(packetBuffer, "002"))
  {
    sendUDP (hum);
  }
  clearAll();
  // listen for incoming clients
  EthernetClient client = server.available();
  if (client)
  {
    Serial.println("new client");
    // an http request ends with a blank line
    boolean currentLineIsBlank = true;
    while (client.connected()) {
      if (client.available()) {
        char c = client.read();
        //Serial.write(c);
        // if you've gotten to the end of the line (received a newline
        // character) and the line is blank, the http request has ended,
        // so you can send a reply
        if (c == '\n' && currentLineIsBlank) {
          // send a standard http response header
          client.println("HTTP/1.1 200 OK");
          client.println("Content-Type: text/html");
          client.println("Connection: close");
          client.println();
          client.println("<!DOCTYPE HTML>");
          client.println("<html>");
          // add a meta refresh tag, so the browser pulls again every 5 seconds:
          client.println("<meta http-equiv=\"refresh\" content=\"10\">");
          // output the value of each analog input pin

          client.println("Current Humidity = "); //Prints information within qoutation
          client.println(hum); //Prints the Humidity read from the DHT11 on PIN 5
          client.println("% ");
          client.println("Temperature = ");
          client.println(temp); //Prints the temperature read from the DHT11 on PIN 5
          client.println("C ");
          client.println("CO2 = ");
          client.println(aq);
          client.println(" ");
          client.println("[ppm]");
          client.println("</html>");
          break;
        }
        if (c == '\n') {
          // you're starting a new line
          currentLineIsBlank = true;
        }
        else if (c != '\r') {
          // you've gotten a character on the current line
          currentLineIsBlank = false;
        }
      }
    }
    // give the web browser time to receive the data
    delay(1);
    // close the connection:
    client.stop();
    Serial.println("client disonnected");

  }
}

//// Module ////
// Serial-Speicher loeschen
void clearAll() {
  // Paket-Buffer leeren
  for (int i = 0; i < UDP_TX_PACKET_MAX_SIZE; i++) packetBuffer[i] = (char)0;
}

// empfangene UDP-Befehle auswerten
void checkUDP()
{
  // pruefen ob Daten vorhanden sind
  int packetSize = Udp.parsePacket();
  if (packetSize)
  {
    Udp.read(packetBuffer, packetSize);
    Serial.print("Packet Content: ");
    Serial.println(packetBuffer);
    RecipientIP=Udp.remoteIP();
    Serial.print("Remote IP: ");
    Serial.println(RecipientIP);
  }
  delay(10);
}

// UDP-Befehl senden
void sendUDP(String text)
{
  Udp.beginPacket(RecipientIP, RecipientPort);
  Udp.print(text);
  Udp.endPacket();
  delay(10);
}