ダイキンエアコン用スマートリモコンをDIYする

/// Class for handling detailed Daikin 64-bit A/C messages.

/// Class for handling detailed Daikin 312-bit A/C messages.
class IRDaikin2 {

#include <IRremoteESP8266.h>
#include <ir_Daikin.h>
const uint16_t kIrLed = 4; // ESP8266 GPIO pin to use. Recommended: 4 (D2).
IRDaikin2 daikin=IRDaikin2(kIrLed);

//base values for the IR Remote state (Daikin AC)
uint8_t coolState [kDaikin312StateLength] = { //28deg. off, cool, max, noswing
0x11, 0xDA, 0x27, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x13,
0x11, 0xDA, 0x27, 0x00, 0x00, 0x38, 0x38, 0x00, 0x70, 0x00, 0x00, 0x06, 0x60, 0x00, 0x00, 0xC1, 0x90, 0x00, 0xA9
};

void setup() {
  dht.begin(GPIO_SDA, GPIO_SCL); //DHT20
  daikin.setRaw(coolState); //initialize the raw value
  daikin.begin();
  client = new EspMQTTClient(SSID,PASS,MQTTADD,MQTTUSER,MQTTPASS,CLIENTID,MQTTPORT); 
  delay(1000);
}

daikin.setTemp(28); //引数は温度
daikin.send(0); //引数は繰り返し回数、実リモコンに合わせて一回だけ送出

uint8_t *raw=daikin.getRaw(); //get pointer to the IR state data
raw[25] = (raw[25] & 0xFE) | 0x01; //on

raw[25] = (raw[25] & 0xFE); //off

IRsend irsend(kIrLed); //for sending raw IR data
const uint16_t kDaikinLeader[12]= { 420, 420, 420, 420, 420, 420, 420, 420, 420, 420, 420, 25300 };

void send_daikin(){ //original is IRsend::sendDaikin2()
  uint8_t *data=daikin.getRaw();
  // Leader
  irsend.sendRaw(kDaikinLeader, 12, 38);//send 12 bytes with 38kHz
  // Section #1
  irsend.sendGeneric(kDaikin2HdrMark, kDaikin2HdrSpace, kDaikin2BitMark,
    kDaikin2OneSpace, kDaikin2BitMark, kDaikin2ZeroSpace,
    kDaikin2BitMark, kDaikin2Gap, data, kDaikin2Section1Length,
    kDaikin2Freq, false, 0, 50);
  // Section #2
  irsend.sendGeneric(kDaikin2HdrMark, kDaikin2HdrSpace, kDaikin2BitMark,
    kDaikin2OneSpace, kDaikin2BitMark, kDaikin2ZeroSpace,
    kDaikin2BitMark, kDaikin2Gap, data + kDaikin2Section1Length,
    kDaikin2Section2Length, kDaikin2Freq, false, 0, 50);
}

daikin.setTemp(28); //引数は温度
//daikin.send(0); //daikin.send()を呼び出す代わりに
daikin_send();  //自前で作ったdaikin_send()を呼び出す

//MQTT
#include  <EspMQTTClient.h>
EspMQTTClient *client; //instance of MQTT client

//WiFi & MQTT
const char SSID[] = "xxxxxxxx"; //WiFi SSID
const char PASS[] = "XXXXXXXX"; //WiFi password
char CLIENTID[] = "IRremote_07649874"; //something random
const char  MQTTADD[] = "xxx.xxx.xxx.xxx"; //Broker IP address
const short MQTTPORT = 1883; //Broker port
const char  MQTTUSER[] = "";//Can be omitted if not needed
const char  MQTTPASS[] = "";//Can be omitted if not needed
const char  SUBTOPIC[] = "mqttthing/irLiving/set/#"; //mqtt topic to subscribe
const char  DEBUG[] = "mqttthing/irLiving/debug"; //topic for debug
（略）

void setup() {
（略）
  client = new EspMQTTClient(SSID,PASS,MQTTADD,MQTTUSER,MQTTPASS,CLIENTID,MQTTPORT); 
（略）
}

void onMessageReceived(const String& topic, const String& message) { 
（略）
  if (command.equals("Active")) {
（略）
  }else if(command.equals("TargetHeaterCoolerState")){
（略）
  }else if(command.equals("CoolingThresholdTemperature")){
（略）
  }else if(command.equals("HeatingThresholdTemperature")){
（略）
  }else if(command.equals("SwingMode")){
（略）
}

void onConnectionEstablished() {
  client->subscribe(SUBTOPIC, onMessageReceived); //set callback function
（略）
}

void loop() {
  client->loop(); 
（略）
}

#define GPIO_SDA 21 //I2C for DHT20
#define GPIO_SCL 22 //I2C for DHT20
（略）

 void setup() { 
dht.begin(GPIO_SDA, GPIO_SCL); //DHT20 daikin.setRaw(coolState); //initialize the raw value daikin.begin(); Serial.begin(115200); while (!Serial); // wait for serial port to connect. client = new EspMQTTClient(SSID,PASS,MQTTADD,MQTTUSER,MQTTPASS,CLIENTID,MQTTPORT); delay(1000); }
（略）
}

//IR Remo and MQTT: read DHT20 and publish results
//check every 10 sec.
//if temp or humi change publish soon, otherwise publish every 5 min.
void publishDHT() { 
  char buff[64];
  static int count10=0; //counts up in every 10 sec.
  float humi, temp;
  static int oldhumi=0, oldtemp=0; //previous value
  int newhumi, newtemp; //new value
  if(millis() - dht.lastRead() < 10000) return;//do nothing < 10 sec. count10++; //count up 10 s counter if(DHT20_OK != dht.read()){ client->publish(DEBUG,"DHT20 Read Error.");
    return; //sensor error, do nothing.
  }
  //read the current temp and humi
  humi=dht.getHumidity();
  newhumi=round(humi);//int version
  temp=dht.getTemperature();
  newtemp=round(temp * 10);//int version (x10)
  //if measurement changes or 300 seconds passed
  if((oldtemp != newtemp) || (oldhumi != newhumi) || (count10 >= 30)){
    oldtemp=newtemp;
    oldhumi=newhumi;    
    sprintf(buff, "{\"temperature\":%.1f,\"humidity\":%.0f}", temp, humi);
    client->publish(PUBTOPIC,buff);
    count10=0; //reset counter
  }
}

void loop() {
（略）
  client->loop(); 
  publishDHT(); //publish temp and humi if needed
}

#include <ArduinoOTA.h>
（略）

void onConnectionEstablished() {
  ArduinoOTA.setHostname("irLiving");
  ArduinoOTA.setPasswordHash("xxxxxxxxxxxxxxxxxxxxxxx");
  ArduinoOTA.begin();
（略）
}

void loop() {
  ArduinoOTA.handle();
（略）
}

/* IRremoteESP8266 over MQTT */

#include <Arduino.h>
#include <ArduinoOTA.h>
#include <cstring> //for std::memcpy method

//IR Remote
#include <IRremoteESP8266.h>
#include <ir_Daikin.h>
const uint16_t kIrLed = 4;  // ESP8266 GPIO pin to use. Recommended: 4 (D2).
IRDaikin2 daikin=IRDaikin2(kIrLed);
//DHT sensor
#include "DHT20.h"
#define GPIO_SDA 21 //I2C for DHT20
#define GPIO_SCL 22 //I2C for DHT20
DHT20 dht; //instance of DHT20
//MQTT
#include <EspMQTTClient.h>
EspMQTTClient *client; //instance of MQTT client

//WiFi & MQTT
const char SSID[] = "xxxxxxxx"; //WiFi SSID
const char PASS[] = "XXXXXXXX"; //WiFi password
char CLIENTID[] = "IRremote_73140574"; //something random
const char  MQTTADD[] = "192.168.xxx.xxx"; //Broker IP address
const short MQTTPORT = 1883; //Broker port
const char  MQTTUSER[] = "";//Can be omitted if not needed
const char  MQTTPASS[] = "";//Can be omitted if not needed
const char  SUBTOPIC[] = "mqttthing/irLiving/set/#"; //mqtt topic to subscribe
const char  PUBTOPIC[] = "mqttthing/irLiving/get"; //to publish temperature
const char  DEBUG[] = "mqttthing/irLiving/debug"; //topic for debug

//base values for the IR Remote state (Daikin AC)
uint8_t coolState [kDaikin312StateLength] = { //28deg. off, cool, max, noswing
0x11, 0xDA, 0x27, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x13,
0x11, 0xDA, 0x27, 0x00, 0x00, 0x38, 0x38, 0x00, 0x70, 0x00, 0x00, 0x06, 0x60, 0x00, 0x00, 0xC1, 0x90, 0x00, 0xA9
};
uint8_t heatState [kDaikin312StateLength] = { //25deg, off, heat, max, noswing
0x11, 0xDA, 0x27, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x13,
0x11, 0xDA, 0x27, 0x00, 0x00, 0x48, 0x32, 0x00, 0x70, 0x00, 0x00, 0x06, 0x60, 0x00, 0x00, 0xC1, 0x90, 0x00, 0xB3
};

//Daikin IR remote Leader data
IRsend irsend(kIrLed);  //for sending raw IR data
const uint16_t kDaikinLeader[12]= { 420, 420, 420, 420, 420, 420, 420, 420, 420, 420, 420, 25300 };

void send_daikin(){
  uint8_t *data=daikin.getRaw();
  // Leader 
  irsend.sendRaw(kDaikinLeader, 12, 38);//send 12 bytes with 38kHz 
  // Section #1 
  irsend.sendGeneric(kDaikin2HdrMark, kDaikin2HdrSpace, kDaikin2BitMark, kDaikin2OneSpace, kDaikin2BitMark, kDaikin2ZeroSpace, kDaikin2BitMark, kDaikin2Gap, data, kDaikin2Section1Length, kDaikin2Freq, false, 0, 50); 
  // Section #2 
  irsend.sendGeneric(kDaikin2HdrMark, kDaikin2HdrSpace, kDaikin2BitMark, kDaikin2OneSpace, kDaikin2BitMark, kDaikin2ZeroSpace, kDaikin2BitMark, kDaikin2Gap, data + kDaikin2Section1Length, kDaikin2Section2Length, kDaikin2Freq, false, 0, 50); 
}

void setup() {
  dht.begin(GPIO_SDA, GPIO_SCL); //DHT20
  daikin.setRaw(coolState); //initialize the raw value
  daikin.begin();
  client = new EspMQTTClient(SSID,PASS,MQTTADD,MQTTUSER,MQTTPASS,CLIENTID,MQTTPORT); 
  delay(1000);
}

//just for debug
void debugRaw(){
  const uint8_t *raw=daikin.getRaw();
  char buf[kDaikin312StateLength * 2 + 1];
  int i;
  for(i=0;i<kDaikin312StateLength;i++){
    sprintf(&buf[i*2],"%02X",raw[i]);
  }
  buf[kDaikin312StateLength * 2]=0;
  client->publish(DEBUG,buf);
}

//when an MQTT message is received
void onMessageReceived(const String& topic, const String& message) { 
  String command = topic.substring(topic.lastIndexOf("/") + 1);
  
  uint8_t *raw=daikin.getRaw(); //get pointer to the IR state data

  if (command.equals("Active")) {
    if(message.equalsIgnoreCase("true")) raw[25] = (raw[25] & 0xFE) | 0x01; //on
    if(message.equalsIgnoreCase("false")) raw[25] = (raw[25] & 0xFE); //off
    daikin_send();
    debugRaw();
    client->publish(DEBUG,daikin.toString());
  }else if(command.equals("TargetHeaterCoolerState")){
    if(message.equalsIgnoreCase("COOL")) {
      switchMode(kDaikinCool);
    }
    if(message.equalsIgnoreCase("HEAT")) {
      switchMode(kDaikinHeat);
    }
  }else if(command.equals("CoolingThresholdTemperature")){
    daikin.setTemp(message.toInt());
    daikin_send();
    debugRaw();
    client->publish(DEBUG,daikin.toString());
  }else if(command.equals("HeatingThresholdTemperature")){
    daikin.setTemp(message.toInt());
    daikin_send();
    debugRaw();
    client->publish(DEBUG,daikin.toString());
  }else if(command.equals("SwingMode")){
    if(message.equalsIgnoreCase("DISABLED")) raw[28] = (raw[28] & 0xF0) | 0x00; //no swing    
    if(message.equalsIgnoreCase("ENABLED"))  raw[28] = (raw[28] & 0xF0) | 0x0F; //swing
    daikin_send();
    debugRaw();
    client->publish(DEBUG,daikin.toString());
  }else if(command.equals("RotationSpeed")){
    int speed = message.toInt();
    if     (speed < 20) raw[28] = (raw[28] & 0x0F) | 0xA0; //auto
    else if(speed < 40) raw[28] = (raw[28] & 0x0F) | 0xB0; //sizuka
    else if(speed < 50) raw[28] = (raw[28] & 0x0F) | 0x30; //level-1
    else if(speed < 60) raw[28] = (raw[28] & 0x0F) | 0x40; //level-2
    else if(speed < 70) raw[28] = (raw[28] & 0x0F) | 0x50; //level-3
    else if(speed < 80) raw[28] = (raw[28] & 0x0F) | 0x60; //level-4
    else                   raw[28] = (raw[28] & 0x0F) | 0x70; //level-5 max
   }
}

//when MQTT connection is established
void onConnectionEstablished() {
  ArduinoOTA.setHostname("irLiving");
  ArduinoOTA.setPasswordHash("xxxxxxxxxxxxxxxx");
  ArduinoOTA.begin();
  client->subscribe(SUBTOPIC, onMessageReceived); //set callback function
  client->publish(DEBUG,"irOffice started.");
}

//Backup and switch the operating mode.
void switchMode(const uint8_t targetmode){
  uint8_t currentmode;
  
  currentmode = daikin.getMode();
  if(targetmode == currentmode) return; //no switch, do nothing

  const uint8_t *raw=daikin.getRaw();
  
  if((currentmode == kDaikinHeat) && (targetmode == kDaikinCool)) {
    std::memcpy(heatState, raw, kDaikin312StateLength);
    daikin.setRaw(coolState);
  }
  if((currentmode == kDaikinCool) && (targetmode == kDaikinHeat)) {
    std::memcpy(coolState, raw, kDaikin312StateLength);
    daikin.setRaw(heatState);
  }
}

//read DHT20 and publish results
//check every 10 sec.
//if temp or humi change publish soon, otherwise publish every 5 min.
void publishDHT() { 
  char buff[64];
  static int count10=0; //counts up in every 10 sec.
  float humi, temp;
  static int oldhumi=0, oldtemp=0; //previous value
  int newhumi, newtemp; //new value
  if(millis() - dht.lastRead() < 10000) return;//do nothing < 10 sec.
  count10++; //count up 10 s counter
  if(DHT20_OK != dht.read()){
    client->publish(DEBUG,"DHT20 Read Error.");
    return; //sensor error, do nothing.
  }
  //read the current temp and humi
  humi=dht.getHumidity();
  newhumi=round(humi);//int version
  temp=dht.getTemperature();
  newtemp=round(temp * 10);//int version (x10)
  //if measurement changes or 300 seconds passed
  if((oldtemp != newtemp) || (oldhumi != newhumi) || (count10 >= 30)){
    oldtemp=newtemp;
    oldhumi=newhumi;    
    sprintf(buff, "{\"temperature\":%.1f,\"humidity\":%.0f}", temp, humi);
    client->publish(PUBTOPIC,buff);
    count10=0; //reset counter
  }
}

void loop() {
  ArduinoOTA.handle();
  client->loop(); 
  publishDHT(); //publish temp and humi if needed
}

{
  "type": "heaterCooler",
  "name": "Living Aircon",
  "url": "mqtt://localhost:1883",
  "topics": {
    "setActive": "mqttthing/irLiving/set/Active",
    "setCoolingThresholdTemperature": "mqttthing/irLiving/set/CoolingThresholdTemperature",
    "getCurrentTemperature": "mqttthing/irLiving/get$.temperature",
    "setHeatingThresholdTemperature": "mqttthing/irLiving/set/HeatingThresholdTemperature",
    "setRotationSpeed": "mqttthing/Irving/set/RotationSpeed",
    "setSwingMode": "mqttthing/irLiving/set/SwingMode",
    "setTargetHeaterCoolerState": "mqttthing/irLiving/set/TargetHeaterCoolerState"
  },
  "restrictHeaterCoolerState": [1,2],
  "accessory": "mqttthing"
},