[go: up one dir, main page]

CN115984013A - A method for data drainage through aggregation and integration of tripartite system functions - Google Patents

A method for data drainage through aggregation and integration of tripartite system functions Download PDF

Info

Publication number
CN115984013A
CN115984013A CN202310010822.7A CN202310010822A CN115984013A CN 115984013 A CN115984013 A CN 115984013A CN 202310010822 A CN202310010822 A CN 202310010822A CN 115984013 A CN115984013 A CN 115984013A
Authority
CN
China
Prior art keywords
platform
data
business
request
service
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
CN202310010822.7A
Other languages
Chinese (zh)
Other versions
CN115984013B (en
Inventor
付春波
李力伟
林震
王宇琴
王鹏
包金岩
宋鹏
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Inner Mongolia Aisino Co ltd
Original Assignee
Inner Mongolia Aisino Co ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Inner Mongolia Aisino Co ltd filed Critical Inner Mongolia Aisino Co ltd
Publication of CN115984013A publication Critical patent/CN115984013A/en
Application granted granted Critical
Publication of CN115984013B publication Critical patent/CN115984013B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Landscapes

  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

The invention discloses a data flow guiding method of a polymerization and integration three-party system, which introduces, aggregates and integrates a third-party service data platform, aggregates integrated data flow and provides data flow guiding service for users according to preset rules on the basis of providing invoice, accounting and tax declaring functions by accessing an invoice query platform, an invoicing platform, an accounting platform, a declaration platform and an OCR recognition system of a finance and tax cloud platform. The preset rule is that platform function rights and interests are packaged into service commodities, the service commodities are mapped with rights and interests in a contrast mode, and the service commodities are sold through a cooperative third-party service platform.

Description

一种通过聚合集成三方系统功能进行数据引流的方法A method of data drainage through aggregation and integration of tripartite system functions

技术领域technical field

本发明属于税务管理技术领域,特别涉及一种通过聚合集成三方系统功能进行数据引流的方法。The invention belongs to the technical field of tax management, and in particular relates to a method for data drainage through aggregation and integration of tripartite system functions.

背景技术Background technique

针对目前金税四期税务大环境变革,能提供发票、记账和申报等全方面服务的系统平台较少,部分提供全面服务的系统也只是某一服务较为完善,其他方面服务功能并不能满足当下金税四期全电业务的服务。In view of the current changes in the taxation environment in the fourth phase of the Golden Tax, there are few system platforms that can provide comprehensive services such as invoices, bookkeeping, and declarations. Some systems that provide comprehensive services only have a relatively complete service, and other service functions cannot meet the requirements. The current Golden Tax Phase IV all-electric business service.

随着金税四期全电业务的展开,关于税务方面的各类业务逐步进入全电子信息化,从企业的开票到财税记账,再从记账到纳税申报,市场目前迫切需要能提供全面的软件服务。With the development of the all-electric business in the fourth phase of the Golden Tax, all kinds of business related to taxation have gradually entered into full electronic information. software services.

发明内容Contents of the invention

本发明实施例之一,一种通过聚合集成三方系统功能进行数据引流的方法,该方法在金税四期税务的大环境下,通过财税云平台系统为企业互通如进销项发票通道、发票池、OCR智能识别发票通道、记账、和申报等各类权益功能,通过跨平台聚合集成三方系统功能的方式实现客户及数据引流。One of the embodiments of the present invention is a method for data drainage through aggregation and integration of tripartite system functions. Under the general environment of the fourth phase of the Golden Tax, the method uses the financial and taxation cloud platform system for enterprises to communicate with each other, such as invoice channels for purchase and sales items, invoices, etc. Pool, OCR intelligently identify various rights and interests functions such as invoice channel, bookkeeping, and declaration, and achieve customer and data drainage through cross-platform aggregation and integration of three-party system functions.

云平台的聚合集成三方系统功能方式上采用通道、订单、开放接口、数据引流等多种方式进行聚合集成三方系统功能,将各类功能服务打包成不同种类商品,功能对应用户权益,形成三方的闭环生态,实现数据及用户引流。The aggregation and integration of the three-party system functions of the cloud platform adopts various methods such as channels, orders, open interfaces, and data drainage to aggregate and integrate the functions of the three-party system, and packages various functional services into different types of commodities. The functions correspond to user rights and interests, forming a three-party system. Closed-loop ecology realizes data and user drainage.

本发明的有益效果在于,解决了在金四环境下支持发票的开票到企业财税记账在到纳税申报这一全方面的服务,通过与成熟的业务合作平台进行权益匹配互通,聚合集成他们成熟的业务功能,实现全方面的业务服务功能,从而吸引客户,达到数据引流。The beneficial effect of the present invention is that it solves all aspects of services from billing invoices to corporate tax accounting and tax declaration under the Golden Four environment, and through the matching and intercommunication of rights and interests with mature business cooperation platforms, they are aggregated and integrated. business functions, and realize all-round business service functions, thereby attracting customers and achieving data drainage.

附图说明Description of drawings

通过参考附图阅读下文的详细描述,本发明示例性实施方式的上述以及其他目的、特征和优点将变得易于理解。在附图中,以示例性而非限制性的方式示出了本发明的若干实施方式,其中:The above and other objects, features and advantages of exemplary embodiments of the present invention will become readily understood by reading the following detailed description with reference to the accompanying drawings. In the drawings, several embodiments of the invention are shown by way of illustration and not limitation, in which:

图1根据本发明实施例之一的通过聚合集成三方系统进行数据引流的基本流程示意图。Fig. 1 is a schematic flow diagram of the basic flow of data drainage through aggregation and integration of a tripartite system according to one embodiment of the present invention.

图2根据本发明实施例之一的聚合集成三方系统示意图。Fig. 2 is a schematic diagram of an aggregation and integration tripartite system according to one embodiment of the present invention.

图3根据本发明实施例之一的聚合集成三方系统示意图。Fig. 3 is a schematic diagram of an aggregation and integration tripartite system according to one embodiment of the present invention.

图4根据本发明实施例之一的聚合集成三方系统示意图。Fig. 4 is a schematic diagram of an aggregation and integration tripartite system according to one embodiment of the present invention.

具体实施方式Detailed ways

根据一个或者多个实施例,一种聚合集成三方系统数据引流方法,如图1所示。通过接入财税云平台的发票查询平台、开票平台、记账平台、申报平台、OCR识别系统,在提供发票、记账、报税功能基础上,引入、聚合、集成第三方业务数据平台,聚合集成的数据流,根据预设规则,为用户提供数据引流服务。According to one or more embodiments, a data drainage method for aggregation and integration of a tripartite system is shown in FIG. 1 . By accessing the invoice query platform, billing platform, accounting platform, declaration platform, and OCR identification system of the fiscal and taxation cloud platform, on the basis of providing invoices, accounting, and tax declaration functions, it introduces, aggregates, and integrates third-party business data platforms, aggregation and integration According to the preset rules, it provides users with data drainage services.

财税云平台通过接口方式集成三方企业成熟且支持金四全电票业务的开票功能,企业在云平台选择开票功能,输入必要信息后,云平台调用开票接口将开票信息发送,等待回调接口返回对应发票下载路径后,将票面信息展示。针对金税四期全电票的一些特性,程序针对新特性做出相应技术改进和支持,原普通发票开票,无论是电子票还是纸票,最终依赖的还是税盘和UKey,开票成功后,需要具体的盖有发票章的票据文件信息进行打印交付。与原普通发票交付方式不同的是,全电票是数据传输介质,没有实体,在开票后,开票方和受票方税务数字账户便存在发票信息,不存在打印有盖章的发票文件交付这一过程。云平台同样通过开放接口调用方式,对支持全电票面识别的三方系统的OCR智能票面识别功能,将识别的发票数据自动生成凭证信息纳入财务记账。OCR智能票面识别通过上传发票扫描图片文件后返回发票详细数据,云平台接收数据后进行处理生成记账凭证信息入库。The finance and taxation cloud platform integrates the billing function of three-party enterprises that are mature and support the Jinsiquan electric bill business through the interface. The enterprise selects the billing function on the cloud platform, and after entering the necessary information, the cloud platform calls the billing interface to send the billing information, and waits for the callback interface to return the corresponding After the invoice download path, the face information will be displayed. Aiming at some characteristics of the Golden Tax Phase 4 electronic invoice, the program makes corresponding technical improvements and supports for the new features. The original ordinary invoice issuance, whether it is an electronic invoice or a paper invoice, ultimately depends on the tax disk and UKey. After the invoice is successfully issued, Specific bill document information stamped with the invoice is required for printing and delivery. The difference from the original ordinary invoice delivery method is that the electronic invoice is a data transmission medium and has no entity. After the invoice is issued, the invoice information will exist in the tax digital accounts of the issuer and the invoice recipient. There is no delivery of printed invoice documents with stamps. a process. The cloud platform also uses the open interface call method to automatically generate voucher information from the recognized invoice data for the OCR intelligent face recognition function of the three-party system that supports all-electric face recognition into financial accounting. OCR intelligent face recognition returns the detailed data of the invoice by uploading the scanned image file of the invoice, and the cloud platform receives the data and processes it to generate accounting voucher information for storage.

云平台的代账功能和开票以及OCR票面识别产生的数据生成记账凭证,通过对凭证信息的分类别处理计算收支差,生成基本财务报表。在处理财务报表的方式上,采用分科目类别递归统计汇总方式。为构建纳税申报的相关报表如增值税、企业所得税、城建税等提供基础数据。最终生成纳税申报所需必要报表,企业可选择导出报表人工自主申报或使用云平台通过接口集成的三方成熟申报业务功能进行自动申报。The accounting function of the cloud platform and the data generated by invoicing and OCR face recognition generate accounting vouchers, and calculate the income and expenditure difference by classifying the voucher information to generate basic financial statements. In the way of processing financial statements, the method of recursive statistics and summary by subject category is adopted. Provide basic data for constructing related reports for tax declarations, such as value-added tax, corporate income tax, urban construction tax, etc. Finally, the necessary reports required for tax declaration are generated. Enterprises can choose to export the reports and declare manually or use the cloud platform to make automatic declarations through the three-party mature declaration business functions integrated through the interface.

云平台将集成的三方平台成熟的业务功能封装打包为商品,在第三方平台销售后,走消息队列将订单信息传到云平台。云平台根据订单信息为购买权益的企业开通账号并进行初始化权益的配置,考虑企业存在多次购买不同权益,且页面根据功能权重优先级展示,例:开票业务菜单要放到记账业务菜单前,记账等菜单权限要放到申报业务菜单按钮前,根据业务优先级权重,系统为每一个功能菜单进行赋权值,在企业登录云平台初始化菜单功能列表时,对菜单功能数组进行递归排序方式根据权值的大小排列后,依次展示菜单列表。以上业务具体实现流程和数据流向详见附图2和附图3。The cloud platform packages the mature business functions of the integrated third-party platform into commodities, and after the sale on the third-party platform, the order information is transmitted to the cloud platform through the message queue. According to the order information, the cloud platform opens an account for the enterprise that purchases the rights and interests and configures the initial rights and interests. Considering that the enterprise has purchased different rights and interests multiple times, and the page is displayed according to the priority of the function weight, for example: the billing business menu should be placed before the bookkeeping business menu , Accounting and other menu permissions should be placed before the declare business menu button. According to the business priority weight, the system assigns a value to each function menu. When the enterprise logs in to the cloud platform to initialize the menu function list, the menu function array is recursively sorted After the method is arranged according to the size of the weight, the menu list is displayed in sequence. Please refer to attached drawings 2 and 3 for the specific implementation process and data flow of the above business.

接入相关业务功能的方式上区分金税四期全电票业务和原普通正常业务,具体实现业务流程是全电票业务走三方系统独立通道,原普通业务走正常接口。业务实现流程详见附图4。In terms of the way of accessing relevant business functions, it is distinguished between the Golden Tax Phase IV all-electric bill business and the original ordinary normal business. The specific realization of the business process is that the all-electric bill business goes through the independent channel of the tripartite system, and the original ordinary business goes through the normal interface. See Figure 4 for details of the business implementation process.

集成三方系统的实现方式包括增设采集网关、安装后台管理系统的主机、PAAS平台服务器、安装三方系统的主机、数据中台服务器和SAAS平台服务器。通过云平台作为载体,集成如进销项通道发票池、发票智能识别生成凭证、记账和申报功能等相关功能,实现企业客户在使用相关功能同时,享受多方权益互通后带来的数据及功能。各方系统之间的权益相互对照映射,企业客户可直接使用集成系统的相关功能,实现数据的引流。集成系统还可以将系统相关功能权益作为商品销售,由第三方合作平台推广销售权益产品,客户购买产品后,通过权益互通匹配,在集成系统开通商品对应权益功能,客户可直接登录集成系统使用功能,从而实现客户数据引流。The realization method of integrating the three-party system includes adding a collection gateway, installing a host of a background management system, a PAAS platform server, installing a host of a three-party system, a data center server, and a SAAS platform server. Through the cloud platform as a carrier, it integrates relevant functions such as the invoice pool of the purchase and sales channel, the intelligent identification of invoices to generate vouchers, accounting and declaration functions, etc., so that corporate customers can enjoy the data and functions brought by the interoperability of multi-party rights and interests while using relevant functions. . The rights and interests between the systems of all parties are mapped against each other, and corporate customers can directly use the relevant functions of the integrated system to achieve data drainage. The integrated system can also sell system-related functional rights and interests as commodities, and the third-party cooperation platform promotes and sells the rights and interests products. After customers purchase the products, through rights and interests interoperability matching, the corresponding rights and interests functions of the products are opened in the integrated system, and customers can directly log in to the integrated system to use the functions , so as to realize customer data drainage.

根据一个或者多个实施例,一种聚合集成三方系统数据引流方法,包括,According to one or more embodiments, a data drainage method for aggregated and integrated tripartite systems includes:

通过平台集成企业客户使用的各类业务功能,包括发票开票,进销项发票通道、发票池、OCR智能识别发票票面生成凭证、公司代记账和税务申报以及相关税务方面提供质询和解决方案服务。Integrate various business functions used by corporate customers through the platform, including invoice billing, invoice channel for purchase and sale items, invoice pool, OCR intelligent identification of invoice face generation vouchers, company bookkeeping and tax declaration, and provide inquiry and solution services for related taxation .

系统集成各类型业务功能时,与业务成熟的三方合作平台进行业务匹配互通,接入其成熟的业务功能。我们以代记账这一业务为主体核心,将发票和纳税申报这俩个独立的业务流程进行关联做中间的纽带。将开票到记账再到申报这一企业必要业务流程打通。为企业实现一站式服务,通过系统聚合集成三方系统功能,客户能使用的功能不止局限与某一系统固有业务功能。When the system integrates various types of business functions, it performs business matching and interworking with the mature three-party cooperation platform, and accesses its mature business functions. We take the business of bookkeeping as the main core, and link the two independent business processes of invoices and tax declarations as the middle link. Open up the necessary business process from billing to bookkeeping to declaration. Realize one-stop service for enterprises, through system aggregation and integration of three-party system functions, the functions that customers can use are not limited to the inherent business functions of a certain system.

系统聚合集成三方系统功能的实现对应方式有通道、订单、开放接口等多种方式,下面以发票、ocr票面识别、申报和三方销售权益平台对接财税云平台的业务流程和数据流做详细描述。System aggregation and integration of tripartite system functions can be implemented in various ways, such as channels, orders, and open interfaces. The following will describe in detail the business process and data flow of invoices, ocr face recognition, declaration, and tripartite sales rights platform docking with the fiscal and taxation cloud platform.

本公开实施例开发使用的是微服务系统架构,业务之间的交互传递数据偶有网络延时导致超时丢包情况。部分业务情况使用消息队列模式排除解决,但有部分业务不适用消息队列模式。我们必须保证业务请求百分百的请求到目标系统,且重复请求只会达到一种结果,不会造成其他业务不良影响和垃圾数据产生。在解决这个问题上,我们用到了状态机幂等机制和任务调度xxl-job来实现重复请求返回同一结果情况。实现方式如下:记录表记录请求并设置状态,任务调度模块扫描记录表,对请求状态为待请求的请求进行重复请求。目标系统接收请求后根据状态机幂等机制完整处理请求后,返回结果,记录表更新状态为完成。任务调度模块下一周期扫描将排除状态为已完成的请求。实现逻辑如下:The embodiments of the present disclosure are developed using a micro-service system architecture, and the interactive transfer data between services occasionally causes packet loss due to timeout due to network delay. Some business situations are solved by using the message queuing mode, but some businesses do not apply the message queuing mode. We must ensure that 100% of business requests are sent to the target system, and repeated requests will only achieve one result, and will not cause other adverse business effects and garbage data. To solve this problem, we use the idempotent mechanism of the state machine and the task scheduling xxl-job to realize the situation where repeated requests return the same result. The implementation method is as follows: the recording table records the request and sets the status, and the task scheduling module scans the recording table and repeats the request for the request whose request status is pending. After receiving the request, the target system processes the request completely according to the idempotent mechanism of the state machine, returns the result, and the update status of the record table is completed. The next periodic scan of the task scheduling module will exclude requests whose status is completed. The implementation logic is as follows:

//任务轮巡方法//Task patrol method

RetryJobExecutor(){RetryJobExecutor(){

//扫描记录表请求状态为:1(待请求)的数据//Scan record table request status is: 1 (to be requested) data

List<RequestRecord>requestRecordList=findRequestState("1");List<RequestRecord>requestRecordList=findRequestState("1");

//批量发起请求//batch request

for(RequestRecord requestRecord:requestRecordList){for(RequestRecord requestRecord:requestRecordList){

//记录请求次数,达最大重复请求数后进行邮件通知等业务//Record the number of requests, and perform email notifications and other services after reaching the maximum number of repeated requests

updateRequestCount(requestRecord);updateRequestCount(requestRecord);

Response reponse=RequertUtilsSDK.send(requestRecord);Response response = RequestUtilsSDK.send(requestRecord);

if(reponse.isSuccess()){if(reponse.isSuccess()){

//请求返回成功后修改记录状态为:2(已完成)// After the request returns successfully, modify the record status to: 2 (completed)

updateRequestState(requestRecord);updateRequestState(requestRecord);

}}

//请求失败或返回的数据不做操作,等待下一次的任务调度//The request fails or the returned data does not operate, waiting for the next task scheduling

}}

}}

//目标系统接收请求处理//Target system receives request processing

BusinessExecution(RequestRecord requestRecord){BusinessExecution(RequestRecord requestRecord){

//状态机幂等机制,根据状态判断业务执行情况//The idempotent mechanism of the state machine judges the execution of the business according to the state

String businessState=requestRecord.getBusinessState();String businessState = requestRecord. getBusinessState();

String businessId=requestRecord.getBusinessIdString businessId = requestRecord.getBusinessId

BusinessInfo businessInfo=findBusinessInfo(businessId,businessState);BusinessInfo businessInfo = findBusinessInfo(businessId, businessState);

//根据状态和业务唯一id判断是否执行过该业务//Judging whether the business has been executed according to the status and the unique id of the business

if(ObjectUtils.isEmpty(businessInfo)){if(ObjectUtils.isEmpty(businessInfo)){

//该状态业务为空,执行业务//The status business is empty, execute the business

renturn execute(requestRecord);return execute(requestRecord);

}else{}else{

//存在该业务状态,不执行任何操作//The business state exists, do not perform any operations

return Response.success();return Response. success();

}}

}}

根据一个或者多个实施例,一种基于聚合集成三方系统的数据引流系统,包括:According to one or more embodiments, a data drainage system based on aggregation and integration of a tripartite system includes:

1、系统集成了财税方面各类功能,满足在金税四期全电发票推广环境下企业在发票、记账、报税各方面的需求。通过集成全面完善的功能,与各三方合作系统平台成熟的业务打通,使得集成系统的功能在金税四期业务上保持稳定运行,吸引客户,实现客户的引流。1. The system integrates various functions in finance and taxation to meet the needs of enterprises in all aspects of invoices, bookkeeping, and tax declaration under the promotion environment of all-electric invoices in the fourth phase of the Golden Tax. Through the integration of comprehensive and complete functions and the connection with the mature business of various three-party cooperation system platforms, the functions of the integrated system can maintain stable operation in the Golden Tax Phase IV business, attracting customers and realizing customer drainage.

2、系统将自身的权益功能打包成各种商品,将商品和权益对照映射。三方合作平台销售商品,系统和三方合作平台通过约定好的权益配置为购买者开通相应权益功能。2. The system packages its own rights and interests functions into various commodities, and maps the commodities and rights and interests. The three-party cooperation platform sells goods, and the system and the three-party cooperation platform activate the corresponding rights and interests functions for buyers through the agreed rights and interests configuration.

3、系统集成主要功能有开票、发票识别、发票池查询和申报功能,企业在使用各项功能同时,记账所需进销项数据和申报各项数据逐渐累积形成数据流,为后续针对企业提供风险预警等各项业务提供基础数据流。3. The main functions of system integration include invoicing, invoice identification, invoice pool query and declaration functions. While enterprises are using various functions, the data of purchase and sales items required for bookkeeping and various data of declarations gradually accumulate to form a data flow, which is for the follow-up for enterprises Provide risk warning and other services to provide basic data flow.

4、针对满足金税四期全电成熟的业务系统,云平台部分业务功能同时选择俩个三方系统提供业务服务。对企业客户而言面对的只是一个业务功能。平台为提供更优质服务,同时接入两个成熟业务系统,根据优先级调用,在第一个业务系统调用失败情况下,立刻调用第二个备用三方业务系统。4. In view of the mature business system that meets the requirements of the fourth phase of the Golden Tax, two third-party systems are selected to provide business services for some business functions of the cloud platform. For enterprise customers, it is only a business function. In order to provide better services, the platform is connected to two mature business systems at the same time, and is called according to the priority. If the first business system fails to call, it will immediately call the second backup three-party business system.

因此,本发明的有益效果包括Therefore, the beneficial effects of the present invention include

1、本发明的各类功能均能契合实际解决企业客户在金税四期全电发票业务下发票、记账和申报方面的实际问题,持续贡献价值,客户被价值吸引,自然而然形成客户数据流。1. The various functions of the present invention can fit the actual situation and solve the practical problems of corporate customers in invoicing, bookkeeping and reporting under the all-electric invoice business of the fourth phase of the Golden Tax, and continuously contribute value. Customers are attracted by the value, and a customer data flow is naturally formed .

2、本发明方案通过系统间的权益匹配,实现业务与数据的映射关系,实现了业务数据的回流与积累,形成了数据层面的引流功能。2. The scheme of the present invention realizes the mapping relationship between business and data through the equity matching between systems, realizes the return and accumulation of business data, and forms a drainage function at the data level.

3、本发明方案在与第三方系统进行聚合集成三方系统的对接上做通用方式,为第三方应用接入权益的匹配提供了遍历条件。3. The solution of the present invention is a general method for the integration of the three-party system with the third-party system, and provides traversal conditions for the matching of third-party application access rights.

值得说明的是,虽然前述内容已经参考若干具体实施方式描述了本发明创造的精神和原理,但是应该理解,本发明并不限于所公开的具体实施方式,对各方面的划分也不意味着这些方面中的特征不能组合,这种划分仅是为了表述的方便。本发明旨在涵盖所附权利要求的精神和范围内所包括的各种修改和等同布置。It is worth noting that although the foregoing content has described the spirit and principle of the invention with reference to several specific embodiments, it should be understood that the present invention is not limited to the disclosed specific embodiments, and the division of various aspects does not mean that these Features within an aspect cannot be combined, this division is for convenience of presentation only. The present invention is intended to cover various modifications and equivalent arrangements included within the spirit and scope of the appended claims.

Claims (10)

1.一种聚合集成三方系统数据引流方法,其特征在于,通过接入财税云平台的发票查询平台、开票平台、记账平台、申报平台、OCR识别系统,在提供发票、记账、报税功能基础上,引入、聚合、集成第三方业务数据平台,聚合集成的数据流,根据预设规则,为用户提供数据引流服务。1. A data drainage method for aggregation and integration of three-party systems, characterized in that, through access to the invoice query platform, billing platform, accounting platform, declaration platform, and OCR identification system of the financial and taxation cloud platform, the functions of invoices, accounting, and tax declaration are provided. On the basis, introduce, aggregate, and integrate third-party business data platforms, aggregate and integrate data streams, and provide users with data drainage services according to preset rules. 2.根据权利要求1所述的数据引流方法,其特征在于,所述预设规则,是将平台功能权益打包为服务商品,将服务商品与权益对照映射,通过合作的第三方业务平台销售。2. The data drainage method according to claim 1, wherein the preset rule is to package platform functional rights and interests into service commodities, map service commodities and rights and interests, and sell through cooperative third-party business platforms. 3.根据权利要求2所述的数据引流方法,其特征在于,所述第三方业务平台包括服务商品销售平台和申报平台。3. The data drainage method according to claim 2, wherein the third-party business platform includes a service product sales platform and a declaration platform. 4.根据权利要求3所述的数据引流方法,其特征在于,所述第三方业务平台至少包括一个业务调用优先级不同的备用平台。4. The data diversion method according to claim 3, wherein the third-party service platform includes at least one backup platform with different service call priorities. 5.根据权利要求3所述的数据引流方法,其特征在于,所述数据引流基于微服务系统架构。5. The data drainage method according to claim 3, wherein the data drainage is based on a microservice system architecture. 6.根据权利要求5所述的数据引流方法,其特征在于,在微服务系统架构下,采用状态机幂等机制,结合任务调度xxl-job,实现重复请求返回同一结果。6. The data drainage method according to claim 5, characterized in that, under the microservice system architecture, the idempotent mechanism of the state machine is adopted, combined with the task scheduling xxl-job, to realize repeated requests returning the same result. 7.根据权利要求6所述的数据引流方法,其特征在于,实现重复请求返回同一结果的过程是,7. The data drainage method according to claim 6, characterized in that the process of returning the same result for repeated requests is: 记录表记录请求并设置状态,任务调度模块扫描记录表,对请求状态为待请求的请求进行重复请求;The record table records the request and sets the status, the task scheduling module scans the record table, and repeats the request for the request whose request status is pending request; 目标系统接收请求后根据状态机幂等机制完整处理请求后,返回结果,记录表更新状态为完成;After receiving the request, the target system completely processes the request according to the idempotent mechanism of the state machine, returns the result, and the update status of the record table is completed; 任务调度模块下一周期扫描将排除状态为已完成的请求。The next periodic scan of the task scheduling module will exclude requests whose status is completed. 8.根据权利要求7所述的数据引流方法,其特征在于,实现重复请求返回同一结果的程序逻辑包括,8. The data drainage method according to claim 7, characterized in that, the program logic for implementing repeated requests to return the same result includes: 采用任务轮巡,扫描记录表请求状态为:待请求;Using task patrol, the status of the request to scan the record table is: pending request; 批量发起请求,记录请求次数,达最大重复请求数后进行通知;Initiate requests in batches, record the number of requests, and notify when the maximum number of repeated requests is reached; 请求返回成功后修改记录状态为:已完成;After the request returns successfully, modify the record status to: Completed; 请求失败或返回的数据不做操作,等待下一次的任务调度。If the request fails or the returned data does not operate, it waits for the next task scheduling. 9.根据权利要求8所述的数据引流方法,其特征在于,实现重复请求返回同一结果的程序逻辑还包括,9. The data diversion method according to claim 8, characterized in that, the program logic for realizing repeated requests to return the same result further includes: 目标系统接收请求处理包括,采用状态机幂等机制,根据状态判断业务执行情况,The processing of receiving requests by the target system includes adopting the idempotent mechanism of the state machine to judge the execution of the business according to the state, 根据状态和业务唯一id判断是否执行过该业务,According to the state and the unique id of the business, it is judged whether the business has been executed, 若该状态业务为空,则执行业务,If the status service is empty, execute the service, 若存在该业务状态,则不执行任何操作。If the business status exists, no operation is performed. 10.根据权利要求1所述的数据引流方法,其特征在于,根据记账所需进销项数据和申报数据逐渐累积形成数据流,为后续针对用户提供风险预警业务提供基础数据流。10. The data drainage method according to claim 1, characterized in that the data flow is gradually accumulated according to the purchase and sale item data and declaration data required for bookkeeping, and a basic data flow is provided for the subsequent provision of risk warning services for users.
CN202310010822.7A 2022-12-30 2023-01-05 A method for data drainage by aggregating and integrating the functions of third-party systems Active CN115984013B (en)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN2022235586634 2022-12-30
CN202223558663 2022-12-30

Publications (2)

Publication Number Publication Date
CN115984013A true CN115984013A (en) 2023-04-18
CN115984013B CN115984013B (en) 2025-09-02

Family

ID=85960929

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202310010822.7A Active CN115984013B (en) 2022-12-30 2023-01-05 A method for data drainage by aggregating and integrating the functions of third-party systems

Country Status (1)

Country Link
CN (1) CN115984013B (en)

Citations (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20090138433A1 (en) * 2007-11-26 2009-05-28 S.P. Richards Company Data Aggregation Systems And Methods
US20130091204A1 (en) * 2010-08-12 2013-04-11 Joheem Loh System and method of integrating various platforms and methods of using the same
CN111652703A (en) * 2020-06-04 2020-09-11 策拉人工智能科技(云南)有限公司 Method and system for automatic accounting and tax declaration of artificial intelligence accounting
CN114092205A (en) * 2021-10-26 2022-02-25 航天信息股份有限公司 Method and device for tax declaration based on multi-mode integrated declaration system
CN114119186A (en) * 2021-11-18 2022-03-01 航天信息股份有限公司 A financial and taxation integrated processing system and processing method for a group-type enterprise
CN114418717A (en) * 2021-12-16 2022-04-29 航天信息股份有限公司 Finance and tax management system and method for covering full life cycle of value-added tax electronic invoice
CN115269629A (en) * 2022-06-30 2022-11-01 启明信息技术股份有限公司 Data query method and system supporting multiple data sources
CN115456619A (en) * 2022-09-27 2022-12-09 山东鲁商通科技有限公司 Virtual prepaid card issuing system and method based on block chain technology

Patent Citations (8)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20090138433A1 (en) * 2007-11-26 2009-05-28 S.P. Richards Company Data Aggregation Systems And Methods
US20130091204A1 (en) * 2010-08-12 2013-04-11 Joheem Loh System and method of integrating various platforms and methods of using the same
CN111652703A (en) * 2020-06-04 2020-09-11 策拉人工智能科技(云南)有限公司 Method and system for automatic accounting and tax declaration of artificial intelligence accounting
CN114092205A (en) * 2021-10-26 2022-02-25 航天信息股份有限公司 Method and device for tax declaration based on multi-mode integrated declaration system
CN114119186A (en) * 2021-11-18 2022-03-01 航天信息股份有限公司 A financial and taxation integrated processing system and processing method for a group-type enterprise
CN114418717A (en) * 2021-12-16 2022-04-29 航天信息股份有限公司 Finance and tax management system and method for covering full life cycle of value-added tax electronic invoice
CN115269629A (en) * 2022-06-30 2022-11-01 启明信息技术股份有限公司 Data query method and system supporting multiple data sources
CN115456619A (en) * 2022-09-27 2022-12-09 山东鲁商通科技有限公司 Virtual prepaid card issuing system and method based on block chain technology

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
李洋;赵薇;: "马钢增值税发票管理共享服务平台设计与实现", 安徽冶金科技职业学院学报, no. 01, 15 January 2020 (2020-01-15) *

Also Published As

Publication number Publication date
CN115984013B (en) 2025-09-02

Similar Documents

Publication Publication Date Title
US11922382B2 (en) Transaction system having a serverless architecture that provides multi-language multi-platform transaction support for multiple vendors in conjunction with a cloud-based computing platform
CN111833169B (en) A method and device for managing split accounts
US5870717A (en) System for ordering items over computer network using an electronic catalog
JP5117754B2 (en) Business process variant of software model
US8392356B2 (en) Efficient transformation of information between a source schema and a target schema
CN106372975B (en) Invoice management system based on SOAP technology and ActiveX control technology
CN112118116B (en) System and method for recommending merchant discussion groups based on settings in an e-commerce platform
CA2383958A1 (en) A merchandising system utilizing an intermittent network connection
CA2487402A1 (en) Determining taxes by applying tax rules specified using configurable templates
US20210241357A1 (en) Customizable and extensible managed integration platform
CN115147049B (en) Order batch loading method and device, storage medium and computer equipment
KR102272278B1 (en) Pre-commodity open market system based on Internet of Things platform connected with cloud platform
US20250130984A1 (en) Systems and methods for providing tenant-defined event notifications in a multi-tenant database system
CN114579087A (en) Method and device for designing power customer service middlings
US20240403288A1 (en) Optimized database system with updated materialized view
CN112734460B (en) Data processing, payment data output, payment preferential data providing method and device
CN115409589B (en) Financial data standardization system and method thereof
KR102311511B1 (en) Open market system with enhanced security by applying blockchain
US20090248557A1 (en) Method for aggregating and analyzing consumer business data
US20120059691A1 (en) Electronic Sales Incentive Distribution and Clearinghouse System
CN111815378A (en) Management system and method for generating invoice based on bill collection
CN108876577B (en) Multilingual Mobile Visualization Collection and Processing Information System
US20200204514A1 (en) Prioritized messaging system
CN115984013A (en) A method for data drainage through aggregation and integration of tripartite system functions
US7882153B1 (en) Method and system for electronic messaging of trade data

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant