oradb.h

Mysql的处理

#ifndef _ORADB_H_
#define _ORADB_H_


#define sgsnPDPRecord 18
#define ggsnPDPRecord 19
#define sgsnMMRecord 20
#define sgsnSMORecord 21
#define sgsnSMTRecord 22

#define EXT10os
#define EXT10og
#define EXT10om
#define EXT10mo
#define EXT10mt
#define EXT10cs
#define EXT10cg
#define EXT10cg1
#define EXT10cg2

#define LEN_SEQ 20
#define LEN_NAME 20
#define LEN_CONTENT 4000
#define LEN_DATETIME 14
#define LEN_TABLENAME 30
#define LEN_ServedIMSI 16
#define LEN_ServedIMEI 16
#define LEN_SGSNAddr 45
#define LEN_IpAddr 45
#define LEN_NodeID 20
#define LEN_GSNID 10
#define LEN_ServedMSISDN 18
#define LEN_RecordExtensions 120/*64*/
#define LEN_SCFAddress 20
#define LEN_SORT 10

#define LEN_MSNetworkCapability 16
#define LEN_ChargingCharacteristics 4
#define LEN_Diagnostics 2
#define LEN_ServiceKey 10

#define LEN_SgsnPlmnIdentifier 3 /* 需要改成 6*/
	/*1 原始数据报*/
struct S_GTPL
{
	int RecordType;
	char SeqId[LEN_SEQ + 1];
	char Content[LEN_CONTENT + 1];
	int ContentLength;
	int FlagCancel;
	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];
	
	int PeerIp;
	int PeerSeqId;

	int CgType;

	char TableName[LEN_TABLENAME + 1];
};
#define SIZE_S_GTPL sizeof(struct S_GTPL)

	/*2 ASN1解码出错表*/
struct S_ASNERROR
{
	int RecordType;
	char GtpId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];

	char SeqId[LEN_SEQ + 1];
	char Content[LEN_CONTENT + 1];
	int Cause;
	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];
};
#define SIZE_S_ASNERROR sizeof(struct S_ASNERROR)

	/*3 Change of Location 表*/
struct S_LCLOC
{
	char LocationAreaCode[5];
	char RoutingAreaCode[9];
	char CellIdentity[5];
	char ChangeTime[LEN_DATETIME + 1];

	char TableName[LEN_TABLENAME + 1];
	char SeqId[LEN_SEQ + 1];

	char SortId[LEN_SORT+1];
};
#define SIZE_S_LCLOC sizeof(struct S_LCLOC)


	/*4 List of traffic data volumn 表*/
struct S_LLOTV
{
	char ChangeCondition;
	char DataVolumeGPRSUp[16+1];
	char DataVolumeGPRSDown[16+1];
	char ChangeTime[LEN_DATETIME + 1];
	char QoSNUMTS[24 + 1];
	char QoSNMeanThroughput[2+1];
	char QoSNPeakThrougput[2+1];
	char QoSNDelay;
	char QoSNPrecedence;
	char QoSNReliability;
	char QoSRUMTS[24 + 1];
	char QoSRMeanThroughput[2+1];
	char QoSRPeakThrougput[2+1];
	char QoSRDelay;
	char QoSRPrecedence;
	char QoSRReliability;

	char TableName[LEN_TABLENAME + 1];
	char SeqId[LEN_SEQ + 1];

	char SortId[LEN_SORT+1];
};
#define SIZE_S_LLOTV sizeof(struct S_LLOTV)

	/*5 其他的列表 */
struct S_LCOMM
{
	char SeqId[LEN_SEQ + 1];
	int SubId;
	char SGSNAddr[LEN_SGSNAddr + 1];
	char CauseForRecordClosing[3];
	char RSN[11];
	char LRSN[11];
	int SystemType;
	int SGSNChange;
	char NodeId[LEN_NodeID+1];
	int RNC;
	char RecordExtensions[LEN_RecordExtensions+1];

	char TableName[LEN_TABLENAME + 1];

	char SortId[LEN_SORT+1];
};

#define SIZE_S_LCOMM sizeof(struct S_LCOMM)

	/*6 原始 SCDR表 */
struct S_OSCDR
{
	short	RecordType;
	char NetworkInitiatedPDPContext;
	char ServedIMSI[LEN_ServedIMSI+1];
	char ServedIMEI[LEN_ServedIMEI+1];
	char SGSNIPAddress[LEN_IpAddr+1];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char RoutingAreaCode[9];
	char LocationAreaCode[17];
	char CellIdentity[25];
	char ChargingID[11];
	char GGSNAddress[LEN_IpAddr+1];
	char AccessPointNameNI[64];
	char PDPTypeNumber[9];
	char ServedPDPAddress[LEN_IpAddr+1];
	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[12+1];
	char SGSNChange;
	char CauseForRecClosing[3];
	char Diagnostics[LEN_Diagnostics+1];
	char RecordSequenceNumber[11]; 
	char NodeID[LEN_NodeID+1];
	char RecordExtensions[LEN_RecordExtensions+1];
	char LocalRecordSequeceNumnber[11];
	char APNSelectionMode;
	char AccessPointNameOI[38];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];
	char SystemType;
	
	/* CAMEL Information*/
	char SCFAddress[LEN_SCFAddress+1];
	char ServiceKey[LEN_ServiceKey+1];
	char DefaultTransacHandling;
	char CAMELAPNNI[64];
	char CAMELAPNOI[38];
	char NumberOfDPEncounter[11];
	char LevelOfCamelService[4];
	char FreeFormatData[161];
	char FFDAppendIndicator;
	char DefaultSMSHandling;
	char CAMELCallingPartyNumber[15];
	char CAMELAccessDestinationSubNumber[44];
	char CAMELSMSAdress[21];
	char SmsReferenceNumber[9];

	char UnsentDownlinkVolume[11];

	/** NOTE: begin **/
	char DynamicAddressFlag;/* both for R99 & R4 */
	char APNOperatorIdentifier[37+1];/* both for R99 & R4 */

	char AnonyAccessIndicator; /* only for R4 */
	/** NOTE: end **/

	char FlagRead;

	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	char MergeName[LEN_TABLENAME + 1];
	char MergeId[LEN_SEQ + 1];
	
	int FlagRepeat;
	int FlagR499;

	/* stamp */
	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];
	
#ifdef EXT10os
	char ChargingCharacterSelectionMode;
#endif
};
#define SIZE_S_OSCDR sizeof(struct S_OSCDR)

 
	/*7 原始 的 GCDR表*/
struct S_OGCDR
{
	short		RecordType;
	char NetworkInitiatedPDPContext;
	char ServedIMSI[17];
	char GGSNAddress[46];
	char ChargingID[11];
	char SGSNIPAddress[LEN_IpAddr+1];
	char AccessPointNameNI[64];
	char PDPTypeNumber[9];/*3];/**/
	char ServedPDPAddress[46];
	char DynamicAddressFlag;

	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[13];
	char CauseForRecClosing[3];
	char Diagnostics[LEN_Diagnostics+1];
	char RecordSequenceNumber[11];
	char NodeID[LEN_NodeID+1];

	char LocalRecordSequeceNumnber[11];
	char APNSelectionMode;
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];

	/** NOTE: begin **/
	char		SgsnPlmnIdentifier[LEN_SgsnPlmnIdentifier+1]; /* both for R4 & R99*/
	char		AnonyAccessIndicator; /* only for R4 */
	char		RemotePdpAddr[45+1]; /* only for R4 */

	/** NOTE: end **/
	
	char FlagRead;
	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	char MergeName[LEN_TABLENAME + 1];
	char MergeId[LEN_SEQ + 1];
	
	int FlagRepeat;
	int FlagR499;

	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];

#ifdef EXT10og
	char ChargingCharacterSelectionMode;
#endif
};
#define SIZE_S_OGCDR sizeof(struct S_OGCDR)

	/*8 原始的MCDR表*/
struct S_OMCDR
{
	short		RecordType;
	char ServedIMSI[17];
	char ServedIMEI[17];
	char SGSNIPAddress[LEN_IpAddr+1];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char RoutingAreaCode[9];
	char LocationAreaCode[17];
	char CellIdentity[25];
	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[13];
	char SGSNChange;
	char CauseForRecClosing[3];
	char Diagnostics[LEN_Diagnostics+1];
	char RecordSequenceNumber[11];
	char NodeId[21];
	char RecordExtensions[LEN_RecordExtensions+1];
	char LocalRecordSequeceNumnber[11];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];

	/* CAMEL Information*/
	char SCFAddress[LEN_SCFAddress+1];
	char ServiceKey[LEN_ServiceKey+1];
	char DefaultTransacHandling;
	char CAMELAPNNI[64];
	char CAMELAPNOI[38];
	char NumberOfDPEncounter[11];
	char LevelOfCamelService[4];
	char FreeFormatData[161];
	char FFDAppendIndicator;
	char DefaultSMSHandling;
	char CAMELCallingPartyNumber[15];
	char CAMELAccessDestinationSubNumber[44];
	char CAMELSMSAdress[21];
	char SmsReferenceNumber[9];
	
	char SystemType;

	char FlagRead;
	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	
	int FlagRepeat;
	int FlagR499;

	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];

#ifdef EXT10om
	char ChargingCharacterSelectionMode;
#endif
};
#define SIZE_S_OMCDR sizeof(struct S_OMCDR)


	/*9 原始的MOCDR*/
struct S_OMOCDR
{
	short RecordType;
	char ServedIMSI[17];
	char ServedIMEI[17];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char ServiceCenter[21];
	char RecordingEntity[21];
	char LocationAreaCode[17];
	char RoutingAreaCode[9];
	char CellIdentity[25];
	char MessageReference[256];
	char EventStampTime[LEN_DATETIME + 1];
	char SMSResult;
	char RecordExtensions[LEN_RecordExtensions+1];
	char NodeID[LEN_NodeID+1];
	char LocalRecordSequeceNumnber[11];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];
	char SystemType;
	char DestinationNumber[44];

	/* CAMEL Information*/
	char SCFAddress[LEN_SCFAddress+1];
	char ServiceKey[LEN_ServiceKey+1];
	char DefaultTransacHandling;
	char CAMELAPNNI[64];
	char CAMELAPNOI[38];
	char NumberOfDPEncounter[11];
	char LevelOfCamelService[4];
	char FreeFormatData[161];
	char FFDAppendIndicator;
	char DefaultSMSHandling;
	char CAMELCallingPartyNumber[15];
	char CAMELAccessDestinationSubNumber[44];
	char CAMELSMSAdress[21];
	char SmsReferenceNumber[9];

	/* peer ip */
	char GsnIpAddr[LEN_IpAddr+1];

	char FlagRead;
	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	
	int FlagRepeat;
	int FlagR499;

	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];

#ifdef EXT10mo
	char ChargingCharacterSelectionMode;
#endif
};
#define SIZE_S_OMOCDR sizeof(struct S_OMOCDR)

	/*10原始的MTCDR*/
struct S_OMTCDR
{
	short		RecordType;
	char ServedIMSI[17];
	char ServedIMEI[17];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char ServiceCenter[21];
	char RecordingEntity[21];
	char LocationAreaCode[17];
	char RoutingAreaCode[9];
	char CellIdentity[25];
	char EventStampTime[LEN_DATETIME + 1];
	char SMSResult;
	char RecordExtensions[LEN_RecordExtensions+1];
	char NodeID[LEN_NodeID+1];
	char LocalRecordSequeceNumnber[11];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];
	char SystemType;

	/* peer ip */
	char GsnIpAddr[LEN_IpAddr+1];

	char FlagRead;
	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	
	int FlagRepeat;
	int FlagR499;

	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	char TableName[LEN_TABLENAME + 1];

#ifdef EXT10mt
	char ChargingCharacterSelectionMode;
#endif
};
#define SIZE_S_OMTCDR sizeof(struct S_OMTCDR)

/*合并结果*/

	/*11 合并后的SCDR*/
struct S_CSCDR
{
	short	RecordType;
	char NetworkInitiatedPDPContext;/*int*/