Ordinateur_Aquarium/Soft/ESP12F/Ordinateur/Ordinateur.ino

#include "ESP12F.h"
#include <WidgetRTC.h>

#define DEBUG

WidgetTerminal terminal(V50);

uint8_t transmition(uint8_t *in, uint8_t nbTr, uint8_t *out) {
  int i;
  
  out[0]=0;
  out[1]=0;
  out[2]=0;
  out[3]=0;
  out[4]=0;
  out[5]=0;
  out[6]=0;
  out[7]=0;
  
  for (i = 0; i < nbTr; i++) {
    Serial.write(in[i]);
  }
  for (; i < SIZEMES; i++) {
    Serial.write(0xAA);
  }

  int time = 0;
  while (Serial.available() < SIZEMES) {
    time++;
    if (time > 1000000) {
      #ifdef DEBUG
      terminal.print("erreur trans delay");
      terminal.flush();
      #endif
      return ESP_NOK;
    }
  }
  Serial.readBytes(out, SIZEMES);

  if (out[0] & MASKMES != in[0] & MASKMES) {
    #ifdef DEBUG
    terminal.print("erreur trans diff");
    terminal.flush();
    #endif
    return ESP_NOK;
  }

	if (out[0] & MASKERR != ESP_OK){
    #ifdef DEBUG
    terminal.print("erreur trans HAL_ERROR");
    terminal.flush();
    #endif
		return ESP_NOK;
	}
	
  return ESP_OK;
}

float convTemp(uint8_t ent) {
  return (((float)ent) / 10.0) + 10.0;
}

float convPH(uint8_t ent) {
  //TODO
  return 8.2;
}

int convSalinity(uint8_t ent) {
  //TODO
  return 1025;
}


void SyncRTC() {
  uint8_t nbTr = 8;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];

  in[0] = SYNCRTC;
  in[1] = year() - 2000;
  in[2] = month();
  in[3] = day();
  uint8_t weekd = weekday() - 1;
  if (weekday() == 1) weekd = 0;
  in[4] = weekd;
  in[5] = hour();
  in[6] = minute();
  in[7] = second();

  if (transmition(in, nbTr, out)!=ESP_OK) {
    exit;// TODO test si retour NOK
  }
}

uint8_t readAction(){
	uint8_t nbTr = 1;
	uint8_t in[nbTr];
	uint8_t out[SIZEMES];
  
	in[0] = READACTI;
  if (transmition(in, nbTr, out)!=ESP_OK){
      #ifdef DEBUG
      terminal.print("READACTI NOK");
      terminal.flush();
      #endif
      
      return ESP_NOK;
    }
     
  Blynk.virtualWrite(V20, (out[1] &  ACTIREM) >> DECALREME);
  Blynk.virtualWrite(V21, (out[1] &  ACTIECU) >> DECALECUM);
  Blynk.virtualWrite(V22, (out[1] &  ACTICHA) >> DECALCHAU);
  Blynk.virtualWrite(V23, (out[1] &  ACTIBGE) >> DECALBRAG);
  Blynk.virtualWrite(V24, (out[1] &  ACTIBR1) >> DECALBRA1);
  Blynk.virtualWrite(V25, (out[1] &  ACTIBR2) >> DECALBRA2);
  Blynk.virtualWrite(V26, (out[1] &  ACTI0SO) >> DECALOSMO);
  Blynk.virtualWrite(V27, (out[1] &  ACTINOU) >> DECALNOUR);
  Blynk.virtualWrite(V28, (out[2] &  ACTILUM) >> DECALLUM);
  Blynk.virtualWrite(V29, (out[2] &  ACTIOSM) >> DECALOSMM);

  #ifdef DEBUG
  terminal.print("READACTI OK");
  terminal.flush();
  #endif
  return ESP_OK;
}

uint8_t readStatus(){  
  uint8_t nbTr = 1;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];

  in[0] = STATUS;
  if (transmition(in, nbTr, out)!=ESP_OK){
    #ifdef DEBUG
    terminal.print("READSTATUS NOK");
    terminal.flush();
    #endif
    return ESP_NOK;
  }
    
  
  if (out[5] & 0x80 == 0x80)
    TechBas.on();
  else
    TechBas.off();

  if (out[5] & 0x40 == 0x40)
    TechHau.on();
  else
    TechHau.off();

  if (out[5] & 0x20 == 0x20)
    CuveHau.on();
  else
    CuveHau.off();

  if (out[5] & 0x10 == 0x10)
    Reserve.on();
  else
    Reserve.off();

  float air = convTemp(out[1]);
  float eau = convTemp(out[2]);

  Blynk.virtualWrite(V6, air);
  //TODO a changer les notif
  if (air <= 18.0)
	Blynk.notify("Temp air < 18°C");
  if (air >= 29.0)
	Blynk.notify("Temp air > 29°C");

  Blynk.virtualWrite(V7, eau);
  //TODO a changer les notif
  
  if (eau <= 24.0)
  Blynk.notify("Temp eau < 24°C");
  if (eau >= 27.0)
  Blynk.notify("Temp eau > 27°C");

  Blynk.virtualWrite(V8, convPH(out[3]));
  //TODO notif PH

  Blynk.virtualWrite(V9, convSalinity(out[4]));
  //TODO notif sel


  //TODO faire les notif

  //TODO faire les erreurs

  #ifdef DEBUG
  terminal.print("READSTATUS OK");
  terminal.flush();
  #endif
  return ESP_OK;
}

uint8_t readVentil(){
	uint8_t nbTr = 1;
	uint8_t in[nbTr];
	uint8_t out[SIZEMES];


	
	in[0] = READVENT;
	if (transmition(in, nbTr, out)!=ESP_OK){
	  #ifdef DEBUG
    terminal.print("READVENT NOK"); 
    terminal.flush();
    #endif
	  return ESP_NOK;
	}

  Blynk.virtualWrite(V40, (out[1] &  0xF0) >> 4);
  Blynk.virtualWrite(V41, (out[1] &  0x0F) >> 0);
  
  #ifdef DEBUG
  terminal.print("READVENT OK"); 
  terminal.flush();
  #endif
  return ESP_OK;
}

void Status() {
  
  #ifdef DEBUG
  terminal.print("New Status");
  terminal.flush();
  #endif
  
	readStatus();

  readAction();

	readVentil();

  #ifdef DEBUG
  terminal.print("fin Status");
  terminal.flush();
  #endif
}


/* **************************************************************
  Fonction Blynk
 ***************************************************************/

//Remonter
BLYNK_WRITE(V20){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALREME);
  in[2]=0x00;
  in[3] = param.asInt();
  if (transmition(in,nbTr,out)==ESP_OK){
	  ;//TODO pas d'erreur
  }
}

//Ecumeur
BLYNK_WRITE(V21){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALECUM);
  in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Chauffage
BLYNK_WRITE(V22){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALCHAU);
  in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}


//Brassage Général
BLYNK_WRITE(V23){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALBRAG);
    in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Brassage1
BLYNK_WRITE(V24){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALBRA1);
    in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Brassage 2
BLYNK_WRITE(V25){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALBRA2);
  in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Osmolateur ON/OFF
BLYNK_WRITE(V26){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALOSMO);
    in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Nourrisage
BLYNK_WRITE(V27){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 | (1 << DECALNOUR);
    in[2]=0x00;
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Osmolateur Manuelle
BLYNK_WRITE(V28){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00 ;
  in[2]=0x00| (1 << DECALOSMM);
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//Lumiere decante
BLYNK_WRITE(V29){
  uint8_t nbTr = 4;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=WRITACTI;
  in[1]=0x00;
    in[2]=0x00| (1 << DECALLUM);
  in[3] = param.asInt();
  transmition(in,nbTr,out);
}

//delais Brassage
BLYNK_WRITE(V42){
  uint8_t nbTr = 2;
  uint8_t in[nbTr];
  uint8_t out[SIZEMES];
  in[0]=DELAYBRA;
  in[1] = param.asInt();
  transmition(in,nbTr,out);
}


/* **************************************************************
	Fonction main
 ***************************************************************/



void setup() {
  Serial.begin(38400);

  Blynk.begin(auth, ssid, pass, IPAddress(192, 168, 1, 18), 8081);
  
  //timerRTC.setInterval(1000L * 3600, SyncRTC); // une synchro de la RTC par heure
  timerStatus.setInterval(10000L, Status); // un Status toute les 10 secs
  
  terminal.clear();
  
}


void loop() {
  Blynk.run();

  //timerRTC.run();
  timerStatus.run();
  
}