esp_err_t pir_sensor_init(int gpio_num, uint8_t trigger_level, 
                          uint32_t debounce_ms, uint32_t hold_ms)
{
    if (gpio_num == GPIO_NUM_NC) return ESP_ERR_INVALID_ARG;

    s_gpio_pin = gpio_num;
    s_trigger_level = trigger_level;
    s_debounce_ms = debounce_ms;
    s_hold_ms = hold_ms;

    // 配置 GPIO 输入
    gpio_config_t io_conf = {
        .pin_bit_mask = (1ULL << s_gpio_pin),
        .mode = GPIO_MODE_INPUT,
        .pull_up_en = GPIO_PULLUP_ENABLE,
        .pull_down_en = GPIO_PULLDOWN_DISABLE,
        .intr_type = GPIO_INTR_ANYEDGE,
    };
    esp_err_t ret = gpio_config(&io_conf);
    if (ret != ESP_OK) return ret;

    // 创建事件队列
    s_event_queue = xQueueCreate(10, sizeof(uint32_t));
    if (!s_event_queue) return ESP_ERR_NO_MEM;

    // 安装 GPIO ISR 服务
    ret = gpio_install_isr_service(0);
    if (ret != ESP_OK && ret != ESP_ERR_INVALID_STATE) {
        // ESP_ERR_INVALID_STATE 表示已经安装过，可以忽略
        return ret;
    }

    // 添加中断处理
    ret = gpio_isr_handler_add(s_gpio_pin, pir_isr_handler, (void*)s_gpio_pin);
    if (ret != ESP_OK) return ret;

    // 创建事件处理任务
    xTaskCreate(pir_event_task, "pir_event", 4096, NULL, 10, NULL);

    ESP_LOGI(TAG, "Initialized on GPIO %d, trigger level %d", s_gpio_pin, s_trigger_level);
    return ESP_OK;
}

static void pir_event_task(void *arg)
{
    uint32_t io_num;
    while (1) {
        if (xQueueReceive(s_event_queue, &io_num, portMAX_DELAY)) {
            int level = gpio_get_level((int)io_num);
            bool triggered = (level == s_trigger_level);

            if (triggered && !s_is_motion) {
                // 检测到触发，先延时消抖
                vTaskDelay(pdMS_TO_TICKS(s_debounce_ms));
                if (gpio_get_level(s_gpio_pin) == s_trigger_level) {
                    s_is_motion = true;
                    ESP_LOGI(TAG, "Motion detected");
                    if (s_motion_cb) s_motion_cb();
                }
            }
            else if (!triggered && s_is_motion) {
                // 信号消失，保持 hold_ms 时间再确认空闲
                vTaskDelay(pdMS_TO_TICKS(s_hold_ms));
                if (gpio_get_level(s_gpio_pin) != s_trigger_level) {
                    s_is_motion = false;
                    ESP_LOGI(TAG, "Idle");
                    if (s_idle_cb) s_idle_cb();
                }
            }
        }
    }
}

static void mesh_generic_server_cb(
        esp_ble_mesh_generic_server_cb_event_t event,
        esp_ble_mesh_generic_server_cb_param_t *param)
{
    if (event != ESP_BLE_MESH_GENERIC_SERVER_STATE_CHANGE_EVT) return;

    uint32_t op = param->ctx.recv_op;

    /* OnOff Set */
    if (op == ESP_BLE_MESH_MODEL_OP_GEN_ONOFF_SET ||
        op == ESP_BLE_MESH_MODEL_OP_GEN_ONOFF_SET_UNACK) {
        bool on = (param->value.state_change.onoff_set.onoff != 0);
        g_local_led_on = on;
        if (on) {
            uint8_t bri = g_local_brightness ? g_local_brightness : 200;
            g_local_brightness = bri;
            led_pwm_set(true, bri);
            set_pir_enabled(false);
        } else {
            led_pwm_set(false, 0);
            set_pir_enabled(true);
        }
        ESP_LOGI(TAG, "OnOff SET: %s bri=%d, PIR %s", 
             on ? "ON" : "OFF", g_local_brightness,
             on ? "disabled" : "enabled");
    }

    /* Level SET - absolute value (individual node slider) */
    if (op == ESP_BLE_MESH_MODEL_OP_GEN_LEVEL_SET ||
        op == ESP_BLE_MESH_MODEL_OP_GEN_LEVEL_SET_UNACK) {
        int16_t lv  = param->value.state_change.level_set.level;
        uint8_t bri = level_to_bri(lv);
        g_local_brightness = bri;
        g_local_led_on     = (bri > 0);
        if (bri > 0)
        {
            led_pwm_set(g_local_led_on, bri);
            set_pir_enabled(false);
        }
        else{
            led_pwm_set(false, 0);
            set_pir_enabled(true);
        }
        ESP_LOGI(TAG, "Level SET: lv=%d bri=%d (%d%%)", lv, bri, bri*100/255);
    }


}