LaunchRegisterKey/network/udpdatathread.cpp

#include "udpdatathread.h"
#include <QHostAddress>
#include "common.h"
#include <QDebug>
#define MAXSIZES 1024

UdpDataThread::UdpDataThread(QObject *parent)
    : QObject(parent)
    , m_workerThread(new QThread())
    , m_udpWorker(nullptr)
    , m_checkConnectTimer(new QTimer(this))
    , m_connectStatus(false)
    , m_isSending(false)
{
    auto ipAddr = Common::GetInstance()->getHostAddress();
    auto recvPort = Common::GetInstance()->getSrcPort();
    m_hostAddr.setAddress(ipAddr);
    m_udpWorker = new UdpSocketWorker(m_hostAddr, recvPort);
    m_udpWorker->moveToThread(m_workerThread);
    m_workerThread->start();
    connect(m_udpWorker, &UdpSocketWorker::dataReceived, this, &UdpDataThread::recvData);
    connect(m_checkConnectTimer, &QTimer::timeout, this, &UdpDataThread::checkConnectSlot);
    m_checkConnectTimer->start(1000);

}

UdpDataThread::~UdpDataThread()
{

}

void UdpDataThread::sendSnId(const QString &data)
{
    m_udpWorker->startSending("send_sn", data.toLocal8Bit(), m_hostAddr, Common::GetInstance()->getDstPort());
}

void UdpDataThread::sendStop()
{
    m_isSending = false;
}

void UdpDataThread::sendClose()
{
    QString msg = QString("%1%2").arg(CONSTHEAD).arg("0301");
    m_udpWorker->startSending("iecs_close", msg.toLocal8Bit(), m_hostAddr, Common::GetInstance()->getDstPort());
}

void UdpDataThread::stopClose()
{
    m_udpWorker->stopSending("iecs_close");
}

void UdpDataThread::recvData(const QByteArray &data)
{
    if (data.size() == 0)
        return;
    QString dataStr(data);
    if (dataStr.mid(0, 2).toInt() != CONSTHEAD)
        return;

    int msgType = dataStr.mid(2, 2).toInt();
    switch(msgType)
    {
    case SIGNAL_BEATSRC:
    {
        m_connectStatus = true;
        int type = dataStr.mid(4, 2).toInt();
        Common::GetInstance()->setCurrentWorkMode(type);
        emit connectStatus(true);
        break;
    }
    default:
        break;
    }

}

void UdpDataThread::checkConnectSlot()
{
    static int times = 0;
    if (!m_connectStatus)
    {
        times++;
    }
    else
    {
        times = 0;
    }
    if (times >= 3)
    {
        emit connectStatus(false);
        qDebug()<<"disconnect";
        times = 0;
    }
    m_connectStatus = false;
}