test2.cpp

Mysql的处理

#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);