ETM-Schurig
/
nymea
mirror of https://github.com/nymea/nymea.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
nymea/plugins/deviceplugins/eq-3/maxcube.cpp

906 lines
35 KiB
C++
Raw Blame History

/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
* *
* Copyright (C) 2015 Simon Stürz <simon.stuerz@guh.guru> *
* *
* This file is part of guh. *
* *
* Guh is free software: you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation, version 2 of the License. *
* *
* Guh is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License *
* along with guh. If not, see <http://www.gnu.org/licenses/>. *
* *
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
#include "maxcube.h"
#include "extern-plugininfo.h"
MaxCube::MaxCube(QObject *parent, QString serialNumber, QHostAddress hostAdress, quint16 port):
QTcpSocket(parent), m_serialNumber(serialNumber), m_hostAddress(hostAdress), m_port(port)
{
m_cubeInitialized = false;
connect(this,SIGNAL(stateChanged(QAbstractSocket::SocketState)),this,SLOT(connectionStateChanged(QAbstractSocket::SocketState)));
connect(this,SIGNAL(readyRead()),this,SLOT(readData()));
connect(this,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(error(QAbstractSocket::SocketError)));
connect(this,SIGNAL(cubeDataAvailable(QByteArray)),this,SLOT(processCubeData(QByteArray)));
}
QString MaxCube::serialNumber() const
{
return m_serialNumber;
}
void MaxCube::setSerialNumber(const QString &serialNumber)
{
m_serialNumber = serialNumber;
}
QByteArray MaxCube::rfAddress() const
{
return m_rfAddress;
}
void MaxCube::setRfAddress(const QByteArray &rfAddress)
{
m_rfAddress = rfAddress;
}
int MaxCube::firmware() const
{
return m_firmware;
}
void MaxCube::setFirmware(const int &firmware)
{
m_firmware = firmware;
}
QHostAddress MaxCube::hostAddress() const
{
return m_hostAddress;
}
void MaxCube::setHostAddress(const QHostAddress &hostAddress)
{
m_hostAddress = hostAddress;
}
quint16 MaxCube::port() const
{
return m_port;
}
void MaxCube::setPort(const quint16 &port)
{
m_port = port;
}
QDateTime MaxCube::cubeDateTime() const
{
return m_cubeDateTime;
}
void MaxCube::setCubeDateTime(const QDateTime &cubeDateTime)
{
m_cubeDateTime = cubeDateTime;
}
bool MaxCube::portalEnabeld() const
{
return m_portalEnabeld;
}
QList<WallThermostat *> MaxCube::wallThermostatList()
{
return m_wallThermostatList;
}
QList<RadiatorThermostat *> MaxCube::radiatorThermostatList()
{
return m_radiatorThermostatList;
}
QList<Room *> MaxCube::roomList()
{
return m_roomList;
}
void MaxCube::connectToCube()
{
connectToHost(m_hostAddress,m_port);
}
void MaxCube::disconnectFromCube()
{
disconnectFromHost();
}
bool MaxCube::sendData(QByteArray data)
{
if(write(data) < 0){
return false;
}
return true;
}
bool MaxCube::isConnected()
{
if(state() == QAbstractSocket::ConnectedState){
return true;
}
return false;
}
bool MaxCube::isInitialized()
{
return m_cubeInitialized;
}
void MaxCube::decodeHelloMessage(QByteArray data)
{
QList<QByteArray> list = data.split(',');
m_cubeDateTime = calculateDateTime(list.at(7),list.at(8));
m_rfAddress = list.at(1);
m_firmware = list.at(2).toInt();
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " HELLO message:";
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " serial number | " << m_serialNumber;
qCDebug(dcEQ3) << " RF address (hex) | " << m_rfAddress;
qCDebug(dcEQ3) << " firmware | " << m_firmware;
qCDebug(dcEQ3) << " Cube date | " << m_cubeDateTime.date().toString("dd.MM.yyyy");
qCDebug(dcEQ3) << " Cube time | " << m_cubeDateTime.time().toString("HH:mm");
qCDebug(dcEQ3) << " State Cube Time | " << list.at(9);
qCDebug(dcEQ3) << " NTP counter | " << list.at(10);
}
void MaxCube::decodeMetadataMessage(QByteArray data)
{
QList<QByteArray> list = data.left(data.length()-2).split(',');
QByteArray dataDecoded = QByteArray::fromBase64(list.at(2));
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " METADATA message:";
qCDebug(dcEQ3) << "====================================================";
// parse room list
int roomCount = dataDecoded.toHex().mid(4,2).toInt(0,16);
QByteArray roomRawData = dataDecoded.toHex();
roomRawData = roomRawData.right(roomRawData.length()-6);
for(int i = 0; i < roomCount; i++){
Room *room = new Room(this);
room->setRoomId(roomRawData.left(2).toInt(0,16));
int roomNameLength = roomRawData.mid(2,2).toInt(0,16);
room->setRoomName(QByteArray::fromHex(roomRawData.mid(4,roomNameLength*2)));
room->setGroupRfAddress(roomRawData.mid(roomNameLength*2 + 4, 6));
m_roomList.append(room);
roomRawData = roomRawData.right(roomRawData.length() - ((roomNameLength*2) + 10));
}
qCDebug(dcEQ3) << "-------------------------|-------------------------";
qCDebug(dcEQ3) << "found " << m_roomList.count() << "rooms";
qCDebug(dcEQ3) << "-------------------------|-------------------------";
foreach (Room *room, m_roomList) {
qCDebug(dcEQ3) << " Room Name | " << room->roomName();
qCDebug(dcEQ3) << " Room ID | " << room->roomId();
qCDebug(dcEQ3) << " Group RF Address | " << room->groupRfAddress();
qCDebug(dcEQ3) << "-------------------------|-------------------------";
}
// parse device list
int deviceCount = roomRawData.left(2).toInt(0,16);
QByteArray deviceRawData = roomRawData.right(roomRawData.length() - 2);
qCDebug(dcEQ3) << "-------------------------|-------------------------";
qCDebug(dcEQ3) << "found " << deviceCount << "devices";
qCDebug(dcEQ3) << "-------------------------|-------------------------";
for(int i = 0; i < deviceCount; i++){
int deviceType = deviceRawData.left(2).toInt(0,16);
switch (deviceType) {
case MaxDevice::DeviceRadiatorThermostat:{
RadiatorThermostat* device = new RadiatorThermostat(this);
device->setDeviceType(deviceType);
device->setRfAddress(deviceRawData.mid(2,6));
device->setSerialNumber(QByteArray::fromHex(deviceRawData.mid(8,20)));
int deviceNameLenght = deviceRawData.mid(28,2).toInt(0,16);
device->setDeviceName(QByteArray::fromHex(deviceRawData.mid(30,deviceNameLenght*2)));
device->setRoomId(deviceRawData.mid(30 + deviceNameLenght*2,2).toInt(0,16));
deviceRawData = deviceRawData.right(deviceRawData.length() - (32 + deviceNameLenght*2));
// set room data for each device
foreach (Room * room, m_roomList) {
if(device->roomId() == room->roomId()){
device->setRoomName(room->roomName());
}
}
m_radiatorThermostatList.append(device);
qCDebug(dcEQ3) << " Device Name | " << device->deviceName();
qCDebug(dcEQ3) << " Serial Number| " << device->serialNumber();
qCDebug(dcEQ3) << " Device Type String | " << device->deviceTypeString();
qCDebug(dcEQ3) << " RF address (hex) | " << device->rfAddress();
qCDebug(dcEQ3) << " Room ID | " << device->roomId();
qCDebug(dcEQ3) << " Room Name | " << device->roomName();
qCDebug(dcEQ3) << "-------------------------|-------------------------";
break;
}
case MaxDevice::DeviceWallThermostat:{
WallThermostat* device = new WallThermostat(this);
device->setDeviceType(deviceType);
device->setRfAddress(deviceRawData.mid(2,6));
device->setSerialNumber(QByteArray::fromHex(deviceRawData.mid(8,20)));
int deviceNameLenght = deviceRawData.mid(28,2).toInt(0,16);
device->setDeviceName(QByteArray::fromHex(deviceRawData.mid(30,deviceNameLenght*2)));
device->setRoomId(deviceRawData.mid(30 + deviceNameLenght*2,2).toInt(0,16));
deviceRawData = deviceRawData.right(deviceRawData.length() - (32 + deviceNameLenght*2));
// set room data for each device
foreach (Room * room, m_roomList) {
if(device->roomId() == room->roomId()){
device->setRoomName(room->roomName());
}
}
m_wallThermostatList.append(device);
qCDebug(dcEQ3) << " Device Name | " << device->deviceName();
qCDebug(dcEQ3) << " Serial Number| " << device->serialNumber();
qCDebug(dcEQ3) << " Device Type String | " << device->deviceTypeString();
qCDebug(dcEQ3) << " RF address (hex) | " << device->rfAddress();
qCDebug(dcEQ3) << " Room ID | " << device->roomId();
qCDebug(dcEQ3) << " Room Name | " << device->roomName();
qCDebug(dcEQ3) << "-------------------------|-------------------------";
break;
}
default:
break;
}
}
m_cubeInitialized = true;
}
void MaxCube::decodeConfigMessage(QByteArray data)
{
QList<QByteArray> list = data.split(',');
if(list.count() < 2){
return;
}
QByteArray rfAddress = list.at(0);
QByteArray dataRaw = QByteArray::fromBase64(list.at(1)).toHex();
int lengthData = dataRaw.left(2).toInt(0,16);
if(rfAddress != dataRaw.mid(2,6)){
qCWarning(dcEQ3) << "RF addresses not equal!";
}
int deviceType = dataRaw.mid(8,2).toInt(0,16);
//QByteArray unknown = dataRaw.mid(12,6);
QByteArray serialNumber = QByteArray::fromHex(dataRaw.mid(16,20));
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " CONFIG message:";
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " Serial Number | " << serialNumber;
qCDebug(dcEQ3) << " device Type | " << deviceTypeString(deviceType);
qCDebug(dcEQ3) << " RF address (hex) | " << rfAddress;
qCDebug(dcEQ3) << " data length | " << lengthData;
qCDebug(dcEQ3) << "-------------------------|-------------------------";
switch (deviceType) {
case MaxDevice::DeviceCube:{
m_portalEnabeld = (bool)dataRaw.mid(36,2).toInt(0,16);
qCDebug(dcEQ3) << " portal enabled | " << m_portalEnabeld;
qCDebug(dcEQ3) << " portal URL | " << QString(QByteArray::fromHex(dataRaw.mid(170,68)));
qCDebug(dcEQ3) << " time zone | " << QString(QByteArray::fromHex(dataRaw.mid(428,6)));
qCDebug(dcEQ3) << " summer/winter time | " << QString(QByteArray::fromHex(dataRaw.mid(452,8)));
emit cubeConfigReady();
break;
}
case MaxDevice::DeviceRadiatorThermostat:{
foreach (RadiatorThermostat* device, m_radiatorThermostatList) {
if(device->rfAddress() == rfAddress){
//int roomId = dataRaw.mid(10,2).toInt(0,16);
int firmware = dataRaw.mid(12,2).toInt(0,16);
device->setComfortTemp((double)dataRaw.mid(36,2).toInt(0,16) / 2.0);
device->setEcoTemp((double)dataRaw.mid(38,2).toInt(0,16) / 2.0);
device->setMaxSetPointTemp((double)dataRaw.mid(40,2).toInt(0,16) / 2.0);
device->setMinSetPointTemp((double)dataRaw.mid(42,2).toInt(0,16) / 2.0);
device->setOffsetTemp((double)(dataRaw.mid(44,2).toInt(0,16) / 2.0 ) - 3.5);
device->setWindowOpenTemp((double)dataRaw.mid(46,2).toInt(0,16)/2.0);
device->setWindowOpenDuration(dataRaw.mid(48,2).toInt(0,16));
// boost code
QByteArray boostDurationCode = fillBin(QByteArray::number(dataRaw.mid(50,2).toInt(0,16),2),8);
device->setBoostDuration(boostDurationCode.left(3).toInt(0,2) * 5);
device->setBoostValveValue(boostDurationCode.right(5).toInt(0,2) * 5);
// day of week an time
QByteArray dowTime = fillBin(QByteArray::number(dataRaw.mid(52,2).toInt(0,16),2),8);
device->setDiscalcingWeekDay(weekDayString(dowTime.left(3).toInt(0,2)));
device->setDiscalcingTime(QTime(dowTime.right(5).toInt(0,2),0));
device->setValveMaximumSettings((double)dataRaw.mid(54,2).toInt(0,16)*(double)100.0/255.0);
device->setValveOffset((double)dataRaw.mid(56,2).toInt(0,16)*100.0/255.0);
qCDebug(dcEQ3) << " Room ID | " << device->roomId();
qCDebug(dcEQ3) << " firmware | " << firmware;
//qCDebug(dcEQ3) << " Confort Temp. | " << device->confortTemp() << "C";
qCDebug(dcEQ3) << " Eco Temp. | " << device->ecoTemp() << "C";
qCDebug(dcEQ3) << " Max. Set Point Temp. | " << device->maxSetPointTemp() << "C";
qCDebug(dcEQ3) << " Min. Set Point Temp. | " << device->minSetPointTemp() << "C";
qCDebug(dcEQ3) << " Temp. Offset | " << device->offsetTemp() << "C";
qCDebug(dcEQ3) << " Window Open Temp. | " << device->windowOpenTemp() << "C";
qCDebug(dcEQ3) << " Window Open Duration | " << device->windowOpenDuration() << "min";
qCDebug(dcEQ3) << " Boost Duration | " << device->boostDuration() << "min";
qCDebug(dcEQ3) << " Valve value | " << device->boostValveValue() << "%";
qCDebug(dcEQ3) << " disclaiming run day | " << device->discalcingWeekDay();
qCDebug(dcEQ3) << " disclaiming run time | " << device->discalcingTime().toString("HH:mm");
qCDebug(dcEQ3) << " Valve Maximum Settings | " << device->valveMaximumSettings() << "%";
qCDebug(dcEQ3) << " Valve Offset | " << device->valveOffset() << "%";
parseWeeklyProgram(dataRaw.right(dataRaw.length() - 58));
emit radiatorThermostatFound();
}
}
break;
}
case MaxDevice::DeviceRadiatorThermostatPlus:
break;
case MaxDevice::DeviceWallThermostat:{
foreach (WallThermostat* device, m_wallThermostatList) {
if(device->rfAddress() == rfAddress){
//int roomId = dataRaw.mid(10,2).toInt(0,16);
int firmware = dataRaw.mid(12,2).toInt(0,16);
device->setComfortTemp((double)dataRaw.mid(36,2).toInt(0,16) / 2.0);
device->setEcoTemp((double)dataRaw.mid(38,2).toInt(0,16)/2.0);
device->setMaxSetPointTemp((double)dataRaw.mid(40,2).toInt(0,16)/2.0);
device->setMinSetPointTemp((double)dataRaw.mid(42,2).toInt(0,16)/2.0);
qCDebug(dcEQ3) << " Room ID | " << device->roomId();
qCDebug(dcEQ3) << " firmware | " << firmware;
//qCDebug(dcEQ3) << " Confort Temp. | " << device->confortTemp();
qCDebug(dcEQ3) << " Eco Temp. | " << device->ecoTemp();
qCDebug(dcEQ3) << " Max. Set Point Temp. | " << device->maxSetPointTemp();
qCDebug(dcEQ3) << " Min. Set Point Temp. | " << device->minSetPointTemp();
parseWeeklyProgram(dataRaw.right(dataRaw.length() - 44));
emit wallThermostatFound();
}
}
break;
}
case MaxDevice::DeviceEcoButton:
break;
case MaxDevice::DeviceWindowContact:
break;
default:
qCWarning(dcEQ3) << "unknown device type: " << deviceType;
break;
}
}
void MaxCube::decodeDevicelistMessage(QByteArray data)
{
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " LIVE message:";
qCDebug(dcEQ3) << "====================================================";
QByteArray rawDataAll = QByteArray::fromBase64(data).toHex();
QList<QByteArray> deviceMessageList = splitMessage(rawDataAll);
foreach (QByteArray rawData, deviceMessageList) {
QByteArray rfAddress = rawData.mid(0,6);
int deviceType = deviceTypeFromRFAddress(rfAddress);
switch (deviceType) {
case MaxDevice::DeviceWallThermostat:{
foreach (WallThermostat *device, m_wallThermostatList) {
if(device->rfAddress() == rfAddress){
// init/valid code
QByteArray initCode = fillBin(QByteArray::number(rawData.mid(8,2).toInt(0,16),2),8);
device->setInformationValid((bool)initCode.mid(3,1).toInt());
device->setErrorOccured((bool)initCode.mid(4,1).toInt());
device->setIsAnswereToCommand((bool)initCode.mid(5,1).toInt());
device->setInitialized((bool)initCode.mid(6,1).toInt());
// status code
QByteArray statusCode = fillBin(QByteArray::number(rawData.mid(10,2).toInt(0,16),2),8);
device->setBatteryLow((bool)statusCode.mid(0,1).toInt());
device->setLinkStatusOK(!(bool)statusCode.mid(1,1).toInt());
device->setPanelLocked((bool)statusCode.mid(2,1).toInt());
device->setGatewayKnown((bool)statusCode.mid(3,1).toInt());
device->setDtsActive((bool)statusCode.mid(4,1).toInt());
device->setDeviceMode(statusCode.right(2).toInt(0,2));
// calculate current temperature and setpoint temperature
QByteArray tempCode = fillBin(QByteArray::number(rawData.mid(14,2).toInt(0,16),2),8);
device->setSetpointTemperatre((double)tempCode.right(6).toInt(0,2) / 2.0);
if(tempCode.left(2) == "10"){
device->setCurrentTemperatre(((double)rawData.right(2).toInt(0,16) / 10.0) + 25.6);
}else{
device->setCurrentTemperatre((double)rawData.right(2).toInt(0,16) / 10.0);
}
qCDebug(dcEQ3) << " raw data | " << rawData;
qCDebug(dcEQ3) << " device type | " << device->deviceTypeString();
qCDebug(dcEQ3) << " device name | " << device->deviceName();
qCDebug(dcEQ3) << " RF address (hex) | " << device->rfAddress();
qCDebug(dcEQ3) << " initCode | " << initCode;
qCDebug(dcEQ3) << " information valid | " << device->informationValid();
qCDebug(dcEQ3) << " error occured | " << device->errorOccured();
qCDebug(dcEQ3) << " is answere to a command | " << device->isAnswereToCommand();
qCDebug(dcEQ3) << " initialized | " << device->initialized();
qCDebug(dcEQ3) << " battery low | " << device->batteryLow();
qCDebug(dcEQ3) << " link status OK | " << device->linkStatusOK();
qCDebug(dcEQ3) << " panel locked | " << device->panelLocked();
qCDebug(dcEQ3) << " gateway known | " << device->gatewayKnown();
qCDebug(dcEQ3) << " DST settings active | " << device->dtsActive();
qCDebug(dcEQ3) << " device mode | " << device->deviceModeString();
qCDebug(dcEQ3) << " Temperatur Setpoint | " << device->setpointTemperature();
qCDebug(dcEQ3) << " Current Temp | " << device->currentTemperature();
qCDebug(dcEQ3) << "-------------------------|-------------------------";
emit wallThermostatDataUpdated();
}
}
break;
}
case MaxDevice::DeviceRadiatorThermostat:{
foreach (RadiatorThermostat* device, m_radiatorThermostatList) {
if(device->rfAddress() == rfAddress){
QByteArray initCode = fillBin(QByteArray::number(rawData.mid(8,2).toInt(0,16),2),8);
device->setInformationValid((bool)initCode.mid(3,1).toInt());
device->setErrorOccured((bool)initCode.mid(4,1).toInt());
device->setIsAnswereToCommand((bool)initCode.mid(5,1).toInt());
device->setInitialized((bool)initCode.mid(6,1).toInt());
QByteArray statusCode = fillBin(QByteArray::number(rawData.mid(10,2).toInt(0,16),2),8);
device->setBatteryLow((bool)statusCode.mid(0,1).toInt());
device->setLinkStatusOK(!(bool)statusCode.mid(1,1).toInt());
device->setPanelLocked((bool)statusCode.mid(2,1).toInt());
device->setGatewayKnown((bool)statusCode.mid(3,1).toInt());
device->setDtsActive((bool)statusCode.mid(4,1).toInt());
device->setDeviceMode(statusCode.right(2).toInt(0,2));
device->setValvePosition((double)rawData.mid(12,2).toInt(0,16));
device->setSetpointTemperatre((double)rawData.mid(14,2).toInt(0,16)/ 2.0);
qCDebug(dcEQ3) << " device type | " << device->deviceTypeString();
qCDebug(dcEQ3) << " device name | " << device->deviceName();
qCDebug(dcEQ3) << " RF address (hex) | " << device->rfAddress();
qCDebug(dcEQ3) << " information valid | " << device->informationValid();
qCDebug(dcEQ3) << " error occured | " << device->errorOccured();
qCDebug(dcEQ3) << " is answere to a command | " << device->isAnswereToCommand();
qCDebug(dcEQ3) << " initialized | " << device->initialized();
qCDebug(dcEQ3) << " battery low | " << device->batteryLow();
qCDebug(dcEQ3) << " link status OK | " << device->linkStatusOK();
qCDebug(dcEQ3) << " panel locked | " << device->panelLocked();
qCDebug(dcEQ3) << " gateway known | " << device->gatewayKnown();
qCDebug(dcEQ3) << " DST settings active | " << device->dtsActive();
qCDebug(dcEQ3) << " device mode | " << device->deviceModeString();
qCDebug(dcEQ3) << " valve position | " << device->valvePosition() << "%";
qCDebug(dcEQ3) << " Temperatur Setpoint | " << device->setpointTemperature() << " deg C";
qCDebug(dcEQ3) << "-------------------------|-------------------------";
emit radiatorThermostatDataUpdated();
}
}
break;
}
case MaxDevice::DeviceWindowContact:{
//QByteArray windowOpenRawData = fillBin(QByteArray::number(rawData.mid(10,2).toInt(0,16),2),8);
//bool windowOpen = (bool)windowOpenRawData.mid(5,1).toInt();
// qCDebug(dcEQ3) << " raw data | " << rawData;
// qCDebug(dcEQ3) << " device type name | " << "Window Contact";
// qCDebug(dcEQ3) << " RF address (hex) | " << rfAddress;
// qCDebug(dcEQ3) << " window open code | " << windowOpenRawData;
// qCDebug(dcEQ3) << " window open | " << windowOpen;
// qCDebug(dcEQ3) << "-------------------------|-------------------------";
break;
}
default:
break;
}
}
}
void MaxCube::decodeCommandMessage(QByteArray data)
{
QList<QByteArray> list = data.split(',');
if(list.isEmpty()){
return;
}
bool succeeded = !(bool)list.at(2).toInt(0,10);
emit commandActionFinished(succeeded,m_actionId);
}
void MaxCube::parseWeeklyProgram(QByteArray data)
{
for(int i=0; i < 7; i++){
QByteArray dayData = data.left(52);
//qCDebug(dcEQ3) << weekDayString(i);
for(int i = 0; i < 52; i+=4){
QByteArray element = fillBin(QByteArray::number(dayData.mid(i,4).toInt(0,16),2),16);
//int minutes = element.right(9).toInt(0,2) * 5;
//int hours = (minutes / 60) % 24;
//minutes = minutes % 60;
//QTime time = QTime(hours,minutes);
//qCDebug(dcEQ3) << (double)element.left(7).toInt(0,2) / 2 << "\t" << "deg. until" << "\t" << time.toString("HH:mm");
}
data = data.right(data.length() - 52);
}
if(!data.isEmpty()){
//qCDebug(dcEQ3) << " ? | " << data;
}
}
void MaxCube::decodeNewDeviceFoundMessage(QByteArray data)
{
if(data.isEmpty()){
return;
}
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " NEW DEVICE message:";
qCDebug(dcEQ3) << "====================================================";
qCDebug(dcEQ3) << " Serial Number | " << QByteArray::fromBase64(data);
}
QDateTime MaxCube::calculateDateTime(QByteArray dateRaw, QByteArray timeRaw)
{
QDate date;
QTime time;
date.setDate(dateRaw.left(2).toInt(0,16) + 2000, dateRaw.mid(2,2).toInt(0,16), dateRaw.right(2).toInt(0,16));
time.setHMS(timeRaw.left(2).toInt(0,16), timeRaw.right(2).toInt(0,16), 0);
return QDateTime(date,time);
}
QString MaxCube::deviceTypeString(int deviceType)
{
QString deviceTypeString;
switch (deviceType) {
case MaxDevice::DeviceCube:
deviceTypeString = "Cube";
break;
case MaxDevice::DeviceRadiatorThermostat:
deviceTypeString = "Radiator Thermostat";
break;
case MaxDevice::DeviceRadiatorThermostatPlus:
deviceTypeString = "Radiator Thermostat Plus";
break;
case MaxDevice::DeviceEcoButton:
deviceTypeString = "Eco Button";
break;
case MaxDevice::DeviceWindowContact:
deviceTypeString = "Window Contact";
break;
case MaxDevice::DeviceWallThermostat:
deviceTypeString = "Wall Thermostat";
break;
default:
deviceTypeString = "-";
break;
}
return deviceTypeString;
}
QString MaxCube::weekDayString(int weekDay)
{
QString weekDayString;
switch (weekDay) {
case Monday:
weekDayString = "Monday";
break;
case Tuesday:
weekDayString = "Tuesday";
break;
case Wednesday:
weekDayString = "Wednesday";
break;
case Thursday:
weekDayString = "Thursday";
break;
case Friday:
weekDayString = "Friday";
break;
case Saturday:
weekDayString = "Saturday";
break;
case Sunday:
weekDayString = "Sunday";
break;
default:
weekDayString = "-";
break;
}
return weekDayString;
}
QByteArray MaxCube::fillBin(QByteArray data, int dataLength)
{
QByteArray zeros;
for(int i = 0; i < dataLength - data.length(); i++){
zeros.append("0");
}
data = zeros.append(data);
return data;
}
QList<QByteArray> MaxCube::splitMessage(QByteArray data)
{
QList<QByteArray> messageList;
while(!data.isEmpty()){
int length = data.left(2).toInt(0,16)*2;
messageList.append(data.mid(2,length));
data = data.right(data.length() - (length+2));
}
//qCDebug(dcEQ3) << messageList;
return messageList;
}
int MaxCube::deviceTypeFromRFAddress(QByteArray rfAddress)
{
foreach (WallThermostat* device, m_wallThermostatList) {
if(device->rfAddress() == rfAddress){
return device->deviceType();
}
}
foreach (RadiatorThermostat* device, m_radiatorThermostatList) {
if(device->rfAddress() == rfAddress){
return device->deviceType();
}
}
return -1;
}
void MaxCube::connectionStateChanged(const QAbstractSocket::SocketState &socketState)
{
switch (socketState) {
case QAbstractSocket::ConnectedState:
qCDebug(dcEQ3) << "connected to cube " << m_serialNumber << m_hostAddress.toString();
emit cubeConnectionStatusChanged(true);
break;
case QAbstractSocket::UnconnectedState:
m_cubeInitialized = false;
qCDebug(dcEQ3) << "disconnected from cube " << m_serialNumber << m_hostAddress.toString();
emit cubeConnectionStatusChanged(false);
break;
default:
break;
}
}
void MaxCube::error(QAbstractSocket::SocketError error)
{
qCWarning(dcEQ3) << "connection error (" << m_serialNumber << "): " << error;
emit cubeConnectionStatusChanged(false);
}
void MaxCube::readData()
{
QByteArray message;
while(canReadLine()){
QByteArray dataLine = readLine();
message.append(dataLine);
}
emit cubeDataAvailable(message);
}
void MaxCube::processCubeData(const QByteArray &data)
{
//qCDebug(dcEQ3) << "data" << data;
if(data.startsWith("H")){
decodeHelloMessage(data.right(data.length() -2 ));
return;
}
// METADATA message
if(data.startsWith("M")){
decodeMetadataMessage(data.right(data.length() -2 ));
return;
}
// CONFIG message
if(data.startsWith("C")){
QList<QByteArray> dataList = data.split('\r');
foreach (QByteArray dataElement, dataList) {
if(dataElement.startsWith("C")){
decodeConfigMessage(dataElement.right(dataElement.length() -2 ));
}
if(dataElement.startsWith("\nC")){
decodeConfigMessage(dataElement.right(dataElement.length() -3 ));
}
}
return;
}
// LIVE message
if(data.startsWith("L")){
decodeDevicelistMessage(data.right(data.length() -2 ));
return;
}
// NEWDEVICEFOUND message
if(data.startsWith("N")){
decodeNewDeviceFoundMessage(data.right(data.length() -2));
return;
}
// COMMAND answere message
if(data.startsWith("S")){
decodeCommandMessage(data.right(data.length() -2));
return;
}
// ACK message
if(data.startsWith("A")){
qCDebug(dcEQ3) << "cube ACK!";
emit cubeACK();
return;
}
qCWarning(dcEQ3) << " -> unknown message!!!!!!! from cube:" << data;
}
void MaxCube::enablePairingMode()
{
qCDebug(dcEQ3) << "-------> enable pairing mode! press the boost button for min. 3 seconds";
write("n:003c\r\n");
}
void MaxCube::disablePairingMode()
{
qCDebug(dcEQ3) << " ----> disable pairing mode!";
write("x:\r\n");
}
void MaxCube::refresh()
{
if(!isInitialized() || !isConnected()){
return;
}
write("l:\r\n");
}
void MaxCube::customRequest(QByteArray data)
{
qCDebug(dcEQ3) << " ----> custom request" << data;
write(data + "\r\n");
}
void MaxCube::setDeviceSetpointTemp(QByteArray rfAddress, int roomId, double temperature, ActionId actionId)
{
m_actionId = actionId;
if(!isConnected() || !isInitialized()){
emit commandActionFinished(false,m_actionId);
return;
}
QByteArray data = "000440000000";
data.append(rfAddress);
// if roomID = 0....means all rooms
data.append(fillBin(QByteArray::number(roomId,16),2));
QByteArray temperatureData;
//temperature in 6 bits
temperatureData = fillBin(QByteArray::number((int)temperature*2,2),6);
// set auto/ permanent/ temp
// 00 = auto (weekly programm...the hole tempererature byte to 0x00
// 01 = Permanent
// 10 = Temporary (date/time has to be set)
data.append(fillBin(QByteArray::number(temperatureData.toInt(0,2),16),2));
temperatureData.append("01");
// add date/time until (000000 = forever)
data.append("000000");
qCDebug(dcEQ3) << "sending command " << temperatureData << data;
write("s:" + QByteArray::fromHex(data).toBase64() + "\r\n");
}
void MaxCube::setDeviceAutoMode(QByteArray rfAddress, int roomId, ActionId actionId)
{
m_actionId = actionId;
if(!isConnected() || !isInitialized()){
emit commandActionFinished(false,m_actionId);
return;
}
QByteArray data = "000440000000";
data.append(rfAddress);
// if roomID = 0....means all rooms
data.append(fillBin(QByteArray::number(roomId,16),2));
QByteArray temperatureData;
temperatureData.append("00000000");
data.append("000000");
qCDebug(dcEQ3) << "sending command " << temperatureData << data;
write("s:" + QByteArray::fromHex(data).toBase64() + "\r\n");
}
void MaxCube::setDeviceManuelMode(QByteArray rfAddress, int roomId, ActionId actionId)
{
m_actionId = actionId;
if(!isConnected() || !isInitialized()){
emit commandActionFinished(false,m_actionId);
return;
}
QByteArray data = "000440000000";
data.append(rfAddress);
// if roomID = 0....means all rooms
data.append(fillBin(QByteArray::number(roomId,16),2));
data.append("62");
write("s:" + QByteArray::fromHex(data).toBase64() + "\r\n");
}
void MaxCube::setDeviceEcoMode(QByteArray rfAddress, int roomId, ActionId actionId)
{
m_actionId = actionId;
if(!isConnected() || !isInitialized()){
emit commandActionFinished(false,m_actionId);
return;
}
QByteArray data = "000440000000";
data.append(rfAddress);
// if roomID = 0....means all rooms
data.append(fillBin(QByteArray::number(roomId,16),2));
data.append("6b");
write("s:" + QByteArray::fromHex(data).toBase64() + "\r\n");
}
void MaxCube::displayCurrentTemperature(QByteArray rfAddress, int roomId, bool display, ActionId actionId)
{
Q_UNUSED(roomId)
m_actionId = actionId;
if(!isConnected() || !isInitialized()){
emit commandActionFinished(false,m_actionId);
return;
}
QByteArray data = "000082000000";
data.append(rfAddress);
if(display){
data.append("0004");
}else{
data.append("0000");
}
write("s:" + QByteArray::fromHex(data).toBase64() + "\r\n");
}
Reference in New Issue View Git Blame Copy Permalink