单因子预警（只推送，不本地报警）：
  任一参数超阈值 → OLED 显示"WARNING" → MQTT 推送预警消息 → 持续计时

双因子火警（本地报警 + 推送）：
  以下任一组合在 10s 窗口内同时成立：
  ① 烟雾超标 AND (温升速率 > 1°C/s 或温度 > 50°C)
  ② 火焰直接检测到（火焰单因子即可触发火警——明火没有商量余地）
  ③ CO 超标 AND 烟雾超标
  → 蜂鸣器连续鸣响 + LED 闪烁 + MQTT 推送 FIRE ALARM

CO 单独超标 → 按"燃气/燃烧不充分"事件处理：本地报警 + 推送（CO 中毒风险高，单因子也必须报）

#include "stm32f10x.h"
#include "delay.h"
#include "dht11.h"
#include "oled.h"
#include "key.h"
#include "adc.h"
#include "flame.h"
#include "buzzer.h"
#include "esp8266_mqtt.h"

/* ---- 阈值（按键可调，EEPROM 可选保存）---- */
typedef struct {
    float smoke_v;      /* MQ-2 报警电压阈值 */
    float co_v;        /* MQ-7 报警电压阈值 */
    float temp_high;   /* 高温阈值 */
    float temp_rate;   /* 温升速率阈值 °C/s */
} Thresh_t;

static Thresh_t th = { 2.0f, 1.8f, 50.0f, 1.0f };

/* ---- 双因子状态 ---- */
static uint8_t fct_smoke, fct_cotemp, fct_flame, fct_co;
static float   last_temp = 25.0f;

int main(void)
{
    SysTick_Init(); OLED_Init(); Key_Init(); DHT11_Init();
    ADC1_Init(); Flame_Init(); Buzzer_Init();
    ESP8266_Init();                 /* 连Wi-Fi + 连MQTT broker，失败不阻塞报警 */

    while (1)
    {
        /* ---- 1. 采集 ---- */
        uint8_t hum, tmp;
        DHT11_Read(&hum, &tmp);                     /* 1.5s一次更稳 */
        float v_smoke = MQ2_ReadVoltage();
        float v_co    = MQ7_ReadVoltage();
        uint8_t flame = Flame_Detected();
        float temp_rate = (tmp - last_temp) / 1.5f; /* °C/s */
        last_temp = tmp;

        /* ---- 2. 因子计算 ---- */
        fct_smoke = (v_smoke > th.smoke_v);
        fct_cotemp = ((tmp > th.temp_high) || (temp_rate > th.temp_rate));
        fct_flame = flame;
        fct_co = (v_co > th.co_v);

        /* ---- 3. 分级判定 ---- */
        uint8_t fire = 0, warn = 0, coEvent = 0;
        if (fct_flame)                        fire = 1;   /* 明火零容忍 */
        if (fct_smoke && fct_cotemp)          fire = 1;   /* 烟+温 双因子 */
        if (fct_smoke && fct_co)              fire = 1;   /* 烟+CO 双因子 */
        if (fct_smoke || fct_cotemp)          warn = 1;   /* 单因子预警 */
        if (fct_co)                           coEvent = 1;/* CO 事件独立报 */

        /* ---- 4. 输出 ---- */
        if (fire)      { Buzzer_On();  LED_BlinkFast(); MQTT_Publish("hotel/room101/alarm", "FIRE"); }
        else if (coEvent) { Buzzer_On(); LED_On();     MQTT_Publish("hotel/room101/alarm", "CO"); }
        else if (warn) { Buzzer_Off(); LED_BlinkSlow(); MQTT_Publish("hotel/room101/warn",  "WARN"); }
        else           { Buzzer_Off(); LED_Off(); }

        /* ---- 5. 阈值设定（按键进入菜单）---- */
        Key_ThresholdMenu(&th);

        /* ---- 6. 显示 + 周期上报 ---- */
        OLED_ShowAll(tmp, hum, v_smoke, v_co, flame, fire|coEvent|warn);
        MQTT_PeriodicReport(tmp, hum, v_smoke, v_co);  /* 30s一次 */
        delay_ms(10);
    }
}

/* 用法2（恒压模块）：滑动平均 + 预热判断 */
float MQ7_ReadVoltage(void)
{
    static float filt = 0.0f;
    float v = ADC1_ReadCH(2) * 3.3f / 4096.0f * 1.5f;   /* 分压补偿 */
    filt = filt * 0.9f + v * 0.1f;                       /* 一阶低通 */
    return filt;
}

/* 用法1（可控加热）：状态机 */
typedef enum { MQ7_HEAT_HIGH, MQ7_HEAT_LOW } MQ7State;
static MQ7State mq7 = MQ7_HEAT_HIGH;
static uint32_t t0 = 0;
static float mq7_val = 0;

void MQ7_Task(void)   /* 主循环每100ms调用一次 */
{
    uint32_t now = GetTick();
    switch (mq7) {
    case MQ7_HEAT_HIGH:                       /* 5V 加热 60s */
        Heater_5V();
        if (now - t0 >= 60000) { t0 = now; mq7 = MQ7_HEAT_LOW; }
        break;
    case MQ7_HEAT_LOW:                        /* 1.4V 加热 90s，后30s读数 */
        Heater_1V4();
        if (now - t0 >= 60000) mq7_val = MQ7_ReadVoltage();
        if (now - t0 >= 90000) { t0 = now; mq7 = MQ7_HEAT_HIGH; }
        break;
    }
}

/* 正确顺序：复位 → 模式 → 连网 → 单连接 → 建TCP → （透传）→ 发数据 */
1. AT+RST                    → 等 "ready"
2. AT+CWMODE=1               → STA模式
3. AT+CWJAP="SSID","PASS"    → 等 "WIFI GOT IP"
4. AT+CIPMUX=0               → 单连接
5. AT+CIPSTART="TCP","broker_ip",1883   → 等 "CONNECT OK"    ← 先建连接
6. AT+CIPMODE=1              → 透传模式
7. AT+CIPSEND                → 进透传，之后串口数据直发服务器  ← 后发数据
   此后发送的是标准 MQTT 报文（CONNECT/PUBLISH/SUBSCRIBE）
8. 退出透传：单独发送 "+++"（前后不回车，1秒内不发其它数据）

/* MQTT PUBLISH 报文手工组包（QoS0，主题 "hotel/room101/alarm"）*/
void MQTT_Publish(const char *topic, const char *msg)
{
    uint8_t pkt[128];
    uint8_t tl = strlen(topic), ml = strlen(msg);
    uint8_t i = 0;
    /* 剩余长度 = 2 + tl + ml */
    pkt[i++] = 0x30;                    /* PUBLISH, QoS0 */
    pkt[i++] = 2 + tl + ml;             /* 剩余长度（假设<128） */
    pkt[i++] = 0x00; pkt[i++] = tl;     /* 主题长度 */
    memcpy(&pkt[i], topic, tl); i += tl;
    memcpy(&pkt[i], msg, ml);   i += ml;
    UART1_SendBuf(pkt, i);              /* 透传模式下直接发 */
}

void OLED_ShowAll(int8_t t, uint8_t h, float vs, float vc, uint8_t fl, uint8_t al)
{
    OLED_ShowString(0, 0, "Hotel Fire Alarm");
    OLED_ShowString(0,12, "T:xx C  H:xx %");  OLED_ShowNum(20,12,t,2);  OLED_ShowNum(68,12,h,2);
    OLED_ShowString(0,24, "Smoke:x.xx V");    OLED_ShowFloat(48,24,vs,2);
    OLED_ShowString(0,36, "CO   :x.xx V");    OLED_ShowFloat(48,36,vc,2);
    OLED_ShowString(0,48, fl ? "Flame: YES!" : "Flame: no  ");
    OLED_ShowString(0,56, al ? "!! ALARM !!" : "Status: OK  ");
}