一种基于消息队列实现异步数据处理的方法及系统

    公开(公告)号:CN116185654A

    公开(公告)日:2023-05-30

    申请号:CN202211669978.8

    申请日:2022-12-25

    Abstract: 本发明公开了一种基于消息队列实现异步数据处理的方法及系统,其中方法包括:根据业务实际需求将待处理的异步请求进行分类,异步请求的类型分为需完成后立即响应请求,或无需完成后立即响应请求;将经过分类后的异步请求写入消息队列中,基于所述消息队列,将所述异步请求进行解耦,并按照类别分别处理所述异步请求;当所述异步请求完成之后,将需完成后立即响应请求类型的异步请求的响应结果直接向客户端发送;或者将无需完成后立即响应请求的异步请求的响应结果写入数据库。

    一种通过详见销货清单来监控企业虚开发票的方法和系统

    公开(公告)号:CN108269134A

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

    申请号:CN201611246545.6

    申请日:2016-12-29

    Abstract: 本发明涉及一种通过详见销货清单来监控企业虚开发票的方法和系统,所述方法包括:步骤1、获取发票信息数据库中的发票数据,使用sparkSQL进行计算,形成进项发票表和销项发票表以及ETL进项发票明细表和销项发票明细表,并存入数据仓库;步骤3、获取纳税人信息数据库中的纳税人信息以形成纳税人维表;步骤4、对ETL进项发票表和销项发票表进行查询,以获取物品名称为详见销货清单的发票代码和发票号码;步骤5、通过发票代码和发票号码组合形成的关键字KEY去查询ETL进项发票明细表和销项发票明细表,筛选出所述发票明细表中物品名称为详见销货清单的纳税人识别号;以及步骤6、根据步骤5筛选出的纳税人识别号来关联纳税人维表,确定疑点纳税人信息。

    一种基于分析工具SPARK的增值税数据整合方法及系统

    公开(公告)号:CN108255819A

    公开(公告)日:2018-07-06

    申请号:CN201611224500.9

    申请日:2016-12-27

    Abstract: 本发明通过一种基于分析工具SPARK的增值税数据整合方法及系统,为税务机关提供了一种常用的增值税分析的数据模型,可以在税务局规定时间内完成其业务需求对应的数据处理过程,帮助税务局更好的分析增值税数据、监控疑点纳税人,是有效监控和分析不法企业偷逃税款、保障税务收入的重要手段;提高了税务机关纳税评估、税务稽查等方面的工作效率。所述方法包括:使用数据抽取工具从电子底账库和金税三期库中抽取原始数据;使用SPARK对所述原始数据进行数据补全以及清理处理,并按照增值税分析需求形成需求表,并进行数据整合以形成需求数据模型将需求数据模型存储在数据仓库中;使用数据抽取工具将数据仓库中的需求数据模型导入至Greenplum数据库中进行长期存储。

    一种通过顶版开票率监控企业虚开发票的方法和系统

    公开(公告)号:CN108230127A

    公开(公告)日:2018-06-29

    申请号:CN201611198516.7

    申请日:2016-12-22

    CPC classification number: G06Q40/10 G06F17/30563

    Abstract: 本发明涉及一种通过顶版开票率监控企业虚开发票的方法和系统,所述方法包括:步骤1、获取发票信息数据库中的发票,使用分析工具sparkSQL计算纳税人以月为粒度的开票金额,并且将所述以月为粒度的开票金额存入数据仓库;步骤2、获取纳税人指定开票金额字段,进行抽取‑转换‑加载ETL过程,将处理后的纳税人指定开票金额存入数据仓库;步骤3、当每张发票的开票金额与所述纳税人指定开票金额的比值大于或等于第一预定值时,确定所述发票为顶版开票,使用sparkSQL计算出每个纳税人以月为粒度的纳税人顶版开票数量;步骤4、使用sparkSQL计算顶版开票率;步骤5、当纳税人的顶版开票率大于第二预定值时,判定该疑点纳税人为高危疑点纳税人。

    一种液位监控方法、装置、电子设备和存储介质

    公开(公告)号:CN118533256A

    公开(公告)日:2024-08-23

    申请号:CN202310143842.1

    申请日:2023-02-21

    Abstract: 本申请公开了一种液位监控方法、装置、电子设备和存储介质,用于提高对液位数据监控的准确性。本申请实施例中,响应于范围获取指示,获取预设时段对应的正常范围;在预设时段内,基于正常范围对目标对象中的液体液位进行检测。在本申请中,通过基于液位数据的变化斜率来对液位数据进行监管,大幅降低了无效数据的干扰,通过基于历史数据确定正常范围,突出了历史分析结果特征,提升了正常范围的精度,且通过对液位数据的分析和监管,大幅提升了液位数据的真实性和可靠性。

    一种用于共采及共享数据的系统及方法

    公开(公告)号:CN114598492A

    公开(公告)日:2022-06-07

    申请号:CN202111580754.5

    申请日:2021-12-22

    Abstract: 本发明公开了一种用于共采及共享数据的系统及方法,属于数据处理技术领域。本发明系统,包括:数据采集模块服务端,向数据采集模块代理端发送采集报文规范;数据采集模块代理端,根据采集报文规范,提供上报数据;数据加密模块,用于对所述上报数据进行加密以获取加密数据;数据传输安全通道,将所述加密数据传输至数据解密模块;数据解密模块,对所述加密数据进行解密,以获取解密的上报数据;数据共享分发模块,接收所述解密的上报数据,对所述解密的上报数据进行共享及分发。本发明能够与企业系统直接打通,参与多部门的联合采集数据。

    一种企业财务审计的方法和系统
    7.
    发明公开

    公开(公告)号:CN114549151A

    公开(公告)日:2022-05-27

    申请号:CN202111546261.X

    申请日:2021-12-16

    Abstract: 本发明实施例公开了一种企业财务审计的方法和系统,其中方法包括:获取用户上传的财务数据;基于预设的校验规则对所述财务数据进行校验,并在校验通过后将财务数据转换为数据库支持存储的数据并保存至数据库中;基于预设的费用审核规则,对所述财务数据进行费用审核,并在费用审核通过后在预设费用核定表中按照审计编码进行核减与汇总,生成费用核定表;基于预设的资产审核规则,对所述财务数据进行资产审核,并在资产审核通过后在预设资产核定表中将各资产进行汇总,生成资产核定表;基于费用核定表和资产核定表,生成候选核定表;对候选核定表进行政策性审核,并在政策性审核通过后生成最终核定表。

    一种用于纳税人税收风险自助扫描的方法和装置

    公开(公告)号:CN114429391A

    公开(公告)日:2022-05-03

    申请号:CN202111550327.2

    申请日:2021-12-17

    Abstract: 本发明公开了一种用于纳税人税收风险自助扫描的方法和装置,包括:获取纳税人的税收数据;根据所述纳税人选择的业务指标和所述业务指标对应的阈值,建立税收数据风险的扫描任务;将所述扫描任务,结合预选构建的KAFKA+ES+REDIS实时计算数据架构对所述税收数据进行任务扫描,生成纳税人税收风险报告。有效避免了离线数据定时定点处理方式造成的不便,通过灵活自助选择业务指标规则的方式识别企业风险,减少了计算资源的消耗。

    基于SPARK的小规模纳税人年应税销售额的监控方法及系统

    公开(公告)号:CN108242019A

    公开(公告)日:2018-07-03

    申请号:CN201611219202.0

    申请日:2016-12-26

    Abstract: 本发明设计实现了一种基于大数据SPARK框架对小规模纳税人年应税销售额进行监控的方法,通过分析小规模纳税人的销项发票数据来计算其年应税销售额,进而监控小规模纳税人是否达标,并使用sparkSQL代替关系型数据库的数据处理计算过程,提高了监控的准确性和计算速率。所述方法包括:获取小规模纳税人的销项发票表和纳税人信息表;对无关的、冗余的以及杂乱的字段信息进行清洗;关联小规模纳税人的销项发票表和纳税人信息表,获取关联后信息表内注册登记时间在一年以上的所有小规模纳税人的字段信息;进行小规模纳税人的分类并创建纳税人事实表;计算每个小规模纳税人的年应税销售额;与对应的达标认定标准进行对比,并对对比结果进行监控。

Patent Agency Ranking