mothread.h

一个手机通信的源代码 一个手机通信的源代码一个手机通信的源代码

// MoThread1.h: interface for the CMoThread class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_MOTHREAD1_H__C21011CC_7A78_465F_BF99_5CF565E4426B__INCLUDED_)
#define AFX_MOTHREAD1_H__C21011CC_7A78_465F_BF99_5CF565E4426B__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

#include "MoBaseThread.h"
#import "mqoa.dll" no_namespace
#include "Msmqerr.h"
class CServiceAction;
class CMoSocket;
class CMoThread : public CMoBaseThread  
{
public:
	typedef struct StructProvince{
	  CString m_csProvince;
	  CString m_csRemoteIP;
	  UINT    m_LocalPort;
	  int     m_Index;
	  CString m_InQueuePath;
	  CString m_ReportQueuePath;
	  IMSMQQueuePtr m_QueuePtr; //用于写短消息队列
	  IMSMQQueuePtr m_ReportQueuePtr;//用于写状态报告队列
      IMSMQQueueInfoPtr m_QueueInfoPtr;
      IMSMQMessagePtr m_MessagePtr;
	  IMSMQMessagePtr m_ReportMessage;
      CString m_csServerNum;
	}StructProvince;
private:
    CArray<StructProvince*,StructProvince*> m_ProvinceArray;
	BOOL m_bSavereport;
    CString m_ChildType;
	CString m_MsgType;
    UINT m_NotRecDeliver;
	CString m_Province;
	CMoSocket *m_pMoSocket;
	BOOL InitSocket();
	UINT m_LocalPort;
	CString m_ServiceNumber;  //特服号
	CString m_MoPassword;
	BOOL InitQueue();
//	IMSMQQueuePtr m_QueuePtr; //用于写短消息队列
//	IMSMQQueuePtr m_ReportQueuePtr;//用于写状态报告队列
 //   IMSMQQueueInfoPtr m_QueueInfoPtr;
 //   IMSMQMessagePtr m_MessagePtr;
//	IMSMQMessagePtr m_ReportMessage;
    CString m_InQueuePath;
	CString m_ReportQueuePath;
	UINT m_NotWaitMoActive;
public:
	int m_ProvinceNum; //纪录移动的个数
	int m_ReconnectTimes;
	void GetConnectStatus(CString& csConnectStatus);
	void SaveReport(BOOL bSavereport);
    UINT m_WaitDeliverTime;
	UINT m_ReconnectEvent;
	virtual void OnTimer(UINT EventID);
	void InitConnectParam(CString &Province,CString &RemoteIP, UINT &LocalPort, CString &ICPID, CString &UserName, CString &Password, CString &ServiceNumber,int Index,CString InQueuePath,CString ReportQueuePath,CString csServiceNum);
	UINT m_DeliveredMsgs;
	UINT m_DeliverMsgs;
	int m_ConnectStatus;
	CString m_csRemoteIP;
	CString m_csICPID;
	CString m_csPassword;
	CString m_csUserName;
	void GetDeliverMsgs(UINT& DeliverMsgs,UINT& DeliveredMsgs);
	void OnDeliverReport(char& Stat,  char* MsgID,CString& MobileNum,int Index);
	void OnDeliver(CString& DestNumber ,CString& SrcNumber,CString& RecContent,int Index,CString LinkID);
	void ReportNormalInfo(CString& MsgType,CString& ChildType,CString& Content,int Index);
	virtual void ReportError(CString& csErrorInfo,int Index);
	virtual void ExitThread();
	virtual void InitChildClass();
	CMoThread(CServiceAction* pParentAction,UINT DeliverWaitTime);
	virtual ~CMoThread();
    CServiceAction* m_pParentAction;
};

#endif // !defined(AFX_MOTHREAD1_H__C21011CC_7A78_465F_BF99_5CF565E4426B__INCLUDED_)