#include <WiFi.h>
#include <PubSubClient.h>
#include <Wire.h>
#include <LiquidCrystal_I2C.h>
#include <DHT.h>
#include <time.h>

// 传感器与引脚定义
#define DHTPIN 26
#define DHTTYPE DHT22
#define LED_PIN 19     
#define BUZZER_PIN 4   // 蜂鸣器引脚
#define BUTTON_PIN 14  // 新增按钮引脚（来自版本2）

// 报警阈值设置
const float TEMP_THRESHOLD_C = 40.0;    // 温度阈值（摄氏度）
const float TEMP_THRESHOLD_F = 135.0;   // 温度阈值（华氏度）
const float HUMIDITY_THRESHOLD = 45.0;  // 湿度阈值

// WiFi 配置（整合版本2的WiFi设置）
const char* ssid = "Wokwi-GUEST";
const char* password = "";
const char* mqtt_server = "broker.hivemq.com";

// MQTT 主题
const char* mqtt_topic_pub = "IoT/WXP/gp/sensor";     // 温湿度发布
const char* mqtt_topic_time = "IoT/WXP/gp/time";      // 时间发布
const char* mqtt_topic_sub = "IoT/WXP/gp/led";        // LED 控制订阅
const char* mqtt_topic_alarm = "IoT/WXP/gp/alarm";    // 报警消息
const char* mqtt_topic_lwt = "IoT/WXP/gp/status";     // 设备状态（遗嘱消息）

// 对象创建
WiFiClient espClient;
PubSubClient client(espClient);
DHT dht(DHTPIN, DHTTYPE);
LiquidCrystal_I2C lcd(0x27, 20, 4);

// 全局变量
bool ledState = false;
unsigned long lastMsg = 0;           // MQTT 发布计时器
unsigned long lastDisplayChange = 0;
unsigned long lastButtonTime = 0;    // 新增按钮时间记录（来自版本2）
const long publishInterval = 3000;   // 3秒发布一次数据
const long displayInterval = 3000;   // 显示切换间隔
const long idleTimeToSleep = 60000;  // 新增：1分钟无操作进入休眠（来自版本2）
int displayState = 0;                // 显示状态（0:欢迎, 1:时间, 2:温湿度）
char msg[100];                       // MQTT 消息缓冲区
bool welcomeDisplayed = false;

// 报警配置
bool isAlarm = false;
unsigned long alarmStartTime = 0;
const unsigned long ALARM_DURATION = 30000;  // 报警持续30秒
unsigned long lastBuzzerToggle = 0;
const long buzzerInterval = 500;            // 蜂鸣器闪烁间隔

// 自定义℃符号
uint8_t dot[] = {0x0E, 0x0A, 0x0E, 0x00, 0x00, 0x00, 0x00, 0x00};

// WiFi 连接（整合版本2的WiFi连接函数）
void setup_wifi() {
  Serial.println("Connecting to WiFi...");
  WiFi.begin(ssid, password);
  // 等待WiFi连接（版本2的循环逻辑）
  while (WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(250);
  }
  Serial.println("\nWiFi connected successfully!");  // 版本2的成功提示
}

// MQTT 回调（LED 控制）
void callback(char* topic, byte* payload, unsigned int length) {
  payload[length] = 0;
  String command = String((char*)payload);
  command.toUpperCase();  // 版本2的大写转换逻辑
  Serial.print("Received MQTT command: ");
  Serial.println(command);
  
  if (command == "ON") {
    digitalWrite(LED_PIN, HIGH);
    ledState = true;
    Serial.println("LED turned ON via MQTT");
  } else if (command == "OFF") {
    digitalWrite(LED_PIN, LOW);
    ledState = false;
    Serial.println("LED turned OFF via MQTT");
  }
}

// MQTT 重连（保留版本1功能，整合版本2的提示信息）
void reconnect() {
  static unsigned long lastReconnectAttempt = 0;
  const long reconnectInterval = 7000;  // 7秒重连间隔
  
  if (millis() - lastReconnectAttempt < reconnectInterval) return;
  lastReconnectAttempt = millis();

  Serial.println("Connecting to MQTT...");  // 版本2的提示信息
  if (client.connect("ESP32ClientDevice", mqtt_topic_lwt, 0, true, "offline")) {
    Serial.println("MQTT connected successfully");  // 版本2的成功提示
    client.publish(mqtt_topic_lwt, "online", true);
    client.subscribe(mqtt_topic_sub);
    client.setKeepAlive(60);
    client.setSocketTimeout(30);
  } else {
    Serial.print("MQTT connection failed, status=");  // 版本2的失败提示
    Serial.print(client.state());
    Serial.println(", will retry....");
  }
}

// 蜂鸣器控制
void controlBuzzer(bool enable) {
  if (enable) {
    // 报警模式：间歇鸣叫
    unsigned long now = millis();
    if (now - lastBuzzerToggle >= buzzerInterval) {
      lastBuzzerToggle = now;
      digitalWrite(BUZZER_PIN, !digitalRead(BUZZER_PIN));
    }
  } else {
    digitalWrite(BUZZER_PIN, LOW);
  }
}

// 欢迎信息显示（整合版本2的显示逻辑）
void displayWelcome() {
  if (!welcomeDisplayed) {
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("ESP32!");  // 版本2的欢迎语
    lcd.setCursor(0, 1);
    lcd.print("Hello, World!");  // 版本2的欢迎语
    welcomeDisplayed = true;
    delay(2000);
  }
}

// 时间显示与发布
void displayDateTime() {
  struct tm timeinfo;
  if (getLocalTime(&timeinfo)) {
    char dtbuf[21];
    strftime(dtbuf, sizeof(dtbuf), "%Y-%m-%d %H:%M:%S", &timeinfo);
    
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("DateTime:");
    lcd.setCursor(0, 1);
    lcd.print(dtbuf);
    
    unsigned long now = millis();
    if (now - lastMsg >= publishInterval) {
      lastMsg = now;
      client.publish(mqtt_topic_time, dtbuf);
    }
  }
}

// 温湿度显示与发布
void displayTempHumidity() {
  unsigned long start = millis();
  float h = dht.readHumidity();
  float c = dht.readTemperature();
  float f = dht.readTemperature(true);
  
  if (millis() - start > 1000) {
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("Sensor Timeout!");
    return;
  }
  
  if (isnan(h) || isnan(c) || isnan(f)) {
    Serial.println(F("Failed to read from DHT sensor!"));
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("Sensor Error!");
    return;
  }

  Serial.printf("Humidity: %.1f%%  Temp: %.1f°C / %.1f°F\n", h, c, f);

  bool tempAlarm = c > TEMP_THRESHOLD_C || f > TEMP_THRESHOLD_F;
  bool humAlarm = h > HUMIDITY_THRESHOLD;
  
  if (tempAlarm || humAlarm) {
    isAlarm = true;
    alarmStartTime = millis();
    
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("ALARM!");
    lcd.setCursor(0, 1);
    if (tempAlarm) lcd.print("Temp Over!");
    else lcd.print("Humidity Over!");
    lcd.setCursor(0, 2);
    lcd.print(tempAlarm ? String(c) + "C > " + String(TEMP_THRESHOLD_C) + "C" 
                       : String(h) + "% > " + String(HUMIDITY_THRESHOLD) + "%");
    
    char alarmMsg[100];
    snprintf(alarmMsg, sizeof(alarmMsg), "Alarm: %s %.1f%s",
             tempAlarm ? "Temp" : "Humidity",
             tempAlarm ? c : h,
             tempAlarm ? "C" : "%");
    client.publish(mqtt_topic_alarm, alarmMsg);
  } else {
    isAlarm = false;
    digitalWrite(BUZZER_PIN, LOW);
    
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("Humidity: "); 
    lcd.print(h, 1); 
    lcd.print("%");
    
    lcd.setCursor(0, 1);
    lcd.print("Temperature: ");  // 版本2的显示文本
    lcd.print(c, 2); 
    lcd.write(0); 
    lcd.print("C");

    lcd.setCursor(0, 2);
    lcd.print("Temperature: ");  // 版本2的显示文本
    lcd.print(f, 1); 
    lcd.write(0); 
    lcd.print("F");

    unsigned long now = millis();
    if (now - lastMsg >= publishInterval) {
      lastMsg = now;
      snprintf(msg, sizeof(msg), "{\"temp\": %.1f, \"hum\": %.1f}", c, h);  // 版本2的JSON格式
      client.publish(mqtt_topic_pub, msg);
    }
  }
}

void setup() {
  Serial.begin(115200);
  Serial.println("Starting setup()...");  // 版本2的启动提示

  pinMode(LED_PIN, OUTPUT);
  pinMode(BUZZER_PIN, OUTPUT);
  pinMode(BUTTON_PIN, INPUT_PULLUP);  // 新增按钮引脚配置（来自版本2）
  digitalWrite(LED_PIN, LOW);
  digitalWrite(BUZZER_PIN, LOW);
  
  lcd.init();
  lcd.backlight();
  lcd.createChar(0, dot);
  lcd.clear();
  lcd.print("Initializing...");
  delay(1000);

  dht.begin();
  setup_wifi();
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  configTime(8 * 3600, 0, "pool.ntp.org");
  struct tm timeinfo;
  while (!getLocalTime(&timeinfo)) {
    Serial.println("Waiting for time sync...");  // 版本2的时间同步提示
    delay(1000);
  }
  Serial.println("Time synchronized successfully");  // 版本2的同步成功提示

  displayWelcome();
  lastDisplayChange = millis();
  lastMsg = 0;
  lastButtonTime = millis();  // 初始化按钮计时器（来自版本2）

  Serial.println("setup() complete, entering loop()");  // 版本2的提示
}

void loop() {
  if (!client.connected()) reconnect();
  client.loop();

  unsigned long now = millis();

  // 新增按钮检测逻辑（来自版本2）
  if (digitalRead(BUTTON_PIN) == LOW) {
    delay(50);  // 消抖
    if (digitalRead(BUTTON_PIN) == LOW) { 
      // 切换LED状态
      ledState = !ledState;
      digitalWrite(LED_PIN, ledState);
      Serial.print("Button pressed, LED toggled to: ");
      Serial.println(ledState ? "ON" : "OFF");
      // 发布按钮触发的报警消息
      client.publish(mqtt_topic_alarm, "Button pressed!");
      
      // 重置计时器避免休眠
      lastButtonTime = now;
      lastDisplayChange = now;
      
      // 等待按钮释放
      while (digitalRead(BUTTON_PIN) == LOW) {
        delay(10);
        lastButtonTime = millis();  // 持续更新计时器
      }
    }
  }

  // 新增休眠逻辑（来自版本2）
  if (now - lastButtonTime > idleTimeToSleep && !isAlarm) {  // 报警时不进入休眠
    Serial.println("Idle timeout reached, entering light sleep...");
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("Sleeping 50s...");
    
    // 设置50秒后唤醒
    esp_sleep_enable_timer_wakeup(50 * 1000000ULL);
    Serial.println("Entering light sleep now.");
    esp_light_sleep_start();  // 进入浅度休眠
    
    // 唤醒后执行
    Serial.println("Woke up from light sleep!");
    lcd.clear();
    lcd.setCursor(0, 0);
    lcd.print("Woke up!");
    delay(500);
    
    // 重置状态
    lastButtonTime = millis();
    lastDisplayChange = millis();
    displayState = 0;
    displayWelcome();
    return;
  }

  // 报警处理
  if (isAlarm) {
    controlBuzzer(true);  // 激活蜂鸣器
    
    if (now - alarmStartTime > ALARM_DURATION) {
      isAlarm = false;
      digitalWrite(BUZZER_PIN, LOW);
    }
  }

  // 显示切换逻辑（报警时暂停切换）
  if (now - lastDisplayChange >= displayInterval && !isAlarm) {
    lastDisplayChange = now;
    displayState = (displayState + 1) % 3;
    switch (displayState) {
      case 0: displayWelcome(); break;
      case 1: displayDateTime(); break;
      case 2: displayTempHumidity(); break;
    }
  }
}