zum erfassen der Daten von Sensoren.
#include <SPI.h>
#include <Ethernet.h>
#include <DS3231.h>
#include "DHT_U.h"
#include <Wire.h>
#include <OneWire.h>
#include <DS18B20.h>
#define LEDred A0 // PIN A0 - LEDred
#define LEDgreen A1 // PIN A1 - LEDgreen
#define LEDblue A2 // PIN A2 - LEDblue
#define soilPin A3 // PIN A3 - soilPin
#define SDAPin A4 // PIN A4 - SDA rtc
#define SCLPin A5 // PIN A5 - SCL rtc
// PIN 0 - RX
// PIN 1 - TX
#define trigger 2 // PIN 2 - trigger
#define echo 3 // PIN 3 - echo
// PIN 4 - CS SD-Card
#define relayLampe 5 // PIN 5 - relayLampe
#define relayWentylator 6 // PIN 6 - relayWentylator
#define relayPumpe 7 // PIN 7 - relayPumpe
#define DS18B20tempPIN 8 // PIN 8 - DS18B20tempPIN ( 3 x DS18B20 )
#define DHTPIN 9 // PIN 9 - DHTPIN
// PIN 10 - CS ETHERNET Shield
// PIN 11 - ETHERNET Shield
// PIN 12 - ETHERNET Shield
// PIN 13 - ETHERNET Shield
byte mac[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED };
IPAddress ip(192, 168, 178, 15);
IPAddress myDns(192, 168, 178, 1);
EthernetClient client;
char server[] = "plant.msmech.de";
long lastConnectionTime = 0; // last time you connected to the server, in milliseconds
long lastConnectionTime2 = 0; // last time you connected to the server, in milliseconds
long postingInterval = 10L * 1000L; // delay between updates, in milliseconds
long postingInterval2 = 10L * 1000L; // delay between updates, in milliseconds
// the "L" is needed to use long type numbers
#define HTTP_RESPONSE_TIMEOUT 2000
long startOfHttpResponseTime, startOfHttpResponseTime2;
DHT dht(DHTPIN, DHT22);
// Init the DS3231 using the hardware interface
DS3231 rtc(SDAPin, SCLPin);
Time t;
String RTCdaysOfTheWeek, akt_data;
int soilValue = 0;
int oswietlenie = 0, chlodzenie = 0, pompa = 0, x, y, z;
float humidity = 0, temperature = 0;
long odczyt = 0, dystans = 0;
int debug;
String pieces[7];
int counter = 0;
int lastIndex = 0;
String odebraneDane;
String humopt, tempopt;
int OPThumON, OPThumOFF, OPTtempON, OPTtempOFF, OPTpumpON, OPTpumpOFF;
int OPThumONold, OPThumOFFold, OPTtempONold, OPTtempOFFold, OPTpumpONold, OPTpumpOFFold;
int aktualizacja;
float temperature1 = 0;
float temperature2 = 0;
float temperature3 = 0;
String ausgabe;
// Sensor address
byte sensorAddress1[8] = {0x28, 0xFF, 0x88, 0xDB, 0x52, 0x16, 0x4, 0x3B};
byte sensorAddress2[8] = {0x28, 0xFF, 0x68, 0xBD, 0x47, 0x16, 0x3, 0x84};
byte sensorAddress3[8] = {0x28, 0xFF, 0xF5, 0x93, 0x52, 0x16, 0x4, 0x46};
// 1-Wire object
OneWire onewire(DS18B20tempPIN);
// DS18B20 sensors object
DS18B20 sensors(&onewire);
DS18B20 sensors2(&onewire);
DS18B20 sensors3(&onewire);
void setup() {
//Serial.begin(9600);
while (!Serial) { ; } // wait for serial port to connect. Needed for native USB port only
//Serial.println("Warming...");
delay(1000);
Wire.begin(); // join i2c bus (address optional for master)
// Zegar
rtc.begin();
// The following lines can be uncommented to set the date and time
//rtc.setDOW(TUESDAY); // Set Day-of-Week to SUNDAY
//rtc.setTime(21, 36, 0); // 24hr format
//rtc.setDate(16, 01, 2018); // day, mon, year
// Wilgotność i temperatura
dht.begin();
// Sonar
pinMode(trigger, OUTPUT);
pinMode(echo, INPUT);
// DS18B20 sensors setup
sensors.begin();
sensors2.begin();
sensors3.begin();
// The first requests sensor for measurement
sensors.request(sensorAddress1);
sensors2.request(sensorAddress2);
sensors3.request(sensorAddress3);
// Initializacja karty sieciowej
Ethernet.begin(mac, ip, myDns);
//Serial.print("My IP address: ");
//Serial.println(Ethernet.localIP());
// Wyłączenie przekaźników
pinMode(relayLampe, OUTPUT); // Lampe
pinMode(relayWentylator, OUTPUT); // Wentylator
pinMode(relayPumpe, OUTPUT); // Pumpe
digitalWrite(relayLampe, HIGH);
digitalWrite(relayWentylator, HIGH);
digitalWrite(relayPumpe, HIGH);
// Test LED
pinMode(LEDred, OUTPUT); // red LED
pinMode(LEDgreen, OUTPUT); // green LED
pinMode(LEDblue, OUTPUT); // blue LED
digitalWrite(LEDred, 255);
delay(500);
digitalWrite(LEDred, 0);
delay(100);
digitalWrite(LEDgreen, 255);
delay(500);
digitalWrite(LEDgreen, 0);
delay(100);
digitalWrite(LEDblue, 255);
delay(500);
digitalWrite(LEDblue, 0);
delay(100);
Einstellungen();
}
void loop() {
// [DS3231] // Odczyt dzisiejszego dnia, daty i godziny
t = rtc.getTime();
RTCdaysOfTheWeek = t.dow;
akt_data = t.year;
if (t.mon < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.mon;
if (t.date < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.date;
if (t.hour < 10) { akt_data = akt_data + " 0"; } else { akt_data = akt_data + " "; }
akt_data = akt_data + t.hour;
if (t.min < 10) { akt_data = akt_data + ":0"; } else { akt_data = akt_data + ":"; }
akt_data = akt_data + t.min;
if (t.sec < 10) { akt_data = akt_data + ":0"; } else {akt_data = akt_data + ":"; }
akt_data = akt_data + t.sec;
// [DHT22] // Odczyt wilgotności i temperatury może trwać nawet 250 millisekund!
humidity = dht.readHumidity();
temperature = dht.readTemperature();
// [HC-SR04] // Odczyt stanu wody z sonaru
digitalWrite(trigger, LOW);
delayMicroseconds(1);
digitalWrite(trigger, HIGH);
delayMicroseconds(300);
digitalWrite(trigger, LOW);
odczyt = pulseIn(echo, HIGH);
delayMicroseconds(200);
dystans = (odczyt/2) / 29;
// Another requests sensor for measurement
sensors.request(sensorAddress1);
sensors2.request(sensorAddress2);
sensors3.request(sensorAddress3);
// Reads the temperature from sensor
temperature1 = sensors.readTemperature(sensorAddress1);
temperature2 = sensors2.readTemperature(sensorAddress2);
temperature3 = sensors3.readTemperature(sensorAddress3);
// [Soil] // Odczyt czujników gleby
soilValue = analogRead(soilPin);
soilValue = map(soilValue, 0, 800, 99, 1);
OPTtempONold = OPTtempON;
OPTtempOFFold = OPTtempOFF;
OPThumONold = OPThumON;
OPThumOFFold = OPThumOFF;
OPTpumpONold = OPTpumpON;
OPTpumpOFFold = OPTpumpOFF;
if (millis() - lastConnectionTime > postingInterval) {
/*
Einstellungen aus der Datenbank laden
aktualizacja = Aktualizacja
OPThumON = Kiedy włączyć nawilżanie
OPThumOFF = Kiedy je wyłączyć i włączyć wiatrak
OPTtempON = Kiedy włączyć granie lampy
OPTtempOFF = Kiedy je wyłączyć i włączyć wiatrak
OPTpumpON = Kiedy włączyć nawodnienie
OPTpumpOFF = Kiedy je wyłączyć
*/
Einstellungen();
}
// [Relay] // Sterowanie przekaźnikami
if (temperature < OPTtempON) { x = 0; }
if (temperature < OPTtempON && x == 0) { oswietlenie = 1; } else { if (OPTtempON != OPTtempONold) { oswietlenie = 0; } }
if (temperature > OPTtempOFF) { x = 1; }
if (temperature > OPTtempOFF && x == 1) { oswietlenie = 0; } else { if (OPTtempOFF != OPTtempOFFold) { oswietlenie = 1; } }
if (humidity > OPThumON) { y = 1; }
if (humidity > OPThumON && y == 1) { chlodzenie = 1; } else { if (OPThumON != OPThumONold) { chlodzenie = 0; } }
if (humidity < OPThumOFF) { y = 0; }
if (humidity < OPThumOFF && y == 0) { chlodzenie = 0; } else { if (OPThumOFF != OPThumOFFold) { chlodzenie = 1; } }
if (oswietlenie == 1 && chlodzenie == 1) { oswietlenie = 1; chlodzenie = 0; }
if (soilValue < OPTpumpON) { z = 1; }
if (soilValue < OPTpumpON && z == 1) { pompa = 1; } else { if (OPTpumpON != OPTpumpONold) { pompa = 0; } }
if (soilValue > OPTpumpOFF) { z = 0; }
if (soilValue > OPTpumpOFF && z == 0) { pompa = 0; } else { if (OPTpumpOFF != OPTpumpOFFold) { pompa = 1; } }
// Włączanie przekaźników
if (oswietlenie == 0) { digitalWrite(relayLampe, HIGH); }
if (oswietlenie == 1) { digitalWrite(relayLampe, LOW); }
if (chlodzenie == 0) { digitalWrite(relayWentylator, HIGH); }
if (chlodzenie == 1) { digitalWrite(relayWentylator, LOW); }
if (pompa == 0) { digitalWrite(relayPumpe, HIGH); }
if (pompa == 1) { digitalWrite(relayPumpe, LOW); }
if (millis() - lastConnectionTime2 > postingInterval2) {
/*
Sendet ein String:
humidity|temperature|soilValue|dystans|oswietlenie|chlodzenie|pompa|dzien|akt_data|aktualizacja|temperature1|temperature2|temperature3|
45.25|20.20|5|15|0|0|1|Donnerstag|2017-09-21 18:20:30|60|21.10|22.20|23.30|
*/
Daten_senden();
}
// Dane do wyświetlenia
ausgabe = humidity; ausgabe.concat("|");
ausgabe.concat(temperature); ausgabe.concat("|");
ausgabe.concat(soilValue); ausgabe.concat("|");
ausgabe.concat(dystans); ausgabe.concat("|");
ausgabe.concat(oswietlenie); ausgabe.concat("|");
ausgabe.concat(chlodzenie); ausgabe.concat("|");
ausgabe.concat(pompa); ausgabe.concat("|");
ausgabe.concat(RTCdaysOfTheWeek); ausgabe.concat("|");
akt_data.replace("+", " ");
ausgabe.concat(akt_data); ausgabe.concat("|");
ausgabe.concat(postingInterval / 1000L); ausgabe.concat("|");
ausgabe.concat(temperature1); ausgabe.concat("|");
ausgabe.concat(temperature2); ausgabe.concat("|");
ausgabe.concat(temperature3); ausgabe.concat("|");
// Opcje
ausgabe.concat(OPThumON); ausgabe.concat("|");
ausgabe.concat(OPThumOFF); ausgabe.concat("|");
ausgabe.concat(OPTtempON); ausgabe.concat("|");
ausgabe.concat(OPTtempOFF); ausgabe.concat("|");
ausgabe.concat(OPTpumpON); ausgabe.concat("|");
ausgabe.concat(OPTpumpOFF); ausgabe.concat("|");
ausgabe.concat("\n");
//Serial.print(ausgabe);
delay(700);
}
void Einstellungen() {
analogWrite(LEDblue, 255);
client.setTimeout(5000);
/*
* Sendet ein Link:
* /plant.php?recive=true
*
*/
if (client.connect(server, 80)) {
client.print("GET /index.php?recive=true");
client.println(" HTTP/1.1");
client.println("Host: plant.msmech.de");
//client.println("User-Agent: arduino-ethernet");
client.println("Connection: close");
client.println();
/*
* Empfaengt Daten:
* aktualizacja|OPThumON|OPThumOFF|OPTtempON|OPTtempOFF|OPTpumpON|OPTpumpOFF|
* 60|50|40|19|22|2|75|
*
*/
startOfHttpResponseTime = millis();
while ((client.connected()) && ((millis() - startOfHttpResponseTime) < HTTP_RESPONSE_TIMEOUT)) {
if (client.available()) {
odebraneDane = client.readStringUntil('\n');
//Serial.println(odebraneDane);
for (int i = 0; i < odebraneDane.length(); i++) {
// Loop through each character and check if it's a comma
if (odebraneDane.substring(i, i+1) == "|") {
// Grab the piece from the last index up to the current position and store it
pieces[counter] = odebraneDane.substring(lastIndex, i);
// Update the last position and add 1, so it starts from the next character
lastIndex = i + 1;
// Increase the position in the array that we store into
counter++;
}
// If we're at the end of the string (no more commas to stop us)
if (i == odebraneDane.length() - 1) {
// Grab the last part of the string from the lastIndex to the end
pieces[counter] = odebraneDane.substring(lastIndex, i);
}
}
}
// Clear out string and counters to get ready for the next incoming string
odebraneDane = "";
counter = 0;
lastIndex = 0;
aktualizacja = pieces[0].toInt();
OPThumON = pieces[1].toInt();
OPThumOFF = pieces[2].toInt();
OPTtempON = pieces[3].toInt();
OPTtempOFF = pieces[4].toInt();
OPTpumpON = pieces[5].toInt();
OPTpumpOFF = pieces[6].toInt();
}
delay(1);
client.stop();
// note the time that the connection was made:
lastConnectionTime = millis();
} else {
//Serial.println("connection failed");
analogWrite(LEDblue, 0);
analogWrite(LEDred, 255);
delay(1000);
analogWrite(LEDred, 0);
}
// [DS3231] // Odczyt dzisiejszego dnia, daty i godziny
t = rtc.getTime();
RTCdaysOfTheWeek = t.dow;
akt_data = t.year;
if (t.mon < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.mon;
if (t.date < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.date;
if (t.hour < 10) { akt_data = akt_data + " 0"; } else { akt_data = akt_data + " "; }
akt_data = akt_data + t.hour;
if (t.min < 10) { akt_data = akt_data + ":0"; } else { akt_data = akt_data + ":"; }
akt_data = akt_data + t.min;
if (t.sec < 10) { akt_data = akt_data + ":0"; } else {akt_data = akt_data + ":"; }
akt_data = akt_data + t.sec;
if (postingInterval < 10000) { postingInterval = 10L * 1000L; } else { postingInterval = aktualizacja * 1000L; }
if (postingInterval2 < 10000) { postingInterval2 = 10L * 1000L; } else { postingInterval2 = aktualizacja * 1000L; }
if (OPThumON < 0) { OPThumON = 0; } else { OPThumON = OPThumON; }
if (OPThumOFF < 0) { OPThumOFF = 0; } else { OPThumOFF = OPThumOFF; }
if (OPTtempON < 0) { OPTtempON = 0; } else { OPTtempON = OPTtempON; }
if (OPTtempOFF < 0) { OPTtempOFF = 0; } else { OPTtempOFF = OPTtempOFF; }
if (OPThumON < 0) { OPThumON = 0; } else { OPThumON = OPThumON; }
if (OPTpumpOFF < 0) { OPTpumpOFF = 0; } else { OPTpumpOFF = OPTpumpOFF; }
analogWrite(LEDblue, 0);
}
void Daten_senden() {
analogWrite(LEDgreen, 255);
client.setTimeout(5000);
/*
* Sendet ein Link:
* /index.php?send=true&humidity=45.25&temperature=20.20&soilValue=5&dystans=15&oswietlenie=0&chlodzenie=0&pompa=1&dzien=Donnerstag&datum=09.11.2017+18:20:30&aktualizacja=60&temperature1=15.20&temperature2=16.30&temperature3=17.50
*
*/
startOfHttpResponseTime2 = millis();
if ((client.connect(server, 80)) && ((millis() - startOfHttpResponseTime2) < HTTP_RESPONSE_TIMEOUT)) {
// [DS3231] // Odczyt dzisiejszego dnia, daty i godziny
t = rtc.getTime();
RTCdaysOfTheWeek = t.dow;
akt_data = t.year;
if (t.mon < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.mon;
if (t.date < 10) { akt_data = akt_data + "-0"; } else { akt_data = akt_data + "-"; }
akt_data = akt_data + t.date;
if (t.hour < 10) { akt_data = akt_data + "+0"; } else { akt_data = akt_data + "+"; }
akt_data = akt_data + t.hour;
if (t.min < 10) { akt_data = akt_data + ":0"; } else { akt_data = akt_data + ":"; }
akt_data = akt_data + t.min;
if (t.sec < 10) { akt_data = akt_data + ":0"; } else {akt_data = akt_data + ":"; }
akt_data = akt_data + t.sec;
//Serial.println("connecting...");
// send the HTTP GET request:
client.print("GET /index.php?send=true");
client.print("&humidity=");
client.print(humidity);
client.print("&temperature=");
client.print(temperature);
client.print("&soilValue=");
client.print(soilValue);
client.print("&dystans=");
client.print(dystans);
client.print("&oswietlenie=");
client.print(oswietlenie);
client.print("&chlodzenie=");
client.print(chlodzenie);
client.print("&pompa=");
client.print(pompa);
client.print("&dzien=");
client.print(RTCdaysOfTheWeek);
client.print("&datum=");
client.print(akt_data);
client.print("&aktualizacja=");
client.print(aktualizacja);
client.print("&temperature1=");
client.print(temperature1);
client.print("&temperature2=");
client.print(temperature2);
client.print("&temperature3=");
client.print(temperature3);
client.println(" HTTP/1.1");
client.println("Host: plant.msmech.de");
//client.println("User-Agent: arduino-ethernet");
client.println("Connection: close");
client.println();
delay(1);
client.stop();
// note the time that the connection was made:
lastConnectionTime2 = millis();
} else {
//Serial.println("connection failed");
analogWrite(LEDgreen, 0);
analogWrite(LEDred, 255);
delay(1000);
analogWrite(LEDred, 0);
}
analogWrite(LEDgreen, 0);
}