一种代收付交易平台.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN109670952A(43)申请公布日2019.04.23(21)申请号201811519741.5(22)申请日2018.12.12(71)申请人中国对外经济贸易信托有限公司地址100031北京市西城区复兴门内大街28号凯晨世贸中心中座F6(72)发明人杨戈张磊田帅(74)专利代理机构北京知呱呱知识产权代理有限公司11577代理人武媛吕学文(51)Int.Cl.G06Q40/04(2012.01)G06F9/54(2006.01)G06F16/25(2019.01)权利要求书2页说明书4页附图1页(54)发明名称一种代收付交易平台(57)摘要本发明实施例涉及一种代收付交易平台，所述代收付交易平台包括接口程序、批次队列、交易消费队列、单笔队列、非单笔队列以及渠道网关回调监听程序。本申请提供的代收付交易平台，能够简化平台的部署，并提高代收付交易的效率。CN109670952ACN109670952A权利要求书1/2页1.一种代收付交易平台，其特征在于，所述代收付交易平台包括接口程序、批次队列、交易消费队列、单笔队列、非单笔队列以及渠道网关回调监听程序，其中：所述接口程序，用于接收业务系统发来的数据报文，并校验所述数据报文的格式；若所述数据报文校验成功，将所述数据报文写入缓存和数据库，并将所述数据报文对应的批次ID写入所述批次队列中；所述批次队列，用于获取所述批次ID对应的批次交易数据，并从所述批次交易数据中解包出交易信息和条目信息后，将所述交易信息和所述条目信息写入缓存和数据库，并将所述条目信息写入所述交易消费队列中；所述交易消费队列，用于获取下一个待执行的条目信息，并判断所述待执行的条目信息是按照批次处理还是按照单笔处理；所述单笔队列，用于存放按照单笔处理的条目信息，并将所述按照单笔处理的条目信息发送给渠道网关；所述非单笔队列，用于从所述交易消费队列中分批获取队列数据，并根据渠道批量接口将获取的所述队列数据批量发送给所述渠道网关；所述渠道网关回调监听程序，用于根据渠道返回的回调状态，判断当前执行的条目信息是否具备下一个执行计划，若具备，获取并执行下一个执行计划。2.根据权利要求1所述的代收付交易平台，其特征在于，所述接口程序，还用于在所述数据报文校验失败后，将所述数据报文写入数据库，并向所述业务系统返回失败结果。3.根据权利要求1所述的代收付交易平台，其特征在于，所述非单笔队列在分批获取队列数据时，预先读取所述交易消费队列的队列深度，并基于所述队列深度确定在一个批次中获取队列数据的数量，并按照确定出的所述数量从所述交易消费队列中获取当前批次的队列数据。4.根据权利要求1所述的代收付交易平台，其特征在于，所述非单笔队列还用于若同一个接口数据中有必须批量发送的数据时，将所述必须批量发送的数据在同一批次中发送至所述渠道网关。5.根据权利要求1或4所述的代收付交易平台，其特征在于，所述非单笔队列还用于若同一接口数据中没有必须批量发送的数据时，将所述同一接口数据转入所述单笔队列进行处理。6.根据权利要求1所述的代收付交易平台，其特征在于，所述交易消费队列还用于获取所述待执行的条目信息的路由信息，并将所述路由信息写入缓存和数据库中。7.根据权利要求1所述的代收付交易平台，其特征在于，所述批次队列在完成对批次交易数据的处理之后，将所述批次交易数据从缓存中删除。8.根据权利要求1所述的代收付交易平台，其特征在于，所述代收付交易平台还包括业务回调队列和缓存清理队列；相应的，所述渠道网关回调监听程序还用于在当前执行的条目信息不具备下一个执行计划时，尝试获取下一个待执行的条目信息；若不存在下一个待执行的条目信息，将当前的交易数据存入所述业务回调队列和所述缓存数据清理队列。9.根据权利要求8所述的代收付交易平台，其特征在于，所述渠道网关回调监听程序还用于若存在下一个待执行的条目信息，调用所述下一个待执行的条目信息对应的路由，并2CN109670952A权利要求书2/2页将路由结果写入缓存和数据库，以得到需要执行的执行计划。10.根据权利要求1所述的代收付交易平台，其特征在于，在所述代收付交易平台中，开发框架使用springboot，接口方式为Restful，部署框架使用springcloud，队列使用rabbitmq集群，与渠道交互频次限制机制为redis分布式锁。3CN109670952A说明书1/4页一种代收付交易平台技术领域[0001]本申请涉及网络交易技术领域，特别涉及一种代收付交易平台。背景技术[0002]随着线上支付的不断发展，涌现出各式各样的支付渠道。为了针对这些不同的支付渠道提供统一的管理机制，代收付交易平台应运而生。[0003]在当前的代收付交易平台中，开