Peristatique/Soft/MCUnode/PeristatiqueV3/PeristatiqueV3.ino

#include <BlynkSimpleEsp8266.h>
#include <TimeLib.h>
#include <WidgetRTC.h>

#define AQUAGRA
//#define AQUAZOA

#ifdef AQUAGRA
  char auth[] = "hneeH3NrG9r-e1jrrECsZiB_-TUkU6z7"; //220L
#elif AQUAZOA
  char auth[] = "JDoe08avtg2zR73kwk4OiSKk9C7tffjM"; //70L
#endif


char ssid[] = "Livebox-7C2C";
char pass[] = "566C61F61F9C925C9F3D7D79E6";

WidgetRTC rtc;
BlynkTimer timer;
WidgetTerminal terminal(V60);

//************************************************************************
//                Variable Global perso
//************************************************************************
#ifdef AQUAGRA
  #define RESERVE 1200
  #define LITRE 220
  #define FACTEURML 635 //Temps d'allumage de la pompe en ms pour distribuer 1ml
  #define RESERVEMIN 100
  #define STARTCa 16
  #define STARTKh 30
  #define STARTMg 7
  #define STARTEasy 1.8
#elif AQUAZOA
  #define RESERVE 450
  #define LITRE 70
  #define FACTEURML 200//todo //Temps d'allumage de la pompe en ms pour distribuer 1ml
  #define RESERVEMIN 50
  #define STARTCa 16
  #define STARTKh 30
  #define STARTMg 7
  #define STARTEasy 0.6
#endif

#define POMPE0 0
#define POMPE1 1
#define POMPE2 2
#define POMPE3 3
#define POMPE4 4
#define POMPE5 5

//#define POMPE6 6 pin 6 cree une erreur
//#define POMPE7 7

//nombre de ml a distribuer pour remonter de +1 (mg ou kh) par litre d'eau
#define FACTEUR0 0.0057 //FACTEUR CA
#define FACTEUR1 0.36 //0.36ml/L = +1KH
#define FACTEUR3 0.02 //FACTEUR MG

const int PINPOMPE0 = 5;
const int PINPOMPE1 = 4;
const int PINPOMPE2 = 16;
const int PINPOMPE3 = 14;
const int PINPOMPE4 = 12;
const int PINPOMPE5 = 13;

//6 et 7 cree une erreur 
const int PINPOMPE6 = 9;
const int PINPOMPE7 = 10;

float Mesure0, Mesure1, Mesure2, Mesure3, Mesure4, Mesure5, Mesure6, Mesure7;
float ML0, ML1, ML2, ML3, ML4, ML5, ML6, ML7 ;
float Cible0, Cible1, Cible2, Cible3, Cible4, Cible5, Cible6, Cible7 ;
bool Auto0, Auto1, Auto2, Auto3, Auto4, Auto5, Auto6, Auto7 ;
float Reserve0, Reserve1, Reserve2, Reserve3, Reserve4, Reserve5, Reserve6, Reserve7 ;
float MLForce0, MLForce1, MLForce2, MLForce3, MLForce4, MLForce5, MLForce6, MLForce7 ;
int dist;
  
//************************************************************************
//                Fonction Seul
//************************************************************************
void Ft_Timer() {
  int Hmin = hour() * 60 + minute();  
  switch(Hmin){
  case 0: //Calcium
    dist=0;
        AutoDistribue0(ML0);
    break;
  case 360: //Calcium
    dist=1;
        AutoDistribue0(ML0);
    break;
  case 720: //Calcium
    dist=2;
        AutoDistribue0(ML0);
    break;
  case 1080: //Calcium
    dist=3;
    AutoDistribue0(ML0);
    break;
  case 90: //KH
  dist=0;
    AutoDistribue1(ML1);
    break;
  case 450: //KH
  dist=1;
    AutoDistribue1(ML1);
    break;
  case 810: //KH
  dist=2;
    AutoDistribue1(ML1);
    break;
  case 1170: //KH
  dist=3;
  AutoDistribue1(ML1);
    break;
  case 180: //mineral
  dist=0;
      AutoDistribue2(ML2);
    break;
  case 540: //mineral
  dist=1;
      AutoDistribue2(ML2);
    break;
  case 900: //mineral
  dist=2;
      AutoDistribue2(ML2);
    break;
  case 1260: //mineral
  dist=3;
    AutoDistribue2(ML2);
    break;
  case 270://mg
  dist=0;
  AutoDistribue3(ML3);
    break;
  case 630://mg
  dist=1;
  AutoDistribue3(ML3);
    break;
  case 990://mg
  dist=2;
  AutoDistribue3(ML3);
    break;
  case 1350://mg
  dist=3;
    AutoDistribue3(ML3);
    break;
  case 1020://EasyReef
    AutoDistribue4(ML4);
    break;
  }
}

BLYNK_CONNECTED() {
  char message[30];
  sprintf(message, "\nnew Connection\n");
  terminal.print(message);
  terminal.flush();

  rtc.begin();

  Blynk.syncAll();
}

BLYNK_WRITE(V60){
  if (String("Ca") == param.asStr()){
    Blynk.virtualWrite(V3, STARTCa);
    ML0=STARTCa;
  }
  if (String("Kh") == param.asStr()){
    Blynk.virtualWrite(V13, STARTKh);
    ML1=STARTKh;
  }
  if (String("Mi") == param.asStr()){
    Blynk.virtualWrite(V23, (ML0+ML1)/2);
    ML2=(ML0+ML1)/2;
  }
  if (String("Mg") == param.asStr()){
    Blynk.virtualWrite(V33, STARTMg); 
    ML3=STARTMg;
  }
}


void setup(){

  //Pin Setup
  
  pinMode(PINPOMPE0, OUTPUT);
  pinMode(PINPOMPE1, OUTPUT);
  pinMode(PINPOMPE2, OUTPUT);
  pinMode(PINPOMPE3, OUTPUT);
  pinMode(PINPOMPE4, OUTPUT);
  pinMode(PINPOMPE5, OUTPUT);
  
  digitalWrite(PINPOMPE0, LOW);
  digitalWrite(PINPOMPE1, LOW);
  digitalWrite(PINPOMPE2, LOW);
  digitalWrite(PINPOMPE3, LOW);
  digitalWrite(PINPOMPE4, LOW);
  digitalWrite(PINPOMPE5, LOW);

  

  Blynk.begin(auth, ssid, pass, IPAddress(192, 168, 1, 18), 8081);
  
  setSyncInterval(10 * 60); // Sync interval in seconds (10 minutes)

  timer.setInterval(1000L*60, Ft_Timer);
}

void loop(){
  Blynk.run();
  timer.run();
}
//************************************************************************
//                Fonction Calcium
//************************************************************************

void AutoDistribue0(float ml){
  
  if (Auto0) {
    if(((ML0/4)*FACTEURML)>(1000*4)){
      Active0(ML0/4);
    }
    else if((((ML0/2)*FACTEURML)>(1000*2))&(dist==0|dist==2)){
      Active0(ML0/2);
      }
    else if (dist==0){
      Active0(ML0);
    }
  }
  else{
    Blynk.notify("Calcium est Arreter");
  }
}

void Active0(float ml) {
  digitalWrite(PINPOMPE0, HIGH);
  delay(FACTEURML * ml);
  digitalWrite(PINPOMPE0, LOW);
  Reserve0=Reserve0-ml;
  Blynk.virtualWrite(V4, Reserve0);
  char message[30];
  sprintf(message, "Distribution %.1fml de Calcium a %d:%d\n", ml,hour(),minute());
  terminal.print(message);
  terminal.flush();
  if(Reserve0<RESERVEMIN)
    Blynk.notify("Penser a remettre du Calcium");
}

//Mesure
BLYNK_WRITE(V0) {
  if(Mesure0==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Mesure0 = param.asFloat();
    return;
  }
  Mesure0 = param.asFloat();
  
  ML0  = ML0 + (((ML0/Mesure0)* Cible0 - ML0)/4.0);
  MLForce0 = (Cible0-Mesure0)*FACTEUR0*LITRE;

  
  if(MLForce0<0)
    MLForce0=0;
  
  ML2 = (ML1+ML0)/2.0;
  Blynk.virtualWrite(V23, ML2);
  Blynk.virtualWrite(V3, ML0);
  Blynk.virtualWrite(V7, MLForce0);
}

//Cible
BLYNK_WRITE(V1) {
  if(Cible0==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Cible0 = param.asFloat();
    return;
  }
  Cible0 = param.asFloat();
  ML0 = ML0 +(((ML0/Mesure0)* Cible0- ML0)/4.0);
  ML2 = (ML1+ML0)/2.0;
  
  Blynk.virtualWrite(V23, ML2);
  Blynk.virtualWrite(V3, ML0);
}

//En route
BLYNK_WRITE(V2) {
  if ( param.asInt()){
    Auto0 = true;
  }
  else{
    Auto0 = false;
  }
}

BLYNK_WRITE(V3){
  ML0=param.asFloat();
  Blynk.virtualWrite(V3, ML0);
}

BLYNK_WRITE(V4){
  Reserve0=param.asFloat();
  Blynk.virtualWrite(V4, Reserve0);
}


//RAZ Reserve
BLYNK_WRITE(V5){
  if(param.asInt()){
    Reserve0=RESERVE;
    Blynk.virtualWrite(V4, Reserve0);
  }
}

//Forcé4
BLYNK_WRITE(V6){
  if(param.asInt()){
    Active0(4.0);
  }
}

//NB/Forcé
BLYNK_WRITE(V7){
  MLForce0=param.asFloat();
}

//Forcé
BLYNK_WRITE(V8){
  if ( param.asInt()){
    Active0(MLForce0);
  }
}



//************************************************************************
//                Fonction KH
//************************************************************************

void AutoDistribue1(float ml){
  if (Auto1) {
    if(((ML1/4)*FACTEURML)>(1000*4)){
      Active1(ML1/4);
    }
    else if((((ML1/2)*FACTEURML)>(1000*2))&(dist==0|dist==2)){
      Active1(ML1/2);
      }
    else if (dist==0){
      Active1(ML1);
    }
  }
  else{
    Blynk.notify("KH est Arreter");
  }
}

void Active1(float ml) {
  digitalWrite(PINPOMPE1, HIGH);
  delay(FACTEURML * ml);
  digitalWrite(PINPOMPE1, LOW);
  Reserve1=Reserve1-ml;
  Blynk.virtualWrite(V14, Reserve1);
  char message[30];
  sprintf(message, "Distribution %.1fml de KH a %d:%d\n", ml,hour(),minute());
  terminal.print(message);
  terminal.flush();
  if(Reserve1<RESERVEMIN)
    Blynk.notify("Penser a remettre du KH");
}

//Mesure
BLYNK_WRITE(V10) {
    if(Mesure1==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Mesure1 = param.asFloat();
    return;
  }
  Mesure1 = param.asFloat();

  ML1  = ML1 + (((ML1/Mesure1)* Cible1 - ML1)/4.0);
  MLForce1 = (Cible1-Mesure1)*FACTEUR1*LITRE;
  if(MLForce1<0)
    MLForce1=0;
  
  ML2 = (ML1+ML0)/2.0;
  Blynk.virtualWrite(V23, ML2);
  Blynk.virtualWrite(V13, ML1);
  Blynk.virtualWrite(V17, MLForce1);
}

//Cible
BLYNK_WRITE(V11) {
      if(Cible1==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Cible1 = param.asFloat();
    return;
  }
  Cible1 = param.asFloat();
  ML1 = ML1 +(((ML1/Mesure1) * Cible1- ML1)/4.0);
  
  ML2 = (ML0+ML1)/2.0;
  
  Blynk.virtualWrite(V23, ML2);
  Blynk.virtualWrite(V13, ML1);
}

//En route
BLYNK_WRITE(V12) {
  if ( param.asInt()){
    Auto1 = true;
  }
  else{
    Auto1 = false;
  }
}

BLYNK_WRITE(V13){
  ML1=param.asFloat();
  Blynk.virtualWrite(V13, ML1);
}

BLYNK_WRITE(V14){
   Reserve1=param.asFloat();
  Blynk.virtualWrite(V14, Reserve1);
}


//RAZ Reserve
BLYNK_WRITE(V15){
  if(param.asInt()){
    Reserve1=RESERVE;
    Blynk.virtualWrite(V14, Reserve1);
  }
}

//Forcé4
BLYNK_WRITE(V16){
  if(param.asInt()){
    Active1(4.0);
  }
}

//NB/Forcé
BLYNK_WRITE(V17){
  MLForce1=param.asFloat();
}

//Forcé
BLYNK_WRITE(V18){
  if ( param.asInt()){
    Active1(MLForce1);
  }
}

//************************************************************************
//                Fonction Mineral
//************************************************************************

void AutoDistribue2(float ml){
  if (Auto2) {
    if(((ML2/4)*FACTEURML)>(1000*4)){
      Active2(ML2/4);
    }
    else if((((ML2/2)*FACTEURML)>(1000*2))&(dist==0|dist==2)){
      Active2(ML2/2);
      }
    else if (dist==0){
      Active2(ML2);
    }
  }
  else{
    Blynk.notify("Mineral est Arreter");
  }
}

void Active2(float ml) {
  digitalWrite(PINPOMPE2, HIGH);
  delay(FACTEURML * ml);
  digitalWrite(PINPOMPE2, LOW);
  Reserve2=Reserve2-ml;
  Blynk.virtualWrite(V24, Reserve2);
  char message[30];
  sprintf(message, "Distribution %.1fml de Mineral a %d:%d\n", ml,hour(),minute());
  terminal.print(message);
  terminal.flush();
  if(Reserve2<RESERVEMIN)
    Blynk.notify("Penser a remettre du Mineral");
}

//En route
BLYNK_WRITE(V22) {
  if ( param.asInt()){
    Auto2 = true;
  }
  else{
    Auto2 = false;
  }
}

BLYNK_WRITE(V23){
  ML2=param.asFloat();
  Blynk.virtualWrite(V23, ML2);
}

BLYNK_WRITE(V24){
  Reserve2=param.asFloat();
  Blynk.virtualWrite(V24, Reserve2);
}


//RAZ Reserve
BLYNK_WRITE(V25){
  if(param.asInt()){
    Reserve2=RESERVE;
    Blynk.virtualWrite(V24, Reserve2);
  }
}

//Forcé4
BLYNK_WRITE(V26){
  if(param.asInt()){
    Active2(4.0);
  }
}

//NB/Forcé
BLYNK_WRITE(V27){
  MLForce2=param.asFloat();
}

//Forcé
BLYNK_WRITE(V28){
  if ( param.asInt()){
    Active2(MLForce2);
  }
}

//************************************************************************
//                Fonction Magnesium
//************************************************************************

void AutoDistribue3(float ml){
  if (Auto3) {
    if(((ML3/4)*FACTEURML)>(1000*4)){
      Active3(ML3/4);
    }
    else if((((ML3/2)*FACTEURML)>(1000*2))&(dist==0|dist==2)){
      Active3(ML3/2);
      }
    else if (dist==0){
      Active3(ML3);
    }
  }
  else{
    Blynk.notify("Magnesium est Arreter");
  }
}

void Active3(float ml) {
  digitalWrite(PINPOMPE3, HIGH);
  delay(FACTEURML * ml);
  digitalWrite(PINPOMPE3, LOW);
  Reserve3=Reserve3-ml;
  Blynk.virtualWrite(V34, Reserve3);
  char message[30];
  sprintf(message, "Distribution %.1fml de Magnesium  a %d:%d\n", ml,hour(),minute());
  terminal.print(message);
  terminal.flush();
  if(Reserve3<RESERVEMIN)
    Blynk.notify("Penser a remettre du Magnesium");
}

//Mesure
BLYNK_WRITE(V30) {
        if(Mesure3==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Mesure3 = param.asFloat();
    return;
  }
  Mesure3 = param.asFloat();
  ML3  = ML3 + (((ML3/Mesure3)* Cible3 - ML3)/4.0);
  MLForce3 = (Cible3-Mesure3)*FACTEUR3*LITRE;
  if(MLForce3<0)
    MLForce3=0;

  Blynk.virtualWrite(V33, ML3);
  Blynk.virtualWrite(V37, MLForce3);
}

//Cible
BLYNK_WRITE(V31) {
  if(Cible3==0){//Si nouvelle connection on recupere juste la valeur enregistrer sur le server
    Cible3 = param.asFloat();
    return;
  }
  Cible3 = param.asFloat();
  ML3 = ML3 +(((ML3/Mesure3)* Cible3- ML3)/4.0);
  Blynk.virtualWrite(V23, ML2);
  Blynk.virtualWrite(V33, ML3);
}

//En route
BLYNK_WRITE(V32) {
  if ( param.asInt()){
    Auto3 = true;
  }
  else{
    Auto3 = false;
  }
}

BLYNK_WRITE(V33){
  ML3=param.asFloat();
  Blynk.virtualWrite(V33, ML3);
}

BLYNK_WRITE(V34){
  Reserve3=param.asFloat();
  Blynk.virtualWrite(V34, Reserve3);
}


//RAZ Reserve
BLYNK_WRITE(V35){
  if(param.asInt()){
    Reserve3=RESERVE;
    Blynk.virtualWrite(V34, Reserve3);
  }
}

//Forcé4
BLYNK_WRITE(V36){
  if(param.asInt()){
    Active3(4.0);
  }
}

//NB/Forcé
BLYNK_WRITE(V37){
  MLForce3=param.asFloat();
}

//Forcé
BLYNK_WRITE(V38){
  if ( param.asInt()){
    Active3(MLForce3);
  }
}

//************************************************************************
//                Fonction EASYREEF
//************************************************************************

void AutoDistribue4(float ml){
  if (Auto4) {
  Active4(ML4);
  }
  else{
    Blynk.notify("EASYReef est Arreter");
  }
}

void Active4(float ml) {
  digitalWrite(PINPOMPE4, HIGH);
  delay(FACTEURML * ml);
  digitalWrite(PINPOMPE4, LOW);
  Reserve4=Reserve4-ml;
  Blynk.virtualWrite(V44, Reserve4);
  char message[30];
  sprintf(message, "Distribution %.1fml de EASYreef a %d:%d\n", ml,hour(),minute());
  terminal.print(message);
  terminal.flush();
  if(Reserve4<40)
    Blynk.notify("Penser a remettre de l'EasyReef");
}

//En route
BLYNK_WRITE(V42) {
  if ( param.asInt()){
    Auto4 = true;
  }
  else{
    Auto4 = false;
  }
}

BLYNK_WRITE(V43){
  ML4=param.asFloat();
  Blynk.virtualWrite(V43, ML4);
}

BLYNK_WRITE(V44){
   Reserve4=param.asFloat();
  Blynk.virtualWrite(V44, Reserve4);
}


//RAZ Reserve
BLYNK_WRITE(V45){
  if(param.asInt()){
    Reserve4=250;
    Blynk.virtualWrite(V44, Reserve4);
  }
}

//Forcé4
BLYNK_WRITE(V46){
  if(param.asInt()){
    Active4(1.0);
  }
}