Wheel 7: TCP client

#ifndef TCPCMDCLIENT_H
#define TCPCMDCLIENT_H

#include <QObject>
#include <QTcpSocket>
#include "CustomFrameBuffer/CustomFrameBufferFor48s.h"

class TcpCmdClient : public QObject
{
    Q_OBJECT
public:
    explicit TcpCmdClient(QObject *parent = nullptr);
    ~TcpCmdClient();
    void setServerIpPort(QString strIp, quint16 port);
signals:
    // Will receive Tcp Data transmission to business interface class 
    void sig_TransferData(QByteArray ba);
public slots:
    void slot_InitSocket();
    void slot_onConnected();
    void slot_onDisconnected();
    void slot_recvData();
    // Network error 
    void slot_networkError(QAbstractSocket::SocketError err);
    void slot_sendData(QByteArray ba);
private:
    void connectTcpServer();
private:
    QTcpSocket *m_pClientSocket;//tcp Client object pointer 
    QString m_strServerIP;//tcp Server side ip
    quint16 m_uServerPort;//tcp Server port 
    bool m_bConnect;// Whether to connect identification 
    CustomFrameBufferFor48s m_FrameBuffer;
};

#endif // TCPCMDCLIENT_H

#include "TcpCmdClient.h"
#include "Player.h"

TcpCmdClient::TcpCmdClient(QObject *parent) : QObject(parent)
{
    m_bConnect = false;
    m_strServerIP = "";
    m_uServerPort = 0;
    m_pClientSocket = nullptr;
}


TcpCmdClient::~TcpCmdClient()
{
    if(m_pClientSocket)
    {
        m_pClientSocket->abort();
        m_pClientSocket->deleteLater();
    }
}

void TcpCmdClient::setServerIpPort(QString strIp, quint16 port)
{
    m_strServerIP = strIp;
    m_uServerPort = port;
}

void TcpCmdClient::connectTcpServer()
{
    if(nullptr==m_pClientSocket)
    {
        m_pClientSocket = new QTcpSocket;
        connect(m_pClientSocket,&QTcpSocket::readyRead,this,&TcpCmdClient::slot_recvData);
        connect(m_pClientSocket,&QTcpSocket::connected,this,&TcpCmdClient::slot_onConnected);
        connect(m_pClientSocket,&QTcpSocket::disconnected,this,&TcpCmdClient::slot_onDisconnected);
        connect(m_pClientSocket,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(slot_networkError(QAbstractSocket::SocketError)));
    }
    m_pClientSocket->abort();

    //m_pClientSocket->setProxy(QNetworkProxy::NoProxy);
    m_pClientSocket->connectToHost(m_strServerIP,m_uServerPort);
    m_bConnect = m_pClientSocket->waitForConnected(5000);
    if(m_bConnect)
    {
        AddLog(QStringLiteral(" Connect tcp Server success "),QString("ip=%1 port=%2").arg(m_strServerIP).arg(m_uServerPort));
    }
    else
    {
        AddLog(QStringLiteral(" Connect tcp The server failed "),QString("ip=%1 port=%2").arg(m_strServerIP).arg(m_uServerPort));
    }
}

void TcpCmdClient::slot_InitSocket()
{
    connectTcpServer();
}

void TcpCmdClient::slot_onConnected()
{
    m_bConnect = true;
}

void TcpCmdClient::slot_onDisconnected()
{
    m_bConnect = false;
    AddLog(QStringLiteral(" Connect tcp The server is disconnected "),"");
}

void TcpCmdClient::slot_networkError(QAbstractSocket::SocketError err)
{
    AddLog(QStringLiteral(" Connect tcp An error occurred on the server "),QString("err = %1").arg(err));
}

void TcpCmdClient::slot_recvData()
{
    while((m_pClientSocket->bytesAvailable())>0)
    {
        QByteArray readmsg = m_pClientSocket->readAll();
        //qDebug()<<readmsg.size();
        m_FrameBuffer.Write(readmsg.data(),readmsg.size());
        QByteArray baFrame;

        while(1){
            int ret = m_FrameBuffer.GetFrame(baFrame);
            if(ret == 1){
                // Send a complete frame to businessIf Parsing 
                emit sig_TransferData(baFrame);

                //qDebug() << "m_FrameBuffer.GetFrame is complete.";
            }else{
                //qDebug() << "m_FrameBuffer.GetFrame is not complete.";
                break;
            }
        }
    }
}

void TcpCmdClient::slot_sendData(QByteArray ba)
{
    if(m_bConnect)
    {
        m_pClientSocket->write(ba.data(),ba.size());
    }
}