DB65∕T 4227-2019 基层基础数据共享交换平台 共享数据发布规范(新疆维吾尔自治区).pdf

ICS 35. 100. 70 L 79 I飞飞电飞Z电飞J1号Basic-level basic data sharing exchange platform一一.Shareddata release specifications DB65/丁4227-2019自IJ1=1 本标准按照GB/T1.1-2009 标准化工作导则第1部分:标准的结构和编写的规则编制。本标准由自治区密码管理局提出。本标准由自治区密码管理局归口。本标准主要起草单位:自治区密码管理局、自治区标准化研究院、新疆亚泰信息技术有限公司、自治区市场监督管理局宣传信息中心。本标准主要起草人:杨顺轩、阿里甫江、张振宁、陈硕、霍川、赛丽滩乃提、安金鹏、李瑜、朱翔、陈明、哈丽旦、李楠、艾力、智勇、王成、张敬闻。本标准实施中的疑问请咨询自治区密码管理局、自治区标准化研究院、新疆亚泰信息技术有限公司。对本标准的修改意见或建议，请反馈至自治区市场监督管理局(乌鲁木齐市新华南路167号、自治区密码管理局(乌鲁木齐市天山区健康路2号)、自治区标准化研究院(乌鲁木齐市河北东路188号)、新疆亚泰信息技术有限公司(乌鲁木齐市新市区体育馆巷188号)。自治区市场监督管理局联系电话[phone];传真[phone];邮编830004自治区密码管理局联系电话[phone];传真[phone];邮编830003自治区标准化研究院联系电话[phone];传真[phone];邮编830011新疆亚泰信息技术有限公司联系电话[phone];传真0991一3825269;邮编8300111 范围基层基础数据共享交换平台共享数据发布规范DB65/T 4227-2019 本标准规定了基层基础数据共享交换平台共享数据发布的术语定义、基本要求、资格审查、数据准备、数据审核、数据发布和更新维护。本标准适用于通过基层基础数据共享交换平台进行共享数据发布过程的规范与管理。2 规范性引用文件下列文件对于本文件的应用是必不可少的。凡是注日期的引用文件，仅所注日期的版本适用于本文件。凡是不注日期的引用文件，其最新版本(包括所有的修改单)适用于本文件。GB/T 19488.1-2004数据元第1部分:设计和管理规范GB/T 19488.2-2008数据元第2部分:公共数据元吕录GB/T 21062 (所有部分)政务信息资源交换体系GB/T 21063 (所有部分)政务信息资源自录体系DB65/T 4288 基层基础数据共享交换平台共享数据元目录3 术语与定义GB/T 19488. 1-2004和臼/T19488.2-2008及DB65/T4288给出的以及下列术语和定义适用于本文件。3. 1 基层基础数据共享交换平台basic-Ievel basic data sharing exchange platform 汇集政务服务部门或业务系统的基层基础数据，经过整理、比对、转换等技术手段形成基层基础数据目录库和数据资源库，保持实时更新，为政务服务业务开展提供共享数据服务的信息系统，简称平台或平台系统。3. 2 数据发布data released 依据共享数据资源目录，在平台系统生中生成实时或批量数据服务，向其他系统提供数据共享的过程。3. 3 数据发布系统data released system D865/T 4227-2019 部署在平台以及前置系统上，为共享数据发布提供服务的应用程序。3.4 数据获取data acquisition 数据使用方从业务系统或平台系统获得共享数据的过程。3.5 数据提供方data providers 为基层基础数据共享交换平台提供共享数据的单位和部门。3. 6 数据抽取规则data extraction rules 依据平台系统的要求和规定从数据源通常为数据库)中抽取目的数据的执行语句的组合。4 基本要求4. 1 基层基础数据共享交换平台的政务信息共享数据来源于各个业务系统，业务系统可通过共享数据发布的方式，将共享数据目录或数据内容推送到平台系统中，供其他业务系统查询和调用。4. 2 平台与业务系统间的共享数据交换应遵循GB/T21062 (所有部分)的规定。4. 3 共享数据发布应通过平台提供的数据交换服务完成。数据交换服务应包括:a) 数据接入服务:平台应提供多种用于处理流数据的数据接收方式即数据接入方式)，数据接入方式应支持同构或异构交换平台系统的相互对接，以实现平台与各业务系统间的数据交换。数据接入方式可包括:数据库接入、文件接入、服务接口接入。数据接入的技术要求见附录A;b) 目录服务:平台应为数据发布和数据获取提供必要的目录服务。目录服务应符合GB/T21063 (所有部分)的规定。目录服务应具备下列功能:1) 目录管理:对共享数据目录的审核、分类及存储:2) 服务查询:对平台内各项数据服务的查询:3) 数据浏览:对平台中已发布的数据内容的查询和浏览:4) 接口规范查询:可查询目录中各数据项提供的数据接口的规范。c) 密钥服务:提供数据加密所需的加密方式和密钥生成服务。数据的加密、解密和密钥生成参见附录B的示例:d) 数据传输服务:提供用于共享数据传送所需的服务功能。数据传输方式参见附录C的示例鄂4.4 共享信息数据元应符合DB65/T4288的规定，并可依据其原则进行扩充。4.5 按照数据发布的先后顺序，共享数据发布可分为资格审查、数据准备、数据审核、数据推送和更新维护5个环节。5 资格审查5. 1 业务系统须经过平台系统的资格审查，确认具备相应服务能力，方可作为平台共享数据的提供方，通过平台发布相应的共享数据。2 D865/丁4227-20195.2 应制定审查要求或考核规范，对业务系统的数据提供能力进行确认，确保共享数据的权威性、准确性、安全性、时效性和科学性。5. 3 资格审查的内容可包括:a) 业务系统的基本情况:b) 对所提供信息数据的管理权威性:c) 实施数据交换的方式和网络连接状况:d) 硬件和软件条件(包括服务器的C陀、内存、网络等核心资源指标)e) 业务系统运行环境安全性;f) 数据采集和数据更新能力;g) 共享数据内容及覆盖范围，应为业务系统产生或通过业务规则产生的数据:h) 数据质量的保障能力。5.4 平台应依据审核结果，赋予业务系统相应的数据共享资格和服务调用权限。6 数据准备6. 1 发布数据的业务系统(共享数据提供方)向平台推送共享数据应依据GB/T21063 (所有部分)的要求，形成共享数据目录后向平台推送。6. 2 共享数据提供方应依据平台的要求，对需要交换的共享数据和数据提供能力进行梳理和调整，确保数据交换过程的顺利完成。梳理的内容应包括:a) 确定共享数据的数据组成和数据结构;b) 确定数据文件的格式;c) 确定数据交换的接入方式:d) 共享数据的数据说明:e) 确定下列共享数据的数据内容:1) 数据表名称;2) 创建时间:3) 推送批次号;4) 推送时间;5) 数据更新周期:6) 数据项名称:7) 数据项长度:8) 数据项字符;9) 数据唯一标识:10)数据有效期限:11)更新频率。6. 3 应通过目录生成工具软件或系统形成待审核数据目录。6.4 待审核数据目录应依据平台要求，推送至指定的文件或目录中等待平台系统的数据审核。6.5 需提取数据的，应依据数据组成和数据库结构，制定相应的数据抽取规则和数据存储方案。7 数据审核7. 1 平台系统应依据第6章的规定对业务系统提交的待审核数据实施数据审核。7. 2 审核合格的数据，可按照第8章的规定完成共享数据的发布静3 DB65/T 4227-2019 7.3 不合格的数据返回数据提供方，修改完善后重新审核。8 数据发布8.1 经数据审核确定为共享数据的，可通过平台数据发布系统完成共享数据目录和数据的发布。8.2 数据发布系统应提供下列附加服务功能:a) 格式转换:由数据格式转换适配器(包括:关系型数据格式转换适配器、空间数据格式转换适配器、文件数据格式转换适配器、多媒体数据格式转换适配器等将需要发布的内容进行XML格式转换:b) 数据压缩:对发布内容进行压缩;c) 数据加密:使用密钥进行数据加密和解密。8. 3 数据发布的过程可包括数据接口生成、身份验证、数据文件生成、数据推送和数据接收等环节。数据发布示例参见附录C。8.4 共享数据的数据目录可存入平台共享数据目录。8.5 需要提取数据内容的，应依据数据提取规则提取数据内容，依据数据存储方案存储至相应的数据库。不需要提数据内容的，应在数据目录中对共享数据内容的存储路径、存储方式等予以说明。8.6 数据目录发布或数据内容交换完成后，应对传输数据的完整性、准确性进行审核。9 更新维护9. 1 数据发布方对其发布的共享数据，应具有访问管理和控制权限。9.2 应根据数据安全级别和要求提供相应的加密方式。加密密钥应及时更新，确保共享数据的安全09. 3 平台系统应依据实际情况制定更新维护的方案和要求，确保平台共享数据的准确有效。4 DB65/T 4227-2019 人1数据接入A. 1. 1 数据库接入A. 1. 1. 1 描述附录A规范性附录)数据接入数据量较大、数据增量或更新频繁的数据交换时，宜借助中转数据库，在业务系统数据库与平台数据库间通过数据库接入的方式进行数据传输。数据库接入时应设置相应的交换表和中转数据库接入管理字段。A. 1. 1.2 交换表中转数据库应依据接收的业务数据设置对应的交换表，用于记录数据交换时接收的数据结果。交换表主键与业务表主键字段的名称、类型、长度应一一对应。交换表的字段及技术要求见表A.L表A.1 交换表的字段及技术要求字段名称技术要求tong_tme 描述:业务接收方从接收前重库提取数据的时间:类型timestamp;默认约束current_timestamp，取前置库的系统当前时间，不允许其他操作。division 描述:行政区划;类型varchar(50)。department 描述:部门名称:类型varchar(50) 0 operator 描述:数据安全责任人姓名:类型varchar(50)。rcvtme 描述:数据交换到达接收前置库时间，取接收前重库的tong_time时间:类型datetimeA. 1. 1.3 中转数据库接入管理字段中转数据库的交换表应增加接入管理字段。接入管理字段见表A.2oA. 1. 1.4 其他技术约束前置交换表的设置还应遵循下列要求:a) 前置交换表中除管理字段外，不应存在自增列;b) 时间类型(如datatime、data、timestamp)的字段值不允许为nu11、空字符串、空格、制表符(TAB)、NU11字符串和0000-00-0000:00:00字符串;c) 非空字段(notnu11)的值不允许为空字符串、空格、制表符(TAB)和阳11字符串;d) 主键字段值不允许为nu11、空字符串、空格、制表符(TAB)和NU11字符串。5 D865/T 4227-2019 表A.2交换表接入管理字段字段名中文名称说明tong_tirne 数据入库时间类型tirnestarnp;默认约束current_tirnestarnp，取前置库系统当前时间，不允许其他操作。op 操作标记类型varchar(30) 新增数据记录时需要标记op的值为insert更新数据记录时需要标记op的值为update删除数据记录时需要标记op的值为delete。tongID 发送端自增列类型bigint;默认约束auto_incrernent，与前置交换表的业务主键作为联合主键。仅发送端前置交换表上有约束。sendtirne 数据发送时间类型:datatirne。仅接收端前置交换表上需要增加。A. 1.2 文件接入A. 1.2.1 描述文件接入方式是指发送端和接收端均通过文件形式进行数据交换。文件接入方式可分为结构化文件解析接入和非结构化文件交换。A.1.2.2 结构化文件解析接入发送端通过平台数据交换软件进行文件上传，将结构化文件解析后推入中转数据库。结构化文件应满足下列要求:a) 能通过数据解析转换为二维数据表结构，如Excel、XML，csv、txt等格式文件:b) 应提供二维数据表的元数据描述、表的属性及各个字段的属性说明包括表名、字段名、字段类型，字段长度、字段非空属性、主键属性、默认值、小数点等)。A. 1.2.3 非结构化文件接入发送端和接收端通过数据交换平台的桥接软件实现非结构化文件的交换。A. 1.3 接口方式接入6 接口接入方式是指通过数据接口进行数据交换的数据传输方式。接口方式接入应满足下列要求:a) 接口类型支持SOAP1. 1/1. 2、HTTP1.1, HTTPS; b) 由数据发布方在平台上进行自主数据接口的注册:c) 发布的数据接口应提供接口调用说明:d) 数据发布方应对接口性能和服务质量负责。数据接口的调用示例参见附录CoDB65/丁4227-2019附录B(资料性附录)数据加密、解密和密钥生成示例B. 1 加密算法n o -i 牛LP lv 户UX FU QU W o r Lu 牛L、1/r / 牛LanU+L ma aD Tiu ar ps b.， n/a., 化iyt)主reavd勾/+LVnu.，nUQU而S臼叼盯七飞hNKAJ4lvd/tTif飞r变b吨吨h的优.口阳出叩度hu山但长吨ump一吨串.口耐门dd扎符toBEtQurt-nb 字串以fmvMA仪缸与介寸CLS-YH-dLA川fpue1irro门川HU77+L牛L14+LnLb+L刀寻JPvdtnbnnypbume-s 被)密rp;earl臼着写加m-U吭叫盯工缸UE吉ph们Je&Btpyxu协阳/、Ln口t-yaeetk-AL川川Jgx一一-b二rhtx俨忖AZ寸/牛巾日nueh口.，吁立Tye#卢企阵一oiT昨吁ata经AtBTiErrhMiryh丁tgt伪认rg剧定y忽缸M刷归阳一个hth斐ho飞二恼日固VMm串仁cCIL忖盯ufm刮叩x力?小XHJr?反)xic炜knsfc已刁，ta介Jl运EtHE-IZ比eT怡、-m度h密P字nsM吨脱口时口昭口叭盯m昭LM长m制m密盯仰S口-MSM力Mb山阴阳土刀DAL汇r忏zr日tret/Vd/Vd/Vd/114x、TJau刀a万ehinb/b/b/b/crm艇密郎四郎待仕航M/门U*p 1* *加密模式之Ecb* explain * param key * param data * return * throws Exception *1 public static byteJ encrypt_Ecb_Padding(byteJ key, byteJ data) throws Exception Cipher cipher二generateEcbCipher(ALGORITHM_NfuE_ECB_PADDING，Cipher.ENCRYPT_MODE, key) ; return cipher.doFinal(data); 7 DB65/T 4227-2019 B.2 解密操作rttE、n o -i 牛LDA U 户Ux pu nb w o r L +L 、2+L X 凸U丁jra ut/+L Hta pxD Jier CTie rh geDA n)hi -YPC TLOU-i +LVnuc QUX/飞aeb+L ，唱nna飞/Vd/飞iDGegTYN vnn+LeTi x-SKD erx/飞nUhu+Lubntu SHnN gxm-IEu nue01G iHrd rmriaa +L0nret 飞/Qurs-a写KJHddk尸cstpurBU记串1dL也CJP?.,ttpg Ebovd舟个NeueyyHnErh严HtetBrgiu忽串创怕一-W川W=m-m口A工3r十u+ua一玉(守d，日;B;d甘S盯hpzgFW川tg=gt=swt或川归时-m密dtathatmd山居民hf，sir-牛P-t-r和uTbL三习tthE川Vdgagea&一-vd部均yrd二JRPS父rnDnkD-r轩KK密密c别时.口町.口叩mLJUmh用X口叮pnH刀卒X1中壶Aut噜ktcSLQUAU切山h仰的.口时叶nUM于吨nm口时口陪口阳刚m巾am4mtrw引用ihehe角ebru卒la常a市uorttjtct&mpr比r比-trc/t/Y/Vd/VJ/ee4xa叫卫au卫。uh-/S/b/b/b/drmepnop6rtl nb品mu命MU-白mu-命川口而mu队/u 中个中+中个中个中个中mT中个中中中ATny1* *解密* explain * param key * param cipherText * return * throws Exception *1 public static byte J decrypt_Ecb_Padding (byte J key, byte J cipherText) throws Exception Cipher cipher = generateEcbCipher(ALGORITlli_NAME_ECB_PADDING， Cipher.DECRYPT_MODE, key) ; return cipher.doFinal(cipherText); 日3密钥生成*自动生成密钥* explain 8 * return * throws NoSuchAlgorithmException * throws NoSuchProviderException *1 public static byteJ generateKey() throws Exception return generateKey(DEFAULT_KEY_SIZE) ; 1* * explain * param keySize * return * throws Exception *1 public static byteJ generateKey(int keySize) throws Exception Ke旬ey川Generato盯rk阳g二Keey川Generato盯r.ge创t口Ins创tar丑lce(ALGO侃RI口THM自旧t【(呻-一一一一-臼-【一-句句甲币白PROVIDER_NAME) ; kg. init(keySize, new SecureRandom(); return kg.generateKey(). getEncoded(); DB65/丁4227-20199 D865/T 4227-2019 附录C(资料性附录)数据传输示例C. 1 概述本示例通过VisualStudio C#和Java语言示例，描述传输系统对共享数据的传送过程。共享数据传送可包括下列过程:a) 建立VisualStudio C#工程，将推送接口所在服务对应的WSDL添加Web引用到工程中(Web引用命名为WS); b) 声明一个对象实例。在代码中通过WS.webservicenametest new WS.webservicename()声明，其中webservicename为政务数据推送接口所在服务的YzwConvergenceService.asmx类名称，通过test调用政务数据推送接口:c) 词用政务数据推送接口。使用访问数据汇聚接口可用的用户帐号和密码进行身份验证，调用政务数据推送接口，进行行政许可、行政处罚等政务数据提交:d) 数据文件生成:e) 数据推送;f) 数据接收。C. 2 数据传输示例C. 2. 1 身份验证stringguid = test.LoginByAccount(用户帐号用户密码) ; /此用户必须是在注册的用户stringcatalogid=HxxxH; /由每个对接事项分配一个唯一标识string xmlstr= BuildXmlStr() ; /构造政务数据信息文件/. /调用政务数据推送接口string result二test.pushXml(guid，catalogid，xmlstr); /返回XML格式的推送结果C.2.2 数据文件生成10 public string BuildXmlStr 0 /创建Xml文档XmlDocument doc 二newXmlDocument 0 ; /添加根节点D865/T 4227-2019 XmlNode rootNode = doc. CreateNode (XmlNodeType. Element, table厅，doc.NamespaceURI); doc.AppendChild(rootNode) ; /添加row节点XmlNode firstNode = doc. CreateNode (XmlNodeType. Element, row气doc.NamespaceURI); /添加row节点的type属性XmlAttribute newAttribute二doc.CreateAttribute(type); newAttribute. InnerText = add: firstNode. Attributes. Append(newAttribute) ; rootNode.AppendChild(firstNode) ; /添加row子节点AddChi ldNode (ref firstNode, xksxmc肘，PIlame厅许可事项名称肘，/ xxx, doc) AddChi ldNode (ref firstNode, sbsxmc肘，pname厅申报事项名称气/xxx厅，doc); AddChildNode (ref firstNode, xkidsbb，Nname厅许可ID厅/xxx, doc) AddChi ldNode (ref firstNode, xkw jbh, name，气午可文件编号厅xxx，doc) AddChi ldNode (ref firstNode, xkw jmc厅，Nname厅，气午可文件名称厅xxx/，doc) AddChi ldNode (ref firstNode, yxqz厅name，用有效期自厅xxx，doc) AddChildNode (ref firstNode, yxqzhi, name厅，用有效期至厅xxx，doc) AddChi ldNode (ref firstNode, xkjg, name, /许可机关气xxx，doc) ; AddChi ldNode (ref firstNode, xknr/，飞ame厅许可内容厅xxx，doc) AddChi ldNode (ref firstNode, djzt，飞ame厅，用登记状态厅/xxx, doc) AddChi ldNode (ref firstNode, xzxdrmc厅name/，行政相对人名称厅xxx/，doc) AddChildNode(reffirstNo巾，tyshxydm, name厅统一社会信用代石矿/xxx厅，doc) ; AddChi ldNode (ref firstNode, qyzch, name, 企业注册号厅/xxx/, doc) AddChi ldNode (ref firstNode, zzjgdm/, name, 组织机构代码厅，pxxf，doc);return doc. OuterXml ; /添加子节点方法public void AddChildNode (ref XmlNode node, string childNodeName, string attrName, string a ttrValue, string childNodeValue, XmlDocument doc) RI) ; /添加子节点XmlNode chi ldNode = doc. CreateNode (XmlNodeType. Element, chi ldNodeName, doc. NamespaceU chi ldNode. InnerText = chi ldNodeValue; /添加属性XmlAttribute newAttribute二doc.CreateAttribute(attrName); newAttribute. InnerText二attrValue;childNode. Attributes. Append(newAttribute) ; node.AppendChild(childNode) ; 11 D865/T 4227-2019 C.2.3 数据推送C. 2. 3.1 获取cxf组件从http:/cxf.apache.org/download.html下载cxf组件。C.2.3.2 项目引入cxf组件 org.apache.cxf cxf-rt-frontend-jaxws 3.1.4 org.apache. cxf cxf-rt-transports-http 3.1.4 C. 2. 3.3 引入调用代码import org.apache.cxf. jaxws. endpoint.dynamic.axWsDynamicClientFactory; /* * testwebservice接口测试方法* param String userName用户名* param String passWord密码* param String catalogld目录id* param String xmlStr xml格式参数* param String wsdl接口wsdl*/ public static void testWebService(String userName, String passWord, String catalogld, String xmlStr, String wsdl) try axWsDynamicClientFactorydcf axWsDynamicClientFactory.newlnstance(); /wsdl为实际接口地址org.apache.cxf. endpoint.Client client二dcf.createClient(wsdl); /LoginByAccount为用户身份验证接口方法名称，userName为用户名，passWord为密码Object guidObjects二client.invoke(nLoginByAccountn, userName, passWord); System.out.println(n获取gud:n + guidObjectsO. toString(); /pushXml为政务数据推送接口方法名称，参数个数按照接口定义进行传参，返回一个Object数组Object objects二client.invoke(npushXml气guidObjectsO.toString(), catalogld, xmlStr) ; 12 /输出调用结果，Object数组第一条数据为返回结果System.out.println(气周用结果:n+ objectsO. toString(); catch (Exception e) e.printStackTrace() ; C.2.4 数据接收package convergence. servlet; import java. io. IOException; import . URLDecoder; import java. text.SimpleDateFormat; import java.util.Date; import javax. servlet.ServletException; import javax. servlet.ServletInputStream; import javax. servlet.annotation. WebServlet; import javax. servlet.http.HttpServlet; import javax. servlet.http.HttpServletRequest; import javax. servlet.http.HttpServletResponse; 1* * Servle1 implementation class GetErrordata *1 WebServlet(HIGetErrordatatestH) public class GetErrordata extends HttpServlet private static final long serialVersionUID lL; 1* * see HttpServlet#HttpServlet() *1 public GetErrordata() superO; 1* DB65/T 4227-2019 * see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response) *1 public void doGet (HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException doPost(request, response); 1* * see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response) *1 13 D865/丁4227-2019publ ic void doPost (HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException 14 getErrorDataByServletStream(request, response); public static void getErrorDataByServletStream(HttpServletRequest request, HttpServletResponse response) throws IOException SimpleDateFormat sdf二newSimpleDateFormat(Hyyyy-MM-dd HH:mm:ssH); System.out.println(H开始处理数据H+ sdf.format(new Date(); ServletlnputStream inputstream = request.getlnputStream(); StringBuffer errordataBuffer二newStringBuffer() ; byte b = new byte512 ; int lens = -1; while (lens = inputstream.read(b) 0) errordataBuffer.append(new String(b, 0, lens); System.out.println(Herrordata1:用十URLDecoder.codl(errordataBuffer. toString(), Hutf-8H); response. getWriter().write(HokH);