让smartac支持esphome的mqtt协议

trz0332

一直在用ryanh7大佬的smarac空调控制插件感觉这个插件非常好用，但是大佬比较低调，所以对这个插件有没有太多的介绍不过不知道为啥大佬更新后删掉了红外库的索引文件，现在最新的插件里面不包含了代码库索引，所以导致新手配置这个索引可能比较困难。
https://bbs.hassbian.com/forum.php?mod=viewthread&tid=15827


插件对esphome的原生api插件支持比较友好，但是如果esphome刷了mqtt协议就不太友好了，
首先就是配置方面，如果是原生的api，只需要在配置文件里面加上如下代码，就搞定了，但是esphome的原生api和mqtt协议不能同时存在，使用mqtt协议无法套用此配置

esphome:
  name: my_espir
  platform: ESP8266
  board: esp01_1m

api:
  services:
    - service: send_raw_command
      variables:
        command: int[]
      then:
        - remote_transmitter.transmit_raw:
            code: !lambda 'return command;'

remote_transmitter:
  pin: GPIO14
  carrier_duty_percent: 50%

复制代码

经过对esphome几天几夜的研究，翻阅大量资料，结合chatgpt的代码解析功能，终于研究出了esphome-mqtt搭配smartAC的使用方法需要在esphome中使用如下配置

mqtt:
  id: mqtt_client
  broker: mqtt.iot.org
  port: 1883
  username: pi
  password: xxxx
  discovery_prefix: tj
  discovery_object_id_generator: device_name
  discovery_unique_id_generator: mac
  log_topic:
    topic: "${device_name}/logs"
    level: debug
  discovery: true
  
ota:
  safe_mode: true
  password: xxxx
  on_state_change:
    then:
      - lambda: "App.feed_wdt();delay(1);"
captive_portal:

web_server:
  port: 80
  version: 2
  auth:
    username: xxxx
    password: xxxxxxx
wifi:
  networks:
  - ssid: iot
    password: xxxxxx

  reboot_timeout: 1200s
  fast_connect: true
  ap:
    ssid: esphome
    password: xxxxxx




substitutions:
  device_name: my_espir
  #device_name: esp32mmwsolo
  gpio_ir_t: GPIO14
  gpio_ir_r: GPIO26
  config_version: esp32ir-mqtt-20230916




esphome:
  name: $device_name
  platform: esp32
  board: esp32doit-devkit-v1
  name_add_mac_suffix: yes 
  build_path: ../build/$device_name


  on_boot: 
    - priority: 300
      then:
        - lambda: |-
              MQTTMessage new_birth_message;
              new_birth_message.topic = App.get_name() + "/" + "status";
              new_birth_message.payload = "online";
              new_birth_message.qos = 1;
              new_birth_message.retain = true;
              id(mqtt_client).set_birth_message(std::move(new_birth_message));

              MQTTMessage new_last_message;
              new_last_message.topic =   App.get_name() + "/" + "status";
              new_last_message.payload = "offline";
              new_last_message.qos = 1;
              new_last_message.retain = true;
              id(mqtt_client).set_last_will(std::move(new_last_message));

              MQTTMessage new_shutdown_message;
              new_shutdown_message.topic =   App.get_name() + "/" + "status";
              new_shutdown_message.payload = "offline";
              new_shutdown_message.qos = 1;
              new_shutdown_message.retain = true;
              id(mqtt_client).set_shutdown_message(std::move(new_shutdown_message));

              id(mqtt_client).set_topic_prefix(App.get_name());

    - priority: -100
      then:
        - lambda: |-
            id(mqtt_client).subscribe(App.get_name() + "/ir_send", [=](const std::string &topic, const std::string &payload) {
            
            std::string txstr = payload;
            std::vector<int> txv1;
            if (!txstr.empty()) {
              txstr = txstr.substr(1);  
              }
            if (!txstr.empty()) {
              txstr = txstr.substr(0, txstr.size() - 1);  
              }
              txstr.erase(std::remove_if(txstr.begin(), txstr.end(), [](char c) { return std::isspace(c); }), txstr.end());
  
            char * token;
            char seps[] = ",";
            token = strtok (&txstr[0],seps);
            while (token != NULL)
            {
              txv1.push_back( atoi(token) );
              token = strtok (NULL, seps);
            }
            for (int i = 0; i < txv1.size(); i++) {
              if (i % 2 == 1) {  // 如果是偶数位
                txv1[i] = -txv1[i];  // 在偶数位的数据前面加上负号
              }
            }
            id(txv)=txv1;
            id(irsend).press();
            });
            //
logger:
  level: ERROR  #不同的log等级看到的信息详细程度不一样，信息量从少到多依次为NONE、ERROR、WARN、INFO、DEBUG、VERBOSE、VERY_VERBOSE
#  baud_rate: 0 #设置为0关闭通过UART的log输出


globals:
  - id: txv
    type: std::vector<int>
    restore_value: false

button:
  - platform: template
    name: "irsend"
    id: "irsend"
    internal: true
    on_press:
      then:
        - remote_transmitter.transmit_raw:
            carrier_frequency: 38kHz
            code: !lambda |-
                    return id(txv);
remote_transmitter:
  pin: $gpio_ir_t
  carrier_duty_percent: 50%
  id: my_transmitter

复制代码

接下来就只需要在smartAC插件里面填入订阅的topic就行了。

sorrypqa

厉害！！俺一看到MQTT的东西就头痛！

ghostist

两个疑问：
1、为啥不用原生API而用mqtt呢，这么做的好处是？
2、还有原作不包含代码库索引后，在使用上有什么问题？

smartac刚出来那周我就吃上了，后续一直没更新过，用的挺好
硬件用的移动X12，在esphome里把电量计量也做进去了
然后通过巴法接到天猫，现在遥控器都没电好久了

trz0332

ghostist 发表于 2023-9-18 09:09
两个疑问：
1、为啥不用原生API而用mqtt呢，这么做的好处是？
2、还有原作不包含代码库索引后，在使用上有 ...

1、原生api需要在路由器里面绑定mac地址，如果不绑定，路由器重启ip变更后可能会出现2个esphome设备串IP，测点出不来，需要删除重新添加，使用mqtt就方便多了，配置好自动发现在mqtt里面就直接出现设备了。
2、使用没问题，就是需要你自己添加索引，而且需要去自己下载红外代码库。如果你有最开始的smartac插件就不要担心这个问题，旧版本是包含了索引库和红外代码库

ghostist

trz0332 发表于 2023-9-18 10:47
1、原生api需要在路由器里面绑定mac地址，如果不绑定，路由器重启ip变更后可能会出现2个esphome设备串IP， ...

哦 原来如此，好像出现过HA里识别到两个一样名字的ESP设备
不过我前阵子抽空把家里所有wifi设备都划分了静态IP，可能就没这个问题了

ryanh7

内存富余的可以这么干，大概会多占用3~4kB内存

mqtt:
  # .... 其他配置
  on_message:
    topic: climate/send
    qos: 0
    then:
      - remote_transmitter.transmit_raw:
          code: !lambda |-
            std::vector<int> data;
            DynamicJsonDocument json_document(JSON_ARRAY_SIZE(x.size() / 5));
            deserializeJson(json_document, x);
            JsonArray root = json_document.as<JsonArray>();
            int s = -1;
            for(auto value : root) {
                s *= -1;
                data.push_back(value.as<int>() * s);
            }
            return data;
          carrier_frequency: 38k

复制代码

trz0332

ryanh7 发表于 2023-9-19 10:51
内存富余的可以这么干，大概会多占用3~4kB内存

大神本尊驾到 顺便可以抄一下你的代码。

hongboy8899

学习

hongboy8899