CN109067775B - A communication data compression and decompression method, device and system - Google Patents

Abstract

The invention discloses a communication data compression and decompression method, device and system. The method comprises: receiving a configuration frame and a data frame; dividing the data frame into a set of data frames to determine whether it is the first frame data of this round of compression; The value of the SYNC field of the current frame is changed to the preset field, and the next frame of the current frame is taken as the current frame; if not, the variable segment ΔDATA_Frame is obtained by variable compression of the current frame; according to the compression count number Count_byte, it is judged whether the compressed data frame is not Reach the upper limit of compression; judge whether the compression time is greater than or equal to the preset time limit T; send the combination of DATA_Frame1, the compression count Count_byte and the variable segment ΔDATA_Frame as the compressed data to the WAMS system for receiving the data sent by the data sending device 's main site. By applying the embodiments of the present invention, the transmission efficiency of information can be improved.

Description

A communication data compression and decompression method, device and system

technical field

The present invention relates to a communication data compression and decompression method, and more particularly to a communication data compression and decompression method, device and system.

Background technique

Distribution network WAMS (Wide Area Measurement System, wide area monitoring system) is a wide area monitoring system applied to the distribution network, using synchrophasor measurement technology, by arranging the distribution line PDC (Phasor Data Concentrator, phasor data concentrator), arrange distribution line PMU (Phasor Measurement Unit, synchrophasor measurement unit) in each section of the distribution line to achieve real-time high-speed data on the synchrophasor of the distribution line and the main data of the distribution network. rate collection. The distribution network WAMS system includes PMU equipment for data collection, PDC equipment or NIC (Network Interface Controller, communication adapter) equipment for data compression and transmission; then PMU sends the collected data to PDC or NIC, PDC or NIC , compress the data collected by the PMU and send it to the WAMS master station in the distribution network WAMS system. Usually, the communication protocol adopted by the distribution network WAMS is: GBT 26865.2-2011 Power System Real-time Dynamic Monitoring System Part 2: Data Transmission Protocol. The communication system of the distribution network WAMS has the following characteristics: the structure of the communication network is complex, the number of communication terminal nodes is large, the communication distance is short, and the amount of communication data is large. In order to meet the requirements of the communication system in the construction of the distribution network WAMS, a variety of power system communication methods need to be used together.

However, since the PDC or NIC is connected to the PMU through optical fiber, the communication frequency can reach 100 frames per second. However, the transmission rate of the wireless network system in which the PDC or NIC sends data to the WAMS master station is lower than 100 frames per second. As a result, the amount of information contained in the data per unit capacity transmitted by the PDC or NIC is too small, which in turn leads to low information transmission efficiency.

SUMMARY OF THE INVENTION

The technical problem to be solved by the present invention is to provide a communication data compression and decompression method, device and system to improve the information transmission efficiency.

The present invention solves the above-mentioned technical problems through the following technical solutions:

In a first aspect, an embodiment of the present invention provides a communication data compression method, which is applied to a data sending device that sends data to a master station in a WAMS system of a distribution network, and the method includes:

A: Receive the configuration frame sent by the WAMS master station in the WAMS system, and receive the data frame sent by each PMU unit; divide the data frame into at least two data frame sets;

B: For each data frame set, the first data frame in the data frame set is used as the current data frame, and it is judged whether the current data frame is the first frame data of this round of compression;

C: If yes, change the numerical value of the SYNC field of the current data frame to a preset field, and set the value of the compression count number Count_byte to 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and judge Whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step F, if the compression time of this round of compression is less than the preset time limit T, Taking the next frame of the current data frame as the current data frame, and returning to execute the B step;

D: If not, take the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number; according to the phasor of the current data frame and the previous data frame of the current data frame Corresponding to the difference of the phasors, the variable segment ΔDATA_Frame is obtained by performing variable compression on the current data frame;

E: According to the compression count number Count_byte, determine whether the data frame compressed in this round of compression reaches the upper limit of compression; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step F; if the data frame compressed in this round of compression does not When the upper limit of compression is reached, determine whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step F, if the compression time of this round of compression is less than or equal to the preset time limit T Preset time limit T, take the next frame of the current data frame as the current data frame, and return to execute the step B;

F: When the current data frame is the first frame of this round of compression, and the compression time of this round of compression is greater than or equal to the preset time limit T, the combination of the DATA_Frame1 and the compression count number Count_byte is used as the compressed The data is sent to the master station in the WAMS system for receiving the data sent by the data sending device; except that the current data frame is the first frame of this round of compression, and the compression time of this round of compression is greater than or equal to the preset In cases other than the time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data sending device .

Optionally, the data sending device includes at least one of a PDC unit and a NIC unit.

Optionally, the step A includes:

Receive a data frame sent by each PMU unit and generate the line data collected by itself according to the configuration frame.

Optionally, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, perform variable compression on the current data frame to obtain a variable segment ΔDATA_Frame, including:

D1: Divide the number n of phasors contained in the current data frame by j to obtain a group of phasors, and the remainder b phasors, and b is less than j;

D2: Starting from the first group of phasors in the a group of phasors, take the first group of vectors as the current group vector, and for each phasor in the current group of phasors, compare the amplitude of the phasor with the The amplitude of the corresponding phasor of the previous data frame of the current data frame is compared to obtain the first amplitude variation; the angle of each phasor of the current data frame is compared with the previous data of the current data frame. Comparing the angles of each corresponding phasor of the frame to obtain a first angle change, and generating a first variable identifier according to the first amplitude change and the first angle change; changing the first amplitude The amount and the first angle change amount are combined into a first variable;

D3: store the first variable flag corresponding to the current group of phasors in the flag array flag; store the first variable in the variable array data; then use the next group of phasors of the current group of phasors as the current group phasors, and return to perform the D2 step until the a group of phasors are processed;

D4: For each phasor in the b phasors, compare the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a second amplitude variation ; Compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; According to the second amplitude change and the second angle The variation generates a second variable identification, and stores the second variable identification in the identification array flag; synthesizes the second amplitude variation and the second angle variation into a second variable; The variable is stored in the variable array data;

D5 composes the flag array flag and the variable array data into a variable segment ΔDATA_Frame.

Optionally, comparing the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a first amplitude change; The angle of each phasor is compared with the angle of each corresponding phasor in the previous data frame of the current data frame to obtain a first angle change. According to the first amplitude change and the first angle The delta generates a first variable identifier, including:

1), let k be the count, the initial value is 0, and judge whether k is less than j:

2) If yes, take the difference H1 between the amplitude r1 of each phasor of the current data frame and the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame as the first amplitude variation ; The difference H2 of the angle r2 of each phasor of the current data frame and the angle p2 of each corresponding phasor of the previous data frame of the current data frame is used as the first angle variation; And judge H1 and H2 Whether the absolute value is less than 8;

3) If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign [k] to 0x00; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, change the value of H2 The value of is updated to the sum of H2 and 8; H1 and H2 are stored in the cache array one;

4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128;

5) If the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, update the first variable sign [k] to 0x01; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 into the cache array two;

6) If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048;

7), if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign [k] to 0x02; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 into the cache array three;

8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, and then store r1, r2 in the cache array four;

9), update the value of k to k+1, and return to execute the step 1); until each vector in the current group of vectors is processed;

10) When the value of k is greater than or equal to j, execute the step D3.

Optionally, the first variable identifier corresponding to the current group of phasors is stored in the identifier array flag, including:

The first variable identifier corresponding to each phasor in the current group of phasors is stored in the temporary identifier array sign, and then the set of first variable identifiers corresponding to each phasor in the current group is stored in the identifier array flag.

Optionally, the preset step size is 1.

Optionally, the preset field is: 0xAA63.

The embodiment of the present invention also provides a communication data decompression method, which is applied to a master station in a WAMS system that receives data sent by a data sending device, and the method includes:

G: Receive the compressed data frame corresponding to the data frame set sent by the data sending device;

H: judge whether the SYNC field of the data frame is a preset field, if not, return to execute the G step; if so, execute the I step;

I: Put the L bytes of data after the compression count number Count_byte into the flag array flag in sequence, and put the data after L bytes into the variable array data;

J: Sequentially take out j identifiers from the identifier array flag and put them in the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the sign content, and according to the data corresponding to the variable array data The phasor of the previous data frame of the frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data;

K: Sequentially take out b identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the contents of the sign, and according to the data corresponding to the variable array data The phasor of the previous data frame of the frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data;

L: Generate other fields except phasors according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame.

Optionally, the method further includes:

Determine whether the obtained decompressed data frame has errors or missed sending, and if so, send a re-send command to the data sending device, so that the data sending device can retrieve the corresponding error or missed sending of the data frame.

An embodiment of the present invention also provides a communication data compression device, which is applied to a data sending device for sending data to a master station in a WAMS system of a power distribution network, and the device includes:

The first receiving module is used for receiving the configuration frame sent by the WAMS master station in the WAMS system, and receiving the data frame sent by each PMU unit; dividing the data frame into at least two data frame sets, wherein, in the configuration frame contains data a and b;

The first judgment module is used to, for each data frame set, take the first data frame in the data frame set as the current data frame, and judge whether the current data frame is the first frame data of this round of compression;

The first setting module is used to change the value of the SYNC field of the current data frame to a preset field when the judgment result of the first judgment module is yes, and set the value of the compression count number Count_byte as 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and judge whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T , trigger the second setting module, if the compression time of the current round of compression is less than the preset time limit T, take the next frame of the current data frame as the current data frame, and trigger the first judgment module;

a compression module, configured to use the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number when the judgment result of the first judgment module is no; according to the current The difference between the phasor of the data frame and the corresponding phasor of the previous data frame of the current data frame, the variable segment ΔDATA_Frame is obtained by performing variable compression on the current data frame;

The second judgment module is used for judging whether the data frame compressed in this round of compression reaches the upper limit of compression according to the compression count number Count_byte; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step F; The compressed data frame does not reach the upper limit of compression, and judge whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, trigger the second setting module, if this The compression time of round compression is less than the preset time limit T, and the next frame of the current data frame is used as the current data frame, and the first judgment module is triggered;

The second setting module is configured to set the DATA_Frame1, the compression count number Count_byte when the current data frame is the first frame of this round of compression, and the compression time of the current round of compression is greater than or equal to the preset time limit T The combination is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data transmission device; except that the current data frame is the first frame of this round of compression, and the compression time of this round of compression If it is greater than or equal to the preset time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent to the WAMS system as the compressed data for receiving the data sent by the sending device. data master.

Optionally, the data sending device includes at least one of a PDC unit and a NIC unit.

Optionally, the first receiving module is further configured to:

Receive a data frame sent by each PMU unit and generate the line data collected by itself according to the configuration frame.

Optionally, the compression module is further used for:

D1: Divide the number n of phasors contained in the current data frame by j to obtain a group of phasors, and the remainder b phasors, and b is less than j;

D2: Starting from the first group of phasors in the a group of phasors, take the first group of vectors as the current group vector, and for each phasor in the current group of phasors, compare the amplitude of the phasor with the The amplitude of the corresponding phasor of the previous data frame of the current data frame is compared to obtain the first amplitude variation; the angle of each phasor of the current data frame is compared with the previous data of the current data frame. Comparing the angles of each corresponding phasor of the frame to obtain a first angle change, and generating a first variable identifier according to the first amplitude change and the first angle change; changing the first amplitude The amount and the first angle change amount are combined into a first variable;

D3: store the first variable flag corresponding to the current group of phasors in the flag array flag; store the first variable in the variable array data; then use the next group of phasors of the current group of phasors as the current group phasors, and return to perform the D2 step until the a group of phasors are processed;

D4: For each phasor in the b phasors, compare the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a second amplitude variation ; Compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; According to the second amplitude change and the second angle The variation generates a second variable identification, and stores the second variable identification in the identification array flag; synthesizes the second amplitude variation and the second angle variation into a second variable; The variable is stored in the variable array data;

D5: Form the flag array flag and the variable array data into a variable segment ΔDATA_Frame.

Optionally, the compression module is also used to:

1), let k be the count, the initial value is 0, and judge whether k is less than j:

2) If yes, take the difference H1 between the amplitude r1 of each phasor of the current data frame and the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame as the first amplitude variation ; The difference H2 of the angle r2 of each phasor of the current data frame and the angle p2 of each corresponding phasor of the previous data frame of the current data frame is used as the first angle variation; And judge H1 and H2 Whether the absolute value is less than 8;

3) If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign [k] to 0x00; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, change the value of H2 The value of is updated to the sum of H2 and 8; H1 and H2 are stored in the cache array one;

4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128;

5) If the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, update the first variable sign [k] to 0x01; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 into the cache array two;

6) If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048;

7), if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign [k] to 0x02; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 into the cache array three;

8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, and then store r1, r2 in the cache array four;

9), update the value of k to k+1, and return to execute the step 1); until each vector in the current group of vectors is processed;

10) When the value of k is greater than or equal to j, execute the step D3.

Optionally, the compression module is also used to:

The first variable identifier corresponding to each phasor in the current group of phasors is stored in the temporary identifier array sign, and then the set of first variable identifiers corresponding to each phasor in the current group is stored in the identifier array flag.

Optionally, the preset step size is 1.

Optionally, the preset field is: 0xAA63.

An embodiment of the present invention also provides a communication data decompression device, which is applied to a master station in a WAMS system that receives data sent by a data sending device, and the device includes:

a second receiving module, configured to receive the compressed data frame corresponding to the data frame set sent by the data sending device;

a third judging module for judging whether the SYNC field of the data frame is a preset field, if not, triggering the second receiving module; if so, triggering a storage module;

The storage module is used to sequentially place the L bytes of data after the compression count number Count_byte into the flag array flag, and the data after the L bytes into the variable array data;

Sequentially take out j identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the content of sign, and according to the data frame corresponding to the variable array data The phasor of the previous data frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data;

The decompression module is used to sequentially take out b identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the content of the sign, and according to the variable array data The phasor of the previous data frame of the corresponding data frame restores the original phasor corresponding to the data read according to the sign content, and stores the original phasor in the array Full_data in sequence;

The combination module is used to generate other fields except phasors according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame.

Optionally, the device further includes: a fourth judgment module for:

Determine whether the obtained decompressed data frame has errors or missed sending, and if so, send a re-send command to the data sending device, so that the data sending device can retrieve the corresponding error or missed sending of the data frame.

The embodiment of the present invention also provides a communication data compression and decompression system, the system includes:

Based on the communication data compression device according to any one of the above, and based on the communication data decompression device according to any one of the above.

Compared with the prior art, the present invention has the following advantages:

Applying the embodiment of the present invention, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, variable compression is performed on the current data frame, and only the phasors in each round of compression are retained. The first frame of data frame, and then data compression is performed according to the difference between the phasors in the data frames after the first frame of data frame, and the storage space occupied by the difference between the phasors is smaller than that of the phasors, so The amount of data corresponding to the data frame is reduced, the amount of information contained in the data per unit capacity is increased, and the efficiency of information transmission is improved.

Description of drawings

1 is a schematic flowchart of a communication data compression method according to an embodiment of the present invention;

2 is a schematic structural diagram of a distribution network WAMS system provided by an embodiment of the present invention;

3 is a schematic diagram of data exchange of a WAMS system of a distribution network provided by an embodiment of the present invention;

FIG. 4 is a schematic diagram of the principle of a communication data compression method provided by an embodiment of the present invention;

5 is a schematic diagram of a generation principle of a variable identifier in a communication data compression method provided by an embodiment of the present invention;

6 is a schematic structural diagram of data compressed by a communication data compression method according to an embodiment of the present invention;

7 is a schematic flowchart of a method for decompressing communication data according to an embodiment of the present invention;

FIG. 8 is a schematic diagram of the principle of a communication data decompression method provided by an embodiment of the present invention;

FIG. 9 is a schematic structural diagram of a communication data compression apparatus provided by an embodiment of the present invention;

10 is a schematic structural diagram of a communication data decompression apparatus provided by an embodiment of the present invention;

FIG. 11 is a schematic structural diagram of a communication data compression and decompression system according to an embodiment of the present invention.

Detailed ways

The embodiments of the present invention are described in detail below. This embodiment is implemented on the premise of the technical solution of the present invention, and provides a detailed implementation manner and a specific operation process, but the protection scope of the present invention is not limited to the following implementation. example.

In order to solve the problems of the prior art, the embodiments of the present invention provide a communication data compression and decompression method, device and system.

In the first aspect, the following first introduces a communication data compression method provided by an embodiment of the present invention.

First of all, it should be noted that the communication data compression method provided by the embodiment of the present invention is preferably applicable to a data sending device that sends data to a master station in a WAMS system of a power distribution network, and the data sending device at least includes: a PDC unit and one of the NIC units.

FIG. 1 is a schematic flowchart of a communication data compression method according to an embodiment of the present invention. As shown in FIG. 1 , the method includes:

S101: Receive a configuration frame sent by a WAMS master station in a WAMS system, and receive a data frame sent by each PMU unit; divide the data frame into at least two data frame sets, wherein the configuration frame includes data a and b .

Specifically, a data frame sent by each PMU unit and generated from line data collected by itself according to the configuration frame can be received.

Exemplarily, FIG. 2 is a schematic structural diagram of a distribution network WAMS system provided by an embodiment of the present invention; FIG. 3 is a data exchange schematic diagram of a distribution network WAMS system provided by an embodiment of the present invention; FIG. 2-3 As shown, the PDC device obtains the data frame from the PMU device through the Ethernet, and then compresses the data frame, and sends the compressed data frame to the WAMS system master station through the dedicated VPN in the wireless network. In another application scenario, the NIC device obtains the data frame from the PMU device, then compresses the data frame, and sends the compressed data frame to the WAMS system master station through the dedicated VPN in the wireless network. The specific transmission steps of the data frame are shown in Figure 3. The PMU device sends a data frame DATA to the PDC device or NIC device every Jms, and the PDC device or NIC compresses the N data frames received in N*Jms every N*Jms. Then, it is sent to the main station of the WAMS system. Usually, the process of compressing the N data frames received within N*Jms by the PDC device or the NIC device is called a round of compression.

Exemplarily, the WAMS master station in the WAMS system will send a preset configuration frame to each data sending device, wherein the configuration frame includes the number a of phasors included in each phasor group in each data frame. , and the number b of ungrouped phasors in this data frame. For example, a data frame contains 18 phasors, the value of a is 4, that is, every four phasors are divided into one group, and then four groups of phasors are obtained. There are still two phasors remaining, which are the b phasors that are not grouped.

If three data frame sets are obtained in this step, the data frames contained in data frame set-1 are frame-1-1, frame-1-2, frame-1-3, frame-1-4, frame-1- 5. Frame-1-6; the data frames included in the data frame set-2 are frame-2-1, frame-2-2, frame-2-3, frame-2-4, frame-2-5, frame -2-6; The data frames contained in the data frame set-3 are frame-3-1, frame-3-2, frame-3-3, frame-3-4, frame-3-5, frame-3- 6.

S102: For each data frame set, use the first data frame in the data frame set as the current data frame, and determine whether the current data frame is the first frame data of this round of compression; if so, perform step S103; if not , and execute step S104;

It can be seen from step S101 that the PDC device or the NIC compresses the N data frames received in N*Jms every N*Jms and sends them to the WAMS system master station. Therefore, it is necessary to judge the current frame received by the PDC device or the NIC device. -1-1, whether it is the first frame of data compressed in this round, if it is the first frame of data, start this round of compression, and execute step S103; if it is not the first frame of data compressed in this round, execute step S104.

S103: Change the value of the SYNC field of the current data frame to a preset field, and set the value of the compression count number Count_byte to 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and determine the current round Whether the compression time of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step S106, if the compression time of this round of compression is less than the preset time limit T, all The next frame of the current data frame is regarded as the current data frame, and the step S102 is returned to be executed.

Specifically, the preset field may be: 0xAA63.

Exemplarily, the compression for data frame set-1 is taken as the first round of compression. In the existing WAMS system, the field value of the data frame is implemented in accordance with the provisions of GBT26865.2-2011, and the value of the SYNC field of the data frame is 0xAA03. In the embodiment of the present invention, the first frame of data frame of each round of compressed communication is SYNC is changed to 0xAA63 to distinguish it; at the same time, the value of the compression count number Count_byte of this round of compression is set to 0, and then the content of the current frame, frame-1-1, is stored in the DATA_Frame1 segment at the head of the cache array TEMP. Then, the duration of the unit price of data compression from the moment when the data frame set-1 is received to the current moment is taken as the compression time of this round of compression, and then it is judged whether the compression time of this round of compression is greater than or equal to the preset time limit T If the compression time-consuming of this round of compression is greater than or equal to the preset time limit T, step S106 is executed, if the compression time-consuming of this round of compression is less than the preset time limit T, the next frame of the current data frame described in 0, frame- 1-2, as the current data frame, and return to execute the step S102.

It should be noted that the SYNC field may also be referred to as a synchronization field.

S104: Use the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number; according to the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame The difference is that the variable segment ΔDATA_Frame is obtained by performing variable compression on the current data frame;

Specifically, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, performing variable compression on the current data frame to obtain a variable segment ΔDATA_Frame may include: D1: compressing the current data frame The number of phasors contained in the frame is divided by j to obtain a group of phasors, and the remainder b phasors, and b is less than j; D2: Starting from the first group of phasors in the a group of phasors, for the current group of phasors For each phasor in the quantity, compare the magnitude of the phasor with the magnitude of the corresponding phasor of the previous data frame of the current data frame to obtain a first magnitude change; The angle of each phasor of the frame is compared with the angle of each corresponding phasor of the previous data frame of the current data frame to obtain the first angle change; D3: the first angle corresponding to the current group of phasors is compared. The variable identification is stored in the identification array flag; the first variable is stored in the variable array data; then the next group of phasors of the current group of phasors are used as the current group of phasors, and return to execute the D2 step, until a All groups of phasors are processed; D4: for each of the b phasors, compare the magnitude of the phasor with the magnitude of the corresponding phasor of the previous data frame of the current data frame, Obtain a second amplitude change; compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; change according to the second amplitude The amount and the second angle change amount generate a second variable identification, and the second variable identification is stored in the identification array flag; the second amplitude change amount and the second angle change amount are synthesized into a second variable; store the second variable in the variable array data; D5 forms the variable segment ΔDATA_Frame with the flag array flag and the variable array data.

Specifically, comparing the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a first amplitude change; The angle of a phasor is compared with the angle of each corresponding phasor in the previous data frame of the current data frame to obtain a first angle change, according to the first amplitude change and the first angle change Quantity generates the first variable identification, which can include: 1), set k as a count, the initial value is 0, and determine whether k is less than j: 2), if so, compare the amplitude r1 of each phasor of the current data frame with the described The difference H1 of the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame is taken as the first amplitude variation; the angle r2 of each phasor of the current data frame and the The difference H2 of the angle p2 of each corresponding phasor of a data frame is used as the first angle change; and it is judged whether the absolute values of H1 and H2 are both less than 8; 3), if the absolute values of H1 and H2 are both less than 8, Allocate 0.5 bytes of storage space for H1 and H2, update the first variable sign sign[k] to 0x00; determine whether the value of H1 is negative, if the value of H1 is negative, update the value of H1 to H1 and 8 sum, and judge whether the value of H2 is negative; if the value of H1 is positive, judge whether the value of H2 is negative, if the value of H2 is negative, update the value of H2 to the sum of H2 and 8; change the value of H1 and H2 Store it in the cache array one; 4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128; 5) If the absolute values of H1 and H2 are both less than 128, it is H1 and H2 each allocate 1 byte of storage space, update the first variable sign sign[k] to 0x01; judge whether the value of H1 is negative, if the value of H1 is negative, update the value of H1 to the sum of H1 and 128 , and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative, update the value of H2 to the sum of H2 and 128; H1 and H2 are stored in the cache array two; 6), if the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048; 7), if the absolute values of H1 and H2 are both less than 2048 , allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign sign[k] to 0x02; judge whether the value of H1 is negative, if the value of H1 is negative, update the value of H1 to H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative, update the value of H2 to the value between H2 and 2048 and; store H1 and H2 in the cache array three; 8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] = 0x03, and then store r1, r2 in the cache array four; 9), update the value of k to k+1, and Return to execute the step 1); until each vector in the current group of vectors is processed; 10), when the value of k is greater than or equal to j, execute the D3 step.

Specifically, storing the first variable identifier corresponding to the current group of phasors in the flag array flag may include: storing the first variable identifier corresponding to each phasor in the current group of phasors in a temporary identifier In the array sign, the set of first variable identifiers corresponding to each phasor of the current group is then stored in the identifier array flag.

FIG. 4 is a schematic diagram of the principle of a communication data compression method provided by an embodiment of the present invention. As shown in FIG. 4 , if the number of phasors included in the current data frame is 18, and a is 4 and b is 2, then The 18 phasors contained in the current data frame are divided into 4 groups in order. Let i be the number of counts, representing how many groups of phasors have been processed. For example, when i=0, start to perform variable compression on the four phasors in the first group of phasors, and then compress each group of phasors. , let j be the number of counts, and j represents how many phasors in the current group of phasors have been processed.

Each phasor in the first group is numbered phasor-1-1, phasor-1-2, phasor-1-3, phasor-1-4; similarly, each phasor in the second group The numbers of the phasors are phasor-2-1, phasor-2-2, phasor-2-3, phasor-2-4; the numbers of each phasor in the third group are phasor-3-1, phasor-2-4 Quantity-3-2, phasor-3-3, phasor-3-4; the number of each phasor in the fourth group is phasor-4-1, phasor-4-2, phasor-4- 3. Phasor-4-4; the remaining two phasors can be phasor-b-1 and phasor-b-2.

First, perform variable compression on the first phasor in the first group of phasors, and compare the amplitude of phasor-1-1 with the amplitude of the corresponding position of frame-1-1. For example, the difference can be calculated to obtain the frame. The difference in magnitude between the phasor -1-1 in the first set of phasors of -1-2, and the phasor -1-1 in the first set of phasors of frame -1-1, the difference As the first amplitude change; then, compare the angle of the phasor-1-1 with the angle of the corresponding position of the frame-1-1, for example, the first group of phasors of the frame-1-2 can be obtained by calculating the difference The angle difference between the phasor-1-1 in the frame-1-1 and the phasor-1-1 in the first group of phasors of the frame-1-1 is taken as the first angle change amount.

Then, the vector-1-1 in the first set of vectors of the data frame-1-2 is used as the current phasor, and the first variable identifier is generated according to the first angle change and the first amplitude change of the current phasor.

5 is a schematic diagram of the generation principle of a variable identifier in a communication data compression method provided by an embodiment of the present invention, as shown in FIG. First, judge whether k is less than 4. If it is not less than 4, it means that the process of generating the first variable identification for each vector of the first group has ended, and it is necessary to combine the first variable identification of each phasor in the first group. to be stored. When the value of k is greater than or equal to j, a first variable identifier is generated according to the first amplitude variation and the first angle variation, and the first variable identifier is stored in the identifier array flag; the first amplitude variation is and the first angle change amount is combined into a first variable; the first variable is stored in the variable array data; the flag array flag and the variable array data are formed into a variable segment ΔDATA_Frame.

When k is less than 4, it indicates that the first variable identifier of the phasor in the first group needs to be generated. For example, compare the magnitude r1 of the phasor-1-1 of the data frame-1-2 with the corresponding phasor of the data frame-1-1 of the data frame-1-2, the magnitude of the phasor-1-1 The difference H1 of p1 is used as the magnitude change; the angle r2 of the phasor-1-1 of the data frame-1-2 and the corresponding phasor of the data frame-1-1 of the data frame-1-2 are compared with each other. The difference H2 of the angle p2 of the quantity -1-1 is used as the angle change amount; and it is judged whether the absolute values of H1 and H2 are both less than 8.

If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign sign[k] to 0x00; judge whether the value of H1 is negative, if the value of H1 is Negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, update the value of H2 is the sum of H2 and 8; store H1 and H2 into the cache array one.

If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128; if the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, and update The first variable identifier sign[k] is 0x01; determine whether the value of H1 is negative, if the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and determine whether the value of H2 is negative; if the value of H1 is negative If the value is positive, execute the step of judging whether the value of H2 is negative. If the value of H2 is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 in the cache array two.

If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048; if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for each of H1 and H2, and update The first variable identifier sign[k] is 0x02; determine whether the value of H1 is negative, if the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and determine whether the value of H2 is negative; if the value of H1 is negative If the value is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 in the cache array three.

If the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, then store r1 and r2 in the cache array four; update the value of k to k+1, and the data frame The vector -1-2 in the first set of vectors of -1-2 is used as the current phasor, and then the first identifier corresponding to the current phasor is generated. At the same time, store the data in the cache array one of the vector-1-1, or the cache array two, or the cache array three in sequence into the variable array data; store sign[k] into the flag array flag. For the current data frame, each vector in the first group of vectors in the data frame-1-2 is subjected to the above processing, and further, the above processing is performed on each group of vectors in the data frame-1-2, and then the a group is processed. Phasor. The finally obtained identification array flag is sequentially stored, the first variable identification of the four vectors in the first group of phasors of the data frame-1-2, the first variable identification of the four vectors in the second group of phasors, the first variable identification of the four vectors in the second group of phasors The first variable identifiers of the four vectors in the three groups of phasors and the first variable identifiers of the four vectors in the fourth group of phasors. The storage order of the variables in the variable data data is the same as the storage order of the first variable identifier in the identifier array flag, which is not repeated here.

After processing a group of vectors, the remaining 2 vectors need to be processed, and the process of generating the second variable identifier in the processing process is the same as the process of generating the first variable identifier in the a group vector; The process of is the same as the process of generating the first variable in the a group of vectors, and will not be repeated here.

Then, the variable array data corresponding to the data frame-1-2 and the flag array flag are combined into a variable segment ΔDATA_Frame2 of the data frame-1-2.

It should be noted that when storing the first variable identifier, taking the cache array one as an example, in the actual storage process, there is no half-byte content. In order to save space, the data of the cache array one needs to be compared with other The data are spliced together to fill one byte. Therefore, in this embodiment of the present invention, there needs to be 0.5 bytes of data in the byte cache array one. Similarly, the cache array three is allocated three bytes for Stores 1.5 bytes of data in the cache array, and its corresponding storage space is three[0], three[1], three[2].

S105: Determine whether the data frame compressed in this round of compression reaches the upper limit of compression according to the compression count number Count_byte; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step S106; if the data frame compressed in this round of compression does not reach the upper limit of compression Reaching the upper limit of compression, determine whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step S106, if the compression time of this round of compression is less than or equal to the preset time limit T Preset time limit T, take the next frame of the current data frame as the current data frame, and return to execute the step S102.

Exemplarily, after the variable compression is performed on the data frame-1-2, it is determined whether the number of data frames compressed during the compression of the data frame set-1 has reached the upper limit of the number of data frames that can be compressed, If the upper limit is reached, the compression process is stopped, and then step S106 is performed.

If the upper limit is not reached, it is determined whether the compression time corresponding to the compression of the data frame set-1 has reached the preset time limit T, and if the preset time limit T is reached, step S106 is performed; if the preset time limit T is not reached, the data The next data frame of the data frame-1-2 in the frame set-1, the data frame-1-30 is regarded as the current frame, and then returns to step S102 until all the data frames in the data frame set are compressed.

S106: When the current data frame is the first frame of this round of compression, and the compression time of the current round of compression is greater than or equal to the preset time limit T, use the combination of the DATA_Frame1 and the compression count number Count_byte as the compressed The data is sent to the master station in the WAMS system for receiving the data sent by the data sending device; except that the current data frame is the first frame of this round of compression, and the compression time of this round of compression is greater than or equal to the preset In cases other than the time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data sending device .

FIG. 6 is a schematic structural diagram of data compressed by a communication data compression method according to an embodiment of the present invention; as shown in FIG. 6 , for the current round of compression, DATA_Frame1 is used to store the first frame data of the current round of compression, i.e. dataframe-1-1;

Compression count number Count_byte, used to store the number of data frames included in each round of compression; ΔDATA_Frame2, used to store the compressed data of data frame-1-2 in the current round of compression, that is, the corresponding first variable and the first variable identifier; and so on.

It should be noted that, taking ΔDATA_Frame2 as an example, when combining variable segments of data frame-1-2, the first variable identification array flag of data frame-1-2 can be stored in the first half of ΔDATA_Frame2, and then each The first variable of a phasor: PHASORS1, PHASORS2, PHASORS3, and so on.

Applying the embodiment shown in FIG. 1 of the present invention, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, variable compression is performed on the current data frame, and only each The first frame of data frame in round compression, and then data compression is performed according to the difference between the phasors in the data frames after the first frame of data frame, and the storage space occupied by the difference between the phasors is smaller than the storage space occupied by the phasors space, increase the amount of information contained in the data per unit capacity, and improve the efficiency of information transmission

In addition, by applying the embodiment shown in FIG. 1 of the present invention, data can also be sent out in time to avoid data backlog.

In the second aspect, corresponding to the embodiment shown in FIG. 1 of the present invention, the embodiment of the present invention further provides a communication data decompression method.

It should be noted that the communication data decompression method provided by the embodiment of the present invention is preferably applied to a master station in a WAMS system that receives data sent by a data sending device.

7 is a schematic flowchart of a communication data decompression method provided by an embodiment of the present invention, and FIG. 8 is a schematic schematic diagram of a principle of a communication data decompression method provided by an embodiment of the present invention; as shown in FIGS. 7 and 8 , the method include:

S701: Receive a compressed data frame corresponding to the data frame set sent by the data sending device.

Exemplarily, the received compressed data is shown in FIG. 6 .

S702: Determine whether the SYNC field of the data frame is a preset field, and if not, return to performing the step S701; if so, perform the step S703.

Determine whether the SYNC field of the received data is 0xAA63, and if so, it indicates that the received data is data compressed according to the method described in the embodiment of the present invention, and executes step S703; if not, it indicates that the received data is not according to the embodiment of the present invention. The method described above performs the compressed data, jumps out of the loop, and receives the next round of data.

S703: Put the data of L bytes after the compression count number Count_byte into the flag array flag in sequence, and put the data after the L bytes into the variable array data;

Exemplarily, data of L bytes after the Count_byte of the received data frame is stored as a variable flag in the flag array flag. The subsequent data of the data frame is stored in the variable array data as variable data.

It can be understood that the size of L is preset by the system, and its value can be a+1.

S704: sequentially take out j identifiers from the identifier array flag and put them in the array sign, then sequentially read the data of the corresponding length in the variable array data according to the content of sign, and according to the data corresponding to the variable array data From the phasor of the previous data frame of the frame, the original phasor corresponding to the data read according to the sign content is restored, and the original phasor is sequentially stored in the array Full_data.

Exemplarily, 4 identifiers are sequentially taken from the identifier array flag and put into the array sign, and then the data of the corresponding length in the variable array data is sequentially read.

According to the phasor of the previous data frame of the data frame corresponding to the variable array data, the original phasor corresponding to the data read according to the content of sign is restored, and the original phasor is sequentially stored in the array Full_data. It can be understood that the process of restoring the original phasor and the variable compression process in step S104 in the embodiment of the present invention are dual processes, which are not repeated in the embodiment of the present invention.

S705: Sequentially take out b identifiers from the identifier array flag and put them in the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the contents of sign, and according to the data corresponding to the variable array data From the phasor of the previous data frame of the frame, the original phasor corresponding to the data read according to the sign content is restored, and the original phasor is sequentially stored in the array Full_data.

Exemplarily, sequentially take out 2 signs from the sign array flag and put them in the array sign, then read the data of the corresponding length in the variable array data sequentially according to the sign content, and according to the corresponding length of the variable array data The phasor of the previous data frame of the data frame, restore the original phasor corresponding to the data read according to the content of sign, and store the original phasor into the array Full_data in sequence, that is, store the original phasor restored in the step S704 The back of the phasor. In addition, it can be understood that the sizes of a and b are both data included in the configuration frame sent by the master station in the WAMS system to the data sending device.

S706: Generate other fields except the phasor according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame.

It should be emphasized that the process corresponding to this step is in the prior art, which is not repeated in this embodiment of the present invention.

By applying the embodiment shown in FIG. 7 of the present invention, the compressed data can be decompressed.

In a specific implementation of the embodiment of the present invention, the method further includes:

S707 (not shown in the figure): determine whether the obtained decompressed data frame has errors or is missing, and if so, send a reissue command to the data sending device, so that the data sending device calls the corresponding error or Missing data frame.

Exemplarily, the WAMS master station determines whether there is an error in the decompressed data frame, for example, it can determine whether the value corresponding to the data frame is obviously beyond a reasonable range, or there are obviously undetected data items, or data between data items. Reversal occurred, etc.; or according to the preset identification information of the data frame, determine whether the data of the received data frame matches the preset identification information, if so, it means that the data frame has been missed, and then send the data to the data frame. When the device sends a reissue command, for example, it can send a reissue instruction to the corresponding data sending device according to the identification information of the data frame that has an error or missed sending.

By applying the above embodiments of the present invention, data errors caused by data errors or missing transmissions can be avoided.

In the third aspect, corresponding to the first aspect of the embodiment of the present invention, the embodiment of the present invention further provides a communication data compression device, which is applied to a data sending device for sending data to a master station in a WAMS system of a power distribution network.

FIG. 9 is a schematic structural diagram of a communication data compression apparatus according to an embodiment of the present invention. As shown in FIG. 9 , the apparatus includes:

The first receiving module 901 is used for receiving the configuration frame sent by the WAMS master station in the WAMS system, and receiving the data frame sent by each PMU unit; dividing the data frame into at least two data frame sets;

The first judgment module 902 is used to, for each data frame set, use the first data frame in the data frame set as the current data frame, and judge whether the current data frame is the first frame data of this round of compression;

The first setting module 903 is used to change the value of the SYNC field of the current data frame to a preset field when the judgment result of the first judgment module 902 is yes, and change the value of the compression count number Count_byte Set to 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and determine whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit Time limit T, the second setting module 905 is triggered, if the compression time of the current round of compression is less than the preset time limit T, the next frame of the current data frame is taken as the current data frame, and the first judgment module 902 is triggered;

The compression module 904 is configured to use the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number when the judgment result of the first judgment module 902 is no; The difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, and performing variable compression on the current data frame to obtain a variable segment ΔDATA_Frame;

The second judgment module 905 is configured to judge whether the data frame compressed in this round of compression reaches the upper limit of compression according to the compression count number Count_byte; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step F; The compressed data frame does not reach the upper limit of compression, and judge whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, trigger the second setting module, if The compression time of this round of compression is less than the preset time limit T, and the next frame of the current data frame is regarded as the current data frame, and the first judgment module 902 is triggered;

The second setting module 906 is configured to set the DATA_Frame1, the compression count number when the current data frame is the first frame of this round of compression and the compression time of the current round of compression is greater than or equal to the preset time limit T The combination of Count_byte is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data sending device; except that the current data frame is the first frame of this round of compression, and the compression consumption of this round of compression is When the time is greater than or equal to the preset time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent as compressed data to the WAMS system for receiving data. The master of the sent data.

Applying the embodiment shown in FIG. 9 of the present invention, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, variable compression is performed on the current data frame, and only each The first frame of data frame in round compression, and then data compression is performed according to the difference between the phasors in the data frames after the first frame of data frame, and the storage space occupied by the difference between the phasors is smaller than the storage space occupied by the phasors space, increase the amount of information contained in the data per unit capacity, and improve the efficiency of information transmission.

In a specific implementation manner of the embodiment of the present invention, the data sending device includes at least one of a PDC unit and a NIC unit.

In a specific implementation manner of the embodiment of the present invention, the first receiving module 901 is further configured to:

Receive a data frame sent by each PMU unit and generate the line data collected by itself according to the configuration frame.

In a specific implementation manner of the embodiment of the present invention, the compression module 904 is further configured to:

D1: Divide the number n of phasors contained in the current data frame by j to obtain a group of phasors, and the remainder b phasors, and b is less than j;

D2: Starting from the first group of phasors in the a group of phasors, take the first group of vectors as the current group vector, and for each phasor in the current group of phasors, compare the amplitude of the phasor with the The amplitude of the corresponding phasor of the previous data frame of the current data frame is compared to obtain the first amplitude variation; the angle of each phasor of the current data frame is compared with the previous data of the current data frame. The angles of each corresponding phasor of the frame are compared to obtain the first angle change;

D3: store the first variable flag corresponding to the current group of phasors in the flag array flag; store the first variable in the variable array data; then use the next group of phasors of the current group of phasors as the current group phasors, and return to perform the D2 step until the a group of phasors are processed;

D4: For each phasor in the b phasors, compare the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a second amplitude variation ; Compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; According to the second amplitude change and the second angle The variation generates a second variable identification, and stores the second variable identification in the identification array flag; synthesizes the second amplitude variation and the second angle variation into a second variable; The variable is stored in the variable array data;

D5 composes the flag array flag and the variable array data into a variable segment ΔDATA_Frame.

In a specific implementation manner of the embodiment of the present invention, the compression module 904 is further configured to:

1), let k be the count, the initial value is 0, and judge whether k is less than j:

2) If yes, take the difference H1 between the amplitude r1 of each phasor of the current data frame and the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame as the first amplitude variation ; The difference H2 of the angle r2 of each phasor of the current data frame and the angle p2 of each corresponding phasor of the previous data frame of the current data frame is used as the first angle variation; And judge H1 and H2 Whether the absolute value is less than 8;

3) If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign [k] to 0x00; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, change the value of H2 The value of is updated to the sum of H2 and 8; H1 and H2 are stored in the cache array one;

4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128;

5) If the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, update the first variable sign [k] to 0x01; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 into the cache array two;

6) If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048;

7), if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign [k] to 0x02; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 into the cache array three;

8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, and then store r1, r2 in the cache array four;

9), update the value of k to k+1, and return to execute the step 1); until each vector in the current group of vectors is processed;

10) When the value of k is greater than or equal to j, execute the step D3.

In a specific implementation manner of the embodiment of the present invention, the compression module 904 is further configured to:

The first variable identifier corresponding to each phasor in the current group of phasors is stored in the temporary identifier array sign, and then the set of first variable identifiers corresponding to each phasor in the current group is stored in the identifier array flag.

In a specific implementation manner of the embodiment of the present invention, the preset step size is 1.

In a specific implementation manner of the embodiment of the present invention, the preset field is: 0xAA63.

In the fourth aspect, corresponding to the second aspect of the embodiment of the present invention, the embodiment of the present invention further provides a communication data decompression device.

It should be noted that the apparatus for decompressing communication data provided by the embodiment of the present invention is preferably applicable to a master station in a WAMS system that receives data sent by a data sending device.

FIG. 10 is a schematic structural diagram of an apparatus for decompressing communication data according to an embodiment of the present invention. As shown in FIG. 10 , the apparatus includes:

A second receiving module 1001, configured to receive the compressed data frame corresponding to the data frame set sent by the data sending device;

The third judging module 1002 is used to judge whether the SYNC field of the data frame is a preset field, if not, trigger the second receiving module 1001; if so, trigger the storage module 1003;

The storage module 1003 is used to sequentially place the data of L bytes after the compression count number Count_byte into the flag array flag, and place the data after the L bytes into the variable array data;

Sequentially take out j identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the content of sign, and according to the data frame corresponding to the variable array data The phasor of the previous data frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data;

The decompression module 1004 is used to sequentially take out b identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the sign content, and according to the variable array The phasor of the previous data frame of the data frame corresponding to data restores the original phasor corresponding to the data read according to the sign content, and stores the original phasor in the array Full_data in sequence;

The combination module 1005 is configured to generate other fields except the phasors according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame.

By applying the embodiment shown in FIG. 10 of the present invention, the compressed data can be decompressed.

In a specific implementation of the embodiment of the present invention, on the basis of the embodiment shown in FIG. 10 of the present invention, the embodiment of the present invention further adds: a fourth judgment module 1006 (not shown in the figure), which is used for:

Determine whether the obtained decompressed data frame has errors or missed sending, and if so, send a re-send command to the data sending device, so that the data sending device can retrieve the corresponding error or missed sending of the data frame.

In a specific implementation of the embodiment of the present invention, the system includes:

Based on the communication data compression apparatus provided by the third aspect of the embodiments of the present invention, and the communication data decompression apparatus provided by the fourth aspect of the present invention.

By applying the above embodiments of the present invention, data errors caused by data errors or missing transmissions can be avoided.

In a fifth aspect, in order to solve the problem of the prior art, the embodiment of the present invention further provides a communication data compression and decompression system.

FIG. 11 is a schematic structural diagram of a communication data compression and decompression system according to an embodiment of the present invention. , as shown in Figure 11, the system includes:

Based on the communication data compression apparatus 1101 described in the third aspect of the embodiment of the present invention, and based on the communication data decompression apparatus 1102 described in the fourth aspect of the embodiment of the present invention.

By applying the embodiment shown in FIG. 11 of the present invention, the communication data can be compressed and decompressed.

In the sixth aspect, in order to solve the problem of the prior art, corresponding to the communication data compression and decompression system provided in the fifth aspect of the embodiment of the present invention, the embodiment of the present invention further provides a communication method, which is applied to the WAMS system. include:

Apply the data compression method described in the first aspect of the embodiment of the present invention to perform data compression and send the compressed data; receive the compressed data, and apply the data decompression method described in the second aspect of the embodiment of the present invention to decompress the data. unzip.

By applying the above embodiments of the present invention, data compression and decompression can be realized.

It is understood that compression and decompression together constitute the entire communication process.

The above descriptions are only preferred embodiments of the present invention and are not intended to limit the present invention. Any modifications, equivalent replacements and improvements made within the spirit and principles of the present invention shall be included in the protection of the present invention. within the range.

Claims (21)

1. a communication data compression method, is characterized in that, is applied to the data transmission equipment that sends data to master station in distribution network WAMS system, described method comprises: A: Receive the configuration frame sent by the WAMS master station in the WAMS system, and receive the data frame sent by each PMU unit; divide the data frame into at least two data frame sets; B: For each data frame set, the first data frame in the data frame set is used as the current data frame, and it is judged whether the current data frame is the first frame data of this round of compression; C: If yes, change the numerical value of the SYNC field of the current data frame to a preset field, and set the value of the compression count number Count_byte to 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and judge Whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step F, if the compression time of this round of compression is less than the preset time limit T, Taking the next frame of the current data frame as the current data frame, and returning the first frame data of the current round of compression according to the judgment described in step B; D: If not, take the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number; according to the phasor of the current data frame and the previous data frame of the current data frame Corresponding to the difference of the phasors, the variable segment ΔDATA_Frame is obtained by performing variable compression on the current data frame; E: According to the compression count number Count_byte, determine whether the data frame compressed in this round of compression reaches the upper limit of compression; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step F; if the data frame compressed in this round of compression does not When the upper limit of compression is reached, determine whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, perform step F, if the compression time of this round of compression is less than or equal to the preset time limit T Preset time limit T, take the next frame of the current data frame as the current data frame, and return to execute step B to determine whether the current data frame is the first frame data of this round of compression; F: When the current data frame is the first frame of this round of compression, and the compression time of this round of compression is greater than or equal to the preset time limit T, the combination of the DATA_Frame1 and the compression count number Count_byte is used as the compressed The data is sent to the master station in the WAMS system for receiving the data sent by the data sending device; except that the current data frame is the first frame of this round of compression, and the compression time of this round of compression is greater than or equal to the preset In cases other than the time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data sending device . 2 . The method for compressing communication data according to claim 1 , wherein the data sending device comprises at least one of a PDC unit and a NIC unit. 3 . 3. a kind of communication data compression method according to claim 1, is characterized in that, described step A, comprises: Receive a data frame sent by each PMU unit and generate the line data collected by itself according to the configuration frame. 4. A communication data compression method according to claim 1, wherein, according to the difference between the phasor of the current data frame and the corresponding phasor of the previous data frame of the current data frame, the Perform variable compression on the current data frame to obtain a variable segment ΔDATA_Frame, including: D1: Divide the number n of phasors contained in the current data frame by j to obtain a group of phasors, and the remainder b phasors, and b is less than j; D2: Starting from the first group of phasors in the a group of phasors, take the first group of vectors as the current group vector, and for each phasor in the current group of phasors, compare the amplitude of the phasor with the The amplitude of the corresponding phasor of the previous data frame of the current data frame is compared to obtain the first amplitude variation; the angle of each phasor of the current data frame is compared with the previous data of the current data frame. Comparing the angles of each corresponding phasor of the frame to obtain a first angle change, and generating a first variable identifier according to the first amplitude change and the first angle change; changing the first amplitude The amount and the first angle change amount are combined into a first variable; D3: store the first variable flag corresponding to the current group of phasors in the flag array flag; store the first variable in the variable array data; then use the next group of phasors of the current group of phasors as the current group phasors, and return to perform the D2 step until the a group of phasors are processed; D4: For each phasor in the b phasors, compare the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a second amplitude variation ; Compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; According to the second amplitude change and the second angle The variation generates a second variable identification, and stores the second variable identification in the identification array flag; synthesizes the second amplitude variation and the second angle variation into a second variable; The variable is stored in the variable array data; D5: Form the flag array flag and the variable array data into a variable segment ΔDATA_Frame. 5. A communication data compression method according to claim 4, characterized in that the amplitude of the phasor is compared with the amplitude of the corresponding phasor of the previous data frame of the current data frame , obtain the first amplitude change; compare the angle of each phasor of the current data frame with the angle of each corresponding phasor of the previous data frame of the current data frame to obtain the first angle change , generating a first variable identifier according to the first amplitude change and the first angle change, including: 1), let k be the count, the initial value is 0, and judge whether k is less than j: 2) If yes, take the difference H1 between the amplitude r1 of each phasor of the current data frame and the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame as the first amplitude variation ; The difference H2 of the angle r2 of each phasor of the current data frame and the angle p2 of each corresponding phasor of the previous data frame of the current data frame is used as the first angle variation; And judge H1 and H2 Whether the absolute value is less than 8; 3) If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign [k] to 0x00; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, change the value of H2 The value of is updated to the sum of H2 and 8; H1 and H2 are stored in the cache array one; 4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128; 5) If the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, update the first variable sign [k] to 0x01; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 into the cache array two; 6) If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048; 7), if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign [k] to 0x02; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 into the cache array three; 8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, and then store r1, r2 in the cache array four; 9), update the value of k to k+1, and return to execute the step 1); until each vector in the current group of vectors is processed; 10) When the value of k is greater than or equal to j, execute the step D3. 6. a kind of communication data compression method according to claim 4, is characterized in that, described first variable identification corresponding to described current group phasor is stored in identification array flag, comprising: The first variable identifier corresponding to each phasor in the current group of phasors is stored in the temporary identifier array sign, and then the set of first variable identifiers corresponding to each phasor in the current group is stored in the identifier array flag. 7 . The method for compressing communication data according to claim 1 , wherein the preset step size is 1. 8 . 8. A communication data compression method according to claim 1, wherein the preset field is: 0xAA63. 9. A communication data decompression method, characterized in that it is applied to a master station that receives data sent by a data sending device in a WAMS system, the method comprising: G: Receive the compressed data frame corresponding to the data frame set sent by the data sending device; H: judge whether the SYNC field of the data frame is a preset field, if not, return to execute the G step; if so, execute the I step; I: Put the L bytes of data after the compression count number Count_byte into the flag array flag in sequence, and put the data after L bytes into the variable array data; J: Sequentially take out j identifiers from the identifier array flag and put them in the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the sign content, and according to the data corresponding to the variable array data The phasor of the previous data frame of the frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data; K: Sequentially take out b identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the contents of the sign, and according to the data corresponding to the variable array data The phasor of the previous data frame of the frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data; L: Generate other fields except phasors according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame. 10. A communication data decompression method according to claim 9, wherein the method further comprises: Determine whether the obtained decompressed data frame has errors or missed sending, and if so, send a re-send command to the data sending device, so that the data sending device can retrieve the corresponding error or missed sending of the data frame. 11. A communication data compression device, characterized in that it is applied to a data sending device for sending data to a master station in a power distribution network WAMS system, the device comprising: The first receiving module is used for receiving the configuration frame sent by the WAMS master station in the WAMS system, and receiving the data frame sent by each PMU unit; dividing the data frame into at least two data frame sets; The first judgment module is used to, for each data frame set, take the first data frame in the data frame set as the current data frame, and judge whether the current data frame is the first frame data of this round of compression; The first setting module is used to change the value of the SYNC field of the current data frame to a preset field when the judgment result of the first judgment module is yes, and set the value of the compression count number Count_byte as 0; store the current data frame in the DATA_Frame1 segment at the head end of the cache array TEMP, and judge whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T , trigger the second setting module, if the compression time of the current round of compression is less than the preset time limit T, take the next frame of the current data frame as the current data frame, and trigger the judgment of the current data frame described in the first judgment module Whether it is the first frame of data compressed in this round; a compression module, configured to use the sum of the current value of the compression count number Count_byte and the preset step size as the current value of the compression count number when the judgment result of the first judgment module is no; according to the current The difference between the phasor of the data frame and the corresponding phasor of the previous data frame of the current data frame, the variable segment ΔDATA_Frame is obtained by performing variable compression on the current data frame; The second judgment module is used for judging whether the data frame compressed in this round of compression reaches the upper limit of compression according to the compression count number Count_byte; if the data frame compressed in this round of compression reaches the upper limit of compression, perform step F; The compressed data frame does not reach the upper limit of compression, and judge whether the compression time of this round of compression is greater than or equal to the preset time limit T; if the compression time of this round of compression is greater than or equal to the preset time limit T, trigger the second setting module, if this The compression time of the round compression is less than the preset time limit T, and the next frame of the current data frame is used as the current data frame, and the first judgment module is triggered to judge whether the current data frame is the first frame data of this round of compression. ; The second setting module is configured to set the DATA_Frame1, the compression count number Count_byte when the current data frame is the first frame of this round of compression, and the compression time of the current round of compression is greater than or equal to the preset time limit T The combination is sent as compressed data to the master station in the WAMS system for receiving the data sent by the data transmission device; except that the current data frame is the first frame of this round of compression, and the compression time of this round of compression If it is greater than or equal to the preset time limit T, the combination of the DATA_Frame1, the compression count number Count_byte and the variable segment ΔDATA_Frame is sent to the WAMS system as the compressed data for receiving the data sent by the sending device. data master. 12 . The communication data compression apparatus according to claim 11 , wherein the data sending device comprises at least one of a PDC unit and a NIC unit. 13 . 13. A communication data compression device according to claim 11, wherein the first receiving module is further configured to: Receive a data frame sent by each PMU unit and generate the line data collected by itself according to the configuration frame. 14. A communication data compression device according to claim 11, wherein the compression module is further configured to: D1: Divide the number n of phasors contained in the current data frame by j to obtain a group of phasors, and the remainder b phasors, and b is less than j; D2: Starting from the first group of phasors in the a group of phasors, take the first group of vectors as the current group vector, and for each phasor in the current group of phasors, compare the amplitude of the phasor with the The amplitude of the corresponding phasor of the previous data frame of the current data frame is compared to obtain the first amplitude variation; the angle of each phasor of the current data frame is compared with the previous data of the current data frame. Comparing the angles of each corresponding phasor of the frame to obtain a first angle change, and generating a first variable identifier according to the first amplitude change and the first angle change; changing the first amplitude The amount and the first angle change amount are combined into a first variable; D3: store the first variable flag corresponding to the current group of phasors in the flag array flag; store the first variable in the variable array data; then use the next group of phasors of the current group of phasors as the current group phasors, and return to perform the D2 step until the a group of phasors are processed; D4: For each phasor in the b phasors, compare the amplitude of the phasor with the amplitude of the corresponding phasor of the previous data frame of the current data frame to obtain a second amplitude variation ; Compare the angle of the phasor with the angle of the corresponding phasor of the previous data frame of the current data frame to obtain a second angle change; According to the second amplitude change and the second angle The variation generates a second variable identification, and stores the second variable identification in the identification array flag; synthesizes the second amplitude variation and the second angle variation into a second variable; The variable is stored in the variable array data; D5: Form the flag array flag and the variable array data into a variable segment ΔDATA_Frame. 15. A communication data compression device according to claim 14, wherein the compression module is further used for: 1), let k be the count, the initial value is 0, and judge whether k is less than j: 2) If yes, take the difference H1 between the amplitude r1 of each phasor of the current data frame and the amplitude p1 of each corresponding phasor of the previous data frame of the current data frame as the first amplitude variation ; The difference H2 of the angle r2 of each phasor of the current data frame and the angle p2 of each corresponding phasor of the previous data frame of the current data frame is used as the first angle variation; And judge H1 and H2 Whether the absolute value is less than 8; 3) If the absolute values of H1 and H2 are both less than 8, allocate 0.5 bytes of storage space for each of H1 and H2, update the first variable sign [k] to 0x00; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 8, and determine whether the value of H2 is negative; if the value of H1 is positive, determine whether the value of H2 is negative, if the value of H2 is negative, change the value of H2 The value of is updated to the sum of H2 and 8; H1 and H2 are stored in the cache array one; 4) If the absolute values of H1 and H2 are not both less than 8, judge whether the absolute values of H1 and H2 are both less than 128; 5) If the absolute values of H1 and H2 are both less than 128, allocate 1 byte of storage space for each of H1 and H2, update the first variable sign [k] to 0x01; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 128, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative, if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 128; store H1 and H2 into the cache array two; 6) If the absolute values of H1 and H2 are not both less than 128, judge whether the absolute values of H1 and H2 are both less than 2048; 7), if the absolute values of H1 and H2 are both less than 2048, allocate 1.5 bytes of storage space for H1 and H2, update the first variable sign [k] to 0x02; judge whether the value of H1 is negative, if H1 If the value of H1 is negative, update the value of H1 to the sum of H1 and 2048, and judge whether the value of H2 is negative; if the value of H1 is positive, execute the step of judging whether the value of H2 is negative; if the value of H2 is negative If it is negative, update the value of H2 to the sum of H2 and 2048; store H1 and H2 into the cache array three; 8), if the absolute values of H1 and H2 are not both less than 2048, update the first variable sign sign[k] to = 0x03, and then store r1, r2 in the cache array four; 9), update the value of k to k+1, and return to execute the step 1); until each vector in the current group of vectors is processed; 10) When the value of k is greater than or equal to j, execute the step D3. 16. A communication data compression device according to claim 14, wherein the compression module is further used for: The first variable identifier corresponding to each phasor in the current group of phasors is stored in the temporary identifier array sign, and then the set of first variable identifiers corresponding to each phasor in the current group is stored in the identifier array flag. 17 . The communication data compression device according to claim 11 , wherein the preset step size is 1. 18 . 18. The communication data compression device according to claim 11, wherein the preset field is: 0xAA63. 19. A communication data decompression device, characterized in that it is applied to a master station that receives data sent by a data sending device in a WAMS system, the device comprising: a second receiving module, configured to receive the compressed data frame corresponding to the data frame set sent by the data sending device; a third judging module for judging whether the SYNC field of the data frame is a preset field, if not, triggering the second receiving module; if so, triggering a storage module; The storage module is used to sequentially place the L bytes of data after the compression count number Count_byte into the flag array flag, and the data after the L bytes into the variable array data; Sequentially take out j identifiers from the identifier array flag and put them into the array sign, then read the data of the corresponding length in the variable array data sequentially according to the content of sign, and according to the data frame corresponding to the variable array data The phasor of the previous data frame is restored to the original phasor corresponding to the data read according to the sign content, and the original phasor is sequentially stored in the array Full_data; The decompression module is used to sequentially take out b identifiers from the identifier array flag and put them into the array sign, and then sequentially read the data of the corresponding length in the variable array data according to the content of the sign, and according to the variable array data The phasor of the previous data frame of the corresponding data frame restores the original phasor corresponding to the data read according to the sign content, and stores the original phasor in the array Full_data in sequence; The combination module is used to generate other fields except phasors according to the configuration frame and the first frame data frame, and combine the generated other fields with the data in the array Full_data to generate a complete data frame. 20. A communication data decompression device according to claim 19, wherein the device further comprises: a fourth judgment module, configured to: Determine whether the obtained decompressed data frame has errors or missed sending, and if so, send a re-send command to the data sending device, so that the data sending device can retrieve the corresponding error or missed sending of the data frame. 21. A communication data compression and decompression system, wherein the system comprises: Based on the communication data compression device according to any one of claims 11-18, and based on the communication data decompression device according to claim 19.

Images