eachitemdoc.h

一个多线程的网络数据采集系统（客户端）

// EachItemDoc.h :  CEachItemDoc 类的接口
//
#include "RealTime.h"
#include "ClientSocket.h"

#pragma once

class CEachItemDoc : public CDocument
{
protected: // 仅从序列化创建
	CEachItemDoc();
	DECLARE_DYNCREATE(CEachItemDoc)

// 属性
public:
	CRealTime m_graph;
	//for TCP/IP communication
	/**
     * 申请连接的服务器ip地址串
     *
	 */
	BOOL m_bData;
	BOOL m_bConnected;
	BOOL bSignIn;
	BOOL bAway;
	
	CClientThread *m_pClientThread;
	/**
	* 数据包接收队列
	**/
	CPkgQueue m_recvQueue;
	/**
	* 数据包发送队列
	**/
	CPkgQueue m_sendQueue;
	UINT m_dCommStatus;  //进行通信时，curveview的状态
	int	m_iComNo;
	CString	m_strServerIP;
	CommDataType m_DataType;
	//////////////////////////////

// 操作
public:

// 重写
public:
	virtual BOOL OnNewDocument();
	virtual void Serialize(CArchive& ar);

// 实现
public:
	virtual ~CEachItemDoc();
#ifdef _DEBUG
	virtual void AssertValid() const;
	virtual void Dump(CDumpContext& dc) const;
#endif

protected:

// 生成的消息映射函数
protected:
	//{{AFX_MSG(CEachItemDoc)
	afx_msg void OnConnect();
	afx_msg void OnUpdateConnectUI(CCmdUI* pCmdUI);
	afx_msg void OnSend();
	afx_msg void OnUpdateSendUI(CCmdUI* pCmdUI);
	afx_msg void OnStopSend();
	afx_msg void OnUpdateStopSendUI(CCmdUI* pCmdUI);
	afx_msg void OnDisconnect();
	afx_msg void OnUpdateDisconnectUI(CCmdUI* pCmdUI);
	//}}AFX_MSG
	DECLARE_MESSAGE_MAP()
public:
	void SendOpenCom();
	double GetPkgValue(CPkg* pkg);
	void Receive(int i, CPkg* pkg);//SPLINEDATA pkg);
	void SetComDataType(CString strDataType);
};