CN114386957A - High-speed calculation system for electric charge - Google Patents

Abstract

The invention provides a high-speed electric charge calculation system, comprising: the data integration module is used for extracting the charge control calculation charge related data, initializing the charge control calculation charge related data into the high-performance calculation distributed storage, and performing preprocessing operation; the electric quantity calculation module is used for storing the synchronous surface code data in the marketing management information system in a distributed column storage format in a data processing platform and calculating the electric quantity through an electric quantity calculation algorithm; the electric charge calculation module is used for calculating the electric charge corresponding to each metering point according to the electric quantity calculation result, wherein the electric charge comprises electric charge, fund and additional charge, basic electric charge and power factor adjustment electric charge; the remote charge control management module is used for realizing measurement management and power failure and power restoration management in charge control service; and the result write-back module is used for writing back the generated result data to the marketing management information system after the relevant calculation, the check and the comparison are completed. The invention can assist the marketing management information system to meet the processing requirement of massive user data.

Description

A high-speed calculation system for electricity bills

technical field

The invention relates to the technical field of data processing, in particular to a high-speed calculation system for electricity charges.

Background technique

The cost control in the marketing management information system is based on the functional modules on the database server of the marketing management information system, which can adapt to the calculation of the amount and cost of small-scale users. For high-concurrency and high-availability business scenarios such as publishing, if large-scale user cost control calculations are performed every day, it will inevitably bring considerable pressure to the production environment of marketing, and also bring great risks to the production and operation of marketing. The main reason is that the current cost-controlled daily electricity bill calculation relies on stored procedures, and the calculation efficiency is limited. Taking the electricity bill calculation of a province as an example, considering the most extreme situation, it is necessary to complete the electricity bill calculation for millions of users every day. At present, the calculation capability of the cost control module is far from meeting business needs. In addition, the marketing management information system involves the storage and data processing capacity of 3 million business data for 3 years according to the actual business volume and moderate forecast at the time of construction. The data of electricity bills and electricity results are generated, and the storage requirements of these data have exceeded the design capabilities of the marketing management information system. Based on the above analysis, the calculation and storage requirements proposed by the remote charge control daily meter reading and calculation service are beyond the design capabilities of the existing marketing management information system. It is necessary to build a high-speed electricity calculation function to meet the business needs.

SUMMARY OF THE INVENTION

In view of this, the purpose of the present invention is to provide a high-speed electricity bill calculation system to overcome or at least partially solve the above-mentioned problems existing in the prior art.

A high-speed electricity bill calculation system, the system includes:

The data integration module is used to extract data related to cost control and calculation, initialize it into high-performance computing distributed storage, and perform preprocessing operations;

The power calculation module is used to save the table code data synchronized from the marketing management information system in the data processing platform in the format of distributed columnar storage, and perform power calculation through the power calculation algorithm;

The electricity fee calculation module is used to calculate the electricity fee corresponding to each metering point according to the electricity calculation result, and the electricity fee includes the electricity electricity fee, fund and surcharge, basic electricity fee and power factor adjustment electricity fee;

The remote cost control management module is used to realize the measurement management and power failure and power restoration management in the cost control business;

The result write-back module is used to write back the generated result data to the marketing management information system after completing the relevant calculation, verification and comparison.

Further, the data integration module specifically includes:

The file management sub-module is used to realize the initialization, synchronization and opening of marketing files;

The table code data management sub-module is used to realize the integration, distribution, opening, and abnormal verification management of the table code data required for calculation.

Further, the power calculation module specifically includes:

The calculation sub-module is used to calculate various types of electricity data and integrate them into the historical calculation results as independent fields;

The power integration sub-module is used to integrate all power into a total power, and eliminate redundant fields generated by the calculation process.

Further, the electricity fee calculation module specifically includes:

The electricity charge calculation sub-module is used to input the electricity calculation result into the electricity charge calculation algorithm to calculate the electricity charge corresponding to each metering point;

The electricity fee integration sub-module is used to integrate each electricity fee to form a summary electricity fee.

Further, the remote cost control management module specifically includes:

The key type management sub-module is used to add the required field "key type" in the related functions of electric energy meter filing. When the marketing management information system performs power failure and power recovery, the power failure and recovery control of the old and new key types will be distinguished. The instruction is sent to the metering automation system, so that the metering automation system points to and invokes the corresponding key system service according to the "key type";

Charge control stop electronic module, used to judge whether the user's meter type has the word "charge control" in the power failure process of ordinary users, if so, start the remote switch function, otherwise operate according to the ordinary process;

The power recovery control sub-module is used to implement forced power recovery and set timed power recovery tasks;

The abnormal data processing sub-module is used to process the artificial abnormal data of the arrears users after power failure and power failure.

Further, the system also includes a balance comparison module, which is used to compare the electricity bill calculation result with the user balance information, and mark the data below the threshold according to the arrears alarm threshold and the power outage warning threshold. After the comparison and marking are completed. Feedback the results to the Marketing Management Information System.

Further, the system further includes a withholding management module, which is used for triggering a single bill of power supply to be used to deduct the prepaid expenses of the plan when the daily measurement and calculation of the fee control user reaches the corresponding withholding condition.

Compared with the prior art, the beneficial effects of the present invention are:

The high-speed electricity calculation system provided by the present invention company builds the daily calculation function from the aspects of electricity calculation, electricity calculation and remote control and management functions, etc. The system can effectively complement the enterprise-level marketing management information system. The business that affects performance and the data and calculation processes that need mass storage are processed in this project, and the processing results are returned after the processing is completed. to the marketing management information system,

Description of drawings

In order to illustrate the technical solutions in the embodiments of the present invention more clearly, the following briefly introduces the accompanying drawings used in the description of the embodiments. Obviously, the accompanying drawings in the following description are only preferred embodiments of the present invention. For those of ordinary skill in the art, other drawings can also be obtained from these drawings without creative effort.

FIG. 1 is a schematic diagram of an overall structure of a high-speed electricity bill calculation system provided by an embodiment of the present invention.

In the figure, 1 data integration module, 101 file management submodule, 102 table code data management submodule, 2 electricity calculation module, 201 calculation submodule, 202 electricity integration submodule, 3 electricity bill calculation module, 301 electricity bill calculation submodule, 302 Electricity charge integration sub-module, 4 remote charge control management module, 401 key type management sub-module, 402 charge control and stop electronic module, 403 re-electronic control sub-module, 404 abnormal data processing sub-module, 5 result write-back module.

Detailed ways

The principles and features of the present invention will be described below with reference to the accompanying drawings. The enumerated embodiments are only used to explain the present invention, but not to limit the scope of the present invention.

Referring to FIG. 1 , this embodiment provides a high-speed calculation system for electricity bills. The system is divided into four layers in terms of architecture: an infrastructure layer, a basic software layer, a service support layer, and an application layer. The infrastructure layer is the hardware infrastructure layer of the system. For the needs of cost control business applications, the application server is considered to publish Web applications; the database server is considered to realize the storage of application and management data; and in the high-performance computing platform Consider building a server cluster with servers. The basic software layer adopts mainstream high-performance computing platform components for cost control business support, mainly using Hadoop cloud ecological components, and supports cost control file data processing, table code data processing and measurement through the data and computing services provided by each component. Require. The service support layer uses the service design concept based on SOA architecture to design a variety of business services for cost control business applications, encapsulates basic high-performance computing development technologies in terms of cost control business support, and designs a high-performance computing service suite. The application layer implements specific business functions based on the service support layer.

Specifically, the system includes a data integration module 1 , an electricity calculation module 2 , an electricity charge calculation module 3 , a remote charge control management module 4 and a result write-back module 5 . Wherein, the data integration module 1 is used to extract data related to cost control and calculation, initialize it into high-performance computing distributed storage, and perform preprocessing operations. The electricity calculation module 2 is used to calculate the electricity fee corresponding to each metering point according to the electricity quantity calculation result, and the electricity fee includes the electricity electricity fee, fund and surcharge, basic electricity fee and power factor adjustment electricity fee. The remote cost control management module 4 is used to realize measurement management and power failure and power restoration management in the cost control business. The result write-back module 5 is used to write back the generated result data to the marketing management information system after completing the relevant calculation, verification and comparison.

The data integration module 1 specifically includes a file management sub-module 101 and a table code data management sub-module 102 . The file management sub-module 101 is used to realize the initialization, synchronization and opening of marketing files. The initialization includes raw data initialization, paradigm conversion, initial profile normalization, and profile normalization. The original data is initialized to extract the archive data of the marketing management information system into the system through a data extraction tool, so as to perform a series of subsequent operations on the metering data. The initialization content includes: user files, metering point information, transformer information, metering point-to-point transformer relationship, account balance, electricity price information, etc.; the paradigm is converted into a data format that is convenient for business processing in the marketing management information system into a data format that is convenient for cost control calculation; the initial file is normalized to Standardize file data, construct various grid relationships, and power price allocation levels, and promptly handle abnormal and unreasonable files found to improve the accuracy of cost control; the file standardization is to partition the user files after initialization, And control the dependencies and serialization format, perform columnar storage and management, so as to facilitate high-performance computing and performance control. The synchronization is specifically the acquisition, integration and integration of marketing file changes. The marketing file changes involve multiple database tables and information, which need to be collected and obtained according to the model design. The content includes user files, metering point information, transformer information, metering point transformers relationship, account balance, electricity price information, etc.; the integration is to integrate the changes into the marketing file of cost control after obtaining the marketing file, and load it into the memory for calculation of the amount and charge. The content that needs to be synchronized includes user files, metering points information, transformer information, metering point-transformer relationship, account balance, electricity price information, etc.; the integration is specifically to integrate the synchronized marketing archive data and the marketing archive data stored in the high-performance computing platform into a complete and latest archive data. The data needs to be sharded to participate in the final volume fee calculation. The opening of marketing archives is to realize the opening operation of archive data after integrating archive data.

The table code data management sub-module 102 is used to realize the integration, distribution, opening, and abnormal check management of the table code data required for calculation. The integration is specifically to obtain the cost control table code data required for the calculation from the marketing system, convert the obtained table code into a file format of columnar storage, and store it in the distributed file storage system of the cost control calculation; the The distribution is specifically that in order to improve the processing speed of meter code data and thus shorten the overall cost control calculation process, the system uses a distributed message system after the data integration node to realize the online real-time processing of the meter code; the opening of the meter code data is specifically the integration of Form code data is opened according to the form code combined with the marketing measurement file; the abnormal verification management includes verification rule management, verification instance management, verification log management and verification result management, and the verification rule management is to check the table according to the verification rules. The verification instance is managed to generate a verification instance when the system runs the verification function module, and the verification task can be viewed through the instance; the verification log will record the process of data quality verification, including the start time. , end time, task creator, task status, task information and other information, in which task information will record various standard outputs and standard errors generated during the task running process, and query log information can be filtered according to start, end time, task status, etc. , to realize verification log management; the verification result management is to store the verified abnormal data, and the verification abnormal result data can be viewed through the result management function. When performing form code verification, the verification rule information configured by the verification rule management function is automatically loaded, the form code verification is performed, the abnormal form code data is marked, and the abnormal verification result is saved in the database.

The electric quantity calculation module 2 specifically includes a calculation sub-module 201 and an electric quantity integration sub-module 202. The electric quantity calculation sub-module 201 is used to calculate various types of electric quantity data and integrate them into the historical calculation results as independent fields. The various types of electricity data include the electricity quantity copied, electricity quantity for meter replacement, electricity quantity refunded and supplemented, total electricity quantity, variable loss electricity quantity, line loss electricity quantity, fixed ratio quantity electricity quantity, free electricity quantity and share electricity quantity. After a series of electricity calculations, such as copying, meter replacement, refund, total score, change loss, line loss, fixed ratio and quantification, free electricity, and shared electricity, the electricity forms a large wide meter based on the metering point. The integration sub-module 202 integrates all the powers into a total power through power integration, and eliminates redundant fields generated in the calculation process.

The electricity fee calculation module 3 specifically includes an electricity fee calculation sub-module 301 and an electricity fee integration sub-module 302. The electricity fee calculation sub-module 301 is used for inputting the electricity calculation result into the electricity fee calculation algorithm to calculate the electricity fee corresponding to each metering point, and the electricity fee is calculated. It mainly includes electricity charges, funds and surcharges, basic electricity charges and power factor adjustment charges. The electricity fee integration sub-module 302 adjusts the electricity fee according to the previously calculated electricity fee, fund and surcharge, basic electricity fee, and power factor through the high-performance computing platform, and integrates each electricity fee to form a summary electricity fee.

The remote charge control and management module 4 specifically includes a key type management sub-module 401 , a charge control and stop electronic module 402 , a recovery control sub-module 403 and an abnormal data processing sub-module 404 .

Among them, the key type management sub-module 401 is used to add a required field "key type" in the related functions of electric energy meter filing. The power failure and power recovery control command is sent to the metering automation system, so that the metering automation system points to and invokes the corresponding key system service according to the "key type".

The charge control stop electronic module 402 is used to judge whether the user meter type has the word "charge control" in the ordinary user power failure process, and if so, activate the remote switch-off function, otherwise operate according to the ordinary process.

The power restoration control sub-module 403 is used to implement forced power restoration and set timed power restoration tasks.

The abnormal data processing sub-module 404 is used to process the artificial abnormal data of arrears users after power failure and power failure.

The result write-back module 5 is specifically used to send the electricity quantity, the quantity fee result data generated by the electricity fee calculation, the verification result data from the daily quantity fee verification, the result data from the balance comparison, the arrears alarm data and the power outage alarm data through the interface. Write back to the marketing management system for the marketing management system to query. At the same time, it provides a daily test information interface for cost control users, which is used for querying cost control meter reading information, cost control daily electricity bill result information and other related information in various channels.

As a preferred example, the system further includes a balance comparison module, and the balance comparison module is configured to compare the electricity bill calculation result with the user balance information, and compare the lower threshold according to the arrears warning threshold and the power outage warning threshold. The data is marked, and the results are fed back to the marketing management information system after the comparison and marking are completed. The balance comparison module can set the alarm threshold. By loading the user account balance information in the marketing management system, the balance information is compared with the electricity bill result data generated by the calculation of the daily consumption fee for cost control, and the balance comparison result is generated. It can load the arrears alarm threshold configuration information and power outage alarm threshold configuration information in the marketing management system, and mark the data that meets the arrears alarm conditions and power outage alarm conditions in combination with the balance comparison result data.

As a preferred example, the system further includes a withholding management module, and the withholding management module is configured to trigger a single power supply to be used for the pre-collection of the deduction plan when the daily measurement and calculation of the fee control user reaches the corresponding withholding condition. Through the data analysis model, it can predict the amount withheld by the user according to the historical daily calculation results of the fee control user, and use it to set the deduction amount of the fee control user, and support the operation of initiating the bank withholding of the fee control user. Open up the deduction channel with banks, Alipay and WeChat. When the withholding is performed, the user's withholding information record is recorded. After the withholding is successful, the user's charge pre-storage information is recorded, and the bank withholding summary and details of the charge-controlled users at different time points of each power supply bureau are comprehensively displayed.

As a preferred example, the system further includes a report query module, which is used to query the current low-voltage charge control file generation and low-voltage new installation business handling, and count the number of remote charge-control users according to the power supply bureau and power supply station, respectively. Proportion and summary of the current month’s low-voltage new installation fee control; query the current low-voltage fee control file generation and low-voltage new installation business processing, respectively, according to the power supply bureau and power supply station. Fee control detailed information, and support excel to export; query fee control customer notification statistical report, fee control insurance power supply statistical report, fee control early warning statistical report, fee control abnormal statistical report, fee control power outage statistical report, fee control charging statistical report , comprehensively query meter reading information, cost control measurement information, query key information by user number, so that control business personnel can quickly query all information about related cost control households, and power outage notices generated by the calculation results of the day's volume and cost will be based on the province, locality The city conducts summary statistics and visualizes it.

The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the present invention. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present invention shall be included in the protection of the present invention. within the range.

Claims (7)

1. A high-speed electric charge calculation system, comprising:

the data integration module is used for extracting the charge control calculation charge related data, initializing the charge control calculation charge related data into the high-performance calculation distributed storage, and performing preprocessing operation;

the electric quantity calculation module is used for storing the synchronous surface code data in the marketing management information system in a distributed column storage format in a data processing platform and calculating the electric quantity through an electric quantity calculation algorithm;

the electric charge calculation module is used for calculating the electric charge corresponding to each metering point according to the electric quantity calculation result, wherein the electric charge comprises electric charge, fund and additional charge, basic electric charge and power factor adjustment electric charge;

the remote charge control management module is used for realizing measurement management and power failure and power restoration management in charge control service;

and the result write-back module is used for writing back the generated result data to the marketing management information system after the relevant calculation, the check and the comparison are completed.

2. The electric charge high-speed computing system according to claim 1, wherein the data integration module specifically comprises:

the file management submodule is used for realizing initialization, synchronization and opening of marketing files;

and the table code data management submodule is used for realizing integration, distribution, opening and exception check management of the table code data required by calculation.

3. The high-speed electric charge computing system according to claim 1, wherein the electric quantity computing module specifically comprises:

the calculation submodule is used for calculating various types of electric quantity data and integrating the electric quantity data into a historical calculation result as an independent field;

and the electric quantity integration sub-module is used for integrating all the electric quantities into a total electric quantity and eliminating redundant fields generated in the calculation process.

4. The electric charge high-speed calculation system according to claim 1, wherein the electric charge calculation module specifically comprises:

the electric charge calculation submodule is used for inputting the electric quantity calculation result into an electric charge calculation algorithm to calculate the electric charge corresponding to each metering point;

and the electric charge integration submodule is used for integrating all the electric charges to form the summarized electric charge.

5. The high-speed electric charge computing system according to claim 1, wherein the remote charge management module specifically comprises:

the key type management submodule is used for adding a mandatory field 'key type' in the related functions of electric energy meter filing, and sending a power failure and restoration control instruction for distinguishing new and old key types to the metering automation system when the marketing management information system performs power failure and restoration, so that the metering automation system points to and calls corresponding key system services according to the 'key type';

the charge control stop electronic module is used for judging whether the user meter type has a charge control character in the power failure process of a common user, if so, starting a remote brake-off function, otherwise, operating according to the common process;

the power restoration control submodule is used for realizing forced power restoration and setting a timing power restoration task;

and the abnormal data processing submodule is used for processing the manual abnormal data of the arrearage user after the power supply is stopped.

6. The high-speed electric charge computing system according to claim 1, further comprising a balance comparison module for comparing the electric charge computing result with balance information of the user, labeling data below a threshold value according to an arrearage warning threshold value and a power failure warning threshold value, and feeding back the result to the marketing management information system after the comparison and labeling are completed.

7. The high-speed electric charge computing system according to claim 1, further comprising a withholding management module for triggering the power supply unit to withhold the planned and pre-paid charges when the daily measurement of the charge control user reaches the withholding condition.

Images