?? test2.cpp
字號:
#include "CDR.h"#include "CDRWriteGTP.h"#include "CDRWriteASNDecode.h"#include "CDRReadForBill.h"#include "CDRReadForCombined.h"#include "CDRWriteCombined.h"#include "Date.h"#include "Dump.h"#include<stdio.h>#include<vector>#include <unistd.h>#include<iostream>using namespace std;int DbOGCDRTest();int DbASNERRORTest();int DbCGCDRTest();int DbCSCDRTest();int DbLCLOCTest();int DbLCOMMTest();int DbLLOTVTest();int DbGTPTest();int DbOMCDRTest();int DbOMOCDRTest();int DbOMTCDRTest();int DbOSCDRTest();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; } gtp.Test(); C_Dump dump;// C_CDRReadForBill bill; C_CDRWriteCombined WCombined; if(!bill.Connect("root", "", "cgdb")) { cout << "Connect failed" << endl; return -1; } if(!WCombined.Connect("root", "", "cgdb")) { cout << "Connect failed" << endl; return -1; }*//* S_CGCDR pIn10; memset(&pIn10,0,sizeof(pIn10));// bill.DbCSCDRTest(); bill.DbCGCDRTest(pIn10); char pOutSzTableDate[10]={0}; char pOutSzSeqId[21]={0}; int nCdrs=1; S_LCLOC pChanageLoc; int nChangeLoc=0; S_LLOTV pLOTV; int nLOTV=0; S_LCOMM pCommon; int nCommon=0; int nFlagR4V99=0; // 0- R99; 1 - R4 int i=0; for(i=0;i<5;i++) { WCombined.InsertGCDR(&pIn10,nCdrs, &pChanageLoc,nChangeLoc, &pLOTV, nLOTV, &pCommon, nCommon, nFlagR4V99, // 0- R99; 1 - R4 pOutSzTableDate, pOutSzSeqId); } WCombined.Disconnect(); char *szTableDate=bill.GetSysdate2(); char *szTableDate2=""; char *szSQLWhere="1=1"; S_CGCDR_LOAD * ppCDR=NULL; int nOutNumber=0; char *szSeqId=""; printf("time=%s\n", szTableDate); int m=bill.SelectGCDR( szTableDate, szTableDate2, szSQLWhere, szSeqId, &ppCDR, &nOutNumber); printf("\n%d\n",m); if (ppCDR != NULL) { // S_CGCDR_LOAD * pp=ppCDR; for(i=0;i<nOutNumber;i++) dump.DumpCGCDR("gcdr.log",&ppCDR[i],0); } else { printf("\n DB NULL \n"); } bill.Disconnect();*//* S_CSCDR pIn11; memset(&pIn11,0,sizeof(pIn11));// bill.DbCSCDRTest(); bill.DbCSCDRTest(pIn11); char pOutSzTableDate[10]={0}; char pOutSzSeqId[21]={0}; int nCdrs=1; S_LCLOC pChanageLoc; int nChangeLoc=0; S_LLOTV pLOTV; int nLOTV=0; S_LCOMM pCommon; int nCommon=0; int nFlagR4V99=0; // 0- R99; 1 - R4 int i=0; for(i=0;i<5;i++) { WCombined.InsertSCDR(&pIn11,nCdrs, &pChanageLoc,nChangeLoc, &pLOTV, nLOTV, &pCommon, nCommon, nFlagR4V99, // 0- R99; 1 - R4 pOutSzTableDate, pOutSzSeqId); } WCombined.Disconnect(); char *szTableDate=bill.GetSysdate2(); char *szTableDate2=""; char *szSQLWhere="1=1"; S_CSCDR_LOAD * ppCDR1=NULL; int nOutNumber=0; char *szSeqId=""; printf("time=%s\n", szTableDate); int m=bill.SelectSCDR( szTableDate, szTableDate2, szSQLWhere, szSeqId, &ppCDR1, &nOutNumber); printf("\n%d\n",m); if (ppCDR1 != NULL) { // S_CGCDR_LOAD * pp=ppCDR; for(i=0;i<nOutNumber;i++) dump.DumpCSCDR("scdr.log",&ppCDR1[i],0); } else { printf("\n DB NULL \n"); } bill.Disconnect();*///OMCDR Begin/* char* szTableDate=bill.GetSysdate(); char *szTableDate2=""; int nOutChangeLoc=0; S_LLOTV *ppLOTV=NULL; int nLOTV=0; S_LCOMM *ppCommon=NULL; int nCommon=0; int i; S_LCLOC *ppChanageLoc=NULL;*//* S_OMCDR *ppCDR=NULL; bill.SelectMCDR(szTableDate, szTableDate2, szSQLWhere, &ppCDR, &nOutNumber, &ppChanageLoc,&nOutChangeLoc, &ppLOTV, &nLOTV, &ppCommon, &nCommon); S_OMCDR *pp=ppCDR; if (ppCDR != NULL) { for(i=0;i<nOutNumber+1;i++,pp++) dump.DumpOMCDR("OutOMCDR",pp,0); } else { printf("\n DB NULL \n"); }*///OMCDR End//OMOCDR Begin/*nOutNumber=0;S_OMOCDR * ppCDR1=NULL;S_OMOCDR * pp1=NULL;bill.SelectMOCDR( szTableDate, szTableDate2, szSQLWhere, &ppCDR1, &nOutNumber, &ppChanageLoc,&nOutChangeLoc, &ppLOTV, &nLOTV, &ppCommon, &nCommon);if (ppCDR1 != NULL) { pp1=ppCDR1; for(i=0;i<nOutNumber+1;i++,pp1++) dump.DumpOMOCDR("OutOMOCDR",pp1,0); } else { printf("\n DB NULL \n"); }*///OMOCDR End//OMTCDR Begin/*nOutNumber=0;S_OMTCDR * ppCDR2=NULL;S_OMTCDR * pp2=NULL;bill.SelectMTCDR( szTableDate, szTableDate2, szSQLWhere, &ppCDR2, &nOutNumber, &ppChanageLoc,&nOutChangeLoc, &ppLOTV, &nLOTV, &ppCommon, &nCommon);if (ppCDR2 != NULL) { pp2=ppCDR2; for(i=0;i<nOutNumber+1;i++,pp2++) dump.DumpOMTCDR("OutOMTCDR",pp2,0); } else { printf("\n DB NULL \n"); }*///OMTCDR End//C_CDRReadForCombined Combined;//OSCDR Begin/*nOutNumber=0;S_OSCDR * ppCDR3=NULL;S_OSCDR * pp3=NULL;Combined.SelectSCDR( szTableDate, szTableDate2, szSQLWhere, &ppCDR3, &nOutNumber, &ppChanageLoc,&nOutChangeLoc, &ppLOTV, &nLOTV, &ppCommon, &nCommon); if (ppCDR3 != NULL) { pp3=ppCDR3; for(i=0;i<nOutNumber+1;i++,pp3++) dump.DumpOSCDR("OutOSCDR",pp3,0); } else { printf("\n DB NULL \n"); }*///OSCDR End//OGCDR Begin/*nOutNumber=0;S_OGCDR * ppCDR4=NULL;S_OGCDR * pp4=NULL;Combined.SelectGCDR( szTableDate, szTableDate2, szSQLWhere, &ppCDR4, &nOutNumber, &ppChanageLoc,&nOutChangeLoc, &ppLOTV, &nLOTV, &ppCommon, &nCommon);if (ppCDR4 != NULL) { pp4=ppCDR4; for(i=0;i<nOutNumber+1;i++,pp4++) dump.DumpOGCDR("OutOGCDR",pp4,0); } else { printf("\n DB NULL \n"); }*///OGCDR End//test//DbOGCDRTest();//DbASNERRORTest();//DbCGCDRTest();//DbCSCDRTest();//DbLCLOCTest();//DbLCOMMTest();//DbLLOTVTest();//DbGTPTest();//DbOMCDRTest();//DbOMOCDRTest();//DbOMTCDRTest();//DbOSCDRTest();/*DbCommit(); //test select beginC_Dump dump;char pInSzTableName[]="LCLOC"; char pInSzSeqId[]="0"; S_LCLOC *pOutLChangeLocation=NULL; int number=0; S_RESULT pOut101;DbLCLOCSelect(pInSzTableName, pInSzSeqId, &pOutLChangeLocation, &number, &pOut101);int i;for(i=0;i<number;i++){// printf("%s %s %s %s %s %s\n",pOutLChangeLocation[i].SeqId,pOutLChangeLocation[i].LocationAreaCode,pOutLChangeLocation[i].RoutingAreaCode,pOutLChangeLocation[i].CellIdentity,pOutLChangeLocation[i].ChangeTime,pOutLChangeLocation[i].SortId);}char pInSzTableName1[]="OGCDR";char pWhere[]="SEQID<5";S_OGCDR *pOutCDR=NULL;S_RESULT pOut102;//DbOGCDRSelect(pInSzTableName1,pWhere,&pOutCDR,&number,&pOut102);for(i=0;i<number;i++){// printf("%d\n",pOutCDR[i].FlagR499);}//dump.DumpOGCDR("out.txt",pOutCDR,1);char pInSzTableName2[]="OMCDR";S_OMCDR *pOutCDR2=NULL; S_RESULT pOut103;//DbOMCDRSelect(pInSzTableName2,pWhere, &pOutCDR2, &number, &pOut103);for(i=0;i<number;i++){// printf("%s %s \n",pOutCDR2[i].SeqId,pOutCDR2[i].RecordOpenTime);}//dump.DumpOMCDR("out.txt",pOutCDR2,1);char pInSzTableName3[]="OMOCDR";S_OMOCDR *pOutCDR3=NULL;S_RESULT pOut104;//DbOMOCDRSelect(pInSzTableName3,pWhere,&pOutCDR3,&number,&pOut104);for(i=0;i<number;i++){// printf("%s %s \n",pOutCDR3[i].SeqId,pOutCDR3[i].ServedMSISDN);}//dump.DumpOMOCDR("out.txt",pOutCDR3,1);char pInSzTableName4[]="OMTCDR";S_OMTCDR *pOutCDR4=NULL;S_RESULT pOut105;//DbOMTCDRSelect(pInSzTableName4,pWhere,&pOutCDR4,&number,&pOut105);for(i=0;i<number;i++){// printf("%s %s\n",pOutCDR4[i].SeqId,pOutCDR4[i].GsnIpAddr);}//dump.DumpOMTCDR("out",pOutCDR4,1);char pInSzTableName5[]="OSCDR";S_OSCDR *pOutCDR5;S_RESULT pOut106;//DbOSCDRSelect(pInSzTableName5,pWhere,&pOutCDR5, &number,&pOut106);for(i=0;i<number;i++){ // printf("%s %s\n",pOutCDR5[i].SeqId,pOutCDR5[i].DateCreated);}//dump.DumpOSCDR("out.txt",pOutCDR5,1);char pInSzTableName6[]="CSCDR";S_CSCDR *pOutCDR6=NULL;S_RESULT pOut107;//DbCSCDRSelect(pInSzTableName6,pWhere,&pOutCDR6,&number, &pOut107);for(i=0;i<number;i++){ //printf("%s %s\n",pOutCDR6[i].SeqId,pOutCDR6[i].DateCreated);} char pInSzTableName7[]="CGCDR";S_CGCDR *pOutCDR7; S_RESULT pOut108;//DbCGCDRSelect(pInSzTableName7,pWhere,&pOutCDR7,&number,&pOut108);for(i=0;i<number;i++){ // printf("%s %s\n",pOutCDR7[i].SeqId,pOutCDR7[i].DateCreated);}//test select end // ReadGtp(gtp);// gtp.Test(); /* C_CDRWriteASNDecode asn; asn.Test();// asn.Test2();*//* C_CDRReadForCombined readCom; readCom.Test(); /* C_CDRWriteCombined writeCom; writeCom.Test();*/// C_CDRReadForBill bill;// bill.Test();/* C_CDRReadForCombined readCom; readCom.Test();/*// gtp.Disconnect(); cout<<"Good Bye to TEST2\n";/* for(int i=0;i<10000;i++) { char* a = gtp.GetSysdate(); CDate date(a, a); date.Calculate(); printf("%d %d\n", i, date.GetCount()); printf("%d %s\n", i ,date.GetAt(i).c_str()); }*///test LCBC & LLCBC C_MYSQL test;test.LCBCTest();test.LLCBCTest();//test LCBC & LLCBC end}?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -