DataProcessService/DataProcessService/ytWaterProcess/waterserver3.cpp

#include "waterserver3.h"

waterserver3::waterserver3(QObject *parent) : QTcpServer(parent)
{

}

void waterserver3::start()
{
    if(!this->listen(QHostAddress::Any,5009)){
        exit(-1);
    }
    printf("Listening at 5009\n");
}

void waterserver3::incomingConnection(qintptr socketDescriptor)
{
    SensorThread3 *thread = new SensorThread3(socketDescriptor,this);
    connect(thread,&SensorThread3::finished,thread,&SensorThread3::quit);
    connect(thread,&SensorThread3::getCommData,this,&waterserver3::egetCommData);
    connect(thread,&SensorThread3::getOnLine,this,&waterserver3::egetOnLine);
    connect(thread,&SensorThread3::getValue,this,&waterserver3::egetValue);
    connect(thread,&SensorThread3::getAlarm,this,&waterserver3::egetAlarm);
    thread->start();
}

void waterserver3::egetOnLine(int deviceidx, bool flag, QDateTime t)
{
    emit getOnLine(deviceidx,flag,t);
}

void waterserver3::egetCommData(QString data)
{
    emit getCommData(data);
}

void waterserver3::egetValue(int deviceidx, QString d1, int d2, int d3, double d4, QString d5, QDateTime t)
{
    emit getValue(deviceidx,d1,d2,d3,d4,d5,t);
}

void waterserver3::egetAlarm(int deviceidx, QString d1, int d2, int d3, double d4, QString d5, QString note, QDateTime t)
{
    emit getAlarm(deviceidx,d1,d2,d3,d4,d5,note,t);
}