#include <ESP8266WiFi.h>
#include <PubSubClient.h>
const char* ssid = "...";
const char* password = "...";
const char* mqtt_server = "xx.xx.xx.xx";
IPAddress ip(xx,xx,xx,x);
IPAddress gateway(xx,xx,xx,xx);
IPAddress subnet(xx,xx,xx,xx);
WiFiClient espClient;
PubSubClient client(espClient);
#define ID_CONNECT "myhome-Conditioner"
#define LED 12
#define LEN_B 37
#define B_CUR_TMP 13 //
#define B_CMD 17 // 00- 7F- ???
#define B_MODE 23 //04 - DRY, 01 - cool, 02 - heat, 00 - smart 03 -
#define B_FAN_SPD 25 // 02 - min, 01 - mid, 00 - max, 03 - auto
#define B_SWING 27 //01 - . 00 - . 02 - / . 03 -
#define B_LOCK_REM 28 //80 . 00 -
#define B_POWER 29 //on/off 01 - on, 00 - off (10, 11)-??? 09 - QUIET
#define B_FRESH 31 //fresh 00 - off, 01 - on
#define B_SET_TMP 35 //
int fresh;
int power;
int swing;
int lock_rem;
int cur_tmp;
int set_tmp;
int fan_spd;
int Mode;
long prev = 0;
byte inCheck = 0;
byte qstn[] = {255,255,10,0,0,0,0,0,1,1,77,1,90};
byte data[37] = {};
byte on[] = {255,255,10,0,0,0,0,0,1,1,77,2,91};
byte off[] = {255,255,10,0,0,0,0,0,1,1,77,3,92};
byte lock[] = {255,255,10,0,0,0,0,0,1,3,0,0,14};
void setup_wifi() {
delay(10);
WiFi.begin(ssid, password);
WiFi.config(ip, gateway, subnet);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
digitalWrite(LED, !digitalRead(LED));
}
digitalWrite(LED, HIGH);
}
void reconnect() {
digitalWrite(LED, !digitalRead(LED));
while (!client.connected()) {
if (client.connect(ID_CONNECT)) {
client.publish("myhome/Conditioner/connection", "true");
client.publish("myhome/Conditioner/RAW", "");
client.subscribe("myhome/Conditioner/#");
digitalWrite(LED, HIGH);
} else {
delay(5000);
}
}
}
void InsertData(byte data[], size_t size){
set_tmp = data[B_SET_TMP]+16;
cur_tmp = data[B_CUR_TMP];
Mode = data[B_MODE];
fan_spd = data[B_FAN_SPD];
swing = data[B_SWING];
power = data[B_POWER];
lock_rem = data[B_LOCK_REM];
fresh = data[B_FRESH];
if (fresh == 0x00){
client.publish("myhome/Conditioner/Fresh", "off");
}
if (fresh == 0x01){
client.publish("myhome/Conditioner/Fresh", "on");
}
if (lock_rem == 0x80){
client.publish("myhome/Conditioner/Lock_Remote", "true");
}
if (lock_rem == 0x00){
client.publish("myhome/Conditioner/Lock_Remote", "false");
}
if (power == 0x01 || power == 0x11){
client.publish("myhome/Conditioner/Power", "on");
}
if (power == 0x00 || power == 0x10){
client.publish("myhome/Conditioner/Power", "off");
}
if (power == 0x09){
client.publish("myhome/Conditioner/Power", "quiet");
}
if (power == 0x11 || power == 0x10){
client.publish("myhome/Conditioner/Compressor", "on");
} else {
client.publish("myhome/Conditioner/Compressor", "off");
}
if (swing == 0x00){
client.publish("myhome/Conditioner/Swing", "off");
}
if (swing == 0x01){
client.publish("myhome/Conditioner/Swing", "ud");
}
if (swing == 0x02){
client.publish("myhome/Conditioner/Swing", "lr");
}
if (swing == 0x03){
client.publish("myhome/Conditioner/Swing", "all");
}
if (fan_spd == 0x00){
client.publish("myhome/Conditioner/Fan_Speed", "max");
}
if (fan_spd == 0x01){
client.publish("myhome/Conditioner/Fan_Speed", "mid");
}
if (fan_spd == 0x02){
client.publish("myhome/Conditioner/Fan_Speed", "min");
}
if (fan_spd == 0x03){
client.publish("myhome/Conditioner/Fan_Speed", "auto");
}
char b[5];
String char_set_tmp = String(set_tmp);
char_set_tmp.toCharArray(b,5);
client.publish("myhome/Conditioner/Set_Temp", b);
String char_cur_tmp = String(cur_tmp);
char_cur_tmp.toCharArray(b,5);
client.publish("myhome/Conditioner/Current_Temp", b);
if (Mode == 0x00){
client.publish("myhome/Conditioner/Mode", "smart");
}
if (Mode == 0x01){
client.publish("myhome/Conditioner/Mode", "cool");
}
if (Mode == 0x02){
client.publish("myhome/Conditioner/Mode", "heat");
}
if (Mode == 0x03){
client.publish("myhome/Conditioner/Mode", "vent");
}
if (Mode == 0x04){
client.publish("myhome/Conditioner/Mode", "dry");
}
String raw_str;
char raw[75];
for (int i=0; i < 37; i++){
if (data[i] < 10){
raw_str += "0";
raw_str += String(data[i], HEX);
} else {
raw_str += String(data[i], HEX);
}
}
raw_str.toUpperCase();
raw_str.toCharArray(raw,75);
client.publish("myhome/Conditioner/RAW", raw);
}
byte getCRC(byte req[], size_t size){
byte crc = 0;
for (int i=2; i < size; i++){
crc += req[i];
}
return crc;
}
void SendData(byte req[], size_t size){
Serial.write(req, size - 1);
Serial.write(getCRC(req, size-1));
}
inline unsigned char toHex( char ch ){
return ( ( ch >= 'A' ) ? ( ch - 'A' + 0xA ) : ( ch - '0' ) ) & 0x0F;
}
void callback(char* topic, byte* payload, unsigned int length) {
payload[length] = '\0';
String strTopic = String(topic);
String strPayload = String((char*)payload);
if (strTopic == "myhome/Conditioner/Set_Temp"){
set_tmp = strPayload.toInt()-16;
if (set_tmp >= 0 && set_tmp <= 30){
data[B_SET_TMP] = set_tmp;
}
}
if (strTopic == "myhome/Conditioner/Mode"){
if (strPayload == "smart"){
data[B_MODE] = 0;
}
if (strPayload == "cool"){
data[B_MODE] = 1;
}
if (strPayload == "heat"){
data[B_MODE] = 2;
}
if (strPayload == "vent"){
data[B_MODE] = 3;
}
if (strPayload == "dry"){
data[B_MODE] = 4;
}
}
if (strTopic == "myhome/Conditioner/Fan_Speed"){
if (strPayload == "max"){
data[B_FAN_SPD] = 0;
}
if (strPayload == "mid"){
data[B_FAN_SPD] = 1;
}
if (strPayload == "min"){
data[B_FAN_SPD] = 2;
}
if (strPayload == "auto"){
data[B_FAN_SPD] = 3;
}
}
if (strTopic == "myhome/Conditioner/Swing"){
if (strPayload == "off"){
data[B_SWING] = 0;
}
if (strPayload == "ud"){
data[B_SWING] = 1;
}
if (strPayload == "lr"){
data[B_SWING] = 2;
}
if (strPayload == "all"){
data[B_SWING] = 3;
}
}
if (strTopic == "myhome/Conditioner/Lock_Remote"){
if (strPayload == "true"){
data[B_LOCK_REM] = 80;
}
if (strPayload == "false"){
data[B_LOCK_REM] = 0;
}
}
if (strTopic == "myhome/Conditioner/Power"){
if (strPayload == "off" || strPayload == "false" || strPayload == "0"){
SendData(off, sizeof(off)/sizeof(byte));
return;
}
if (strPayload == "on" || strPayload == "true" || strPayload == "1"){
SendData(on, sizeof(on)/sizeof(byte));
return;
}
if (strPayload == "quiet"){
data[B_POWER] = 9;
}
}
if (strTopic == "myhome/Conditioner/RAW"){
char buf[75];
char hexbyte[3] = {0};
strPayload.toCharArray(buf, 75);
int octets[sizeof(buf) / 2] ;
for (int i=0; i < 76; i += 2){
hexbyte[0] = buf[i] ;
hexbyte[1] = buf[i+1] ;
data[i/2] = (toHex(hexbyte[0]) << 4) | toHex(hexbyte[1]);
}
Serial.write(data, 37);
client.publish("myhome/Conditioner/RAW", buf);
}
data[B_CMD] = 0;
data[9] = 1;
data[10] = 77;
data[11] = 95;
SendData(data, sizeof(data)/sizeof(byte));
}
void setup() {
pinMode(LED, OUTPUT);
Serial.begin(9600);
setup_wifi();
client.setServer(mqtt_server, 1883);
client.setCallback(callback);
}
void loop() {
if(Serial.available() > 0){
Serial.readBytes(data, 37);
while(Serial.available()){
delay(2);
Serial.read();
}
if (data[36] != inCheck){
inCheck = data[36];
InsertData(data, 37);
}
}
if (!client.connected()){
reconnect();
}
client.loop();
long now = millis();
if (now - prev > 5000) {
prev = now;
SendData(qstn, sizeof(qstn)/sizeof(byte));
}
}