/**
  @brief 一个数据通道,暂时只支持一个通道一种数据类型数据
*/
#ifndef DATACHANNEL_H
#define DATACHANNEL_H
#include <map>
#include <vector>
#include <QMutex>
#include <QObject>
#include <QTime>
#include <QVector>
#include "event.h"
#include "SockMs.h"
#include "CovAnalysisSDK/protocol.h"
#include "GlobalMacroDef.h"
#include <tuple>        // std::tuple, std::make_tuple, std::tuple_element, std::ge
class CoAnalysisServer;
class AnalysisTask;
class QCPGraph;
//最大的数据条数
#define MAXDATASIZE              10000
class DataChannel:public QObject
{
	Q_OBJECT
	friend class CoAnalysisServer;
	
public:
    DataChannel(CoAnalysisServer * powner);
	~DataChannel();



	void ReSetAnalysisTaskOwner(AnalysisTask *task);

	void UpdateData(int type,void * data,size_t len);

	QCPGraph *           GetGraph();
	void                 SetGraph(QCPGraph *       graphPtr);




	void GetRealTimeDataVector(QVector<double>& tvar,QVector<double>& yvar,QString& graphname);


	void SetChannelDesc(const char * desc);
	const char * GetChannelDesc();



	void SetLineStyle(enum LineStyle style);
	enum LineStyle GetLineStyle();
 
	double GetMaximumValue();

	double GetMinimumValue();
signals:
	void NewChannelDataRecvied();
protected:
	
	static void DataChannelRecvHead(struct ClientMs *pConnect, void *pUserData) ;
	static void DataChannelRecvBody(struct ClientMs *pConnect, void *pUserData) ;



	
private:
	CoAnalysisServer	*m_pAsvr;
	AnalysisTask        *m_taskPtr;
	struct ClientMs		*m_pConnect;
	uint32_t			m_nGateSid; // 唯一ID，由服务器生成，每连接一个客户端，生成一个对应ID
	struct event		*m_eventErrClose;
	MessageHead			m_tHead;  // 用于接收数据头
	std::map<int,std::vector<std::tuple<double,void *>>> m_alldata;//key:类型
	QMutex              m_datalock;
	char                         m_channeldesc[NAME_LEN];
	QCPGraph *           m_graphPtr;

	double               m_maximumvale;
	double               m_minimumvale;
	bool                 m_setmumvale;//是否已经设置了极值
	enum LineStyle       m_linestyle;
};

#endif // DATACHANNEL_H