#include "AnalysisTask.h"
#include "CoAnalysisServer.h"
#include "mainwindow.h"
#include <windows.h>

AnalysisTask::AnalysisTask(CoAnalysisServer * powner,uint32_t taskid):m_pAsvr(powner),m_taskID(taskid),m_datatrendwidget(NULL)
{
	memset(m_TaskName,0,sizeof(m_TaskName));
	QObject::connect(this, SIGNAL(CreateWidget(QString,QString,QString )), m_pAsvr->m_pown, SLOT(OnCreateAnalysisWidget(QString,QString,QString )));
	//connect(m_alarmviewForm, SIGNAL(currentStockSeleted(QString & )), this, SLOT(onCurrentStockSeleted(QString& )));

}
AnalysisTask::~AnalysisTask()
{
	m_datachannels.clear();
}
void AnalysisTask::BindDataTrendWidget(QDataTrendWidget* widget)
{
	
	m_datatrendwidget=widget;
	qDebug()<<QString("[%1:%2]:").arg(__FUNCTION__).arg(__LINE__)<<this<<","<<m_datatrendwidget;
	InitConnections();

}

void AnalysisTask::InitConnections()
{
	while(m_datatrendwidget==NULL)
	{
		qDebug()<<QString("[%1:%2]:").arg(__FUNCTION__).arg(__LINE__)<<this<<","<<m_datatrendwidget;
		Sleep(10);
	}
	
	assert(m_datatrendwidget!=NULL);
	for(std::list<DataChannel* >::iterator it=m_datachannels.begin();it!=m_datachannels.end();it++)
	{
		DataChannel* &  ptr= *it;
		QObject::connect(ptr, SIGNAL(NewChannelDataRecvied()),m_datatrendwidget,SLOT(SlotNewChannelDataRecvied()));
	}
}
QDataTrendWidget* AnalysisTask::GetDataTrendWidget()
{
	return m_datatrendwidget;
}
uint32_t AnalysisTask::GetTaskID()
{
	return m_taskID;
}
bool AnalysisTask::AddDataChannel(DataChannel * pChannel)
{
	for(std::list<DataChannel* >::iterator it=m_datachannels.begin();it!=m_datachannels.end();it++)
	{
			DataChannel* &  ptr= *it;
		    if(ptr==pChannel)
			{
				derf("重复加入");
				return false;
			}
	}
	m_datachannels.push_back(pChannel);

	return true;
}

bool AnalysisTask::DelDataChannel(DataChannel * pChannel)
{
	bool flag=false;
	for(std::list<DataChannel* >::iterator it=m_datachannels.begin();it!=m_datachannels.end();)
	{
		DataChannel* &  ptr= *it;
		if(ptr==pChannel)
		{
			flag=true;
			it=m_datachannels.erase(it);
			continue;
		}
		it++;
	}

	return flag;
}
const char * AnalysisTask::GetTaskName()
{
	return m_TaskName;
}

void AnalysisTask::SetTaskName(const char * taskname)
{
		_snprintf(m_TaskName,NAME_LEN,"%s",taskname);
}

void AnalysisTask::SetXAxisName(const char * axisname)
{
		_snprintf(m_XAxisName,NAME_LEN,"%s",axisname);
}
void AnalysisTask::SetYAxisName(const char * axisname)
{
		_snprintf(m_YAxisName,NAME_LEN,"%s",axisname);
}
void AnalysisTask::EmitCreateWidget()
{
		emit CreateWidget(QString(m_TaskName),QString(m_XAxisName),QString(m_YAxisName));
}
void AnalysisTask::OnNewChannelDataRecvied()
{
	   emit NewChannelDataRecvied();
}