#include "querymsg.h"
#include <QCoreApplication>
#include <iostream>

static int gnquery = 1;
querymsg::querymsg(QObject *parent) : QObject(parent)
{
    mmsg = QDBusMessage::createSignal("/catarc/adc",  "adciv.interface", "modulemsgquery");
    mmsg<<1;
    bool bconnect = QDBusConnection::sessionBus().connect(QString(),"/catarc/adc",  "adciv.interface", "modulemsgres",this,SLOT(onQuery(QByteArray)));

    QTimer * timer = new QTimer();
    connect(timer,SIGNAL(timeout()),this,SLOT(onTimer()));
    timer->start(5000);

    std::cout<<gnquery<<".query:"<<std::endl;
    QDBusConnection::sessionBus().send(mmsg);
}

void querymsg::onTimer()
{
    gnquery++;
    std::cout<<gnquery<<".query:"<<std::endl;
    QDBusConnection::sessionBus().send(mmsg);
//    QCoreApplication::exit();
}

void querymsg::onQuery(QByteArray ba)
{
    if(ba.size() < sizeof(iv::modulemsg_type))
    {
        std::cout<<" querymsg::onQuery size error."<<std::endl;
        return;
    }

    iv::modulemsg_type xmodulemsg;
    memcpy((char *)&xmodulemsg,ba.data(),sizeof(iv::modulemsg_type));

    std::cout<<xmodulemsg.mstrmsgname<<"\t"<<xmodulemsg.mnBufSize<<"\t"<<xmodulemsg.mnMsgBufCount<<std::endl;
}