#include <ESP8266WiFi.h>
#include <ESP8266WebServer.h>
#include <DHT.h>

const char* ssid = "당신의_와이파이_이름";
const char* password = "당신의_와이파이_비밀번호";

// DHT 센서 설정
#define DHTPIN D2
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);

ESP8266WebServer server(80);

// 센서 데이터 저장 변수
float temperature = 0;
float humidity = 0;
unsigned long lastUpdate = 0;

// 메인 페이지 HTML (자동 새로고침 포함)
String getHTML() {
  String html = "<!DOCTYPE html><html>";
  html += "<head><meta charset='UTF-8'>";
  html += "<meta name='viewport' content='width=device-width, initial-scale=1.0'>";
  html += "<meta http-equiv='refresh' content='5'>";  // 5초마다 자동 새로고침
  html += "<title>환경 모니터링 시스템</title>";
  html += "<style>.tx-container{max-width:100%;
margin:0 auto;
font-family:'Segoe UI',Tahoma,Geneva,Verdana,sans-serif;
line-height:1.8;
color:#333;}
.tx-header{background:linear-gradient(135deg,#667eea 0%,#764ba2 100%);
padding:40px 25px;
border-radius:16px;
text-align:center;
margin-bottom:35px;
box-shadow:0 8px 20px rgba(102,126,234,0.3);}
.tx-section{margin:35px 0;
padding:0;}
.tx-highlight-box{background:linear-gradient(135deg,#f5f7fa 0%,#c3cfe2 100%);
padding:20px;
border-radius:12px;
margin:25px 0;
border-left:5px solid #667eea;}
.tx-tip-box{background:#fff9e6;
padding:18px;
border-radius:10px;
margin:20px 0;
border-left:4px solid #ffd93d;}
.tx-step-box{background:#ffffff;
padding:20px;
border-radius:12px;
margin:20px 0;
box-shadow:0 2px 8px rgba(0,0,0,0.08);
border-top:3px solid #667eea;}
.tx-warning-box{background:#ffe6e6;
padding:18px;
border-radius:10px;
margin:20px 0;
border-left:4px solid #ff6b6b;}
.tx-table{width:100%;
border-collapse:collapse;
margin:20px 0;
font-size:0.95em;}
.tx-table th{background:#667eea;
color:white;
padding:12px;
text-align:left;
font-weight:600;}
.tx-table td{padding:12px;
border-bottom:1px solid #e1e4e8;}
.tx-table tr:nth-child(even){background:#f8f9fa;}
.tx-emoji{font-size:1.3em;
margin:0 3px;}</style></head>";
  html += "<body><div class='container'>";
  html += "<div class='header'><h1>🏠 스마트 환경 모니터링</h1></div>";
  html += "<div class='cards'>";
  
  // 온도 카드
  html += "<div class='card'>";
  html += "<div class='icon'>🌡️</div>";
  html += "<div class='value'>" + String(temperature, 1) + "°C</div>";
  html += "<div class='label'>온도</div>";
  html += "</div>";
  
  // 습도 카드
  html += "<div class='card'>";
  html += "<div class='icon'>💧</div>";
  html += "<div class='value'>" + String(humidity, 1) + "%</div>";
  html += "<div class='label'>습도</div>";
  html += "</div>";
  
  // 체감 온도 계산 (간단한 공식)
  float heatIndex = temperature + (0.5 * (humidity / 100) * (temperature - 14.5));
  html += "<div class='card'>";
  html += "<div class='icon'>🌤️</div>";
  html += "<div class='value'>" + String(heatIndex, 1) + "°C</div>";
  html += "<div class='label'>체감온도</div>";
  html += "</div>";
  
  html += "</div>";
  html += "<div class='timestamp'>마지막 업데이트: " + String(millis() / 1000) + "초 전</div>";
  html += "</div></body></html>";
  return html;
}

// JSON 형식으로 데이터 제공 (API 엔드포인트)
void handleData() {
  String json = "{";
  json += "\"temperature\":" + String(temperature, 2) + ",";
  json += "\"humidity\":" + String(humidity, 2) + ",";
  json += "\"timestamp\":" + String(millis());
  json += "}";
  server.send(200, "application/json", json);
}

void handleRoot() {
  server.send(200, "text/html", getHTML());
}

void setup() {
  Serial.begin(115200);
  dht.begin();
  
  // Wi-Fi 연결
  Serial.print("Wi-Fi 연결 중...");
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("\nWi-Fi 연결 성공!");
  Serial.print("IP 주소: ");
  Serial.println(WiFi.localIP());
  
  // 웹 서버 설정
  server.on("/", handleRoot);
  server.on("/data", handleData);  // JSON API
  server.begin();
  
  Serial.println("환경 모니터링 시스템 시작! 🌟");
}

void loop() {
  server.handleClient();
  
  // 2초마다 센서 읽기
  if (millis() - lastUpdate > 2000) {
    humidity = dht.readHumidity();
    temperature = dht.readTemperature();
    
    // 센서 읽기 실패 체크
    if (isnan(humidity) || isnan(temperature)) {
      Serial.println("센서 읽기 실패!");
      return;
    }
    
    Serial.print("온도: ");
    Serial.print(temperature);
    Serial.print("°C, 습도: ");
    Serial.print(humidity);
    Serial.println("%");
    
    lastUpdate = millis();
  }
}

#define BLYNK_TEMPLATE_ID "당신의_템플릿_ID"
#define BLYNK_TEMPLATE_NAME "스마트홈컨트롤러"
#define BLYNK_AUTH_TOKEN "당신의_인증_토큰"

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

// Wi-Fi 정보
char ssid[] = "당신의_와이파이_이름";
char pass[] = "당신의_와이파이_비밀번호";

// DHT 센서 설정
#define DHTPIN D2
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);

// LED 핀
#define LED_PIN D4

// 타이머 객체
BlynkTimer timer;

// 센서 데이터를 Blynk로 전송하는 함수
void sendSensorData() {
  float h = dht.readHumidity();
  float t = dht.readTemperature();
  
  if (isnan(h) || isnan(t)) {
    Serial.println("센서 읽기 실패!");
    return;
  }
  
  // Blynk 가상 핀으로 데이터 전송
  Blynk.virtualWrite(V0, t);  // V0에 온도
  Blynk.virtualWrite(V1, h);  // V1에 습도
  
  Serial.print("온도: ");
  Serial.print(t);
  Serial.print("°C, 습도: ");
  Serial.print(h);
  Serial.println("%");
}

// Blynk 앱에서 버튼을 누르면 실행되는 함수 (V2 핀)
BLYNK_WRITE(V2) {
  int value = param.asInt();  // 버튼 상태 (0 또는 1)
  
  if (value == 1) {
    digitalWrite(LED_PIN, LOW);  // LED 켜기
    Serial.println("LED 켜짐! 💡");
  } else {
    digitalWrite(LED_PIN, HIGH);  // LED 끄기
    Serial.println("LED 꺼짐! 🌙");
  }
}

// 슬라이더로 밝기 조절 (PWM 핀 사용 시)
BLYNK_WRITE(V3) {
  int brightness = param.asInt();  // 0~255
  analogWrite(LED_PIN, brightness);
  Serial.print("밝기: ");
  Serial.println(brightness);
}

void setup() {
  Serial.begin(115200);
  pinMode(LED_PIN, OUTPUT);
  digitalWrite(LED_PIN, HIGH);
  
  dht.begin();
  
  // Blynk 연결
  Blynk.begin(BLYNK_AUTH_TOKEN, ssid, pass);
  
  // 2초마다 센서 데이터 전송
  timer.setInterval(2000L, sendSensorData);
  
  Serial.println("Blynk 시스템 준비 완료! 🚀");
}

void loop() {
  Blynk.run();  // Blynk 라이브러리 실행
  timer.run();  // 타이머 실행
}

#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>
#include <ArduinoJson.h>

// Wi-Fi 설정
const char* ssid = "당신의_와이파이_이름";
const char* password = "당신의_와이파이_비밀번호";

// MQTT 브로커 설정
const char* mqtt_server = "broker.hivemq.com";  // 또는 당신의 브로커 주소
const int mqtt_port = 1883;
const char* mqtt_user = "";  // 필요시 입력
const char* mqtt_password = "";  // 필요시 입력

// MQTT 토픽 정의
const char* topic_temperature = "smarthome/sensor/temperature";
const char* topic_humidity = "smarthome/sensor/humidity";
const char* topic_led_control = "smarthome/control/led";
const char* topic_status = "smarthome/status";

// DHT 센서
#define DHTPIN D2
#define DHTTYPE DHT11
DHT dht(DHTPIN, DHTTYPE);

// LED 핀
#define LED_PIN D4

WiFiClient espClient;
PubSubClient client(espClient);

unsigned long lastMsg = 0;
float temperature = 0;
float humidity = 0;

// Wi-Fi 연결 함수
void setup_wifi() {
  delay(10);
  Serial.println();
  Serial.print("Wi-Fi 연결 중: ");
  Serial.println(ssid);
  
  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("");
  Serial.println("Wi-Fi 연결 성공!");
  Serial.print("IP 주소: ");
  Serial.println(WiFi.localIP());
}

// MQTT 메시지 수신 콜백 함수
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("메시지 도착 [");
  Serial.print(topic);
  Serial.print("]: ");
  
  String message = "";
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
  }
  Serial.println(message);
  
  // LED 제어 토픽 처리
  if (String(topic) == topic_led_control) {
    if (message == "ON" || message == "1") {
      digitalWrite(LED_PIN, LOW);
      Serial.println("LED 켜짐! 💡");
      client.publish(topic_status, "LED is ON");
    } else if (message == "OFF" || message == "0") {
      digitalWrite(LED_PIN, HIGH);
      Serial.println("LED 꺼짐! 🌙");
      client.publish(topic_status, "LED is OFF");
    }
  }
}

// MQTT 재연결 함수
void reconnect() {
  while (!client.connected()) {
    Serial.print("MQTT 연결 시도...");
    
    // 고유한 클라이언트 ID 생성
    String clientId = "ESP8266Client-";
    clientId += String(random(0xffff), HEX);
    
    if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {
      Serial.println("연결 성공! 🎉");
      
      // 상태 메시지 발행
      client.publish(topic_status, "ESP8266 Connected");
      
      // LED 제어 토픽 구독
      client.subscribe(topic_led_control);
      Serial.println("토픽 구독 완료!");
      
    } else {
      Serial.print("실패, rc=");
      Serial.print(client.state());
      Serial.println(" 5초 후 재시도...");
      delay(5000);
    }
  }
}

void setup() {
  Serial.begin(115200);
  pinMode(LED_PIN, OUTPUT);
  digitalWrite(LED_PIN, HIGH);
  
  dht.begin();
  setup_wifi();
  
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
  
  Serial.println("MQTT 시스템 준비 완료! 🚀");
}

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();
  
  unsigned long now = millis();
  
  // 5초마다 센서 데이터 발행
  if (now - lastMsg > 5000) {
    lastMsg = now;
    
    humidity = dht.readHumidity();
    temperature = dht.readTemperature();
    
    if (isnan(humidity) || isnan(temperature)) {
      Serial.println("센서 읽기 실패!");
      return;
    }
    
    // JSON 형식으로 데이터 생성
    StaticJsonDocument<200> doc;
    doc["device"] = "ESP8266_Sensor";
    doc["temperature"] = temperature;
    doc["humidity"] = humidity;
    doc["timestamp"] = now;
    
    char jsonBuffer[200];
    serializeJson(doc, jsonBuffer);
    
    // 개별 토픽으로 발행
    client.publish(topic_temperature, String(temperature).c_str());
    client.publish(topic_humidity, String(humidity).c_str());
    
    // JSON 데이터도 발행
    client.publish("smarthome/sensor/data", jsonBuffer);
    
    Serial.print("데이터 발행 완료 - 온도: ");
    Serial.print(temperature);
    Serial.print("°C, 습도: ");
    Serial.print(humidity);
    Serial.println("%");
  }
}

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

// Blynk 설정
#define BLYNK_TEMPLATE_ID "당신의_템플릿_ID"
#define BLYNK_TEMPLATE_NAME "스마트화분"
#define BLYNK_AUTH_TOKEN "당신의_인증_토큰"

// Wi-Fi 설정
char ssid[] = "당신의_와이파이_이름";
char pass[] = "당신의_와이파이_비밀번호";

// 핀 정의
#define SOIL_SENSOR_PIN A0
#define PUMP_PIN D1
#define DHT_PIN D2
#define DHT_TYPE DHT11

DHT dht(DHT_PIN, DHT_TYPE);
BlynkTimer timer;

// 설정값
int soilMoistureThreshold = 30;  // 습도 30% 이하면 물 주기
bool autoWateringEnabled = true;
int wateringDuration = 5000;  // 5초간 물 주기

// 센서 데이터 전송
void sendSensorData() {
  // 토양 습도 읽기 (0~1023, 낮을수록 습함)
  int soilValue = analogRead(SOIL_SENSOR_PIN);
  int soilMoisture = map(soilValue, 1023, 0, 0, 100);  // 0~100%로 변환
  
  // 온습도 읽기
  float temperature = dht.readTemperature();
  float humidity = dht.readHumidity();
  
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("DHT 센서 읽기 실패!");
    return;
  }
  
  // Blynk로 데이터 전송
  Blynk.virtualWrite(V0, soilMoisture);  // 토양 습도
  Blynk.virtualWrite(V1, temperature);   // 온도
  Blynk.virtualWrite(V2, humidity);      // 습도
  
  Serial.print("토양 습도: ");
  Serial.print(soilMoisture);
  Serial.print("%, 온도: ");
  Serial.print(temperature);
  Serial.print("°C, 습도: ");
  Serial.print(humidity);
  Serial.println("%");
  
  // 자동 물주기 체크
  if (autoWateringEnabled && soilMoisture < soilMoistureThreshold) {
    waterPlant();
  }
}

// 물 주기 함수
void waterPlant() {
  Serial.println("💧 물 주기 시작!");
  Blynk.logEvent("watering_started", "화분에 물을 주고 있습니다.");
  
  digitalWrite(PUMP_PIN, HIGH);  // 펌프 켜기
  delay(wateringDuration);
  digitalWrite(PUMP_PIN, LOW);   // 펌프 끄기
  
  Serial.println("✅ 물 주기 완료!");
  Blynk.logEvent("watering_completed", "물 주기가 완료되었습니다.");
}

// Blynk 버튼: 수동 물주기 (V3)
BLYNK_WRITE(V3) {
  int value = param.asInt();
  if (value == 1) {
    waterPlant();
  }
}

// Blynk 스위치: 자동 물주기 활성화/비활성화 (V4)
BLYNK_WRITE(V4) {
  autoWateringEnabled = param.asInt();
  Serial.print("자동 물주기: ");
  Serial.println(autoWateringEnabled ? "활성화" : "비활성화");
}

// Blynk 슬라이더: 습도 임계값 설정 (V5)
BLYNK_WRITE(V5) {
  soilMoistureThreshold = param.asInt();
  Serial.print("습도 임계값 변경: ");
  Serial.print(soilMoistureThreshold);
  Serial.println("%");
}

// Blynk 슬라이더: 물주기 시간 설정 (V6)
BLYNK_WRITE(V6) {
  wateringDuration = param.asInt() * 1000;  // 초 단위를 밀리초로 변환
  Serial.print("물주기 시간 변경: ");
  Serial.print(wateringDuration / 1000);
  Serial.println("초");
}

void setup() {
  Serial.begin(115200);
  pinMode(PUMP_PIN, OUTPUT);
  digitalWrite(PUMP_PIN, LOW);
  
  dht.begin();
  
  // Blynk 연결
  Blynk.begin(BLYNK_AUTH_TOKEN, ssid, pass);
  
  // 10초마다 센서 데이터 전송
  timer.setInterval(10000L, sendSensorData);
  
  Serial.println("🌱 스마트 화분 시스템 시작!");
}

void loop() {
  Blynk.run();
  timer.run();
}