一种交易服务编排系统的制作方法

本申请涉及计算机，特别是涉及一种交易服务编排系统。

背景技术：

1、在金融科技领域，交易场景中涉及大量数据的查询、归并和计算，这些操作通常非常耗时。因此，传统的交易接口通常采用异步处理方式，尤其是核心交易接口依赖于多个其他交易接口时，这种方式尤为重要。异步操作处理通常包含两个远程调用：一个是交易处理接口，另一个是交易结果查询接口。

2、在具体的应用场景中，例如配置一个对公转账交易时，前置操作依赖于流水核验，首先需要配置一系列原子接口，如流水查询、流水校验、对公转账和转账结果查询，并进行优先级配置：流水查询的优先级最高，依次为流水校验、对公转账和转账查询。所有这些接口按照优先级依次衔接，确保交易流程的顺利进行。为了实现整个交易闭环，通常会设置跑批组：一组负责交易发起任务，另一组负责异步结果查询任务。通过跑批机制自驱动业务流程，实现交易的最终完成。

3、这种复杂的异步交易处理方式虽然能够实现交易的最终一致性，但若每笔核心交易依赖于其他交易的成功，必须确保依赖的所有交易都成功才能进行下一步操作。若最终交易失败，则需要对前面的交易进行回滚操作。如果其中一笔依赖交易成功，而另一笔失败，也需要对成功的交易进行回滚。

4、随着异步交易数量的增加，处理逻辑会变得极其复杂，管理这些异步操作变得更加困难。需要在多个异步操作之间协调，以确保它们按预期顺序执行。这要求系统具备强大的并发处理能力和精确的状态管理功能，以避免由于处理不当导致的交易失败或数据不一致。

5、交易场景中不仅需要保证交易的最终一致性，还需要确保处理的时效性。而现有异步处理逻辑存在使交易处理陷入死锁或长时间等待的风险。

技术实现思路

1、本申请实施例提供了一种交易服务编排系统，以实现优化异步交易处理流程，提高处理效率，减少交易失败的风险。

2、为了实现上述目的，本申请实施例提供了一种交易服务编排系统，包括：

3、交易服务接口配置模块，将所述交易服务接口配置为包括：交易接口、查询接口，所述交易接口用于执行交易操作，所述交易操作包括但不限于：流水查询、资金占用、充值、转账，所述查询接口用于获取交易接口的交易操作结果；

4、类型标记模块，将所述交易接口、查询接口标记为同步接口或异步接口，其中，异步接口下允许配置依赖接口，所述异步接口在并异步任务队列中执行任务，所述同步接口在并行执行队列中执行任务，所述同步接口用于根据交易请求调用所需数据并立即返回调用结果，所述异步接口用于根据交易调用请求在后台进行数据处理并在完成后通知调用方；

5、接口编排模块，配置所述交易接口的优先级和/或所述查询接口的优先级，基于交易服务的业务逻辑对交易接口、查询接口之间的调用顺序进行编排，基于所述优先级及编排后的调用顺序通过跑批服务对并行执行队列进行触发调用，所述交易跑批服务下挂载多个交易接口、查询接口，其中，按照编排后的调用顺序将并行执行队列中的任务与异步任务队列中的任务进行串联调用。

6、在其中一些实施例中，所述接口编排模块进一步包括：

7、优先级配置单元，基于交易服务的业务逻辑配置所述交易接口和/或查询接口的优先级顺序，用于按照优先级顺序实现接口的顺序执行。

8、在其中一些实施例中，所述接口编排模块进一步包括：

9、并行执行配置单元，将业务逻辑中可并行执行的交易接口和/或查询接口按照接口路径path、接口入参、接口出参进行配置绑定，并对优先级相同的接口进行标记，从而实现优先级相同且可并行执行的交易接口的批量并行执行。

10、在其中一些实施例中，所述接口编排模块进一步包括：

11、当所述异步接口下设置有多个依赖接口时，根据其依赖接口的优先级及执行类型进行操作，所述执行类型包括同步执行、并行执行，所述同步执行表示业务请求间串联执行，所述并行执行表示将所述并行执行配置单元标记的接口同时执行，以缩短交易时间。

12、在其中一些实施例中，所述接口编排模块进一步包括：

13、接口组编辑单元，将所述查询接口按照执行需求阶段分为参数准备查询接口组、异步结果查询接口组，所述参数准备查询接口组中的查询接口用于在跑批任务执行前获取或验证所需的参数信息；所述异步结果查询接口组中的查询接口用于在跑批任务执行后查询任务的执行状态或结果。

14、在其中一些实施例中，所述接口编排模块提供有跑批配置接口，所述跑批配置接口连接至配置跑批服务的技术平台，从而允许查询和设置跑批时间。

15、在其中一些实施例中，所述跑批时间采用时间周期结合时间的形式进行配置，时间周期如每小时、每天、每周，时间如8:00、12:20等，相较于现有技术按照cron表达式配置，该形式降低专业性要求，以方便业务人员配置。

16、在其中一些实施例中，所述交易操作结果包括：成功、失败或处理中。

17、在其中一些实施例中，所述交易接口还包括：

18、交易撤销接口，用于在查询接口获取交易接口的交易操作结果失败时进行失败撤销操作；

19、交易撤销查询接口，用于查询交易撤销接口的撤销操作结果。

20、在其中一些实施例中，所述交易撤销接口标记为异步接口，所述交易撤销查询接口标记为同步接口。

21、相比于相关技术，本申请实施例提供的交易服务编排系统，通过结合交易接口逻辑编排、交易查询接口逻辑编排及跑批的时间编排，最终输出整个核心交易结果，通过抽象配置化，将交易类操作实现标准化、配置化，减少研发时间；通过双管道跑批服务，并开放时间，可以灵活的根据自己的交易接口异步时效合理的设置串并行触发时间，使得整笔交易时间大大缩短；交易接口的上下配置衔接及设置优先级和并串行，使得执行顺序清晰，容易排错；整体使得硬编码的业务逻辑通过标准化的服务编排来打包场景核心交易，使得输出标准化，方便对接。

22、本申请的一个或多个实施例的细节在以下附图和描述中提出，以使本申请的其他特征、目的和优点更加简明易懂。

1.一种交易服务编排系统，其特征在于，包括：

2.根据权利要求1所述的交易服务编排系统，其特征在于，所述接口编排模块进一步包括：

3.根据权利要求2所述的交易服务编排系统，其特征在于，所述接口编排模块进一步包括：

4.根据权利要求3所述的交易服务编排系统，其特征在于，所述接口编排模块进一步包括：

5.根据权利要求1所述的交易服务编排系统，其特征在于，所述接口编排模块进一步包括：

6.根据权利要求1所述的交易服务编排系统，其特征在于，所述接口编排模块提供有跑批配置接口，所述跑批配置接口连接至配置跑批服务的技术平台，从而允许查询和设置跑批时间。

7.根据权利要求6所述的交易服务编排系统，其特征在于，所述跑批时间采用时间周期结合时间的形式进行配置。

8.根据权利要求1所述的交易服务编排系统，其特征在于，所述交易操作结果包括：成功、失败或处理中。

9.根据权利要求8所述的交易服务编排系统，其特征在于，所述交易接口还包括：

10.根据权利要求9所述的交易服务编排系统，其特征在于，所述交易撤销接口标记为异步接口，所述交易撤销查询接口标记为同步接口。