#include <WiFi.h>
#include <esp_wifi.h>
#include "DHTesp.h"
#include "ThingsBoard.h"
#include <RTClib.h>
#include <TimeLib.h>
#include <TimeAlarms.h>
#include <Wire.h>
#include <DS1307RTC.h> // a basic DS1307 library that returns time as a time_t
#include <ESP32Servo.h>
#include <WiFiUdp.h>
#define CURRENT_FIRMWARE_TITLE "TEST"
#define CURRENT_FIRMWARE_VERSION "1.0.0"
#define WIFI_SSID "Wokwi-GUEST"
#define WIFI_PASSWORD ""
#define ECHO_PIN 12
#define TRIG_PIN 13
#define ledTangki 4 //led tangki Pakan akan menyala apabila pakan akan habis
#define pelontar 5 //Pelontar disimulasikan dengan Relay dan LED
#define potensio 32 //Turbidity sensor disimulasikan dengan potensiometer
#define pompa 2 //Pompa pengontrol kekeruhan disimulasikan dengan Relay dan LED
const int DHT_PIN = 15;
const int tinggiTangki = 80;
Servo servoPakan;
IPAddress timeServer(162, 159, 200, 1);//ip dari server NTP id.pool.ntp.org
const int timeZone = 7; // GMT+7 Jakarta, Bangkok, Hanoi Time
WiFiUDP Udp;
unsigned int localPort = 8889;
time_t prevDisplay = 0;
int keruh=0;
DHTesp dhtSensor;
// See https://thingsboard.io/docs/getting-started-guides/helloworld/
// to understand how to obtain an access token
#define TOKEN "ddTyQPV8wjDIS8Gcu9ar"
#define THINGSBOARD_SERVER "thingsboard.cloud"
// Baud rate for debug serial
#define SERIAL_DEBUG_BAUD 115200
// Initialize ThingsBoard client
WiFiClient espClient;
// Initialize ThingsBoard instance
ThingsBoard tb(espClient);
// the Wifi radio's status
int status = WL_IDLE_STATUS;
uint8_t newMACAddress[] = {0x32, 0xAE, 0xA4, 0x07, 0x0D, 0x18};
// uint8_t newMACAddress[] = {0x32, 0xAE, 0xA4, 0x07, 0x0D, 0x66};
// uint8_t newMACAddress[] = {0x32, 0xAE, 0xA4, 0x07, 0x0D, 0x66};
void InitWiFi()
{
Serial.println("Connecting to AP ......");
// attempt to connect to WiFi network
WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
Serial.println("Connected to AP");
}
void reconnect() {
// Loop until we're reconnected
status = WiFi.status();
if ( status != WL_CONNECTED) {
WiFi.begin(WIFI_SSID, WIFI_PASSWORD);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print("..");
}
Serial.println("Connected to AP");
}
}
void setup() {
// initialize serial for debugging
Serial.begin(SERIAL_DEBUG_BAUD);
InitWiFi();
Serial.println();
servoPakan.attach(33);
pinMode(ledTangki, OUTPUT);
pinMode(TRIG_PIN, OUTPUT);
pinMode(ECHO_PIN, INPUT);
pinMode(pelontar, OUTPUT);
pinMode(potensio, INPUT);
pinMode(pompa, OUTPUT);
dhtSensor.setup(DHT_PIN, DHTesp::DHT22);
while (!Serial) ;
Udp.begin(localPort);
setSyncProvider(getNtpTime);
//setSyncProvider(RTC.get);
if (timeStatus() != timeSet)
Serial.println("Unable to sync with the RTC");
else
Serial.println("RTC has set the system time");
Serial.print("[OLD] ESP32 Board MAC Address: ");
Serial.println(WiFi.macAddress());
// ESP32 Board add-on before version < 1.0.5
//esp_wifi_set_mac(ESP_IF_WIFI_STA, &newMACAddress[0]);
// ESP32 Board add-on after version > 1.0.5
esp_wifi_set_mac(WIFI_IF_STA, &newMACAddress[0]);
Serial.print("[NEW] ESP32 Board MAC Address: ");
Serial.println(WiFi.macAddress());
// to test your project, you can set the time manually
//setTime(21,22,0,10,22,22); // set time to Saturday 8:29:00am Jan 1 2011
// create the scheduled tasks, to trigger functions at specific times
Alarm.alarmRepeat(21,27,10,feedingPagi); //jam,menit,detik (kalau 1 digit tidak usah tambah nol di depan)
Alarm.alarmRepeat(21,27,20,feedingSiang); //jam,menit,detik (kalau 1 digit tidak usah tambah nol di depan)
Alarm.alarmRepeat(21,27,30,feedingMalam); //jam,menit,detik (kalau 1 digit tidak usah tambah nol di depan)
}
void loop() {
//delay(1000);
if (WiFi.status() != WL_CONNECTED) {
reconnect();
}
if (!tb.connected()) {
// Connect to the ThingsBoard
Serial.print("Connecting to: ");
Serial.print(THINGSBOARD_SERVER);
Serial.print(" with token ");
Serial.println(TOKEN);
if (!tb.connect(THINGSBOARD_SERVER, TOKEN)) {
Serial.println("Failed to connect");
return;
}
}
digitalClockDisplay();
Alarm.delay(1000);
Serial.println("Sending data...");
// Uploads new telemetry to ThingsBoard using MQTT.
// See https://thingsboard.io/docs/reference/mqtt-api/#telemetry-upload-api
// for more details
digitalWrite(TRIG_PIN, LOW);
delayMicroseconds(2);
digitalWrite(TRIG_PIN, HIGH);
delayMicroseconds(10);
digitalWrite(TRIG_PIN, LOW);
int duration = pulseIn(ECHO_PIN, HIGH);
float distance = duration * 0.034 / 2;
float pakan= (tinggiTangki - distance)/tinggiTangki * 100;
if (pakan >= 30 && pakan <= 100)
{
Serial.print("Pakan: ");
Serial.println(pakan);
tb.sendTelemetryFloat("pakan", pakan);
tb.sendTelemetryString("statusTangki", "Normal");
digitalWrite(ledTangki, LOW);
}
else if (pakan < 30 && pakan >=0) {
Serial.print("Pakan: ");
Serial.println(pakan);
Serial.println("SEGERA ISI PAKAN");
tb.sendTelemetryFloat("pakan", pakan);
tb.sendTelemetryString("statusTangki", "Low");
digitalWrite(ledTangki, HIGH);
}
else
{
Serial.println("Periksa Tutup Tangki Pakan");
tb.sendTelemetryString("statusTangki", "Error");
digitalWrite(ledTangki, HIGH);
}
float turbidity = 4.5 - analogRead(potensio)/1000;
if (turbidity < 3.5 && keruh==0)
{
Serial.println("Kekeruhan Tinggi, pompa dihidupkan");
digitalWrite(pompa, HIGH);
keruh=1;
tb.sendTelemetryInt("statusPompa", 1);
}
else if (turbidity >= 3.5 && keruh==1)
{
Serial.println("Kekeruhan Normal, pompa dimatikan");
digitalWrite(pompa, LOW);
keruh=0;
tb.sendTelemetryInt("statusPompa", 0);
}
TempAndHumidity data = dhtSensor.getTempAndHumidity();
tb.sendTelemetryFloat("turbidity", turbidity);
tb.sendTelemetryInt("temperature", data.temperature);
tb.sendTelemetryFloat("humidity", data.humidity);
Serial.print("Kekeruhan Air: ");
Serial.println(turbidity);
Serial.print("Suhu: ");
Serial.println(data.temperature);
Serial.print("Kelembaban: ");
Serial.println(data.humidity);
tb.loop();
tb.loop();
}
void feedingPagi() {
Serial.println("Eksekusi Feeding ke-1");
servoPakan.write(30);
digitalWrite(pelontar, HIGH);
Serial.println("Pelontar Start");
tb.sendTelemetryInt("statusPelontar",1);
delay(3000);
servoPakan.write(90);
delay(2000);
digitalWrite(pelontar, LOW);
Serial.println("Pelontar Stop");
tb.sendTelemetryInt("statusPelontar",0);
}
void feedingSiang() {
Serial.println("Eksekusi Feeding ke-2");
servoPakan.write(30);
digitalWrite(pelontar, HIGH);
Serial.println("Pelontar Start");
tb.sendTelemetryInt("statusPelontar",1);
delay(3000);
servoPakan.write(90);
delay(2000);
digitalWrite(pelontar, LOW);
Serial.println("Pelontar Stop");
tb.sendTelemetryInt("statusPelontar",0);
}
void feedingMalam() {
Serial.println("Eksekusi Feeding ke-3");
servoPakan.write(30);
digitalWrite(pelontar, HIGH);
Serial.println("Pelontar Start");
tb.sendTelemetryInt("statusPelontar",1);
delay(3000);
servoPakan.write(90);
delay(2000);
digitalWrite(pelontar, LOW);
Serial.println("Pelontar Stop");
tb.sendTelemetryInt("statusPelontar",0);
}
void digitalClockDisplay() {
Serial.print(hour());
printDigits(minute());
printDigits(second());
Serial.println();
}
void printDigits(int digits) {
Serial.print(":");
if (digits < 10)
Serial.print('0');
Serial.print(digits);
}
const int NTP_PACKET_SIZE = 48; // NTP time is in the first 48 bytes of message
byte packetBuffer[NTP_PACKET_SIZE]; //buffer to hold incoming & outgoing packets
time_t getNtpTime()
{
while (Udp.parsePacket() > 0) ; // discard any previously received packets
Serial.println("Transmit NTP Request");
sendNTPpacket(timeServer);
uint32_t beginWait = millis();
while (millis() - beginWait < 1500) {
int size = Udp.parsePacket();
if (size >= NTP_PACKET_SIZE) {
Serial.println("Receive NTP Response");
Udp.read(packetBuffer, NTP_PACKET_SIZE); // read packet into the buffer
unsigned long secsSince1900;
// convert four bytes starting at location 40 to a long integer
secsSince1900 = (unsigned long)packetBuffer[40] << 24;
secsSince1900 |= (unsigned long)packetBuffer[41] << 16;
secsSince1900 |= (unsigned long)packetBuffer[42] << 8;
secsSince1900 |= (unsigned long)packetBuffer[43];
return secsSince1900 - 2208988800UL + timeZone * SECS_PER_HOUR;
}
}
Serial.println("No NTP Response :-(");
return 0; // return 0 if unable to get the time
}
// send an NTP request to the time server at the given address
void sendNTPpacket(IPAddress &address)
{
// set all bytes in the buffer to 0
memset(packetBuffer, 0, NTP_PACKET_SIZE);
// Initialize values needed to form NTP request
// (see URL above for details on the packets)
packetBuffer[0] = 0b11100011; // LI, Version, Mode
packetBuffer[1] = 0; // Stratum, or type of clock
packetBuffer[2] = 6; // Polling Interval
packetBuffer[3] = 0xEC; // Peer Clock Precision
// 8 bytes of zero for Root Delay & Root Dispersion
packetBuffer[12] = 49;
packetBuffer[13] = 0x4E;
packetBuffer[14] = 49;
packetBuffer[15] = 52;
// all NTP fields have been given values, now
// you can send a packet requesting a timestamp:
Udp.beginPacket(address, 123); //NTP requests are to port 123
Udp.write(packetBuffer, NTP_PACKET_SIZE);
Udp.endPacket();
}