業(yè)務數(shù)據(jù)集成

1、業(yè)務數(shù)據(jù)集成業(yè)務數(shù)據(jù)集成是指 MDM Server 與外圍系統(tǒng)之間的數(shù)據(jù)交換時需要中間處理的模塊應用層。業(yè)務電商電商個險團險養(yǎng)老金銀?？偪刈灾站W(wǎng)上銷售HttpMQFTP(file)近實時處理批量處理業(yè)務集成層Ext Package數(shù)據(jù)服務層Base ServicesMDM infrastructure批量加載架構(gòu)服務層MDM DB Module如圖所示，外圍系統(tǒng)要緊通過三種模式與 MDM Server 交互 (那個地點不考慮 ETL) ：直截了當?shù)?web service訪咨詢 要緊通過 http 協(xié)議聯(lián)機訪咨詢， 一樣不通過業(yè)務集成層而直截了當訪咨詢數(shù)據(jù)服務層近實時的消息通知 要緊通過

2、MQ 消息訪咨詢，需要在業(yè)務集成層進行必要的處理批量處理 要緊通過文件進行數(shù)據(jù)傳遞，需要在業(yè)務集成層進行處理業(yè)務集成服務層的要緊內(nèi)容包括：近實時的消息通知數(shù)據(jù)標準代碼的轉(zhuǎn)換交易 xml 的拆分MQ 組件是所有的客戶信息更新消息的載體，MsgReceiver 組件負責接收 MQ 的消息，通過 MsgParser組件進行 xml 格式解析， MsgReceiver 轉(zhuǎn)交到 IntegrateFW 組件，IntegrateFW 組件是轉(zhuǎn)發(fā)框架， 負責業(yè)務集成層的差不多操縱，按照報文的類型調(diào)用必要的規(guī)則處理進行數(shù)據(jù)轉(zhuǎn)換或者信息拆分，然后交由具體邏輯處理實現(xiàn)模塊 IntegrateImpl 完成業(yè)務集成

3、邏輯，并最終通過 ServiceInvocation 模塊調(diào)用 MDM 的服務，完成交易。數(shù)據(jù)服務層要緊包括擴展服務和組合服務。如上圖，按照業(yè)務需求，一樣性的順序如下詳述：1 ejbCreate MQ 中的信息通知 WAS 容器，按照 MsgReceiver 組件的 MDB 情形，創(chuàng)建一個實例進入池態(tài)；2 onMessage WAS 容器調(diào)用 MDB 的 onMessage方法，并把消息作為參數(shù)傳遞到該方法；2.1 deliver onMessage方法中調(diào)用 IntegrateFW 組件的 deliver 方法，并傳遞消息；2.1.1 parse IntegrateFW 組件調(diào)用 MsgPa

4、rser組件解析傳入的消息體； Constructor MsgParser組件按照消息體解析，生成一個IBObj 對象；2.1.2 parse parse方法返回生成的IBObj 對象；2.1.3 getTCRMTxType 獵取 IBObj 對象的服務類型；2.1.4 getTCRMTxType 返回字符串結(jié)果；2.1.5 getRequestName 獵取 IBObj 的要求者；2.1.6 getRequestName 返回；2.1.7 Constructor IntegrateFW 按照服務對象和要求者， 實例化一個IntegrateImpl 組件中集成服務實例；2.1.8

5、 execute 調(diào)用具體實例的業(yè)務邏輯， 并把 IBObj 作為參數(shù)傳遞； callRule 調(diào)用標準代碼轉(zhuǎn)換規(guī)則，進行必要規(guī)則處理； callRule 返回規(guī)則處理后的IBObj 對象； matchRule 調(diào)用客戶識不規(guī)則，進行識不 matchRule 調(diào)用返回 constructIBObj 在具體的業(yè)務邏輯處理中，按照具體需要調(diào)用 MsgParser創(chuàng)建需要的 IBObj 對象；.1 Constructor MsgParser構(gòu)建新的 IBObj 實例； constructIBObj 返回

6、具體的 IBObj 實例； setAttribute 處理具體的 IBObj 實例內(nèi)容； setAttribute 處理內(nèi)容返回； toServiceXml 處理完所有的 IBObj 實例內(nèi)容后，調(diào)用方法轉(zhuǎn)換為 xml 標準服務格式；0 toServiceXml 返回 xml 字節(jié)流；1 invoke 調(diào)用 MDM 服務；2 invoke 返回；2.1.9 execute 完成具體業(yè)務集成邏輯實例的執(zhí)行；調(diào)用；的調(diào)用需要包括在事務處理中；MsgReceiver 組件要緊由 IntegrateMDB 組成，Int

7、egrateMDB 是一個 Me ssageDriverBean，通過 onMessage(Message)方法接收 MQ 的消息通知。信息接收組件要緊負責從MQ 接收消息，參數(shù)Message使用 BytesMessage類型，消息格式為 XML 形式，其具體的接口定義參見 服務接口定義中的有關(guān)通過 MQ 接口部分。接口要緊包括：個險 增加客戶 (addPerson / CSCMQ)個險 保全修改客戶 (updatePerson / CSCMQ)電商網(wǎng)上銷售 增加客戶 (addPerson / TOLMQ)電商網(wǎng)上銷售 修改客戶差不多信息 (updatePersonBase/ TOLMQ)電商

8、網(wǎng)上銷售 保全修改客戶 (updatePerson / TOLMQ)注：以上括號中的服務名是指各個業(yè)務系統(tǒng)提交到 MQ 中的消息服務名，而不是 MDM 調(diào)用的標準服務名；組件調(diào)用 IntegrateFW 組件進行后續(xù)處理。public void onMessage(Messagemsg) if (msg instanceof BytesMessage) BytesMessage bm = (BytesMessage) msg; long length = bm.getBodyLength(); byte bs = new bytelength; bm.getBytes(bs);BytesInp

9、utStream bis = new BytesInputStream(bs);IntegrateFW.deliver(bis); else 件是框架 件， 集成 的操 度。 件 用然后按照 文 型 用具體的操 理 ，同 用 理 行數(shù)據(jù)和 理，最后形成 理后的 文提交 ，完成整個 理，同 如果在 理中 生 ， 交由如果 用出 需要 行回 理。/* 行具體的 集成任 . 用于 MQ 異步通知模式* 在 IntegrateImpl 件 方法， 理具體某一 接口的 用，一 包括* 代 、服 拆分、服 、 DSP 判定等* param is 輸入流，是通過 MQ 接收到的消息內(nèi)容， xml 字節(jié)流*

10、throws ItegrateException 例外，如果發(fā)生例外需要到例外組件處理*/public void execute(IBobj obj) throws ItegrateException;根據(jù)請求來源把消息開始中所有的標準代碼轉(zhuǎn)換為 MDM 代碼根據(jù)客戶號和 lob 類型查詢 MDM 數(shù)據(jù)庫 是否存在確定是否存在該客戶組件對外調(diào)用的Fa? ade 接口調(diào)用是 IntegratFW 類，使用靜態(tài)方法。否/*傳遞到 IntegrateFW 組件執(zhí)行后續(xù)任務 . 用于 MQ 異步通知模式新增客戶，調(diào)用調(diào)用在線可疑客戶識否成功匹配*AddPerson服務別程序param is 輸入流，是

11、通過MQ 接收到的消息內(nèi)容， xml 字節(jié)流*/是是public static void根據(jù)已有deliver(InputStream客戶名稱調(diào)根據(jù)已is);有客戶 Id更新用updatePersonName服務更新姓名根據(jù)客戶號和 lob類IntegrateImpl開始 組件型查詢 MDM 數(shù)據(jù)庫確定是否存在該客戶基本客戶，調(diào)用updatePerson服務是否存在記錄錯誤信息否例外處理IntegrateImpl 組件是按照報文類型確定的具體的業(yè)務集成邏輯的實現(xiàn)。根據(jù)客戶號和 lob類記錄錯誤信息根據(jù)已有 partyid 分拆根據(jù)已有 partyid 分拆形成開始否根據(jù)已有 partyid 分

12、拆型查詢 MDM 數(shù)據(jù)庫是否存在例外處理形成客戶地址服務，客戶電話、電子郵件聯(lián)系是形成客戶證件服務，一期需求要緊包括：確定是否存在該客戶服務，調(diào)用調(diào)用調(diào)用個險增加客戶結(jié)束changePartyAddress根據(jù)已有客戶名稱調(diào)用 updatePersonName服務更新姓名根據(jù)已有客戶名稱調(diào)用 updatePersonName服務更新姓名changePartyContactMethodchangePartyIdentifier根據(jù)已有客戶 Id更新根據(jù)請求來源把消息基本客戶，調(diào)用是中所有的標準代碼轉(zhuǎn)updatePerson服務換為 MDM 代碼根據(jù)已有客戶 Id更新根據(jù)請求來源把消息基本客戶，調(diào)

13、用中所有的標準代碼轉(zhuǎn)updatePerson服務換為 MDM 代碼個險修改客戶差不多信息根據(jù)已有 partyid分拆結(jié)束形成客戶地址服務，調(diào)用changePartyAddress個險保全修改客戶信息根據(jù)已有 partyid分拆形成根據(jù)已有 partyid分拆客戶電話、電子郵件聯(lián)系形成客戶證件服務，服務，調(diào)用調(diào)用changePartyContactMethodchangePartyIdentifier結(jié)束網(wǎng)上銷售增加客戶參見個險增加客戶，只是其接口內(nèi)容稍有差異網(wǎng)上銷售修改客戶差不多信息參見個險修改客戶差不多信息，只是其接口內(nèi)容稍有差異網(wǎng)上銷售保全修改客戶信息參見個險保全修改客戶信息，只是其接口內(nèi)

14、容稍有差異此組件需要處理地址、電話、電子郵件、客戶標識等的格式變換，是把輸入的對象格式變?yōu)闃藴实?MDM 擴展服務格式，包括：從粗粒度服務格式轉(zhuǎn)換為updatePersonName服務格式轉(zhuǎn)換為 changePartyAddress服務格式 服務中確定具體調(diào)用correctPartyAddress 依舊 addPartyAddress依舊不做處理；轉(zhuǎn)換為 changePartyContactMethod服務格式 服務中定具體調(diào)用updatePartyContactMethod依舊 addPartyContactMethod依舊不做處理；從粗粒度服務格式轉(zhuǎn)換為 changePartyIdenti

15、fer 服務格式 服務中定具體調(diào)用 updatePartyIdentifer依舊 addPartyIdentifer 依舊不做處理；具體接口參見服務接口和MDM 開發(fā)文檔。MsgParser是暴露在外的 Fa? ade調(diào)用界面，通過兩個個方法接收外部調(diào)用。/* 解析 xml.* param is 輸入流，是通過 MQ 接收到的消息內(nèi)容， xml 字節(jié)流*/public static IBObj parse(InputStream is);/* 把 IBObj 按照類型輸出為標準的MDMservice 報文 .* param obj 輸入的 IBObj* return 返回一個字節(jié)數(shù)組，組成xm

16、l，使用標準的iso-8859-1 格式*/public static byte toServiceXml(IBObj obj); /* 按照名稱構(gòu)建新的 IBObj 對象 .* param name 輸入的 IBObj 名稱* return 返回 IBObj 對象*/public static IBObj constructIBObj(String name);IBObj 是用于定義報文的bean，類似 MDM 中的 BObj。IBObj 要緊定義 xml 中的 bobj 對象，IBObj 內(nèi)部能夠嵌套。其暴露的接口如下。/* 設置 IBObj 的類型 . 是指對象類型，如 TCRMPers

17、onBObj、* TCRMAdminContEquivBObj 、TCRMPartyAddressBObj、TCRMAdd ressBObj 等。*/public void setType(String name);public String getType();/* 設置服務的類型 .*/public void setTCRMTxType(String type); pubic String getTCRMTxType();/* 設置服務的對象類型 .*/public void setTCRMTxObject(String obj);public String getTCRMTxObject

18、();/* 設置 IBObj 對象 .*/public void setIBObj(IBObj obj); /* 按照名字獵取 IBObj 對象 . 只能獵取下一級對象 .*/public IBObj getIBObj(String type); public String getAttribute(String type); /* 設置屬性 . 自動區(qū)分處理 Extension 屬性 .*/public String setAttribute(String type, String value); /* 設置服務頭 .*/public void setHeader(String header

19、); public String getHeader();/* 設置要求操縱部分 .*/public void setRequestControl(String rc);public String getRequestControl();/* 設置要求操縱部分的要求名稱 .*/public void setRequestName(String rn); public String getRequestName();/* 置要求操 部分的 LOB.*/public void setRequestLOB(String rlob); public String getRequestLOB();DSP

20、 Rule 件 理 DSP ，具體參 DSP 中在 可疑客 不。CD Rule 件 理 準代 的 ， 按照 requestName來判定來源，并把源系 準代 MDM 準代 。CDRule 件由 CDPool 從數(shù)據(jù) 中裝 準代 數(shù)據(jù)映射。映射關(guān)系是各個源系 指向MDM 。perites文件是每個源系 接口中的需要 的代 定 ，其格式如下：CSCMQ= GenderType|HighestEducationType|TCRMAdminContEquivBObj. AdminSystemType|TOLMQ=GenderType|格式以 Key=Value 方式存放， key

21、 源系 提交的requestName，而 是以 分割的多個數(shù)據(jù)域，每個數(shù)據(jù)域都需要 行 準代 替 。如果 數(shù)據(jù)域是在接口的更底 ，以TCRMAdminContEquivBObj.AdminSystemTypeTCRMAdminContEquivBObj 象和相 數(shù)據(jù)定 行代 任 。RuleFW 是 外暴露的 用 ，提供靜 方法。/* 規(guī)則調(diào)用處理 .* param type 規(guī)則類型，按照此類型確定是調(diào)用哪個規(guī)則實現(xiàn)* param obj 輸入輸出對象，規(guī)則實現(xiàn)對其進行處理，并形成結(jié)果返回*/public static void callRule(Stirng type, IBObj obj)

22、 throws IntegrateExc eption;一期需要進行的代碼轉(zhuǎn)換為：個險數(shù)據(jù)域源系統(tǒng)代碼源系統(tǒng)值MDM 代碼MDM 值GenderTypeM男M男F女F女U未知U未知TCRMPartyIdentificationBObj0身份證.IdentificationType00其它1參字第10后字第11空文字第12北文字13護照14裝字第15北文字第RelationshipType1本人2夫君3妻子4父親5母親6親小孩HighestEducationType01文盲 02小學 03初中 04高中 05大專 06本科 07 研 究生 及 以上 08中專 未知MaritalStatusTyp

23、e0未婚0未婚1已婚1已婚2離婚2離婚3鰥寡3鰥寡AddressUsageTypeB單位地址2單位地址P郵遞地址3郵遞地址R家庭地址1家庭地址電商網(wǎng)上銷售銀保養(yǎng)老金團險Utils 組件Utils 組件是工具類組件，要緊包括服務調(diào)用組件，負責進行MDM 服務的調(diào)用通過 IIOP 方式訪咨詢 MDM 的 EJB(DWLServiceController) 來處理 web service 格式的要求，具體請參考 MDM workbench 中的 com.ibm.mdm.traini ng.testerDWLServiceControllerTester。數(shù)據(jù)庫訪咨詢IntegException 組件

24、例外處理的組件，如果處理過程中有例外，則需要記錄例外的緣故和狀態(tài)，并把該服務要求xml 儲存到數(shù)據(jù)庫。例外后需要儲存的內(nèi)容如下：字段代碼類型備注錯誤流水號ERRLOGIDBigIntPK ，自增型時刻LOG_DTTimestamp錯誤返回消息ERRMESSAGEVarchar(255)exception.getMessage()或者業(yè)務邏輯錯誤講明，如找不到該客戶等錯誤提交消息REQUESTXMLXml 字段批量處理的要緊內(nèi)容類似業(yè)務數(shù)據(jù)集成章節(jié)的近實時處理部分，要緊是 FileParserMsgParser模塊解析具體的數(shù)據(jù)內(nèi)容，同樣，按照規(guī)則處理各個業(yè)務邏輯規(guī)則，然后形成具體的批量文件，并

25、調(diào)用批量處理的部分將會復用較多的近實時處理部分的業(yè)務組件，包括：MsgParser組件IntegException 組件CDRule 組件1 detectFile 守護線程，檢查各個系統(tǒng)相應名目下的上穿文件是否ready；2 Constructor 讀入文件，形成文件輸入流和輸出流， 并調(diào)用批量處理，按照源系統(tǒng)類型實例化具體的業(yè)務邏輯處理實例，傳遞輸入流；3 readOneService 從輸入流讀取一個service 塊；4 readOneService 返回讀取的 service塊；5 parse 調(diào)用 MsgParser把 servie塊的 xml 格式解析成為一個 IBObj ；6 p

26、arse 返回 IBObj ；7 callRule 調(diào)用代碼轉(zhuǎn)換 rule，轉(zhuǎn)換客戶證件類型、地址類型、聯(lián)系類型為 MDM 標準代碼；8 callRule 調(diào)用返回；9 writeTmp 把客戶關(guān)鍵信息寫入數(shù)據(jù)庫，內(nèi)容參見臨時表定義；10 writeTmp 返回；以上從 3 到 10 循環(huán)處理，直到文件輸入流到尾端；11 resetFile 把文件輸入流重新定位到開始；12 resetFile 返回重新定位后的文件輸入流；13 callRule 調(diào)用批量客戶識不的規(guī)則處理；13.1 updateTmp 按照規(guī)則處理結(jié)果更新臨時表，確定客戶增加、修改類型以及客戶的地址、聯(lián)系、證件類型更換類型；1

27、3.2 updateTmp 處理臨時表終止；14 callRule 調(diào)用規(guī)則返回；15 readOneService 從文件輸入流讀入一個service xml 塊；16 readOneService 返回 service塊；17 parse 調(diào)用 MsgParser解析為一個 IBObj ；18 parse 返回 IBObj ；19 readTmp 讀入一條與 IBObj 匹配的臨時表記錄；20 readTmp 讀入返回數(shù)據(jù)；21 callRule 調(diào)用格式轉(zhuǎn)換規(guī)則處理，按照臨時表類型標志，轉(zhuǎn)換 I BObj 的內(nèi)容為標準服務的 IBObj ；22 callRule 返回轉(zhuǎn)換完畢的IBObj

28、 ；23 toServiceXml 把 IBObj 轉(zhuǎn)換為標準的 xml 格式；24 toServiceXml xml 結(jié)果；25 writeXml2File 把 xml 結(jié)果寫入文件輸出流；26 writeXml2File 返回；以上 15 到 26 循環(huán)處理，直到文件處理完畢；27 runbatch.sh 關(guān)閉相應資源，調(diào)用 MDM 的 BatchProcessor進行批量處理，完成后處理相應輸入輸出及中間文件；批量處理接口批量處理要緊包括三個外部系統(tǒng)接口：銀保增加客戶養(yǎng)老金增加客戶團險增加客戶具體接口格式參見服務接口到規(guī)定的名目，具體參見服務接口中“批量接口模式”組件是解析文件的處理，其

29、要緊處理客戶的上傳數(shù)據(jù)文件，同時新建輸出結(jié)果文件。只能是一行；FileParser組件暴露一個抽象類 IntegrateBatchLogic 供 IntegrateImpl 組件實現(xiàn)，其抽象方法如下。/* 執(zhí)行具體的業(yè)務集成任務 . 用于批量模式否* 在 IntegrateImpl 組件實現(xiàn)該方法，處理具體某一項接口的邏輯調(diào)用，循環(huán)到各個源系統(tǒng)對是否存在狀態(tài)讀入文件讀入一個 service塊一樣包括是應目錄檢測上傳文件文件* 代碼轉(zhuǎn)換、服務拆分、服務變換、 DSP 判定等* param is 輸入流，是通過 MQ 接收到的消息內(nèi)容， xml 字節(jié)流進行代碼轉(zhuǎn)換：證件把關(guān)鍵信息寫入臨時例外，如果

30、發(fā)生例外需要到例外組件處* throws ItegrateException類型、地址類型、聯(lián)否文件結(jié)束表系類型理是*/從文件讀入一個service塊讀入臨時表信息一個重置文件到頭批量客戶匹配操作public abstract void executeBatch(InputStream is,OutputStream參見sq1參考 os) thro內(nèi)存塊ws ItegrateException;標準代碼轉(zhuǎn)換，把源根據(jù)已有 partyid分拆系統(tǒng)代碼轉(zhuǎn)換為形成客戶地址服務，在 IntegrateBatchLogic 中還實現(xiàn)必要根方據(jù)已法有：客戶名稱形MDM 標準代碼成updatePersonN

31、amecorrectPartyAddress格resetFile 重置文件指針到文件頭；服務 xml 格式式或者addPartyAddress是callBatchSDP 調(diào)用批量客戶識不規(guī)則；內(nèi)存塊結(jié)束修改客戶，根據(jù)內(nèi)存根據(jù)已有 partyid分拆形成客戶電callRule 調(diào)用代碼轉(zhuǎn)換規(guī)則；話、電子郵件聯(lián)系服務，否和文件內(nèi)容，形成匹配updatePartyContactMethod格式或updatePerson服務 xmlgetService 獵取文件的下一個格式service 塊；者 addPartyContactMethod客戶匹配類型 調(diào)用 MDM的 runbatch.shcallMD

32、MBatch根據(jù)已有 partyid分拆否不匹配形成客戶證件服務，把xml 輸出到文件updatePartyIdentificati增加客戶on或者IntegrateImpl 組件addPartyIdentification形成 addPerson服務xml 格式具體的業(yè)務集成邏輯實現(xiàn)，三個不同源系統(tǒng)的增加客戶業(yè)務集成邏輯相同，其具體內(nèi)容格式有所差異。是否結(jié)束調(diào)用 runbatch.sh具體邏輯處輸理入如文件下備份圖。臨時文件清理批量客戶識不匹配規(guī)則批量客戶識不匹配規(guī)則是指考慮執(zhí)行效率而進行的客戶識不匹配程序，其匹配規(guī)則與在線完全相同，但處理方式變成批量，規(guī)則參考如下：統(tǒng)一客戶治理平臺進行客戶

33、識不的關(guān)鍵數(shù)據(jù)包括：客戶名稱 +出生日期、證件類型 +證件編號以及客戶性不。為了提升系統(tǒng)的客戶識不能力和信息的準確度，加快業(yè)務處理的速度，系統(tǒng)針對用于客戶識不的關(guān)鍵數(shù)據(jù)進行了有效性規(guī)定，符合下列規(guī)定的信息才能夠作為客戶識不的依據(jù)：客戶名稱不承諾為空證件編號長度至少8 位。不滿足上述有效性規(guī)則的客戶信息會被加入統(tǒng)一客戶治理平臺，但可不能進行客戶識不。注：規(guī)則以在線匹配規(guī)則為準，請參考有關(guān)設計文檔以確認規(guī)則一致性；客戶匹配的主體是 MDM 數(shù)據(jù)庫的 contact / person / identifier 表；另外進行匹配的表是臨時表： tmp_contactSql 參考：- 先按照客戶號和源系

34、統(tǒng) id 進行匹配update tmp_contact t set(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_dtfromcontact c,person p,tmp_contact t,contequiv e,personname pnwherec.cont_id=p.cont_idand t.

35、lob_tp=e.ADMIN_SYS_TP_CDand t.lob_custno=e.ADMIN_CLIENT_IDand e.cont_id=p.cont_idand pn.cont_id=c.cont_idand _usage_tp_cd=1and (pn.end_dt is null or pn.end_dt current timestamp)and (c.end_dt is null or c.end_dt current timestamp)and (p.end_dt is null or p.end_dt current timestamp)and (e.end_d

36、t is null or e.end_dt current timestamp)where exists(select1fromcontact c,person p,tmp_contact t,contequiv e,personname pnwherec.cont_id=p.cont_idand t.lob_tp=e.ADMIN_SYS_TP_CDand t.lob_custno=e.ADMIN_CLIENT_IDand e.cont_id=p.cont_idand pn.cont_id=c.cont_idand _usage_tp_cd=1and (pn.end_dt is

37、null or pn.end_dt current timestamp)and (c.end_dt is null or c.end_dt current timestamp)and (p.end_dt is null or p.end_dt current timestamp)and (e.end_dt is null or e.end_dt current timestamp);- 按照證件類型證件號碼客戶姓名客戶生日進行匹配update tmp_contact t set(MATCH_TP,MATCH_PARTYID,MATCH_PARTYUPDT,MATCH_PERSONUPDT,PE

38、RSONNAMEID,PERSONNAME_UPDT)=(select1,c.cont_id,c.last_update_dt,p.last_update_dt,pn.person_name_id,pn.last_update_dtfromcontact c,person p,tmp_contact t,identifier i,personname pnwherec.cont_id=p.cont_idand i.cont_id=c.cont_idand t.id_tp_cd=i.id_tp_cdand t.ref_num=i.ref_numand length(rtrim(ltrim(t.r

39、ef_num)7and t.contact_name=c.contact_nameand t.person_name is not nulland t.person_nameand (t.GENDER_TP_CODE is null and p. t.GENDER_TP_CODE is null) or t.GENDER_TP_CODE=p.GENDER_TP_CODE)and char(t.birth_dt, ISO)=substr(p.birth_dt, 1, 10)and t.match_tp=2and pn.cont_id=c.cont_idand _usage_tp_c

40、d=1and (pn.end_dt is null or pn.end_dt current timestamp)and (c.end_dt is null or c.end_dt current timestamp)and (p.end_dt is null or p.end_dt current timestamp)and (i.end_dt is null or i.end_dt current timestamp)where exists(select c.cont_idfromcontact c,person p,tmp_contact t,identifier i,personna

41、me pnwherec.cont_id=p.cont_idand i.cont_id=c.cont_idand t.id_tp_cd=i.id_tp_cdand t.ref_num=i.ref_numand length(rtrim(ltrim(t.ref_num)7and t.contact_name=c.contact_nameand t.person_name is not nulland t.person_nameand (t.GENDER_TP_CODE is null and p.GENDER_TP_CODE is null) or t.GENDER_TP_CODE=p.GENDE

42、R_TP_CODE) and char(t.birth_dt, ISO)=substr(p.birth_dt, 1, 10) and t.match_tp=2and pn.cont_id=c.cont_id and _usage_tp_cd=1and (pn.end_dt is null or pn.end_dt current timestamp) and (c.end_dt is null or c.end_dt current timestamp) and (p.end_dt is null or p.end_dt current timestamp) and (i.end

43、_dt is null or i.end_dt current timestamp);- 按照匹配結(jié)果查找需要修改的證件號碼update tmp_contact t set(IDENT_MATCH_TP,IDENTIFIR_ID, IDENTIFIR_UPDT ) =(select1,IDENTIFIER_ID,LAST_UPDATE_DTfromtmp_contact t,identifier iwheret.match_partyid=i.cont_idand t.id_tp_cd=i.id_tp_cdand t.ref_numi.ref_numand (i.end_dt is null

44、or i.end_dt current timestamp)where exists(select1fromtmp_contact t,identifier iwheret.match_partyid=i.cont_idand t.id_tp_cd=i.id_tp_cdand t.ref_numi.ref_numand (i.end_dt is null or i.end_dt current timestamp);- 按照匹配結(jié)果查找需要修改的地址update tmp_partyaddress set(ADDR_UP_TP, PARTYADDRESSID, PARTYADDRESSUPDT,

45、 LOCATIONGROUPUPDT ) =(select2,a.location_group_id ,a.last_update_dt,l.last_update_dtfromlocationgroup l ,adderssgroup a ,tmp_contact t ,tmp_partyaddress pawhere l.location_group_id=a.location_group_id and l.cont_id=t.matcd_partyidand t.lob_tp=pa.lob_tpand t.lob_custno =pa.lob_custnoand pa.ADDR_USAGE_TP_CD=a.ADDR_USAGE_TP_CD and (l.end_dt is null or l.end_dt current timestamp)and (a.end_dt is null or a.end_dt current timestamp)where exists(select1fromlocationgroup l,adderssgroup a,tmp_contact t,tmp_partyaddress pawherel.location_group_id=a.location_