业务数据集成

功能概述业务数据集成是指MDMServer和外围系统之间的数据交换时需要中间处理的模块应用层。感谢阅读如图所示，外围系统主要通过三种模式和MDMServer交互(这里不考虑ETL)：感谢阅读直接的webservice访问–主要通过http协议联机访问，壹般不通过业务集成层而精品文档放心下载直接访问数据服务层近实时的消息通知–主要通过MQ消息访问，需要于业务集成层进行必要的处理谢谢阅读批量处理–主要通过文件进行数据传递，需要于业务集成层进行处理精品文档放心下载业务集成服务层的主要内容包括：近实时的消息通知数据标准代码的转换交易xml的拆分其他规则批量处理标准代码的转换入库方式判断处理，判断是否是新增仍是更改交易拆分其他规则）联机数据集成主要处理近实时消息通知，处理模式如下图所示。感谢阅读MQ组件是所有的客户信息更新消息的载体，MsgReceiver组件负责接收MQ的消息，通精品文档放心下载过MsgParser组件进行xmlMsgReceiver转交到IntegrateFW组件，IntegrateFW精品文档放心下载组件是转发框架，负责业务集成层的基本控制，根据报文的类型调用必要的规则处理进行数谢谢阅读据转换或者信息拆分，然后交由具体逻辑处理实现模块IntegrateImpl完成业务集成逻辑，精品文档放心下载且最终通过ServiceInvocation模块调用MDM的服务，完成交易。感谢阅读数据服务层主要包括扩展服务和组合服务。如上图，根据业务需求，壹般性的顺序如下详述：1ejbCreate–MQ中的信息通知WASMsgReceiver组件的MDB精品文档放心下载实例进入池态；2onMessage–WAS容器调用MDB的onMessage方法，且把消息作为参数传递到该方法；谢谢阅读2.1deliver–onMessage方法中调用IntegrateFW组件的deliver方法，且传递消息；谢谢阅读2.1.1parse–IntegrateFW组件调用MsgParser组件解析传入的消息体；感谢阅读Constructor–MsgParser组件根据消息体解析，生成壹个IBObj对象；精品文档放心下载2.1.2parse–parse方法返回生成的IBObj对象；感谢阅读2.1.3getTCRMTxType–获取IBObj对象的服务类型；谢谢阅读2.1.4getTCRMTxType–返回字符串结果；精品文档放心下载2.1.5getRequestName–获取IBObj的请求者；谢谢阅读2.1.6getRequestName–返回；2.1.7Constructor–IntegrateFW根据服务对象和请求者，实例化壹个IntegrateImpl精品文档放心下载组件中集成服务实例；2.1.8execute–调用具体实例的业务逻辑，且把IBObj作为参数传递；精品文档放心下载callRule–调用标准代码转换规则，进行必要规则处理；精品文档放心下载callRule–返回规则处理后的IBObj对象；谢谢阅读matchRule–调用客户识别规则，进行识别精品文档放心下载matchRule–调用返回constructIBObj–于具体的业务逻辑处理中，根据具体需要调用MsgParser创精品文档放心下载建需要的IBObj对象；.1Constructor–MsgParser构建新的IBObj实例；感谢阅读constructIBObj–返回具体的IBObj实例；感谢阅读setAttribute–处理具体的IBObj实例内容；谢谢阅读setAttribute–处理内容返回；感谢阅读toServiceXml–处理完所有的IBObj实例内容后，调用方法转换为xml标准服精品文档放心下载务格式；0toServiceXml–返回xml字节流；感谢阅读1invoke–调用MDM服务；2invoke–返回；2.1.9execute–完成具体业务集成逻辑实例的执行；感谢阅读2.2deliver–完成整个业务集成逻辑的执行；注：2.1.8到2.1.9之间可能有多次的callRule和invoke调用；谢谢阅读2.1.8到2.1.9execute的调用需要包括于事务处理中；谢谢阅读批量处理的业务集成层设计参见《批量型》章节。MsgReceiver组件主要由IntegrateMDB组成，IntegrateMDB是壹个精品文档放心下载MessageDriverBean，通过onMessage(Message)方法接收MQ的消息通知。感谢阅读信息接收组件主要负责从MQ接收消息，参数Message使用BytesMessage类型，消息格谢谢阅读式为XML形式，其具体的接口定义参见《服务接口定义》中的关联通过MQ接口部分。感谢阅读接口主要包括：个险–增加客户(addPerson/CSCMQ)个险–保全修改客户(updatePerson/CSCMQ)感谢阅读电商网上销售–增加客户(addPerson/TOLMQ)谢谢阅读电商网上销售–修改客户基本信息(updatePersonBase/TOLMQ)感谢阅读电商网上销售–保全修改客户(updatePerson/TOLMQ)精品文档放心下载注：之上括号中的服务名是指各个业务系统提交到MQ中的消息服务名，而不是MDM调精品文档放心下载用的标准服务名；组件调用IntegrateFW组件进行后续处理。精品文档放心下载publicvoidonMessage(Messagemsg){感谢阅读……if(msginstanceofBytesMessage){精品文档放心下载BytesMessagebm=(BytesMessage)msg;精品文档放心下载longlength=bm.getBodyLength();精品文档放心下载byte[]bs=newbyte[length];bm.getBytes(bs);BytesInputStreambis=newBytesInputStream(bs);精品文档放心下载IntegrateFW.deliver(bis);}else{……}……}IntegrateFW组件是框架组件，负责业务集成层的控制调度。组件负责调用MsgParser感谢阅读组件，解析xml报文，然后根据报文类型调用具体的控制处理逻辑，同时调用业务处理规则精品文档放心下载进行数据和业务处理，最后形成处理后的报文提交ServiceInvocation组件调用精品文档放心下载MDMService，完成整个处理，同时如果于处理中发生异常，则交由IntegException组件处谢谢阅读理异常结果。IntegrateFW组件中对于多个service调用作为同壹事务来管理，如果调用出错需要进感谢阅读行回滚处理。IntegrateFW组件暴露壹个接口IntegrateLogic供IntegrateImpl精品文档放心下载法如下。/***执行具体的业务集成任务.用于MQ异步通知模式*于IntegrateImpl组件实现该方法，处理具体某壹项接口的逻辑调用，壹般包括感谢阅读*代码转换、服务拆分、服务变换、DSP判断等*@paramis输入流，是通过MQ接收到的消息内容，xml字节流谢谢阅读*@throwsItegrateException例外，如果发生例外需要到例外组件处理精品文档放心下载*/publicvoidexecute(IBobjobj)throwsItegrateException;谢谢阅读组件对外调用的Façade接口调用是IntegratFW类，使用静态方法。谢谢阅读/***传递到IntegrateFW组件执行后续任务.用于MQ异步通知模式精品文档放心下载*@paramis输入流，是通过MQ接收到的消息内容，xml字节流谢谢阅读*/publicstaticvoiddeliver(InputStreamis);谢谢阅读IntegrateImpl组件是根据报文类型确定的具体的业务集成逻辑的实现。谢谢阅读壹期需求主要包括：个险增加客户个险修改客户基本信息个险保全修改客户信息网上销售增加客户参见个险增加客户，只是其接口内容稍有差异网上销售修改客户基本信息参见个险修改客户基本信息，只是其接口内容稍有差异网上销售保全修改客户信息参见个险保全修改客户信息，只是其接口内容稍有差异此组件需要处理地址、电话、电子邮件、客户标识等的格式变换，是把输入的对象格式谢谢阅读变为标准的MDM扩展服务格式，包括：从粗粒度服务格式转换为updatePersonName服务格式感谢阅读转换为changePartyAddress服务格式–服务中确定具体调用correctPartyAddress精品文档放心下载仍是addPartyAddress仍是不做处理；精品文档放心下载转换为changePartyContactMethod服务格式–服务中定具体调用感谢阅读updatePartyContactMethod仍是addPartyContactMethod仍是不做处理；精品文档放心下载从粗粒度服务格式转换为changePartyIdentifer服务格式–服务中定具体调用谢谢阅读updatePartyIdentifer仍是addPartyIdentifer仍是不做处理；精品文档放心下载具体接口参见《服务接口》和MDM开发文档。服务逻辑参见关联于线服务组合服务设计；信息解析主要是根据xml报文解析其内容。MsgParser组件根据不同的报文类型解析不同的内容。感谢阅读MsgParser组件仍负责输出变更后的报文结果。感谢阅读MsgParser是暴露于外的Façade调用界面，通过俩个个方法接收外部调用。感谢阅读/***解析xml.*@paramis输入流，是通过MQ接收到的消息内容，xml字节流精品文档放心下载*/publicstaticIBObjparse(InputStreamis);精品文档放心下载/***把IBObj根据类型输出为标准的MDMservice报文.感谢阅读*@paramobj输入的IBObj*@return返回壹个字节数组，组成xml，使用标准的iso-8859-1格式精品文档放心下载*/publicstaticbyte[]toServiceXml(IBObjobj);谢谢阅读/***根据名称构建新的IBObj对象.*@paramname输入的IBObj名称*@return返回IBObj对象*/publicstaticIBObjconstructIBObj(Stringname);谢谢阅读IBObj是用于定义报文的bean，类似MDM中的BObj。精品文档放心下载IBObj主要定义xml中的bobj对象，IBObj内部能够嵌套。其暴露的接口如下。谢谢阅读/***设置IBObj的类型.是指对象类型，如TCRMPersonBObj、谢谢阅读*TCRMAdminContEquivBObj、TCRMPartyAddressBObj、TCRMAddressBObj等。感谢阅读*/publicvoidsetType(Stringname);谢谢阅读publicStringgetType();/***设置服务的类型.*/publicvoidsetTCRMTxType(Stringtype);谢谢阅读pubicStringgetTCRMTxType();精品文档放心下载/***设置服务的对象类型.*/publicvoidsetTCRMTxObject(Stringobj);精品文档放心下载publicStringgetTCRMTxObject();感谢阅读/***设置IBObj对象.*/publicvoidsetIBObj(IBObjobj);精品文档放心下载/***根据名字获取IBObj对象.只能获取下壹级对象.感谢阅读*/publicIBObj[]getIBObj(Stringtype);谢谢阅读publicStringgetAttribute(Stringtype);感谢阅读/***设置属性.自动区分处理Extension属性.谢谢阅读*/publicStringsetAttribute(Stringtype,Stringvalue);谢谢阅读/***设置服务头.*/publicvoidsetHeader(Stringheader);谢谢阅读publicStringgetHeader();/***设置请求控制部分.*/publicvoidsetRequestControl(Stringrc);谢谢阅读publicStringgetRequestControl();感谢阅读/***设置请求控制部分的请求名称.*/publicvoidsetRequestName(Stringrn);谢谢阅读publicStringgetRequestName();精品文档放心下载/***设置请求控制部分的LOB.*/publicvoidsetRequestLOB(Stringrlob);精品文档放心下载publicStringgetRequestLOB();精品文档放心下载处理DSP规则，具体参见DSP设计中于线可疑客户识别。谢谢阅读处理标准代码的转换，根据requestName来判断来源，且把源系统标准代码转换为MDM谢谢阅读标准代码。CDRule组件由CDPool从数据库中装载标准代码数据映射。映射关系是各个源系统指向精品文档放心下载MDM。perites文件是每个源系统接口中的需要转换的代码定义，其格式如下：感谢阅读CSCMQ=GenderType|HighestEducationType|TCRMAdminContEquivBObj.AdminSystemTyp感谢阅读e|…TOLMQ=GenderType|…格式以Key=Value方式存放，key为源系统提交的requestName，而值是以’|’分割的精品文档放心下载多个数据域，每个数据域均需要进行标准代码替换。如果该数据域是于接口的更底层，精品文档放心下载以’.’作为路径分割，如TCRMAdminContEquivBObj.AdminSystemType表示是于该对象中的精品文档放心下载TCRMAdminContEquivBObj对象下的AdminSystemType需要进行代码转换。感谢阅读具体的实现类CDRule则根据输入IBObj对象和相应数据定义进行代码转换任务。感谢阅读RuleFW是对外暴露的调用类，提供静态方法。/***规则调用处理.*@paramtype规则类型，根据此类型确定是调用哪个规则实现感谢阅读*@paramobj输入输出对象，规则实现对其进行处理，且形成结果返回谢谢阅读*/publicstaticvoidcallRule(Stirngtype,IBObjobj)throwsIntegrateException;精品文档放心下载壹期需要进行的代码转换为：精品文档放心下载个险充GenderTypeM男M男F女F女U未知U未知TCRMPartyIdentificationBOb0身份证谢谢阅读j00其它.IdentificationType1参字第10后字第11空文字第12北文字13护照14装字第15北文字第RelationshipType1本人2丈夫3妻子4父亲5母亲6儿子HighestEducationType'01''文盲'感谢阅读'02''小学''03''初中''04''高中''05''大专''06''本科''07''研究生及之上''08''中专'未知MaritalStatusType0未婚0未婚感谢阅读1已婚1已婚2离婚2离婚3鳏寡3鳏寡AddressUsageTypeB单位地址2单位地址谢谢阅读P邮递地址3邮递地址R家庭地址1家庭地址电商网上销售银保养老金团险Utils组件是工具类组件，主要包括服务调用组件，负责进行MDM服务的调用通过IIOP方式访问MDM的EJB(DWLServiceController)来处理webservice格式的请求，精品文档放心下载具体请参考MDMworkbench中的com.ibm.mdm.training.testerDWLServiceControllerTester。感谢阅读数据库访问谢谢阅读例外处理的组件，如果处理过程中有例外，则需要记录例外的原因和状态，且把该服务精品文档放心下载请求xml保存到数据库。例外后需要保存的内容如下：错误流水号ERRLOGIDBigIntPK，自增型谢谢阅读时间LOG_DTTimestamp错误返回消息ERRMESSAGEVarchar(255exception.getMessage()精品文档放心下载)或者业务逻辑错误说明，如找不到该客户等错误提交消息REQUESTXMLXml字段错误堆栈同样需要记录到log4j日志中。）批量处理的主要内容类似业务数据集成章节的近实时处理部分，主要是FileParser模谢谢阅读块管理各个业务系统上传的批量文件，且调用MsgParser模块解析具体的数据内容，同样，感谢阅读根据规则处理各个业务逻辑规则，然后形成具体的批量文件，且调用MDM的BatchProcessor感谢阅读进行批量处理。具体模块关系如下图所示。批量处理的部分将会复用较多的近实时处理部分的业务组件，包括：谢谢阅读MsgParser组件IntegException组件CDRule组件1detectFile–守护线程，检查各个系统相应目录下的上穿文件是否ready；感谢阅读2Constructor–读入文件，形成文件输入流和输出流，且调用批量处理，根据源系统类感谢阅读型实例化具体的业务逻辑处理实例，传递输入流；3readOneService–从输入流读取壹个service块；感谢阅读4readOneService–返回读取的service块；谢谢阅读5parse–调用MsgParser把servie块的xml格式解析成为壹个IBObj；谢谢阅读6parse–返回IBObj；7callRule–调用代码转换rule，转换客户证件类型、地址类型、联系类型为MDM标准感谢阅读代码；8callRule–调用返回；9writeTmp–把客户关键信息写入数据库，内容参见临时表定义；精品文档放心下载10writeTmp–返回；之上从3到10循环处理，直到文件输入流到尾端；感谢阅读11resetFile–把文件输入流重新定位到开始；感谢阅读12resetFile–返回重新定位后的文件输入流；谢谢阅读13callRule–调用批量客户识别的规则处理；13.1updateTmp–根据规则处理结果更新临时表，确定客户增加、修改类型以及客户的感谢阅读地址、联系、证件类型更改类型；13.2updateTmp–处理临时表结束；14callRule–调用规则返回；15readOneService–从文件输入流读入壹个servicexml块；感谢阅读16readOneService–返回service块；感谢阅读17parse–调用MsgParser解析为壹个IBObj；精品文档放心下载18parse–返回IBObj；19readTmp–读入壹条和IBObj匹配的临时表记录；感谢阅读20readTmp–读入返回数据；21callRule–调用格式转换规则处理，根据临时表类型标志，转换IBObj的内容为标准谢谢阅读服务的IBObj；22callRule–返回转换完毕的IBObj；23toServiceXml–把IBObj转换为标准的xml格式；感谢阅读24toServiceXml–xml结果；25writeXml2File–把xml结果写入文件输出流；感谢阅读26writeXml2File–返回；之上15到26循环处理，直到文件处理完毕；27runbatch.sh–关闭相应资源，调用MDM的BatchProcessor进行批量处理，完成后处精品文档放心下载理相应输入输出及中间文件；批量处理主要包括三个外部系统接口：银保增加客户养老金增加客户团险增加客户具体接口格式参见《服务接口》外部系统输出符合接口规范的数据文件，且FTP到规定的目录，具体参见《服务接口》感谢阅读中“批量接口模式。FileParser组件是解析文件的处理，其主要处理客户的上传数据文件，同时新建输出结谢谢阅读果文件。解析整体文件格式；包括输入输出，输出文件每个servicexml只能是壹行；精品文档放心下载FileParser调用IntegrateFW组件以处理不同的业务集成逻辑。精品文档放心下载FileParser组件暴露壹个抽象类IntegrateBatchLogic供IntegrateImpl感谢阅读抽象方法如下。/***执行具体的业务集成任务.用于批量模式*于IntegrateImpl组件实现该方法，处理具体某壹项接口的逻辑调用，壹般包括谢谢阅读*代码转换、服务拆分、服务变换、DSP判断等*@paramis输入流，是通过MQ接收到的消息内容，xml字节流精品文档放心下载*@throwsItegrateException例外，如果发生例外需要到例外组件处理谢谢阅读*/publicabstractvoidexecuteBatch(InputStreamis,OutputStreamos)throwsItegrateE感谢阅读xception;于IntegrateBatchLogic中仍实现必要方法：感谢阅读resetFile–重置文件指针到文件头；callBatchSDP–调用批量客户识别规则；感谢阅读callRule–调用代码转换规则；getService–获取文件的下壹个service块；谢谢阅读callMDMBatch–调用MDM的runbatch.sh谢谢阅读具体的业务集成逻辑实现，三个不同源系统的增加客户业务集成逻辑相同，其具体内容谢谢阅读格式有所差异。具体逻辑处理如下图。批量客户识别匹配规则是指考虑执行效率而进行的客户识别匹配程序，其匹配规则和于谢谢阅读线完全相同，但处理方式变成批量，规则参考如下：统壹客户管理平台进行客户识别的关键数据包括：客户名称+出生日期、证件类型+证件感谢阅读编号以及客户性别。为了提高系统的客户识别能力和信息的准确度，加快业务处理的速度，精品文档放心下载系统针对用于客户识别的关键数据进行了有效性规定，符合下列规定的信息才能够作为客户感谢阅读识别的依据：客户名称不允许为空证件编号长度至少8位。不满足上述有效性规则的客户信息会被加入统壹客户管理平台，但不会进行客户识别。谢谢阅读注：规则以于线匹配规则为准，请参考关联设计文档以确认规则壹致性；感谢阅读客户匹配的主体是MDM数据库的contact/person/identifier表；感谢阅读另外进行匹配的表是临时表：tmp_contactSql参考：--先根据客户号和源系统id进行匹配updatetmp_contacttset(MATCH_TP,MATCH_PARTYID,MATCH_PARTYUPDT,MATCH_PERSONUPDT,PERSONNAMEID,PERSONNAME_UPDT)=(select1,c.cont_id,c.last_update_dt,p.last_update_dt,pn.person_name_id,pn.last_update_dtfromcontactc,personp,tmp_contactt,contequive,personnamepnwherec.cont_id=p.cont_idandt.lob_tp=e.ADMIN_SYS_TP_CD谢谢阅读andt.lob_custno=e.ADMIN_CLIENT_ID感谢阅读ande.cont_id=p.cont_idandpn.cont_id=c.cont__usage_tp_cd=1and(pn.end_dtisnullorpn.end_dt>currenttimestamp)精品文档放心下载and(c.end_dtisnullorc.end_dt>currenttimestamp)感谢阅读and(p.end_dtisnullorp.end_dt>currenttimestamp)精品文档放心下载and(e.end_dtisnullore.end_dt>currenttimestamp)感谢阅读)whereexists(select1fromcontactc,personp,tmp_contactt,contequive,personnamepnwherec.cont_id=p.cont_idandt.lob_tp=e.ADMIN_SYS_TP_CD精品文档放心下载andt.lob_custno=e.ADMIN_CLIENT_ID谢谢阅读ande.cont_id=p.cont_idandpn.cont_id=c.cont__usage_tp_cd=1and(pn.end_dtisnullorpn.end_dt>currenttimestamp)感谢阅读and(c.end_dtisnullorc.end_dt>currenttimestamp)精品文档放心下载and(p.end_dtisnullorp.end_dt>currenttimestamp)谢谢阅读and(e.end_dtisnullore.end_dt>currenttimestamp)谢谢阅读);--根据证件类型证件号码客户姓名客户生日进行匹配updatetmp_contacttset(MATCH_TP,MATCH_PARTYID,MATCH_PARTYUPDT,MATCH_PERSONUPDT,PERSONNAMEID,PERSONNAME_UPDT)=(select1,c.cont_id,c.last_update_dt,p.last_update_dt,pn.person_name_id,pn.last_update_dtfromcontactc,personp,tmp_contactt,identifieri,personnamepnwherec.cont_id=p.cont_idandi.cont_id=c.cont_idandt.id_tp_cd=i.id_tp_cdandt.ref_num=i.ref_numandlength(rtrim(ltrim(t.ref_num)))>7感谢阅读andt.contact_name=c.contact_name精品文档放心下载andt.person_nameisnotnullandt.person_name<>’’and((t.GENDER_TP_CODEisnullandp.t.GENDER_TP_CODEisnull)ort.GENDER_T感谢阅读P_CODE=p.GENDER_TP_CODE)andchar(t.birth_dt,ISO)=substr(p.birth_dt,1,10)感谢阅读andt.match_tp=2andpn.cont_id=c.cont__usage_tp_cd=1and(pn.end_dtisnullorpn.end_dt>currenttimestamp)精品文档放心下载and(c.end_dtisnullorc.end_dt>currenttimestamp)精品文档放心下载and(p.end_dtisnullorp.end_dt>currenttimestamp)精品文档放心下载and(i.end_dtisnullori.end_dt>currenttimestamp)感谢阅读)whereexists(selectc.cont_idfromcontactc,personp,tmp_contactt,identifieri,personnamepnwherec.cont_id=p.cont_idandi.cont_id=c.cont_idandt.id_tp_cd=i.id_tp_cdandt.ref_num=i.ref_numandlength(rtrim(ltrim(t.ref_num)))>7谢谢阅读andt.contact_name=c.contact_name感谢阅读andt.person_nameisnotnullandt.person_name<>’’and((t.GENDER_TP_CODEisnullandp.GENDER_TP_CODEisnull)ort.GENDER_TP_谢谢阅读CODE=p.GENDER_TP_CODE)andchar(t.birth_dt,ISO)=substr(p.birth_dt,1,10)谢谢阅读andt.match_tp=2andpn.cont_id=c.cont__usage_tp_cd=1and(pn.end_dtisnullorpn.end_dt>currenttimestamp)精品文档放心下载and(c.end_dtisnullorc.end_dt>currenttimestamp)感谢阅读and(p.end_dtisnullorp.end_dt>currenttimestamp)精品文档放心下载and(i.end_dtisnullori.end_dt>currenttimestamp)感谢阅读);--根据匹配结果查找需要修改的证件号码updatetmp_contacttset(IDENT_MATCH_TP,IDENTIFIR_ID,IDENTIFIR_UPDT)=(select1,IDENTIFIER_ID,LAST_UPDATE_DTfromtmp_contactt,identifieriwheret.match_partyid=i.cont_idandt.id_tp_cd=i.id_tp_cdandt.ref_num<>i.ref_numand(i.end_dtisnullori.end_dt>currenttimestamp)精品文档放心下载)whereexists(select1fromtmp_contactt,identifieriwheret.match_partyid=i.cont_idandt.id_tp_cd=i.id_tp_cdandt.ref_num<>i.ref_numand(i.end_dtisnullori.end_dt>currenttimestamp)感谢阅读);--根据匹配结果查找需要修改的地址updatetmp_partyaddressset(ADDR_UP_TP,PARTYADDRESSID,PARTYADDRESSUPDT,LOCATIONGROUPUPDT)=(select2,a.location_group_id,a.last_update_dt,l.last_update_dtfromlocationgroupl,adderssgroupa,tmp_contactt,tmp_partyaddresspawherel.location_group_id=a.location_group_id谢谢阅读andl.cont_id=t.matcd_partyid谢谢阅读andt.lob_tp=pa.lob_tpandt.lob_custno=pa.lob_custno精品文档放心下载andpa.ADDR_USAGE_TP_CD=a.ADDR_USAGE_TP_CD感谢阅读and(l.end_dtisnullorl.end_dt>currenttimestamp)感谢阅读and(a.end_dtisnullora.end_dt>currenttimestamp)感谢阅读)whereexists(select1fromlocationgroupl,adderssgroupa,tmp_contactt,tmp_partyaddresspawherel.location_group_id=a.location_group_id精品文档放心下载andl.cont_id=t.matcd_partyid谢谢阅读andt.lob_tp=pa.lob_tpandt.lob_custno=pa.lob_custno精品文档放心下载andpa.ADDR_USAGE_TP_CD=a.ADDR_USAGE_TP_CD感谢阅读and(l.end_dtisnullorl.end_dt>currenttimestamp)感谢阅读and(a.end_dtisnullora.end_dt>currenttimestamp)感谢阅读);--根据匹配结果查找需要修改的联系updatetmp_partycontactmethodset精品文档放心下载(CONT_METH_UP_TP,PARTYCONTMETHID,PARTYCONTMETHUPDT,LOCATIONGROUPUPDT)=(select2,a.location_group_id,a.last_update_dt,l.last_update_dtfromlocationgroupl,contactmethodgroupa,tmp_contactt,tmp_partycontactmethodpawherel.location_group_id=a.location_group_id精品文档放心下载andl.cont_id=t.matcd_partyid谢谢阅读andt.lob_tp=pa.lob_tpandt.lob_custno=pa.lob_custno精品文档放心下载andpa.CONT_METH_TP_CD=a.CONT_METH_TP_CD精品文档放心下载and(l.end_dtisnullorl.end_dt>currenttimestamp)感谢阅读and(a.end_dtisnullora.end_dt>currenttimestamp)感谢阅读)whereexists(select1fromlocationgroupl,adderssgroupa,tmp_contactt,tmp_partyaddresspawherel.location_group_id=a.location_group_id精品文档放心下载andl.cont_id=t.matcd_partyid谢谢阅读andt.lob_tp=pa.lob_tpandt.lob_custno=pa.lob_custno精品文档放心下载andpa.CONT_METH_TP_CD=a.CONT_METH_TP_CD感谢阅读and(l.end_dtisnullorl.end_dt>currenttimestamp)谢谢阅读and(a.end_dtisnullora.end_dt>currenttimestamp)谢谢阅读);tmp_Contact源系统类型LOB_TPBigIntPK客户号LOB_CUSTNOVarchar(50)PK感谢阅读客户姓名PERSON_NAMEVarchar(50)感谢阅读客户证件类型ID_TP_CDBigInt客户证件号码REF_NUMVarchar(50)谢谢阅读客户生日BIRTH_DTDate客户性别GENDER_TP_CODEBigInt谢谢阅读匹配类型MATCH_TPInt1–根据源系统客感谢阅读户号匹配2–根据证件类型号码等匹配，3–不匹配缺省为3匹配partyIdMATCH_PARTYIDBigint感谢阅读匹配partyUpdateDTMATCH_PARTYUPDTTimestamp谢谢阅读匹配personUpdateDTMATCH_PERSONUPDTTimestamp谢谢阅读客户姓名IDPERSONNAMEIDBigint精品文档放心下载客户姓名更新时间PERSONNAME_UPDTTimestamp谢谢阅读证件更新标志IDENT_MATCH_TPInt1–更新证件谢谢阅读2–不更新缺省为2证件idIDENTIFIR_IDBigint证件更新时间IDENTIFIR_UPDTTimestamp谢谢阅读需要考虑旧客户的证件号码更新；tmp_PartyAddress源系统类型LOB_TPBigIntPK客户号LOB_CUSTNOVarchar(50)PK谢谢阅读地址类型ADDR_USAGE_TP_CDBigIntPK感谢阅读地址修改类型ADDR_UP_TPInt1–新增精品文档放心下载2–更新缺省为1客户地址idPARTYADDRESSIDBigint精品文档放心下载客户地址updatedtPARTYADDRESSUPDTTimestamp感谢阅读LocationGroupupdtLOCATIONGROUPUPDTTimestamp谢谢阅读tmp_PartyContactMethod源系统类型LOB_TPBigIntPK客户号LOB_CUSTNOVarchar(50)PK谢谢阅读联系类型CONT_METH_TP_CDBigIntPK谢谢阅读联系修改类型CONT_METH_UP_TPInt1–新增感谢阅读2–更新缺省为1客户联系idPARTYCONTMETHIDBigint谢谢阅读客户联系updatedtPARTYCONTMETHUPDTTimestamp感谢阅读LocationGroupupdtLOCATIONGROUPUPDTTimestamp感谢阅读灰色区域是原始写入客户信息，白色区域是匹配后的更新内容；精品文档放心下载遗漏未匹配客户是指于上壹个批量期间由于批量处理时间窗口内实时、近实时增加客户精品文档放心下载时和批量客户可能的合且情况，由于时间的差错导致形成2条不同记录的情况，同时这种情谢谢阅读况由于且发情况下不能完全锁定DSP处理的串行化从而可能出现的情况。精品文档放心下载遗漏未匹配客户处理是针对上述情况的客户合且处理，其条件为：谢谢阅读新增客户–created_dt为新增；符合匹配条件–contact.contact_name/person.birth_dt/identifier.id_tp_cd/identifier.r感谢阅读ef_num/person.GENDER_TP_CODE相