diff options
Diffstat (limited to 'tradeshow/knx-demo/2d-knx-demo/qmlknxdemo.cpp')
| -rw-r--r-- | tradeshow/knx-demo/2d-knx-demo/qmlknxdemo.cpp | 311 |
1 files changed, 311 insertions, 0 deletions
diff --git a/tradeshow/knx-demo/2d-knx-demo/qmlknxdemo.cpp b/tradeshow/knx-demo/2d-knx-demo/qmlknxdemo.cpp new file mode 100644 index 0000000..4215246 --- /dev/null +++ b/tradeshow/knx-demo/2d-knx-demo/qmlknxdemo.cpp @@ -0,0 +1,311 @@ +/**************************************************************************** +** +** Copyright (C) 2018 The Qt Company Ltd. +** Contact: https://www.qt.io/licensing/ +** +** This file is part of the examples of the Qt Toolkit. +** +** $QT_BEGIN_LICENSE:BSD$ +** Commercial License Usage +** Licensees holding valid commercial Qt licenses may use this file in +** accordance with the commercial license agreement provided with the +** Software or, alternatively, in accordance with the terms contained in +** a written agreement between you and The Qt Company. For licensing terms +** and conditions see https://www.qt.io/terms-conditions. For further +** information use the contact form at https://www.qt.io/contact-us. +** +** BSD License Usage +** Alternatively, you may use this file under the terms of the BSD license +** as follows: +** +** "Redistribution and use in source and binary forms, with or without +** modification, are permitted provided that the following conditions are +** met: +** * Redistributions of source code must retain the above copyright +** notice, this list of conditions and the following disclaimer. +** * Redistributions in binary form must reproduce the above copyright +** notice, this list of conditions and the following disclaimer in +** the documentation and/or other materials provided with the +** distribution. +** * Neither the name of The Qt Company Ltd nor the names of its +** contributors may be used to endorse or promote products derived +** from this software without specific prior written permission. +** +** +** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +** "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +** LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +** A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +** OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +** DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +** THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +** OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE." +** +** $QT_END_LICENSE$ +** +****************************************************************************/ + +#include "demodatapoint.h" +#include "qmlknxdemo.h" +#include "utils.h" + +#include <QtCore/QString> +#include <QtKnx/QKnxAddress> +#include <QtNetwork/QNetworkInterface> + +namespace { + const double sliderSectionSize = 1 / 7.0; + using DeviceNumbers = EtsDevelopmentBoard::DeviceNumbers; +} + +QmlKnxDemo::QmlKnxDemo() + : m_tunnel(this) +{ + checkLightStatusOn(); + + if (auto blind = m_etsBoard.getBlind()) { + connect(blind, &DemoBlindDataPoint::blindChange, this, &QmlKnxDemo::blindPositionChange); + connect(blind, &DemoBlindDataPoint::blindFullyUp, this, &QmlKnxDemo::blindFullyUp); + connect(blind, &DemoBlindDataPoint::blindFullyDown, this, &QmlKnxDemo::blindFullyDown); + } + + if (auto rocker = m_etsBoard.getRocker()) + connect(rocker, &DemoRockerDataPoint::rockerChange, this, &QmlKnxDemo::rockerChange); + + if (auto colorLed = m_etsBoard.getColorLed()) + connect(colorLed, &DemoColorLed::colorChange, this, &QmlKnxDemo::colorLedChange); +} + +void QmlKnxDemo::toggleLight(int light) +{ + if (auto dpt = static_cast<DemoSwitchDataPoint *>(m_etsBoard.getGroupObject(light))) { + dpt->uiToggle(); + sendGroupValueWrite(m_tunnel, m_etsBoard.getAddress(light), dpt->bytes()); + } +} + +void QmlKnxDemo::colorSwitch(double value) +{ + QColor colorAtStart = colorState; + if (value < (sliderSectionSize / 2) && colorState != Qt::black) { + colorState = Qt::black; + } else if ((value > (sliderSectionSize / 2)) + && value < (3 * sliderSectionSize / 2) + && (colorState != Qt::white)) { + colorState = Qt::white; + } else if ((value > (3 * sliderSectionSize / 2)) + && value < (5 * sliderSectionSize / 2) + && (colorState != Qt::red)) { + colorState = Qt::red; + } else if ((value > (5 * sliderSectionSize / 2)) + && value < (7 * sliderSectionSize / 2) + && (colorState != Qt::magenta)) { + colorState = Qt::magenta; + } else if ((value > (7 * sliderSectionSize / 2)) + && value < (9 * sliderSectionSize / 2) + && (colorState != Qt::blue)) { + colorState = Qt::blue; + } else if ((value > (9 * sliderSectionSize / 2)) + && value < (11 * sliderSectionSize / 2) + && (colorState != Qt::cyan)) { + colorState = Qt::cyan; + } else if (value > (11 * sliderSectionSize / 2) + && value < (13 * sliderSectionSize / 2) + && (colorState != Qt::green)) { + colorState = Qt::green; + } else if (value > ((6 * sliderSectionSize) + (sliderSectionSize / 2)) + && (colorState != Qt::yellow)) { + colorState = Qt::yellow; + } + + if (colorAtStart != colorState) { + if (auto led = m_etsBoard.getColorLed()) { + led->setCurrentColor(colorState); + sendColorLedGroupValueWriteFrames(m_tunnel, led); + } + } +} + +void QmlKnxDemo::toggleMiddleRight() +{ + auto light = DeviceNumbers::MIDDLE_RIGHT; + if (auto dpt = static_cast<DemoSwitchDataPoint *>(m_etsBoard.getGroupObject(light))) { + dpt->uiToggle(); + sendGroupValueWrite(m_tunnel, m_etsBoard.getAddress(light), dpt->bytes()); + } +} + +void QmlKnxDemo::toggleMiddleLeft() +{ + if (auto led = m_etsBoard.getColorLed()) { + // set green color in dpt by default... + led->setCurrentColor(QColor(0, (!led->isOn() ? 255 : 0), 0)); + sendColorLedGroupValueWriteFrames(m_tunnel, led); + } +} + +QString QmlKnxDemo::getColor() const +{ + if (auto obj = m_etsBoard.getColorLed()) + return obj->currentColor().name(); + return {}; +} + +int QmlKnxDemo::getRockerPosition() const +{ + if (auto rocker = m_etsBoard.getRocker()) + return rocker->position(); + return 0; +} + +bool QmlKnxDemo::getLightState(int lightNum) const +{ + if (auto dpt = static_cast<DemoSwitchDataPoint *>(m_etsBoard.getGroupObject(lightNum))) + return dpt->isOn(); + return false; +} + +int QmlKnxDemo::getBlindPosition() const +{ + if (auto blind = m_etsBoard.getBlind()) + return blind->position(); + return 0; +} + +void QmlKnxDemo::moveBlindUp() +{ + if (auto dpt = m_etsBoard.getBlind()) { + sendGroupValueWrite(m_tunnel, m_etsBoard.getAddress(DeviceNumbers::E7), dpt->moveUpBytes(), + 0xac); + } +} + +void QmlKnxDemo::moveBlindDown() +{ + if (auto dpt = m_etsBoard.getBlind()) { + sendGroupValueWrite(m_tunnel, m_etsBoard.getAddress(DeviceNumbers::E7), dpt->moveDownBytes(), + 0xac); + } +} + +void QmlKnxDemo::stopBlind() +{ + auto index = DeviceNumbers::E16; + if (auto dpt = static_cast<DemoBlindDataPoint *>(m_etsBoard.getGroupObject(index))) + sendGroupValueWrite(m_tunnel, m_etsBoard.getAddress(index), dpt->stopBytes(), 0xac); +} + +void QmlKnxDemo::handleFrame(const QKnxLinkLayerFrame &frame) +{ + auto dstAdd = frame.destinationAddress().toString(); + + if (QKnxLinkLayerFrame::MessageCode::DataConfirmation == frame.messageCode() + || QKnxLinkLayerFrame::MessageCode::DataIndication == frame.messageCode()) { + // data indication come from pushing buttons on the Board + // data confirmation are responses to App UI requests + bool boardStateChanged = false; + const QKnxAddress dstAddress = frame.destinationAddress(); + if (m_etsBoard.exists(dstAddress)) + boardStateChanged = m_etsBoard.getGroupObject(dstAddress)->updateDataPointState(frame); + + if (boardStateChanged) + emit boardUpdate(m_etsBoard.getIndex(dstAddress)); + } +} + +static QHostAddress obtainLocalAddress() +{ + auto addresses = QNetworkInterface::allAddresses(); + for (auto address : qAsConst(addresses)) { + if (address.isLoopback() || address.protocol() != QAbstractSocket::IPv4Protocol) + continue; + return address; + } + return QHostAddress::LocalHost; // no local address found! +} + +QmlKnxTunnel::QmlKnxTunnel(QmlKnxDemo *demo) +{ + connect(&m_connection, &QKnxNetIpTunnel::stateChanged, + this, &QmlKnxTunnel::handleConnection); + connect(&m_connection, &QKnxNetIpTunnel::frameReceived, + demo, &QmlKnxDemo::handleFrame); + connect(&m_timer, &QTimer::timeout, this, &QmlKnxTunnel::send); + + auto newAddress = obtainLocalAddress(); + m_connection.setLocalAddress(newAddress); + m_discoveryAgent.setLocalAddress(newAddress); + + // Automatic KNXnet/Ip router discovery. Connects to first router found + static auto handleDiscoveredServer = [&](const QKnxNetIpServerInfo &info) { + if (!m_connected) { + m_ip = info.controlEndpointAddress(); + m_port = info.controlEndpointPort(); + // establish the knx tunnel + reconnect(); + m_connected = true; + } + }; + connect(&m_discoveryAgent, &QKnxNetIpServerDiscoveryAgent::deviceDiscovered, this, + handleDiscoveredServer); + autoDiscoverKnxServers(); +} + +void QmlKnxTunnel::sendFrame(const QKnxLinkLayerFrame &frame) +{ + if (frame.size() == 0) + return; + + if (m_frames.size() == 0) + m_timer.start(200); + m_frames.enqueue(frame); +} + +void QmlKnxTunnel::reconnect() +{ + m_connection.connectToHost(m_ip, m_port); +} + +void QmlKnxTunnel::autoDiscoverKnxServers() +{ + m_discoveryAgent.stop(); + m_discoveryAgent.start(); +} + +void QmlKnxTunnel::changeIp(const QString &ip, quint16 port) +{ + m_ip = QHostAddress(ip); + m_port = port; + m_connection.disconnectFromHost(); +} + +void QmlKnxTunnel::send() +{ + m_connection.sendFrame(m_frames.dequeue()); + if (m_frames.size() == 0) + m_timer.stop(); +} + +void QmlKnxTunnel::handleConnection(QKnxNetIpEndpointConnection::State state) +{ + switch (state) { + case QKnxNetIpEndpointConnection::State::Disconnected: + autoDiscoverKnxServers(); + break; + default: + break; + } +} + +void QmlKnxDemo::changeTunnelIp(const QString &ipStr, quint16 port) +{ + m_tunnel.changeIp(ipStr, port); +} + +void QmlKnxDemo::checkLightStatusOn() +{ + initBoard(m_etsBoard, m_tunnel); +} |