omcdr.cpp

Mysql的处理

#include "oradb.h"


/********************************************************
*      filename							:OMCDR.pc
*			 function descrpition	:insert data into database OMCDRxxxxxxxxxx 
*			 input								:struct S_OMCDR *	
*			 output								:SQL_OK ( operation sucess) SQL_RET_ERRO (operation failed)
*			 date									:2006-05-22
**********************************************************/
void C_MYSQL::DbOMCDRTest()
{
	S_OMCDR pIn4;
	S_RESULT pOut4;
	memset(&pIn4,0,sizeof(pIn4));

	pIn4.RecordType=2;
	memcpy(pIn4.ServedIMSI,"111111111111111",5);
	memcpy(pIn4.ServedIMEI,"111111111111111",5);
	snprintf(pIn4.SGSNIPAddress,LEN_IpAddr+1,"2");
	snprintf(pIn4.MSNetworkCapability,LEN_MSNetworkCapability+1,"2");
	memcpy(pIn4.RoutingAreaCode,"1111111111111",5);
	memcpy(pIn4.LocationAreaCode,"11111111111",5);
	memcpy(pIn4.CellIdentity,"11111111111111",5);
	snprintf(pIn4.RecordOpenTime,LEN_DATETIME + 1,"2");
	memcpy(pIn4.CallDuration,"11111111111111",5);
	pIn4.SGSNChange=2;
	memcpy(pIn4.CauseForRecClosing,"111111",2);
	snprintf(pIn4.Diagnostics,LEN_Diagnostics+1,"2");
	memcpy(pIn4.RecordSequenceNumber,"1111111111",5);
	memcpy(pIn4.NodeId,"1111111111",5);
	snprintf(pIn4.RecordExtensions,LEN_RecordExtensions+1,"2");
	memcpy(pIn4.LocalRecordSequeceNumnber,"11111111111",5);
	snprintf(pIn4.ServedMSISDN,LEN_ServedMSISDN+1,"2");
	snprintf(pIn4.ChargingCharacteristics,LEN_ChargingCharacteristics+1,"2");
	snprintf(pIn4.SCFAddress,LEN_SCFAddress+1,"2");
	snprintf(pIn4.ServiceKey,LEN_ServiceKey+1,"2");
	pIn4.DefaultTransacHandling=2;
	memcpy(pIn4.CAMELAPNNI,"1111111111111",5);
	memcpy(pIn4.CAMELAPNOI,"111111111111111",5);
	memcpy(pIn4.NumberOfDPEncounter,"11111111111",5);
	memcpy(pIn4.LevelOfCamelService,"111111111",3);
	memcpy(pIn4.FreeFormatData,"111111111111",5);
	pIn4.FFDAppendIndicator=2;
	pIn4.DefaultSMSHandling=2;
	memcpy(pIn4.CAMELCallingPartyNumber,"111111111111",5);
	memcpy(pIn4.CAMELAccessDestinationSubNumber,"1111111111111",5);
	memcpy(pIn4.CAMELSMSAdress,"11111111111111111",5);
	memcpy(pIn4.SmsReferenceNumber,"11111111111",5);
	pIn4.SystemType=2;
	pIn4.FlagRead=2;
	snprintf(pIn4.SeqId,LEN_SEQ + 1,"2");
	snprintf(pIn4.GtpName,LEN_TABLENAME + 1,"2");
	snprintf(pIn4.GtpId,LEN_SEQ + 1,"2");
	pIn4.FlagRepeat=2;
	pIn4.FlagR499=2;
	snprintf(pIn4.GsnId,LEN_GSNID+1,"2");
	snprintf(pIn4.TableName,LEN_TABLENAME + 1,"OMCDR");
	pIn4.ChargingCharacterSelectionMode=2;

	DbOMCDRInsert(&pIn4, &pOut4);
}

int C_MYSQL::DbOMCDRInsert(struct S_OMCDR* pIn, struct S_RESULT* pOut)
{
	short RecordType;
	char *GtpName=(char *)pIn->GtpName;
	char *GtpId=(char *)pIn->GtpId;
	
	int FlagRead = pIn->FlagRead;
	int FlagRepeat=pIn->FlagRepeat;
	int FlagR499=pIn->FlagR499;

	int SystemType=pIn->SystemType;
	char *ServedIMSI=(char *)pIn->ServedIMSI;
	char *ServedIMEI=(char *)pIn->ServedIMEI;
	char *ServedMSISDN=(char *)pIn->ServedMSISDN;
	char *SGSNIPAddress=(char *)pIn->SGSNIPAddress;
	char *MSNetworkCapability=(char *)pIn->MSNetworkCapability;
	char *RoutingAreaCode=(char *)pIn->RoutingAreaCode;
	char *LocationAreaCode=(char *)pIn->LocationAreaCode;
	char *CellIdentity=(char *)pIn->CellIdentity;
	char *NodeId=(char *)pIn->NodeId;/* add by xxh 2006.5.15*/
	char *RecordOpenTime=(char *)pIn->RecordOpenTime;
	char *CallDuration=(char *)pIn->CallDuration;
	int SGSNChange=pIn->SGSNChange;
	char *CauseForRecClosing=(char *)pIn->CauseForRecClosing;
	char *Diagnostics = pIn->Diagnostics;
	char *RecordSequenceNumber=(char *)pIn->RecordSequenceNumber;
	char *LocalRecordSequeceNumnber=(char *)pIn->LocalRecordSequeceNumnber;
	/* CAMEL Information*/
	char *SCFAddress=(char *)pIn->SCFAddress;
	char *ServiceKey=(char *)pIn->ServiceKey;
	/*char */
	int DefaultTransacHandling=pIn->DefaultTransacHandling;
	char *CAMELAPNNI=(char *)pIn->CAMELAPNNI;
	char *CAMELAPNOI=(char *)pIn->CAMELAPNOI;
	char *NumberOfDPEncounter=(char *)pIn->NumberOfDPEncounter;
	char *LevelOfCamelService=(char *)pIn->LevelOfCamelService;
	char *FreeFormatData=(char *)pIn->FreeFormatData;
	/*char */int FFDAppendIndicator=pIn->FFDAppendIndicator;
	/*char*/int DefaultSMSHandling=pIn->DefaultSMSHandling;
	char *CAMELCallingPartyNumber=(char *)pIn->CAMELCallingPartyNumber;
	char *CAMELAccessDestination=(char *)pIn->CAMELAccessDestinationSubNumber;
	char *CAMELSMSAdress=(char *)pIn->CAMELSMSAdress;
	char *SmsReferenceNumber=(char *)pIn->SmsReferenceNumber;

	/*char *DateCreated[LEN_DATETIME + 1]=(char *)pIn->;*/
	char *GsnId=(char *)pIn->GsnId;

	char *TableName=(char *)pIn->TableName;

	char *RecordExtensions = pIn->RecordExtensions;
#ifdef EXT10om
	int ChargingCharacterSelectionMode = pIn->ChargingCharacterSelectionMode;
#endif
	char *ChargingCharacteristics=(char *)pIn->ChargingCharacteristics;

	char szMsg[512];
	char szSQL[SQLMAX];
	char SeqId[LEN_SEQ + 1];

snprintf(szSQL,SQLMAX,"INSERT INTO %s("
   "GTPID,GTPLTABLE,FLAGR499,"     
   "FLAGREPEAT,"             
   "SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,SGSNIPADDRESS,"             
   "MSNNETWORKCAPABILITY,ROUTINGAREACODE,LOCATIONAREACODE,"            
   "CAUSEFORRECCLOSING,DIAGNOSITICS,RECORDSEQUENCENUMBER,NODEID,"                    
   "LOCALRECORDSEQUECENUMBER,SYSTEMTYPE,SCFADDRESS,SERVICEKEY,"                
   "DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER,"       
   "LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"        
   "CAMELCALLINGPARTYNUMBER,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"        
   
   "DATECREATED,GSNID,FLAGREAD,CALLDURATION "
#ifdef EXT10om
",RECORDEXTENSIONS"
",CHARGINGCHARACTERSELECTIONMODE"
",CELLIDENTITY"
",EVENTSTAMPTIME"
",SGSNCHANGE"
",CHARGINGCHARACTERISTICS"
#endif
   ") VALUES("
   " %s,'%s',%d,"  
   "%d,"
   " '%s','%s','%s','%s'," 
   "  '%s','%s','%s'," 
   "  %s,%s,%s,'%s'," 
   "  %s,%d,'%s',%s,"   
   "  %d,'%s','%s',%s,"
   "  '%s','%s',%d,%d,"   
   "  '%s','%s','%s','%s'," 
   " NOW(),%s,%d,%d"
#ifdef EXT10om
",'%s'"
",%d"
",'%s'"
",'%s'"
",%d"
",'%s'"
#endif
   ")" ,
   TableName,

   GtpId[0]==0?"NULL":GtpId,GtpName,FlagR499,
   FlagRepeat,
   ServedIMSI,ServedIMEI,ServedMSISDN,SGSNIPAddress,             	         
   MSNetworkCapability,RoutingAreaCode,LocationAreaCode,
   
   CauseForRecClosing[0]==0?"NULL":CauseForRecClosing,
   Diagnostics[0]==0?"NULL":Diagnostics,
   RecordSequenceNumber[0]==0?"NULL":RecordSequenceNumber,
   NodeId,  

   LocalRecordSequeceNumnber[0]==0?"NULL":LocalRecordSequeceNumnber,
   SystemType,SCFAddress,ServiceKey[0]==0?"NULL":ServiceKey,            	                   
   DefaultTransacHandling,CAMELAPNNI,CAMELAPNOI,NumberOfDPEncounter[0]==0?"NULL":NumberOfDPEncounter,          	           
   LevelOfCamelService,FreeFormatData,FFDAppendIndicator,DefaultSMSHandling,         	           
   CAMELCallingPartyNumber,CAMELAccessDestination,CAMELSMSAdress,SmsReferenceNumber,          	     
   GsnId[0]==0?"NULL":GsnId,FlagRead,CallDuration
   #ifdef EXT10om
   ,RecordExtensions
   ,ChargingCharacterSelectionMode
   ,CellIdentity
   ,RecordOpenTime
   ,SGSNChange
   ,ChargingCharacteristics
   #endif
   );     									

#ifdef _DEBUG
	logOra(sErrLog, szSQL);

#endif	

	Lock();
	int res=0;
	res =mysql_real_query(myConnect, szSQL, strlen(szSQL));
	if(res != 0)
	{
		Unlock();
		logOra(sErrLog, "%d %s\n", mysql_errno(myConnect), mysql_error(myConnect));
		return -1;
	}
	if(GetSeq(pIn->SeqId) != 0)
	{
		Unlock();
		logOra(sErrLog, "%d %s\n", mysql_errno(myConnect), mysql_error(myConnect));
		return -2;
	}
	Unlock();
	return 0;

}


/***********************************************************************
*      filename							:OMCDR.pc
*			 function descrpition	:get records from database OMCDRxxxxxxxxxx 
*			 input								:Tablename,Condition;	
*			 output								:S_OMCDR is record set to store what we want,
														nItems is counter of those record set,S_RESULT
													  is flag to tell us about operation is sucessful or not;
*			 date									:2006-05-22
*************************************************************************************/


int C_MYSQL::DbOMCDRSelect(char* pInSzTableName, char* pWhere, 
	struct S_OMCDR_LOAD** pOutCDR, int *nItems, struct S_RESULT* pOut)
{

	short ind[55];
	short id[2];
	short RecordType;
	char SeqId[LEN_SEQ + 1];