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

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