基于智能算法的聚合跨境商品交易分发系统及方法与流程

本发明涉及知识图谱，尤其涉及基于智能算法的聚合跨境商品交易分发系统及方法。

背景技术：

1、知识图谱技术领域涉及以实体、属性和关系为基础对结构化数据进行表示、存储和推理的计算机处理方式。其中，聚合跨境商品交易分发系统是指服务器将商品实体、商家实体、区域实体、渠道实体和交易记录写入图数据库或关系数据库，通过商品编码、类目关系、区域关系和渠道关系建立数据关联，并在接收交易请求后按照图数据查询路径生成对应的商品分发结果。

2、现有跨境商品交易分发在实际运作中多依赖固定渠道规则和静态库存记录、商品、商家、区域、渠道之间的关联关系分散，渠道网关返回的排队压力，确认时延，剩余接单能力难以及时汇入分发判断，订单路径选择容易与渠道实时承载能力脱节，库存占用和交易需求核对滞后，造成高峰期指令堆积，路径反复回退，部分渠道超量接单，履约时效波动及跨区域分发稳定性持续明显下降。

技术实现思路

1、本发明的目的在于提供一种基于智能算法的聚合跨境商品交易分发系统及方法，使跨境商品交易分发过程中能够围绕商品、商家、区域和渠道之间的关联关系进行路径确定，并结合渠道网关的实时接单状态、路径占用单量以及商品库存数量对分发路径进行核对和排列，从而形成与商品出境状态、渠道剩余接单能力和库存交易数量相匹配的商品分发处理方案。

2、为实现上述目的，本发明提供一种基于智能算法的聚合跨境商品交易分发系统，包括图存储模块、网关读取模块、路径检索模块、接单核对模块和指令生成模块。

3、所述图存储模块用于存储商品实体、商家实体、区域实体、渠道实体，并记录商品出境状态、商品库存数量、交易商品数量、渠道单次接单数量。所述网关读取模块与渠道网关进行通信连接，用于从渠道网关接收排队指令条数、指令确认耗时和剩余接单数量，并将所述排队指令条数、所述指令确认耗时和所述剩余接单数量写入所述渠道实体的当前接单记录。所述路径检索模块与所述图存储模块进行连接，用于接收商品编码、商家标识、收货区域标识和商品出境状态，确定经过所述商品实体、所述商家实体、所述区域实体和所述渠道实体的商品分发路径。所述接单核对模块与所述路径检索模块、所述网关读取模块进行连接，用于对所述商品分发路径中的所述渠道单次接单数量进行累计得到路径占用单量，将所述路径占用单量与所述剩余接单数量进行比较，删除所述路径占用单量超过所述剩余接单数量的所述商品分发路径，生成可下发分发路径。所述指令生成模块与所述接单核对模块、所述网关读取模块和所述图存储模块进行连接，用于依据所述指令确认耗时和所述排队指令条数对所述可下发分发路径进行排列，选取排序在先且所述商品库存数量不低于所述交易商品数量的所述可下发分发路径，并按照对应路径进行商品分发。

4、进一步地，所述图存储模块包括实体索引单元、状态写入单元和关系维护单元。所述实体索引单元用于获取所述商品编码、所述商家标识、所述收货区域标识和渠道标识，将所述商品实体、所述商家实体、所述区域实体和所述渠道实体分别写入不同实体索引区，并建立各实体索引区之间的唯一键值关联，生成实体定位索引。所述状态写入单元用于获取所述商品出境状态、所述商品库存数量、所述交易商品数量和所述渠道单次接单数量，按照所述实体定位索引将所述商品出境状态、所述商品库存数量和所述交易商品数量写入所述商品实体，将所述渠道单次接单数量写入所述渠道实体，生成状态数量记录。所述关系维护单元用于根据所述实体定位索引和所述状态数量记录建立所述商品实体与所述商家实体、所述商家实体与所述区域实体、所述区域实体与所述渠道实体之间的有向关系边，并将所述有向关系边与所述状态数量记录进行绑定。

5、进一步地，所述网关读取模块包括网关接口单元、字段解析单元和记录写入单元。所述网关接口单元用于与渠道网关建立通信连接，按照所述渠道实体对应的渠道标识接收网关返回报文，并从所述网关返回报文中获取所述排队指令条数、所述指令确认耗时和所述剩余接单数量，生成网关接单数据。所述字段解析单元用于获取所述网关接单数据，按照渠道标识将所述排队指令条数、所述指令确认耗时和所述剩余接单数量分别映射至对应所述渠道实体，并对映射后的字段生成读取时间戳，得到接单字段记录。所述记录写入单元用于获取所述接单字段记录，将所述接单字段记录写入所述渠道实体的当前接单记录，并以读取时间戳刷新所述当前接单记录的更新时间。

6、作为附加限定，所述网关接单数据包括网关报文序列值，所述字段解析单元获取同一所述渠道标识对应的上一网关报文序列值，将所述网关报文序列值与所述上一网关报文序列值进行顺序比较，当所述网关报文序列值晚于所述上一网关报文序列值时保留所述排队指令条数、所述指令确认耗时和所述剩余接单数量，当所述网关报文序列值未晚于所述上一网关报文序列值时去除对应的所述网关接单数据。

7、进一步地，所述路径检索模块包括请求解析单元、实体匹配单元和路径生成单元。所述请求解析单元用于获取所述商品编码、所述商家标识、所述收货区域标识和所述商品出境状态，对上述字段进行字段完整性校验，并在校验通过后生成检索约束记录。所述实体匹配单元用于获取所述检索约束记录，从所述图存储模块读取所述商品实体、所述商家实体、所述区域实体和所述渠道实体，按照所述商品编码、所述商家标识、所述收货区域标识和所述商品出境状态分别匹配对应实体，生成路径端点记录。所述路径生成单元用于获取所述路径端点记录，沿所述商品实体、所述商家实体、所述区域实体和所述渠道实体之间的有向关系边进行连续检索，保留同时经过四类实体且满足所述商品出境状态的连续关系边，生成所述商品分发路径。

8、在所述连续检索过程中，获取所述路径端点记录中的所述商品实体、所述商家实体和所述区域实体，将所述商品实体作为起始节点，将所述区域实体作为约束节点，按照所述商品实体至所述商家实体、所述商家实体至所述区域实体、所述区域实体至所述渠道实体的关系边顺序扩展候选边，当候选边的实体顺序与关系边顺序一致时保留候选边，当候选边缺失任一实体顺序时删除候选边。

9、进一步地，所述接单核对模块包括单量读取单元、占用计算单元和路径筛除单元。所述单量读取单元用于获取所述商品分发路径，并读取所述商品分发路径中所述渠道实体对应的所述渠道单次接单数量以及当前接单记录中的所述剩余接单数量，将所述渠道实体、所述渠道单次接单数量和所述剩余接单数量建立对应关系，生成接单核对记录。所述占用计算单元用于获取所述接单核对记录，按照所述商品分发路径中的所述渠道实体出现顺序对所述渠道单次接单数量进行累计，得到所述路径占用单量。所述路径筛除单元用于获取所述路径占用单量和所述剩余接单数量，将两者进行比较，当所述路径占用单量超过所述剩余接单数量时删除对应所述商品分发路径，当所述路径占用单量未超过所述剩余接单数量时保留对应所述商品分发路径，生成所述可下发分发路径。

10、作为优选，确定所述路径占用单量时，获取所述接单核对记录中的所述渠道实体和所述渠道单次接单数量，将同一所述商品分发路径内重复出现的相同所述渠道实体确定为重复渠道实体，仅保留所述重复渠道实体对应的一个所述渠道单次接单数量参与累计，并将非重复渠道实体对应的所述渠道单次接单数量按照路径顺序进行累计，得到所述路径占用单量。

11、进一步地，所述指令生成模块包括排序计算单元、库存核验单元和路径执行单元。所述排序计算单元用于获取所述可下发分发路径、所述指令确认耗时和所述排队指令条数，将同一所述渠道实体对应的所述指令确认耗时和所述排队指令条数映射至对应所述可下发分发路径，并按照指令确认耗时由短至长、排队指令条数由少至多的顺序生成路径排序记录。所述库存核验单元用于获取所述路径排序记录、所述商品库存数量和所述交易商品数量，按照所述路径排序记录依次比较所述商品库存数量与所述交易商品数量，确定所述商品库存数量不低于所述交易商品数量对应的所述可下发分发路径为候选执行路径。所述路径执行单元用于获取所述候选执行路径，按照所述候选执行路径中的渠道实体生成分发指令，并将分发指令发送至对应所述渠道实体。

12、本发明还提供一种基于智能算法的聚合跨境商品交易分发方法，所述方法用于实现上述基于智能算法的聚合跨境商品交易分发系统，包括以下步骤：存储商品实体、商家实体、区域实体、渠道实体，并记录商品出境状态、商品库存数量、交易商品数量、渠道单次接单数量；从渠道网关接收排队指令条数、指令确认耗时和剩余接单数量，将所述排队指令条数、所述指令确认耗时和所述剩余接单数量写入所述渠道实体的当前接单记录；接收商品编码、商家标识、收货区域标识和商品出境状态，确定经过所述商品实体、所述商家实体、所述区域实体和所述渠道实体的商品分发路径；对所述商品分发路径中的所述渠道单次接单数量进行累计得到路径占用单量，将所述路径占用单量与所述剩余接单数量进行比较，删除所述路径占用单量超过所述剩余接单数量的所述商品分发路径，生成可下发分发路径；依据所述指令确认耗时和所述排队指令条数对所述可下发分发路径进行排列，选取排序在先且所述商品库存数量不低于所述交易商品数量的所述可下发分发路径，并按照对应路径进行商品分发。

13、与现有技术相比，本发明的优点和积极效果在于：

14、本发明中，围绕商品、商家、区域、渠道建立统一关联表达，并将出境状态、库存数量、交易数量、渠道单次接单数量纳入同一分发语境，渠道网关的排队条数、确认耗时、剩余接单数量实时写入接单记录，路径检索以商品编码，商家标识，收货区域标识和出境状态共同限定可选范围，再以路径占用单量同剩余接单能力核对，超载路径提前剔除，剩余路径依据确认耗时和排队压力排序，并结合库存与交易数量校验后下发，使分发决策同时受实体关系，渠道承载，库存可用性约束，减少指令积压和路径回退，提升跨境履约稳定性。