Movatterモバイル変換


[0]ホーム

URL:


CN119917495B - Enterprise business data processing system and method based on AI - Google Patents

Enterprise business data processing system and method based on AI
Download PDF

Info

Publication number
CN119917495B
CN119917495BCN202510412689.7ACN202510412689ACN119917495BCN 119917495 BCN119917495 BCN 119917495BCN 202510412689 ACN202510412689 ACN 202510412689ACN 119917495 BCN119917495 BCN 119917495B
Authority
CN
China
Prior art keywords
data
importance
customer
task
synchronization
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.)
Active
Application number
CN202510412689.7A
Other languages
Chinese (zh)
Other versions
CN119917495A (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.)
China Unicom Jiangsu Industrial Internet Co Ltd
Original Assignee
China Unicom Jiangsu Industrial Internet 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 China Unicom Jiangsu Industrial Internet Co LtdfiledCriticalChina Unicom Jiangsu Industrial Internet Co Ltd
Priority to CN202510412689.7ApriorityCriticalpatent/CN119917495B/en
Publication of CN119917495ApublicationCriticalpatent/CN119917495A/en
Application grantedgrantedCritical
Publication of CN119917495BpublicationCriticalpatent/CN119917495B/en
Activelegal-statusCriticalCurrent
Anticipated expirationlegal-statusCritical

Links

Landscapes

Abstract

The invention relates to the field of enterprise business management, in particular to an AI-based enterprise business data processing system and method, wherein the method comprises the following steps of 1, acquiring source system data, and storing the acquired data into one or more target systems; the method comprises the steps of constructing a data synchronization strategy, monitoring and managing data synchronization among databases of a target system based on the data synchronization strategy, generating the data synchronization strategy based on data synchronization cost, optimizing the data synchronization strategy by combining the importance of data and data synchronization tasks with the data synchronization cost after quantifying the importance of the data and the data synchronization tasks, adding an adjustment rule into the optimized data synchronization strategy, and dynamically adjusting the importance of the data or the tasks, and sending the data of one or more target systems to a cloud platform for storage.

Description

Enterprise business data processing system and method based on AI
Technical Field
The invention relates to the field of enterprise business management, in particular to an AI-based enterprise business data processing system and method.
Background
In the digital age today, enterprise business data is a core asset for enterprise operation and development, and its coverage is very wide. Enterprise business data typically includes basic data of the enterprise (e.g., registered addresses, registered capital, operating ranges, organizational structures, etc. of the enterprise), asset information (e.g., detailed information of various types of assets such as fixed assets, liquidated assets, etc. of the enterprise), business operation information (including customer information, customer behavior information), financial data (e.g., income, expense, profit, liability, etc. of the enterprise), supply chain data, etc.
In enterprise business data processing, common methods include data collection and integration, data storage and management, data analysis and mining. Common enterprise business systems are Enterprise Resource Planning (ERP) systems, customer Relationship Management (CRM) systems, and large data processing platforms such as Hadoop and Flink, among others.
In the business processing process of enterprises, data synchronization among different systems is a problem to be solved urgently. Since enterprises typically use multiple different business systems to support their respective business functions, these systems are often developed independently and the data storage schemes employed are not the same.
Disclosure of Invention
According to the invention, by constructing the data synchronization strategy, the data synchronization between the source system (CRM) and different target systems (ERP, hadoop) and the data synchronization between different target systems are realized, and the data consistency in the data synchronization process is ensured.
The technical scheme provided by the invention is that the method for processing the enterprise business data based on the AI comprises the following steps:
step 1, acquiring source system data, and storing the acquired data into one or more target systems;
Step 2, constructing a data synchronization strategy, monitoring and managing data synchronization among databases of a target system based on the data synchronization strategy, wherein the method comprises the following steps:
Generating a data synchronization policy based on the data synchronization cost;
After quantifying the importance of the data and the data synchronization task, combining the importance with the data synchronization cost, and optimizing a data synchronization strategy;
adding an adjustment rule in the optimized data synchronization strategy, and dynamically adjusting the importance of data or tasks;
and 3, sending the data of one or more target systems to a cloud platform for storage.
Preferably, the source system comprises a customer relationship management system CRM and a business intelligent BI system, and the target system comprises an enterprise resource planning ERP system and a big data processing Hadoop system;
before acquiring the source system data and storing the acquired data in the target system database, the method further comprises:
Judging whether the target system database is communicated with the source system or not;
judging the consistency of data synchronized by a source system to different target systems;
the step of judging whether the target system database is communicated with the source system or not comprises the following steps:
Modifying one or more fields in the source system, detecting whether the corresponding field of the target system is changed, if so, entering a step 2, otherwise, entering the following steps:
modifying one or more fields in the target system, checking whether corresponding automation in the source system is synchronous, if so, entering step 2, otherwise, entering the following steps:
Comparing the sampled and exported target system data with the sampled and exported source system data, judging whether the sampled and exported target system data are consistent with the sampled and exported source system data, if so, entering the step 2, otherwise, entering the following steps:
Checking an API (application program interface) call log of a target system, and confirming whether an exchange record exists in a source system, if so, entering a step 2, otherwise, automatically opening a database of the target system and the source system, wherein the method specifically comprises the following steps of:
determining data fields needing to be synchronized;
identifying sensitive fields in the synchronous data fields, encrypting or hashing the sensitive fields, and establishing independent indexes for the high-frequency query fields;
Calling an API interface of the target system to be in butt joint with the source system, or extracting data from the source system by using an ETL tool, and loading the data to the ERP system after cleaning;
And according to the preset monitoring frequency, periodically auditing the access rights of the API interface and removing the redundant account information.
Preferably, the determining the consistency of the data synchronized by the source system to the different target systems includes:
acquiring a plurality of data to be checked from different target systems, and partitioning according to the same rule to acquire a plurality of corresponding data blocks I and data blocks II;
calculating and obtaining a first hash value of each first data block and a second hash value of each second data block;
Constructing a Merck tree I based on the hash value I, and constructing a Merck tree II based on the hash value II;
acquiring a root hash value of the first merck tree and a root hash value of the second merck tree, comparing, if the difference exists, searching for a corresponding first data block and a corresponding second data block, and covering the corresponding second data block by taking the first data block as a reference;
if the second data block cannot be automatically covered, the first difference data block and the second difference data block are pushed to the upper computer to be manually processed.
Preferably, the generating the data synchronization policy based on the data synchronization cost includes:
Constructing a dynamic adjustment model, and dynamically adjusting the data volume proportion of full-volume data and incremental data, specifically:
Building a state matrix, wherein,The rate of change of the data is indicated,Representing the cost of synchronizing the full amount of data,Representing the cost of incremental data synchronization,Representing the average time consumption of the history synchronization;
Constructing a weight matrixThe first line element of the weight matrix is expressed in a decision vector corresponding to full data synchronization, and the second line element of the weight matrix is expressed in a decision vector corresponding to incremental data synchronization;
Generating synchronization policiesWhereinAndA data proportion representing full synchronization and an incremental synchronization data proportion;
optimizing weight matrices by gradient descent to minimize synchronization costsThe gradient calculation process comprises the following steps:
;
The updated weight matrix is;
When (when)Triggering full data synchronization when in use, otherwise, according to the followingThe proportion is used for synchronizing the increment data, wherein,Representing a full synchronization threshold.
Preferably, after quantifying the importance of the data and the data synchronization task, the optimizing the data synchronization policy in combination with the data synchronization cost includes:
Extracting importance of data and importance of a data synchronization task from metadata of a target system, wherein the importance of the data is defined as influence weight of the extracted data on system business based on business rules preset by the target system, the importance of the data synchronization task is defined as priority of the task based on a type of the synchronization task, and the type of the task comprises a real-time report task and an offline analysis task;
specifically, based on the ratings of clients corresponding to the data, the importance of the data is associated with the ratings, and the importance of the data is quantified by the client ratingsBased on the priority of the data synchronization task, the importance of the data synchronization task is related to the priority, and the importance of the data synchronization task is quantized by the priority;
Will beAndAdded toIn (3) forming a new state matrix;
Construction of new synchronization costs, wherein,Represents a penalty coefficient and,Representing a delay time when incremental data is synchronized;
updating weight matrix by gradient descent method, minimizingWherein the gradient calculation process is as follows: wherein, the method comprises the steps of,,;
The optimized synchronization strategy:;
When (when)When the data is synchronized in full, that is,Wherein, the method comprises the steps of,Representing a task importance threshold one;
When (when)When the incremental data synchronization delay is allowed,Representing a task importance threshold two.
Preferably, adding an adjustment rule in the optimized data synchronization strategy, dynamically adjusting the importance of data or tasks, including:
Based on customer behavior, transaction data and system business rules, quantifying customer value, formulating dynamic adjustment rules of customer ratings, comprising the following steps:
acquiring client behavior, transaction data and system business rule data from a target system database to form a client data set;
Extracting key features from a customer dataset to form a customer key feature setThe real-time key features comprise the accumulated transaction amount, the maximum transaction amount, the liveness and the repurchase rate of the clients;
after normalizing the customer key feature set, inputting the customer key feature set into a time sequence model ARIMA, and predicting the consumption of the customer for 6 months in the future;
Constructing a customer value scoring model:
, wherein,Respectively representing scoring weight coefficients; representing a maximum transaction amount for the customer; Representing an accumulated transaction amount; representing the repurchase rate; A forecast value representing a customer's future 6 months of consumption; represents the coefficient of attenuation and,;
Setting a customer value scoring classification interval,When the client is judged to be a high-value client, whenWhen the client is judged to be a low-value client;
The dynamic adjustment rule of the priority of the task is formulated by combining the type of the data synchronization task, the timeliness requirement and the value of the associated data, and the method specifically comprises the following steps:
the types of the data synchronization tasks are divided into real-time wind control, real-time report forms, batch analysis and history archiving according to the data purposes;
Assigning task weights to different types of data synchronization tasks;
Constructing a task importance scoring model:
wherein, the method comprises the steps of,The task weight vector is represented as a vector of weights,;Indicating that the task has been delayed in time,Representing the adjustment coefficient; the importance of the data is indicated and,;
Setting task importance scoring classification interval,When the task is judged to be the task with the highest priority; judging that the synchronous task is a low-priority task;
Setting adjustment rules:
Triggering the upgrading of the customer value score when the trade amount of the customer on a single day is 5 times of the average value of the first 6 months;
When the customer has no transaction data for 3 consecutive months, andTriggering the customer value score to be degraded when the task priority associated with the customer is continuously reduced;
Transmitting customer transaction data through Kafka, calling a customer value scoring model through a Flink, calculating a customer value score, and writing the customer value score into Redis for real-time inquiry of a system;
the time series model ARIMA is periodically trained by Spark to update the Hive table.
Preferably, the adding an adjustment rule in the optimized data synchronization policy dynamically adjusts importance of data or tasks, and further includes:
The temporary importance adjusting mechanism is added to realize temporary improvement and reduction of the importance of data or tasks, and the method specifically comprises the following steps:
Adding a temporary adjustment table in a target system database, wherein the temporary adjustment table comprises an adjustment record ID, an adjustment object type, a client ID, a synchronous task ID, an importance before adjustment, an importance after adjustment, an effective time, a failure time, an operator ID and an adjustment reason;
the adjustment mechanism is that the importance value of the current effect isWherein, the method comprises the steps of,A quantized value representing the importance of the current effect,Indicating the importance of the adjustment after the adjustment,Representing the output of a task importance scoring model or a customer value scoring model,The current time is indicated as such,Indicating the time of the effective period of the adjustment,Indicating an adjusted expiration time;
covering the importance before adjustment by using the importance after adjustment through the priority covering middleware;
According to the preset scanning frequency, automatically scanning and recording the expired adjustment, and automatically stopping the temporary importance adjustment mechanism after triggering the notification information.
Preferably, the method for overlaying the importance before the adjustment by the priority overlay middleware further comprises integrating the customer importance score, the task importance score, the data importance and the temporary adjustment record to generate the comprehensive importance, and generating the final adjusted importance based on the comprehensive importance and the adjusted importance in the temporary adjustment form, wherein the method comprises the following specific steps of:
Obtaining customer importance scores based on a customer value score model;
Acquiring task importance scores based on task importance score models;
Acquiring data importanceAnd a quantized value of the adjusted importance;
Will beAndCarrying out normalization treatment;
Comprehensive importance;
Wherein,Representing the weight coefficient of the resource, wherein,Representation ofNormalized values.
An AI-based enterprise business data processing system comprises a processor, a memory and a communication module connected with the processor, wherein the system is used for executing the AI-based enterprise business data processing method.
A computer readable storage medium storing a computer program for execution by a processor to implement the AI-based enterprise business data processing method.
The invention has the beneficial effects that:
1. According to the invention, whether the client data of the source system (CRM system) and the target system (ERP) are communicated or not is judged, and the safe communication is realized under the condition that the client data are not communicated, so that the client data are ensured to be in different data.
2. According to the method, after the client data and the target system are communicated, different data storage schemes are kept consistent through the design of the data synchronization strategy, for example, partial data or analysis is stored in the Hadoop while the source system is synchronized to the database of the ERP system, and the data consistency of the database of the ERP system and the Hadoop storage scheme is ensured through the data synchronization strategy.
3. According to the invention, the dynamic adjustment model is used for adding an adjustment rule in the data synchronization process to adjust the importance of data or tasks, and the proportion of the total data and the incremental data in the data synchronization process is dynamically adjusted according to the importance of the data and the tasks.
Drawings
Fig. 1 is a flowchart of an AI-based enterprise business data processing method of the present invention.
Detailed Description
The following description is presented to enable one of ordinary skill in the art to make and use the invention. The preferred embodiments in the following description are by way of example only and other obvious variations will occur to those skilled in the art. The basic principles of the invention defined in the following description may be applied to other embodiments, variations, modifications, equivalents, and other technical solutions without departing from the spirit and scope of the invention.
It will be understood that the terms "a" and "an" should be interpreted as referring to "at least one" or "one or more," i.e., in one embodiment, the number of elements may be one, while in another embodiment, the number of elements may be plural, and the term "a" should not be interpreted as limiting the number.
Embodiment one:
referring to fig. 1, the technical scheme provided by the invention is that an enterprise business data processing method based on AI comprises the following steps:
Step 1, acquiring source system data, and storing the acquired data into one or more target systems, wherein the source system comprises a customer relationship management system CRM and a business intelligent BI system, and the target systems comprise an enterprise resource planning ERP system and a big data processing Hadoop system;
Step 2, constructing a data synchronization strategy, monitoring and managing data synchronization among databases of a target system based on the data synchronization strategy, and comprising the following substeps:
And 2.1, generating a data synchronization strategy based on the data synchronization cost. Comprises the following substeps:
Constructing a dynamic adjustment model, and dynamically adjusting the data volume proportion of full-volume data and incremental data, specifically:
Building a state matrix, wherein,The rate of change of the data is indicated,Representing the cost of synchronizing the full amount of data,Representing the cost of incremental data synchronization,Representing the average time consumption of the history synchronization.
The data change rate is the percentage of the number of newly added or modified records in unit time to the total number of records, the number of changed records can be counted from a database log, the total data synchronization cost is the time, bandwidth and computing resources (CPU and memory utilization rate) consumed during the total synchronization, the incremental data synchronization cost is the resource consumption (CPU and memory utilization rate) of a CDC (CDC) tool, and the average time consumption of the historical synchronization is the average time consumption of N times of past synchronization tasks.
Constructing a weight matrixThe first line element of the weight matrix is expressed in a decision vector corresponding to full data synchronization, and the second line element of the weight matrix is expressed in a decision vector corresponding to incremental data synchronization;
Generating synchronization policiesWhereinAndA data proportion representing full synchronization and an incremental synchronization data proportion;
optimizing weight matrices by gradient descent to minimize synchronization costsThe gradient calculation process comprises the following steps:
;
The updated weight matrix is;
When (when)Triggering full data synchronization when in use, otherwise, according to the followingThe proportion is used for synchronizing the increment data, wherein,Representing a full synchronization threshold.
For example, in the present embodiment, the state vector in the current state is;
The weight matrix is,;
Normalized by Softmax to obtain,;
The synchronization strategy is that 52% of the synchronous data volume adopts full volume synchronization and 48% adopts increment synchronization.
And 2.2, after quantifying the importance of the data and the data synchronization task, combining the importance with the data synchronization cost, and optimizing the data synchronization strategy. Comprises the following substeps:
Extracting importance of data and importance of a data synchronization task from metadata of a target system, wherein the importance of the data is defined as influence weight of the extracted data on system business based on business rules preset by the target system, the importance of the data synchronization task is defined as priority of the task based on a type of the synchronization task, and the type of the task comprises a real-time report task and an offline analysis task;
specifically, based on the ratings of clients corresponding to the data, the importance of the data is associated with the ratings, and the importance of the data is quantified by the client ratingsBased on the priority of the data synchronization task, the importance of the data synchronization task is related to the priority, and the importance of the data synchronization task is quantized by the priority;
Will beAndAdded toIn (3) forming a new state matrix;
Construction of new synchronization costs, wherein,Represents a penalty coefficient and,Representing a delay time when incremental data is synchronized;
updating weight matrix by gradient descent method, minimizingWherein the gradient calculation process is as follows:;
Wherein,,;
The optimized synchronization strategy:;
When (when)When the data is synchronized in full, that is,Wherein, the method comprises the steps of,Representing a task importance threshold one;
When (when)When the incremental data synchronization delay is allowed,Representing a task importance threshold two.
For example, in this embodiment, the two target systems are an ERP system and a Hadoop system, and after the data of the CRP system (source system) is accessed to the ERP system, the data needs to be synchronized to the Hadoop for backup.
There is now a need to synchronize the order data of VIP clientsThe type of the synchronous task is order data, the priority of the order data task is set to be 3, namely;
When (when),,,In the time-course of which the first and second contact surfaces,
;
Optimal solution whenIn the time-course of which the first and second contact surfaces,When (1)In the time-course of which the first and second contact surfaces,. Because of the high importance of VIP clients' data, the system chooses full synchronization (avoiding the risk of penalty of 75 units) even though the cost at full synchronization is somewhat higher.
And 2.3, adding an adjustment rule in the optimized data synchronization strategy, and dynamically adjusting the importance of the data or the task. Comprises the following substeps:
Based on customer behavior, transaction data and system business rules, quantifying customer value, formulating dynamic adjustment rules of customer ratings, comprising the following steps:
acquiring client behavior, transaction data and system business rule data from a target system database to form a client data set;
Extracting key features from a customer dataset to form a customer key feature setThe real-time key features comprise the accumulated transaction amount, the maximum transaction amount, the liveness and the repurchase rate of the clients;
after normalizing the customer key feature set, inputting the customer key feature set into a time sequence model ARIMA, and predicting the consumption of the customer for 6 months in the future;
Constructing a customer value scoring model:
, wherein,Respectively representing scoring weight coefficients; representing a maximum transaction amount for the customer; Representing an accumulated transaction amount; representing the repurchase rate; A forecast value representing a customer's future 6 months of consumption; represents the coefficient of attenuation and,;
Setting a customer value scoring classification interval,When the client is judged to be a high-value client, whenWhen the client is judged to be a low-value client;
The dynamic adjustment rule of the priority of the task is formulated by combining the type of the data synchronization task, the timeliness requirement and the value of the associated data, and the method specifically comprises the following steps:
the types of the data synchronization tasks are divided into real-time wind control, real-time report forms, batch analysis and history archiving according to the data purposes;
Assigning task weights to different types of data synchronization tasks;
Constructing a task importance scoring model:
wherein, the method comprises the steps of,The task weight vector is represented as a vector of weights,;Indicating that the task has been delayed in time,Representing the adjustment coefficient; the importance of the data is indicated and,;
Setting task importance scoring classification interval,When the task is judged to be the task with the highest priority; judging that the synchronous task is a low-priority task;
Setting adjustment rules:
Triggering the upgrading of the customer value score when the trade amount of the customer on a single day is 5 times of the average value of the first 6 months;
When the customer has no transaction data for 3 consecutive months, andTriggering the customer value score to be degraded when the task priority associated with the customer is continuously reduced;
Transmitting customer transaction data through Kafka, calling a customer value scoring model through a Flink, calculating a customer value score, and writing the customer value score into Redis for real-time inquiry of a system;
the time series model ARIMA is periodically trained by Spark to update the Hive table.
And 3, generating data of one or more target systems to the cloud platform for storage.
The method further comprises the following steps before the step 1:
And judging whether the target system database is communicated with the source system or not, and judging the consistency of the data synchronized by the source system to different target systems.
The method for judging whether the target system database is communicated with the source system comprises the following steps:
Modifying one or more fields in the source system, detecting whether the corresponding field of the target system is changed, if so, entering a step 2, otherwise, entering the following steps:
modifying one or more fields in the target system, checking whether corresponding automation in the source system is synchronous, if so, entering step 2, otherwise, entering the following steps:
Comparing the sampled and exported target system data with the sampled and exported source system data, judging whether the sampled and exported target system data are consistent with the sampled and exported source system data, if so, entering the step 2, otherwise, entering the following steps:
Checking an API (application program interface) call log of a target system, and confirming whether an exchange record exists in a source system, if so, entering a step 2, otherwise, automatically opening a database of the target system and the source system, wherein the method specifically comprises the following steps of:
determining data fields needing to be synchronized;
identifying sensitive fields in the synchronous data fields, encrypting or hashing the sensitive fields, and establishing independent indexes for the high-frequency query fields;
Calling an API interface of the target system to be in butt joint with the source system, or extracting data from the source system by using an ETL tool, and loading the data to the ERP system after cleaning;
And according to the preset monitoring frequency, periodically auditing the access rights of the API interface and removing the redundant account information.
The method for judging the consistency of the data synchronized by the source system to different target systems comprises the following steps:
acquiring a plurality of data to be checked from different target systems, and partitioning according to the same rule to acquire a plurality of corresponding data blocks I and data blocks II;
calculating and obtaining a first hash value of each first data block and a second hash value of each second data block;
Constructing a Merck tree I based on the hash value I, and constructing a Merck tree II based on the hash value II;
acquiring a root hash value of the first merck tree and a root hash value of the second merck tree, comparing, if the difference exists, searching for a corresponding first data block and a corresponding second data block, and covering the corresponding second data block by taking the first data block as a reference;
if the second data block cannot be automatically covered, the first difference data block and the second difference data block are pushed to the upper computer to be manually processed.
Embodiment two:
In this embodiment, on the basis of the first embodiment, an adjustment rule is added when the importance of data or tasks is dynamically adjusted. The method specifically comprises the following steps:
The temporary importance adjusting mechanism is added to realize temporary improvement and reduction of the importance of data or tasks, and the method specifically comprises the following steps:
Adding a temporary adjustment table in a target system database, wherein the temporary adjustment table comprises an adjustment record ID, an adjustment object type, a client ID, a synchronous task ID, an importance before adjustment, an importance after adjustment, an effective time, a failure time, an operator ID and an adjustment reason;
the adjustment mechanism is that the importance value of the current effect isWherein, the method comprises the steps of,A quantized value representing the importance of the current effect,Indicating the importance of the adjustment after the adjustment,Representing the output of a task importance scoring model or a customer value scoring model,The current time is indicated as such,Indicating the time of the effective period of the adjustment,Indicating an adjusted expiration time;
covering the importance before adjustment by using the importance after adjustment through the priority covering middleware;
According to the preset scanning frequency, automatically scanning and recording the expired adjustment, and automatically stopping the temporary importance adjustment mechanism after triggering the notification information.
In this embodiment, the temporary importance adjustment mechanism cooperates with the dynamic adjustment model, so that business personnel of the enterprise can quickly respond to the time length change and temporarily adjust the importance of data or tasks.
Embodiment III:
On the basis of the second embodiment, the method first integrates the customer importance score, the task importance score, the data importance and the temporary adjustment record to generate the comprehensive importance, and then compares the comprehensive importance with the adjusted importance in the temporary adjustment table to generate the final adjusted importance. To achieve the effect of managing customer importance scores, task importance scores and data importance and temporarily adjusting records through the priority overlay middleware. The method specifically comprises the following steps:
Obtaining customer importance scores based on a customer value score model;
Acquiring task importance scores based on task importance score models;
Acquiring data importanceAnd a quantized value of the adjusted importance;
Will beAndCarrying out normalization treatment;
Comprehensive importance;
Wherein,Representing the weight coefficient of the resource, wherein,Representation ofThe value after the normalization is carried out,
If it isThen useForced coverageOtherwise use
For example, take the slicing task of a 5G network as an example:
the input variables are,,In effect;The values are respectively 0.3, 0.2 and 0.2;
Comprehensive importance;
Due toUsingForced coverage,The final adjusted importance was 0.9.
If the adjusted importance is the importance of the data, using the adjusted importance of the data to replace the importance of the data quantified based on the customer ratingAnd forming a new state matrix, further finally obtaining the data proportion and the increment synchronization data proportion of the full synchronization, and controlling the data synchronization process according to the data proportion and the increment synchronization data proportion of the full synchronization.
The invention also provides an AI-based enterprise business data processing system, which comprises a processor, a memory and a communication module, wherein the memory and the communication module are connected with the processor, and the system is used for executing the AI-based enterprise business data processing method.
The present invention also provides a computer readable storage medium storing a computer program that is executed by a processor to implement the AI-based business data processing method.
The processes described above with reference to flowcharts may be implemented as computer software programs in accordance with the disclosed embodiments of the application. Embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable medium, the computer program comprising program code for performing the method shown in the flow chart. In such embodiments, the computer program may be downloaded and installed from a network via a communication portion, and/or installed from a removable medium. The above-described functions defined in the method of the present application are performed when the computer program is executed by a Central Processing Unit (CPU). The computer readable medium of the present application may be a computer readable signal medium or a computer readable storage medium, or any combination of the two. The computer readable storage medium can be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or a combination of any of the foregoing. More specific examples of a computer-readable storage medium may include, but are not limited to, an electrical connection having one or more wire segments, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present application, however, the computer-readable signal medium may include a data signal propagated in baseband or as part of a carrier wave, with the computer-readable program code embodied therein. Such a propagated data signal may take any of a variety of forms, including, but not limited to, electro-magnetic, optical, or any suitable combination of the foregoing. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless segments, radio lines, fiber optic cables, RF, etc., or any suitable combination of the foregoing.
The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present invention. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams and/or flowchart illustration, and combinations of blocks in the block diagrams and/or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
It will be understood by those skilled in the art that the embodiments of the present invention described above and shown in the drawings are merely illustrative and not restrictive of the current invention, and that this invention has been shown and described with respect to the functional and structural principles thereof, without departing from such principles, and that any changes or modifications may be made to the embodiments of the invention without departing from such principles.

Claims (8)

Translated fromChinese
1.一种基于AI的企业业务数据处理方法,其特征在于,所述方法包括:1. An enterprise business data processing method based on AI, characterized in that the method comprises:步骤1、获取源系统数据,将获取的数据存储至一个或者多个目标系统中;Step 1: Obtain source system data and store the acquired data in one or more target systems;步骤2、构建数据同步策略,基于数据同步策略监控和管理目标系统数据库间的数据同步,包括:Step 2: Build a data synchronization strategy to monitor and manage data synchronization between target system databases based on the data synchronization strategy, including:基于数据同步成本生成数据同步策略;包括:Generate a data synchronization strategy based on data synchronization costs; including:构建动态调整模型,动态调整全量数据和增量数据的数据量比例,具体的:Build a dynamic adjustment model to dynamically adjust the data volume ratio between full data and incremental data. Specifically:构建状态矩阵,其中,表示数据变更率,表示全量数据同步成本,表示增量数据同步成本,表示历史同步的平均耗时;Constructing the state matrix ,in, Indicates the data change rate, Indicates the full data synchronization cost. represents the incremental data synchronization cost, Indicates the average time taken for historical synchronization;构建权重矩阵,所述权重矩阵的第一行元素表示于全量数据同步对应的决策向量;所述权重矩阵的第二行元素表示于增量数据同步对应的决策向量;Constructing the weight matrix , the first row elements of the weight matrix represent the decision vectors corresponding to the full data synchronization; the second row elements of the weight matrix represent the decision vectors corresponding to the incremental data synchronization;生成同步策略;其中表示全量同步的数据比例和增量同步数据比例;Generate synchronization strategy ;in and Indicates the proportion of data synchronized in full and incremen- tally in sync.通过梯度下降法优化权重矩阵,以最小化同步成本,其中,梯度计算过程为:Optimize the weight matrix by gradient descent to minimize the synchronization cost , where the gradient calculation process is: ;更新后的权重矩阵为The updated weight matrix is ;时,触发全量数据同步;否则,按照比例同步增量数据;其中,表示全量同步阈值;when When the full data synchronization is triggered; otherwise, Proportional synchronous incremental data; where, Indicates the full synchronization threshold;将数据和数据同步任务的重要性量化后,与数据同步成本结合,对数据同步策略进行优化;包括:After quantifying the importance of data and data synchronization tasks, we combine them with the data synchronization cost and optimize the data synchronization strategy. This includes:从一个目标系统的元数据中提取数据重要性和数据同步任务的重要性,所述数据重要性为基于目标系统预设的业务规则定义所提取的数据对系统业务的影响权重,所述数据同步任务的重要性为基于同步任务的类型定义的任务的优先级,所述任务的类型包括实时报表任务,离线分析任务;Extracting data importance and data synchronization task importance from metadata of a target system, wherein the data importance is the weight of the impact of the extracted data on the system business based on the preset business rules of the target system, and the data synchronization task importance is the priority of the task defined based on the type of synchronization task, and the task type includes real-time report task and offline analysis task;具体为:基于数据对应的客户的评级,将数据的重要性与评级关联,用客户评级量化数据的重要性;基于数据同步任务的优先级,将数据同步任务的重要性与优先级关联,用优先级量化数据同步任务的重要性Specifically: Based on the rating of the customer corresponding to the data, the importance of the data is associated with the rating, and the importance of the data is quantified using the customer rating. ; Based on the priority of data synchronization tasks, the importance of data synchronization tasks is associated with the priority, and the importance of data synchronization tasks is quantified by the priority ;添加到中,形成新的状态矩阵Will and Add to In the new state matrix ;构建新的同步成本,其中,表示惩罚系数,表示增量数据同步时的延迟时间;Building a new synchronization cost ,in, represents the penalty coefficient, Indicates the delay time when synchronizing incremental data;通过梯度下降法更新权重矩阵,最小化;其中梯度计算过程为:;其中,Update the weight matrix by gradient descent to minimize ; The gradient calculation process is: ;in, , ;优化后的同步策略:Optimized synchronization strategy: ;时,强制数据全量同步,即,;其中,表示任务重要性阈值一;when When the data is fully synchronized, ;in, represents the task importance threshold of one;时,允许增量数据同步延迟,表示任务重要性阈值二;when When , incremental data synchronization delay is allowed. represents the task importance threshold 2;在优化后的数据同步策略内增加调整规则,动态调整数据或任务的重要性;Add adjustment rules to the optimized data synchronization strategy to dynamically adjust the importance of data or tasks;步骤3、将一个或者多个目标系统的数据发生至云平台存储。Step 3: Store the data of one or more target systems on the cloud platform.2.根据权利要求1所述的一种基于AI的企业业务数据处理方法,其特征在于,所述源系统包括客户关系管理系统CRM、商业智能BI系统,所述目标系统包括企业资源计划ERP系统、大数据处理Hadoop系统;2. According to claim 1, the enterprise business data processing method based on AI is characterized in that the source system includes a customer relationship management system CRM and a business intelligence BI system, and the target system includes an enterprise resource planning ERP system and a big data processing Hadoop system;在获取源系统数据,将获取的数据存储至目标系统数据库之前,还包括:Before obtaining the source system data and storing the obtained data in the target system database, it also includes:判断目标系统数据库是否与源系统打通;Determine whether the target system database is connected to the source system;判断源系统同步到不同目标系统的数据的一致性;Determine the consistency of data synchronized from the source system to different target systems;所述判断目标系统数据库是否与源系统打通,包括以下步骤:The step of determining whether the target system database is connected to the source system includes the following steps:修改源系统中的一个或者多个字段,检测目标系统对应字段是否变化,如果是,则进入步骤2,否则,进入下面步骤:Modify one or more fields in the source system and check whether the corresponding fields in the target system have changed. If yes, proceed to step 2. Otherwise, proceed to the following steps:在目标系统中修改一个或者多个字段,查看源系统中的对应自动是否同步,如果是,则进入步骤2,否则,进入下面步骤:Modify one or more fields in the target system and check whether the corresponding fields in the source system are automatically synchronized. If yes, proceed to step 2. Otherwise, proceed to the following steps:抽样导出目标系统和源系统数据进行对比,判断是否一致,如果是,则进入步骤2,否则,进入下面步骤:Sample and export the target system and source system data for comparison to determine whether they are consistent. If yes, proceed to step 2. Otherwise, proceed to the following steps:查看目标系统的API接口调用日志,确认是否存在于源系统的交换记录,如果是,则进入步骤2,否则,自动打通目标系统数据库与源系统,具体包括以下步骤:Check the API call log of the target system to confirm whether there is an exchange record in the source system. If yes, proceed to step 2. Otherwise, automatically connect the target system database with the source system. Specifically, the following steps are included:确定需要同步的数据字段;Determine the data fields that need to be synchronized;识别同步的数据字段中的敏感字段,对敏感字段进行加密或哈希处理,并为高频查询字段建立独立索引;Identify sensitive fields in synchronized data fields, encrypt or hash sensitive fields, and create independent indexes for high-frequency query fields;调用目标系统的API接口与源系统对接,或者使用ETL工具从源系统中抽取数据,经过清洗后加载至ERP系统;Call the API interface of the target system to connect with the source system, or use ETL tools to extract data from the source system and load it into the ERP system after cleaning;按照预设的监控频率,定期审计API接口的访问权限,移除冗余账号信息。According to the preset monitoring frequency, regularly audit the access rights of the API interface and remove redundant account information.3.根据权利要求2所述的一种基于AI的企业业务数据处理方法,其特征在于,所述判断源系统同步到不同目标系统的数据的一致性,包括:3. The AI-based enterprise business data processing method according to claim 2, wherein the step of determining the consistency of data synchronized from a source system to different target systems comprises:从不同目标系统中获取多个待校验的数据,并按照相同规则进行分块,获取多个相应的数据块一和数据块二;Acquire multiple data to be verified from different target systems, and divide them into blocks according to the same rule to obtain multiple corresponding data blocks 1 and data blocks 2;计算获取每个数据块一的哈希值一和数据块二的哈希值二;Calculate and obtain the hash value 1 of each data block 1 and the hash value 2 of each data block 2;基于哈希值一构建默克尔树一,基于哈希值二构建默克尔树二;Construct Merkle tree one based on hash value one, and construct Merkle tree two based on hash value two;获取默克尔树一的根哈希值和默克尔树二的根哈希值后进行比对,如果存在差异,则寻找相应的数据块一和数据块二,并以数据块一为准,覆盖对应的数据块二;Obtain the root hash value of Merkle tree 1 and the root hash value of Merkle tree 2 and compare them. If there is a difference, find the corresponding data block 1 and data block 2, and use data block 1 as the basis to overwrite the corresponding data block 2;如果数据块二无法自动覆盖,则将差异数据块一和数据块二推送至上位机由人工处理。If data block 2 cannot be automatically overwritten, the difference data block 1 and data block 2 are pushed to the host computer for manual processing.4.根据权利要求3所述的一种基于AI的企业业务数据处理方法,其特征在于,在优化后的数据同步策略内增加调整规则,动态调整数据或任务的重要性,包括:4. The AI-based enterprise business data processing method according to claim 3 is characterized in that adjustment rules are added to the optimized data synchronization strategy to dynamically adjust the importance of data or tasks, including:基于客户行为、交易数据和系统业务规则,量化客户价值,制定客户的评级的动态调整规则,具体包括以下步骤:Based on customer behavior, transaction data and system business rules, quantify customer value and formulate dynamic adjustment rules for customer ratings, which specifically include the following steps:从目标系统数据库中获取客户行为、交易数据、系统业务规则数据,构成客户数据集;Obtain customer behavior, transaction data, and system business rule data from the target system database to form a customer data set;从客户数据集中提取关键特征,构成客户关键特征集,实时关键特征包括客户的累计交易额、最大交易额、活跃度、复购率;Extract key features from customer data sets to form customer key feature sets ,Real-time key features include customers’ cumulative transaction amount, maximum transaction amount, activity, and repurchase rate;将客户关键特征集归一化处理后,输入时间序列模型ARIMA内,预测客户未来6个月的消费额;After normalizing the customer's key feature set, input it into the time series model ARIMA to predict the customer's consumption amount in the next 6 months;构建客户价值评分模型:Build a customer value scoring model:,其中,分别表示评分权重系数;表示客户最大交易额;表示累计交易额;表示复购率;表示客户未来6个月的消费额的预测值;表示衰减系数, ,in, They represent the scoring weight coefficients respectively; Indicates the maximum transaction amount of the customer; Indicates the cumulative transaction amount; Represents the repurchase rate; Indicates the predicted value of the customer's consumption in the next 6 months; represents the attenuation coefficient, ;设置客户价值评分分类区间时,判断客户为高价值客户;当时,判断客户为低价值客户;Set customer value rating category range , When When the customer is judged as a low-value customer;结合数据同步任务的类型、时效性要求和关联数据的价值,制定任务的优先级的动态调整规则,具体包括以下步骤:Based on the type of data synchronization task, timeliness requirements, and the value of associated data, a dynamic adjustment rule for the task priority is formulated, which specifically includes the following steps:根据数据用途将数据同步任务的类型分为实时风控、实时报表、批量分析和历史归档;According to the purpose of data, the types of data synchronization tasks are divided into real-time risk control, real-time reporting, batch analysis and historical archiving;为不同的数据同步任务的类型分配任务权重Assign task weights to different types of data synchronization tasks ;构建任务重要性评分模型:Build a task importance scoring model:;其中,表示任务权重向量,表示任务已经延迟时间,表示调节系数;表示数据重要性, ;in, represents the task weight vector, ; Indicates that the task has been delayed. represents the adjustment coefficient; Indicates the importance of data. ;设置任务重要性评分分类区间时,判断为最高优先级任务;时,判断同步任务为低优先级任务;Set the task importance rating classification interval , When , it is judged as the highest priority task; When , the synchronization task is judged as a low priority task;设置调整规则:Set adjustment rules:当客户单日的交易额大于前6个月平均值的5倍时,触发客户价值评分升级;同时升级与客户关联的任务优先级;When a customer's daily transaction volume is more than five times the average of the previous six months, the customer value score is upgraded; at the same time, the task priority associated with the customer is upgraded;当客户连续3个月无交易数据时,且连续下降,则触发客户价值评分降级;同时降低与客户关联的任务优先级;When the customer has no transaction data for 3 consecutive months, and Continuous decline will trigger a downgrade of the customer value score and reduce the priority of tasks associated with the customer;具体为:通过Kafka传输客户交易数据,通过Flink调用客户价值评分模型,计算客户价值评分,将客户价值评分写入Redis以供系统实时查询;Specifically: transmit customer transaction data through Kafka, call the customer value scoring model through Flink, calculate the customer value score, and write the customer value score to Redis for real-time query by the system;通过Spark周期性训练时间序列模型ARIMA,以更新Hive表。Periodically train the ARIMA time series model through Spark to update the Hive table.5.根据权利要求4所述的一种基于AI的企业业务数据处理方法,其特征在于,所述在优化后的数据同步策略内增加调整规则,动态调整数据或任务的重要性,还包括:5. According to claim 4, an AI-based enterprise business data processing method is characterized in that the step of adding adjustment rules to the optimized data synchronization strategy to dynamically adjust the importance of data or tasks also includes:增加临时重要性调整机制,实现临时提升和降低数据或任务重要性,具体为:Add a temporary importance adjustment mechanism to temporarily increase or decrease the importance of data or tasks. Specifically:在一个目标系统数据库中增加临时调整表格,所述临时调整表格包括调整记录ID、调整对象类型、客户ID、同步任务ID、调整前重要性、调整后重要性、生效时间、失效时间、操作人ID和调整原因;Adding a temporary adjustment table in a target system database, wherein the temporary adjustment table includes an adjustment record ID, an adjustment object type, a customer ID, a synchronization task ID, importance before adjustment, importance after adjustment, effective time, expiration time, operator ID, and adjustment reason;调整机制为:当前生效的重要性值为;其中,表示当前生效的重要性的量化值,表示调整后的重要性,表示任务重要性评分模型或者客户价值评分模型的输出,表示当前时间,表示调整的生效时间,表示调整的失效时间;The adjustment mechanism is: the current effective importance value is ;in, A quantitative value indicating the importance of the current effect. represents the adjusted importance, represents the output of the task importance scoring model or the customer value scoring model, Indicates the current time. Indicates the effective time of the adjustment. represents the adjusted expiration time;通过优先级覆盖中间件,使用调整后的重要性覆盖调整前的重要性;Use the priority override middleware to override the importance before adjustment with the adjusted importance;按照预设的扫描频率,自动扫描过期的调整并记录,触发通知信息后自动停止临时重要性调整机制。According to the preset scanning frequency, the overdue adjustments are automatically scanned and recorded, and the temporary importance adjustment mechanism is automatically stopped after the notification information is triggered.6.根据权利要求5所述的一种基于AI的企业业务数据处理方法,其特征在于,所述通过优先级覆盖中间件,使用调整后的重要性覆盖调整前的重要性,还包括:对客户重要性评分、任务重要性评分和数据重要性和临时调整记录进行整合,生成综合重要性,基于综合重要性和临时调整表格中的调整后的重要性,生成最终调整后的重要性,具体步骤如下:6. According to claim 5, an AI-based enterprise business data processing method is characterized in that the priority overlay middleware is used to overwrite the importance before adjustment with the adjusted importance, and further comprises: integrating the customer importance score, the task importance score, the data importance and the temporary adjustment record to generate a comprehensive importance, and generating the final adjusted importance based on the comprehensive importance and the adjusted importance in the temporary adjustment table, and the specific steps are as follows:基于客户价值评分模型获取客户重要性评分Obtain customer importance scores based on the customer value scoring model ;基于任务重要性评分模型获取任务重要性评分Obtaining task importance scores based on the task importance scoring model ;获取数据重要性和调整后的重要性的量化值Obtaining data importance and the quantitative value of adjusted importance ;进行归一化处理;Will , , and Perform normalization processing;综合重要性Overall importance ;其中,表示资源权重系数;其中,表示归一化后的值,in, represents the resource weight coefficient; where, express , The normalized value,如果,则使用强制覆盖,否则使用if , then use Forced coverage , otherwise use .7.一种基于AI的企业业务数据处理系统,包括:处理器和与处理器连接的存储器和通信模块,其特征在于,所述系统用于执行上述权利要求1-6中任意一项所述的一种基于AI的企业业务数据处理方法。7. An AI-based enterprise business data processing system, comprising: a processor and a memory and a communication module connected to the processor, characterized in that the system is used to execute an AI-based enterprise business data processing method as described in any one of claims 1-6.8.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机程序,所述计算机程序被处理器执行以实现上述权利要求1-6中任意一项所述的一种基于AI的企业业务数据处理方法。8. A computer-readable storage medium, characterized in that the computer-readable storage medium stores a computer program, and the computer program is executed by a processor to implement an AI-based enterprise business data processing method as described in any one of claims 1 to 6.
CN202510412689.7A2025-04-032025-04-03Enterprise business data processing system and method based on AIActiveCN119917495B (en)

Priority Applications (1)

Application NumberPriority DateFiling DateTitle
CN202510412689.7ACN119917495B (en)2025-04-032025-04-03Enterprise business data processing system and method based on AI

Applications Claiming Priority (1)

Application NumberPriority DateFiling DateTitle
CN202510412689.7ACN119917495B (en)2025-04-032025-04-03Enterprise business data processing system and method based on AI

Publications (2)

Publication NumberPublication Date
CN119917495A CN119917495A (en)2025-05-02
CN119917495Btrue CN119917495B (en)2025-06-17

Family

ID=95504626

Family Applications (1)

Application NumberTitlePriority DateFiling Date
CN202510412689.7AActiveCN119917495B (en)2025-04-032025-04-03Enterprise business data processing system and method based on AI

Country Status (1)

CountryLink
CN (1)CN119917495B (en)

Citations (1)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN118568181A (en)*2024-07-312024-08-30北京科杰科技有限公司Cross-environment data synchronization method and device

Family Cites Families (5)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN112131237B (en)*2020-09-282024-06-14京东科技控股股份有限公司Data synchronization method, device, equipment and computer readable medium
CN118227599A (en)*2023-12-112024-06-21中电鸿信信息科技有限公司Data standard treatment method, system, equipment and medium based on automatic flow
CN118964489A (en)*2023-12-152024-11-15杭州观远数据有限公司 Offline synchronization method of incremental data in data development
CN119576506B (en)*2025-02-072025-04-18浙江数新网络有限公司Method and system for scheduling task and data collaborative smooth migration based on big data platform
CN119652840A (en)*2025-02-142025-03-18深圳中科德能科技有限公司 Deterministic network delay scheduling method, device and storage medium based on TSN

Patent Citations (1)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN118568181A (en)*2024-07-312024-08-30北京科杰科技有限公司Cross-environment data synchronization method and device

Also Published As

Publication numberPublication date
CN119917495A (en)2025-05-02

Similar Documents

PublicationPublication DateTitle
CN118761745B (en)OA collaborative workflow optimization method applied to enterprise
JP6099712B2 (en) Big stream data real-time processing method, stream data processing engine, and big stream data real-time processing system
US20120330964A1 (en)Smart index creation and reconciliation in an interconnected network of systems
CN118940076A (en) Enterprise internal affairs management system based on cloud-based intelligent collaborative processing
CN113568892A (en)Method and equipment for carrying out data query on data source based on memory calculation
CN117724898A (en) Disaster recovery backup data management system based on cloud computing
CN120215831B (en) Information processing method and system applied to all-flash file storage
CN119809770B (en)Online shopping contract generation method and system based on blockchain
CN110276691A (en) A data processing method and device based on a big data platform
CN120258481A (en) A method and system for enterprise digital management based on data mining
US8201145B2 (en)System and method for workflow-driven data storage
CN119917495B (en)Enterprise business data processing system and method based on AI
CN120013333A (en) Intelligent market supervision data governance system and method based on multi-level data sharing and exchange
CN119668813A (en) A method, device, equipment, medium and product for processing batch interruption tasks
CN119311754A (en) An intelligent data access and integration system based on dynamic expansion architecture
CN114020814A (en)Process industrial manufacturing full-chain data integration and analysis method and system
CN114116223A (en) A request-response method, device, system and readable storage medium
CN112783637A (en)Resource regulation and control method and device
CN117493311A (en)Database capacity control method, apparatus, device, medium, and program product
CN117745239B (en)Self-service template customization on-line filling system and method based on flow engine
CN118409830B (en) Database transaction management method, terminal and storage medium
CN119884229B (en) A processing method and system supporting multi-source heterogeneous data
CN120387558B (en)Material demand analysis and prediction method and device based on big data and storage medium
US12028271B2 (en)Prioritizing messages for server processing based on monitoring and predicting server resource utilization
US20250307848A1 (en)Systems and methods for adaptive api rule management

Legal Events

DateCodeTitleDescription
PB01Publication
PB01Publication
SE01Entry into force of request for substantive examination
SE01Entry into force of request for substantive examination
GR01Patent grant
GR01Patent grant

[8]ページ先頭

©2009-2025 Movatter.jp