支付業(yè)務(wù)監(jiān)控系統(tǒng)改造項(xiàng)目204產(chǎn)品概要設(shè)計(jì)說明書

2014-08-【A】創(chuàng)2015-01-【M】正式注：變化狀態(tài)：A—增加，M—修改，D—?jiǎng)h引 背 編寫目 范 定義和縮略 參考資 標(biāo) 從屬關(guān) 總體設(shè)計(jì)概 設(shè)計(jì)原 設(shè)計(jì)思 系統(tǒng)結(jié) 與算 通用數(shù)據(jù)工 靈活數(shù)據(jù)處理技 靈活設(shè) 主要功 關(guān)鍵應(yīng)用模塊設(shè) 客戶端功能模塊設(shè) 系統(tǒng)中國(guó)地 C業(yè)務(wù) C業(yè)務(wù)量圖 自檢任務(wù)項(xiàng)安排管 自檢任務(wù)項(xiàng)執(zhí)行管 任務(wù)項(xiàng)執(zhí)行步驟管 事件信息定義管 自檢任務(wù)事件記錄管 代碼簡(jiǎn)稱對(duì)應(yīng)管 接入點(diǎn)信息維度管 支付系統(tǒng)業(yè)務(wù)量匯總查 支付系統(tǒng)業(yè)務(wù)量均線查 當(dāng)天系統(tǒng)狀態(tài)變化情況查 功能模塊設(shè) 服 功能模 系統(tǒng)自檢功能模 子系統(tǒng)設(shè) 報(bào)文客戶端功能開放功能引背隨著第二代支付系統(tǒng)的投產(chǎn)運(yùn)行及后續(xù)系統(tǒng)的不斷開發(fā)、完善，業(yè)務(wù)管理部、運(yùn)行部需要運(yùn)維的系統(tǒng)數(shù)量、系統(tǒng)風(fēng)險(xiǎn)也在逐漸增加。然而當(dāng)前業(yè)務(wù)系統(tǒng)所具有的功能，并不能使運(yùn)維實(shí)時(shí)了解所有系統(tǒng)運(yùn)行的異常、存在的風(fēng)險(xiǎn)，并出現(xiàn)的問題，為系統(tǒng)的管理和帶來諸多不便。2014年3月，業(yè)務(wù)管理部、運(yùn)行部就二代系統(tǒng)上線以來存在的業(yè)務(wù)的不足，提出了新的功能需求，要求提供各系統(tǒng)的運(yùn)行時(shí)序監(jiān)控，大小額、分時(shí)業(yè)務(wù)量，系統(tǒng)自檢及事件等功能。針對(duì)本需求的二代交易系統(tǒng)的功能已在PMCS系統(tǒng)上改造完成，并于2014年第二季度末在生產(chǎn)環(huán)境成功上線。本項(xiàng)目是功能的延續(xù)與完善，主要目標(biāo)是增加E系統(tǒng)、信息系統(tǒng)的功能，完善、優(yōu)化展示效果，并對(duì)PMS端、服務(wù)端進(jìn)行改造，實(shí)現(xiàn)靈活的數(shù)據(jù)處理功能。編寫目范本文的預(yù)期讀者為業(yè)務(wù)需求方、項(xiàng)目主管、項(xiàng)目協(xié)管、項(xiàng)目組成員，以及質(zhì)量管理組、測(cè)試組。本文檔包括引言、功能概述、功能、功能模塊等章節(jié)定義和縮略（The2ndGenerationChinaNationalAdvancedPaymentSystem,CNAPS2）支付業(yè)務(wù)系統(tǒng)（PaymentMonitorControlSystem,參考資《支付業(yè)務(wù)系統(tǒng)改造項(xiàng)目（2014）需求規(guī)格說明書《支付業(yè)務(wù)系統(tǒng)改造項(xiàng)目（2014）技術(shù)總體方案（PMCS（PSAS（《二代支付系統(tǒng)數(shù)據(jù)庫(kù)邏輯設(shè)計(jì)（PBCS部分標(biāo)（OSSP_V3.1.0 該工具庫(kù)對(duì)常用的數(shù)據(jù)庫(kù)操作及查詢結(jié)果集進(jìn)行了封裝，通過的接口將數(shù)據(jù)庫(kù)中的記錄為實(shí)體信息供上層應(yīng)用，而使之不必關(guān)心數(shù)據(jù)涉及到的具體細(xì)節(jié)，如根據(jù)配置文件中設(shè)定的數(shù)據(jù)庫(kù)類型及方式自動(dòng)選擇對(duì)應(yīng)的驅(qū)動(dòng)數(shù)據(jù)庫(kù)，提供對(duì)ORACLE/DB2數(shù)據(jù)庫(kù)的驅(qū)動(dòng)（XA及非XA版本），并可擴(kuò)展至對(duì)其他數(shù)據(jù)庫(kù)的支持。數(shù)據(jù)庫(kù)驅(qū)動(dòng)盡可能使用原廠API實(shí)現(xiàn)（對(duì)于ORACLE使用OCI方式，DB2使用CLI-ODBC方式），提高了效率。提供結(jié)構(gòu)化的查詢接口以及原生SQL接口多種結(jié)果集輸出方式，既可將檢索結(jié)果至指定的實(shí)體對(duì)象中，也可以將一些在實(shí)際的應(yīng)用場(chǎng)景中，相比原來的SQL方式，在性能上不會(huì)有太大的下降。一般操作基本能保持效率持平，對(duì)于一些關(guān)于LOB字段的操作性能會(huì)有提使用方本項(xiàng)目在靈活數(shù)據(jù)處理功能中使用了通用數(shù)據(jù)工具，來靈活oracle、db2數(shù)據(jù)SQL語(yǔ)句，進(jìn)行數(shù)據(jù)處理。通用數(shù)據(jù)工具由應(yīng)用研究室開發(fā)，暫未納入開發(fā)中心公共庫(kù)中。本項(xiàng)目在使用時(shí)，PMCS源碼添加至項(xiàng)目代碼中，以用于編程開發(fā)。使用風(fēng)事事靈活數(shù)據(jù)處邏輯定時(shí)任定時(shí)任務(wù)及事件觸發(fā)配12、任務(wù)執(zhí)行模塊從隊(duì)列中事件，并根據(jù)事件所對(duì)應(yīng)的執(zhí)行列表，執(zhí)行任務(wù)對(duì)象說表示觸發(fā)事件，用于定義事件與處理動(dòng)作的對(duì)應(yīng)關(guān)系(1-SQLACTIVE（1-對(duì)象模定關(guān)關(guān)關(guān)產(chǎn)配置文件模NODEITEMEVENT域：定義了事件所關(guān)聯(lián)的處理行為信息，允許一個(gè)事件對(duì)應(yīng)多個(gè)處理行為。TRIGGER域：定義了觸發(fā)器的觸發(fā)條件，觸發(fā)事件信息，僅限于任務(wù)項(xiàng)的。ACTIVE域：定義了行為所要執(zhí)行的動(dòng)作、輸入、輸出、事件等等。CMDSQLID="0000TYPE="MAINIP="6PORT="60000"DESC="PBCS、ID="0003TYPE="PROCID="0000TYPE="MAINIP="6PORT="60000"DESC="PBCS、ID="0003TYPE="PROCMSGID="910DBTYPE="ORACLEDBNAME="ORAPSAS"DBUSER="psas"DBPWD="psasDESCPSASID="0004TYPE="PROCMSGID="911DBTYPE="ORACLEDBNAME="ORAPQDB"DBUSER="pbcs"DBPWD="pbcsDESCPBCSID="0005"TYPE="QUEUE"QPATH="/cnaps2/psas/etc/pmiscfg.ini" QMODE=””QDEP=“100”QLEN=“1024”DESC=”隊(duì)列”ID="0000TYPE="ITEMSTRTIME="18:30:00"ENDTIME="19:30:00INTERVAL="60ATTIMEMSGID=”911”EVENT="EVENT.0000"DESC=" ID="0001TYPE="ITEMSTRTIME="19:00:00"ENDTIME="20:30:00INTERVAL="60ATTIMEMSGID=”911”EVENT="EVENT.0001"DESC=" ID="0002"TYPE="ITEM"STRTIME="16:00:00"ENDTIME="18:30:00"INTERVAL="60"ATTIME=""EVENT="EVENT.0002" ID="0000"TYPE="EVENT"MSGID=”910”ACTIVE="ACTIVE.0000"DESC="事件,對(duì)是 ID="0001TYPE="EVENT"MSGID=”911”ACTIVE="ACTIVE.0001DESCID="0001TYPE="EVENT"MSGID=”910”ACTIVE="ACTIVE.0001DESCID="0000"TYPE="TRIGGER"WHEN="OU.LIST[0][0]-ne'0'"ON=”ACTIVE.0000”CONTENT=”Y:ACTIVE.0001,ACTIVE.0002N:CONTINUE,BREAK,EVENT.0001”DESC="定義在ACTIVE.0001上的觸發(fā)器,當(dāng) 注：CONTENT中定義了匹配相同時(shí)，執(zhí)行哪些內(nèi)容，匹配不相同執(zhí)行哪些內(nèi)容。這些內(nèi)容可以是ACTIVE,EVENT,CONTINUE,BREAKID="0000"TYPE="ACTIVE"RUNCMD="CMD.0000"RUNTYPE="DMLS"DATAID=""MSGID=””O(jiān)U="1,E"IN="1:OU.LIST[0][0],2:’name’"TRIGGER="TRIGGER.0000"DESC=" ID="0001"TYPE="ACTIVE"RUNCMD="CMD.0001"RUNTYPE="DMLS"DATAID="DPS00001"MSGID=”001”O(jiān)U=""IN="" IN ID=”0000”\SMTS=”selectcount(*)frompmispost9903wheredealstatus='4'”“andID=”0001”\SMTS=”selectcolldate,syscode,table,collstatus,begintime,endtimefrom備注：ACTIVERUNTYPE說明：1DMLS：SELECT語(yǔ)句DMLI：INSERT語(yǔ)句DMLD：DELETE語(yǔ)句ACTIVEIN、OUACTIVESELECTSQLCODE、SQLERRM作為返回值。如果在OU中指定SELECT的返回行，則除了默認(rèn)返回值外，還會(huì)將OU中指定的行返回。支持多行。LIST表示返回行，CODE為代碼，RMSG為返回信息數(shù)據(jù)標(biāo)定數(shù)據(jù)標(biāo)識(shí)用來定義數(shù)據(jù)的類型，以供服務(wù)端根據(jù)數(shù)據(jù)標(biāo)識(shí)處理數(shù)編14M-I-B-O-數(shù)據(jù)格定本數(shù)據(jù)格式數(shù)據(jù)的格式，用來進(jìn)行數(shù)據(jù)傳輸及解析編第一行：數(shù)據(jù)標(biāo)識(shí)+批次號(hào)+記錄數(shù)+時(shí)第二行至N行：數(shù)據(jù)，“|@|”為列分隔串“&&&\n”為行分隔示例：DPSM0001|@|00000001|@|10|@|1000|@|2014-09-0212:00:21&&& 隊(duì)列報(bào)文說任務(wù)報(bào)報(bào)文示例：INT.910<0001<2014-09-0212:00:21數(shù)據(jù)發(fā)送指令報(bào)報(bào)文功能：由執(zhí)行主控在數(shù)據(jù)首次寫入隊(duì)列前，將本報(bào)文寫入隊(duì)列，用于獲取后備注：消息類型為ACTIVE域中的msgid值，用于端從隊(duì)列中數(shù)據(jù)內(nèi)容。可用數(shù)據(jù)發(fā)送內(nèi)容報(bào)備注：批次號(hào)由1順序，當(dāng)結(jié)束標(biāo)志為0時(shí)，表示本次完成，結(jié)束標(biāo)志為時(shí)，表示還有后續(xù)數(shù)據(jù)。數(shù)據(jù)內(nèi)容中以堅(jiān)線作為列分隔符，UNIX靈活設(shè)設(shè)計(jì)原靈活功能是原功能的一個(gè)擴(kuò)展，支持oracle、db2的定制化。本功能模式，也支持服務(wù)端直接數(shù)據(jù)模式基本處理流，靈活數(shù)據(jù)處理功能使用通過數(shù)據(jù)工具，按照配置文件進(jìn)行定制化的數(shù)據(jù)臨時(shí)至AIX隊(duì)列管理器中由修改后PMCS原程序從隊(duì)列管理器中數(shù)據(jù)，cncc.981.001.01（數(shù)據(jù)發(fā)送報(bào)文）MQ發(fā)送到服務(wù)端。服務(wù)數(shù)據(jù)寫入指定的表及字段中。至此，完成了數(shù)據(jù)、傳輸、入庫(kù)的過程。， 主要功1、通用的功能，可實(shí)現(xiàn)一點(diǎn)多源的定時(shí)功能23、重新設(shè)計(jì)的展示頁(yè)面，提高用戶的使用體驗(yàn)4、增加對(duì)PSAS、PMCS系統(tǒng)的功能關(guān)鍵應(yīng)用模客戶端功能系統(tǒng)前分時(shí)段業(yè)務(wù)量與M日均線進(jìn)行對(duì)比，如偏差超過+-N%RRRR無(wú)操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)默認(rèn)顯示當(dāng)日大額業(yè)務(wù)量趨勢(shì)圖3）1/C/專屬接入如果查詢條件searchType:C,則查詢條件otherType為C選項(xiàng)。如果查詢條件searchType:otherTypejson1/C/專屬接入時(shí)統(tǒng)時(shí)序界RR無(wú)操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)頁(yè)面3）1json1自檢任務(wù)展[查詢操作統(tǒng)示實(shí)時(shí)HVPS、BEPS、IBPS、NETS、SAPS的系統(tǒng)自檢情況RR操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)3）5json1[手動(dòng)檢查操作統(tǒng)字段為“1：R、操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)5json系統(tǒng)當(dāng)前狀統(tǒng)各個(gè)系統(tǒng)狀態(tài)視RR無(wú)操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)頁(yè)面3）1無(wú)json1統(tǒng)業(yè)務(wù)系統(tǒng)事件示業(yè)務(wù)系統(tǒng)事件界RR操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0100系統(tǒng)1json1中國(guó)地圖C業(yè)務(wù)統(tǒng)中國(guó)地圖C業(yè)務(wù)地圖展示區(qū)，根據(jù)排序類型地圖顏色由深（高）至淺（低。右側(cè)為表格數(shù)信息展示區(qū)，分為1-10名、11-20名、21-32名。系統(tǒng)會(huì)根據(jù)條件進(jìn)行刷新數(shù)據(jù)中國(guó)地圖C業(yè)務(wù)量界RC大額支付業(yè)務(wù)量R小額支付類業(yè)務(wù)R支付業(yè)務(wù)量實(shí)時(shí)R無(wú)默認(rèn)顯示當(dāng)前系統(tǒng)日期的PMCS各C業(yè)務(wù)量數(shù)據(jù)3）4)json1地圖展示區(qū)，根據(jù)排序類型地圖顏色由深（名高）至淺（低）表1-1011-2021-32名。系統(tǒng)會(huì)根據(jù)條件進(jìn)行刷新數(shù)據(jù)C業(yè)務(wù)量圖統(tǒng)C柱狀圖形式實(shí)時(shí)各C大額、小額、業(yè)務(wù)量數(shù)據(jù)。系統(tǒng)默認(rèn)查詢當(dāng)天大32C業(yè)務(wù)量及總量筆數(shù)金額信息。默認(rèn)條件為按照筆數(shù)排序。也可按照排序類型510名CRC大額支付業(yè)務(wù)量R小額支付類業(yè)務(wù)R支付業(yè)務(wù)量實(shí)時(shí)R無(wú)操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N0系統(tǒng)->N0300C業(yè)務(wù)量圖表默認(rèn)顯示當(dāng)前系統(tǒng)日期的PMCS各C業(yè)務(wù)量數(shù)據(jù)510json1展示32C業(yè)務(wù)量及總量筆數(shù)金額信息統(tǒng)統(tǒng)R工作日/1工作日/修統(tǒng)R、W3）12自檢任務(wù)項(xiàng)查統(tǒng)R1修統(tǒng)R、W3）12任務(wù)項(xiàng)執(zhí)行查統(tǒng)R執(zhí)行SQL1執(zhí)行SQL修統(tǒng)R、W3）12執(zhí)行SQL事件信息定查統(tǒng)R1修統(tǒng)R、W3）12明統(tǒng)oR3）1自檢任務(wù)事件記錄管查統(tǒng)理R1修統(tǒng)理R、W3）12明統(tǒng)理oR3）1代碼簡(jiǎn)稱對(duì)查統(tǒng)R1修統(tǒng)R、W3）12新統(tǒng)WW3）12刪統(tǒng)R、W3）12接入點(diǎn)信息查統(tǒng)Rc所屬1號(hào)所屬碼修統(tǒng)R、W操作用戶登錄系統(tǒng)，點(diǎn)擊左菜單“N1系統(tǒng)參數(shù)管理->N1700接入點(diǎn)信息維3）c所屬12號(hào)所屬碼支付系統(tǒng)業(yè)務(wù)量匯總查查統(tǒng)R1C/法人//專屬接入支付系統(tǒng)業(yè)務(wù)量均線查查統(tǒng)R1C/法人//專屬接入當(dāng)天系統(tǒng)狀態(tài)變化情況查統(tǒng)R1功能模服靈活數(shù)據(jù)處理管理功PmisPMCS、PSAS服務(wù)端及端均可使初始化1、從應(yīng)該安裝$APP_HOMEpmiscfg.iniNODE、ITEM2、根據(jù)pmiscfg.ini配置文件中的NODE域中QUEUE配置，創(chuàng)建消息隊(duì)列，設(shè)置消息最大長(zhǎng)度。3、根據(jù)pmiscfg.iniNODEPROCPROC的IDFLAG）（）主控制1、進(jìn)程休眠52、依次ITEM域中的每行數(shù)據(jù)，判斷是否觸發(fā)事件，如果符合觸發(fā)條件則將事件報(bào)文寫入隊(duì)a）觸發(fā)條件：STRTIMEENDTIME&&3、重復(fù)流程1靈活數(shù)據(jù)處理執(zhí)行功PMCSPMCS、PSAS服務(wù)端 端均可使初始化1、從應(yīng)該安裝 2NODE.QUEUEQPATH a)c)NODE.PROC.MSGIDINT.9105EVENTACTIVE從執(zhí)行棧中獲取末端取一條待執(zhí)行的項(xiàng)，執(zhí)行下面的步驟，否則提交事務(wù)，執(zhí)行步驟1a)ACTIVE，ACTIVE塊。c）EVENT，EVENTCOMMIT，6。f）BREAK，ROLLBACK ACTIVE ACTIVE.IDACTIVEACTIVERUNTYPE，DATAFLAG，MSGIDIN,OURUNTYPE”DMLS”，根據(jù)ACTIVE.RUNCMD獲取SQL代碼，至緩沖區(qū)。d）調(diào)用通用數(shù)據(jù)工具，執(zhí)行SQL語(yǔ)句。調(diào)用通用數(shù)據(jù)工具，獲取查詢結(jié)果，按ACTIVE.OU參數(shù)保存輸出信息DATAFLAGINT.920,INT.921INT.921ACTIVEOU.CODE,OU.EMSG,OU.LIST（返回信息 b）根據(jù)ACTIVE.RUNCMD獲取SQL代碼，至緩沖區(qū)。d）調(diào)用通用數(shù)據(jù)工具，執(zhí)行SQL語(yǔ)句。e）ACTIVEOU.CODE,OU.EMSG,OU.LIST ACTIVE.TRIGGERTRIGGERTRIGGER流程TRIGGER.IDTRIGGERTRIGGERWHEN、ON、CONTENTTRIGGER.WHEN如果左值或右值了OU的信息，則解析后，將獲取的值進(jìn)行替換CONTENTYCONTENT為N（EVENT，ACTIVE）EVENT程EVENT.IDEVENTMSGIDMSGIDINT.910數(shù)據(jù)傳Pmis981PMCS本模塊僅限于PMCS端，做為定時(shí)的動(dòng)態(tài)模塊主流程查找消息類型為920數(shù)據(jù)發(fā)送指令消息，如果消息存在，則執(zhí)行以程，否則返回920根據(jù)920報(bào)文中的消息類型獲取數(shù)據(jù)（INT.921報(bào)文），以等待方式獲取消息調(diào)用公共接口函數(shù)，解析921報(bào)文內(nèi)容，獲取數(shù)據(jù)并按原PMCS格式進(jìn)行轉(zhuǎn)化 ew）,將數(shù)據(jù)寫PMISPOST9904表。跳轉(zhuǎn)到步驟4。如果921報(bào)文中數(shù)據(jù)標(biāo)志為0，則按步驟6進(jìn)行數(shù)據(jù)發(fā)送2數(shù)據(jù)寫入流程strOutBuffercncc.981.001.01PMISPOST9904業(yè)務(wù)量日線與月線匯總支付系統(tǒng)業(yè)務(wù)量匯總表-支付系統(tǒng)業(yè)務(wù)量匯總表1、靈活處理SQL服務(wù)配置文200：0001：003SQLINSERTINTOPMCSPOST9832SELECTB.NODECODE,--節(jié)點(diǎn)代碼 B.NODETYPE,--節(jié)點(diǎn)類型B.RECVDATE,--受理日期 FROM(SELECTA.NODECODE ASNODECODE,--節(jié)點(diǎn)代碼 ASSYSCODE,--系統(tǒng)號(hào) ASNODETYPE,--節(jié)點(diǎn)類型 ASRECVDATE,--受理日期SUM(A.SENDNUM)ASSENDNUM,--發(fā)送總筆數(shù)SUM(A.SENDAMT)ASSENDAMT,--發(fā)送總金額SUM(A.RECVNUM)ASRECVNUM,--接收總筆數(shù)SUM(A.RECVAMT)AS --接收總金FROMPMCSPOST9830WHERERECVDATE<TO_CHAR(SYSDATE,'YYYYMMDD')ANDRECVDATENOTIN(SELECTDISTINCTRECVDATEFROMGROUPBYA.NODECODE,A.SYSCODE,A.NODETYPE,A.RECVDATE)數(shù)據(jù)載能模塊處理端數(shù)據(jù)，根據(jù)PMISPOST9841、PMISPOST9842表中的數(shù)據(jù)，入庫(kù)數(shù)據(jù)裝載數(shù)據(jù)裝載信息系統(tǒng)數(shù)據(jù)信息系統(tǒng)數(shù)據(jù)9811、服務(wù)端處理主控程序PmisMesgMainSvr輪詢PMISPOST9905表，根據(jù)未處理報(bào)文的表調(diào)svr_dataload.pc2、svr_dataload.pc3、定義全局變量數(shù)據(jù)標(biāo)識(shí)號(hào)、批次號(hào)、記錄數(shù)（每條數(shù)據(jù)的字段數(shù)）、時(shí)間、定義全局變EXECSQLBEGINDECLAREcharV_DODE[8+1]; charV_COLLNO[8+1]; charV_COLLECTTIME[29+1];//時(shí)間char #define EXECSQLENDDECLARE FIELD_NUM4CleanDataByBanchNo(LPCSTRpBanchNo)PMCSPC00015InsertDataToDB(LPCSTRpDataStream,intnRecordNum)函數(shù)，對(duì)報(bào)文體內(nèi)容繼續(xù)處理。時(shí)間字段，并更新上述全局變量如：if(FParseData((char*)pDataStream,1,FIELD_LENGTH,&V_DODE)=={}、pDataStreamEXECSQLBEGINDECLAREchar DataLoad //PMCSPOST9842char char char //存放SQLEXECSQLENDDECLAREPMCSPIST9841、判斷PMCSPOST9841中的數(shù)據(jù)載入方式，如為M02-刪除后 if(strcmp((LPCSTR)szLOADMODE,"M02")==0{memset(szDynStmt,0x00, WHERE1=1 因?yàn)閃HEREANDEXECSQLDECLAREDELETE_CURCURSORFOR FROMPMCSPOST9842AWHERECOLTYPE='PK'ORDERBY EXECSQLOPENCheckDBError("CURSOR:<DELETE_CUR>",{//{memset(&stDataLoad,0,EXECSQLFETCHDELETE_CURINTOif(SQLCODE=={}CheckDBError("CURSOR:<DELETE_CUR>",//拼刪除SQLsprintf(szDynStmt+strlen(szDynStmt),“AND}g)、按f)步驟拼SQL，并執(zhí)行該SQL PSAS節(jié)點(diǎn)信息功能PSAS節(jié)點(diǎn)下的節(jié)點(diǎn)運(yùn)行狀態(tài)，如節(jié)點(diǎn)運(yùn)行狀態(tài)為異常，則PSAS節(jié)點(diǎn)信息功能PSAS批量節(jié)點(diǎn)定義INSERTINSERT數(shù)據(jù)載入數(shù)據(jù)載入信息系統(tǒng)數(shù)據(jù)INSERT信息系統(tǒng)數(shù)據(jù)981端處理流1、端主控配置文件，解析配置文件進(jìn)行，涉及該項(xiàng)的配置文件如下ID="0000"TYPE="MAIN"IP="6"PORT="60000"DESC="PBCS、PSAS定義文件ID="0001TYPE="LINKDBTYPE="ORACLEDBNAME="ORAPSAS"DBUSER="psas"DBPWD="psasDESC="PSASID="0010TYPE="PROCFLAG="10DESC="定義執(zhí)行進(jìn)程標(biāo)識(shí)用于處理PSASID="0010TYPE="ITEMSTRTIME="18:30:00"ENDTIME="20:30:00INTERVAL="60PROC="NODE.0010"EVENT="EVENT.0010"DESC="PSASPSAS節(jié)點(diǎn)信息功能"ID="0010"TYPE="EVENT"ACTIVE="ACTIVE.0010"DESC="PSAS.PMISPOST9906表中滿足條件的數(shù)據(jù)"ID="0010TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0010"RUNTYPE="DMLSDATAFLAG="DPSI0010OU=""IN=""TRIGGER="" ID="0010"TYPE="RUNCMD"CONTENT="SELECTFROMWHERERUNFLAG='1'ANDNODESTATUS='2'2、如到數(shù)據(jù)，則繼續(xù)，未到數(shù)據(jù)，等待下一時(shí)間重3、端主控對(duì)到數(shù)據(jù)進(jìn)行組裝為981報(bào)文格4、端主控將981報(bào)文放入發(fā)送隊(duì)列表5、端發(fā)送進(jìn)程將未處理的報(bào)文放置MQ隊(duì)列，并更改發(fā)送標(biāo)識(shí)1、服務(wù)端接收?qǐng)?bào)文進(jìn)程從MQ中報(bào)文，放置接收隊(duì)列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的數(shù)據(jù)配置為： PMISPOST9906--表 PMCSPCST0001--目標(biāo)表 5、服務(wù)端報(bào)文處理主控PMCSPOST9842的關(guān)系，將到的數(shù)據(jù)進(jìn)行入庫(kù)原始 對(duì)應(yīng) 對(duì)應(yīng)原始數(shù)據(jù)字段 節(jié)點(diǎn)代 PSAS批量任務(wù)進(jìn)度信息功能PSAS批量PSAS批量任務(wù)進(jìn)度信息，根據(jù)批量任務(wù)進(jìn)度表中的數(shù)據(jù)記錄，定時(shí)輪詢是否有狀態(tài)處理失敗的記錄，則PSAS批量任務(wù)進(jìn)度信息PSAS批量節(jié)點(diǎn)定義INSERTINSERT數(shù)據(jù)載入數(shù)據(jù)載入信息系統(tǒng)數(shù)據(jù)INSERT信息系統(tǒng)數(shù)據(jù)981端處理流1、端主控配置文件，解析配置文件進(jìn)行，涉及該項(xiàng)的配置文件如下ID="0000"TYPE="MAIN"IP="6"PORT="60000"DESC="PBCS、PSAS定義文件ID="0001TYPE="LINKDBTYPE="ORACLEDBNAME="ORAPSAS"DBUSER="psas"DBPWD="psasDESC="PSASID="0010TYPE="PROCFLAG="10DESC="定義執(zhí)行進(jìn)程標(biāo)識(shí)用于處理PSASID="0020TYPE="ITEMSTRTIME="18:30:00"ENDTIME="20:30:00INTERVAL="60PROC="NODE.0010"EVENT="EVENT.0020"DESC="PSAS處理進(jìn)度信息"ID="0020"TYPE="EVENT"ACTIVE="ACTIVE.0020"DESC="PSAS的PMISPOST9903表數(shù)據(jù)表中滿足條件的ID="0020TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0020"RUNTYPE="DMLSDATAFLAG="DPSI0020OU=""IN=""TRIGGER="" ID="0020"TYPE="RUNCMD"CONTENT="SELECTFROMWHERECOLLSTATUS='4'2、如到數(shù)據(jù)，則繼續(xù)，未到數(shù)據(jù)，等待下一時(shí)間重3、端主控對(duì)到數(shù)據(jù)進(jìn)行組裝為981報(bào)文格4、端主控將981報(bào)文放入發(fā)送隊(duì)列表5、端發(fā)送進(jìn)程將未處理的報(bào)文放置MQ隊(duì)列，并更改發(fā)送標(biāo)識(shí)1、服務(wù)端接收?qǐng)?bào)文進(jìn)程從MQ中報(bào)文，放置接收隊(duì)列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的數(shù)據(jù)配置為： PMISPOST9903--表 PMCSPCST0001 5、服務(wù)端報(bào)文處理主控PMCSPOST9842的關(guān)系，將到的數(shù)據(jù)進(jìn)行入庫(kù) 被 標(biāo) 狀 PSASETL項(xiàng)目進(jìn)度信息功能PSASETLPSASETLPMISPOST9911ETL處理失敗的數(shù)據(jù)，則PSASETLPSASETLINSERTINSERT數(shù)據(jù)載入數(shù)據(jù)載入信息系統(tǒng)數(shù)據(jù)INSERT信息系統(tǒng)數(shù)據(jù)981端處理流1、端主控配置文件，解析配置文件進(jìn)行，涉及該項(xiàng)的配置文件如下ID="0000"TYPE="MAIN"IP="6"PORT="60000"DESC="PBCS、PSAS定義文件ID="0001TYPE="LINKDBTYPE="ORACLEDBNAME="ORAPSAS"DBUSER="psas"DBPWD="psasDESC="PSASID="0010TYPE="PROCFLAG="10DESC="定義執(zhí)行進(jìn)程標(biāo)識(shí)用于處理PSASID="0030TYPE="ITEMSTRTIME="18:30:00"ENDTIME="20:30:00INTERVAL="60PROC="NODE.0010"EVENT="EVENT.0030"DESC="PSAS的ETL進(jìn)度信息"ID="0030"TYPE="EVENT"ACTIVE="ACTIVE.0030"DESC="PSAS的PMISPOST9911表數(shù)據(jù)表中滿足條件的ID="0030TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0020"RUNTYPE="DMLSDATAFLAG="DPSI0020OU=""IN=""TRIGGER="" ID="0030"TYPE="RUNCMD"CONTENT="SELECTFROMpmispost9911WHEREDEALSTATUS='4'"2、如到數(shù)據(jù)，則繼續(xù)，未到數(shù)據(jù)，等待下一時(shí)間重3、端主控對(duì)到數(shù)據(jù)進(jìn)行組裝為981報(bào)文格4、端主控將981報(bào)文放入發(fā)送隊(duì)列表5、端發(fā)送進(jìn)程將未處理的報(bào)文放置MQ隊(duì)列，并更改發(fā)送標(biāo)識(shí)1、服務(wù)端接收?qǐng)?bào)文進(jìn)程從MQ中報(bào)文，放置接收隊(duì)列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的數(shù)據(jù)配置為： PMISPOST9911--表 PMCSPCST0001--目標(biāo)表 5、服務(wù)端報(bào)文處理主控PMCSPOST9842的關(guān)系，將到的數(shù)據(jù)進(jìn)行入庫(kù) ETL日期 ETL項(xiàng)目 ETL ETL ETL ETL系統(tǒng)自檢功自檢PSAS服務(wù)端與端通訊正PSASPSAS服務(wù)端與端通訊檢查，檢查PSAS服務(wù)端與端通訊是否正常PSAS服務(wù)端與端通訊自檢任信息系統(tǒng)數(shù)據(jù)SQLPMCSPOST980信息定義正確到PSAS服務(wù)端與端通訊信PMCSPOST9802檢查節(jié)點(diǎn)運(yùn)行狀態(tài)是否與預(yù)期值相符，執(zhí)行以程PMCSPOST9804SQL0，PSASM03全天檢查20PMCSPOST9803如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值相符，則顯示“PSAS服務(wù)端與端通訊正常如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值不匹配，則顯示警報(bào)信息“PSAS服務(wù)端與端通訊不正常SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDM03=’2’自檢PSAS進(jìn)度生成完自檢PSAS進(jìn)。自檢PSAS進(jìn)信息系統(tǒng)數(shù)據(jù)SQLPMCSPOST980信息定義正確到PSAS進(jìn)度信PMCSPOST9802檢查節(jié)點(diǎn)運(yùn)行狀態(tài)是否與預(yù)期值相符，執(zhí)行以程PMCSPOST9804SQL的數(shù)據(jù)行數(shù)，如返回值大于0，則PSAS存在異常M04未下午18:00開始檢查至20:00結(jié) 10分鐘檢查一 PMCSPOST9803如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值相符，則顯示“PSAS進(jìn)度生成失敗如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值不匹配，則顯示警報(bào)信息“PMCS服務(wù)端與端通訊不正常SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDANDPSASETL處理完P(guān)SASETL自檢PSASETL處理，檢查ETL處理進(jìn)度是否正常，異常則PSASETL信息系統(tǒng)數(shù)據(jù)SQLPMCSPOST980信息定義正確到PSAS服務(wù)端與端通訊信PMCSPOST9802檢查節(jié)點(diǎn)運(yùn)行狀態(tài)是否與預(yù)期值相符，執(zhí)行以程PMCSPOST9804SQL0，PSASM07下午18:00開始檢查至20:00結(jié) 10分鐘檢查一PMCSPOST9803如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值相符，則顯示“PSAS服務(wù)端與端通訊正常如果節(jié)點(diǎn)運(yùn)行狀態(tài)與預(yù)期值不匹配，則顯示警報(bào)信息“PSASETL處理失敗SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDAND自檢PMCS服務(wù)端與端通訊正在計(jì)劃時(shí)間點(diǎn)（9：00，14：00）檢查PMCS服務(wù)端與端通訊是否正常PMCS服務(wù)端與端通訊自檢任批量節(jié)點(diǎn)定義SQLPMCSPOST980信息定義設(shè)置PMISP