omocdr.cpp

Mysql的处理

#include "oradb.h"


/********************************************************
*      filename							:OMOCDR.pc
*			 function descrpition	:insert data into database OMOCDRxxxxxxxxxx 
*			 input								:struct S_OMOCDR *	
*			 output								:SQL_OK ( operation sucess) SQL_RET_ERRO (operation failed)
*			 date									:2006-05-22
**********************************************************/

void C_MYSQL::DbOMOCDRTest()
{
	S_OMOCDR pIn5;
	S_RESULT pOut5;
	memset(&pIn5,0,sizeof(pIn5));

	pIn5.RecordType=2;
	memcpy(pIn5.ServedIMEI,"1111111111111111",5);
	memcpy(pIn5.ServedIMSI,"111111111111111111",5);
	snprintf(pIn5.ServedMSISDN,LEN_ServedMSISDN+1,"2");
	snprintf(pIn5.MSNetworkCapability,LEN_MSNetworkCapability+1,"2");
	memcpy(pIn5.ServiceCenter,"11111111111",5);
	memcpy(pIn5.RecordingEntity,"111111111111",5);
	memcpy(pIn5.LocationAreaCode,"11111111111",5);
	memcpy(pIn5.RoutingAreaCode,"111111111111",5);
	memcpy(pIn5.CellIdentity,"1111111111",5);
	memcpy(pIn5.MessageReference,"1111111111111",5);
	snprintf(pIn5.EventStampTime,LEN_DATETIME + 1,"2");
	pIn5.SMSResult=2;
	snprintf(pIn5.RecordExtensions,LEN_RecordExtensions+1,"2");
	snprintf(pIn5.NodeID,LEN_NodeID+1,"2");
	memcpy(pIn5.LocalRecordSequeceNumnber,"111111111111",5);
	snprintf(pIn5.ChargingCharacteristics,LEN_ChargingCharacteristics+1,"2");
	pIn5.SystemType=2;
	memcpy(pIn5.DestinationNumber,"11111111111",5);
	snprintf(pIn5.SCFAddress,LEN_SCFAddress+1,"2");
	snprintf(pIn5.ServiceKey,LEN_ServiceKey+1,"2");
	pIn5.DefaultTransacHandling=2;
	memcpy(pIn5.CAMELAPNNI,"11111111111",5);
	memcpy(pIn5.CAMELAPNOI,"11111111111",5);
	memcpy(pIn5.NumberOfDPEncounter,"11111111111",5);
	memcpy(pIn5.LevelOfCamelService,"1111111111",5);
	memcpy(pIn5.FreeFormatData,"11111111111",5);
	pIn5.FFDAppendIndicator=2;
	pIn5.DefaultSMSHandling=2;
	memcpy(pIn5.CAMELCallingPartyNumber,"11111111111111111",5);
	memcpy(pIn5.CAMELAccessDestinationSubNumber,"1111111111111",5);
	memcpy(pIn5.CAMELSMSAdress,"1111111111111111",5);
	memcpy(pIn5.SmsReferenceNumber,"1111111111111111",5);
	snprintf(pIn5.GsnIpAddr,LEN_IpAddr+1,"2");
	pIn5.FlagRead=2;
	snprintf(pIn5.SeqId,LEN_SEQ + 1,"2");
	snprintf(pIn5.GtpName,LEN_TABLENAME + 1,"2");
	snprintf(pIn5.GtpId,LEN_SEQ + 1,"2");
	pIn5.FlagRepeat=2;
	pIn5.FlagR499=2;
	snprintf(pIn5.GsnId,LEN_GSNID+1,"2");
	snprintf(pIn5.TableName,LEN_TABLENAME + 1,"OMOCDR");
	pIn5.ChargingCharacterSelectionMode=2;

	DbOMOCDRInsert(&pIn5, &pOut5);
}

int C_MYSQL::DbOMOCDRInsert(struct S_OMOCDR* pIn, struct S_RESULT* pOut)
{
/*        get info           */
	/* PK & FK */
	short RecordType=pIn->RecordType;
	char *GtpName=(char *)pIn->GtpName;
	char *GtpId=(char *)pIn->GtpId;
	
	int FlagRead = pIn->FlagRead;
	int FlagRepeat=pIn->FlagRepeat;
	int FlagR499=pIn->FlagR499;

	char *ServedIMSI=(char *)pIn->ServedIMSI;
	char *ServedIMEI=(char *)pIn->ServedIMEI;
	char *ServedMSISDN=(char *)pIn->ServedMSISDN;
	char *MSNetworkCapability=(char *)pIn->MSNetworkCapability;
	char *RoutingAreaCode=(char *)pIn->RoutingAreaCode;
	char *LocationAreaCode=(char *)pIn->LocationAreaCode;
	char *CellIdentity=(char *)pIn->CellIdentity;
/*	int ChargingID=pIn->ChargingID;*/

	char *ServiceCenter=(char *)pIn->ServiceCenter;
	char *RecordingEntity	= (char*)pIn->RecordingEntity;

	char *EventStampTime=(char *)pIn->EventStampTime;
	/*char*/int SystemType=pIn->SystemType;
	char* MessageReference = pIn->MessageReference;
	/*char*/int SMSResult=pIn->SystemType;
	char *NodeID=(char *)pIn->NodeID;
	char *ChargingCharacteristics=(char *)pIn->ChargingCharacteristics;
	char *LocalRecordSequeceNumnber=(char *)pIn->LocalRecordSequeceNumnber;
	char *DestinationNumber=(char *)pIn->DestinationNumber;

	/* 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 EXT10mo
	int ChargingCharacterSelectionMode = pIn->ChargingCharacterSelectionMode;
#endif
	/* peer ip */
	char *GsnIpAddr = pIn->GsnIpAddr;


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


snprintf(szSQL,SQLMAX,"INSERT INTO %s ("
"GTPID,GTPLTABLE,FLAGR499,"  
"FLAGREPEAT,"                  
"SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,MSNNETWORKCAPABILITY,"        
"SERVICECENTER,ROUTINGAREACODE,LOCATIONAREACODE,EVENTSTAMPTIME,"  
/*13*/            
"SMSRESULT,NODEID,LOCALRECORDSEQUECENUMBER,CHARGINGCHARACTERISTICS,"
"SYSTEMTYPE,DESTINATIONNUNMBER,SCFADDRESS,SERVICEKEY,"                  
"DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER, "        
"LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"          
"CAMELCALLINGPARTYNUMBER,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"          
"DATECREATED,GSNID,FLAGREAD,RECORDINGENTITY,MESSAGEREFRENCE"
#ifdef EXT10mo
",RECORDEXTENSIONS"
",CHARGINGCHARACTERSELECTIONMODE"
",CELLIDENTITY"
#endif
",GSNIPADDR"
") VALUES(" 
"%s,'%s',%d," 
"%d,"   
"'%s','%s','%s','%s',"  
"'%s','%s','%s','%s', " 
"%d ,'%s',%s,'%s', "   
"%d,'%s','%s',%s,"    
 "%d,'%s','%s',%s,"  
 "'%s','%s',%d,%d,"  
 "'%s','%s','%s','%s'," 
 "NOW(),%s,%d,'%s','%s'"
#ifdef EXT10mo
",'%s'"
",%d"
",'%s'"
#endif
",'%s'"
")",
 TableName,

  GtpId[0]==0?"NULL":GtpId,GtpName,FlagR499,
  FlagRepeat,
  ServedIMSI,ServedIMEI,ServedMSISDN,MSNetworkCapability,
  ServiceCenter,RoutingAreaCode,LocationAreaCode,EventStampTime,
  SMSResult,NodeID,LocalRecordSequeceNumnber[0]==0?"NULL":LocalRecordSequeceNumnber,ChargingCharacteristics,
  SystemType,DestinationNumber,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,RecordingEntity,MessageReference
#ifdef EXT10mo
,RecordExtensions
,ChargingCharacterSelectionMode
,CellIdentity
#endif
,GsnIpAddr
 );								

#ifdef _DEBUG
	logOra(sErrLog, szSQL);
#endif

	Lock();
	int 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							:OMOCDR.pc
*			 function descrpition	:get records from database OMCDRxxxxxxxxxx 
*			 input								:Tablename,Condition;	
*			 output								:S_OMOCDR 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::DbOMOCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMOCDR** pOutCDR, int *nItems, struct S_RESULT* pOut)
{

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