数据处理框架的实现方法、装置、设备及计算机存储介质

    公开(公告)号:CN111400319B

    公开(公告)日:2025-04-11

    申请号:CN202010180672.0

    申请日:2020-03-13

    Inventor: 刘建波 夏勇

    Abstract: 本发明公开了一种数据处理框架的实现方法、装置、设备及计算机存储介质,涉及金融科技技术领域。该方法包括:创建目标序列号生成器;创建目标序列号生成器工厂类,继承Spring Batch的默认序列号生成器工厂类,并重写目标序列号生成器工厂类中继承的getIncrementer方法,以将继承的getIncrementer方法中的MySQL序列号生成器替换为目标序列号生成器;创建目标配置器类,继承Spring Batch的默认配置器类,并重写目标配置器类中继承的createJobRepository方法,以指定序列号生成器工厂类为目标序列号生成器工厂类。本发明能够避免序列号生成失败的问题、以实现在TiDB上运行Spring Batch。

    文件处理方法、装置、设备及计算机可读存储介质

    公开(公告)号:CN110457260B

    公开(公告)日:2024-07-02

    申请号:CN201910761804.6

    申请日:2019-08-14

    Inventor: 夏勇 李凌

    Abstract: 本发明涉及金融科技技术领域,公开了一种文件处理方法、装置、设备及计算机可读存储介质。该文件处理方法包括:在接收到文件处理请求时,根据所述文件处理请求获取待处理文件及其文件名称,并根据所述文件名称从预设配置表中获取对应的配置信息;根据所述配置信息和第一预设规则对所述待处理文件进行转换处理,得到待处理Java对象;根据所述配置信息中的处理类名,调用对应的执行器对所述待处理Java对象进行处理,得到处理结果Java对象;根据所述配置信息和第二预设规则对所述处理结果Java对象进行转换处理,得到处理结果文件。本发明能够通过配置的方式实现文件的自动化处理,以减少开发人员的工作量、提高开发效率。

    JSON报文的核对方法和JSON报文的核对装置

    公开(公告)号:CN113489593B

    公开(公告)日:2022-11-08

    申请号:CN202110746878.X

    申请日:2021-06-30

    Inventor: 夏柱昌 夏勇

    Abstract: 本发明涉及金融科技(Fintech)技术领域,公开了一种JSON报文的核对方法和JSON报文的核对装置,该方法包括:获取待核对JSON报文和预设的报文核对规则,其中,报文核对规则基于待核对JSON报文进行配置得到;将待核对JSON报文中的第一源报文转换为Map数据结构的第二源报文,并将待核对JSON报文中的第一目标报文转换为Map数据结构的第二目标报文;若比对得到第二源报文与第二目标报文的MD5值不一致,则按照报文核对规则从第二源报文中确定源Value值,和按照报文核对规则从第二目标报文中确定目标Value值;根据源Value值和目标Value值进行核对以得到待核对JSO N报文的报文核对结果。本发明能够提升JSON报文一致性核对的效率。

    一种文件生成方法、装置、设备及计算机可读存储介质

    公开(公告)号:CN110287193A

    公开(公告)日:2019-09-27

    申请号:CN201910570445.6

    申请日:2019-06-27

    Inventor: 夏勇 李凌 刘建波

    Abstract: 本申请公开了一种文件生成方法、装置、设备及计算机可读存储介质,该方法包括:获取数据字典中的至少一个电子表格,电子表格用于描述其对应的数据库表的数据结构;根据至少一个电子表格生成建表脚本,该建表脚本用于生成数据库表;执行该建表脚本,得到与至少一个电子表格对应的至少一个数据库表;根据至少一个数据库表生成应用于至少一个数据库表的文件。

    交易数据处理方法、装置、设备及计算机可读存储介质

    公开(公告)号:CN110175919A

    公开(公告)日:2019-08-27

    申请号:CN201910461198.6

    申请日:2019-05-29

    Inventor: 夏勇 李凌 曹晓橹

    Abstract: 本发明公开了一种交易数据处理方法,该方法包括:获取与待记账的转账交易对应的交易数据;对所述交易数据进行分组,使得同一组交易数据的借贷双方相同;分别对每个分组中的借贷双方的交易金额进行轧差处理,得到每个分组对应的汇总交易金额;根据所述汇总交易金额,对账务数据库中的所述借贷双方的账户余额进行更新。本发明还公开了一种交易数据处理装置、设备和一种计算机可读存储介质。本发明能够减少交易记账耗时,提高交易记账效率。

    一种任务执行方法及装置
    6.
    发明公开

    公开(公告)号:CN110147273A

    公开(公告)日:2019-08-20

    申请号:CN201910413986.8

    申请日:2019-05-17

    Inventor: 夏勇 李凌

    Abstract: 本发明公开了一种任务执行方法及装置,其中方法为:第一处理设备获取预定义任务;所述预定义任务包括N个步骤;N为大于1的整数;所述第一处理设备根据所述N个步骤之间存在的依赖关系,生成所述预定义任务对应的执行有向图;所述执行有向图为指示出所述N个步骤根据所述依赖关系确定的执行顺序的有向图,若所述N个步骤中不存在所述依赖关系的任意两个步骤,则所述有向图指示所述任意两个步骤并行执行;所述第一处理设备按照所述执行有向图指示的步骤执行顺序,执行所述预定义任务,该方法应用于金融科技(Fintech)领域时,提高了金融交易的效率。

    一种任务调度方法及装置
    7.
    发明公开

    公开(公告)号:CN111400015A

    公开(公告)日:2020-07-10

    申请号:CN202010214730.7

    申请日:2020-03-24

    Inventor: 刘建波 夏勇

    Abstract: 本发明公开了一种任务调度方法及装置,其中方法为:主机设备通过第一应用实例竞争任务列表中的第一任务;所述任务列表中的各任务是由各应用实例注册并用于各应用实例共同竞争的;所述第一应用实例为所述各应用实例中任一应用实例;所述第一任务为所述任务列表中的至少一个任务;所述主机设备若通过所述第一应用实例竞争到所述第一任务,则通过所述第一应用实例调度所述第一任务。上述方法应用于金融科技(Fintech)时,能够充分调动各应用实例所在的主机设备的资源,使得各个应用实例都具有较高的执行效率。

    JSON报文的核对方法和JSON报文的核对装置

    公开(公告)号:CN113489593A

    公开(公告)日:2021-10-08

    申请号:CN202110746878.X

    申请日:2021-06-30

    Inventor: 夏柱昌 夏勇

    Abstract: 本发明涉及金融科技(Fintech)技术领域,公开了一种JSON报文的核对方法和JSON报文的核对装置,该方法包括:获取待核对JSON报文和预设的报文核对规则,其中,报文核对规则基于待核对JSON报文进行配置得到;将待核对JSON报文中的第一源报文转换为Map数据结构的第二源报文,并将待核对JSON报文中的第一目标报文转换为Map数据结构的第二目标报文;若比对得到第二源报文与第二目标报文的MD5值不一致,则按照报文核对规则从第二源报文中确定源Value值,和按照报文核对规则从第二目标报文中确定目标Value值;根据源Value值和目标Value值进行核对以得到待核对JSO N报文的报文核对结果。本发明能够提升JSON报文一致性核对的效率。

    一种分布式事务的流程保障方法及装置

    公开(公告)号:CN110288255A

    公开(公告)日:2019-09-27

    申请号:CN201910580564.X

    申请日:2019-06-28

    Inventor: 张兵 夏勇

    Abstract: 本发明实施例涉及计算机技术领域,尤其涉及一种分布式事务的流程保障方法及装置,用以解决分布式事务异常处理机制缺乏灵活性的问题。本发明实施例包括:接收调用系统发送的处理请求;根据处理请求确定主流程以及N个子流程,N≥1;针对N个子流程中的任一子流程,将子流程向对应的子系统发送,以使子系统对子流程进行处理;对N个子流程的处理过程进行监控,当任一子流程的处理过程出现异常时,根据异常类型、主流程类型以及子流程类型确定对应的异常处理策略;根据异常处理策略对子流程进行异常处理,异常处理包括对已经处理成功的子流程执行非对称反向操作,非对称反向操作为执行反向子流程,反向子流程与已经处理的子流程非对称。

    一种数据处理方法及装置
    10.
    发明公开

    公开(公告)号:CN110275917A

    公开(公告)日:2019-09-24

    申请号:CN201910496089.8

    申请日:2019-06-10

    Inventor: 郭铭睿 夏勇 李凌

    Abstract: 本发明公开了一种数据处理方法及装置,涉及数据处理领域,其中方法包括:对源端分布式架构数据库发起N个数据抽取、转换和装载ETL进程;N为大于0的整数;所述N个ETL进程用于在数据仓库中生成第一目标表;当所述N个ETL进程在执行过程中存在M个失败的ETL进程时,重新发起所述N个ETL进程;当重新发起的所述N个ETL进程成功执行时,获取重新发起的所述N个ETL进程在所述数据仓库中生成的所述第一目标表,以及对所述第一目标表进行统计汇总生成的第一结果表;当所述第一结果表存在数据缺失时,对所述第一结果表进行数据修复。该方法可应用于金融科技(Fintech)。

Patent Agency Ranking