Estação Meteorológica IoT

<?php
require_once 'config.php';
setCorsHeaders();

$method = $_SERVER['REQUEST_METHOD'];

try {
    $pdo = getConnection();
    
    // GET: Enviar os dados ao Gráfico do Dashboard
    if ($method === 'GET') {
        $filtro = $_GET['filtro'] ?? 'hoje';
        
        $sql = "SELECT * FROM estacao_meteorologica WHERE 1=1";
        
        switch ($filtro) {
            case 'hoje': $sql .= " AND DATE(data_registro) = CURDATE()"; break;
            case 'semana': $sql .= " AND data_registro >= DATE_SUB(CURDATE(), INTERVAL 7 DAY)"; break;
            case 'mes': $sql .= " AND data_registro >= DATE_SUB(CURDATE(), INTERVAL 30 DAY)"; break;
            case 'ano': $sql .= " AND data_registro >= DATE_SUB(CURDATE(), INTERVAL 365 DAY)"; break;
        }
        
        $sql .= " ORDER BY data_registro ASC";
        
        $stmt = $pdo->prepare($sql);
        $stmt->execute();
        
        jsonResponse([
            'success' => true,
            'dados' => $stmt->fetchAll(PDO::FETCH_ASSOC)
        ]);
    }
    
    // POST: Receber os dados do ESP32 via Wi-FI
    else if ($method === 'POST') {
        $data = getPostData();
        
        $ambiente = sanitize($data['ambiente'] ?? 'N/A');
        $temp = filter_var($data['temperatura'], FILTER_VALIDATE_FLOAT);
        $umid = filter_var($data['umidade'], FILTER_VALIDATE_FLOAT);
        
        if ($temp === false || $umid === false) {
            jsonResponse(['success' => false, 'error' => 'Temp/Umidade invalidos'], 400);
        }
        
        $sql = "INSERT INTO estacao_meteorologica (ambiente, temperatura, umidade) VALUES (?, ?, ?)";
        $pdo->prepare($sql)->execute([$ambiente, $temp, $umid]);
        
        jsonResponse([
            'success' => true,
            'message' => 'Salvo!'
        ], 201);
    }
} catch (PDOException $e) {
    jsonResponse(['success' => false, 'error' => 'Erro de DB'], 500);
}
?>

#include <WiFi.h>
#include <HTTPClient.h>
#include <DHT.h>

// ⚠️ CONFIGURE SUA REDE AQUI
const char* ssid = "SUA_REDE_WIFI";
const char* password = "SUA_SENHA_WIFI";
const char* serverUrl = "http://192.168.0.XYZ/iot/api/clima.php"; 
const String NOME_AMBIENTE = "Sala de Estar";

#define DHTPIN 4
#define DHTTYPE DHT22
#define BOTAO_WAKEUP 33
#define TEMPO_DORMINDO 30 * 60 * 1000000ULL // 30 Minutos em Microsegundos

DHT dht(DHTPIN, DHTTYPE);

void setup() {
  Serial.begin(115200);
  delay(1000); 

  Serial.println("--- ESP32 ACORDOU! ---");
  dht.begin();
  delay(2000); // DHT precisa estabilizar
  
  float umidade = dht.readHumidity();
  float temperatura = dht.readTemperature();

  if (isnan(umidade) || isnan(temperatura)) {
    Serial.println("Falha Sensor!");
    voltarADormir();
    return;
  }

  WiFi.begin(ssid, password);
  int t = 0;
  while (WiFi.status() != WL_CONNECTED && t < 20) {
    delay(500);
    t++;
  }

  if (WiFi.status() == WL_CONNECTED) {
    enviarDados(temperatura, umidade);
  }

  voltarADormir();
}

void loop() {
  // O chip dorme no SETUP. O LOOP NUNCA RODA no Deep Sleep
}

void enviarDados(float temp, float umid) {
  HTTPClient http;
  http.begin(serverUrl);
  http.addHeader("Content-Type", "application/json");

  String payload = "{\"ambiente\":\"" + NOME_AMBIENTE + "\",\"temperatura\":" + String(temp) + ",\"umidade\":" + String(umid) + "}";
  http.POST(payload);
  http.end();
}

void voltarADormir() {
  WiFi.disconnect(true);
  WiFi.mode(WIFI_OFF);
  
  esp_sleep_enable_timer_wakeup(TEMPO_DORMINDO);
  esp_sleep_enable_ext0_wakeup((gpio_num_t)BOTAO_WAKEUP, 1);
  
  Serial.println("ZzZzZzZ");
  Serial.flush(); 
  esp_deep_sleep_start();
}

// 1. Variável global e Estado
let myChart = null;
let ambienteAtual = 'Todos';

// 2. Modificado: Busca dados do ambiente selecionado também!
async function carregarDados(filtro) {
    try {
        const url = `api/clima.php?filtro=${filtro}&ambiente=${encodeURIComponent(ambienteAtual)}`;
        const resposta = await fetch(url);
        const json = await resposta.json();

        if (json.success && json.dados.length > 0) {
            atualizarGraficoDashboard(json.dados);
        } else {
            console.warn("Sem dados...");
        }
    } catch (erro) { console.error(erro); }
}

// 3. Recebe o JSON do banco e prepara os arrays
function atualizarGraficoDashboard(dados_bd) {
    const labels = dados_bd.map(r => new Date(r.data_registro).toLocaleString('pt-BR'));
    const temps = dados_bd.map(r => parseFloat(r.temperatura));
    const umids = dados_bd.map(r => parseFloat(r.umidade));

    renderizarChart(labels, temps, umids);
}

// 4. Desenha o Gráfico Linha Vermelha / Azul usando Chart.js
function renderizarChart(labels, temps, umids) {
    const ctx = document.getElementById('climaChart').getContext('2d');
    
    // Se já existe um gráfico, destrói e recria (para animação funcionar)
    if (myChart) myChart.destroy();

    myChart = new Chart(ctx, {
        type: 'line',
        data: {
            labels: labels,
            datasets: [
                {
                    label: 'Temperatura (°C)',
                    data: temps,
                    borderColor: '#f59e0b',
                    borderWidth: 3,
                    tension: 0.4
                },
                {
                    label: 'Umidade (%)',
                    data: umids,
                    borderColor: '#3b82f6',
                    borderWidth: 2,
                    borderDash: [5, 5],
                    tension: 0.4
                }
            ]
        },
        options: {
            responsive: true,
            maintainAspectRatio: false,
            interaction: { mode: 'index', intersect: false }
        }
    });
}

// Carrega automático ao abrir a página!
window.addEventListener('load', () => carregarDados('hoje'));