mirror of
https://github.com/ratgdo/esphome-ratgdo.git
synced 2025-02-09 01:04:30 +00:00
fix
This commit is contained in:
J. Nick Koston
parent
2a1d2f053c
commit
b15063763a
@ -2,12 +2,13 @@ import esphome.codegen as cg
|
|||||||
import esphome.config_validation as cv
|
import esphome.config_validation as cv
|
||||||
from esphome.const import CONF_ID
|
from esphome.const import CONF_ID
|
||||||
from esphome import pins, automation
|
from esphome import pins, automation
|
||||||
|
from esphome.components import uart
|
||||||
|
|
||||||
DEPENDENCIES = ["preferences"]
|
DEPENDENCIES = ["preferences", "uart"]
|
||||||
|
|
||||||
|
|
||||||
ratgdo_ns = cg.esphome_ns.namespace("ratgdo")
|
ratgdo_ns = cg.esphome_ns.namespace("ratgdo")
|
||||||
RATGDO = ratgdo_ns.class_("RATGDOComponent", cg.Component)
|
RATGDO = ratgdo_ns.class_("RATGDOComponent", cg.Component, uart.UARTDevice)
|
||||||
|
|
||||||
|
|
||||||
CONF_OUTPUT_GDO = "output_gdo_pin"
|
CONF_OUTPUT_GDO = "output_gdo_pin"
|
||||||
@ -46,7 +47,7 @@ CONFIG_SCHEMA = cv.Schema(
|
|||||||
cv.Optional(CONF_STATUS_DOOR, default=DEFAULT_STATUS_DOOR): pins.internal_gpio_input_pin_schema,
|
cv.Optional(CONF_STATUS_DOOR, default=DEFAULT_STATUS_DOOR): pins.internal_gpio_input_pin_schema,
|
||||||
cv.Optional(CONF_STATUS_OBST, default=DEFAULT_STATUS_OBST): pins.internal_gpio_input_pin_schema,
|
cv.Optional(CONF_STATUS_OBST, default=DEFAULT_STATUS_OBST): pins.internal_gpio_input_pin_schema,
|
||||||
}
|
}
|
||||||
).extend(cv.COMPONENT_SCHEMA)
|
).extend(cv.COMPONENT_SCHEMA).extend(uart.UART_DEVICE_SCHEMA)
|
||||||
|
|
||||||
|
|
||||||
async def to_code(config):
|
async def to_code(config):
|
||||||
|
|||||||
@ -88,443 +88,445 @@ namespace ratgdo {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void RATGDOComponent::setup()
|
class RATGDOComponent : public Component, public UARTDevice {
|
||||||
{
|
public:
|
||||||
this->pref_ = global_preferences->make_preference<int>(734874333U);
|
RATGDOComponent(UARTComponent *parent) : UARTDevice(parent) {}
|
||||||
if (!this->pref_.load(&this->rollingCodeCounter)) {
|
|
||||||
this->rollingCodeCounter = 0;
|
void setup()
|
||||||
|
{
|
||||||
|
this->pref_ = global_preferences->make_preference<int>(734874333U);
|
||||||
|
if (!this->pref_.load(&this->rollingCodeCounter)) {
|
||||||
|
this->rollingCodeCounter = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
this->output_gdo_pin_->setup();
|
||||||
|
this->input_gdo_pin_->setup();
|
||||||
|
this->input_obst_pin_->setup();
|
||||||
|
|
||||||
|
this->trigger_open_pin_->setup();
|
||||||
|
this->trigger_close_pin_->setup();
|
||||||
|
this->trigger_light_pin_->setup();
|
||||||
|
|
||||||
|
this->status_door_pin_->setup();
|
||||||
|
this->status_obst_pin_->setup();
|
||||||
|
|
||||||
|
this->store_.input_obst = this->input_obst_pin_->to_isr();
|
||||||
|
|
||||||
|
this->store_.trigger_open = this->trigger_open_pin_->to_isr();
|
||||||
|
this->store_.trigger_close = this->trigger_close_pin_->to_isr();
|
||||||
|
this->store_.trigger_light = this->trigger_light_pin_->to_isr();
|
||||||
|
|
||||||
|
this->trigger_open_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
||||||
|
this->trigger_close_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
||||||
|
this->trigger_light_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
||||||
|
|
||||||
|
this->status_door_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
||||||
|
this->status_obst_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
||||||
|
|
||||||
|
//this->output_gdo_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
||||||
|
//this->input_gdo_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
||||||
|
this->input_obst_pin_->pin_mode(gpio::FLAG_INPUT);
|
||||||
|
|
||||||
|
this->swSerial.begin(9600, SWSERIAL_8N1, this->input_gdo_pin_->get_pin(), this->output_gdo_pin_->get_pin(), true);
|
||||||
|
|
||||||
|
this->trigger_open_pin_->attach_interrupt(RATGDOStore::isrDoorOpen, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
||||||
|
this->trigger_close_pin_->attach_interrupt(RATGDOStore::isrDoorClose, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
||||||
|
this->trigger_light_pin_->attach_interrupt(RATGDOStore::isrLight, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
||||||
|
this->input_obst_pin_->attach_interrupt(RATGDOStore::isrObstruction, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
||||||
|
|
||||||
|
ESP_LOGD(TAG, "Syncing rolling code counter after reboot...");
|
||||||
|
sync(); // if rolling codes are being used (rolling code counter > 0), send
|
||||||
|
// reboot/sync to the opener on startup
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
this->output_gdo_pin_->setup();
|
void loop()
|
||||||
this->input_gdo_pin_->setup();
|
{
|
||||||
this->input_obst_pin_->setup();
|
ESP_LOGD(TAG, "loop rollingCodeCounter: %d", this->rollingCodeCounter);
|
||||||
|
obstructionLoop();
|
||||||
this->trigger_open_pin_->setup();
|
gdoStateLoop();
|
||||||
this->trigger_close_pin_->setup();
|
dryContactLoop();
|
||||||
this->trigger_light_pin_->setup();
|
statusUpdateLoop();
|
||||||
|
//ESP_LOGD(TAG, "Door State: %s", this->doorState.c_str());
|
||||||
this->status_door_pin_->setup();
|
|
||||||
this->status_obst_pin_->setup();
|
|
||||||
|
|
||||||
this->store_.input_obst = this->input_obst_pin_->to_isr();
|
|
||||||
|
|
||||||
this->store_.trigger_open = this->trigger_open_pin_->to_isr();
|
|
||||||
this->store_.trigger_close = this->trigger_close_pin_->to_isr();
|
|
||||||
this->store_.trigger_light = this->trigger_light_pin_->to_isr();
|
|
||||||
|
|
||||||
this->trigger_open_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
|
||||||
this->trigger_close_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
|
||||||
this->trigger_light_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
|
||||||
|
|
||||||
this->status_door_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
|
||||||
this->status_obst_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
|
||||||
|
|
||||||
//this->output_gdo_pin_->pin_mode(gpio::FLAG_OUTPUT);
|
|
||||||
//this->input_gdo_pin_->pin_mode(gpio::FLAG_INPUT | gpio::FLAG_PULLUP);
|
|
||||||
this->input_obst_pin_->pin_mode(gpio::FLAG_INPUT);
|
|
||||||
|
|
||||||
this->swSerial.begin(9600, SWSERIAL_8N1, this->input_gdo_pin_->get_pin(), this->output_gdo_pin_->get_pin(), true);
|
|
||||||
|
|
||||||
this->trigger_open_pin_->attach_interrupt(RATGDOStore::isrDoorOpen, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
|
||||||
this->trigger_close_pin_->attach_interrupt(RATGDOStore::isrDoorClose, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
|
||||||
this->trigger_light_pin_->attach_interrupt(RATGDOStore::isrLight, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
|
||||||
this->input_obst_pin_->attach_interrupt(RATGDOStore::isrObstruction, &this->store_, gpio::INTERRUPT_ANY_EDGE);
|
|
||||||
|
|
||||||
ESP_LOGD(TAG, "Syncing rolling code counter after reboot...");
|
|
||||||
sync(); // if rolling codes are being used (rolling code counter > 0), send
|
|
||||||
// reboot/sync to the opener on startup
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::loop()
|
|
||||||
{
|
|
||||||
ESP_LOGD(TAG, "loop rollingCodeCounter: %d", this->rollingCodeCounter);
|
|
||||||
obstructionLoop();
|
|
||||||
gdoStateLoop();
|
|
||||||
dryContactLoop();
|
|
||||||
statusUpdateLoop();
|
|
||||||
//ESP_LOGD(TAG, "Door State: %s", this->doorState.c_str());
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::readRollingCode(uint8_t &door, uint8_t &light, uint8_t &lock, uint8_t &motion, uint8_t &obstruction){
|
|
||||||
uint32_t rolling = 0;
|
|
||||||
uint64_t fixed = 0;
|
|
||||||
uint32_t data = 0;
|
|
||||||
|
|
||||||
uint16_t cmd = 0;
|
|
||||||
uint8_t nibble = 0;
|
|
||||||
uint8_t byte1 = 0;
|
|
||||||
uint8_t byte2 = 0;
|
|
||||||
|
|
||||||
decode_wireline(this->rxRollingCode, &rolling, &fixed, &data);
|
|
||||||
|
|
||||||
cmd = ((fixed >> 24) & 0xf00) | (data & 0xff);
|
|
||||||
|
|
||||||
nibble = (data >> 8) & 0xf;
|
|
||||||
byte1 = (data >> 16) & 0xff;
|
|
||||||
byte2 = (data >> 24) & 0xff;
|
|
||||||
|
|
||||||
if(cmd == 0x81){
|
|
||||||
door = nibble;
|
|
||||||
light = (byte2 >> 1) & 1;
|
|
||||||
lock = byte2 & 1;
|
|
||||||
motion = 0; // when the status message is read, reset motion state to 0|clear
|
|
||||||
// obstruction = (byte1 >> 6) & 1; // unreliable due to the time it takes to register an obstruction
|
|
||||||
|
|
||||||
}else if(cmd == 0x281){
|
|
||||||
light ^= 1; // toggle bit
|
|
||||||
}else if(cmd == 0x84){
|
|
||||||
}else if(cmd == 0x285){
|
|
||||||
motion = 1; // toggle bit
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::getRollingCode(const char* command)
|
void readRollingCode(uint8_t &door, uint8_t &light, uint8_t &lock, uint8_t &motion, uint8_t &obstruction){
|
||||||
{
|
uint32_t rolling = 0;
|
||||||
|
uint64_t fixed = 0;
|
||||||
|
uint32_t data = 0;
|
||||||
|
|
||||||
uint64_t id = 0x539;
|
uint16_t cmd = 0;
|
||||||
uint64_t fixed = 0;
|
uint8_t nibble = 0;
|
||||||
uint32_t data = 0;
|
uint8_t byte1 = 0;
|
||||||
|
uint8_t byte2 = 0;
|
||||||
|
|
||||||
if(strcmp(command,"reboot1") == 0){
|
decode_wireline(this->rxRollingCode, &rolling, &fixed, &data);
|
||||||
fixed = 0x400000000;
|
|
||||||
data = 0x0000618b;
|
cmd = ((fixed >> 24) & 0xf00) | (data & 0xff);
|
||||||
}else if(strcmp(command,"reboot2") == 0){
|
|
||||||
fixed = 0;
|
nibble = (data >> 8) & 0xf;
|
||||||
data = 0x01009080;
|
byte1 = (data >> 16) & 0xff;
|
||||||
}else if(strcmp(command,"reboot3") == 0){
|
byte2 = (data >> 24) & 0xff;
|
||||||
fixed = 0;
|
|
||||||
data = 0x0000b1a0;
|
if(cmd == 0x81){
|
||||||
}else if(strcmp(command,"reboot4") == 0){
|
door = nibble;
|
||||||
fixed = 0;
|
light = (byte2 >> 1) & 1;
|
||||||
data = 0x01009080;
|
lock = byte2 & 1;
|
||||||
}else if(strcmp(command,"reboot5") == 0){
|
motion = 0; // when the status message is read, reset motion state to 0|clear
|
||||||
fixed = 0x300000000;
|
// obstruction = (byte1 >> 6) & 1; // unreliable due to the time it takes to register an obstruction
|
||||||
data = 0x00008092;
|
|
||||||
}else if(strcmp(command,"reboot6") == 0){
|
}else if(cmd == 0x281){
|
||||||
fixed = 0x300000000;
|
light ^= 1; // toggle bit
|
||||||
data = 0x00008092;
|
}else if(cmd == 0x84){
|
||||||
}else if(strcmp(command,"door1") == 0){
|
}else if(cmd == 0x285){
|
||||||
fixed = 0x200000000;
|
motion = 1; // toggle bit
|
||||||
data = 0x01018280;
|
}
|
||||||
}else if(strcmp(command,"door2") == 0){
|
}
|
||||||
fixed = 0x200000000;
|
|
||||||
data = 0x01009280;
|
void getRollingCode(const char* command)
|
||||||
}else if(strcmp(command,"light") == 0){
|
{
|
||||||
fixed = 0x200000000;
|
|
||||||
data = 0x00009281;
|
uint64_t id = 0x539;
|
||||||
}else if(strcmp(command,"lock") == 0){
|
uint64_t fixed = 0;
|
||||||
fixed = 0x0100000000;
|
uint32_t data = 0;
|
||||||
data = 0x0000728c;
|
|
||||||
} else {
|
if(strcmp(command,"reboot1") == 0){
|
||||||
ESP_LOGD(TAG, "ERROR: Invalid command");
|
fixed = 0x400000000;
|
||||||
|
data = 0x0000618b;
|
||||||
|
}else if(strcmp(command,"reboot2") == 0){
|
||||||
|
fixed = 0;
|
||||||
|
data = 0x01009080;
|
||||||
|
}else if(strcmp(command,"reboot3") == 0){
|
||||||
|
fixed = 0;
|
||||||
|
data = 0x0000b1a0;
|
||||||
|
}else if(strcmp(command,"reboot4") == 0){
|
||||||
|
fixed = 0;
|
||||||
|
data = 0x01009080;
|
||||||
|
}else if(strcmp(command,"reboot5") == 0){
|
||||||
|
fixed = 0x300000000;
|
||||||
|
data = 0x00008092;
|
||||||
|
}else if(strcmp(command,"reboot6") == 0){
|
||||||
|
fixed = 0x300000000;
|
||||||
|
data = 0x00008092;
|
||||||
|
}else if(strcmp(command,"door1") == 0){
|
||||||
|
fixed = 0x200000000;
|
||||||
|
data = 0x01018280;
|
||||||
|
}else if(strcmp(command,"door2") == 0){
|
||||||
|
fixed = 0x200000000;
|
||||||
|
data = 0x01009280;
|
||||||
|
}else if(strcmp(command,"light") == 0){
|
||||||
|
fixed = 0x200000000;
|
||||||
|
data = 0x00009281;
|
||||||
|
}else if(strcmp(command,"lock") == 0){
|
||||||
|
fixed = 0x0100000000;
|
||||||
|
data = 0x0000728c;
|
||||||
|
} else {
|
||||||
|
ESP_LOGD(TAG, "ERROR: Invalid command");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
fixed = fixed | id;
|
||||||
|
|
||||||
|
encode_wireline(this->rollingCodeCounter, fixed, data, this->txRollingCode);
|
||||||
|
|
||||||
|
printRollingCode();
|
||||||
|
|
||||||
|
if (strcmp(command, "door1") != 0) { // door2 is created with same counter and should always be called after door1
|
||||||
|
this->rollingCodeCounter = (this->rollingCodeCounter + 1) & 0xfffffff;
|
||||||
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
fixed = fixed | id;
|
void printRollingCode()
|
||||||
|
{
|
||||||
encode_wireline(this->rollingCodeCounter, fixed, data, this->txRollingCode);
|
for (int i = 0; i < CODE_LENGTH; i++) {
|
||||||
|
if (this->txRollingCode[i] <= 0x0f)
|
||||||
printRollingCode();
|
ESP_LOGD(TAG, "0");
|
||||||
|
ESP_LOGD(TAG, "%x", this->txRollingCode[i]);
|
||||||
if (strcmp(command, "door1") != 0) { // door2 is created with same counter and should always be called after door1
|
}
|
||||||
this->rollingCodeCounter = (this->rollingCodeCounter + 1) & 0xfffffff;
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::printRollingCode()
|
|
||||||
{
|
|
||||||
for (int i = 0; i < CODE_LENGTH; i++) {
|
|
||||||
if (this->txRollingCode[i] <= 0x0f)
|
|
||||||
ESP_LOGD(TAG, "0");
|
|
||||||
ESP_LOGD(TAG, "%x", this->txRollingCode[i]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// handle changes to the dry contact state
|
|
||||||
void RATGDOComponent::dryContactLoop()
|
|
||||||
{
|
|
||||||
if (this->store_.dryContactDoorOpen) {
|
|
||||||
ESP_LOGD(TAG, "Dry Contact: open the door");
|
|
||||||
this->store_.dryContactDoorOpen = false;
|
|
||||||
openDoor();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (this->store_.dryContactDoorClose) {
|
// handle changes to the dry contact state
|
||||||
ESP_LOGD(TAG, "Dry Contact: close the door");
|
void dryContactLoop()
|
||||||
this->store_.dryContactDoorClose = false;
|
{
|
||||||
closeDoor();
|
if (this->store_.dryContactDoorOpen) {
|
||||||
|
ESP_LOGD(TAG, "Dry Contact: open the door");
|
||||||
|
this->store_.dryContactDoorOpen = false;
|
||||||
|
openDoor();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this->store_.dryContactDoorClose) {
|
||||||
|
ESP_LOGD(TAG, "Dry Contact: close the door");
|
||||||
|
this->store_.dryContactDoorClose = false;
|
||||||
|
closeDoor();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (this->store_.dryContactToggleLight) {
|
||||||
|
ESP_LOGD(TAG, "Dry Contact: toggle the light");
|
||||||
|
this->store_.dryContactToggleLight = false;
|
||||||
|
toggleLight();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (this->store_.dryContactToggleLight) {
|
/*************************** OBSTRUCTION DETECTION ***************************/
|
||||||
ESP_LOGD(TAG, "Dry Contact: toggle the light");
|
void obstructionLoop()
|
||||||
this->store_.dryContactToggleLight = false;
|
{
|
||||||
toggleLight();
|
long currentMillis = millis();
|
||||||
|
static unsigned long lastMillis = 0;
|
||||||
|
|
||||||
|
// the obstruction sensor has 3 states: clear (HIGH with LOW pulse every 7ms), obstructed (HIGH), asleep (LOW)
|
||||||
|
// the transitions between awake and asleep are tricky because the voltage drops slowly when falling asleep
|
||||||
|
// and is high without pulses when waking up
|
||||||
|
|
||||||
|
// If at least 3 low pulses are counted within 50ms, the door is awake, not obstructed and we don't have to check anything else
|
||||||
|
|
||||||
|
// Every 50ms
|
||||||
|
if(currentMillis - lastMillis > 50){
|
||||||
|
// check to see if we got between 3 and 8 low pulses on the line
|
||||||
|
if(this->store_.obstructionLowCount >= 3 && this->store_.obstructionLowCount <= 8){
|
||||||
|
// obstructionCleared();
|
||||||
|
this->store_.obstructionState = 1;
|
||||||
|
|
||||||
|
// if there have been no pulses the line is steady high or low
|
||||||
|
}else if(this->store_.obstructionLowCount == 0){
|
||||||
|
// if the line is high and the last high pulse was more than 70ms ago, then there is an obstruction present
|
||||||
|
if(this->input_obst_pin_->digital_read() && currentMillis - this->store_.lastObstructionHigh > 70){
|
||||||
|
this->store_.obstructionState = 0;
|
||||||
|
// obstructionDetected();
|
||||||
|
}else{
|
||||||
|
// asleep
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
lastMillis = currentMillis;
|
||||||
|
this->store_.obstructionLowCount = 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
/*************************** OBSTRUCTION DETECTION ***************************/
|
void gdoStateLoop(){
|
||||||
|
if(!this->swSerial.available()) {
|
||||||
|
//ESP_LOGD(TAG, "No data available input:%d output:%d", this->input_gdo_pin_->get_pin(), this->output_gdo_pin_->get_pin());
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
uint8_t serData = this->swSerial.read();
|
||||||
|
|
||||||
|
static uint32_t msgStart;
|
||||||
|
static bool reading = false;
|
||||||
|
static uint16_t byteCount = 0;
|
||||||
|
|
||||||
void RATGDOComponent::obstructionLoop()
|
if(!reading){
|
||||||
{
|
// shift serial byte onto msg start
|
||||||
long currentMillis = millis();
|
msgStart <<= 8;
|
||||||
static unsigned long lastMillis = 0;
|
msgStart |= serData;
|
||||||
|
|
||||||
// the obstruction sensor has 3 states: clear (HIGH with LOW pulse every 7ms), obstructed (HIGH), asleep (LOW)
|
// truncate to 3 bytes
|
||||||
// the transitions between awake and asleep are tricky because the voltage drops slowly when falling asleep
|
msgStart &= 0x00FFFFFF;
|
||||||
// and is high without pulses when waking up
|
|
||||||
|
|
||||||
// If at least 3 low pulses are counted within 50ms, the door is awake, not obstructed and we don't have to check anything else
|
// if we are at the start of a message, capture the next 16 bytes
|
||||||
|
if(msgStart == 0x550100){
|
||||||
|
byteCount = 3;
|
||||||
|
rxRollingCode[0] = 0x55;
|
||||||
|
rxRollingCode[1] = 0x01;
|
||||||
|
rxRollingCode[2] = 0x00;
|
||||||
|
|
||||||
// Every 50ms
|
reading = true;
|
||||||
if(currentMillis - lastMillis > 50){
|
return;
|
||||||
// check to see if we got between 3 and 8 low pulses on the line
|
|
||||||
if(this->store_.obstructionLowCount >= 3 && this->store_.obstructionLowCount <= 8){
|
|
||||||
// obstructionCleared();
|
|
||||||
this->store_.obstructionState = 1;
|
|
||||||
|
|
||||||
// if there have been no pulses the line is steady high or low
|
|
||||||
}else if(this->store_.obstructionLowCount == 0){
|
|
||||||
// if the line is high and the last high pulse was more than 70ms ago, then there is an obstruction present
|
|
||||||
if(this->input_obst_pin_->digital_read() && currentMillis - this->store_.lastObstructionHigh > 70){
|
|
||||||
this->store_.obstructionState = 0;
|
|
||||||
// obstructionDetected();
|
|
||||||
}else{
|
|
||||||
// asleep
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
lastMillis = currentMillis;
|
if(reading){
|
||||||
this->store_.obstructionLowCount = 0;
|
this->rxRollingCode[byteCount] = serData;
|
||||||
|
byteCount++;
|
||||||
|
|
||||||
|
if(byteCount == 19){
|
||||||
|
reading = false;
|
||||||
|
msgStart = 0;
|
||||||
|
byteCount = 0;
|
||||||
|
|
||||||
|
readRollingCode(this->store_.doorState, this->store_.lightState, this->store_.lockState, this->store_.motionState, this->store_.obstructionState);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::gdoStateLoop(){
|
|
||||||
if(!this->swSerial.available()) {
|
void statusUpdateLoop(){
|
||||||
//ESP_LOGD(TAG, "No data available input:%d output:%d", this->input_gdo_pin_->get_pin(), this->output_gdo_pin_->get_pin());
|
// initialize to unknown
|
||||||
return;
|
static uint8_t previousDoorState = 0;
|
||||||
|
static uint8_t previousLightState = 2;
|
||||||
|
static uint8_t previousLockState = 2;
|
||||||
|
static uint8_t previousObstructionState = 2;
|
||||||
|
|
||||||
|
if(this->store_.doorState != previousDoorState) sendDoorStatus();
|
||||||
|
if(this->store_.lightState != previousLightState) sendLightStatus();
|
||||||
|
if(this->store_.lockState != previousLockState) sendLockStatus();
|
||||||
|
if(this->store_.obstructionState != previousObstructionState) sendObstructionStatus();
|
||||||
|
|
||||||
|
if(this->store_.motionState == 1){
|
||||||
|
sendMotionStatus();
|
||||||
|
this->store_.motionState = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
previousDoorState = this->store_.doorState;
|
||||||
|
previousLightState = this->store_.lightState;
|
||||||
|
previousLockState = this->store_.lockState;
|
||||||
|
previousObstructionState = this->store_.obstructionState;
|
||||||
}
|
}
|
||||||
uint8_t serData = this->swSerial.read();
|
|
||||||
|
|
||||||
static uint32_t msgStart;
|
void sendDoorStatus(){
|
||||||
static bool reading = false;
|
ESP_LOGD(TAG, "Door state %d", this->store_.doorState);
|
||||||
static uint16_t byteCount = 0;
|
this->status_door_pin_->digital_write(this->store_.doorState == 1);
|
||||||
|
}
|
||||||
|
|
||||||
if(!reading){
|
void sendLightStatus(){
|
||||||
// shift serial byte onto msg start
|
ESP_LOGD(TAG, "Light state %d", this->store_.lightState);
|
||||||
msgStart <<= 8;
|
}
|
||||||
msgStart |= serData;
|
|
||||||
|
|
||||||
// truncate to 3 bytes
|
void sendLockStatus(){
|
||||||
msgStart &= 0x00FFFFFF;
|
ESP_LOGD(TAG, "Lock state %d", this->store_.lockState);
|
||||||
|
}
|
||||||
|
|
||||||
// if we are at the start of a message, capture the next 16 bytes
|
void sendMotionStatus(){
|
||||||
if(msgStart == 0x550100){
|
ESP_LOGD(TAG, "Motion state %d", this->store_.motionState);
|
||||||
byteCount = 3;
|
this->store_.motionState = 0; // reset motion state
|
||||||
rxRollingCode[0] = 0x55;
|
}
|
||||||
rxRollingCode[1] = 0x01;
|
|
||||||
rxRollingCode[2] = 0x00;
|
|
||||||
|
|
||||||
reading = true;
|
void sendObstructionStatus(){
|
||||||
|
ESP_LOGD(TAG, "Obstruction state %d", this->store_.obstructionState);
|
||||||
|
this->status_obst_pin_->digital_write(this->store_.obstructionState == 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
/************************* DOOR COMMUNICATION *************************/
|
||||||
|
/*
|
||||||
|
* Transmit a message to the door opener over uart1
|
||||||
|
* The TX1 pin is controlling a transistor, so the logic is inverted
|
||||||
|
* A HIGH state on TX1 will pull the 12v line LOW
|
||||||
|
*
|
||||||
|
* The opener requires a specific duration low/high pulse before it will accept
|
||||||
|
* a message
|
||||||
|
*/
|
||||||
|
void transmit(const unsigned char * payload)
|
||||||
|
{
|
||||||
|
this->output_gdo_pin_->digital_write(true); // pull the line high for 1305 micros so the
|
||||||
|
// door opener responds to the message
|
||||||
|
delayMicroseconds(1305);
|
||||||
|
this->output_gdo_pin_->digital_write(false); // bring the line low
|
||||||
|
|
||||||
|
delayMicroseconds(1260); // "LOW" pulse duration before the message start
|
||||||
|
this->swSerial.write(payload, CODE_LENGTH);
|
||||||
|
}
|
||||||
|
|
||||||
|
void sync()
|
||||||
|
{
|
||||||
|
getRollingCode("reboot1");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
getRollingCode("reboot2");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
getRollingCode("reboot3");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
getRollingCode("reboot4");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
getRollingCode("reboot5");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
getRollingCode("reboot6");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(65);
|
||||||
|
|
||||||
|
this->pref_.save(&this->rollingCodeCounter);
|
||||||
|
}
|
||||||
|
|
||||||
|
void openDoor()
|
||||||
|
{
|
||||||
|
if(this->doorStates[this->store_.doorState] == "open" || doorStates[this->store_.doorState] == "opening"){
|
||||||
|
ESP_LOGD(TAG, "The door is already %s", this->doorStates[this->store_.doorState]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
toggleDoor();
|
||||||
}
|
}
|
||||||
|
|
||||||
if(reading){
|
void closeDoor()
|
||||||
this->rxRollingCode[byteCount] = serData;
|
{
|
||||||
byteCount++;
|
if(this->doorStates[this->store_.doorState] == "closed" || doorStates[this->store_.doorState] == "closing"){
|
||||||
|
ESP_LOGD(TAG, "The door is already %s", this->doorStates[this->store_.doorState]);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
toggleDoor();
|
||||||
|
}
|
||||||
|
|
||||||
if(byteCount == 19){
|
void stopDoor(){
|
||||||
reading = false;
|
if(this->doorStates[this->store_.doorState] == "opening" || doorStates[this->store_.doorState] == "closing"){
|
||||||
msgStart = 0;
|
toggleDoor();
|
||||||
byteCount = 0;
|
}else{
|
||||||
|
Serial.print("The door is not moving.");
|
||||||
readRollingCode(this->store_.doorState, this->store_.lightState, this->store_.lockState, this->store_.motionState, this->store_.obstructionState);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
|
void toggleDoor()
|
||||||
|
{
|
||||||
|
getRollingCode("door1");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
delay(40);
|
||||||
|
getRollingCode("door2");
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
this->pref_.save(&this->rollingCodeCounter);
|
||||||
|
|
||||||
void RATGDOComponent::statusUpdateLoop(){
|
|
||||||
// initialize to unknown
|
|
||||||
static uint8_t previousDoorState = 0;
|
|
||||||
static uint8_t previousLightState = 2;
|
|
||||||
static uint8_t previousLockState = 2;
|
|
||||||
static uint8_t previousObstructionState = 2;
|
|
||||||
|
|
||||||
if(this->store_.doorState != previousDoorState) sendDoorStatus();
|
|
||||||
if(this->store_.lightState != previousLightState) sendLightStatus();
|
|
||||||
if(this->store_.lockState != previousLockState) sendLockStatus();
|
|
||||||
if(this->store_.obstructionState != previousObstructionState) sendObstructionStatus();
|
|
||||||
|
|
||||||
if(this->store_.motionState == 1){
|
|
||||||
sendMotionStatus();
|
|
||||||
this->store_.motionState = 0;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
previousDoorState = this->store_.doorState;
|
void lightOn(){
|
||||||
previousLightState = this->store_.lightState;
|
if(this->lightStates[this->store_.lightState] == "on"){
|
||||||
previousLockState = this->store_.lockState;
|
ESP_LOGD(TAG, "already on");
|
||||||
previousObstructionState = this->store_.obstructionState;
|
}else{
|
||||||
}
|
toggleLight();
|
||||||
|
}
|
||||||
void RATGDOComponent::sendDoorStatus(){
|
|
||||||
ESP_LOGD(TAG, "Door state %d", this->store_.doorState);
|
|
||||||
this->status_door_pin_->digital_write(this->store_.doorState == 1);
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sendLightStatus(){
|
|
||||||
ESP_LOGD(TAG, "Light state %d", this->store_.lightState);
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sendLockStatus(){
|
|
||||||
ESP_LOGD(TAG, "Lock state %d", this->store_.lockState);
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sendMotionStatus(){
|
|
||||||
ESP_LOGD(TAG, "Motion state %d", this->store_.motionState);
|
|
||||||
this->store_.motionState = 0; // reset motion state
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sendObstructionStatus(){
|
|
||||||
ESP_LOGD(TAG, "Obstruction state %d", this->store_.obstructionState);
|
|
||||||
this->status_obst_pin_->digital_write(this->store_.obstructionState == 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
/************************* DOOR COMMUNICATION *************************/
|
|
||||||
/*
|
|
||||||
* Transmit a message to the door opener over uart1
|
|
||||||
* The TX1 pin is controlling a transistor, so the logic is inverted
|
|
||||||
* A HIGH state on TX1 will pull the 12v line LOW
|
|
||||||
*
|
|
||||||
* The opener requires a specific duration low/high pulse before it will accept
|
|
||||||
* a message
|
|
||||||
*/
|
|
||||||
void RATGDOComponent::transmit(const unsigned char * payload)
|
|
||||||
{
|
|
||||||
this->output_gdo_pin_->digital_write(true); // pull the line high for 1305 micros so the
|
|
||||||
// door opener responds to the message
|
|
||||||
delayMicroseconds(1305);
|
|
||||||
this->output_gdo_pin_->digital_write(false); // bring the line low
|
|
||||||
|
|
||||||
delayMicroseconds(1260); // "LOW" pulse duration before the message start
|
|
||||||
this->swSerial.write(payload, CODE_LENGTH);
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sync()
|
|
||||||
{
|
|
||||||
getRollingCode("reboot1");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
getRollingCode("reboot2");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
getRollingCode("reboot3");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
getRollingCode("reboot4");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
getRollingCode("reboot5");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
getRollingCode("reboot6");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(65);
|
|
||||||
|
|
||||||
this->pref_.save(&this->rollingCodeCounter);
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::openDoor()
|
|
||||||
{
|
|
||||||
if(this->doorStates[this->store_.doorState] == "open" || doorStates[this->store_.doorState] == "opening"){
|
|
||||||
ESP_LOGD(TAG, "The door is already %s", this->doorStates[this->store_.doorState]);
|
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
toggleDoor();
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::closeDoor()
|
void lightOff(){
|
||||||
{
|
if(this->lightStates[this->store_.lightState] == "off"){
|
||||||
if(this->doorStates[this->store_.doorState] == "closed" || doorStates[this->store_.doorState] == "closing"){
|
ESP_LOGD(TAG, "already off");
|
||||||
ESP_LOGD(TAG, "The door is already %s", this->doorStates[this->store_.doorState]);
|
}else{
|
||||||
return;
|
toggleLight();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
toggleDoor();
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::stopDoor(){
|
void toggleLight(){
|
||||||
if(this->doorStates[this->store_.doorState] == "opening" || doorStates[this->store_.doorState] == "closing"){
|
sendCommand("light");
|
||||||
toggleDoor();
|
}
|
||||||
}else{
|
|
||||||
Serial.print("The door is not moving.");
|
// Lock functions
|
||||||
|
void lock(){
|
||||||
|
if(this->lockStates[this->store_.lockState] == "locked"){
|
||||||
|
ESP_LOGD(TAG, "already locked");
|
||||||
|
}else{
|
||||||
|
toggleLock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void unlock(){
|
||||||
|
if(this->lockStates[this->store_.lockState] == "unlocked"){
|
||||||
|
ESP_LOGD(TAG, "already unlocked");
|
||||||
|
}else{
|
||||||
|
toggleLock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void toggleLock(){
|
||||||
|
sendCommand("lock");
|
||||||
|
}
|
||||||
|
|
||||||
|
void sendCommand(const char* command){
|
||||||
|
getRollingCode(command);
|
||||||
|
transmit(this->txRollingCode);
|
||||||
|
this->pref_.save(&this->rollingCodeCounter);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void RATGDOComponent::toggleDoor()
|
|
||||||
{
|
|
||||||
getRollingCode("door1");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
delay(40);
|
|
||||||
getRollingCode("door2");
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
this->pref_.save(&this->rollingCodeCounter);
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::lightOn(){
|
|
||||||
if(this->lightStates[this->store_.lightState] == "on"){
|
|
||||||
ESP_LOGD(TAG, "already on");
|
|
||||||
}else{
|
|
||||||
toggleLight();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::lightOff(){
|
|
||||||
if(this->lightStates[this->store_.lightState] == "off"){
|
|
||||||
ESP_LOGD(TAG, "already off");
|
|
||||||
}else{
|
|
||||||
toggleLight();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::toggleLight(){
|
|
||||||
sendCommand("light");
|
|
||||||
}
|
|
||||||
|
|
||||||
// Lock functions
|
|
||||||
void RATGDOComponent::lock(){
|
|
||||||
if(this->lockStates[this->store_.lockState] == "locked"){
|
|
||||||
ESP_LOGD(TAG, "already locked");
|
|
||||||
}else{
|
|
||||||
toggleLock();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::unlock(){
|
|
||||||
if(this->lockStates[this->store_.lockState] == "unlocked"){
|
|
||||||
ESP_LOGD(TAG, "already unlocked");
|
|
||||||
}else{
|
|
||||||
toggleLock();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::toggleLock(){
|
|
||||||
sendCommand("lock");
|
|
||||||
}
|
|
||||||
|
|
||||||
void RATGDOComponent::sendCommand(const char* command){
|
|
||||||
getRollingCode(command);
|
|
||||||
transmit(this->txRollingCode);
|
|
||||||
this->pref_.save(&this->rollingCodeCounter);
|
|
||||||
}
|
|
||||||
|
|
||||||
} // namespace ratgdo
|
} // namespace ratgdo
|
||||||
} // namespace esphome
|
} // namespace esphome
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user