/*===== Final Project Kelompok 4 versi 1.5 ===========
  Kelompok:
    I Nengah Arnawa
    Agustrian Maulana
    Arif Hidayatullah
    Candrayana P

  =====================================================
  Fitur:
    + Pewaktu otomatis (RTC)
    + Pemberi pakan sesuai jadwal (Servo)
    + Pengukuran stok pakan otomatis (HC-SR04)
    + Lampu indikator stok pakan (LED)
    + Tampilan LCD
    + Notifikasi ke Telegram
    + Notifikasi ke e-mail
    + Rekap data pada web
  =====================================================
*/

//Libraries
#include <WiFi.h>
#include <WiFiClientSecure.h>
#include "ThingsBoard.h"
#include <PubSubClient.h>
#include <ESP32Servo.h>
#include "RTClib.h"
#include <LiquidCrystal_I2C.h>
#include <UniversalTelegramBot.h>
#include <HTTPClient.h>

//definisi LCD
LiquidCrystal_I2C lcd(0x27, 20, 4);

//definisi pin led
#define ledHijau 12
#define ledMerah 14

//definisi motor servo
Servo myServo;
int posisi = 0;
int sudutMax = 90;

//Definisi RTC
RTC_DS1307 rtc;

//Definisi Jadwal pakan ikan
//Jadwal pagi
const int JamMakan1 = 1;
const int MenitMakan1 = 29;
const int DetikMakan1 = 00;
//Jadwal siang
const int JamMakan2 = 1;
const int MenitMakan2 = 29;
const int DetikMakan2 = 30;
//Jadwal sore
const int JamMakan3 = 1;
const int MenitMakan3 = 50;
const int DetikMakan3 = 00;

//variabel dependen
int counter = 0;
float persentaseSisaPakan = 0;

//Definisi sensor ultrasonik
#define ECHO_PIN 2
#define TRIG_PIN 15
#define tinggiTabungPakan 100

//credentials wifi
const char *ssid = "Wokwi-GUEST";
const char *password = "";

//koneksi ke thingsboard
#define TOKEN "FinalProjectKelompok4" //Access token of device Display Thingsboard
const char* mqtt_server = "thingsboard.cloud";

//web
const char* serverName = "http://arnawaiot.000webhostapp.com/post-data.php";
String apiKeyValue = "@rnawa1234";
String sensorName = "HC-SR04";
String sensorLocation = "Kolam1";

WiFiClient wifiClient;
PubSubClient client(wifiClient);
int status = WL_IDLE_STATUS;

// inisialisasi Telegram BOT
#define BOTtoken "5464133622:AAG4J7N49fXeuuUjFdR4AjxJ46V5I8ZF_K8" //  Token Bot Telegram
String chat_id = "231396955";//  user id penerima yang tetap yaitu I Nengah Arnawa

WiFiClientSecure wifiClientSecure;
UniversalTelegramBot bot(BOTtoken, wifiClientSecure);

void setup() {
  Serial.begin(115200);
  digitalWrite(ledMerah, LOW);
  digitalWrite(ledHijau, LOW);
  //lcd
  lcd.init();
  lcd.backlight();
  lcd.setCursor(0, 0);
  lcd.print("Feeder Machine");

  wifiClientSecure.setInsecure();

  WiFi.begin(ssid, password);
  //  WiFi.config(IP, NETWORK, NETMASK, DNS);
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
    Serial.print("...");
  }
  Serial.print("\n");
  Serial.print("IP address : ");
  Serial.print(WiFi.localIP());
  Serial.print("\n");
  Serial.print("Connect to : ");
  Serial.println(ssid);
  client.setServer( mqtt_server, 1883);

  //HC-SR04
  pinMode(TRIG_PIN, OUTPUT);
  pinMode(ECHO_PIN, INPUT);

  //LED
  pinMode(ledHijau, OUTPUT);
  pinMode(ledMerah, OUTPUT);

  //Servo
  myServo.attach(13);
  myServo.write(posisi);

  //RTC
  if (! rtc.begin()) { //bila RTC tidak terhubung
    Serial.println("Couldn't find RTC");
    Serial.flush();
    while (1) delay(10);
  }

  if (! rtc.isrunning()) { //bila RTC tidak jalan maka set waktu
    Serial.println("RTC is NOT running, let's set the time!");
    // ketika set waktu diperlukan untuk alat baru, atau saat power loss,
    // berikut ini set waktu saat sketch ini di-compile
    rtc.adjust(DateTime(F(__DATE__), F(__TIME__)));
  }

}
float pengukuranSisaPakan() {
  //Sensor ultrasonik mengkondisikan impuls
  digitalWrite(TRIG_PIN, LOW);
  delayMicroseconds(2);
  digitalWrite(TRIG_PIN, HIGH);
  delayMicroseconds(10);
  digitalWrite(TRIG_PIN, LOW);

  int durasi = pulseIn(ECHO_PIN, HIGH);
  float jarakPakanDariAtas = durasi * 0.034 / 2;
  //misal tinggi tabung pakan sesuai definisi awal
  float ketinggianPakan = tinggiTabungPakan - jarakPakanDariAtas;
  return persentaseSisaPakan = (ketinggianPakan) * 100 / tinggiTabungPakan;

  //debug melalui serial monitor
  Serial.print("Tinggi sisa pakan: ");
  Serial.print(ketinggianPakan);
  Serial.println(" cm");
  Serial.print("Persentase sisa pakan: ");
  Serial.print(persentaseSisaPakan);
  Serial.println(" %");

  //display sisa pakan ke lcd
  lcd.setCursor(0, 3);
  lcd.print("Sisa pakan : ");
  lcd.print(persentaseSisaPakan);
  lcd.println(" %");
}

void indikatorLed() {
  if (persentaseSisaPakan >  5) {
    digitalWrite(ledHijau, HIGH);
    digitalWrite(ledMerah, LOW);
  }
  if (persentaseSisaPakan <= 5) {
    digitalWrite(ledMerah, HIGH);
    digitalWrite(ledHijau, LOW);
  }
}

void pergerakanServo() {
  for (posisi = 0; posisi <= sudutMax; posisi ++) {
    myServo.write(posisi);
    delay(15);
  }
  for (posisi = sudutMax; posisi >= 0; posisi --) {
    myServo.write(posisi);
    delay(15);
  }
}

//menambah counter
float tambahCounter() {
  counter = counter + 1;
  return counter;
  if (counter > 3) {
    counter = 0;
  }
  Serial.print("Total: ");
  Serial.print(counter);
  Serial.println(" kali.");

  //display total makan ke lcd
  lcd.setCursor(0, 2);
  lcd.print("Total Makan : ");
  lcd.print(counter);
  lcd.println(" kali.");
}
void kirimKeThingsboard() {
  //kirim counter
  String payload2 = "{";
  payload2 += "\"Total makan\":"; payload2 += counter;
  payload2 += "}";

  char attributes2[1000];
  payload2.toCharArray( attributes2, 1000 );
  client.publish( "v1/devices/me/telemetry", attributes2);
  client.publish( "v1/devices/me/attributes", attributes2);
  Serial.println( attributes2 );

  //kirim Stok pakan
  String payload1 = "{";
  payload1 += "\"StokPakanIkan\":"; payload1 += persentaseSisaPakan;
  payload1 += "}";

  char attributes1[1000];
  payload1.toCharArray( attributes1, 1000 );
  client.publish( "v1/devices/me/telemetry", attributes1);
  client.publish( "v1/devices/me/attributes", attributes1);
  Serial.println( attributes1 );

}

void loop() {
  //cek waktu sekarang
  DateTime sekarang = rtc.now();
  Serial.print("Saat ini pukul: ");
  Serial.print(sekarang.hour(), DEC);
  Serial.print(':');
  Serial.print(sekarang.minute(), DEC);
  Serial.print(':');
  Serial.print(sekarang.second(), DEC);
  Serial.println();

  //cek waktu sekarang di lcd
  lcd.setCursor(0, 1);
  lcd.print("Pukul : ");
  lcd.print(sekarang.hour(), DEC);
  lcd.print(':');
  lcd.print(sekarang.minute(), DEC);
  lcd.print(':');
  lcd.print(sekarang.second(), DEC);
  lcd.println();


  //set the time for fish feeding
  if ((sekarang.hour() == JamMakan1 && sekarang.minute() == MenitMakan1 && sekarang.second() == DetikMakan1) || (sekarang.hour() == JamMakan2 && sekarang.minute() == MenitMakan2 && sekarang.second() == DetikMakan2) || (sekarang.hour() == JamMakan3 && sekarang.minute() == MenitMakan3 && sekarang.second() == DetikMakan3)) {
    tambahCounter();
    pergerakanServo();
    pengukuranSisaPakan();
    kirimKeThingsboard();
    kirimKeWeb();
    updatePesan();
  }
  if ( !client.connected() )
  {
    reconnect();
  }
  indikatorLed();

}

void updatePesan() {
  Serial.println("Kirim notif telegram");
  String showTotalMakan = "Total Makan : ";
  showTotalMakan += (counter);
  showTotalMakan += " kali";
  bot.sendMessage(chat_id, showTotalMakan, "");

  String showSisaPakan = "Sisa Pakan : ";
  showSisaPakan += (persentaseSisaPakan);
  showSisaPakan += " %";
  bot.sendMessage(chat_id, showSisaPakan, "");

  String showWeb = "Rekap di: https://arnawaiot.000webhostapp.com/ikan.php ";
  bot.sendMessage(chat_id, showWeb, "");

}
void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    status = WiFi.status();
    if ( status != WL_CONNECTED) {
      WiFi.begin(ssid, password);
      while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");
      }
      Serial.println("Connected to AP");
    }
    Serial.print("Connecting to ThingsBoard node ...");
    // Attempt to connect (clientId, username, password)
    if ( client.connect("3a90f960-1ad1-11ed-b480-cbe4cea4aa70", TOKEN, "") ) {
      Serial.println( "[DONE]" );
    } else {
      Serial.print( "[FAILED] [ rc = " );
      Serial.println( " : retrying in 5 seconds]" );
      delay( 500 );
    }
  }
}
void kirimKeWeb() {
  HTTPClient http;
  DateTime sekarang = rtc.now();
  http.begin(serverName);
  http.addHeader("Content-Type", "application/x-www-form-urlencoded");
  //  HTTP POST request data
  float makan = counter;
  float stok = persentaseSisaPakan;
  String httpRequestData = "api_key=" + apiKeyValue + "&Sensor=" + sensorName
                           + "&Lokasi=" + sensorLocation
                           + "&Makan=" + makan + "&Stok=" + stok + "";
  Serial.print("httpRequestData: ");
  Serial.println(httpRequestData);
  int httpResponseCode = http.POST(httpRequestData);
  if (httpResponseCode > 0) {
    Serial.print("HTTP Response code: ");
    Serial.println(httpResponseCode);
  }
  else {
    Serial.print("Error code: ");
    Serial.println(httpResponseCode);
  }
  http.end();
  // ini alamat webnya: https://arnawaiot.000webhostapp.com/ikan.php
}