cdrwritegtp.h

Mysql的处理

/***********************************************************************
 * Module:  CExceptionADO.h
 * Author:  asus
 * Modified: 2006年4月27日 10:35:46
 * 
 * comment:  Insert 接口不再使用,启用Insert2
 * datetime: 2006/7/3 11:52
 * by:       Mark


 * Purpose: Declaration of the class CExceptionADO
 * Comment: 原始GTP'包的接口类
 ***********************************************************************/
#ifndef __CCDRWriteGTP_H__
#define __CCDRWriteGTP_H__

#include <stdio.h>
#include "CDR.h"
#include "Clock.h"

class C_CDRWriteGTP : public C_CDR  
{
public:
	C_CDRWriteGTP();
	virtual ~C_CDRWriteGTP();

	//
	//功能描述:
	//把GTP数据报保存到数据库中
	//输入参数
	//[1]szContent 信息内容 
	//[2]nLength 信息长度
	//[3]szGsnId, CDR记录的总条数 !!!!!!!!!!!!
	//[4]flagCancel 是否取消
	//[5]inIPeerIp 对方（GGSN，SGSN）IP地址
	//[6]inIPeerSeqId 对方生成的序列号码
	//输出参数
	//[7]outSzTableName[31],
	//[8]outSzSeqId[21]
	//返回
	// true -成功 
	// false-失败
	bool Insert(const char* inSzContent, long inILength, const char* inSzGsnId, 
		long inBflagCancel, long inIPeerIp, long inIPeerSeqId,
		char outSzTableName[31] = NULL, char outSzSeqId[21] = NULL);



	//
	//功能描述:
	//把GTP数据报保存到数据库中
	//输入参数
	//[1]szContent			信息内容 
	//[2]nLength			信息长度
	//[3]inINumberOfCdrs	CDR记录的总条数				<原来默认是0，现在改成CDR记录的总条数>
	//[4]inBflagCancel		是否取消
	//[5]inIPeerIp			对方（GGSN，SGSN）IP地址
	//[6]inIPeerSeqId		对方生成的序列号码
	//[7]inCgType			CG类型:0-主CG;1-备CG		<新增加，支持主备CG的标识>
	//[8]inIRecordType		0-存在数据库中；1-存在文件中
	//                      
	//输出参数
	//[8]outSzTableName[31]	表的名字
	//[9]outSzSeqId[21]		对应表中的SeqId
	//返回
	// true -成功 
	// false-失败
	bool Insert2(const char* inSzContent, 
				long inILength, 
				long inINumberOfCdrs, 
				long inBflagCancel, 
				long inIPeerIp, 
				long inIPeerSeqId,
				short inICgType,
				short inIRecordType,
				char outSzTableName[31] = NULL, char outSzSeqId[21] = NULL);

	//
	//功能描述:
	//把GTP数据报保存到数据库中
	//输入参数
	//[1]inIIpAddress 对方（GGSN，SGSN）IP地址
	//[2]inIGGSNSeqId 对方生成的序列号码
	//[3]inBflagCancel 
	//		0 - 初始
	//		1 - RELEASE  
	//		2 - CANCEL    过滤掉
	//[4]RecordType
	//     0 - binary
	//     1 - filename
	//[5]outFileName 
	//[6]nLength     长度

	//输出参数
	//返回
	// true -成功 
	// false-失败

	// RecordType

	bool Update(long inIPeerIp, long inIPeerSeqId, long inBflagCancel,
		int &RecordType, char outFileName[4000], int &nLength,
		char outSzTableName[31], char outSzSeqId[21]);

	//
	//功能描述:
	//把GTP数据报保存到数据库中
	//输入参数
	//[1]inIIpAddress 对方（GGSN，SGSN）IP地址
	//[2]inIGGSNSeqId 对方生成的序列号码
	//输出参数
	//返回
	// true -成功 
	// false-失败
	bool GetCount(long inIPeerIp, long inIPeerSeqId, long& outICount);

	bool ReadRecord(char* pInSzTableName, char* pInSeqId, 
		char szOutContent[4000], int &nLength, 	int &RecordType, 
		char szOutSeqId[21], char szOutIpAdd[16], int &nFalgCancel);
	bool Update(const char* pInSzSQL);

	void Test();

	bool TimeLimit(
		//in
		const char *p_timeStart,
	    int   p_timeAcceptedFree,
		//out
	    int  &p_bIsFree,
	    char p_timeErrorStart[15],
	    char p_timeErrorEnd[15],
	    int  &p_nResult);

private:
	S_GTPL m_In;
	C_Clock m_nClock;
	char m_szDest[4001];
	char m_szDest2[4001];
};

#endif