Pakan Ikan Monitor PH Turbidity Amoniak Suhu dan Monitor Water Level IOT Blynk 2.0

Pakan Ikan Monitor PH Turbidity Amoniak Suhu dan Monitor Water Level IOT Blynk 2.0

 

         Pada kesempatan kali ini saya akan menjelaskan mengenai bagaimana cara membuat sebuah alat yang bisa mengukur PH Turbidity Suhu dan water level via IOT Blynk. alat ini juga terdapat RTC sebagai pewaktu, jadi ketika waktu sesuai dengan setingan maka pelontar berupa servo akan aktif. berikut adalah kodingdan skemanya.

 

 

1. Skema

 

 

2. Program Arduino IDE

 

#include <Wire.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include <LiquidCrystal_I2C.h>
#include <DS3231.h>
#include <EEPROM.h>
#define ONE_WIRE_BUS 12  
#include <Servo.h>
#include <SoftwareSerial.h>

SoftwareSerial mySerial(2, 3); // RX pin 2, TX pin 3

#define trigPin1 2
#define echoPin1 3
#define trigPin2 5
#define echoPin2 6
 
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);

LiquidCrystal_I2C lcd(0x27,20,4);
DS3231  rtc(SDA, SCL);
Servo myservo1;

int addr1 = 0;
int addr2 = 1;
int addr3 = 2;
int addr4 = 3;
int addr5 = 4;

Time  t;
int jampagi,jamsiang,jamsore;
float TempC;
float pHValue;
int tds;
int adctds;
int adcPH;
int TempCx;
int pHValuex;
int ntux;
float ntufix;
long duration1, distance1;
long duration2, distance2;  
int btset = 4;
int btup = 8;
int btdown = 7;
int btok = 11;
int btsetx;
int btupx;
int btdownx;
int btokx;
float batasamo;
float batasph;
float amoniak;
int relayaerator = A2;
int relayout = A3;
int relayin = A6;
int tanda = 0;
int kolam;
int tinggipakan;
int tdsValue;

void setup(){  
  
jampagi = EEPROM.read(addr1);
jamsiang = EEPROM.read(addr2);
jamsore = EEPROM.read(addr3);
batasamo = EEPROM.read(addr4);
batasph = EEPROM.read(addr5);

pinMode(trigPin1, OUTPUT);
pinMode(echoPin1, INPUT);
pinMode(trigPin2, OUTPUT);
pinMode(echoPin2, INPUT); 

pinMode(relayaerator,OUTPUT);
digitalWrite(relayaerator,HIGH);
pinMode(relayin,OUTPUT);
digitalWrite(relayin,HIGH);
pinMode(relayout,OUTPUT);
digitalWrite(relayout,HIGH);

pinMode(btset,INPUT_PULLUP);
pinMode(btup,INPUT_PULLUP);
pinMode(btdown,INPUT_PULLUP);
pinMode(btok,INPUT_PULLUP);

Wire.begin();  
sensors.begin();
Serial.begin(9600);
lcd.begin();  
lcd.clear(); 

rtc.begin();
//rtc.setDOW(WEDNESDAY);     // Set Day-of-Week to SUNDAmy
//rtc.setTime(14, 37, 0);     // Set the time to 12:00:00 (24hr format)
//rtc.setDate(1, 1, 2014);   // Set the date to January 1st, 2014

myservo1.attach(9);
}

void loop(){

btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);

if(btsetx == 0){
delay(1000);
lcd.clear();
setjampagi();
setjamsiang();
setjamsore();
setbatasamo();
setbatasph();
}
  
 t = rtc.getTime();
    
 adcPH = analogRead(A0); //menggunakan pin A0 untuk membaca output sensor pH
 pHValue = (adcPH - 1093.4) / -30.897;

 adctds = analogRead(A1);             
 tdsValue = map(adctds, 566, 1, 0, 100);
 
 pHValuex = pHValue * 100.0;
 
  sensors.requestTemperatures();
  TempC = sensors.getTempCByIndex(0); // Celcius
  TempCx =  TempC * 100.0;

if(pHValue < 6.5){
  amoniak = (pHValue / TempC) * 0.202; 
}

if(pHValue == 7.0){
  amoniak = (pHValue / TempC) * 1.131; 
}

if(pHValue > 7.0){
  amoniak = (pHValue / TempC) * 3.306; 
}

if(amoniak > batasamo){
  digitalWrite(relayaerator,HIGH);
  }

if(amoniak <= batasamo){
  digitalWrite(relayaerator,LOW);
  }

if((t.hour == jampagi)&&(jampagi > 0)&&(tanda == 0)){
  myservo1.write(150);
  delay(5000);
  myservo1.write(100);
  tanda = 1;
}

if((t.hour == jamsiang)&&(jamsiang > 0)&&(tanda == 1)){
  myservo1.write(150);
  delay(5000);
  myservo1.write(100);
  tanda = 2;
}

if((t.hour == jamsore)&&(jamsore > 0)&&(tanda == 2)){
  myservo1.write(150);
  delay(5000);
  myservo1.write(100);
  tanda = 0;
}

  lcd.setCursor(0,0);
  lcd.print("TDS:");
  lcd.print(tdsValue);
  lcd.print(" ");
 
  lcd.print("PH:");
  lcd.print(pHValue);
  lcd.print(" ");

  lcd.setCursor(0,1);
  lcd.print("T:");
  lcd.print(TempC,1);
  lcd.print("c ");
  
  lcd.print(batasamo,1);
  lcd.print("/");
  lcd.print(batasph,1);
  lcd.print("");

  lcd.setCursor(0,2);
  lcd.print(t.hour, DEC);
  lcd.print(":");
  lcd.print(t.min, DEC);
  lcd.print(":");
  lcd.print(t.sec, DEC);
  lcd.print("  ");
  lcd.print(jampagi);
  lcd.print("/");
  lcd.print(jamsiang);
  lcd.print("/");
  lcd.print(jamsore);
  lcd.print("");

  lcd.setCursor(0,3);
  lcd.print("Mg/l:");
  lcd.print(amoniak,1);
  lcd.print(" ");
 lcd.print(distance1);
 lcd.print("/");
 lcd.print(distance2);
 lcd.print("  ");

  //ketinggian air kolam 
  digitalWrite(trigPin1, LOW);  // Added this line
  delayMicroseconds(2); // Added this line
  digitalWrite(trigPin1, HIGH);
  delayMicroseconds(10); // Added this line
  digitalWrite(trigPin1, LOW);
  duration1 = pulseIn(echoPin1, HIGH);
  distance1 = (duration1/2) / 29.1;

  //ketinggian pakan ikan
  digitalWrite(trigPin2, LOW);  // Added this line
  delayMicroseconds(2); // Added this line
  digitalWrite(trigPin2, HIGH);
  delayMicroseconds(10); // Added this line
  digitalWrite(trigPin2, LOW);
  duration2 = pulseIn(echoPin2, HIGH);
  distance2 = (duration2/2) / 29.1;
  
  tinggipakan = map(distance2, 5,30,100,0);

if((kolam >= 29)&&(kolam <= 31)){
  digitalWrite(relayin,LOW);
  digitalWrite(relayout,LOW);  
  }

if(kolam < 29){
  digitalWrite(relayin,HIGH);
  digitalWrite(relayout,LOW);
  }

if(kolam > 31){
  digitalWrite(relayin,LOW);
  digitalWrite(relayout,HIGH);
  }

  Serial.print("*");
  Serial.print(pHValue * 100.0);
  Serial.print(",");
  Serial.print(tdsValue);
  Serial.print(",");
  Serial.print(amoniak * 100.0);
  Serial.print(",");
  Serial.print(TempC * 100.0);
  Serial.println("#");
  
  delay(1000);
}

void setjampagi(){
  
btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);  

  lcd.setCursor(0,0);
  lcd.print("Waktu Pakan Pagi");
  lcd.setCursor(0,1);
  lcd.print("Jam: ");
  lcd.print(jampagi);
  lcd.print("   ");

if(btupx == 0){
  delay(200);
  jampagi++; 
}

if(btdownx == 0){
  delay(200);
  jampagi--; 
}

if(jampagi > 23){
jampagi = 0;  
}

if(btokx == 0){
  lcd.clear();
  delay(2000);
  EEPROM.write(addr1, jampagi);
  return; 
}

setjampagi();  
}

void setjamsiang(){
  
btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);  

  lcd.setCursor(0,0);
  lcd.print("Waktu Pakan Siang  ");
  lcd.setCursor(0,1);
  lcd.print("Jam: ");
  lcd.print(jamsiang);
  lcd.print("   ");

if(btupx == 0){
  delay(200);
  jamsiang++; 
}

if(btdownx == 0){
  delay(200);
  jamsiang--; 
}

if(jamsiang > 23){
jamsiang = 0;  
}

if(btokx == 0){
  lcd.clear();
  delay(2000);
  EEPROM.write(addr2, jamsiang);
  return; 
}

setjamsiang();  
}

void setjamsore(){
  
btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);  

  lcd.setCursor(0,0);
  lcd.print("Waktu Pakan Sore  ");
  lcd.setCursor(0,1);
  lcd.print("Jam: ");
  lcd.print(jamsore);
  lcd.print("   ");

if(btupx == 0){
  delay(200);
  jamsore++; 
}

if(btdownx == 0){
  delay(200);
  jamsore--; 
}

if(jamsore > 23){
jamsore = 0;  
}

if(btokx == 0){
  lcd.clear();
  delay(2000);
  EEPROM.write(addr3, jamsore);
  return; 
}

setjamsore();  
}

void setbatasamo(){
  
btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);  

  lcd.setCursor(0,0);
  lcd.print("BATAS AMONIAK  ");
  lcd.setCursor(0,1);
  lcd.print("mg/l: ");
  lcd.print(batasamo);
  lcd.print("   ");

if(btupx == 0){
  delay(200);
  batasamo = batasamo + 0.1; 
}

if(btdownx == 0){
  delay(200);
  batasamo = batasamo - 0.1; 
}

if(batasamo > 100.0){
batasamo = 0;  
}

if(btokx == 0){
  lcd.clear();
  delay(2000);
  EEPROM.write(addr4, batasamo);
  return; 
}

setbatasamo();  
}

void setbatasph(){
  
btsetx = digitalRead(btset);
btupx = digitalRead(btup);
btdownx = digitalRead(btdown);
btokx = digitalRead(btok);  

  lcd.setCursor(0,0);
  lcd.print("BATAS PH  ");
  lcd.setCursor(0,1);
  lcd.print("PH: ");
  lcd.print(batasph);
  lcd.print("   ");

if(btupx == 0){
  delay(200);
  batasph = batasph + 0.1; 
}

if(btdownx == 0){
  delay(200);
  batasph = batasph - 0.1; 
}

if(batasph > 100.0){
batasph = 0;  
}

if(btokx == 0){
  lcd.clear();
  delay(2000);
  EEPROM.write(addr5, batasph);
  return; 
}

setbatasph();  
}

 

 

3. Program ESP8266

 

#define BLYNK_TEMPLATE_ID "TMPL7GgHJ-bSF"
#define BLYNK_TEMPLATE_NAME "Pakan Ikan"
#define BLYNK_AUTH_TOKEN "2ycYdRyEJqHnFgXXsJKH3rh-yb5_cvbn"
#define  BLYNK_PRINT Serial  

#include <SPI.h>
#include <SPI.h>
#include <ESP8266WiFi.h>
#include <BlynkSimpleEsp8266.h>

int temp;
int x = 5;
int y;

int value1;
int value2;
int value3;
int value4;

float ph;
int tds;
float amoniak;
float suhu;

int datain1;
int datain2;
int datain3;
int datain4;

String dataIn;
String dt[10];
int i;
boolean parsing = false;
BlynkTimer timer;

char ssid[] = "hotspothpku";
char pass[] = "123456789";

void sendSensor()
{
 Blynk.virtualWrite(V0, ph);
 Blynk.virtualWrite(V1, tds);
 Blynk.virtualWrite(V2, amoniak);
 Blynk.virtualWrite(V3, suhu);
 delay(1000);
}

void setup(){  
Serial.begin(9600);
Blynk.begin(BLYNK_AUTH_TOKEN, ssid, pass);
timer.setInterval(1000L, sendSensor);
}

void loop() {
        
while(Serial.available()>0) {
//   dataIn="";
    char inChar = (char)Serial.read();
    dataIn += inChar;
    if (inChar == '\n') {
    parsing = true;
  }
}

if(parsing){
    parsingData();

  Blynk.run();
  timer.run();
  delay(200);

}
 
delay(100);
}

void parsingData(){
int j=0;

//kirim data yang telah diterima sebelumnya
//Serial.print("data masuk : ");
//Serial.print(dataIn);
//Serial.print("\n");

//inisialisasi variabel, (reset isi variabel)
dt[j]="";
//proses parsing data
for(i=1;i<dataIn.length();i++){
//pengecekan tiap karakter dengan karakter (#) dan (,)
if ((dataIn[i] == '#') || (dataIn[i] == ','))
{
//increment variabel j, digunakan untuk merubah index array penampung
j++;
dt[j]="";       //inisialisasi variabel array dt[j]
}
else
{
//proses tampung data saat pengecekan karakter selesai.
dt[j] = dt[j] + dataIn[i];
}
}

 datain1 = dt[0].toInt();
 datain2 = dt[1].toInt();
 datain3 = dt[2].toInt();
 datain4 = dt[3].toInt();

 ph = datain1 / 100.0;
 tds = datain2 / 1;
 amoniak = datain3 / 100.0;
 suhu = datain4 / 100.0;
 
}

 

 

4. VIDEO HASILNYA

 

Monitor PH Turbidity NTU TDS Suhu IOT Notif TELEGRAM

Monitor PH Turbidity NTU TDS Suhu IOT Notif TELEGRAM

        Pada kesempatan kali ini saya akan menjelaskan mengenai bagaimana cara membuat sebuah alat yang dapat mengukur PH ,TDS ,NTU ,Turbidity ,Suhu dan notif IOT telegram untuk lebih jelasnya berikut adalah koding dan foto alatnya.

 

1. Foto Alat

2. Program Arduino IDE

#include <Wire.h>

#include <LiquidCrystal_I2C.h> 

#include <OneWire.h>

#include <DallasTemperature.h>

LiquidCrystal_I2C lcd(0x27,20,4);

#define TdsSensorPin A2

#define ONE_WIRE_BUS 7  

const int pHMeterPin = A0;

const int sensorTurbi = A1;

float volt;

float ntu;

float TempC;

int phx;

int suhux;

int ntux;

int tdsx;

#define VREF 5.0      // analog reference voltage(Volt) of the ADC

#define SCOUNT  30           // sum of sample point

int analogBuffer[SCOUNT];    // store the analog value in the array, read from ADC

int analogBufferTemp[SCOUNT];

int analogBufferIndex = 0,copyIndex = 0;

float averageVoltage = 0,tdsValue = 0,temperature = 25;

OneWire oneWire(ONE_WIRE_BUS);

DallasTemperature sensors(&oneWire);

void setup() {

  Serial.begin(9600); // Start serial communication at 9600 baud rate

  lcd.begin();  

  lcd.clear();

  lcd.noCursor();  

  pinMode(TdsSensorPin,INPUT);

  Wire.begin();  

  sensors.begin();

}

void loop() {

  int sensorValue = analogRead(pHMeterPin); // Read the analog value from sensor

  float voltage = sensorValue * (5.0 / 1023.0); // Convert to voltage

  float pH = (voltage * 3.5) + 0.5; // Convert voltage to pH value (example equation)

  volt = 0;

    for(int i=0; i<800; i++)

    {

        volt += ((float)analogRead(sensorTurbi)/1023)*5;

    }

    volt = volt/800;

    volt = round_to_dp(volt,2);

    if(volt < 2.5){

      ntu = 3000;

    }else{

      ntu = -1120.4*square(volt)+5742.3*volt-4353.8; 

    }

//==========================================

static unsigned long analogSampleTimepoint = millis();

   if(millis()-analogSampleTimepoint > 40U)     //every 40 milliseconds,read the analog value from the ADC

   {

     analogSampleTimepoint = millis();

     analogBuffer[analogBufferIndex] = analogRead(TdsSensorPin);    //read the analog value and store into the buffer

     analogBufferIndex++;

     if(analogBufferIndex == SCOUNT) 

         analogBufferIndex = 0;

   }   

   static unsigned long printTimepoint = millis();

   if(millis()-printTimepoint > 800U)

   {

      printTimepoint = millis();

      for(copyIndex=0;copyIndex<SCOUNT;copyIndex++)

        analogBufferTemp[copyIndex]= analogBuffer[copyIndex];

      averageVoltage = getMedianNum(analogBufferTemp,SCOUNT) * (float)VREF / 1024.0; // read the analog value more stable by the median filtering algorithm, and convert to voltage value

      float compensationCoefficient=1.0+0.02*(temperature-25.0);    //temperature compensation formula: fFinalResult(25^C) = fFinalResult(current)/(1.0+0.02*(fTP-25.0));

      float compensationVolatge=averageVoltage/compensationCoefficient;  //temperature compensation

      tdsValue=(133.42*compensationVolatge*compensationVolatge*compensationVolatge - 255.86*compensationVolatge*compensationVolatge + 857.39*compensationVolatge)*0.5; //convert voltage value to tds value

      //Serial.print("voltage:");

      //Serial.print(averageVoltage,2);

      //Serial.print("V   ");

      //Serial.print("TDS Value:");

      //Serial.print(tdsValue,0);

      //Serial.println("ppm");

      

     lcd.setCursor(0,2);

     lcd.print("TDS: ");

     lcd.print(tdsValue,0);

     lcd.print(" ppm  ");

   }

  sensors.requestTemperatures();

  TempC = sensors.getTempCByIndex(0); // Celcius

  

  lcd.setCursor(0,0);

  lcd.print("pH: ");

  lcd.print(pH,1);

  lcd.print("  ");

   

  lcd.setCursor(0,1);

  lcd.print("NTU: ");

  lcd.print(ntu,0);

  lcd.print("  ");

  lcd.setCursor(0,3);

  lcd.print("Suhu: ");

  lcd.print(TempC,0);

  lcd.print(" C  ");

 phx = pH;

 ntux = ntu;

 tdsx = tdsValue;

 suhux = TempC;

  Serial.print("*");

  Serial.print(phx);

  Serial.print(",");

  Serial.print(ntux);

  Serial.print(",");

  Serial.print(tdsx);

  Serial.print(",");

  Serial.print(suhux);

  Serial.println("#");

  delay(1000); // Wait for a second before reading again

}

float round_to_dp( float in_value, int decimal_place )

{

  float multiplier = powf( 10.0f, decimal_place );

  in_value = roundf( in_value * multiplier ) / multiplier;

  return in_value;

}

int getMedianNum(int bArray[], int iFilterLen) 

{

      int bTab[iFilterLen];

      for (byte i = 0; i<iFilterLen; i++)

    bTab[i] = bArray[i];

      int i, j, bTemp;

      for (j = 0; j < iFilterLen - 1; j++) 

      {

    for (i = 0; i < iFilterLen - j - 1; i++) 

          {

      if (bTab[i] > bTab[i + 1]) 

            {

    bTemp = bTab[i];

          bTab[i] = bTab[i + 1];

    bTab[i + 1] = bTemp;

       }

    }

      }

      if ((iFilterLen & 1) > 0)

  bTemp = bTab[(iFilterLen - 1) / 2];

      else

  bTemp = (bTab[iFilterLen / 2] + bTab[iFilterLen / 2 - 1]) / 2;

      return bTemp;

}

3. Program Arduino IDE ver 2

#include <Wire.h>

#include <LiquidCrystal_I2C.h> 

#include <OneWire.h>

#include <DallasTemperature.h>

LiquidCrystal_I2C lcd(0x27,20,4);

#define TdsSensorPin A2

#define ONE_WIRE_BUS 7  

const int pHMeterPin = A0;

const int sensorTurbi = A1;

float volt;

float ntu;

float TempC;

int phx;

int suhux;

int ntux;

int tdsx;

#define VREF 5.0      // analog reference voltage(Volt) of the ADC

#define SCOUNT  30           // sum of sample point

int analogBuffer[SCOUNT];    // store the analog value in the array, read from ADC

int analogBufferTemp[SCOUNT];

int analogBufferIndex = 0,copyIndex = 0;

float averageVoltage = 0,tdsValue = 0,temperature = 25;

OneWire oneWire(ONE_WIRE_BUS);

DallasTemperature sensors(&oneWire);

void setup() {

  Serial.begin(9600); // Start serial communication at 9600 baud rate

  lcd.begin();  

  lcd.clear();

  lcd.noCursor();  

  pinMode(TdsSensorPin,INPUT);

  Wire.begin();  

  sensors.begin();

}

void loop() {

  int sensorValue = analogRead(pHMeterPin); // Read the analog value from sensor

  float pH = (sensorValue - 520.5)/-36.228; 

  volt = 0;

    for(int i=0; i<800; i++)

    {

        volt += ((float)analogRead(sensorTurbi)/1023)*5;

    }

    volt = volt/800;

    volt = round_to_dp(volt,2);

    if(volt < 2.5){

      ntu = 3000;

    }else{

      ntu = -1120.4*square(volt)+5742.3*volt-4353.8; 

    }

//==========================================

static unsigned long analogSampleTimepoint = millis();

   if(millis()-analogSampleTimepoint > 40U)     //every 40 milliseconds,read the analog value from the ADC

   {

     analogSampleTimepoint = millis();

     analogBuffer[analogBufferIndex] = analogRead(TdsSensorPin);    //read the analog value and store into the buffer

     analogBufferIndex++;

     if(analogBufferIndex == SCOUNT) 

         analogBufferIndex = 0;

   }   

   static unsigned long printTimepoint = millis();

   if(millis()-printTimepoint > 800U)

   {

      printTimepoint = millis();

      for(copyIndex=0;copyIndex<SCOUNT;copyIndex++)

        analogBufferTemp[copyIndex]= analogBuffer[copyIndex];

      averageVoltage = getMedianNum(analogBufferTemp,SCOUNT) * (float)VREF / 1024.0; // read the analog value more stable by the median filtering algorithm, and convert to voltage value

      float compensationCoefficient=1.0+0.02*(temperature-25.0);    //temperature compensation formula: fFinalResult(25^C) = fFinalResult(current)/(1.0+0.02*(fTP-25.0));

      float compensationVolatge=averageVoltage/compensationCoefficient;  //temperature compensation

      tdsValue=(133.42*compensationVolatge*compensationVolatge*compensationVolatge - 255.86*compensationVolatge*compensationVolatge + 857.39*compensationVolatge)*0.5; //convert voltage value to tds value

      //Serial.print("voltage:");

      //Serial.print(averageVoltage,2);

      //Serial.print("V   ");

      //Serial.print("TDS Value:");

      //Serial.print(tdsValue,0);

      //Serial.println("ppm");

      

     lcd.setCursor(0,2);

     lcd.print("TDS: ");

     lcd.print(tdsValue,0);

     lcd.print(" ppm  ");

   }

  sensors.requestTemperatures();

  TempC = sensors.getTempCByIndex(0); // Celcius

  

  lcd.setCursor(0,0);

  lcd.print("pH: ");

  lcd.print(pH,1);

  lcd.print("  ");

   

  lcd.setCursor(0,1);

  lcd.print("NTU: ");

  lcd.print(ntu,0);

  lcd.print("  ");

  lcd.setCursor(0,3);

  lcd.print("Suhu: ");

  lcd.print(TempC,0);

  lcd.print(" C  ");

 phx = pH;

 ntux = ntu;

 tdsx = tdsValue;

 suhux = TempC;

  Serial.print("*");

  Serial.print(phx);

  Serial.print(",");

  Serial.print(ntux);

  Serial.print(",");

  Serial.print(tdsx);

  Serial.print(",");

  Serial.print(suhux);

  Serial.println("#");

  delay(1000); // Wait for a second before reading again

}

float round_to_dp( float in_value, int decimal_place )

{

  float multiplier = powf( 10.0f, decimal_place );

  in_value = roundf( in_value * multiplier ) / multiplier;

  return in_value;

}

int getMedianNum(int bArray[], int iFilterLen) 

{

      int bTab[iFilterLen];

      for (byte i = 0; i<iFilterLen; i++)

    bTab[i] = bArray[i];

      int i, j, bTemp;

      for (j = 0; j < iFilterLen - 1; j++) 

      {

    for (i = 0; i < iFilterLen - j - 1; i++) 

          {

      if (bTab[i] > bTab[i + 1]) 

            {

    bTemp = bTab[i];

          bTab[i] = bTab[i + 1];

    bTab[i + 1] = bTemp;

       }

    }

      }

      if ((iFilterLen & 1) > 0)

  bTemp = bTab[(iFilterLen - 1) / 2];

      else

  bTemp = (bTab[iFilterLen / 2] + bTab[iFilterLen / 2 - 1]) / 2;

      return bTemp;

}

4. Program ESP8266

#include <SPI.h>

#include <ESP8266WiFi.h>

#include <WiFiClientSecure.h>

#include <UniversalTelegramBot.h>

#include <ArduinoJson.h>

#define BOTtoken "8599512345:AAHWGXsuTQp5IRhkjhhgyrdrdSFDdtrdtdgh" //token bot telegram

#define idChat "1123456777" //idbot

WiFiClientSecure client;

UniversalTelegramBot bot(BOTtoken, client);

int temp;

int x = 5;

int y;

int value1;

int value2;

int value3;

int value4;

int ph;

int tds;

int ntu;

int suhu;

int datain1;

int datain2;

int datain3;

int datain4;

String dataIn;

String dt[10];

int i;

boolean parsing = false;

char ssid[] = "hotspothpku";

char pass[] = "1234567890";

void setup(){  

  

  client.setInsecure();

  Serial.begin(9600);

  Serial.print("Connecting Wifi: ");

  Serial.println(ssid);

  WiFi.mode(WIFI_STA);

  WiFi.begin(ssid, pass);

  while (WiFi.status() != WL_CONNECTED) {

    Serial.print(".");

    delay(500);

  }

  Serial.println("");

  Serial.println("WiFi connected");

  Serial.print("IP address: ");

  Serial.println(WiFi.localIP());

  delay(5000);

}

void loop() {

        

while(Serial.available()>0) {

//   dataIn="";

    char inChar = (char)Serial.read();

    dataIn += inChar;

    if (inChar == '\n') {

    parsing = true;

  }

}

if(parsing){

    parsingData();

    bot.sendChatAction(idChat, "Sedang mengetik...");

    

    String hasil = " PH : "; hasil += int(ph);

    hasil += " NTU : "; hasil += int(ntu);

    hasil += " TDS : "; hasil += int(tds);

    hasil += " SUHU : "; hasil += int(suhu);

    bot.sendMessage(idChat, hasil, "");

    Serial.print("Mengirim data sensor ke telegram");

    

  delay(200);

}

 

delay(1000);

}

void parsingData(){

int j=0;

//kirim data yang telah diterima sebelumnya

//Serial.print("data masuk : ");

//Serial.print(dataIn);

//Serial.print("\n");

//inisialisasi variabel, (reset isi variabel)

dt[j]="";

//proses parsing data

for(i=1;i<dataIn.length();i++){

//pengecekan tiap karakter dengan karakter (#) dan (,)

if ((dataIn[i] == '#') || (dataIn[i] == ','))

{

//increment variabel j, digunakan untuk merubah index array penampung

j++;

dt[j]="";       //inisialisasi variabel array dt[j]

}

else

{

//proses tampung data saat pengecekan karakter selesai.

dt[j] = dt[j] + dataIn[i];

}

}

 datain1 = dt[0].toInt();

 datain2 = dt[1].toInt();

 datain3 = dt[2].toInt();

 datain4 = dt[3].toInt();

 Serial.print(datain1);Serial.print("||"); Serial.print(datain2);Serial.print("||"); Serial.print(datain3);Serial.print("||"); Serial.println(datain4);

 

 ph = datain1;

 ntu = datain2;

 tds = datain3;

 suhu = datain4;

 

} 

 

 

5. VIDEO HASILNYA