2023-08-25 18:38:17 +00:00
|
|
|
// #define USE_INTERRUPT
|
|
|
|
#include <ESPMegaPRO.h>
|
|
|
|
#include <ETH.h>
|
|
|
|
#include <PubSubClient.h>
|
|
|
|
#include <PubSubClientTools.h>
|
|
|
|
#include <Thread.h>
|
|
|
|
#include <StaticThreadController.h>
|
2023-08-27 19:07:04 +00:00
|
|
|
#include <IRremote.hpp>
|
|
|
|
#include <daikin_ir.hpp>
|
2023-08-28 17:49:11 +00:00
|
|
|
#include <dhtnew.h>
|
2023-09-03 09:28:01 +00:00
|
|
|
#include "EasyNextionLibrary.h"
|
|
|
|
#include <lcd.hpp>
|
2023-08-25 18:38:17 +00:00
|
|
|
|
|
|
|
// Network Connectivity
|
|
|
|
#define HOSTNAME "espmega-pro-r3"
|
|
|
|
const IPAddress IP(192, 168, 0, 210);
|
|
|
|
const IPAddress SUBNET(255, 255, 255, 0);
|
|
|
|
const IPAddress GATEWAY(192, 168, 0, 1);
|
|
|
|
const IPAddress DNS(10, 192, 1, 1);
|
|
|
|
const IPAddress MQTT_SERVER(192, 168, 0, 26);
|
2023-09-03 09:28:01 +00:00
|
|
|
bool standalone = true;
|
2023-08-25 18:38:17 +00:00
|
|
|
const int MQTT_PORT = 1883;
|
2023-08-26 08:22:59 +00:00
|
|
|
#define MQTT_BASE_TOPIC "/espmega/ProR3"
|
2023-08-28 17:49:11 +00:00
|
|
|
char STATE_REQUEST_TOPIC[75] = MQTT_BASE_TOPIC "/requeststate";
|
2023-08-25 18:38:17 +00:00
|
|
|
// #define MQTT_USE_AUTH
|
|
|
|
#ifdef MQTT_USE_AUTH
|
|
|
|
const char MQTT_USERNAME[] = "username";
|
|
|
|
const char MQTT_PASSWORD[] = "password";
|
|
|
|
#endif
|
|
|
|
|
|
|
|
// Inputs
|
2023-08-26 08:22:59 +00:00
|
|
|
#define VINT_COUNT 16
|
2023-08-25 18:38:17 +00:00
|
|
|
const int DEBOUNCE_TIME_MS = 50;
|
2023-08-26 08:22:59 +00:00
|
|
|
const int virtual_interrupt_pins[VINT_COUNT] = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15};
|
|
|
|
int virtual_interupt_state[VINT_COUNT];
|
|
|
|
unsigned long virtual_interupt_timer[VINT_COUNT];
|
2023-08-25 18:38:17 +00:00
|
|
|
|
|
|
|
// Outputs
|
|
|
|
#define PWM_COUNT 16
|
|
|
|
const int pwm_pins[PWM_COUNT] = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15};
|
|
|
|
int pwm_states[PWM_COUNT];
|
|
|
|
int pwm_values[PWM_COUNT];
|
2023-09-10 07:24:27 +00:00
|
|
|
// output = m*input+c
|
|
|
|
const float pwm_linear_scaling_m[PWM_COUNT] = {1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1};
|
|
|
|
const float pwm_linear_scaling_c[PWM_COUNT] = {0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0};
|
2023-08-25 18:38:17 +00:00
|
|
|
#define PWM_CYCLE_VALUES_COUNT 3
|
|
|
|
const int PWM_CYCLE_VALUES[PWM_CYCLE_VALUES_COUNT] = {50, 125, 255};
|
2023-08-28 17:49:11 +00:00
|
|
|
char PWM_SET_STATE_TOPIC[75] = MQTT_BASE_TOPIC "/pwm/00/set/state";
|
|
|
|
char PWM_SET_VALUE_TOPIC[75] = MQTT_BASE_TOPIC "/pwm/00/set/value";
|
2023-08-25 18:38:17 +00:00
|
|
|
|
2023-08-27 19:07:04 +00:00
|
|
|
// Infrared Transciever
|
2023-08-28 17:49:11 +00:00
|
|
|
#define IR_RECIEVE_PIN 32
|
|
|
|
#define IR_SEND_PIN 15
|
2023-08-27 19:07:04 +00:00
|
|
|
#define MARK_EXCESS_MICROS 20
|
2023-08-28 17:49:11 +00:00
|
|
|
#define RAW_BUFFER_LENGTH 750
|
|
|
|
|
2023-09-03 09:28:01 +00:00
|
|
|
// LCD
|
|
|
|
int lcd_current_page = 1;
|
2023-09-03 10:41:31 +00:00
|
|
|
int lcd_pwmAdj_id = 0;
|
2023-09-03 09:28:01 +00:00
|
|
|
EasyNex panel(Serial);
|
|
|
|
|
2023-08-28 17:49:11 +00:00
|
|
|
// Air Conditioner Control
|
|
|
|
/*
|
|
|
|
Mode 0: Off, 1: Cool, 2: Fan
|
|
|
|
Fan Speed 0: Auto, 1: High, 2: Mid, 3: Low
|
|
|
|
*/
|
|
|
|
#define DHT22_PIN 17
|
|
|
|
int ac_mode = 0;
|
|
|
|
int ac_fan_speed = 0;
|
|
|
|
int ac_temperature = 25;
|
|
|
|
#define AC_MAX_TEMPERATURE 30
|
|
|
|
#define AC_MIN_TEMPERATURE 18
|
|
|
|
char AC_SET_MODE_TOPIC[75] = MQTT_BASE_TOPIC "/ac/set/mode";
|
|
|
|
char AC_SET_FAN_TOPIC[75] = MQTT_BASE_TOPIC "/ac/set/fan_speed";
|
|
|
|
char AC_SET_TEMPERATURE_TOPIC[75] = MQTT_BASE_TOPIC "/ac/set/temperature";
|
|
|
|
char AC_MODE_TOPIC[75] = MQTT_BASE_TOPIC "/ac/mode";
|
|
|
|
char AC_FAN_TOPIC[75] = MQTT_BASE_TOPIC "/ac/fan_speed";
|
|
|
|
char AC_TEMPERATURE_TOPIC[75] = MQTT_BASE_TOPIC "/ac/temperature";
|
|
|
|
char AC_ROOM_TEMPERATURE_TOPIC[75] = MQTT_BASE_TOPIC "/ac/room_temperature";
|
|
|
|
char AC_HUMIDITY_TOPIC[75] = MQTT_BASE_TOPIC "/ac/humidity";
|
2023-08-27 19:07:04 +00:00
|
|
|
|
2023-08-25 18:38:17 +00:00
|
|
|
// Forward declaration
|
|
|
|
void virtual_interrupt_loop();
|
|
|
|
void virtual_interrupt_callback(int pin, int state);
|
|
|
|
void network_begin();
|
|
|
|
void mqtt_connect();
|
|
|
|
void mqtt_subscribe();
|
|
|
|
void thread_initialization();
|
2023-08-26 08:22:59 +00:00
|
|
|
void pwm_state_callback(String topic, String message);
|
|
|
|
void pwm_value_callback(String topic, String message);
|
|
|
|
void state_request_callback(String topic, String message);
|
2023-08-26 05:53:25 +00:00
|
|
|
void io_begin();
|
2023-08-27 19:07:04 +00:00
|
|
|
void ir_loop();
|
2023-08-25 18:38:17 +00:00
|
|
|
|
|
|
|
void publish_pwm_states();
|
|
|
|
void publish_pwm_state(int id);
|
|
|
|
void pwm_set_state(int id, int state);
|
|
|
|
void pwm_set_value(int id, int value);
|
|
|
|
void pwm_toggle(int id);
|
|
|
|
void pwm_toggle(int id1, int id2);
|
|
|
|
void pwm_cycle_value(int id);
|
|
|
|
boolean pwm_group_state(int id1, int id2);
|
|
|
|
|
2023-08-28 17:49:11 +00:00
|
|
|
void publish_ac_state();
|
|
|
|
void publish_env_state();
|
|
|
|
void ac_state_callback(String topic, String message);
|
|
|
|
void ac_set_state(int mode, int temperature, int fan_speed);
|
|
|
|
|
2023-08-26 08:22:59 +00:00
|
|
|
void publish_input_states();
|
|
|
|
void publish_input_state(int id);
|
|
|
|
void publish_input_state(int id, int state);
|
|
|
|
|
2023-09-03 09:28:01 +00:00
|
|
|
void lcd_begin();
|
|
|
|
void lcd_loop();
|
|
|
|
void lcd_refresh();
|
|
|
|
void lcd_refresh_pd();
|
|
|
|
void lcd_top_bar_update();
|
2023-09-03 10:41:31 +00:00
|
|
|
void trigger0();
|
|
|
|
void trigger1();
|
|
|
|
void trigger2();
|
2023-09-03 15:55:07 +00:00
|
|
|
void trigger3();
|
2023-09-03 10:41:31 +00:00
|
|
|
void trigger4();
|
2023-09-03 15:55:07 +00:00
|
|
|
void trigger5();
|
|
|
|
void trigger6();
|
|
|
|
void trigger7();
|
|
|
|
void trigger8();
|
|
|
|
void trigger9();
|
|
|
|
void trigger10();
|
|
|
|
void trigger11();
|
|
|
|
void trigger12();
|
|
|
|
void trigger13();
|
|
|
|
|
|
|
|
void lcd_ac_refresh_fan();
|
|
|
|
void lcd_ac_refresh_mode();
|
2023-09-03 09:28:01 +00:00
|
|
|
|
2023-08-26 08:22:59 +00:00
|
|
|
char PWM_STATE_TOPIC[75] = MQTT_BASE_TOPIC "/pwm/00/state";
|
|
|
|
char PWM_VALUE_TOPIC[75] = MQTT_BASE_TOPIC "/pwm/00/value";
|
|
|
|
char INPUTS_TOPIC[75] = MQTT_BASE_TOPIC "/input/00";
|
|
|
|
|
2023-08-25 18:38:17 +00:00
|
|
|
WiFiClient eth;
|
|
|
|
PubSubClient mqtt_client(MQTT_SERVER, 1883, eth);
|
|
|
|
PubSubClientTools mqtt(mqtt_client);
|
|
|
|
|
2023-08-28 17:49:11 +00:00
|
|
|
DHTNEW env_sensor(DHT22_PIN);
|
|
|
|
|
2023-08-25 18:38:17 +00:00
|
|
|
Thread mqtt_reconnector = Thread();
|
2023-08-28 17:49:11 +00:00
|
|
|
Thread environment_reporter = Thread();
|
|
|
|
StaticThreadController<2> thread_controller(&mqtt_reconnector, &environment_reporter);
|
2023-08-25 18:38:17 +00:00
|
|
|
|
2023-09-03 09:28:01 +00:00
|
|
|
Thread top_bar_updater = Thread();
|
|
|
|
Thread page_updater = Thread();
|
|
|
|
StaticThreadController<2> lcd_thread_controller(&top_bar_updater, &page_updater);
|
|
|
|
|
2023-08-25 18:38:17 +00:00
|
|
|
void setup()
|
|
|
|
{
|
|
|
|
Serial.begin(115200);
|
2023-09-03 09:28:01 +00:00
|
|
|
panel.begin(115200);
|
|
|
|
lcd_init();
|
|
|
|
lcd_begin();
|
|
|
|
lcd_send_command("boot_state.txt=\"Core Initializing . . .\"");
|
2023-08-25 18:38:17 +00:00
|
|
|
Serial.println("ESPMega R3 Initializing . . .");
|
2023-08-26 05:53:25 +00:00
|
|
|
ESPMega_begin();
|
2023-08-26 10:28:21 +00:00
|
|
|
io_begin();
|
2023-08-27 19:07:04 +00:00
|
|
|
Serial.println("Initializing Infrared . . .");
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_command("boot_state.txt=\"Infrared Initializing . . .\"");
|
2023-08-28 17:49:11 +00:00
|
|
|
IrReceiver.begin(IR_RECIEVE_PIN);
|
|
|
|
IrSender.begin(IR_SEND_PIN);
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_command("boot_state.txt=\"Network Initializing . . .\"");
|
2023-08-25 18:38:17 +00:00
|
|
|
network_begin();
|
|
|
|
Serial.println("Initializing MQTT . . .");
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_command("boot_state.txt=\"IoT Core Initializing . . .\"");
|
2023-08-25 18:38:17 +00:00
|
|
|
mqtt_connect();
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_command("boot_state.txt=\"Threads Initializing . . .\"");
|
2023-08-25 18:38:17 +00:00
|
|
|
thread_initialization();
|
2023-08-26 08:22:59 +00:00
|
|
|
Serial.println("Initialization Completed.");
|
|
|
|
Serial.println("Jumping to User Code.");
|
2023-09-10 07:24:27 +00:00
|
|
|
// Begin User Code
|
|
|
|
|
|
|
|
/*
|
|
|
|
Pre-NTP Implementation
|
|
|
|
*/
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_command("page dashboard");
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void loop()
|
|
|
|
{
|
|
|
|
virtual_interrupt_loop();
|
|
|
|
mqtt_client.loop();
|
|
|
|
ESPMega_loop();
|
2023-08-27 19:07:04 +00:00
|
|
|
ir_loop();
|
2023-08-26 05:53:25 +00:00
|
|
|
thread_controller.run();
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_loop();
|
2023-08-26 05:53:25 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void io_begin()
|
|
|
|
{
|
|
|
|
Serial.println("Initializing I/O . . .");
|
2023-08-28 17:49:11 +00:00
|
|
|
pinMode(IR_RECIEVE_PIN, INPUT_PULLUP);
|
|
|
|
pinMode(IR_SEND_PIN, OUTPUT);
|
2023-08-26 05:53:25 +00:00
|
|
|
memset(pwm_states, 0, PWM_COUNT);
|
2023-08-28 17:49:11 +00:00
|
|
|
for (int i = 0; i < PWM_COUNT; i++)
|
|
|
|
{
|
2023-08-26 10:28:21 +00:00
|
|
|
pwm_values[i] = 4095;
|
|
|
|
}
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void network_begin()
|
|
|
|
{
|
2023-08-26 05:53:25 +00:00
|
|
|
Serial.print("Initializing Network ");
|
2023-08-25 18:38:17 +00:00
|
|
|
ETH.begin();
|
2023-08-26 05:53:25 +00:00
|
|
|
ETH.setHostname(HOSTNAME);
|
|
|
|
ETH.config(IP, GATEWAY, SUBNET, DNS, DNS);
|
|
|
|
for (int i = 0; i < 3; i++)
|
|
|
|
{
|
|
|
|
delay(2500);
|
|
|
|
Serial.print(" .");
|
|
|
|
}
|
|
|
|
Serial.println();
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void mqtt_connect()
|
|
|
|
{
|
|
|
|
if (!mqtt_client.connected())
|
|
|
|
{
|
|
|
|
Serial.print("MQTT not connected, connecting . . .\n");
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_stop_bit();
|
2023-08-25 18:38:17 +00:00
|
|
|
#ifdef MQTT_USE_AUTH
|
|
|
|
mqtt_client.connect(HOSTNAME, MQTT_USERNAME, MQTT_PASSWORD);
|
|
|
|
#else
|
|
|
|
mqtt_client.connect(HOSTNAME);
|
|
|
|
#endif
|
|
|
|
if (mqtt_client.connected())
|
|
|
|
{
|
|
|
|
mqtt_subscribe();
|
|
|
|
Serial.print("MQTT connected\n");
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_stop_bit();
|
2023-08-26 08:22:59 +00:00
|
|
|
publish_pwm_states();
|
|
|
|
publish_input_states();
|
2023-08-28 17:49:11 +00:00
|
|
|
publish_ac_state();
|
2023-09-03 09:28:01 +00:00
|
|
|
standalone = false;
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
2023-09-03 09:28:01 +00:00
|
|
|
standalone = true;
|
2023-08-25 18:38:17 +00:00
|
|
|
Serial.print("MQTT not connected, continuing in standalone mode\n");
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_stop_bit();
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
2023-09-03 09:28:01 +00:00
|
|
|
lcd_send_stop_bit();
|
|
|
|
lcd_refresh();
|
|
|
|
lcd_top_bar_update();
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void mqtt_subscribe()
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
for (int i = 0; i < PWM_COUNT; i++)
|
|
|
|
{
|
|
|
|
PWM_SET_VALUE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 4] = ((i - i % 10) / 10) + '0';
|
|
|
|
PWM_SET_VALUE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 5] = (i % 10) + '0';
|
|
|
|
PWM_SET_STATE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 4] = ((i - i % 10) / 10) + '0';
|
|
|
|
PWM_SET_STATE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 5] = (i % 10) + '0';
|
|
|
|
mqtt.subscribe(PWM_SET_STATE_TOPIC, pwm_state_callback);
|
|
|
|
mqtt.subscribe(PWM_SET_VALUE_TOPIC, pwm_value_callback);
|
|
|
|
}
|
2023-08-28 17:49:11 +00:00
|
|
|
mqtt.subscribe(AC_SET_FAN_TOPIC, ac_state_callback);
|
|
|
|
mqtt.subscribe(AC_SET_TEMPERATURE_TOPIC, ac_state_callback);
|
|
|
|
mqtt.subscribe(AC_SET_MODE_TOPIC, ac_state_callback);
|
2023-08-26 08:22:59 +00:00
|
|
|
mqtt.subscribe(STATE_REQUEST_TOPIC, state_request_callback);
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void thread_initialization()
|
|
|
|
{
|
2023-08-26 05:53:25 +00:00
|
|
|
Serial.println("Initializing Threads . . .");
|
|
|
|
Serial.println("Initializing MQTT Thread . . .");
|
2023-08-25 18:38:17 +00:00
|
|
|
mqtt_reconnector.onRun(mqtt_connect);
|
2023-09-03 09:28:01 +00:00
|
|
|
mqtt_reconnector.setInterval(15000);
|
2023-08-28 17:49:11 +00:00
|
|
|
environment_reporter.onRun(publish_env_state);
|
|
|
|
environment_reporter.setInterval(5000);
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
2023-08-26 08:22:59 +00:00
|
|
|
void pwm_state_callback(String topic, String message)
|
2023-08-25 18:38:17 +00:00
|
|
|
{
|
2023-08-28 17:49:11 +00:00
|
|
|
int a = topic.charAt(sizeof(MQTT_BASE_TOPIC) + 4) - '0';
|
|
|
|
int b = topic.charAt(sizeof(MQTT_BASE_TOPIC) + 5) - '0';
|
2023-08-26 08:22:59 +00:00
|
|
|
int id = 10 * a + b;
|
2023-08-28 17:49:11 +00:00
|
|
|
if (message.compareTo("on") == 0)
|
2023-08-26 08:22:59 +00:00
|
|
|
{
|
|
|
|
pwm_set_state(id, true);
|
|
|
|
}
|
2023-08-28 17:49:11 +00:00
|
|
|
else if (message.compareTo("off") == 0)
|
2023-08-26 08:22:59 +00:00
|
|
|
{
|
|
|
|
pwm_set_state(id, false);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_value_callback(String topic, String message)
|
|
|
|
{
|
2023-08-28 17:49:11 +00:00
|
|
|
int a = topic.charAt(sizeof(MQTT_BASE_TOPIC) + 4) - '0';
|
|
|
|
int b = topic.charAt(sizeof(MQTT_BASE_TOPIC) + 5) - '0';
|
2023-08-26 08:22:59 +00:00
|
|
|
int id = 10 * a + b;
|
|
|
|
int value = message.toInt();
|
|
|
|
pwm_set_value(id, value);
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void virtual_interrupt_callback(int pin, int state)
|
|
|
|
{
|
2023-09-03 09:28:01 +00:00
|
|
|
|
2023-08-28 17:49:11 +00:00
|
|
|
publish_input_state(pin, state);
|
2023-09-03 09:28:01 +00:00
|
|
|
// Serial.printf("Pin %d changed to %d\n", pin, state);
|
|
|
|
if (lcd_current_page == 2)
|
|
|
|
panel.writeNum("I" + String(pin) + ".val", state);
|
2023-08-28 17:49:11 +00:00
|
|
|
if (pin == 15)
|
|
|
|
{
|
2023-08-26 10:28:21 +00:00
|
|
|
pwm_toggle(4);
|
|
|
|
}
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void virtual_interrupt_loop()
|
|
|
|
{
|
|
|
|
for (int i = 0; i < 16; i++)
|
|
|
|
{
|
|
|
|
int current_pin_value = ESPMega_digitalRead(virtual_interrupt_pins[i]);
|
|
|
|
if (virtual_interupt_state[i] != current_pin_value)
|
|
|
|
{
|
|
|
|
if (millis() - virtual_interupt_timer[i] > DEBOUNCE_TIME_MS)
|
|
|
|
{
|
|
|
|
virtual_interupt_state[i] = current_pin_value;
|
|
|
|
virtual_interrupt_callback(i, current_pin_value);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
virtual_interupt_timer[i] = millis();
|
|
|
|
}
|
|
|
|
yield();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void publish_pwm_states()
|
|
|
|
{
|
|
|
|
for (int i = 0; i < PWM_COUNT; i++)
|
|
|
|
{
|
|
|
|
publish_pwm_state(i);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void publish_pwm_state(int id)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
int state = pwm_states[id];
|
|
|
|
int value = pwm_values[id];
|
|
|
|
PWM_STATE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 4] = ((id - id % 10) / 10) + '0';
|
|
|
|
PWM_STATE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 5] = (id % 10) + '0';
|
2023-09-03 10:41:31 +00:00
|
|
|
PWM_VALUE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 4] = ((id - id % 10) / 10) + '0';
|
|
|
|
PWM_VALUE_TOPIC[sizeof(MQTT_BASE_TOPIC) + 5] = (id % 10) + '0';
|
2023-08-25 18:38:17 +00:00
|
|
|
if (state == 1)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
mqtt_client.publish(PWM_STATE_TOPIC, "on");
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
else if (state == 0)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
mqtt_client.publish(PWM_STATE_TOPIC, "off");
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
2023-08-26 08:22:59 +00:00
|
|
|
mqtt.publish(String(PWM_VALUE_TOPIC), String(value));
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_set_state(int id, int state)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
if (state != pwm_states[id])
|
2023-08-25 18:38:17 +00:00
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
pwm_states[id] = state;
|
|
|
|
int pwm_value = pwm_values[id];
|
|
|
|
ESPMega_analogWrite(pwm_pins[id], state * (int)(pwm_linear_scaling_m[id] * pwm_value + pwm_linear_scaling_c[id]));
|
2023-09-03 09:28:01 +00:00
|
|
|
if (lcd_current_page == 3)
|
2023-09-03 10:41:31 +00:00
|
|
|
panel.writeNum("j" + String(id) + ".pco", state ? 47829 : 12710);
|
|
|
|
else if (lcd_current_page == 5 && id == lcd_pwmAdj_id)
|
|
|
|
panel.writeStr("pwm_state.txt", pwm_states[lcd_pwmAdj_id] ? "ON" : "OFF");
|
2023-08-25 18:38:17 +00:00
|
|
|
publish_pwm_state(id);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_set_value(int id, int value)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
pwm_values[id] = value;
|
|
|
|
int pwm_state = pwm_states[id];
|
|
|
|
ESPMega_analogWrite(pwm_pins[id], pwm_state * (int)(pwm_linear_scaling_m[id] * value + pwm_linear_scaling_c[id]));
|
2023-09-03 09:28:01 +00:00
|
|
|
if (lcd_current_page == 3)
|
|
|
|
panel.writeNum("j" + String(id) + ".val", int(value / 4095.0 * 100.0));
|
2023-09-03 10:41:31 +00:00
|
|
|
else if (lcd_current_page == 5 && id == lcd_pwmAdj_id)
|
|
|
|
panel.writeNum("pwm_value.val", pwm_values[lcd_pwmAdj_id]);
|
2023-08-25 18:38:17 +00:00
|
|
|
publish_pwm_state(id);
|
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_toggle(int id)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
int state = !pwm_states[id];
|
2023-08-25 18:38:17 +00:00
|
|
|
pwm_set_state(id, state);
|
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_toggle(int id1, int id2)
|
|
|
|
{
|
|
|
|
boolean state = pwm_group_state(id1, id2);
|
|
|
|
if (state)
|
|
|
|
{
|
|
|
|
pwm_set_state(id1, 0);
|
|
|
|
pwm_set_state(id2, 0);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
pwm_set_state(id1, 1);
|
|
|
|
pwm_set_state(id2, 1);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
boolean pwm_group_state(int id1, int id2)
|
|
|
|
{
|
|
|
|
int state1 = pwm_states[id1 - 1], state2 = pwm_states[id2 - 1];
|
|
|
|
if (state1 || state2)
|
|
|
|
return true;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
void pwm_cycle_value(int id)
|
|
|
|
{
|
2023-08-26 08:22:59 +00:00
|
|
|
int state = pwm_states[id];
|
|
|
|
int value = pwm_values[id];
|
2023-08-25 18:38:17 +00:00
|
|
|
if (state == 1)
|
|
|
|
for (int i = 0; i < PWM_CYCLE_VALUES_COUNT; i++)
|
|
|
|
{
|
|
|
|
if (PWM_CYCLE_VALUES[i] == value)
|
|
|
|
{
|
|
|
|
if (i > 0)
|
|
|
|
{
|
|
|
|
pwm_set_value(id, PWM_CYCLE_VALUES[i - 1]);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
pwm_set_state(id, 0);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
pwm_set_state(id, 1);
|
|
|
|
pwm_set_value(id, PWM_CYCLE_VALUES[PWM_CYCLE_VALUES_COUNT - 1]);
|
2023-08-26 08:22:59 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void publish_input_states()
|
|
|
|
{
|
|
|
|
for (int i = 0; i < VINT_COUNT; i++)
|
|
|
|
{
|
|
|
|
publish_input_state(i);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
void publish_input_state(int id)
|
|
|
|
{
|
|
|
|
int state = ESPMega_digitalRead(virtual_interrupt_pins[id]);
|
|
|
|
publish_input_state(id, state);
|
|
|
|
}
|
|
|
|
|
|
|
|
void publish_input_state(int id, int state)
|
|
|
|
{
|
|
|
|
char INPUTS_TOPIC[75] = MQTT_BASE_TOPIC "/input/00";
|
|
|
|
INPUTS_TOPIC[sizeof(MQTT_BASE_TOPIC) + 6] = ((id - id % 10) / 10) + '0';
|
|
|
|
INPUTS_TOPIC[sizeof(MQTT_BASE_TOPIC) + 7] = (id % 10) + '0';
|
|
|
|
mqtt.publish(String(INPUTS_TOPIC), state ? "1" : "0");
|
|
|
|
}
|
|
|
|
|
|
|
|
void state_request_callback(String topic, String message)
|
|
|
|
{
|
|
|
|
publish_input_states();
|
|
|
|
publish_pwm_states();
|
2023-08-28 17:49:11 +00:00
|
|
|
publish_ac_state();
|
2023-08-27 19:07:04 +00:00
|
|
|
}
|
|
|
|
|
2023-08-28 17:49:11 +00:00
|
|
|
void ir_loop()
|
|
|
|
{
|
|
|
|
if (IrReceiver.decode())
|
|
|
|
{
|
2023-09-03 09:28:01 +00:00
|
|
|
// Serial.println();
|
|
|
|
// IrReceiver.compensateAndPrintIRResultAsCArray(&Serial, false);
|
|
|
|
// Serial.println();
|
|
|
|
// Serial.println();
|
2023-08-28 17:49:11 +00:00
|
|
|
IrReceiver.resume();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void publish_ac_state()
|
|
|
|
{
|
|
|
|
String temp = "";
|
|
|
|
switch (ac_mode)
|
|
|
|
{
|
|
|
|
case 0:
|
|
|
|
temp = "off";
|
|
|
|
break;
|
|
|
|
case 1:
|
|
|
|
temp = "cool";
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
temp = "fan";
|
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
mqtt.publish(String(AC_MODE_TOPIC), temp);
|
|
|
|
mqtt.publish(String(AC_TEMPERATURE_TOPIC), String(ac_temperature));
|
|
|
|
switch (ac_fan_speed)
|
|
|
|
{
|
|
|
|
case 0:
|
|
|
|
temp = "auto";
|
|
|
|
break;
|
|
|
|
case 1:
|
|
|
|
temp = "high";
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
temp = "med";
|
|
|
|
break;
|
|
|
|
case 3:
|
|
|
|
temp = "low";
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
mqtt.publish(String(AC_FAN_TOPIC), temp);
|
|
|
|
}
|
|
|
|
|
|
|
|
void ac_state_callback(String topic, String message)
|
|
|
|
{
|
|
|
|
if (topic.compareTo(String(AC_SET_TEMPERATURE_TOPIC)) == 0)
|
|
|
|
{
|
|
|
|
int new_temp = message.toInt();
|
|
|
|
if (new_temp >= AC_MIN_TEMPERATURE && new_temp <= AC_MAX_TEMPERATURE)
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, new_temp, ac_fan_speed);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else if (topic.compareTo(String(AC_SET_MODE_TOPIC)) == 0)
|
|
|
|
{
|
|
|
|
if (message.compareTo("off") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(0, ac_temperature, ac_fan_speed);
|
2023-08-27 19:07:04 +00:00
|
|
|
}
|
2023-08-28 17:49:11 +00:00
|
|
|
else if (message.compareTo("cool") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(1, ac_temperature, ac_fan_speed);
|
|
|
|
}
|
|
|
|
else if (message.compareTo("fan") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(2, ac_temperature, ac_fan_speed);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else if (topic.compareTo(String(AC_SET_FAN_TOPIC)) == 0)
|
|
|
|
{
|
|
|
|
if (message.compareTo("auto") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 0);
|
|
|
|
}
|
|
|
|
else if (message.compareTo("low") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 1);
|
|
|
|
}
|
|
|
|
else if (message.compareTo("med") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 2);
|
|
|
|
}
|
|
|
|
else if (message.compareTo("high") == 0)
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 3);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void ac_set_state(int mode, int temperature, int fan_speed)
|
|
|
|
{
|
|
|
|
ac_mode = mode;
|
|
|
|
ac_temperature = temperature;
|
|
|
|
ac_fan_speed = fan_speed;
|
|
|
|
temperature -= AC_MIN_TEMPERATURE;
|
2023-09-03 15:55:07 +00:00
|
|
|
|
|
|
|
if (lcd_current_page == 4)
|
|
|
|
{
|
|
|
|
lcd_ac_refresh_fan();
|
|
|
|
lcd_ac_refresh_mode();
|
|
|
|
if (ac_mode != 2)
|
|
|
|
panel.writeStr("temp.txt", String(ac_temperature) + "C");
|
|
|
|
else
|
|
|
|
panel.writeStr("temp.txt", "--C");
|
|
|
|
}
|
2023-08-28 17:49:11 +00:00
|
|
|
publish_ac_state();
|
|
|
|
switch (mode)
|
|
|
|
{
|
|
|
|
case 0:
|
|
|
|
IrSender.sendRaw(ir_code_off, sizeof(ir_code_off) / sizeof(ir_code_off[0]), NEC_KHZ);
|
|
|
|
break;
|
|
|
|
case 1:
|
|
|
|
IrSender.sendRaw(ir_code_cool[fan_speed][temperature], sizeof(ir_code_cool[fan_speed][temperature]) / sizeof(ir_code_cool[fan_speed][0]), NEC_KHZ);
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
IrSender.sendRaw(ir_code_fan[fan_speed], sizeof(ir_code_fan[fan_speed]) / sizeof(ir_code_fan[fan_speed][0]), NEC_KHZ);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void publish_env_state()
|
|
|
|
{
|
|
|
|
int errorCode = env_sensor.read();
|
|
|
|
yield();
|
|
|
|
switch (errorCode)
|
|
|
|
{
|
|
|
|
case DHTLIB_OK:
|
|
|
|
mqtt.publish(String(AC_ROOM_TEMPERATURE_TOPIC), String(env_sensor.getTemperature()));
|
|
|
|
mqtt_client.loop();
|
|
|
|
mqtt.publish(String(AC_HUMIDITY_TOPIC), String(env_sensor.getHumidity()));
|
|
|
|
mqtt_client.loop();
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
mqtt.publish(String(AC_ROOM_TEMPERATURE_TOPIC), "ERROR");
|
|
|
|
mqtt_client.loop();
|
|
|
|
mqtt.publish(String(AC_HUMIDITY_TOPIC), "ERROR");
|
|
|
|
mqtt_client.loop();
|
|
|
|
}
|
2023-09-03 09:28:01 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void lcd_begin()
|
|
|
|
{
|
|
|
|
top_bar_updater.onRun(lcd_top_bar_update);
|
|
|
|
top_bar_updater.setInterval(10000);
|
|
|
|
page_updater.onRun(lcd_refresh_pd);
|
|
|
|
page_updater.setInterval(5000);
|
|
|
|
lcd_refresh();
|
|
|
|
}
|
|
|
|
|
|
|
|
void lcd_loop()
|
|
|
|
{
|
|
|
|
lcd_thread_controller.run();
|
|
|
|
panel.NextionListen();
|
|
|
|
if (panel.currentPageId != lcd_current_page)
|
|
|
|
{
|
|
|
|
lcd_current_page = panel.currentPageId;
|
|
|
|
lcd_refresh();
|
|
|
|
lcd_top_bar_update();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void lcd_refresh_pd()
|
|
|
|
{
|
|
|
|
if (lcd_current_page == 1)
|
|
|
|
{
|
|
|
|
lcd_refresh();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void lcd_refresh()
|
|
|
|
{
|
|
|
|
switch (lcd_current_page)
|
|
|
|
{
|
|
|
|
case 1:
|
|
|
|
panel.writeStr("hostname.txt", HOSTNAME);
|
|
|
|
panel.writeStr("server_address.txt", MQTT_SERVER.toString());
|
|
|
|
panel.writeStr("ip_address.txt", IP.toString());
|
|
|
|
panel.writeStr("status_txt.txt", standalone ? "Standalone" : "BMS Managed");
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
for (int i = 0; i <= 15; i++)
|
|
|
|
{
|
|
|
|
panel.writeNum("I" + String(i) + ".val", virtual_interupt_state[i]);
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
case 3:
|
|
|
|
for (int i = 0; i <= 15; i++)
|
|
|
|
{
|
|
|
|
panel.writeNum("j" + String(i) + ".val", int(pwm_values[i] / 4095.0 * 100.0));
|
2023-09-03 10:41:31 +00:00
|
|
|
panel.writeNum("j" + String(i) + ".pco", pwm_states[i] ? 47829 : 12710);
|
2023-09-03 09:28:01 +00:00
|
|
|
}
|
|
|
|
break;
|
2023-09-03 15:55:07 +00:00
|
|
|
case 4:
|
|
|
|
if (ac_mode != 2)
|
|
|
|
panel.writeStr("temp.txt", String(ac_temperature) + "C");
|
|
|
|
else
|
|
|
|
panel.writeStr("temp.txt", "--C");
|
|
|
|
lcd_ac_refresh_fan();
|
|
|
|
lcd_ac_refresh_mode();
|
2023-09-03 10:41:31 +00:00
|
|
|
case 5:
|
|
|
|
panel.writeStr("pwm_id.txt", String("P") + String(lcd_pwmAdj_id));
|
|
|
|
panel.writeStr("pwm_state.txt", pwm_states[lcd_pwmAdj_id] ? "ON" : "OFF");
|
|
|
|
panel.writeNum("pwm_value.val", pwm_values[lcd_pwmAdj_id]);
|
|
|
|
break;
|
2023-09-03 15:55:07 +00:00
|
|
|
|
2023-09-03 09:28:01 +00:00
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
void lcd_top_bar_update()
|
|
|
|
{
|
2023-09-10 07:24:27 +00:00
|
|
|
String time_str = String(rtc.getHour())+":"+String(rtc.getMinute());
|
|
|
|
panel.writeStr("time.txt", time_str);
|
2023-09-03 09:28:01 +00:00
|
|
|
panel.writeNum("server.pic", standalone ? 4 : 5);
|
|
|
|
panel.writeNum("lan.pic", ETH.linkUp() ? 3 : 2);
|
2023-09-03 10:41:31 +00:00
|
|
|
}
|
|
|
|
|
2023-09-03 15:55:07 +00:00
|
|
|
void lcd_ac_refresh_mode()
|
|
|
|
{
|
|
|
|
// auto high mid low
|
|
|
|
panel.writeNum("mode_cool.pic", ac_mode == 1 ? 12 : 13);
|
|
|
|
panel.writeNum("mode_fan.pic", ac_mode == 2 ? 22 : 23);
|
|
|
|
panel.writeNum("mode_off.pic", ac_mode == 0 ? 24 : 25);
|
|
|
|
}
|
|
|
|
|
|
|
|
void lcd_ac_refresh_fan()
|
|
|
|
{
|
|
|
|
panel.writeNum("fan_auto.pic", ac_fan_speed == 0 ? 14 : 15);
|
|
|
|
panel.writeNum("fan_low.pic", ac_fan_speed == 3 ? 18 : 19);
|
|
|
|
panel.writeNum("fan_mid.pic", ac_fan_speed == 2 ? 20 : 21);
|
|
|
|
panel.writeNum("fan_high.pic", ac_fan_speed == 1 ? 16 : 17);
|
|
|
|
}
|
|
|
|
|
2023-09-03 10:41:31 +00:00
|
|
|
void trigger0()
|
|
|
|
{
|
|
|
|
if (lcd_pwmAdj_id >= 15)
|
|
|
|
lcd_pwmAdj_id = 0;
|
|
|
|
else
|
|
|
|
lcd_pwmAdj_id++;
|
|
|
|
lcd_refresh();
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger1()
|
|
|
|
{
|
|
|
|
if (lcd_pwmAdj_id <= 0)
|
|
|
|
lcd_pwmAdj_id = 15;
|
|
|
|
else
|
|
|
|
lcd_pwmAdj_id--;
|
|
|
|
lcd_refresh();
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger2()
|
|
|
|
{
|
|
|
|
pwm_toggle(lcd_pwmAdj_id);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger3()
|
|
|
|
{
|
|
|
|
int value = panel.readNumber("pwm_value.val");
|
|
|
|
lcd_send_stop_bit();
|
2023-09-03 15:55:07 +00:00
|
|
|
pwm_set_value(lcd_pwmAdj_id, value);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger4()
|
|
|
|
{
|
|
|
|
if (ac_temperature < AC_MAX_TEMPERATURE && ac_mode != 2)
|
|
|
|
ac_set_state(ac_mode, ac_temperature + 1, ac_fan_speed);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger5()
|
|
|
|
{
|
|
|
|
if (ac_temperature > AC_MIN_TEMPERATURE && ac_mode != 2)
|
|
|
|
ac_set_state(ac_mode, ac_temperature - 1, ac_fan_speed);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger6()
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger7()
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 3);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger8()
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 2);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger9()
|
|
|
|
{
|
|
|
|
ac_set_state(ac_mode, ac_temperature, 1);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger10()
|
|
|
|
{
|
|
|
|
ac_set_state(1, ac_temperature, ac_fan_speed);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger11()
|
|
|
|
{
|
|
|
|
ac_set_state(2, ac_temperature, ac_fan_speed);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger12()
|
|
|
|
{
|
|
|
|
ac_set_state(0, ac_temperature, ac_fan_speed);
|
|
|
|
}
|
|
|
|
|
|
|
|
void trigger13()
|
|
|
|
{
|
2023-08-25 18:38:17 +00:00
|
|
|
}
|