SINAPTEC: Tutorial #6 ESP8266 - MySQL + PHP en Servidor Local

domingo, 18 de junio de 2017

Tutorial #6 ESP8266 - MySQL + PHP en Servidor Local

En este video sobre de IOT (internet de las cosas) explico cómo enviar la temperatura que lee un LM35 a un servidor local Apache usando una HTTP REQUEST con el método POST a un archivo PHP que es el encargado de insertar esa temperatura y otros datos en la base de datos. También explico cómo crear esa base de datos MySQL usando la herramienta phpMyAdmin incluida en el servidor.

enviardatos.php:

<?php
$conexion = mysql_connect("localhost", "root", "root");
mysql_select_db("tutorial", $conexion);
mysql_query("SET NAMES 'utf8'");

$chipid = $_POST ['chipid'];
$temperatura = $_POST ['temperatura'];

mysql_query("INSERT INTO `tutorial`.`tabla` (`id`, `chipId`, `fecha`, `temperatura`) VALUES (NULL, '$chipid', CURRENT_TIMESTAMP, '$temperatura');");

mysql_close();

echo "Datos ingresados correctamente.";
?>

formulario.html:

<!DOCTYPE html>
<html>
<head>
<title>Formulario</title>
</head>
<body>
<form action="enviardatos.php" method="POST">
ChipID:<br>
<input type="text" name="chipid" ><br>
Temperatura:<br>
<input type="text" name="temperatura" ><br>
<input type="submit" name="Enviar" >
</body>
</html>

Código Fuente:

#include <ESP8266WiFi.h>
#include <WiFiClient.h> 

//-------------------VARIABLES GLOBALES--------------------------
int contconexion = 0;

const char *ssid = "----";
const char *password = "----";

unsigned long previousMillis = 0;

char host[48];
String strhost = "192.168.1.115";
String strurl = "/tutorial/enviardatos.php";
String chipid = "";

//-------Función para Enviar Datos a la Base de Datos SQL--------

String enviardatos(String datos) {
  String linea = "error";
  WiFiClient client;
  strhost.toCharArray(host, 49);
  if (!client.connect(host, 80)) {
    Serial.println("Fallo de conexion");
    return linea;
  }

  client.print(String("POST ") + strurl + " HTTP/1.1" + "\r\n" + 
               "Host: " + strhost + "\r\n" +
               "Accept: */*" + "*\r\n" +
               "Content-Length: " + datos.length() + "\r\n" +
               "Content-Type: application/x-www-form-urlencoded" + "\r\n" +
               "\r\n" + datos);           
  delay(10);             
  
  Serial.print("Enviando datos a SQL...");
  
  unsigned long timeout = millis();
  while (client.available() == 0) {
    if (millis() - timeout > 5000) {
      Serial.println("Cliente fuera de tiempo!");
      client.stop();
      return linea;
    }
  }
  // Lee todas las lineas que recibe del servidro y las imprime por la terminal serial
  while(client.available()){
    linea = client.readStringUntil('\r');
  }  
  Serial.println(linea);
  return linea;
}

//-------------------------------------------------------------------------

void setup() {

  // Inicia Serial
  Serial.begin(115200);
  Serial.println("");

  Serial.print("chipId: "); 
  chipid = String(ESP.getChipId());
  Serial.println(chipid); 

  // Conexión WIFI
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED and contconexion <50) { //Cuenta hasta 50 si no se puede conectar lo cancela
    ++contconexion;
    delay(500);
    Serial.print(".");
  }
  if (contconexion <50) {
      //para usar con ip fija
      IPAddress ip(192,168,1,156); 
      IPAddress gateway(192,168,1,1); 
      IPAddress subnet(255,255,255,0); 
      WiFi.config(ip, gateway, subnet); 
      
      Serial.println("");
      Serial.println("WiFi conectado");
      Serial.println(WiFi.localIP());
  }
  else { 
      Serial.println("");
      Serial.println("Error de conexion");
  }
}

//--------------------------LOOP--------------------------------
void loop() {

  unsigned long currentMillis = millis();

  if (currentMillis - previousMillis >= 10000) { //envia la temperatura cada 10 segundos
    previousMillis = currentMillis;
    int analog = analogRead(17);
    float temp = analog*0.322265625;
    Serial.println(temp);
    enviardatos("chipid=" + chipid + "&temperatura=" + String(temp, 2));
  }
}

13 comentarios:

Andrés18 de junio de 2017, 20:23
Excelente! Un compacto resumen base para muchos posibles proyectos.
Muchas gracias!
ResponderEliminar
Respuestas
PEDROTRONI21 de junio de 2017, 7:42
Gracias por el tutorial amigo
ResponderEliminar
Respuestas
Gustavo Gomez15 de julio de 2017, 19:35
Muchas gracias por el tutorial, muy completo, yo lo modifique con el sensor de temperatura y humedad DHT11, espero a alguien le sirva, hay que modificar los php y la base de datos con un nuevo campo humedad

#include
#include
#include

//-------------------VARIABLES GLOBALES--------------------------
int contconexion = 0;

const char *ssid = "gustavo";
const char *password = "582413gusalgora";
#define DHTPIN 2
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);
unsigned long previousMillis = 0;

char host[48];
String strhost = "192.168.0.104";
String strurl = "/iot/enviardatos.php";
String chipid = "";

//-------Función para Enviar Datos a la Base de Datos SQL--------

String enviardatos(String datos) {
String linea = "error";
WiFiClient client;
strhost.toCharArray(host, 49);
if (!client.connect(host, 80)) {
Serial.println("Fallo de conexion a MySql");
return linea;
}

client.print(String("POST ") + strurl + " HTTP/1.1" + "\r\n" +
"Host: " + strhost + "\r\n" +
"Accept: */*" + "*\r\n" +
"Content-Length: " + datos.length() + "\r\n" +
"Content-Type: application/x-www-form-urlencoded" + "\r\n" +
"\r\n" + datos);
delay(10);

Serial.print("Enviando datos a SQL...");

unsigned long timeout = millis();
while (client.available() == 0) {
if (millis() - timeout > 5000) {
Serial.println("Cliente fuera de tiempo!");
client.stop();
return linea;
}
}
// Lee todas las lineas que recibe del servidro y las imprime por la terminal serial
while(client.available()){
linea = client.readStringUntil('\r');
}
Serial.println(linea);
return linea;
}

//-------------------------------------------------------------------------

void setup() {

// Inicia Serial
Serial.begin(115200);
Serial.println("");

Serial.print("chipId: ");
chipid = String(ESP.getChipId());
Serial.println(chipid);

// Conexión WIFI
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED and contconexion <50) { //Cuenta hasta 50 si no se puede conectar lo cancela
++contconexion;
delay(500);
Serial.print(".");
}
if (contconexion <50) {
//para usar con ip fija
IPAddress ip(192,168,0,156);
IPAddress gateway(192,168,0,1);
IPAddress subnet(255,255,255,0);
WiFi.config(ip, gateway, subnet);

Serial.println("");
Serial.println("WiFi conectado");
Serial.println(WiFi.localIP());
}
else {
Serial.println("");
Serial.println("Error de conexion");
}
}

//--------------------------LOOP--------------------------------
void loop() {

unsigned long currentMillis = millis();

if (currentMillis - previousMillis >= 10000) { //envia la temperatura cada 10 segundos
previousMillis = currentMillis;

float t = dht.readTemperature();
float h = dht.readHumidity();
if (isnan(h) || isnan(t)) {
Serial.println("Falla al leer el sensor DHT11!");
return;
}
Serial.println(t);
Serial.println(h);
enviardatos("chipid=" + chipid + "&temperatura=" + String(t, 2) + "&humedad=" + String(h, 2));
}
}
ResponderEliminar
Gustavo Gomez15 de julio de 2017, 19:36
Este comentario ha sido eliminado por el autor.
ResponderEliminar
Respuestas
Unknown1 de agosto de 2017, 21:02
Este comentario ha sido eliminado por el autor.
ResponderEliminar
miguel0911951 de agosto de 2017, 21:03
Una pregunta el tipo de datos de la DB debe ser igual al tipo de dato que se va a enviar? Quiero probarlo con un led que prende y apaga 1 y 0, convertirlo a string para que solo sea 1 en texto pero al mandarlo dice "fallo de conexion" te mando el LOOP, el insert de DB y el tipo de dato al que quiero enviar.

void loop() {

unsigned long currentMillis = millis();

if (currentMillis - previousMillis >= 10000) {
previousMillis = currentMillis;
int a=0;

digitalWrite(leda,HIGH);
a=digitalRead(4);
delay(1000);
digitalWrite(leda,LOW);
delay(1000);
Serial.println(a);
enviardatos("chipid=" + chipid + "&click=" + String(a));
}

////INSERT

$chipid = $_POST['chipid'];
$click=$_POST['click'];

$insertar="INSERT INTO `cosos`.`mee` (`noact`, `chipid`, `estado`, `fecha`) VALUES (NULL, '$chipid', '$click', CURRENT_TIMESTAMP);";

//// BD tipo de dato de estado

estado varchar(50);
ResponderEliminar
Respuestas

Añadir comentario

Cargar más...