#include "CDR.h"#include "CDRWriteGTP.h"#include "CDRWriteASNDecode.h"#include "CDRReadForBill.h"#include "CDRReadForCombined.h"#include "CDRWriteCombined.h"#include "Date.h"#include<iostream>using namespace std;bool ReadGtp(C_CDRWriteGTP& gtp){	CDate date("0606120000","0606152330");	date.Calculate();	int count = date.GetCount();	printf(" == ALL ITEMS = %d \n", count);	int p=0;	for(int i = 0; i < count; i++)	{		char szTableName[31];		char szDate[21];		snprintf(szDate, 21, "%s", date.GetAt(i).c_str());		snprintf(szTableName, LEN_TABLENAME+1, "OGTPL%s", szDate);		char szSeqId[21]={"0",};		snprintf(szSeqId, 21, "0");		int id(0);		char szContent[4000];		int nLength;		int RecordType;		char szaa[16];		int nFalgCancel;		for(;;)		{			printf("ID=%d SeqId = '%s'\n", i, szSeqId);			memset(szContent, 0, 4000);			nLength = -1;			if(!gtp.ReadRecord(szTableName, szSeqId, szContent, 				nLength, RecordType, szSeqId,				szaa,nFalgCancel				))				break;			if(nLength < 10)				break;			char szFileName[1024];			snprintf(szFileName, 1024, "/space/cgateway/asbcg/src/ogtp/%s.%d", szDate, id++);			FILE* fp = fopen(szFileName, "wb");			fwrite(szContent, 1, nLength, fp);			fclose(fp);			fp = fopen("data.log", "a");			fprintf(fp,"i=%d id=%d !%s!\n", i, id, szDate);			fclose(fp);		}	}	return true;}int main(char** argv, int argn){	C_CDRWriteGTP gtp;	if(!gtp.Connect("root", "", "cgdb"))	{		cout << "Connect failed" << endl;		return -1;	}	S_GTPL pIn;	S_RESULT pOut;		memset(&pIn,0,sizeof(pIn));		pIn.CgType=10;	memcpy(pIn.Content,"11111111111111111111111111111111111111", 12);	snprintf(pIn.TableName, LEN_TABLENAME+1, "OGTPL");	pIn.RecordType=100;	pIn.ContentLength=20;	pIn.FlagCancel=1;	pIn.PeerIp=66666;	pIn.PeerSeqId=88;    memcpy(pIn.GsnId,"11111111111111111111111111111111111111", 12);    memcpy(pIn.GsnId,"2006.8.1", 12);    	DbGTPInsert(&pIn, &pOut);    S_ASNERROR pIn1;    S_RESULT pOut1;    pIn1.RecordType=22;    memcpy(pIn1.GtpId,"11111111111111111111111111111111111111", 12);    snprintf(pIn1.GtpName, 10, "ASNERROR");    memcpy(pIn1.Content,"11111111111111111111111111111111111111", 12);	pIn1.Cause=22;    memcpy(pIn1.GsnId,"11111111111111111111111111111111111111", 12);    snprintf(pIn1.TableName, LEN_TABLENAME+1, "ASNERROR"); 	DbASNERRORInsert(&pIn1, &pOut1);	S_OGCDR pIn2;	S_RESULT pOut2;	pIn2.RecordType=2;	pIn2.NetworkInitiatedPDPContext=2;	memcpy(pIn2.ServedIMSI,"11111111111111111111111111111111",12);    memcpy(pIn2.GGSNAddress,"11111111111111111111111111111111",12);	memcpy(pIn2.ChargingID,"11111111111111111111111111111111",10);    snprintf(pIn2.SGSNIPAddress, LEN_IpAddr+1, "255.255");	memcpy(pIn2.AccessPointNameNI,"11111111111111111111111111111111",12);	memcpy(pIn2.PDPTypeNumber,"11111111111111111111111111111111",12);	memcpy(pIn2.ServedPDPAddress,"11111111111111111111111111111111",12);	pIn2.DynamicAddressFlag='A';    snprintf(pIn2.RecordOpenTime, LEN_DATETIME+1, "200682");    memcpy(pIn2.CallDuration,"11111111111111111111111111111111",12);	memcpy(pIn2.CauseForRecClosing,"111",2);    snprintf(pIn2.Diagnostics,LEN_Diagnostics+1, "123");	memcpy(pIn2.RecordSequenceNumber,"11111111111111111111111111111111",10);    snprintf(pIn2.NodeID,LEN_NodeID+1, "AAA");    memcpy(pIn2.LocalRecordSequeceNumnber,"11111111111111111111111111111111",10);    pIn2.APNSelectionMode=2;    snprintf(pIn2.ServedMSISDN,LEN_ServedMSISDN+1, "123");	snprintf(pIn2.ChargingCharacteristics,LEN_ChargingCharacteristics+1, "123");	snprintf(pIn2.GtpName,LEN_TABLENAME + 1, "123");    snprintf(pIn2.GtpId,LEN_SEQ + 1, "123");    snprintf(pIn2.MergeName,LEN_TABLENAME + 1, "123");    snprintf(pIn2.MergeId,LEN_SEQ + 1, "123");	pIn2.FlagRepeat=2;	pIn2.FlagR499=2;    snprintf(pIn2.GsnId,LEN_GSNID+1, "123");    snprintf(pIn2.TableName,LEN_TABLENAME + 1, "OGCDR");    pIn2.FlagRead=2;	snprintf(pIn2.Diagnostics,2,"12");	pIn2.ChargingCharacterSelectionMode=2;	snprintf(pIn2.SgsnPlmnIdentifier,LEN_SgsnPlmnIdentifier+1, "123");	pIn2.AnonyAccessIndicator=2;    memcpy(pIn2.RemotePdpAddr,"11111111111111111111111111111111",10);    	DbOGCDRInsert(&pIn2, &pOut2);//test OSCDR begin	S_OSCDR pIn3;	S_RESULT pOut3;    pIn3.RecordType=2;	pIn3.NetworkInitiatedPDPContext='A';    snprintf(pIn3.ServedIMSI,LEN_ServedIMSI+1,"2");	snprintf(pIn3.ServedIMEI,LEN_ServedIMEI+1,"2");	snprintf(pIn3.SGSNIPAddress,LEN_IpAddr+1,"2");	snprintf(pIn3.MSNetworkCapability,LEN_MSNetworkCapability+1,"2");	memcpy(pIn3.RoutingAreaCode,"1111111111111111111111",5);	memcpy(pIn3.LocationAreaCode,"11111111111111111111111111",5);	memcpy(pIn3.CellIdentity,"111111111111111111111111",5);	memcpy(pIn3.ChargingID,"11111111111111111111",5);	snprintf(pIn3.GGSNAddress,LEN_IpAddr+1,"2");	memcpy(pIn3.AccessPointNameNI,"111111111111111111111111",5);	memcpy(pIn3.PDPTypeNumber,"11111111111111",5);	snprintf(pIn3.ServedPDPAddress,LEN_IpAddr+1,"2");	snprintf(pIn3.RecordOpenTime,LEN_DATETIME + 1,"2");	memcpy(pIn3.CallDuration,"11111111111111111",5);	pIn3.SGSNChange='A';	memcpy(pIn3.CauseForRecClosing,"111111",2);	snprintf(pIn3.Diagnostics,LEN_Diagnostics+1,"2");	memcpy(pIn3.RecordSequenceNumber,"1111111111111111",5);	snprintf(pIn3.NodeID,LEN_NodeID+1,"2");	snprintf(pIn3.RecordExtensions,LEN_RecordExtensions+1,"2");	memcpy(pIn3.LocalRecordSequeceNumnber,"11111111111111111",5);	pIn3.APNSelectionMode=2;	memcpy(pIn3.AccessPointNameOI,"11111111111111111",5);	snprintf(pIn3.ServedMSISDN,LEN_ServedMSISDN+1,"2");	snprintf(pIn3.ChargingCharacteristics,LEN_ChargingCharacteristics+1,"2");	pIn3.SystemType=2;	snprintf(pIn3.SCFAddress,LEN_SCFAddress+1,"2");	snprintf(pIn3.ServiceKey,LEN_ServiceKey+1,"2");	pIn3.DefaultTransacHandling=2;	memcpy(pIn3.CAMELAPNNI,"1111111111111111111",5);	memcpy(pIn3.CAMELAPNOI,"111111111111111111111111",5);	memcpy(pIn3.NumberOfDPEncounter,"1111111111111111",5);	memcpy(pIn3.LevelOfCamelService,"111111111111111",5);	memcpy(pIn3.FreeFormatData,"111111111111111111",5);	pIn3.FFDAppendIndicator=2;	pIn3.DefaultSMSHandling=2;	memcpy(pIn3.CAMELCallingPartyNumber,"11111111111111111",5);	memcpy(pIn3.CAMELAccessDestinationSubNumber,"111111111111111",5);	memcpy(pIn3.CAMELSMSAdress,"11111111111111111",5);	memcpy(pIn3.SmsReferenceNumber,"111111111111111111",5);	memcpy(pIn3.UnsentDownlinkVolume,"11111111111111111111",5);	pIn3.DynamicAddressFlag=1;	memcpy(pIn3.APNOperatorIdentifier,"1111111111111111",5);	pIn3.AnonyAccessIndicator=2;	pIn3.FlagRead=2;	snprintf(pIn3.GtpName,LEN_TABLENAME + 1,"2");	snprintf(pIn3.GtpId,LEN_SEQ + 1,"2");	snprintf(pIn3.MergeName,LEN_TABLENAME + 1,"2");	snprintf(pIn3.MergeId,LEN_SEQ + 1,"2");	pIn3.FlagRepeat=2;	pIn3.FlagR499=2;	snprintf(pIn3.DateCreated,LEN_DATETIME + 1,"2");	snprintf(pIn3.GsnId,LEN_GSNID+1,"2");	snprintf(pIn3.TableName,LEN_TABLENAME + 1,"OSCDR");	pIn3.ChargingCharacterSelectionMode=2;	DbOSCDRInsert(&pIn3, &pOut3);//test OSCDR end//test OMCDR begin	S_OMCDR pIn4;	S_RESULT pOut4;	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);//test OMCDR end//test OMOCDR begin	S_OMOCDR pIn5;	S_RESULT pOut5;	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);