精选数据交换详细设计说明书

精选数据交换详细设计说明书PAGE

江苏省并联审批平台数据交换系统管理详细设计说明书

文档编号：SN/SD-MB-002保密级别：保密版本：V1.0修改日期：2012-09-14目录1引言 11.1编写目的 11.2工程背景 11.3目前状况 12详细说明 12.1数据库设计 12.1.1数据库命名规那么 12.1.2表空间命名规那么 12.2逻辑结构 22.2.1T_USER〔用户信息〕 22.2.2T_ORG(机构信息) 22.2.3T_MENU〔菜单信息〕 32.2.4T_USER_MENU(用户菜单信息) 32.2.5T_USER_MANAGE_ORG〔用户数据权限信息〕 32.2.6T_TASK_DEF〔任务定义〕 42.2.7T_ENDPOINT〔端点配置〕 42.2.8T_TASK_CTRL〔任务运行控制〕 52.2.9T_DICT_TRANS〔传输方式字典〕 52.2.10T_DICT_CDC〔增量识别机制字典〕 62.2.11T_DATA_QUEUE〔待传数据队列〕 62.2.12T_TRANS_LOG〔数据交换日志〕 62.2.13T_SYS_RT_LOG〔运行时日志〕 62.2.14T_DICT_FMT〔数据格式字典〕 72.2.15T_NODE_ORG〔交换节点表〕 72.2.16T_SYS_LOGING_LOG〔登录日志〕 82.2.17T_SYS_LOGING_LOG_BACKUP〔登录日志备份〕 82.2.18T_SYS_USE_LOG〔系统日志〕 82.2.19T_SYS_USE_LOG_BACKUP〔系统日志备份〕 92.2.20T_DICT_MAIN〔字典项主表〕 92.2.21T_DICT_MAIN_VALUE〔字典值表〕 102.2.22T_RT_INST〔实例管理表〕 102.3系统菜单 102.4用户及权限管理 112.4.1功能说明 112.4.2页面设计 112.4.3相关规那么 142.4.4相关SQL 142.5机构管理 152.5.1功能说明 152.5.2页面设计 152.5.3相关规那么 152.5.4相关SQL 162.6交换管理 162.6.1功能说明 162.6.2用例图 172.6.3用例分析 172.6.4页面设计 172.6.5相关规那么 182.6.6相关SQL 182.7日志管理 192.7.1功能说明 192.7.2用例图 192.7.3用例分析 192.7.4页面设计 202.7.5相关规那么 212.7.6相关SQl 212.8字典管理〔暂缓〕 222.8.1功能说明 222.8.2用例图 222.8.3用例分析 222.8.4页面设计 232.8.5相关规那么 232.8.6相关SQL 242.9任务管理 242.9.1模块概述 242.9.2任务定义 252.9.3任务控制 332.9.4错误日志 352.9.5实例管理 372.9.6任务组管理〔暂缓〕 382.9.7运行控制〔暂未实现〕 392.10任务运行 402.10.1模块概述 402.10.2根本流程 402.10.3映射规那么文件 442.10.4外部接口 572.10.5内部接口 612.10.6交换日志〔暂缓〕 662.10.7运行时事件日志 672.10.8任务自动启停 682.10.9异常处理 682.10.10运行方式 692.10.11安装部署 69引言编写目的工程背景目前状况详细说明数据展示时根据机构权限过滤此次暂不考虑数据库设计数据库命名规那么数据库主键全部采用是32位UUID,针对Oracle数据库采用char(32)表名以“T_〞开头，视图名以“V_〞开头，函数以“FN_〞开头，存储过程以“SP_〞触发器以“TR_〞针对数据库中相应的字符串，提供以下标准性的字符升序约定：短字符串：varchar2(20),如姓名、电子邮件，类别等。中字符串：varchar2(100),如地址、部门名称等。长字符串：varchar2(1000),如处理意见，备注等。文本型字符串：CLOB，如摘要信息等。表空间命名规那么以TS开头加‘_’命名各个表空间，具体内容如下：TS_LOB：大字段存储TS_INDEX：索引表空间TS_DATA：一般数据存储TS_TEMP：临时数据表空间TS_HISTORY：归档数据存储表空间逻辑结构T_USER〔用户信息〕NameCodeCommentDataTypePFMUSER_IDUSER_ID主键CHAR(32)XXSTAFF_CODESTAFF_CODE用户名VARCHAR2(100)PASSWORDPASSWORD登录密码VARCHAR2(100)BELONG_ORG_IDBELONG_ORG_ID所属机构IDCHAR(32)POSITIONPOSITION用户职务VARCHAR2(100)USER_NAMEUSER_NAME姓名VARCHAR2(20)EMAILEMAIL电子邮箱VARCHAR2(100)LINK_TELLINK_TEL联系电话VARCHAR2(20)STATESTATE状态(1有效，0无效)NUMBER(1)CREATE_ORGCREATE_ORG创立机构CHAR(32)CREATE_DATECREATE_DATE创立时间，精确到秒DATEUSER_TYPEUSER_TYPE用户类型(A管理员，U普通用户)CHAR(1)T_ORG(机构信息)NameCodeCommentDataTypePFMORG_IDORG_ID主键CHAR(32)XXORG_CODEORG_CODE机构代码VARCHAR2(10)ORG_NAMEORG_NAME机构名称VARCHAR2(100)SIMPLE_NAMESIMPLE_NAME机构简称VARCHAR2(50)PARENT_ORG_IDPARENT_ORG_ID上级机构IDCHAR(32)VER_ORG_IDVER_ORG_ID垂管机构父节点IDCHAR(32)ORG_TYPEORG_TYPE机构类型(00省政府，01省级部门，02市政府，03市级部门，04区县政府，05区县部门，)CHAR(2)CREATE_DATECREATE_DATE创立时间，精确到秒DATESTATESTATE状态(1有效，0无效)NUMBER(1)ORDORD机构顺序NUMBER(4)T_MENU〔菜单信息〕NameCodeCommentDataTypePFMMENU_IDMENU_ID主键CHAR(32)XXPARENT_MENU_IDPARENT_MENU_ID父级菜单IDCHAR(32)MENU_TITLEMENU_TITLE菜单标题VARCHAR2(50)MENU_NAMEMENU_NAME菜单名称VARCHAR2(50)MENU_TYPEMENU_TYPE菜单分类(0系统管理，1非系统管理)NUMBER(1)MENU_DESCRIBEMENU_DESCRIBE菜单描述VARCHAR2(200)MENU_PICMENU_PIC菜单图标VARCHAR2(100)MENU_URLMENU_URL菜单URLVARCHAR2(1000)ORDORD顺序号NUMBER(4)CREATE_DATECREATE_DATE创立时间，精确到秒DATESTATESTATE状态(1有效，0无效)NUMBER(1)T_USER_MENU(用户菜单信息)NameCodeCommentDataTypePFMUSER_MENU_IDUSER_MENU_ID主键CHAR(32)XXMENU_IDMENU_ID菜单IDCHAR(32)USER_IDUSER_ID用户IDCHAR(32)CREATE_ORGCREATE_ORG创立机构CHAR(32)CREATE_DATECREATE_DATE创立时间DATET_USER_MANAGE_ORG〔用户数据权限信息〕NameCodeCommentDataTypePFMMANAGE_ORG_IDMANAGE_ORG_ID主键CHAR(32)XXUSER_IDUSER_ID用户IDCHAR(32)MANAGE_ORGMANAGE_ORG1省级权限，2市级权限NUMBER(1)CREATE_ORGCREATE_ORG创立机构CHAR(32)CREATE_DATECREATE_DATE创立时间DATET_TASK_DEF〔任务定义〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXTASK_NAMETASK_NAME名称VARCHAR2(100)TASK_DESCTASK_DESC描述CLOBORG_IDORG_ID所属机构CHAR(32)CREATE_USERCREATE_USER创立人CHAR(32)CREATE_DATECREATE_DATE创立时间DATETASK_STATETASK_STATE1启用0停用NUMBER(1)TRANS_SCRTRANS_SCR转换脚本CLOBSTATESTATE删除标记位NUMBER(1)STATE_DATESTATE_DATE创立/修改时间DATEINST_IDINST_ID执行此任务的运行时平台实例CHAR(32)T_ENDPOINT〔端点配置〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXEP_TYPEEP_TYPE端点类型.0源端点1目标端点NUMBER(1)TASK_IDTASK_ID所属任务CHAR(32)EP_NAMEEP_NAME端点名称VARCHAR2(100)NODE_IDNODE_ID所属节点CHAR(32)MAP_FILEMAP_FILE映射规那么文件CLOBFMT_IDFMT_ID数据格式NUMBER(8)TRANS_IDTRANS_ID传输方式NUMBER(8)DB_TYPE_IDDB_TYPE_ID数据库类型NUMBER(8)JDBC_URLJDBC_URLJDBC连接串VARCHAR2(100)JDBC_USERJDBC_USERJDBC用户名VARCHAR2(100)JDBC_PSWDJDBC_PSWDJDBC密码SHA的HEX散列值CHAR(32)WS_USERWS_USERWS用户名VARCHAR2(100)WS_PWSDWS_PWSDWS密码SHA的HEX散列值CHAR(32)S_CDC_IDS_CDC_ID增量识别机制NUMBER(8)S_TSS_TS时间戳字段VARCHAR2(20)S_TS_DBS_TS_DB时间戳子段是否使用数据库字段.0否1是NUMBER(1)S_TIME_LAGS_TIME_LAG源端点与本系统的保险时差，单位分钟NUMBER(8)D_DB_OPD_DB_OP目标端点数据库操作.位运算.增改删都支持为111,即十进制7NUMBER(1)D_DB_CONFLICTD_DB_CONFLICT目标端点数据库操作时,主键冲突的处理.0合并1丢弃源2丢弃目标3改变主键插入NUMBER(1)D_WS_URLD_WS_URL

VARCHAR2(100)D_CONSIS_MAPD_CONSIS_MAP(目标端点)是否使用和源端点一致的映射规那么NUMBER(1)T_TASK_CTRL〔任务运行控制〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXTASK_IDTASK_ID关联的任务CHAR(32)RUN_PERIODRUN_PERIOD任务可以运行的时间段,自动cron判断VARCHAR2(100)POLL_INTERVALPOLL_INTERVAL轮询间隔,自动cron判断VARCHAR2(100)DAILY_QUOTADAILY_QUOTA日配额控制的数据条数NUMBER(8)BATCH_SIZEBATCH_SIZE批量条数NUMBER(8)DEDICATED_VMDEDICATED_VM是否使用专用虚拟机运行任务NUMBER(1)VM_ARGSVM_ARGS虚拟机启动参数VARCHAR2(100)LAST_SCHELAST_SCHE上次调度时间DATELAST_RUNLAST_RUN上次交换数据时间DATELAST_TSLAST_TS上次交换的截止时间戳(源端点基于时间戳识别时)本系统数据库时间DATET_DICT_TRANS〔传输方式字典〕NameCodeCommentDataTypePFMIDID

NUMBER(8)XXCODECODE传输方式代码NUMBER(2)NAMENAME传输方式名称VARCHAR2(100)STATESTATE删除标记位NUMBER(1)T_DICT_CDC〔增量识别机制字典〕NameCodeCommentDateTypePFMIDID

NUMBER(8)XXCODECODE增量识别机制代码NUMBER(2)NAMENAME增量识别机制名称VARCHAR2(100)STATESTATE删除标记位NUMBER(1)T_DATA_QUEUE〔待传数据队列〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXTASK_IDTASK_ID所属的任务CHAR(32)D_EP_IDD_EP_ID目标端点CHAR(32)CREATE_DATECREATE_DATE数据创立时间DATEPATHPATH数据存放位置(数据必须被串行化到文件系统)VARCHAR2(100)LAST_TRANS_DATELAST_TRANS_DATE最后尝试传输的时间DATEFAILED_TIMESFAILED_TIMES已经失败次数NUMBER(8)T_TRANS_LOG〔数据交换日志〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXTASK_IDTASK_ID产生数据交换的任务CHAR(32)S_EP_IDS_EP_ID数据来源端点CHAR(32)D_EP_IDD_EP_ID数据目标端点CHAR(32)DATA_COUNTDATA_COUNT交换的数据条数NUMBER(8)DATA_KBDATA_KB交换的数据量NUMBER(8)START_DATESTART_DATE源端点发起数据交换的时间(以本系统获得数据的时刻计)DATEEND_DATEEND_DATE目标端点得到数据的时间(以本系统将数据成功发送给目标端点计)DATET_SYS_RT_LOG〔运行时日志〕NameCodeCommentDataTypePFMIDID

CHAR(32)XXSEVERITYSEVERITY严重度：0一般1警告2错误NUMBER(1)OCCUROCCUR事件发生阶段：0平台启动1任务启动2任务停止3任务运行NUMBER(1)EVENT_TYPEEVENT_TYPE事件类型：0数据交换成功1数据交换失败NUMBER(8)MESSAGEMESSAGE消息VARCHAR2(200)THREAD_NAMETHREAD_NAME线程名称VARCHAR2(50)ERR_STACKERR_STACK错误堆栈CLOBSOURCESOURCE事件源〔发生事件的对象〕〔对于OCCUR:1、2、3，存放TASK_ID〕CHAR(32)EVENT_TIMEEVENT_TIME时间发生时间DATET_DICT_FMT〔数据格式字典〕NameCodeCommentDataTypePFMIDID

NUMBER(8)XXCODECODE数据格式代码NUMBER(2)NAMENAME数据格式名称VARCHAR2(100)STATESTATE删除标记位NUMBER(1)T_NODE_ORG〔交换节点表〕NameCodeCommentDataTypePFMIDID节点IDCHAR(32)XNODE_NAMENODE_NAME节点名称VARCHAR2(100)BELONG_ORGBELONG_ORG机构ORGCHAR(32)CREATE_USER_IDCREATE_USER_ID创立人员IDCHAR(32)CREATE_DATECREATE_DATE创立时间，精确到日DATESTATE_DATESTATE_DATE修改时间，精确到日DATENODE_STATENODE_STATE节点状态1-有效0-无效NUMBER(1)STATESTATE删除标记位1-有效0-无效NUMBER(1)T_SYS_LOGING_LOG〔登录日志〕NameCodeCommentDataTypePFMIDID日志IDCHAR(32)XPERSON_IDPERSON_ID登录人员IDCHAR(32)PERSON_NAMEPERSON_NAME登录人员VARCHAR2(20)LOGING_TIMELOGING_TIME登录时间DATEEXIT_TIMEEXIT_TIME退出时间DATELOGING_IPLOGING_IP登录IPVARCHAR2(100)LOGING_MACLOGING_MAC客户机MAC地址VARCHAR2(100)CREATE_ORGCREATE_ORG创立机构CHAR(32)CREATE_DATECREATE_DATE创立时间，精确到秒DATESTATESTATE是否归档1-已归档0-未归档NUMBER(1)T_SYS_LOGING_LOG_BACKUP〔登录日志备份〕NameCodeCommentDataTypePFMIDID日志IDCHAR(32)XPERSON_IDPERSON_ID登录人员IDCHAR(32)PERSON_NAMEPERSON_NAME登录人员VARCHAR2(20)LOGING_TIMELOGING_TIME登录时间DATEEXIT_TIMEEXIT_TIME退出时间DATELOGING_IPLOGING_IP登录IPVARCHAR2(100)LOGING_MACLOGING_MAC客户机MAC地址VARCHAR2(100)CREATE_ORGCREATE_ORG创立机构CHAR(32)CREATE_DATECREATE_DATE创立时间，精确到秒DATEBACKUP_DATEBACKUP_DATE归档时间，精确到秒DATET_SYS_USE_LOG〔系统日志〕NameCodeCommentDataTypePFMIDID日志IDCHAR(32)XPERSON_IDPERSON_ID操作人员IDCHAR(32)PERSON_NAMEPERSON_NAME操作人员VARCHAR2(20)USE_IPUSE_IPIPVARCHAR2(100)USE_MACUSE_MAC客户机MAC地址VARCHAR2(100)MENU_TITLEMENU_TITLE操作模块标题VARCHAR2(100)USE_DESCREBEUSE_DESCREBE操作模块描述VARCHAR2(1000)CREATE_DATECREATE_DATE操作时间，精确到秒DATECREATE_ORGCREATE_ORG创立机构CHAR(32)STATESTATE是否归档1-已归档0-未归档NUMBER(1)T_SYS_USE_LOG_BACKUP〔系统日志备份〕NameCodeCommentDataTypePFMIDID日志IDCHAR(32)XPERSON_IDPERSON_ID操作人员IDCHAR(32)PERSON_NAMEPERSON_NAME操作人员VARCHAR2(20)USE_IPUSE_IPIPVARCHAR2(100)USE_MACUSE_MAC客户机MAC地址VARCHAR2(100)MENU_TITLEMENU_TITLE操作模块标题VARCHAR2(100)USE_DESCREBEUSE_DESCREBE操作模块描述VARCHAR2(1000)CREATE_DATECREATE_DATE操作时间，精确到秒DATECREATE_ORGCREATE_ORG创立机构CHAR(32)BACKUP_DATEBACKUP_DATE归档时间，精确到秒DATET_DICT_MAIN〔字典项主表〕NameCodeCommentDataTypePFMDICT_IDDICT_ID字典项IDNUMBER(8)XDICT_NAMEDICT_NAME字典项VARCHAR2(20)DICT_DESCRIPTDICT_DESCRIPT字典项描述VARCHAR2(1000)PARENT_DICT_IDPARENT_DICT_ID上级字典CHAR(32)ITEMITEM所属工程VARCHAR2(20)DICT_NODICT_NO字典编号VARCHAR2(20)CREATE_DATECREATE_DATE创立时间，精确到日DATECREATE_ORGCREATE_ORG创立机构CHAR(32)STATESTATE有效性1-有效0-无效NUMBER(1)T_DICT_MAIN_VALUE〔字典值表〕NameCodeCommentDataTypePFMDICT_VALUE_IDDICT_VALUE_ID字典值IDNUMBER(8)XDICT_IDDICT_ID字典项IDNUMBER(8)XDICT_VALUEDICT_VALUE字典值VARCHAR2(100)ORDORD顺序号NUMBER(4)CREATE_DATECREATE_DATE创立时间，精确到日DATESTATESTATE有效性1-有效0-无效NUMBER(1)T_RT_INST〔实例管理表〕NameCodeCommentDataTypePFMIDID标识符CHAR(32)XNAMENAME实例名称VARCHAR2(100)VM_ARGSVM_ARGS虚拟机启动参数VARCHAR2(100)HTTP_PORTHTTP_PORTHTTP侦听端口NUMBER(5)HTTPS_PORTHTTPS_PORTHTTPS侦听端口NUMBER(5)IPIP所在主机的IP地址VARCHAR2(1000)STATESTATE状态，1为显示，0为删除标记位CHAR(1)CREATE_USERCREATE_USER创立人CHAR(32)CREATE_DATECREATE_DATE创立时间DATEUPDATE_DATEUPDATE_DATE更新时间DATE系统菜单系统管理用户及权限管理机构管理交换管理登录日志系统日志任务管理任务定义任务控制错误日志实例管理用户及权限管理功能说明管理维护系统中用户的根本信息，包括：用户名、密码、电子邮箱、联系电话、所属部门、状态〔有效、无效〕。页面设计新增/编辑页面用户信息T_USER用户名STAFF_CODE密码PASSWORD姓名USER_NAME职务POSITION电子邮箱EMAIL联系电话LINK_TEL所属部门BELONG_ORG_ID数据权限过滤，省级权限展示全省的机构，市级权限展示登录用户所在市政府及其下级机构状态有效VSTATE提交关闭列表页面查询条件中所属部门进行数据权限过滤，省级权限展示全省的机构、市级权限展示当前登录用户所在机构及其下级机构。当查询条件全部为空时，列表查询数据根据数据权限进行过滤，省级权限查询全部数据、市级权限查询登录用户所在机构及其下级机构数据，示意SQL：省级权限数据查询范围省级权限查询全省的数据，列表中直接查询全表有效数据SELECT*FROMT_USER市级权限数据查询范围市级权限查询当前登录用户所在市政府及其下级机构的数据SELECT*FROMT_USERRWHERER.CREATE_ORGIN(SELECTORG_IDFROMT_ORGAWHEREA.STATE=1STARTWITHA.ORG_ID='&当前登录登录所在机构ORG_ID'CONNECTBYPRIORA.ORG_ID=A.PARENT_ORG_ID)修改密码修改密码用户名只读、自动带入STAFF_CODE姓名只读、自动带入USER_NAME新密码必输项PASSWORD新密码确认必输项PASSWORD确认返回相关规那么新增用户时状态默认为有效，不可修改。用户修改时页面中数据项都放开可编辑。点击“修改密码〞直接弹出新密码录入页面，由用户录入新的密码。用户名：必输项，需进行唯一性校验职务：带入后可修改登录密码与确认密码必须一致，最小4位最大12位，并通过SHA加密如列表中选中了多条数据，那么将修改按钮灰化，不可点击用户删除时可进行多项选择，删除时询问：是否确定将选中用户删除？权限树状列表为数据交换系统中所有模块的清单。选择用户点击用户权限中的新增按钮弹出权限的树状列表。数据权限分为省级权限、市级权限，具备省级权限可查看全省的数据，具备市级权限可查看登录用户所在市政府及下属政府、机构的数据。数据权限中省级权限、市级权限不可同时选择。相关SQL查询用户信息SELECTU.STAFF_CODE,U.USER_NAME,U.POSITION,O.ORG_NAME,DECODE(STATE,1,'有效',0,'无效')STATEFROMT_USERU,T_ORGOWHEREU.ORG_ID=O.ORG_IDORDERBYO.ORD查询用户权限SELECTM.MENU_TITLEFROMT_MENUM,T_USER_MENUUMWHEREM.MENU_ID=UM.MENU_IDANDUM.USER_ID='选择的USER_ID'新增用户：INSERTINTOT_USER修改用户：UPDATET_USER删除用户菜单DELETEFROMT_USER_MENUWHEREUSER_IDIN('选择的USER_ID')删除用户UPDATET_USERSETSTATE='0'WHEREUSER_IDIN('选择的USER_ID')--菜单查询SELECTMENU_TITLEFROMT_MENUWHERESTATE='--插入菜单INSERTT_USER_MENU用户权限删除可进行多项选择，删除时询问：是否确定将选中用户权限删除？DELETEFROMT_USER_MENUWHEREIDIN('选择的ID')机构管理功能说明管理维护数据交换所涉及的各机构的信息，包括：机构名称、标准化简称、机构代码、所属行政区划、部门间隶属关系。页面设计页面设计以软件为准，要求页面数据项一致、功能实现，页面布局不做要求，新增/修改页面机构维护机构代码输入框ORG_CODE机构名称输入框ORG_NAME机构简称输入框SIMPLE_NAME机构类型下拉框ORG_TYPE上级机构下拉框PARENT_ORG_ID上级垂管机构下拉框VER_ORG_ID状态下拉框STATE顺序号输入框ORD确定返回列表页面相关规那么列表展示所有的机构数据，并支持多项选择机构名称为模糊查询机构类型为下拉选择【空-全部、00-省政府、01-省级部门、02-市政府、03-市级部门、04-区县政府、05-区县部门、】状态为下拉选择【空-全部、1-有效、0-无效】相关SQL查询机构信息SELECTO.ORG_ID,O.ORG_NAME,O.SIMPLE_NAME,DECODE(O.ORG_TYPE,'00','省政府','01','省级部门','02','市政府','03','市级部门','04','区县政府','05','区县部门',')ORG_TYPE(SELECTORG_NAMEFROMT_ORGWHEREORG_ID=O.PARNET_ORG_ID)PARENT_ORG_NAME,DECODE(O.STATE,'1','有效','0','无效')STATEFROMT_ORGOORDERO.ORD新增：INSERTINTOT_ORG修改：UPDATET_ORG机构删除可进行多项选择，删除时询问：是否将选中机构及其下级机构一并删除？--查询要删除的所有ORG_IDSELECTORD_IDFROMT_ORGSTARTWITHORG_IDIN('选中的ORG_ID')CONNECTBYPRIORORG_ID=PARENT_ORG_ID--删除用户UPDATET_USERSETSTATE='0'WHEREORG_IDIN('查询的ORG_ID')--删除机构UPDATET_ORGSETSTATE='0'WHEREORG_IDIN('查询的ORG_ID')机构列表展示时根据登录用户进行数据过滤，省级权限查询全省的数据，市级权限查询当前登录用户所在机构及其下级机构的数据。交换管理功能说明该模块主要包含：交换节点管理，负责维护数据交换系统中各交换节点信息。用例图用例分析概述用例名称：交换节点维护参与者：系统管理员用例概述：系统管理员针对节点与机构绑定进行管理、修改操作，该操作只对软件的统计分析有影响，对软件整体运行无影响。事件流前置条件：无后置条件：无根本领件流：系统管理员进入交换节点管理页面后，点击新增和修改良行交换节点内容的操作，点击删除那么节点不在展示在列表中。备选〔扩展〕事件流：无异常事件流：系统维护中保存失败或删除失败后，系统仍然显示信息录入界面或列表页面，并提示失败原因页面设计交换节点管理维护管理数据交换系统中各交换节点对应的机构。提供新增、删除、修改功能。查询条件“机构名称〞进行数据权限过滤，省级权限查全省的数据，市级权限根据登录登录用户查其本级及其下级机构的数据。新增页面新增交换节点节点名称TXT框NODE_NAME机构名称∨ORG_ID状态有效∨NODE_STATE提交关闭相关规那么根据登录人员所在机构展示该机构下的所有交换节点，即本机构下的所有管理员均可对该机构下的所有交换节点进行维护。新增页面进入时状态默认有效且只读不可修改，各数据项必输。修改页面进入时所有数据项均放开可修改，各数据项不可为空。删除后，将不在列表中展示。相关SQL查询规那么：根据登录用户所在机构展示该机构下的所有节点Selectnode_name,(selectorg_namefromt_orga,t_node_orgbwhere_id=_id),node_statefromt_node_orgwherestate=1andorg_id=‘登录用户ORG’;插入规那么：insertt_node_org插入时默认node_state=1，state=1修改规那么：NODE_NAME,ORG_ID,NODE_STATE状态可修改。删除规那么：updatet_node_orgsetstate=0;日志管理功能说明记录数据交换系统中各功能模块所产生的日志，主要内容包括：登录日志、系统日志。用例图用例分析概述用例名称：维护系统日志参与者：系统管理员用例概述：系统管理员进行系统日志维护等操作。事件流前置条件：无后置条件：无根本领件流：系统管理员进入数据日志管理页面后，可以进行日志查询、归档操作；备选〔扩展〕事件流：无异常事件流：归档成功返回成功信息，假设失败那么仍显示查询页面，并提示失败原因页面设计登录日志在菜单项中选择【登录日志】，进入页面系统日志在菜单项中选择【系统日志】，进入页面查询条件“机构名称〞数据需进行数据权限过滤双击某条数据可查看操作详细页面操作描述USE_DESCREBE相关规那么登录日志：记录用户登录该系统的历史信息。机构名称：假设为省局用户那么出本级及下级机构名称，默认省局，假设为市级用户那么默认为本级，展示本级及下级机构名称登录人员：模糊查询，根据机构名称查询该机构下的登录人员。日志归档：对日志进行归档操作系统日志：记录用户对系统中增、删、改等一系列操作信息。机构名称：同登录日志操作人员：同登录日志操作模块时间：即触发ButtonClick事件后进行记录，记录的操作含增、删、改，备份等事务操作，不包含查询。双击某条数据可以查看操作描述页面相关SQl首次进入页面时查询规那么：展示未归档日志，省局用户展示本级及下级局；市局用户只展示本级。Selectcreate_org,person_name,loging_time,exit_time,loging_ip,loging_macfromT_SYS_LOGING_LOGwherestate=0andcreate_org=‘根据登录用户判断’登录日志数据插入规那么：用户首次登录时执行insert操作，退出时间为空；当用户退出时，根据PERSON_ID查找CREATE_DATE最大那条数据，执行update操作，其他字段不变，只修改退出时间。归档规那么：Insertt_sys_loging_log_backup(t_sys_use_log_backup)取t_sys_loging_log(t_sys_use_log)中state=0且create_org=’本机构’的数据Updatet_sys_loging_log(t_sys_use_log)setstate=1(已归档)输入查询条件后:查询t_sys_loging_log(t_sys_use_log)中statein(0,1)的数据，且需要根据登录人员所在机构过滤字典管理〔暂缓〕功能说明对系统内部一些取值根本能固定下来的数据选取项，通过数据字典进行维护。用例图用例分析概述用例名称：维护数据字典参与者：系统管理员用例概述：系统管理员进行系统中数据字典的维护等操作，一般对字典主表的操作建议不给系统管理员操作权限。事件流前置条件：无后置条件：无根本领件流：系统管理员进入数据字典管理页面后，点击新增字典和修改字典进行字典的操作，点击新增字典值、修改字典值和删除字典值进行字典值操作；备选〔扩展〕事件流：无异常事件流：系统维护中保存失败或删除失败后，系统仍然显示信息录入界面或列表页面，并提示失败原因页面设计列表显示页进入该模块后显示如下，左侧为字典项列表，右侧为对应左侧字典项的字典值的列表信息；字典管理字典项.使用机构.查询重置新增字典修改字典删除字典新增字典值修改字典值删除字典值字

项上级字典使用工程使用机构字典项值排序口DICT_NAMEPARE

T_DICT_IDITEMCREATE_ORG口DICT_VALUE1口口2口口3口。。。首页上一页下一页末页第XX页GODIC

_VA

UESO

D新增修改字典页面字典编号DICT_NO字典项DICT_NAME字典项描述DICT_DESCRIPT上级字典PARENT_DICT_ID下拉选使用工程ITEM下拉选不能为空默认为公共使用机构CREATE_ORG保存取消新增修改字典值页面字典项默认左边选中的字典项的值DICT字典项值排序保存保存继续取消相关规那么除使用机构外，页面各数据项不能为空；该功能只提供应管理员进行维护，一般情况用户只能增删改字典项的值，字典主表由开发人员开发时维护或初始化化时执行脚本生成；字典值维护页面，点击保存按钮返回列表，点击保存继续按钮保存数据继续新增操作。先根据ITEM来取本工程的字典，没有那么取ITEM为公共的数据字典；再根据当前人的机构ID取本机构字典，没有那么BELONG_ORG为空的。相关SQL查询规那么：selecta.dict_name,a.parent_dict_id,a.item,a.create_org,b.dict_value,b.ordfromt_dict_maina,t_dict_main_valuewherea.dict_id=b.dict_idanda.create_org=‘用户所在机构’;插入规那么：insertt_dict_main/insertt_dict_main_valewheredict_id=‘所选dict_id’删除规那么：deletet_dict_main/insertt_dict_main_vale任务管理模块概述任务管理模块负责数据交换任务的定义、维护和运行控制。为方便扩展，对当前数据交换需求中的角色进行抽象化，定义以下概念：端点：直接连接到本系统，进行数据交换的实体。该实体可以是业务系统、数据库，甚至是操作系统目录。端点之间以本系统作为中介，进行通信。本节采用数据格式+通信方式的形式，作为端点类型的非正式表示源端点：在数据交换任务中，作为数据来源的端点。主动源端点是指主动触发任务运行的源端点〔如XML+WebService〕；被动源端点是指仅仅产生待交换数据而不触发任务运行，由本系统轮询触发任务运行的源端点增量识别机制：指从源端点的数据存储中确认新增/变化数据的方式。包括基于触发器、基于时间戳、基于Where子句、全表扫描等目标端点：在数据交换任务中，接收数据的端点数据格式：端点对数据的组织形式，主要分为RDBMS〔表或者视图〕、二进制格式和文本格式三类。其中二进制格式包括Excel电子表格；文本格式包括XML、逗号分隔符等通信方式：端点连接到本系统的通信协议或者技术手段。包括JDBC、HTTP、WebService、JMS、MOM〔主要指MQ〕、FTP等方式内部数据格式：本系统内部对数据格式的一致性表示。该表示为一树形结构，支持对端点数据格式的自动化映射映射规那么：描述端点数据格式——内部数据格式的映射规那么的元数据，以XML的形式表示对上述概念的补充说明：端点的数据格式、通信方式、增量识别机制不能任意组合，依赖于特定的技术的固有特征。例如RDBMS只能和JDBC组合本次设计，不涉及上述数据格式、通信方式的全部例示。主要实现对XML+WebService、RDBMS+JDBC两种端点的支持；增量识别机制支持基于时间戳的方式任务定义该模块属于人机交互模块，负责数据交换任务的定义。任务定义的核心是源端点、目标端点的配置。数据对应关系表关系说明本模块涉及三张平台库中的表：T_TASK_DEF：任务根本信息表T_TASK_CTRL：任务控制信息表T_ENDPOINT：端点信息表〔EP_TYPE=0表示源端点，EP_TYPE=1表示目标端点，每个任务只有一个源、一个目标端点〕T_TASK_DEF.ID=T_TASK_CTRL.TASK_IDT_TASK_DEF.ID=T_ENDPOINT.TASK_ID字段对照表页面元素表字段说明任务名称T_TASK_DEFTASK_NAME任务描述T_TASK_DEFTASK_DESC创立人T_TASK_DEFCREATE_USER所属机构T_TASK_DEFORG_ID创立时间T_TASK_DEFCREATE_DATE状态T_TASK_DEFTASK_STATE创立/修改时间T_TASK_DEFSTATE_DATE每次对任务进行变动，必须修改此字段为SYSDATE执行此任务的运行时平台实例T_TASK_DEFINST_ID运行时段T_TASK_CTRLRUN_PERIOD日配额控制T_TASK_CTRLDAILY_QUOTA轮询周期T_TASK_CTRLPOLL_INTERVAL独立VM运行T_TASK_CTRLDEDICATED_VMJVM参数T_TASK_CTRLVM_ARGS最近调度时间T_TASK_CTRLLAST_SCHE最近运行时间T_TASK_CTRLLAST_RUN转换脚本T_TASK_DEFTRANS_SCR端点名称T_ENDPOINTEP_NAME所属节点T_ENDPOINTNODE_ID映射规那么文件T_ENDPOINTMAP_FILE数据格式T_ENDPOINTFMT_ID传输方式T_ENDPOINTTRANS_ID数据库类型T_ENDPOINTDB_TYPE_ID启用XA事务T_ENDPOINTXA_ENABLEDJDBC连接串T_ENDPOINTJDBC_URLJDBC用户名T_ENDPOINTJDBC_USERJDBC密码T_ENDPOINTJDBC_PSWD增量识别机制T_ENDPOINTS_CDC_ID时间戳字段T_ENDPOINTS_TIMESTAMP步进〔秒〕T_ENDPOINTS_TIME_STEP注意：数据库单位是毫秒，模型层/Service层执行转换条件表达式T_ENDPOINTS_WHERE_CLAUSE回填表达式T_ENDPOINTBACKFILL_CLAUSE执行删除T_ENDPOINTBACKFILL_CLAUSE如果选中，直接填入delete字样批量条数T_ENDPOINTS_BATCH_SIZE允许的操作T_ENDPOINTD_DB_OP主键冲突处理T_ENDPOINTD_DB_CONFLICT和源端点使用相同的配置T_ENDPOINTD_CONSIS_MAPWS客户端用户名T_ENDPOINTWS_USERWS客户端密码T_ENDPOINTWS_PWSD向源端点报告异常T_ENDPOINTS_RPT_ERRWS名字空间T_ENDPOINTD_WS_NSWS效劳端地址T_ENDPOINTHTTP_URLHTTP通道T_ENDPOINTHTTP_CHNL同时勾选那么填写2保存时差T_ENDPOINTS_OVERSTEP注意：数据库单位是毫秒，模型层/Service层执行转换查询功能说明查询已经存在的交换任务，展示根本信息，并提供新建、修改、控制任务的功能入口点。页面设计注意：字段顺序、每行展示字段数、展示方式可以根据需要自行调整。相关规那么点击创立任务按钮，进入详情录入模块。点击类似任务创立按钮，重新载入选择的模块，任务名称验证其唯一性，文本框的值自动带入，列表的值只能选择其一不能多项选择点击修改按钮，进入任务修改模块。进入页面所有显示状态均是STATE=1点击删除按钮，STATE设置为“0〞；创立人展示为单项选择字典，显示所属机构下的人员。所属机构展示为字典，显示当前用户有权看到的机构，如果为空，查询语句根据用户所能看见的机构进行过滤。相关SQL查询sqlselectTRIM(b.id)defId,b.task_name,to_char(b.create_date,'yyyy-mm-dd')create_date,(select_namefromt_orgawhere_id=_id)org_id,(selectuser_namefromt_userdwhered.user_id=b.create_user)create_user,(SELECTto_char(c.last_sche,'yyyy-mm-ddhh24:mi:ss')last_scheFROMt_task_ctrlcWHEREb.id=c.task_id)last_sche,(SELECTto_char(c.last_run,'yyyy-mm-ddhh24:mi:ss')last_runFROMt_task_ctrlcWHEREb.id=c.task_id)last_run,(SELECTc.poll_intervalFROMt_task_ctrlcWHEREb.id=c.task_id)poll_interval,(SELECTC.RUN_PERIODFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)RUN_PERIOD,(SELECTC.DEDICATED_VMFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)DEDICATED_VM,(SELECTC.DAILY_QUOTAFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)DAILY_QUOTA,(SELECTc.idFROMt_task_ctrlcWHEREb.id=c.task_id)id,DECODE(b.task_state,'1','submit.gif','0','disable.gif')task_statefromt_task_defbwhereb.state=1删除sqlupdatet_task_defaseta.state=0whereid=“所选标记id〞详情录入功能说明该子模块负责数据交换任务的设计，核心逻辑是源、目标端点的配置和组合。页面设计注意：字段顺序、每行展示字段数、展示方式可以根据需要自行调整。在修改交换任务时，映射规那么文件的表单文本框不显示任何内容。转换脚本字段如下，可放在页面上单独的选项卡内，脚本内容目前不做任何验证：〔暂未实现，字段在页面中隐藏〕数据库模式源端点使用基于时间戳的增量识别器的情况：图中未画的字段：保存时差注释：cron表达式目前没有实质用途，目前先隐藏。源端点使用基于时间戳增量识别器的情况：基于过滤条件增量识别器的页面如下：报文模式类似创立页面相关规那么注意！源端点和目标端点可以使用不同的模式：数据库或者报文对于条件表达式的填写即填写where字句，填写格式为字段=‘值’对于多个字段的填写格式为字段=‘值’and字段=‘值’and………对于映射规那么文件在修改的时候如果库里面有数据那么可以不用限制必填。数据库模式数据格式选中关系型数据库时，传输方式自动变为JDBC，并显示上节图中显示的数据库相关的数据项映射规那么文件由客户端上传，点击上传后立即存放于应用效劳器的临时位置，并调用接口执行验证：sparknet.canary.core.mapping.parser.MappingRulesParser.parse如果抛出异常，那么提示用户格式有误。注意：此parse方法比拟消耗资源，实现时一个映射文件只parse一次，解析结果存放在HTTPSession范围，以MD5为key，在提交本页面后，去除之。数据库类型从T_DICT_DB_TYPE拉出字典展示如果选中的数据库类型支持XA，那么显示启用XA复选框，默认勾选。目标数据库支持XA要求T_DICT_DB_TYPE.XA_DS_CLS不为空。如果XA_DS_CLS为空，那么不得为启用状态！！JDBC连接串只读，只能点击编辑修改。点击编辑，弹出窗/层中展示T_DICT_DB_TYPE.URL_TEMPLT中定义的EL表达式风格的变量占位符,弹出层提交后，自动进行模板替换，并填入到JDBC连接串。以Oracle10g为例：jdbc:oracle:thin:@${主机地址}:${TNS侦听端口}:${效劳名}弹出窗口需要展示主机地址、TNS侦听端口、效劳名3字段提交表单时，执行数据库连通性验证：CanaryHelper.testDbConnection，如果失败，那么警告用户，源端点(或者目标端点)无法联通，是否继续。增量识别机制根据T_DICT_CDCWHERESTATE=1拉出字典如果选中时间戳触发，那么展示：时间戳字段、步进〔秒〕两个页面元素；如果选中过滤条件触发，那么展示：条件表达式、回填表达式、执行删除、批量条数几个页面元素。时间戳字段必须在上传映射规那么文件后才能录入，时间戳字段可以填写实体映射(EntityMapping)的实体属性名(name)，或者对应列名(column)，而且必须使用简单属性(SimplePropertyMapping)，以上规那么通过MappingRulesParser.parse得到的映射规那么模型(MRM)进行验证，如果有错，那么报告前台。验证触发时期为失去焦点onblur步进的单位为秒，数据库是毫秒，该转换在MVC-M层或者Service层执行转换条件表达式，为where子句片段，调用sparknet.canary.core.cdc.HqlConverter.convertWhereClauseIfNecessary执行验证和转换，转换结果自动替换原值，如果抛出InvalidClauseException那么报告前台。验证触发时期为失去焦点onblur。回填表达式，为set子句片段，调用sparknet.canary.core.cdc.HqlConverter.convertSetClauseIfNecessary执行验证和转换，转换结果自动替换原值，如果抛出InvalidClauseException那么报告前台。验证触发时期为失去焦点onblur。如果勾选“执行删除〞，那么回填表达式灰化，并且值变为“delete〞字样允许的操作，默认勾选插入、更新如果不允许插入操作，那么主键冲突处理全部radio灰化改变主键插入因为目前不支持，永远灰化如果勾选“和源端点使用相同的配置〞，那么目标端点的映射规那么文件灰化。Service层自动把源端点的映射文件赋值给目标端点。对轮询周期增加提示说明，当鼠标移至“轮询周期〞时显示提示信息，内容如下：实时性高：1-10实时性中：20-50〔推荐〕实时性低：50-1000。对步进增加提示说明，当鼠标移至“步进〞时显示提示信息，内容如下：高度并发：1-10中度并发：20-100〔推荐〕低度并发：150-300。报文模式映射规那么文件和上节规那么一致源端点的Webservice用户名，必须全局唯一，即SELECTCOUNT(*)FROMT_ENDPOINTWHEREEP_TYPE=0ANDWS_USER=any的结果<=0WS名字空间默认为/提交表单时调用CanaryHelper.testHTTPConnection验证目标WebService的连通性，如果失败那么提示用户：目标端点无法联通，是否继续任务控制功能说明该子模块负责任务的启用、停用的控制。页面设计相关规那么点击“启用〞，有以下两种情况：原启动的任务重新启动〔重启〕；原停用的任务启动。点击“停用〞，也有以下两种情况：原停用的任务保持停用。原启用的任务变为停用。3.进入页面所有显示状态均是STATE=相关SQL查询sqlselectTRIM(b.id)defId,b.task_name,to_char(b.create_date,'yyyy-mm-dd')create_date,(select_namefromt_orgawhere_id=_id)org_id,(selectuser_namefromt_userdwhered.user_id=b.create_user)create_user,(SELECTto_char(c.last_sche,'yyyy-mm-ddhh24:mi:ss')last_scheFROMt_task_ctrlcWHEREb.id=c.task_id)last_sche,(SELECTto_char(c.last_run,'yyyy-mm-ddhh24:mi:ss')last_runFROMt_task_ctrlcWHEREb.id=c.task_id)last_run,(SELECTc.poll_intervalFROMt_task_ctrlcWHEREb.id=c.task_id)poll_interval,(SELECTC.RUN_PERIODFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)RUN_PERIOD,(SELECTC.DEDICATED_VMFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)DEDICATED_VM,(SELECTC.DAILY_QUOTAFROMT_TASK_CTRLCWHEREB.ID=C.TASK_ID)DAILY_QUOTA,(SELECTc.idFROMt_task_ctrlcWHEREb.id=c.task_id)id,DECODE(b.task_state,'1','submit.gif','0','disable.gif')task_statefromt_task_defbwhereb.state=1启用sqlupdatet_task_defbsetb.task_state=1,b.state_date=sysdatewhereid='“所选标记id〞andb.state=1停用sqlupdatet_task_defbsetb.task_state=0,b.state_date=sysdatewhereid=“所选标记id〞andb.sta