业务数据集成业务数据集成是指MDM Server与外围系统之间的数据交换时需要中间处理的模块应用层。1业务电商自助服务电商 网上销售个险团险养老金银保MQ* * *FTP(file)近实时处理批量处理业务集成层【Ext PackageBase Services数据服务层:MDM infrastructure批量加载架构服务层iMDM DB Module如图所示，外围系统要紧通过三种模式与MDM Server交互（那个地点 不考虑 ETL）：直截了当的web service访咨询-要紧通过http协议联机访咨询，一 样不通过业务集成层而直截了当访咨询数据服务层近实时的消息通知-要紧通过MQ消息访咨询，需要在业务集成层 进行必要的处理批量处理-要紧通过文件进行数据传递，需要在业务集成层进行处 理业务集成服务层的要紧内容包括： 近实时的消息通知数据标准代码的转换交易 xml 的拆分其他规则component*IMQ批量处理-mq标准代码的转换1- msgre匚ever“匚 o mponentx omponentDSP Rule交易拆分图 IBObj其他规则 收匚0 mponent 口 CDRuleuseuseusecomponentH IntegrateFWuse联机数据集成（基于MQ/XML）罔 IntegrateLogi 匚 图 IntegrateBat 匚 hLoqi 匚connponent*rnmnon（联机数据集成要紧处理近实时消通知，处理模式如MQ 组件是所有的客户信息更新消息的载体， MsgReceiver 组件负责接 收MQ的消息，通过MsgParser组件进行xml格式解析，MsgReceiver转交 到IntegrateFW组件，IntegrateFW组件是转发框架，负责业务集成层的差不 多操纵，按照报文的类型调用必要的规则处理进行数据转换或者信息拆分 然后交由具体逻辑处理实现模块IntegrateImpl完成业务集成逻辑，并最终 通过Serviceinvocation模块调用MDM的服务，完成交易。数据服务层要紧包括扩展服务和组合服务。2.1.8.10; tcSHvceXrTi如上图，按照业务需求，一样性的顺序如下详述：1 ejbCreate - MQ中的信息通知 WAS容器，按照MsgReceiver组件 的 MDB 情形，创建一个实例进入池态；2 onMessage - WAS容器调用MDB的onMessage方法，并把消息作 为参数传递到该方法；2.1 deliver - onMessage 方法中调用 IntegrateFW 组件的 deliver 方法， 并传递消息；2.1.1 parse - IntegrateFW组件调用MsgParser组件解析传入的消息 体；2.1.1.1 Constructor - MsgParser组件按照消息体解析，生成一个IBO bj 对象；2.1.2 parse - parse方法返回生成的IBObj对象；2.1.3 getTCRMTxType -猎取IBObj对象的服务类型；2.1.4 getTCRMTxType - 返回字符串结果；2.1.5 getRequestName - 猎取 IBObj 的要求者；2.1.6 getRequestName - 返回；2.1.7 Constructor - IntegrateFW按照服务对象和要求者，实例化一个 IntegrateImpl 组件中集成服务实例；2.1.8 execute -调用具体实例的业务逻辑，并把IBObj作为参数传递;2.1.8.1 callRule -调用标准代码转换规则，进行必要规则处理；2.1.8.2 callRule -返回规则处理后的IBObj对象；2.1.8.3 matchRule -调用客户识不规则，进行识不2.1.8.4 matchRule - 调用返回2.1.8.5 constructIBObj -在具体的业务逻辑处理中，按照具体需要调 用MsgParser创建需要的IBObj对象；2.1.8.5.1 Constructor - MsgParser 构建新的 IBObj 实例；2.1.8.6 constructIBObj - 返回具体的 IBObj 实例；2.1.8.7 setAttribute - 处理具体的IBObj实例内容；2.1.8.8 setAttribute - 处理内容返回；2.1.8.9 toServiceXml -处理完所有的IBObj实例内容后，调用方法转 换为 xml 标准服务格式；2.1.8.10 toServiceXml - 返回 xml 字节流；2.1.8.11 invoke -调用 MDM 服务；2.1.8.12 invoke - 返回；2.1.9 execute -完成具体业务集成逻辑实例的执行；2.2巧enver完成整个业务集成逻辑的执行；、注：幻土：nnq : MQ2.1.8到2.1.9之间可能有多次的callRule和invoke调用；2.1.8到2.1.9 execute的调用t需要包括1在事务处理中；integratFw : IntegratFWinteratefw : InterateFW批量处理的业务集成层设计参见批量型章节。O,k intenratelogic : IntegrateLogicIMsgRecGiver 组件OMsgReceiver 组件要紧由 IntegrateMDB 组成，IntegrateMDB 是一个 Me ssageDriverBean，通过 onMessage(Message)方法接收 MQ 的消息通知。信息接收组件要紧负责从MQ接收消息，参数Message使用BytesMes sage类型，消息格式为XML形式，其具体的接口定义参见服务接口定义 中的有关通过MQ接口部分。接口要紧包括：个险-增加客户(addPerson / CSCMQ) 个险-保全修改客户(updatePerson / CSCMQ) 电商网上销售-增加客户(addPerson / TOLMQ) 电商网上销售-修改客户差不多信息(updatePersonBase / TOLMQ) 电商网上销售-保全修改客户(updatePerson / TOLMQ)注：以上括号中的服务名是指各个业务系统提交到MQ中的消息服务 名，而不是MDM调用的标准服务名；组件调用 IntegrateFW 组件进行后续处理。public void onMessage(Message msg) if (msg instanceof BytesMessage) BytesMessage bm = (BytesMessage) msg; long length = bm.getBodyLength(); byte bs = new bytelength;bm.getBytes(bs);BytesInputStream bis = new BytesInputStream(bs);IntegrateFW.deliver(bis); else /* 执行具体的业务集成任务. 用于 MQ 异步通知模式* 在 IntegrateImpl 组件实现该方法，处理具体某一项接口的逻辑调用 一样包括*代码转换、服务拆分、服务变换、DSP判定等* param is输入流，是通过MQ接收到的消息内容，xml字节流* throws ItegrateException 例外，如果发生例外需要到例外组件处 理*/public void qxecute(IBobj obj) throws ItegrateException;根据客户号和l ob类卜型查询MDM数据库确根据请求来源把消息 中所有的标准代码转 .换为MDM代码、.组件对外调用的Fa ade接口调/*是否存在negraFw类，使用静态方法。否传递到IntegrateFW组件执行后续任务二用于MQ异步通知模式调用在线可疑客户识新增客户，调用 9 亍击甬调用在线可疑客户识param is输入s流服务是通过mQ接成收到配的消息内容别程xml字节流B,*/public static 根据已有客户名称inputStream已有客 户 id 更新 基本客户，调用 updatePerson服务用 updatePersonName 吗IntgrateImpl C 件 IntegrateImpl 组 期需求要服务更新姓名-据客户号和lob类型查询MDM数据库定是按照报类文类型确定的具体的业务集成逻辑的实现。是否存在-否记录错误信息例外处理个险增加客户结束 円分拆库务客户根据已有啓 客户电话是.服务，调用chlangePartyAddress 根据已有客户名称调 用 updatePersonName 服务更新姓名 根据已有客?户名称调 用 updatePersonName子分件联紀是L根据录错误rty息分拆. 形成客户处件服务，调用个险修改客户差不多信息名F根据已有 partyid 分结束根据已有partyid分拆 形成客户地址服务， 调用Address/个险保全修改客户信息结束 NchangePartyContactMetho根据已有客户Id更新基本客户，调用是updatePerson 服务根据已有客户Id更新基本客户，调用updatePerson 服务根据已有partyid分拆形成客户电话、电子邮件联系服务，调用changePartyContactMethodchangePartyldentifier 根据请求来源把消息 中所有的标准代码转 换为MDM代码 根据请求来源把消息 中所有的标准代码转 换为MDM代码根据已有partyid分拆形成客户证件服务，调用changePartyldentifier网上销售增加客户 参见个险增加客户，只是其接口内容稍有差异 网上销售修改客户差不多信息 参见个险修改客户差不多信息，只是其接口内容稍有差异 网上销售保全修改客户信息 参见个险保全修改客户信息，只是其接口内容稍有差异此组件需要处理地址、电话、电子邮件、客户标识等的格式变换，是把输入的对象格式变为标准的 MDM 扩展服务格式，包括： 从粗粒度服务格式转换为 updatePersonName 服务格式转换为changePartyAddress服务格式-服务中确定具体调用correctP artyAddress 依旧 addPartyAddress 依旧不做处理；转换为changePartyContactMethod服务格式-服务中定具体调用upd atePartyContactMethod 依旧 addPartyContactMethod 依旧不做处理；从粗粒度服务格式转换为changePartyldentifer服务格式-服务中定具体调用 updatePartyldentifer 依旧 addParty