#include "MyThread.h"
#include "osapi/osapi.h"
#include "GBK.h"

MyThread::MyThread(QString str,QObject *parent)
	: QThread(parent)
{
	strLocal=str;
}

MyThread::~MyThread()
{

}

void MyThread::run()
{
	string bufLocal=GBK::FromUnicode(strLocal);//获取对话框中对方地址
// 	char *chLocal=new char[32];
// 	chLocal=(char*)bufLocal.c_str();

	OS_SockAddr local(bufLocal.c_str(),9001);
	OS_UdpSocket sock;
	sock.Open(local,true);

	OS_SockAddr peer;//对方地址
	while (1)
	{
		//获取当下时间
		time_t now=time(NULL);
		tm one=*localtime(&now);
		int hour=one.tm_hour;
		int minute=one.tm_min;
		int second=one.tm_sec;
		char buftime[1024];
		if (hour>=0&&hour<=12)
		{
			sprintf(buftime,"AM-%d-%d-%d: ",hour,minute,second);
		}
		else
		{
			sprintf(buftime,"PM-%d-%d-%d: ",hour,minute,second);
		}


		char buf[1024];
		if (sock.RecvFrom(buf,1024,peer)<=0)
		{
			break;
		}
		//strcat(buftime,buf);
		QString strtime=GBK::ToUnicode(buftime);
		QString str=GBK::ToUnicode(buf);
		//m_str=str;
		emit ResvMessage(strtime,str);//发射信号
	}

	sock.Close();
}
// QString MyThread::Over()
// {
// 	return m_str;
// }