时间戳控制-技术说明文档-Oracle EBS技术文档整理

REFDocTitleOracleERP最佳技术实践REFLastDateMarch20,2013IfSection2>1“DateAuthorVersionChangeReference2015/08/22Zhengyan.CaoDraft1aNoPreviousDocument2015/09/30Rex.HuaUpdateReviewersNamePositionDistributionCopyNo.NameLocationNoteToHolders:Ifyoureceiveanelectroniccopyofthisdocumentandprintitout,pleasewriteyournameontheequivalentofthecoverpage,fordocumentcontrolpurposes.Ifyoureceiveahardcopyofthisdocument,pleasewriteyournameonthefrontcover,fordocumentcontrolpurposes.ContentsTOC\o"2-3"DocumentControl iiPreface 2时间戳控制使用说明 3使用说明 3OpenandClosedIssuesforthisDeliverable 6OpenIssues 6ClosedIssues 6PAGE10Preface在很多场景下我们需要控制全量数据的获取，改全量为增量。比如：EBS和MES集成，EBS定时从MES中获取完工数据，完工数据量巨大，我们不可能每次把全部数据取出来。这个时候我们就考虑一个增量的办法。时间戳为获取增量数据较为常用的方法之一：每次数据处理的时候，把当前时间存储下来，在下次获取数据的时候，只获取上次保存时间点之后(含)的数据即可。时间戳控制使用说明使用说明获取系统当前时间或者与外围系统集成的需要获取对方的系统时间2. 获取时间戳cux_pub_timestamp_control_pub.get_timestamp_datecux_pub_timestamp_control_pub.get_timestamp_date3. 更新时间戳,把当前时间l_sysdate更新上去cux_pub_timestamp_control_pub.update_timestamp_datecux_pub_timestamp_control_pub.update_timestamp_date4. 把获取的时间戳日期作为参数传入,获取数据（此处注意,时间判断一定要大于等于,否则有数据丢失的风险）参考cux_pub_timestamp_control_cess_timestamp_demo进行时间戳的控制内容如下：PROCEDUREPROCEDUREprocess_timestamp_demo(p_init_msg_listINVARCHAR2DEFAULTfnd_api.g_false,p_commitINVARCHAR2DEFAULTfnd_api.g_false,x_return_statusOUTNOCOPYVARCHAR2,x_msg_countOUTNOCOPYNUMBER,x_msg_dataOUTNOCOPYVARCHAR2)ISl_api_nameCONSTANTVARCHAR2(100):='PROCESS_TIMESTAMP_DEMO';l_savepoint_nameCONSTANTVARCHAR2(100):='PROCESS_TIMESTAMP_DEMO_SP';CURSORcur_data(p_timestamp_dateDATE)ISSELECT*FROMfnd_userfuWHERE(fu.last_update_date>=p_timestamp_dateORp_timestamp_dateISNULL)--此处注意,一定要大于等于,否则有数据丢失的风险;l_timestamp_dateDATE;--时间戳l_sysdateDATE;--获取当前时间,与外围系统集成的需要获取对方的系统时间l_tiemstamp_typeVARCHAR2(80):=upper('DEMO');--时间戳类型：快码CUX_PUB_TIMESTAMP_TYPE中定义BEGIN--STARTACTIVITYTOCREATESAVEPOINT,CHECKCOMPATIBILITY--ANDINITIALIZEMESSAGELIST,INCLUDEDEBUGMESSAGEHINTTOENTERAPIx_return_status:=cux_api.start_activity(p_pkg_name=>g_pkg_name,p_api_name=>l_api_name,p_savepoint_name=>l_savepoint_name,p_init_msg_list=>p_init_msg_list);raise_exception(x_return_status);-->>1.0获取系统当前时间或者与外围系统集成的需要获取对方的系统时间l_sysdate:=SYSDATE;/*--对于DBlink,需要用dblink获取对方的系统时间,这个一定要注意SELECTSYSDATEINTOl_sysdateFROMdual@erp_linkto_;*/-->>2.0获取时间戳l_timestamp_date:=cux_pub_timestamp_control_pub.get_timestamp_date(p_tiemstamp_type=>l_tiemstamp_type);-->>3.0更新时间戳,把当前时间l_sysdate更新上去cux_pub_timestamp_control_pub.update_timestamp_date(x_return_status=>x_return_status,x_msg_count=>x_msg_count,x_msg_data=>x_msg_data,p_tiemstamp_type=>l_tiemstamp_type,p_timestamp_date=>l_sysdate);raise_exception(x_return_status);-->>4.0把获取的时间戳日期作为参数传入,获取数据FORrecINcur_data(p_timestamp_date=>l_timestamp_date)LOOP--数据处理NULL;ENDLOOP;x_return_status:=cux_api.end_activity(p_pkg_name=>g_pkg_name,p_api_name=>l_api_name,p_commit=>p_commit,x_msg_count=>x_msg_count,x_msg_data=>x_msg_data);raise_exception(x_return_status);EXCEPTIONWHENfnd_api.g_exc_errorTHENx_return_status:=cux_api.handle_exceptions(p_pkg_name=>g_pkg_name,p_api_name=>l_api_name,p_savepoint_name=>l_savepoint_name,p_exc_name=>cux_api.g_exc_name_error,x_msg_count=>x_msg_count,x_msg_data=>x_msg_data);WHENfnd_api.g_exc_unexpected_errorTHENx_return_status:=cux_api.handle_exceptions(p_pkg_name=>g_pkg_name,p_api_name=>l_api_name,p_savepoint_name=>l_savepoint_name,p_exc_name=>cux_api.g_exc_name_unexp,x_msg_count=>x_msg_count,x_msg_data=>x_msg_data);WHENOTHERSTHENx_return_status:=cux_api.handle_exceptions(p_pkg_name=>g_pkg_name