// SmsTraffic.h: interface for the CSmsTraffic class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_SMSTRAFFIC_H__3A4D81DE_C363_42D6_8A47_3BA017BFBF56__INCLUDED_)
#define AFX_SMSTRAFFIC_H__3A4D81DE_C363_42D6_8A47_3BA017BFBF56__INCLUDED_

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

//#include "ServerMonitor.h"
#include "SMSSend.h"

// 用戶信息編碼方式
#define GSM_7BIT		0
#define GSM_8BIT		4
#define GSM_UCS20		0X18 //免提
#define GSM_UCS2		8

// 應答狀態
#define GSM_WAIT		0		// 等待，不確定
#define GSM_OK			1		// OK
#define GSM_ERR			-1		// ERROR

// 短消息參數結構，編碼/解碼共用
// 其中，字符串以'\0'結尾
typedef struct {
	char SCA[16];			// 短消息服務中心號碼(SMSC地址)
	char TPA[16];			// 目標號碼或回復號碼(TP-DA或TP-RA)
	char TP_PID;			// 用戶信息協議標識(TP-PID)
	char TP_DCS;			// 用戶信息編碼方式(TP-DCS)
	char TP_SCTS[16];		// 服務時間戳字符串(TP_SCTS), 接收時用到
	char TP_UD[512];		// 原始用戶信息(編碼前或解碼后的TP-UD)
	short index;			// 短消息序號，在讀取時用到
	char m_total_num;
	char m_this_num;
	char send_times;
	char send_type;         //0:正常發送1:已超時發送
} SM_PARAM;

// 讀取應答的緩沖區
typedef struct {
	int len;
	char data[16384];
} SM_BUFF;




class CSmsTraffic  
{
public:
	CSmsTraffic();
	virtual ~CSmsTraffic();
	int m_ModuleType;//模塊類型0：短信通知模塊1：發送模塊2：接收模塊3：同時發送接收模塊
	int m_WaitNum;//待發短信數量
	char cs_com[10];
	char SMSC[20];
	int m_nSendIn;		// 發送隊列的輸入指針
	int m_nSendOut;		// 發送隊列的輸出指針

	int m_nSendInTimeOut;		// 已超時發送隊列的輸入指針
	int m_nSendOutTimeOut;		// 已超時發送隊列的輸出指針

	int m_nRecvIn;		// 接收隊列的輸入指針
	int m_nRecvOut;		// 接收隊列的輸出指針

	SM_PARAM m_SmSend[MAX_SM_SEND];		// 發送短消息隊列
	SM_PARAM m_SmRecv[MAX_SM_SEND];		// 接收短消息隊列
	SM_PARAM m_SmSendTimeOut[MAX_SM_SEND];		// 已超時發送短消息隊列

	CRITICAL_SECTION m_csSend;		// 與發送相關的臨界段
	CRITICAL_SECTION m_csRecv;		// 與接收相關的臨界段

	HANDLE m_hKillThreadEvent;		// 通知子線程關閉的事件
	HANDLE m_hThreadKilledEvent;	// 子線程宣告關閉的事件
	HANDLE hComm;// 串口設備句柄


	bool PutSendMessage(SM_PARAM* pSmParam);	// 將短消息放入發送隊列
	BOOL GetSendMessage(SM_PARAM* pSmParam);	// 從發送隊列中取一條短消息
	void PutRecvMessage(SM_PARAM* pSmParam, int nCount);	// 將短消息放入接收隊列
	BOOL GetRecvMessage(SM_PARAM* pSmParam);	// 從接收隊列中取一條短消息
	void SendTimeOut(SM_PARAM* pparam);         //發送超時處理

	static UINT SmThread(LPVOID lpParam);	// 短消息收發處理子線程

 int gsmBytes2String(const unsigned char* pSrc, char* pDst, int nSrcLength);
 int gsmString2Bytes(const char* pSrc, unsigned char* pDst, int nSrcLength);
 int gsmEncode7bit(const char* pSrc, unsigned char* pDst, int nSrcLength);
 int gsmDecode7bit(const unsigned char* pSrc, char* pDst, int nSrcLength);
 int gsmEncode8bit(const char* pSrc, unsigned char* pDst, int nSrcLength);
 int gsmDecode8bit(const unsigned char* pSrc, char* pDst, int nSrcLength);
 int gsmEncodeUcs2(const char* pSrc, unsigned char* pDst, int nSrcLength);
 int gsmDecodeUcs2(const unsigned char* pSrc, char* pDst, int nSrcLength);
 int gsmInvertNumbers(const char* pSrc, char* pDst, int nSrcLength);
 int gsmSerializeNumbers(const char* pSrc, char* pDst, int nSrcLength);
 int gsmEncodePdu(const SM_PARAM* pSrc, char* pDst);
 int gsmDecodePdu(const char* pSrc, SM_PARAM* pDst);

 BOOL gsmInit();

 int gsmSendMessage(SM_PARAM* pSrc);
 int gsmReadMessageList();
 int gsmDeleteMessage(int index);

 int gsmGetResponse(SM_BUFF* pBuff);

 int gsmParseMessageList(SM_PARAM* pMsg, SM_BUFF* pBuff);


 BOOL OpenComm(const char* pPort, int nBaudRate=57600, int nParity=NOPARITY, int nByteSize=8, int nStopBits=ONESTOPBIT);
 BOOL CloseComm();
 int ReadComm(void* pData, int nLength);
 int WriteComm(void* pData, int nLength);

};

#endif // !defined(AFX_SMSTRAFFIC_H__3A4D81DE_C363_42D6_8A47_3BA017BFBF56__INCLUDED_)