threadsocket.cpp

#include "threadsocket.h"

ThreadSocket::ThreadSocket(QObject *parent)
    : QObject{parent}
{
    qDebug() << "构造ThreadSocket成功！";
    QObject::connect(this,SIGNAL(setAddressSignal(QString,int)),this,SLOT(setAddress(QString,int)));
    QObject::connect(this,SIGNAL(connectSiganl()),this,SLOT(connect()));
    QObject::connect(this,SIGNAL(sendLoginSignal(QString,QString,QString)),this,SLOT(sendLogin(QString,QString,QString)));
    QObject::connect(this,SIGNAL(sendRgsSignal(QString,QString,QString)),this,SLOT(sendRgs(QString,QString,QString)));
    QObject::connect(this,SIGNAL(sendFacialLoginSignal()),this,SLOT(sendFacialLogin()));

}

void ThreadSocket::setMainwindow(ElaWindow *_w)
{
    w = _w;
}

void ThreadSocket::setAddress(QString _IP, int _port)
{
    socket = new QTcpSocket();

    QObject::connect(socket,SIGNAL(connected()),this,SLOT(connected_SLOT()));
    QObject::connect(socket,SIGNAL(readyRead()),this,SLOT(readyRead_SLOT()));

    QObject::connect(this,SIGNAL(getForecastSignal(forecast*)),this,SLOT(getForecast(forecast*)));
    QObject::connect(this,SIGNAL(getliveIndexSignal(liveIndex*)),this,SLOT(getliveIndex(liveIndex*)));
    QObject::connect(this,SIGNAL(getAqiSignal(aqi*)),this,SLOT(getAqi(aqi*)));

    QObject::connect(this,SIGNAL(setAddressSignal(QString,int)),this,SLOT(setAddress(QString,int)));
    QObject::connect(this,SIGNAL(connectSiganl()),this,SLOT(connect()));
    QObject::connect(this,SIGNAL(sendMesSignal(QString,QString,QString)),this,SLOT(sendMes(QString,QString,QString)));

    QObject::connect(this,SIGNAL(sendSeatAngleSignal(QString)),this,SLOT(sendSeatAngle(QString)));

    isSetAddress = false;
    isConnect = false;

    IP = _IP;
    port = _port;
    isSetAddress = true;

    qDebug() << QString("设置SocketIP和port成功！IP:"+IP+" port:"+QString::number(port));
}

void ThreadSocket::connect()
{
    //连接服务器
    socket->connectToHost(IP,port);

    qDebug() << "Try to connect with IP:" << IP << "; port:" << port;
    if(socket->waitForConnected(10000))
    {
        qDebug() << "Connect Successfully! Connect with IP:" << IP << "; port:" << port;
        sendMes("CONNECT","none","none");
        emit connectSuccess();
    }
    else//如果等待超过10000ms
    {
        qDebug() << "Connect failed, entering request loop!";
        //emit connectFailure();
        int i = 0;
        do{
            socket->connectToHost(IP,port);
            qDebug() << "第" << i+1 << "次重连……";
            i++;
            //Sleep(1000);
            if(i > 9)
            {
                qDebug() << "重连失败，请待会再试！";
                break;
            }
        }while(!socket->waitForConnected(10000));
    }
}

void ThreadSocket::sendMes(QString COMMAND, QString dataType, QString city)
{
    QJsonObject obj;
    obj["COMMAND"] = COMMAND;
    obj["client_type"] = "UI";
    obj["dataType"] = dataType;
    obj["city"] = city;

    QJsonDocument doc(obj);
    QByteArray json = doc.toJson(QJsonDocument::Indented);

    socket->write(json);
}

void ThreadSocket::sendSeatAngle(QString angle)
{
    QJsonObject obj;
    obj["COMMAND"] = "SEND_DATA";
    obj["client_type"] = "UI";
    obj["dataType"] = "setSeat";
    obj["seatAngle"] = angle;

    QJsonDocument doc(obj);
    QByteArray json = doc.toJson(QJsonDocument::Indented);

    socket->write(json);
}

void ThreadSocket::sendLogin(QString username, QString pwd, QString uid)
{
    qDebug() << "发送login信息!";
    QJsonObject obj;
    obj["COMMAND"] = "SEND_DATA";
    obj["client_type"] = "UI";
    obj["dataType"] = "logIn";
    obj["username"] = username;
    obj["password"] = pwd;
    obj["uid"] = uid;

    QJsonDocument doc(obj);
    QByteArray json = doc.toJson(QJsonDocument::Indented);

    socket->write(json);
}

void ThreadSocket::sendRgs(QString username, QString pwd, QString facialRecognition)
{
    qDebug() << "发送注册信息……";
    QJsonObject obj;
    obj["COMMAND"] = "SEND_DATA";
    obj["client_type"] = "UI";
    obj["dataType"] = "signUp";
    obj["username"] = username;
    obj["password"] = pwd;
    obj["facialRecognition"] = facialRecognition;//是否需要人脸识别记录

    QJsonDocument doc(obj);
    QByteArray json = doc.toJson(QJsonDocument::Indented);

    socket->write(json);
}

void ThreadSocket::sendFacialLogin()
{
    QJsonObject obj;
    obj["COMMAND"] = "SEND_DATA";
    obj["client_type"] = "UI";
    obj["dataType"] = "requestFacialRecord";


    QJsonDocument doc(obj);
    QByteArray json = doc.toJson(QJsonDocument::Indented);

    socket->write(json);
}


void ThreadSocket::getForecast(forecast *_forecastData)
{
    for(int i = 0; i < 7; i++)
    {
        _forecastData[i] = forecastData[i];     //复制一下
    }
    emit getForecastSignalSuccess();
    qDebug() << "getForecastSignalSuccess";
}

void ThreadSocket::getliveIndex(liveIndex *_liveIndexData)
{
    for(int i = 0; i < 11; i++)
    {
        _liveIndexData[i] = liveIndexData[i];   //复制一下
    }
    emit getliveIndexSignalSuccess();
    qDebug() << "getliveIndexSignalSuccess";


}

void ThreadSocket::getAqi(aqi *_aqiData)
{
    _aqiData->co = aqiData.co;
    _aqiData->no2 = aqiData.no2;
    _aqiData->o3 = aqiData.o3;
    _aqiData->pm10 = aqiData.pm10;
    _aqiData->pm25 = aqiData.pm25;
    _aqiData->value = aqiData.value;

    emit getAqiSignalSuccess();
    qDebug() << "getAqiSignalSuccess";

}

void ThreadSocket::readyRead_SLOT()
{
    json_str.append(socket->readLine());
    if (json_str.contains("conditionDay"))
    {
        if(!json_str.contains("aqi"))//如果不包含就是没读全，再读一遍
        {
            for(int i = 0;i<50;i++){
                json_str.append(socket->readLine());
                if(json_str.contains("aqi"))//保险起见，再检查一遍
                {
                    qDebug() << "beyond服务器发信息不给力啊！可算是接收到了";
                    break;
                }
                qDebug() <<"循环第"<<i<<"次";
                /*防止逆天服务器数据发不全的解决办法*/
                QEventLoop loop;
                QTimer::singleShot(1000, &loop, SLOT(quit())); // 1秒后退出事件循环
                loop.exec();
            }
        }
    }
    qDebug() << "服务器发来消息:" << json_str;
    emit readyRead();

    // QJsonParseError类用于在JSON解析期间报告错误。
    QJsonParseError jsonError;
    // 将json解析为UTF-8编码的json文档，并从中创建一个QJsonDocument。
    // 如果解析成功，返回QJsonDocument对象，否则返回null
    QJsonDocument doc = QJsonDocument::fromJson(json_str.toUtf8(), &jsonError);
    // 判断是否解析失败
    if (jsonError.error != QJsonParseError::NoError && !doc.isNull()) {
        qDebug() << "Json格式错误！" << jsonError.error;
        return;
    }
    qDebug() << "Json解析成功";
    QJsonObject rootObj = doc.object(); // 获取根
    // 根据键获取值
    if (rootObj.contains("forecast") && rootObj["forecast"].isArray()) {
        QJsonArray forecastArray = rootObj["forecast"].toArray(); // 转换为数组
        int i = 0;
        // qDebug() << "1";
        for (const QJsonValue &value : forecastArray) {
            if (value.isObject()) {
                QJsonObject item = value.toObject();
                if (item.contains("conditionDay") && item["conditionDay"].isString()) {
                    forecastData[i].conditionDay = item["conditionDay"].toString();
                    // qDebug() << "conditionDay:" <<forecastData[i].conditionDay;
                }
                if (item.contains("conditionNight") && item["conditionNight"].isString()) {
                    forecastData[i].conditionNight = item["conditionNight"].toString();
                }
                if (item.contains("predictDate") && item["predictDate"].isString()) {
                    forecastData[i].date = item["predictDate"].toString();
                }
                if (item.contains("humidity") && item["humidity"].isString()) {
                    forecastData[i].humidity = item["humidity"].toString();
                }
                if (item.contains("tempDay") && item["tempDay"].isString()) {
                    forecastData[i].tempDay = item["tempDay"].toString();
                }
                if (item.contains("tempNight") && item["tempNight"].isString()) {
                    forecastData[i].tempNight = item["tempNight"].toString();
                }
            }
            i++;
        }
    }
    if (rootObj.contains("liveIndex") && rootObj["liveIndex"].isArray()) {
        QJsonArray liveIndexArray = rootObj["liveIndex"].toArray(); // 转换为数组
        int i = 0;
        // qDebug() << "2";
        for (const QJsonValue &value : liveIndexArray) {
            if (value.isObject()) {
                QJsonObject item = value.toObject();
                if (item.contains("name") && item["name"].isString()) {
                    liveIndexData[i].name = item["name"].toString();
                }
                if (item.contains("day") && item["day"].isString()) {
                    liveIndexData[i].day = item["day"].toString();
                }
                if (item.contains("desc") && item["desc"].isString()) {
                    liveIndexData[i].desc = item["desc"].toString();
                }
                if (item.contains("level") && item["level"].isString()) {
                    liveIndexData[i].level = item["level"].toString();
                }
                if (item.contains("status") && item["status"].isString()) {
                    liveIndexData[i].status = item["status"].toString();
                }
            }
            i++;
        }
    }
    if (rootObj.contains("aqi") && rootObj["aqi"].isObject())
    {
        // qDebug() << "3";
        QJsonObject item = rootObj["aqi"].toObject();
        aqiData.co = item["co"].toString();
        aqiData.no2 = item["no2"].toString();
        aqiData.o3 = item["o3"].toString();
        aqiData.value = item["value"].toString();
        aqiData.pm10 = item["pm10"].toString();
        aqiData.pm25 = item["pm25"].toString();
        // qDebug() << "CO指数:\t" << aqiData.co;
        // qDebug() << "NO2指数:\t" << aqiData.no2;
        // qDebug() << "O3指数:\t" << aqiData.o3;
        // qDebug() << "PM10指数:\t" << aqiData.pm10;
        // qDebug() << "PM2.5指数:\t" << aqiData.pm25;
        // qDebug() << "空气总指数:\t" << aqiData.value;
    }
    if (rootObj.contains("sensor") && rootObj["sensor"].isObject())
    {
        QJsonObject item = rootObj["sensor"].toObject();
        globalVal::DHT_H = item["DHT_H"].toString();
        globalVal::DHT_T = item["DHT_T"].toString();
        globalVal::BPM = item["heartData"].toString();
        globalVal::power = item["power"].toString();
        globalVal::seat = item["seat"].toString();
        qDebug()<<"温度:"<<globalVal::DHT_H<<" 湿度:"<<globalVal::DHT_T;
        qDebug()<<"BPM:"<<globalVal::BPM<<" 电量:"<<globalVal::power;
        emit getSensorSignal(); // 发出信号让其它的类接收
    }
    if (rootObj.contains("loginState")&& rootObj["loginState"].isObject())
    {
        QJsonObject item = rootObj["loginState"].toObject();
        if (item["state"] == "True")
        {
            qDebug() << "登录成功！";
            emit loginstate(true);
            emit changeUserInfo(item["name"].toString());
            qDebug()<<"name:" << item["name"].toString();
        }

        else if(item["state"] == "False")
        {
            qDebug() << "登录失败！";
            emit loginstate(false);
        }
    }
    if (rootObj.contains("rgsState")&& rootObj["rgsState"].isObject())
    {
        QJsonObject item = rootObj["rgsState"].toObject();
        if (item["state"] == "True")
        {
            emit signUpState(true);
            qDebug() << "注册成功";
        }
        else if(item["state"] == "False")
        {
            emit signUpState(false);
            qDebug() << "注册成功";
        }
    }

    json_str = "";
}

void ThreadSocket::connected_SLOT()
{
    // emit connected();
}