支付业务监控系统改造项目204产品概要设计说明书

2014-08-【A】创2015-01-【M】正式注：变化状态：A—增加，M—修改，D—删引 背 编写目 范 定义和缩略 参考资 标 从属关 总体设计概 设计原 设计思 系统结 与算 通用数据工 灵活数据处理技 灵活设 主要功 关键应用模块设 客户端功能模块设 系统中国地 C业务 C业务量图 自检任务项安排管 自检任务项执行管 任务项执行步骤管 事件信息定义管 自检任务事件记录管 代码简称对应管 接入点信息维度管 支付系统业务量汇总查 支付系统业务量均线查 当天系统状态变化情况查 功能模块设 服 功能模 系统自检功能模 子系统设 报文客户端功能开放功能引背随着第二代支付系统的投产运行及后续系统的不断开发、完善，业务管理部、运行部需要运维的系统数量、系统风险也在逐渐增加。然而当前业务系统所具有的功能，并不能使运维实时了解所有系统运行的异常、存在的风险，并出现的问题，为系统的管理和带来诸多不便。2014年3月，业务管理部、运行部就二代系统上线以来存在的业务的不足，提出了新的功能需求，要求提供各系统的运行时序监控，大小额、分时业务量，系统自检及事件等功能。针对本需求的二代交易系统的功能已在PMCS系统上改造完成，并于2014年第二季度末在生产环境成功上线。本项目是功能的延续与完善，主要目标是增加E系统、信息系统的功能，完善、优化展示效果，并对PMS端、服务端进行改造，实现灵活的数据处理功能。编写目范本文的预期读者为业务需求方、项目主管、项目协管、项目组成员，以及质量管理组、测试组。本文档包括引言、功能概述、功能、功能模块等章节定义和缩略（The2ndGenerationChinaNationalAdvancedPaymentSystem,CNAPS2）支付业务系统（PaymentMonitorControlSystem,参考资《支付业务系统改造项目（2014）需求规格说明书《支付业务系统改造项目（2014）技术总体方案（PMCS（PSAS（《二代支付系统数据库逻辑设计（PBCS部分标（OSSP_V3.1.0 该工具库对常用的数据库操作及查询结果集进行了封装，通过的接口将数据库中的记录为实体信息供上层应用，而使之不必关心数据涉及到的具体细节，如根据配置文件中设定的数据库类型及方式自动选择对应的驱动数据库，提供对ORACLE/DB2数据库的驱动（XA及非XA版本），并可扩展至对其他数据库的支持。数据库驱动尽可能使用原厂API实现（对于ORACLE使用OCI方式，DB2使用CLI-ODBC方式），提高了效率。提供结构化的查询接口以及原生SQL接口多种结果集输出方式，既可将检索结果至指定的实体对象中，也可以将一些在实际的应用场景中，相比原来的SQL方式，在性能上不会有太大的下降。一般操作基本能保持效率持平，对于一些关于LOB字段的操作性能会有提使用方本项目在灵活数据处理功能中使用了通用数据工具，来灵活oracle、db2数据SQL语句，进行数据处理。通用数据工具由应用研究室开发，暂未纳入开发中心公共库中。本项目在使用时，PMCS源码添加至项目代码中，以用于编程开发。使用风事事灵活数据处逻辑定时任定时任务及事件触发配12、任务执行模块从队列中事件，并根据事件所对应的执行列表，执行任务对象说表示触发事件，用于定义事件与处理动作的对应关系(1-SQLACTIVE（1-对象模定关关关产配置文件模NODEITEMEVENT域：定义了事件所关联的处理行为信息，允许一个事件对应多个处理行为。TRIGGER域：定义了触发器的触发条件，触发事件信息，仅限于任务项的。ACTIVE域：定义了行为所要执行的动作、输入、输出、事件等等。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上的触发器,当 注：CONTENT中定义了匹配相同时，执行哪些内容，匹配不相同执行哪些内容。这些内容可以是ACTIVE,EVENT,CONTINUE,BREAKID="0000"TYPE="ACTIVE"RUNCMD="CMD.0000"RUNTYPE="DMLS"DATAID=""MSGID=””OU="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”OU=""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为返回信息数据标定数据标识用来定义数据的类型，以供服务端根据数据标识处理数编14M-I-B-O-数据格定本数据格式数据的格式，用来进行数据传输及解析编第一行：数据标识+批次号+记录数+时第二行至N行：数据，“|@|”为列分隔串“&&&\n”为行分隔示例：DPSM0001|@|00000001|@|10|@|1000|@|2014-09-0212:00:21&&& 队列报文说任务报报文示例：INT.910<0001<2014-09-0212:00:21数据发送指令报报文功能：由执行主控在数据首次写入队列前，将本报文写入队列，用于获取后备注：消息类型为ACTIVE域中的msgid值，用于端从队列中数据内容。可用数据发送内容报备注：批次号由1顺序，当结束标志为0时，表示本次完成，结束标志为时，表示还有后续数据。数据内容中以坚线作为列分隔符，UNIX灵活设设计原灵活功能是原功能的一个扩展，支持oracle、db2的定制化。本功能模式，也支持服务端直接数据模式基本处理流，灵活数据处理功能使用通过数据工具，按照配置文件进行定制化的数据临时至AIX队列管理器中由修改后PMCS原程序从队列管理器中数据，cncc.981.001.01（数据发送报文）MQ发送到服务端。服务数据写入指定的表及字段中。至此，完成了数据、传输、入库的过程。， 主要功1、通用的功能，可实现一点多源的定时功能23、重新设计的展示页面，提高用户的使用体验4、增加对PSAS、PMCS系统的功能关键应用模客户端功能系统前分时段业务量与M日均线进行对比，如偏差超过+-N%RRRR无操作用户登录系统，点击左菜单“N0系统->N0100系统默认显示当日大额业务量趋势图3）1/C/专属接入如果查询条件searchType:C,则查询条件otherType为C选项。如果查询条件searchType:otherTypejson1/C/专属接入时统时序界RR无操作用户登录系统，点击左菜单“N0系统->N0100系统页面3）1json1自检任务展[查询操作统示实时HVPS、BEPS、IBPS、NETS、SAPS的系统自检情况RR操作用户登录系统，点击左菜单“N0系统->N0100系统3）5json1[手动检查操作统字段为“1：R、操作用户登录系统，点击左菜单“N0系统->N0100系统5json系统当前状统各个系统状态视RR无操作用户登录系统，点击左菜单“N0系统->N0100系统页面3）1无json1统业务系统事件示业务系统事件界RR操作用户登录系统，点击左菜单“N0系统->N0100系统1json1中国地图C业务统中国地图C业务地图展示区，根据排序类型地图颜色由深（高）至浅（低。右侧为表格数信息展示区，分为1-10名、11-20名、21-32名。系统会根据条件进行刷新数据中国地图C业务量界RC大额支付业务量R小额支付类业务R支付业务量实时R无默认显示当前系统日期的PMCS各C业务量数据3）4)json1地图展示区，根据排序类型地图颜色由深（名高）至浅（低）表1-1011-2021-32名。系统会根据条件进行刷新数据C业务量图统C柱状图形式实时各C大额、小额、业务量数据。系统默认查询当天大32C业务量及总量笔数金额信息。默认条件为按照笔数排序。也可按照排序类型510名CRC大额支付业务量R小额支付类业务R支付业务量实时R无操作用户登录系统，点击左菜单“N0系统->N0300C业务量图表默认显示当前系统日期的PMCS各C业务量数据510json1展示32C业务量及总量笔数金额信息统统R工作日/1工作日/修统R、W3）12自检任务项查统R1修统R、W3）12任务项执行查统R执行SQL1执行SQL修统R、W3）12执行SQL事件信息定查统R1修统R、W3）12明统oR3）1自检任务事件记录管查统理R1修统理R、W3）12明统理oR3）1代码简称对查统R1修统R、W3）12新统WW3）12删统R、W3）12接入点信息查统Rc所属1号所属码修统R、W操作用户登录系统，点击左菜单“N1系统参数管理->N1700接入点信息维3）c所属12号所属码支付系统业务量汇总查查统R1C/法人//专属接入支付系统业务量均线查查统R1C/法人//专属接入当天系统状态变化情况查统R1功能模服灵活数据处理管理功PmisPMCS、PSAS服务端及端均可使初始化1、从应该安装$APP_HOMEpmiscfg.iniNODE、ITEM2、根据pmiscfg.ini配置文件中的NODE域中QUEUE配置，创建消息队列，设置消息最大长度。3、根据pmiscfg.iniNODEPROCPROC的IDFLAG）（）主控制1、进程休眠52、依次ITEM域中的每行数据，判断是否触发事件，如果符合触发条件则将事件报文写入队a）触发条件：STRTIMEENDTIME&&3、重复流程1灵活数据处理执行功PMCSPMCS、PSAS服务端 端均可使初始化1、从应该安装 2NODE.QUEUEQPATH a)c)NODE.PROC.MSGIDINT.9105EVENTACTIVE从执行栈中获取末端取一条待执行的项，执行下面的步骤，否则提交事务，执行步骤1a)ACTIVE，ACTIVE块。c）EVENT，EVENTCOMMIT，6。f）BREAK，ROLLBACK ACTIVE ACTIVE.IDACTIVEACTIVERUNTYPE，DATAFLAG，MSGIDIN,OURUNTYPE”DMLS”，根据ACTIVE.RUNCMD获取SQL代码，至缓冲区。d）调用通用数据工具，执行SQL语句。调用通用数据工具，获取查询结果，按ACTIVE.OU参数保存输出信息DATAFLAGINT.920,INT.921INT.921ACTIVEOU.CODE,OU.EMSG,OU.LIST（返回信息 b）根据ACTIVE.RUNCMD获取SQL代码，至缓冲区。d）调用通用数据工具，执行SQL语句。e）ACTIVEOU.CODE,OU.EMSG,OU.LIST ACTIVE.TRIGGERTRIGGERTRIGGER流程TRIGGER.IDTRIGGERTRIGGERWHEN、ON、CONTENTTRIGGER.WHEN如果左值或右值了OU的信息，则解析后，将获取的值进行替换CONTENTYCONTENT为N（EVENT，ACTIVE）EVENT程EVENT.IDEVENTMSGIDMSGIDINT.910数据传Pmis981PMCS本模块仅限于PMCS端，做为定时的动态模块主流程查找消息类型为920数据发送指令消息，如果消息存在，则执行以程，否则返回920根据920报文中的消息类型获取数据（INT.921报文），以等待方式获取消息调用公共接口函数，解析921报文内容，获取数据并按原PMCS格式进行转化 ew）,将数据写PMISPOST9904表。跳转到步骤4。如果921报文中数据标志为0，则按步骤6进行数据发送2数据写入流程strOutBuffercncc.981.001.01PMISPOST9904业务量日线与月线汇总支付系统业务量汇总表-支付系统业务量汇总表1、灵活处理SQL服务配置文200：0001：003SQLINSERTINTOPMCSPOST9832SELECTB.NODECODE,--节点代码 B.NODETYPE,--节点类型B.RECVDATE,--受理日期 FROM(SELECTA.NODECODE ASNODECODE,--节点代码 ASSYSCODE,--系统号 ASNODETYPE,--节点类型 ASRECVDATE,--受理日期SUM(A.SENDNUM)ASSENDNUM,--发送总笔数SUM(A.SENDAMT)ASSENDAMT,--发送总金额SUM(A.RECVNUM)ASRECVNUM,--接收总笔数SUM(A.RECVAMT)AS --接收总金FROMPMCSPOST9830WHERERECVDATE<TO_CHAR(SYSDATE,'YYYYMMDD')ANDRECVDATENOTIN(SELECTDISTINCTRECVDATEFROMGROUPBYA.NODECODE,A.SYSCODE,A.NODETYPE,A.RECVDATE)数据载能模块处理端数据，根据PMISPOST9841、PMISPOST9842表中的数据，入库数据装载数据装载信息系统数据信息系统数据9811、服务端处理主控程序PmisMesgMainSvr轮询PMISPOST9905表，根据未处理报文的表调svr_dataload.pc2、svr_dataload.pc3、定义全局变量数据标识号、批次号、记录数（每条数据的字段数）、时间、定义全局变EXECSQLBEGINDECLAREcharV_DODE[8+1]; charV_COLLNO[8+1]; charV_COLLECTTIME[29+1];//时间char #define EXECSQLENDDECLARE FIELD_NUM4CleanDataByBanchNo(LPCSTRpBanchNo)PMCSPC00015InsertDataToDB(LPCSTRpDataStream,intnRecordNum)函数，对报文体内容继续处理。时间字段，并更新上述全局变量如：if(FParseData((char*)pDataStream,1,FIELD_LENGTH,&V_DODE)=={}、pDataStreamEXECSQLBEGINDECLAREchar DataLoad //PMCSPOST9842char char char //存放SQLEXECSQLENDDECLAREPMCSPIST9841、判断PMCSPOST9841中的数据载入方式，如为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，并执行该SQL PSAS节点信息功能PSAS节点下的节点运行状态，如节点运行状态为异常，则PSAS节点信息功能PSAS批量节点定义INSERTINSERT数据载入数据载入信息系统数据INSERT信息系统数据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="定义执行进程标识用于处理PSASID="0010TYPE="ITEMSTRTIME="18:30:00"ENDTIME="20:30:00INTERVAL="60PROC="NODE.0010"EVENT="EVENT.0010"DESC="PSASPSAS节点信息功能"ID="0010"TYPE="EVENT"ACTIVE="ACTIVE.0010"DESC="PSAS.PMISPOST9906表中满足条件的数据"ID="0010TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0010"RUNTYPE="DMLSDATAFLAG="DPSI0010OU=""IN=""TRIGGER="" ID="0010"TYPE="RUNCMD"CONTENT="SELECTFROMWHERERUNFLAG='1'ANDNODESTATUS='2'2、如到数据，则继续，未到数据，等待下一时间重3、端主控对到数据进行组装为981报文格4、端主控将981报文放入发送队列表5、端发送进程将未处理的报文放置MQ队列，并更改发送标识1、服务端接收报文进程从MQ中报文，放置接收队列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的数据配置为： PMISPOST9906--表 PMCSPCST0001--目标表 5、服务端报文处理主控PMCSPOST9842的关系，将到的数据进行入库原始 对应 对应原始数据字段 节点代 PSAS批量任务进度信息功能PSAS批量PSAS批量任务进度信息，根据批量任务进度表中的数据记录，定时轮询是否有状态处理失败的记录，则PSAS批量任务进度信息PSAS批量节点定义INSERTINSERT数据载入数据载入信息系统数据INSERT信息系统数据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="定义执行进程标识用于处理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表数据表中满足条件的ID="0020TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0020"RUNTYPE="DMLSDATAFLAG="DPSI0020OU=""IN=""TRIGGER="" ID="0020"TYPE="RUNCMD"CONTENT="SELECTFROMWHERECOLLSTATUS='4'2、如到数据，则继续，未到数据，等待下一时间重3、端主控对到数据进行组装为981报文格4、端主控将981报文放入发送队列表5、端发送进程将未处理的报文放置MQ队列，并更改发送标识1、服务端接收报文进程从MQ中报文，放置接收队列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的数据配置为： PMISPOST9903--表 PMCSPCST0001 5、服务端报文处理主控PMCSPOST9842的关系，将到的数据进行入库 被 标 状 PSASETL项目进度信息功能PSASETLPSASETLPMISPOST9911ETL处理失败的数据，则PSASETLPSASETLINSERTINSERT数据载入数据载入信息系统数据INSERT信息系统数据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="定义执行进程标识用于处理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表数据表中满足条件的ID="0030TYPE="ACTIVELINK="NODE.0001"RUNCMD="CMD.0020"RUNTYPE="DMLSDATAFLAG="DPSI0020OU=""IN=""TRIGGER="" ID="0030"TYPE="RUNCMD"CONTENT="SELECTFROMpmispost9911WHEREDEALSTATUS='4'"2、如到数据，则继续，未到数据，等待下一时间重3、端主控对到数据进行组装为981报文格4、端主控将981报文放入发送队列表5、端发送进程将未处理的报文放置MQ队列，并更改发送标识1、服务端接收报文进程从MQ中报文，放置接收队列表PMISPOST9905中2PMISPOST99053SQL4、PMCSPOST9841表中的数据配置为： PMISPOST9911--表 PMCSPCST0001--目标表 5、服务端报文处理主控PMCSPOST9842的关系，将到的数据进行入库 ETL日期 ETL项目 ETL ETL ETL ETL系统自检功自检PSAS服务端与端通讯正PSASPSAS服务端与端通讯检查，检查PSAS服务端与端通讯是否正常PSAS服务端与端通讯自检任信息系统数据SQLPMCSPOST980信息定义正确到PSAS服务端与端通讯信PMCSPOST9802检查节点运行状态是否与预期值相符，执行以程PMCSPOST9804SQL0，PSASM03全天检查20PMCSPOST9803如果节点运行状态与预期值相符，则显示“PSAS服务端与端通讯正常如果节点运行状态与预期值不匹配，则显示警报信息“PSAS服务端与端通讯不正常SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDM03=’2’自检PSAS进度生成完自检PSAS进。自检PSAS进信息系统数据SQLPMCSPOST980信息定义正确到PSAS进度信PMCSPOST9802检查节点运行状态是否与预期值相符，执行以程PMCSPOST9804SQL的数据行数，如返回值大于0，则PSAS存在异常M04未下午18:00开始检查至20:00结 10分钟检查一 PMCSPOST9803如果节点运行状态与预期值相符，则显示“PSAS进度生成失败如果节点运行状态与预期值不匹配，则显示警报信息“PMCS服务端与端通讯不正常SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDANDPSASETL处理完PSASETL自检PSASETL处理，检查ETL处理进度是否正常，异常则PSASETL信息系统数据SQLPMCSPOST980信息定义正确到PSAS服务端与端通讯信PMCSPOST9802检查节点运行状态是否与预期值相符，执行以程PMCSPOST9804SQL0，PSASM07下午18:00开始检查至20:00结 10分钟检查一PMCSPOST9803如果节点运行状态与预期值相符，则显示“PSAS服务端与端通讯正常如果节点运行状态与预期值不匹配，则显示警报信息“PSASETL处理失败SELECTCOUNT(*)FROMPMCSPCST0001WHEREDANDAND自检PMCS服务端与端通讯正在计划时间点（9：00，14：00）检查PMCS服务端与端通讯是否正常PMCS服务端与端通讯自检任批量节点定义SQLPMCSPOST980信息定义设置PMISP