【正文】 ile()，處理單條記錄DealOneCdr()，完成一個文件操作同時入庫：DoneOneFile()。 if(!m_EventPcsInfo) { throw TException(TPcsTrans::TPcsTrans alloc memory for TEventPcsInfo !)。 m_EventPcsInfo = NULL。private: // 根據(jù)執(zhí)行方式預(yù)設(shè)查詢SQL bool PreSetQuerySQL(const TPcsTransExecInfo amp。 // 處理話單文件 bool ProcessPcsFile(const char *psSQL, TPcsTransExecInfo amp。clRateFileIOMan,TCdrEvent amp。clRateFileIOMan, TRateFileDBInterface amp。 //預(yù)設(shè)的入庫緩沖區(qū)記錄數(shù)量 int m_iCount。（TeventPcsInfo）的設(shè)計由上面類TPcsTrans對它的要求，TeventPcsInfo必須具備內(nèi)存空間用于存儲數(shù)據(jù)，且還要有把內(nèi)存中的數(shù)據(jù)寫入數(shù)據(jù)庫的功能。另外還有一些成員變量來輔助實現(xiàn)上述功能。public: inline int GetBufferCount() { return iBufferCount。tCdrEvent, TPcsTransExecInfo amp。nor_result,int amp。private: vectorEvent_Pcs_Abnormal msEventPcs。 //下個帳期的清單費用 vectorEvent_Pcs_Abnormal msTmpEventPcs。 //對應(yīng)一個處理文件的下個帳期的清單費用 Event_Pcs_Abnormal m_EventPcs。 TDBQuery *p_dbquery 。 //下個帳期SD表內(nèi)存（與數(shù)據(jù)庫同步） HASHTABLE *m_phtSdInsertCurrent。 //下個帳期更新方式入庫容器 vectorAcct_Item_Sd_Prepaypcs m_vTmpSdInsertCurrent。 //存儲各個內(nèi)存Hash的元素個數(shù) long long m_lSizeSdCurrent。 //下個帳期插入方式入庫容器尺寸 long long m_lSizeSdUpdateCurrent。 TServHistoryInfo *m_pServHistory。初始化程序：。預(yù)付費入庫靜態(tài)資料：加載PHS_FEE_TYPE表信息、加載ACCT_ITEM_GROUP_MEMBER、連接共享內(nèi)存指針、裝載私有內(nèi)存指針。取得應(yīng)用配置信息：，并放入?yún)?shù)tConfigInfo對應(yīng)的成員變量中。用來存放當(dāng)前處理文件的信息；TRateFileDBInterface clRateFileDBIF(m_pclTbInfoManager)。()：從計費文件數(shù)據(jù)庫接口類TRateFileDBInterface的成員變量 m_vUnsettledFileInfo中取得一條待處理的計費文件信息到未處理文件信息ptUnsettledFileInfo中。tCdrEvent)：先取一條話單記錄，然后循環(huán)取得話單字段，并根據(jù)文件頭的屬性ID序列來設(shè)置話單屬性到ptCdrEvent中的計費原數(shù)據(jù)結(jié)構(gòu)（TCallDetailRecord）pRecordData的對應(yīng)的成員變量里。批量入庫m_EventPcsInfoPcsIntoDB()：先清單表和費用。完成一個文件的處理DoneOneFile()：調(diào)用m_EventPcsInfoInsertOneFileResult()將臨時數(shù)據(jù)插入入庫向量msEventPcs 、sEventPcsNext、sEventPcsFee和msEventPcsFeeNext中，同時增加入庫緩沖iBufferCount的值。()：通過參數(shù)把ptUnsettledFileInfo和tConfigInfo放入計費文件解析類TRateFileIOManager的成員變量m_ptCurFileInfo、m_ptConfigInfo中；接著從ptUnsettledFileInfosFileName中解析出ptUnsettledFileInfolCustGroup；然后修正文件名，即用路徑和文件名合成新的文件名；如果打開計費文件的文件指針()為空則用修正后的文件名打開文件；如果打開文件成功，取出第一行即文件頭sInputCdr中，并調(diào)用成員函數(shù)ParseFileHead（）來解析出屬性標(biāo)識ID到當(dāng)前文件的屬性ID序列m_vCurFileAttrSeq中。用于解析話單文件。處理文件：執(zhí)行處理話單文件函數(shù)ProcessPcsFile()。 處理命令Execute()程序流程圖 10，Execute()程序流程加載SD表數(shù)據(jù)到內(nèi)存：把帳期表ACCT_ITEM_SD_PREPAYPCS_帳期ID中的數(shù)據(jù)加載到內(nèi)存m_phtSdCurrent和m_phtSdNext中。獲得帳期信息：（帳務(wù)周期表）,把帳期開始時間，帳期截止時間和下個帳期填寫到結(jié)構(gòu)體 TPcsTransExecInfo 中。}。 //下個帳期更新方式入庫容器尺寸 TUniqueID m_acct_item_id_generator。 //下個帳期SD表內(nèi)存尺寸 long long m_lSizeSdInsertCurrent。 vectorAcct_Item_Sd_Prepaypcs m_vTmpSdUpdateCurrent。 //下個帳期插入方式入庫容器 HASHTABLE *m_phtSdUpdateCurrent。 //入庫緩沖 //內(nèi)存Hash HASHTABLE *m_phtSdCurrent。 //有可能對應(yīng)多條費用 bool m_bCurrent。 //對應(yīng)一個處理文件的下個帳期的清單 vectorEvent_Pcs_Fee msTmpEventPcsFee。 //下個帳期的清單 vectorEvent_Pcs_Fee msEventPcsFee。 //往數(shù)據(jù)集合類里面插入數(shù)據(jù) bool InsertPcsElement() bool InsertPcsFeeElement() //將一個文件處理成功的結(jié)果插入容器 bool InsertOneFileResult()。 //獲得對應(yīng)事件類型的帳目類型 int GetAcctItemType(char* service_type)。tPcsTransExecInfo)。為了方便類TPcsTrans對它操作，將類TPcsTrans定義為TEventPcsInfo的友元類。清單表、費用表只需要進(jìn)行入庫，定義為vector向量即可實現(xiàn)；SD表的入庫時候，要和原來的記錄進(jìn)行比較，有了記錄要進(jìn)行合帳，沒有記錄插入記錄，如果不采取任何措施的話程序會很慢，因此我們要用到Hash表（HASHTABLE），用它來定義內(nèi)存空間，先把SD表讀到內(nèi)存，產(chǎn)生一條記錄時，先查找SD表，如果有了記錄把它放到更新的Hash內(nèi)存中，沒有記錄把它放到插入的Hash內(nèi)存中。 //存放已經(jīng)處理的文件信息 vectorTEventSourceFileInfo m_vFileProc。tPcsTransExecInfo)。tPcsTransExecInfo)。tConfigInfo)。 // 讀取配置信息 bool GetConfigInfo(TConfigInfo amp。 // 處理 bool Execute(TPcsTransExecInfo amp。 }。還需要成員變量：存放已經(jīng)處理的文件信息 vectorTEventSourceFileInfo m_vFileProc等，另外它還要繼承類TAppComponent，這樣可以方便對數(shù)據(jù)庫的操作。因為對數(shù)據(jù)庫的操作很慢，會占用大量的運行時間，所以先把這些記錄放在內(nèi)存中，等到達(dá)一定數(shù)量時，再成批的放入數(shù)據(jù)庫，為此我們需要一個用于存放這些記錄的空間，所以我們還要設(shè)計一個數(shù)據(jù)組織操作類（數(shù)據(jù)庫緩沖區(qū)）TEventPcsInfo，并把它作為TPcsTrans的一個成員。Hash內(nèi)存等這些在計費系統(tǒng)的其他模塊中也用到過，相關(guān)結(jié)構(gòu)和申明都已經(jīng)寫好放在公用的庫中，在這里我們只要使用它，所以不會細(xì)講它。入清單表和費用表與入sd表也有不同，入清單表和費用表時，只要將解析出的記錄寫進(jìn)對應(yīng)的表中即可，而入sd表時比較復(fù)雜，新記錄還要與對應(yīng)sd表中的記錄比較，如果沒有記錄才寫入新的紀(jì)錄，有相同記錄要修改記錄。實現(xiàn)從文件級到表級的轉(zhuǎn)換，關(guān)鍵是如何提取文件中的話單記錄并把它放到表中相應(yīng)得位置中，在這里我們用的是事件驅(qū)動來實現(xiàn)，即先讀取話單文件的頭文件，把它屬性標(biāo)識ID存放到當(dāng)前文件的屬性ID序列中；然后取出一條話單記錄，依次讀取話單字段，然后根據(jù)當(dāng)前文件的屬性ID序列中對應(yīng)屬性標(biāo)識ID來設(shè)置話單屬性，并把它存放到話單計費事件適配器類（TCdrEvent）中的計費原數(shù)據(jù)結(jié)構(gòu)（TCallDetailRecord）pRecordData的對應(yīng)的成員變量里。字段名字段代碼數(shù)據(jù)類型接口類型長度屬性標(biāo)識描述話單標(biāo)識event_inst_idLong longchar12100000事件類型Event_type_idLong longChar9100001網(wǎng)元IDnet_IDLong longChar9100002網(wǎng)元標(biāo)識主叫Calling_nbrcharChar20100003主叫，帶區(qū)號被叫CALLED_NBRChar char20100004被叫主產(chǎn)品實例標(biāo)識Serv_idLong longChar12200001客戶標(biāo)識Cust_idLong longChar12300001客戶分組Cust_categoryLong longChar9300002原始文件標(biāo)識Old_file_idLong longChar9100008文件ID標(biāo)識，可以通過關(guān)聯(lián)查找到預(yù)處理的文件名開始時間Start_timeDATETIMEChar14100005格式：yyyymmddhhmmss結(jié)束時間End_timeDATETIMEChar14100006格式：yyyymmdd hh:mm:ss時長durationlonglong14100007優(yōu)惠前費用1Pcs_oldcharge1doubledouble10160001優(yōu)惠后費用1Pcs_charge1doubledouble10160002優(yōu)惠前費用2Pcs_oldcharge2doubledouble10160003優(yōu)惠后費用2Pcs_charge2doubledouble10160011優(yōu)惠前費用3Pcs_oldcharge3doubledouble10160012優(yōu)惠后費用3Pcs_charge3doubledouble10160013優(yōu)惠前費用4Pcs_oldcharge4doubledouble10160014優(yōu)惠后費用4Pcs_charge4doubledouble10160015優(yōu)惠前費用5Pcs_oldcharge5doubledouble10160016優(yōu)惠后費用5Pcs_charge5doubledouble10160017優(yōu)惠前費用6Pcs_oldcharge6doubledouble10160018優(yōu)惠后費用6Pcs_charge6doubledouble10160019是否需要計算跳次PCS_ORSHIHUAIntInt1160020計費方標(biāo)志PCS_BILLINGFLAGcharchar5160021表 7，話單格式第三章 預(yù)付費入庫設(shè)計預(yù)付費入庫就是將揀重以后的話單文件，經(jīng)過處理，解析并提取其中的信息，然后把這些信息入庫，將它們以表的結(jié)構(gòu)存放在數(shù)據(jù)庫中，總的來說它實現(xiàn)的是從文件級到表級的過程。表 3，帳目組_帳目表入庫后形成的三張表：清單表、費用表和sd表的基表結(jié)構(gòu)如下：EVENT_PREPAYPCS (預(yù)付費PCS話單基表），字段名稱字段含義數(shù)據(jù)類型非空說明event_inst_id話單標(biāo)識DECIMAL(15,0)YPKevent_type_id事件類型DECIMAL(9,0)Ycalling_nbr主叫號碼VARCHAR(20)called_nbr被叫號碼VARCHAR(24)start_time開始時間DATETIME YEAR TO SECONDend_time結(jié)束時間DATETIME YEAR TO SECONDduration時長DECIMAL(9,0)serv_id用戶標(biāo)識DEC