CN113032358B - Water affair data processing method and device and terminal equipment - Google Patents
Water affair data processing method and device and terminal equipment Download PDFInfo
- Publication number
- CN113032358B CN113032358B CN202010453885.6A CN202010453885A CN113032358B CN 113032358 B CN113032358 B CN 113032358B CN 202010453885 A CN202010453885 A CN 202010453885A CN 113032358 B CN113032358 B CN 113032358B
- Authority
- CN
- China
- Prior art keywords
- identifier
- data
- data acquisition
- water
- water service
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- XLYOFNOQVPJJNP-UHFFFAOYSA-N water Substances O XLYOFNOQVPJJNP-UHFFFAOYSA-N 0.000 title claims abstract description 293
- 238000003672 processing method Methods 0.000 title claims abstract description 34
- 238000004891 communication Methods 0.000 claims abstract description 31
- 238000000034 method Methods 0.000 claims abstract description 27
- 238000004590 computer program Methods 0.000 claims description 24
- 230000002159 abnormal effect Effects 0.000 claims description 14
- 238000013480 data collection Methods 0.000 claims description 12
- 238000001514 detection method Methods 0.000 claims description 11
- 238000012545 processing Methods 0.000 claims description 8
- 230000005856 abnormality Effects 0.000 claims description 6
- 238000012544 monitoring process Methods 0.000 description 15
- 238000004458 analytical method Methods 0.000 description 10
- 230000006870 function Effects 0.000 description 7
- 230000008569 process Effects 0.000 description 7
- 230000004044 response Effects 0.000 description 4
- 230000008878 coupling Effects 0.000 description 3
- 238000010168 coupling process Methods 0.000 description 3
- 238000005859 coupling reaction Methods 0.000 description 3
- 238000010586 diagram Methods 0.000 description 3
- 230000005540 biological transmission Effects 0.000 description 2
- 238000007405 data analysis Methods 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- ZAMOUSCENKQFHK-UHFFFAOYSA-N Chlorine atom Chemical compound [Cl] ZAMOUSCENKQFHK-UHFFFAOYSA-N 0.000 description 1
- 230000003190 augmentative effect Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 229910052801 chlorine Inorganic materials 0.000 description 1
- 239000000460 chlorine Substances 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000018109 developmental process Effects 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 238000005538 encapsulation Methods 0.000 description 1
- 210000001503 joint Anatomy 0.000 description 1
- 239000000463 material Substances 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000004806 packaging method and process Methods 0.000 description 1
- 230000002093 peripheral effect Effects 0.000 description 1
- 230000011218 segmentation Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000012800 visualization Methods 0.000 description 1
- 239000002699 waste material Substances 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/21—Design, administration or maintenance of databases
- G06F16/211—Schema design and management
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/22—Indexing; Data structures therefor; Storage structures
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q50/00—Information and communication technology [ICT] specially adapted for implementation of business processes of specific business sectors, e.g. utilities or tourism
- G06Q50/06—Energy or water supply
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Databases & Information Systems (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Business, Economics & Management (AREA)
- Data Mining & Analysis (AREA)
- General Engineering & Computer Science (AREA)
- Health & Medical Sciences (AREA)
- Economics (AREA)
- Human Resources & Organizations (AREA)
- Software Systems (AREA)
- Public Health (AREA)
- Water Supply & Treatment (AREA)
- General Health & Medical Sciences (AREA)
- Computational Linguistics (AREA)
- Marketing (AREA)
- Primary Health Care (AREA)
- Strategic Management (AREA)
- Tourism & Hospitality (AREA)
- General Business, Economics & Management (AREA)
- Selective Calling Equipment (AREA)
Abstract
The application is applicable to the technical field of water affairs, and provides a water affair data processing method, a device and terminal equipment, wherein the water affair data processing method comprises the following steps: acquiring a water affair data message uploaded by data acquisition equipment; determining a software protocol code corresponding to the hardware protocol code according to a preset communication protocol corresponding relation; generating a unique acquisition identifier corresponding to the water affair data according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code; determining a water service equipment identifier according to a data acquisition equipment identifier, a data acquisition channel identifier and a preset first corresponding relation, and establishing an association relation between the water service equipment identifier and the unique acquisition identifier; and storing the water affair data and the corresponding association relation in a database. The method and the device are convenient for managing the service data.
Description
Technical Field
The application belongs to the technical field of water affairs, and particularly relates to a water affair data processing method and device and terminal equipment.
Background
With the increase of the intelligent water affair service universality, data generated by the same water affair equipment has different application scenes in different service systems. Taking data read by water service equipment for collecting pressure as an example, the data is applied to a water meter in a large user system aiming at a user, so that the application of the pressure data needs to bring the water meter in the large user system and the attribute of the user; in a SCADA (Supervisory Control And Data Acquisition, Data Acquisition And monitoring Control) system in the water service industry, the pressure Data is applied to a monitoring point of the SCADA system, And therefore the application of the pressure Data needs to bring an attribute associated with the SCADA monitoring point.
The hardware general protocol is introduced, so that the corresponding hardware message can be analyzed into the original equipment data without modifying the original lower hardware program by increasing parameters at will, the type of the analyzed data becomes configurable, and no corresponding general data analysis scheme exists in the upper service level.
Therefore, the same hardware data needs to be respectively analyzed on the basis of different service systems to obtain the service data corresponding to the service systems, so that the service data is difficult to be uniformly managed.
Disclosure of Invention
In order to overcome the problems in the related art, the embodiment of the application provides a water affair data processing method, a water affair data processing device and terminal equipment.
The application is realized by the following technical scheme:
in a first aspect, an embodiment of the present application provides a water affair data processing method, including:
acquiring a water affair data message uploaded by data acquisition equipment; the water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code;
determining a software protocol code corresponding to the hardware protocol code according to a preset communication protocol corresponding relation; the communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence;
generating a unique acquisition identifier corresponding to the water affair data according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code;
determining a water service equipment identifier according to a data acquisition equipment identifier, a data acquisition channel identifier and a preset first corresponding relation, and establishing an association relation between the water service equipment identifier and the unique acquisition identifier; the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier;
and storing the water affair data and the corresponding association relation in a database.
In a possible implementation manner of the first aspect, the method further includes:
acquiring each water affair device and each data acquisition device in a target area; each data acquisition device comprises a plurality of data acquisition channels, and each water affair device corresponds to one data acquisition channel;
and establishing the first corresponding relation among the water service equipment, the data acquisition equipment and the data acquisition channel.
In a possible implementation manner of the first aspect, the water service data includes a parameter type, and the method further includes:
acquiring all hardware protocols corresponding to the water affair data of various parameter types acquired by the data acquisition equipment; each hardware protocol corresponds to a hardware protocol code;
respectively setting a corresponding software protocol for each hardware protocol; each software protocol corresponds to a software protocol code;
and the corresponding relation between each hardware protocol and each software protocol forms the corresponding relation of the communication protocols.
In a possible implementation manner of the first aspect, the generating a unique acquisition identifier corresponding to the water service data according to a data acquisition device identifier, a data acquisition channel identifier, and a software protocol code includes:
combining a data acquisition equipment identifier, a data acquisition channel identifier and a software protocol code to obtain a unique acquisition identifier corresponding to the water affair data; or
And correspondingly setting a unique acquisition identifier consisting of numbers and/or letters for each group of data acquisition equipment identifier, data acquisition channel identifier and software protocol code.
In a possible implementation manner of the first aspect, the determining, according to a data acquisition device identifier, a data acquisition channel identifier, and a preset first corresponding relationship, a water service device identifier, and establishing an association relationship between the water service device identifier and the unique acquisition identifier includes:
determining the water affair equipment identification corresponding to the data acquisition equipment identification and the data acquisition channel identification in the first corresponding relation;
associating the unique collection identification with the determined water service equipment identification.
In a possible implementation manner of the first aspect, the water data includes a parameter type, a value, and a collection time, and the method further includes:
acquiring an abnormal detection request, wherein the abnormal detection request comprises a target water service equipment identifier;
determining a target association relation containing the target water affair identifier in the database;
and acquiring the parameter type, the value and the acquisition time of the water service data corresponding to the target association relation, and determining whether the water service equipment corresponding to the target water service equipment identification is abnormal or not based on the parameter type, the value and the acquisition time.
In a possible implementation manner of the first aspect, the determining, based on the parameter type, the value, and the collection time, whether an abnormality exists at a water service device corresponding to the target water service device identifier includes:
acquiring a preset value range and a preset time period corresponding to the target water service equipment identification;
determining a value corresponding to the time and the preset value range according to the acquisition time and the preset time period;
and when the value corresponding to the time exceeds the preset value range, determining that the water service equipment corresponding to the target water service equipment identification is abnormal.
In a second aspect, an embodiment of the present application provides a water affairs data processing apparatus, including:
the message acquisition module is used for acquiring the water affair data message uploaded by the data acquisition equipment; the water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code;
the software protocol code determining module is used for determining a software protocol code corresponding to the hardware protocol code according to a preset communication protocol corresponding relation; the communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence;
the acquisition identifier generation module is used for generating a unique acquisition identifier corresponding to the water service data according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code;
the incidence relation establishing module is used for determining a water service equipment identifier according to the data acquisition equipment identifier, the data acquisition channel identifier and a preset first corresponding relation and establishing the incidence relation between the water service equipment identifier and the unique acquisition identifier; the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier;
and the storage module is used for storing the water affair data and the corresponding association relation into a database.
In a third aspect, an embodiment of the present application provides a terminal device, which includes a memory, a processor, and a computer program stored in the memory and executable on the processor, where the processor implements the water affair data processing method according to any one of the first aspect when executing the computer program.
In a fourth aspect, the present application provides a computer-readable storage medium, where a computer program is stored, and when executed by a processor, the computer program implements the water affairs data processing method according to any one of the first aspect.
In a fifth aspect, the present application provides a computer program product, which when run on a terminal device, causes the terminal device to execute the water affair data processing method according to any one of the above first aspects.
It is understood that the beneficial effects of the second aspect to the fifth aspect can be referred to the related description of the first aspect, and are not described herein again.
Compared with the prior art, the embodiment of the application has the advantages that:
in the embodiment of the application, the water affair data message uploaded by the data acquisition equipment is acquired, the software protocol code corresponding to the hardware protocol code is determined according to the corresponding relation of the preset communication protocol, generating a unique acquisition identifier corresponding to the water service data message according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code, determining the water service equipment identification according to the data acquisition equipment identification, the data acquisition channel identification and a preset first corresponding relation, establishing an associated relation between the water service equipment identification and the unique acquisition identification, storing the water service data and the corresponding associated relation into a database, therefore, the same hardware data can adopt an analytic method to obtain service data for various service systems and store the service data in the database, various service systems can call corresponding service data from the database, so that the service data can be managed conveniently.
It is to be understood that both the foregoing general description and the following detailed description are exemplary and explanatory only and are not restrictive of the specification.
Drawings
In order to more clearly illustrate the technical solutions in the embodiments of the present application, the drawings needed to be used in the embodiments or the prior art descriptions will be briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the present application, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without inventive exercise.
Fig. 1 is a schematic view of an application scenario of a water data processing method according to an embodiment of the present application;
fig. 2 is a schematic flow chart of a water affairs data processing method according to an embodiment of the present application;
fig. 3 is a schematic flow chart of a water affairs data processing method according to an embodiment of the present application;
FIG. 4 is a schematic flow chart illustrating a water affairs data processing method according to an embodiment of the present disclosure;
FIG. 5 is a schematic flow chart illustrating a water affairs data processing method according to an embodiment of the present disclosure;
FIG. 6 is a schematic flow chart illustrating a water affairs data processing method according to an embodiment of the present disclosure;
FIG. 7 is a schematic structural diagram of a water data processing apparatus according to an embodiment of the present disclosure;
fig. 8 is a schematic structural diagram of a terminal device according to an embodiment of the present application.
Detailed Description
In the following description, for purposes of explanation and not limitation, specific details are set forth, such as particular system structures, techniques, etc. in order to provide a thorough understanding of the embodiments of the present application. It will be apparent, however, to one skilled in the art that the present application may be practiced in other embodiments that depart from these specific details. In other instances, detailed descriptions of well-known systems, devices, circuits, and methods are omitted so as not to obscure the description of the present application with unnecessary detail.
It will be understood that the terms "comprises" and/or "comprising," when used in this specification and the appended claims, specify the presence of stated features, integers, steps, operations, elements, and/or components, but do not preclude the presence or addition of one or more other features, integers, steps, operations, elements, components, and/or groups thereof.
It should also be understood that the term "and/or" as used in this specification and the appended claims refers to and includes any and all possible combinations of one or more of the associated listed items.
As used in this specification and the appended claims, the term "if" may be interpreted contextually as "when", "upon" or "in response to" determining "or" in response to detecting ". Similarly, the phrase "if it is determined" or "if a [ described condition or event ] is detected" may be interpreted contextually to mean "upon determining" or "in response to determining" or "upon detecting [ described condition or event ]" or "in response to detecting [ described condition or event ]".
Furthermore, in the description of the present application and the appended claims, the terms "first," "second," "third," and the like are used for distinguishing between descriptions and not necessarily for describing or implying relative importance.
Reference throughout this specification to "one embodiment" or "some embodiments," or the like, means that a particular feature, structure, or characteristic described in connection with the embodiment is included in one or more embodiments of the present application. Thus, appearances of the phrases "in one embodiment," "in some embodiments," "in other embodiments," or the like, in various places throughout this specification are not necessarily all referring to the same embodiment, but rather "one or more but not all embodiments" unless specifically stated otherwise. The terms "comprising," "including," "having," and variations thereof mean "including, but not limited to," unless expressly specified otherwise.
With the increase of the intelligent water affair service universality, data generated by the same water affair equipment has different application scenes in different service systems. Taking data read by water service equipment for collecting pressure as an example, the data is applied to a water meter in a large user system aiming at a user, so that the application of the pressure data needs to bring the water meter in the large user system and the attribute of the user; in a SCADA (Supervisory Control And Data Acquisition, Data Acquisition And monitoring Control) system in the water service industry, the pressure Data is applied to a monitoring point of the SCADA system, And therefore the application of the pressure Data needs to bring an attribute associated with the SCADA monitoring point.
The hardware general protocol is introduced, so that the corresponding hardware message can be analyzed into the original equipment data without modifying the original lower hardware program by increasing parameters at will, the type of the analyzed data becomes configurable, and no corresponding general data analysis scheme exists in the upper service level. Therefore, the same hardware data needs to be respectively analyzed on the basis of different service systems to obtain the service data corresponding to the service systems, so that the service data is difficult to be uniformly managed.
Based on the above problems, the water service data processing method in the embodiment of the present application obtains the water service data message uploaded by the data acquisition device, determines the software protocol code corresponding to the hardware protocol code according to the preset communication protocol correspondence, generates the unique acquisition identifier corresponding to the water service data message according to the data acquisition device identifier, the data acquisition channel identifier and the software protocol code, determines the water service device identifier according to the data acquisition device identifier, the data acquisition channel identifier and the preset first correspondence, establishes the association relationship between the water service device identifier and the unique acquisition identifier, and stores the water service data and the corresponding association relationship into the database, so that the same hardware data can be analyzed for various service systems to obtain service data and store the service data into the database, and the various service systems can retrieve the corresponding service data from the database, thereby facilitating management of the service data.
For example, the embodiment of the present application can be applied to the exemplary scenario shown in fig. 1. In this scenario, the data collecting device 10 is configured to collect water service data of the water service device 1, the water service device 2, … …, and the water service device n, where the water service data may include pressure data, flow data, water quality data, and the like, and the corresponding water service device may include a water service device for monitoring pressure data, a water service device for monitoring flow data, a water service device for monitoring water quality data, and the like. The data acquisition device 10 may include a plurality of data acquisition channels, such as a data acquisition channel 1, a data acquisition channel 2, … …, and a data acquisition channel n, where each water service device corresponds to one data acquisition channel. Specifically, the data acquisition device 10 may acquire the water service data of the corresponding water service device through each data acquisition channel, encapsulate the water service data of each water service device, the corresponding data acquisition device identifier, the data acquisition channel identifier, and other information, and send the encapsulated information to the server 20 in the form of a water service data message.
The server 20 obtains the water affair data message uploaded by the data acquisition device 10, determines a software protocol code corresponding to a hardware protocol code in the water affair data message according to a preset communication protocol corresponding relationship, generates an unique acquisition identifier corresponding to the water affair data message according to the data acquisition device identifier, the data acquisition channel identifier and the software protocol code, determines a water affair device identifier according to the data acquisition device identifier, the data acquisition channel identifier and a preset first corresponding relationship, establishes an association relationship between the water affair device identifier and the unique acquisition identifier, and further stores the water affair data and the corresponding association relationship in a database.
The visualization interaction method of the present application is described in detail below with reference to fig. 1.
Fig. 2 is a schematic flow chart of a water affairs data processing method according to an embodiment of the present application, and referring to fig. 2, the water affairs data processing method is described in detail as follows:
in step 101, a water affair data message uploaded by a data acquisition device is acquired.
The water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code. For example, the data acquisition device identifier may be a factory number of each data acquisition device, an International Mobile Equipment Identity (IEMI) of each data acquisition device, or a manual number of all data acquisition devices in the target area (e.g., CJQ001, CJQ 002), which is not limited in this embodiment of the present invention.
For example, referring to fig. 1, the data collecting device 10 may be configured to collect water service data of the water service device 1, the water service device 2, … …, and the water service device n, where the water service data may include pressure data, flow data, water quality data (such as PH value), and the like, and correspondingly, the water service device may include a water service device for monitoring the pressure data, a water service device for monitoring the flow data, a water service device for monitoring the water quality data, and the like. The data acquisition device may include a plurality of data acquisition channels, such as data acquisition channel 1, data acquisition channel 2, … …, and data acquisition channel n, and each water service device corresponds to one data acquisition channel.
Specifically, the data acquisition device 10 may acquire the water service data of the corresponding water service device through each data acquisition channel, encapsulate the water service data of each water service device, the corresponding data acquisition device identifier, the data acquisition channel identifier, and other information, and send the encapsulated information to the server 20 in the form of a water service data message. Each water affair data message can contain water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code.
In this step, the hardware protocol may be an agreement on a transmission mode, a message structure, and/or an analysis rule of the device message, and the hardware protocol code may be a code preset for each hardware protocol, and is used to distinguish each hardware protocol, for example, the hardware protocol code may be a number, a letter, and a combination of the number and the letter, which is not limited in this embodiment of the present application. The corresponding hardware protocol can be determined according to a code preset by the hardware protocol.
Illustratively, the water service equipment may include one or more of a flow meter, a pressure monitor, a water quality monitor, a thermometer, a water pump, a valve, a residual chlorine meter, a turbidimeter, and the like.
In step 102, a software protocol code corresponding to the hardware protocol code is determined according to a preset communication protocol correspondence.
The communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence. Referring to table 1, the communication protocol correspondence may include, for example, a plurality of sets of data, each of which may include a hardware protocol code, a software protocol code, and a parameter type. The hardware protocol is the agreement of the transmission mode, the message structure and/or the analysis rule of the equipment message, the software protocol is an analysis method which is corresponding to the hardware protocol and is converted into practical application, and the parameter type represents the parameter type of the water service data which is correspondingly transmitted by the hardware protocol and the software protocol. The hardware protocol and the software protocol can carry out communication, data butt joint and data identification through an appointed structure, format and analysis mode.
TABLE 1
| Hardware protocol encoding | Software protocol encoding | Type of parameter | |
| 1 | AA | 1 | Pressure of |
| 2 | A1 | 2 | Flow rate |
| 3 | AD | 3 | pH value |
| … | …… | …… | …… |
Based on table 1, a preset communication protocol correspondence may be obtained, and the hardware protocol codes are matched with each hardware protocol code in the communication protocol correspondence; the hardware protocol code in step 101 is determined to be the matched hardware protocol code in the communication protocol, so as to obtain the corresponding software protocol code.
It should be noted that the hardware protocol codes, the software protocol codes and the parameter types in table 1 are only exemplary illustrations, where the hardware protocol codes may also be represented by numbers, the software protocol codes may also be represented by letters, and the parameter types may be other types, which are not limited in this application.
In step 103, a unique collection identifier corresponding to the water service data is generated according to the data collection device identifier, the data collection channel identifier and the software protocol code.
In a possible implementation manner, step 103 may specifically include:
and combining the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code to obtain the unique acquisition identifier corresponding to the water affair data.
Specifically, the number of the data acquisition devices may be plural, and the number of the data acquisition channels in one data acquisition device may be plural. Illustratively, the identifier of the data acquisition device may be CJQ001, the identifier of the data acquisition channel may be 01, and the software protocol code may be 1, based on which CJQ001, 01, and 1 may be directly synthesized into an identifier "CJQ 001011", where "CJQ 001011" may be the unique acquisition identifier corresponding to the water service data. According to the unique collection identifier "CJQ 001011", it can be determined that the data collection device identifier CJQ001, the data collection channel identifier 01, and the software protocol code 1 correspond to the water service data.
In addition, the data acquisition device identifier, the data acquisition channel identifier and the software protocol code may also be combined in other forms, for example, a division symbol may be added between the data acquisition device identifier, the data acquisition channel identifier and the software protocol code to obtain a unique acquisition identifier corresponding to the water service data. Illustratively, the data acquisition device identifier may be CJQ001, the data acquisition channel identifier may be 01, and the software protocol code may be 1, based on which CJQ001, 01, and 1 are combined with the segmentation agreement, a "CJQ 001-01-1" may be obtained, and this "CJQ 001-01-1" may be the unique acquisition identifier corresponding to the water service data. According to the unique collection identifier 'CJQ 001-01-1', the data collection equipment identifier CJQ001, the data collection channel identifier 01 and the software protocol code 1 corresponding to the water service data can be determined.
In another possible implementation manner, step 103 may specifically include:
and correspondingly setting a unique acquisition identifier consisting of numbers and/or letters for each group of data acquisition equipment identifier, data acquisition channel identifier and software protocol code.
Specifically, the number of the data acquisition devices may be plural, and the number of the data acquisition channels in one data acquisition device may be plural. Illustratively, the data acquisition device identifier may be CJQ001, the data acquisition channel identifier may be 01, and the software protocol code may be 1, based on which a unique acquisition identifier made of numbers and/or letters may be set according to a preset rule, corresponding to the data acquisition device identifier CJQ001, the data acquisition channel identifier 01, and the software protocol code 1. For example, a unique collection identifier 198727 formed by numbers may be set according to a preset rule, corresponding to the data collection device identifier CJQ001, the data collection channel identifier 01, and the software protocol code 1.
Referring to table 2, the data acquisition device identifier CJQ001, the data acquisition channel identifier 01, and the software protocol code 1 correspond to a unique acquisition identifier 198727; the data acquisition equipment identifier CJQ001, the data acquisition channel identifier 01 and the software protocol code 2, wherein the corresponding unique acquisition identifier is 198728; the data acquisition equipment comprises a data acquisition equipment identifier CJQ001, a data acquisition channel identifier 02 and a software protocol code 1, wherein the corresponding unique acquisition identifier is 198729; the data acquisition device identification CJQ001, the data acquisition channel identification 02 and the software protocol code 2, and the corresponding unique acquisition identification is 198730.
TABLE 2
| Data acquisition device identification | Data acquisitionChannel identification | Software protocol encoding | Unique collection identifier | |
| 1 | CJQ001 | 01 | 1 | 198727 |
| 2 | CJQ001 | 01 | 2 | 198728 |
| 3 | CJQ001 | 02 | 1 | 198729 |
| 4 | CJQ001 | 02 | 2 | 198730 |
In step 104, a water service device identifier is determined according to the data acquisition device identifier, the data acquisition channel identifier and a preset first corresponding relationship, and an association relationship between the water service device identifier and the unique acquisition identifier is established.
And the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier. For example, the water service Equipment identifier may be a factory number for each water service Equipment, an International Mobile Equipment Identity (IEMI) for each water service Equipment, or a manual number (e.g., 01, 02) for all water service Equipment in the target area, which is not limited in this embodiment of the present invention.
In this step, the first corresponding relationship may be pre-established, and the first corresponding relationship is established according to the corresponding data acquisition device, the data acquisition channel, and the water service device. The specific establishment process may refer to the embodiment corresponding to fig. 4.
Referring to fig. 3, in some embodiments, step 104 may include the steps of:
in step 1041, a water service device identifier corresponding to the data acquisition device identifier and the data acquisition channel identifier is determined in the first corresponding relationship.
In step 1042, the unique collection identification is associated with the determined water service device identification.
The first corresponding relation may include a plurality of sets of corresponding water service device identifiers, data acquisition device identifiers and data acquisition channel identifiers, and after the data acquisition device identifiers and the data acquisition channel identifiers are determined, the water service device identifiers corresponding to the data acquisition device identifiers and the data acquisition channel identifiers may be determined.
The unique collection identifier determined in step 103 and the water service device identifier determined in step 1041 both correspond to the same water service device, so that the unique collection identifier and the determined water service device identifier can be associated to establish an association relationship between the water service device identifier and the unique collection identifier.
As shown in table 3, a unique collection identifier may be determined according to the data collection device identifier, the data collection channel identifier, and the software protocol code, and the unique collection identifier is associated with a water service device identifier, so that the relationship shown in table 3 may be obtained. A group of data acquisition equipment identification, data acquisition channel identification and software protocol code correspond to a water service equipment identification and a unique acquisition identification.
TABLE 3
In step 105, the water affair data and the corresponding association relation are stored in a database.
The water affair data processing method obtains the water affair data message uploaded by the data acquisition equipment, determines the software protocol code corresponding to the hardware protocol code according to the corresponding relation of the preset communication protocol, generating a unique acquisition identifier corresponding to the water service data message according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code, determining the water service equipment identification according to the data acquisition equipment identification, the data acquisition channel identification and a preset first corresponding relation, establishing an associated relation between the water service equipment identification and the unique acquisition identification, storing the water service data and the corresponding associated relation into a database, therefore, the same hardware data can adopt an analytic method to obtain service data for various service systems and store the service data in the database, various service systems can call corresponding service data from the database, so that the service data can be managed conveniently.
In some embodiments, based on the embodiment shown in fig. 2, the water affair data processing method may further include the step of establishing a first corresponding relationship; referring to fig. 4, the step of establishing the first corresponding relationship may include:
in step 106, each water service device and each data acquisition device in the target area are obtained. Each data acquisition device comprises a plurality of data acquisition channels, and each water service device corresponds to one data acquisition channel.
In step 107, the first correspondence between the water service equipment, the data acquisition equipment and the data acquisition channel is established.
The target area may be a city, an urban area, a town, a cell, etc., and may be set according to actual needs. Taking a town as an example, all the water affair equipment and the data acquisition equipment in the town are coded to obtain the identification of each water affair equipment and the identification of each data acquisition equipment. And one water service device corresponds to one data acquisition channel of one data acquisition device, as shown in table 4, so that the first corresponding relationship can be established according to the data acquisition device and the data acquisition channel corresponding to each water service device.
TABLE 4
| Data acquisition equipment | Data acquisition channel | Water affair equipment | |
| 1 | CJQ001 | 1 | 01 |
| 2 | CJQ001 | 2 | 02 |
| 3 | CJQ001 | 3 | 03 |
| … | …… | …… | …… |
Referring to fig. 5, in some embodiments, based on the embodiment shown in fig. 2, the water affair data processing method may further include:
in step 108, acquiring all hardware protocols corresponding to the water affair data of various parameter types acquired by the data acquisition equipment; wherein each hardware protocol corresponds to a hardware protocol code.
In step 109, a corresponding software protocol is set for each hardware protocol; wherein each software protocol corresponds to a software protocol code.
In step 110, the correspondence between each hardware protocol and each software protocol is used to form the communication protocol correspondence.
Illustratively, the corresponding relationship between the software protocol and the hardware protocol may be established by a default hardware message structure and a default hardware message 16-bit parsing format. After receiving the message, the software program analyzes information carried in the message load according to an agreed message structure, wherein the information may include an identifier of a collector, an identifier of a collector channel, and a hardware protocol code, and then obtains a certain parameter, which is acquired by the channel of which collector, of the value carried by the message through a corresponding relationship between the hardware protocol code and the software protocol code, and a corresponding relationship between the software protocol code and the parameter type. The parameter type is the type of the collected parameters of the water service equipment, and for example, the parameter type can include various types such as pressure, flow, water quality data and the like.
Referring to fig. 6, in some embodiments, the water affair data processing method may further include:
in step 201, an anomaly detection request is obtained, where the anomaly detection request includes an identification of a target water service device.
The anomaly detection request may be an anomaly detection request of a user for a certain water service device or some water service devices, and therefore, the anomaly detection request may include one target water service device identifier or more than two target water service device identifiers.
In step 202, a target association relation containing the target water service equipment identification is determined in the database.
In step 203, the parameter type, the value and the acquisition time of the water service data corresponding to the target association relationship are obtained, and it is determined whether an abnormality exists at the water service device corresponding to the target water service device identifier based on the parameter type, the value and the acquisition time.
Referring to table 3, a target association relationship including the target water service device identifier may be determined in the database, and the target association relationship may include a group of data acquisition device identifiers, data acquisition channel identifiers, software protocol codes, and unique acquisition identifiers, so that corresponding water service data may be determined according to the unique acquisition identifiers. The water affair data can include parameter types, values, acquisition time and the like. For example, the water service data may include pressure data having a value a and a time of acquisition of the pressure data.
For example, the determining whether an abnormality exists at the water service device corresponding to the target water service device identifier based on the parameter type, the value and the acquisition time may specifically include:
acquiring a preset value range and a preset time period corresponding to the target water service equipment identification;
determining a value corresponding to the time and the preset value range according to the acquisition time and the preset time period;
and when the value corresponding to the time exceeds the preset value range, determining that the water service equipment corresponding to the target water service equipment identification is abnormal.
For example, for a certain water service device identifier, the corresponding water service device monitors a certain parameter, such as pressure, and the water service device corresponds to a preset pressure range and a preset time period, i.e., the preset pressure ranges corresponding to the time periods may be different. After determining the corresponding preset time period according to the acquisition time, the value in step 203 may be compared with the preset pressure range corresponding to the preset time period: if the numerical value is within the preset pressure range, the water service equipment corresponding to the target water service equipment identification is not abnormal, and if the numerical value exceeds the preset pressure range, the water service equipment corresponding to the target water service equipment identification is abnormal.
In addition, a higher-level service system (data monitoring and analyzing systems such as an SCADA (supervisory control and data acquisition), a remote meter and a leakage control system) is connected with the database, so that corresponding equipment data can be obtained to complete service, for example, the SCADA calls pressure data of the database to complete monitoring on pressure monitoring points of the water supply network, and the leakage control system calculates and analyzes the leakage points of the water supply network according to the pressure and flow data of the database.
When the acquired parameter types need to be added, only the corresponding parameter types need to be added to the communication protocol, the hardware protocol codes of the communication protocol on the hardware messages and the software protocol codes of the communication protocol on the software system are supplemented, then the corresponding water service equipment is mounted to the corresponding data acquisition channels of the corresponding data acquisition equipment, the relationships between the water service equipment and the data acquisition equipment as well as the corresponding data acquisition channels are maintained, and the access is completed by the parameter types. By the method, parameters can be flexibly expanded, and upper and lower programs do not need to be changed.
The water affair data processing method has the following advantages:
1. the data sources obtained by all the services are unified, so that the uniqueness and the safety of the data are well guaranteed;
2. by uniformly establishing the service analysis rule of the hardware data, a set of service analysis program is realized to correspond to all service data, and the development cost on the service analysis program is reduced;
3. data in the public database is unified through each service, so that a large amount of storage resource waste can be saved;
4. the timeliness is strong, the data after all hardware messages are analyzed does not need to be subjected to multiple analyses aiming at multiple services, and the analysis efficiency is greatly improved;
5. strong reusability and high encapsulation degree: establishing a database, packaging a uniform data providing interface, and converting the data into the data required by the query of the database in the unique label dimension of the original business data according to a certain business rule only by correlating the original business data in the database according to the business dimension required by the business when a new business needs to use hardware data;
6. the labor cost and the material resource cost are reduced. One piece of hardware data is analyzed once without different analyses according to the service, so that software for developers to analyze the service according to the service data is saved.
It should be understood that, the sequence numbers of the steps in the foregoing embodiments do not imply an execution sequence, and the execution sequence of each process should be determined by its function and inherent logic, and should not constitute any limitation to the implementation process of the embodiments of the present application.
Fig. 7 shows a block diagram of a water affair data processing device provided in the embodiment of the present application, corresponding to the water affair data processing method described in the above embodiment, and only the relevant parts of the embodiment of the present application are shown for convenience of description.
Referring to fig. 7, the water affair data processing apparatus in the embodiment of the present application may include a message obtaining module 301, a software protocol code determining module 302, a collection identifier generating module 303, an association relationship establishing module 304, and a storage module 305.
The message acquisition module 301 is configured to acquire a water service data message uploaded by the data acquisition device; the water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code;
a software protocol code determining module 302, configured to determine a software protocol code corresponding to the hardware protocol code according to a preset communication protocol correspondence; the communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence;
the acquisition identifier generation module 303 is configured to generate a unique acquisition identifier corresponding to the water service data according to a data acquisition device identifier, a data acquisition channel identifier, and a software protocol code;
an association relationship establishing module 304, configured to determine a water service device identifier according to the data acquisition device identifier, the data acquisition channel identifier, and a preset first correspondence relationship, and establish an association relationship between the water service device identifier and the unique acquisition identifier; the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier;
the storage module 305 is configured to store the water affair data and the corresponding association relationship in a database.
Optionally, the apparatus may further include an apparatus obtaining module and a first corresponding relationship establishing module.
The equipment acquisition module is used for acquiring each water service equipment and each data acquisition equipment in the target area; each data acquisition device comprises a plurality of data acquisition channels, and each water affair device corresponds to one data acquisition channel;
and the first corresponding relation establishing module is used for establishing the first corresponding relation among the water service equipment, the data acquisition equipment and the data acquisition channel.
Optionally, the water service data includes a parameter type, and the apparatus may further include a hardware protocol acquisition module, a software protocol setting module, and a second correspondence relationship establishing module.
The hardware protocol acquisition module is used for acquiring all hardware protocols corresponding to the water service data of various parameter types acquired by the data acquisition equipment; each hardware protocol corresponds to a hardware protocol code;
the software protocol setting module is used for setting a corresponding software protocol for each hardware protocol; each software protocol corresponds to a software protocol code;
and the second corresponding relation establishing module is used for forming the corresponding relation of the communication protocol by the corresponding relation between each hardware protocol and each software protocol.
Optionally, the acquisition identifier generating module 303 may be specifically configured to:
combining a data acquisition equipment identifier, a data acquisition channel identifier and a software protocol code to obtain a unique acquisition identifier corresponding to the water affair data; or
And correspondingly setting a unique identification formed by numbers and/or letters for each group of data acquisition equipment identification, data acquisition channel identification and software protocol code, and taking the unique identification formed by the numbers and/or letters as the unique acquisition identification corresponding to the water service data.
Optionally, the association relationship establishing module 304 may include a water service device identifier determining unit and an associating unit.
The water service equipment identification determining unit is used for determining water service equipment identifications corresponding to the data acquisition equipment identifications and the data acquisition channel identifications in the first corresponding relation;
and the association unit is used for associating the unique acquisition identifier with the determined water service equipment identifier.
Optionally, the water service data includes a parameter type, a value, and a collection time, and the apparatus may further include a request acquisition module, an association relation determination module, and an abnormality determination module.
The request acquisition module is used for acquiring an abnormal detection request, wherein the abnormal detection request comprises a target water service equipment identifier;
the incidence relation determining module is used for determining a target incidence relation containing the target water affair identifier in the database;
and the abnormity determining module is used for acquiring the parameter type, the value and the acquisition time of the water affair data corresponding to the target association relation, and determining whether the water affair equipment corresponding to the target water affair equipment identification has abnormity or not based on the parameter type, the value and the acquisition time.
Optionally, the abnormality determining module may be specifically configured to:
acquiring a preset value range and a preset time period corresponding to the target water service equipment identification;
determining a value corresponding to the time and the preset value range according to the acquisition time and the preset time period;
and when the value corresponding to the time exceeds the preset value range, determining that the water service equipment corresponding to the target water service equipment identification is abnormal.
It should be noted that, for the information interaction, execution process, and other contents between the above-mentioned devices/units, the specific functions and technical effects thereof are based on the same concept as those of the embodiment of the method of the present application, and specific reference may be made to the part of the embodiment of the method, which is not described herein again.
It will be apparent to those skilled in the art that, for convenience and brevity of description, only the above-mentioned division of the functional units and modules is illustrated, and in practical applications, the above-mentioned function distribution may be performed by different functional units and modules according to needs, that is, the internal structure of the apparatus is divided into different functional units or modules to perform all or part of the above-mentioned functions. Each functional unit and module in the embodiments may be integrated in one processing unit, or each unit may exist alone physically, or two or more units are integrated in one unit, and the integrated unit may be implemented in a form of hardware, or in a form of software functional unit. In addition, specific names of the functional units and modules are only for convenience of distinguishing from each other, and are not used for limiting the protection scope of the present application. The specific working processes of the units and modules in the system may refer to the corresponding processes in the foregoing method embodiments, and are not described herein again.
An embodiment of the present application further provides a terminal device, and referring to fig. 8, the terminal device 400 may include: at least one processor 410, a memory 420, and a computer program stored in the memory 420 and executable on the at least one processor 410, wherein the processor 410 when executing the computer program implements the steps of any of the method embodiments described above, such as the steps S101 to S105 in the embodiment shown in fig. 2. Alternatively, the processor 410, when executing the computer program, implements the functions of the modules/units in the above-described device embodiments, such as the functions of the modules 301 to 305 shown in fig. 7.
Illustratively, a computer program may be partitioned into one or more modules/units, which are stored in the memory 420 and executed by the processor 410 to accomplish the present application. The one or more modules/units may be a series of computer program segments capable of performing specific functions, which are used to describe the execution of the computer program in the terminal device 400.
Those skilled in the art will appreciate that fig. 8 is merely an example of a terminal device and is not limiting and may include more or fewer components than shown, or some components may be combined, or different components such as input output devices, network access devices, buses, etc.
The Processor 410 may be a Central Processing Unit (CPU), other general purpose Processor, a Digital Signal Processor (DSP), an Application Specific Integrated Circuit (ASIC), a Field-Programmable Gate Array (FPGA) or other Programmable logic device, discrete Gate or transistor logic, discrete hardware components, etc. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like.
The memory 420 may be an internal storage unit of the terminal device, or may be an external storage device of the terminal device, such as a plug-in hard disk, a Smart Media Card (SMC), a Secure Digital (SD) Card, a Flash memory Card (Flash Card), and the like. The memory 420 is used for storing the computer programs and other programs and data required by the terminal device. The memory 420 may also be used to temporarily store data that has been output or is to be output.
The bus may be an Industry Standard Architecture (ISA) bus, a Peripheral Component Interconnect (PCI) bus, an Extended ISA (EISA) bus, or the like. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, the buses in the figures of the present application are not limited to only one bus or one type of bus.
The water affair data processing method provided by the embodiment of the application can be applied to terminal devices such as computers, wearable devices, vehicle-mounted devices, tablet computers, notebook computers, netbooks, Personal Digital Assistants (PDAs), Augmented Reality (AR)/Virtual Reality (VR) devices and mobile phones, and the embodiment of the application does not limit the specific types of the terminal devices.
The embodiment of the present application further provides a computer-readable storage medium, where a computer program is stored, and when the computer program is executed by a processor, the computer program can implement the steps in the embodiments of the water affair data processing method described above.
The embodiment of the present application provides a computer program product, which when running on a mobile terminal, enables the mobile terminal to implement the steps in the foregoing water affair data processing method in each embodiment when executed.
The integrated unit, if implemented in the form of a software functional unit and sold or used as a stand-alone product, may be stored in a computer readable storage medium. Based on such understanding, all or part of the processes in the methods of the embodiments described above can be implemented by a computer program, which can be stored in a computer-readable storage medium and can implement the steps of the embodiments of the methods described above when the computer program is executed by a processor. Wherein the computer program comprises computer program code, which may be in the form of source code, object code, an executable file or some intermediate form, etc. The computer readable medium may include at least: any entity or device capable of carrying computer program code to a photographing apparatus/terminal apparatus, a recording medium, computer Memory, Read-Only Memory (ROM), Random Access Memory (RAM), an electrical carrier signal, a telecommunications signal, and a software distribution medium. Such as a usb-disk, a removable hard disk, a magnetic or optical disk, etc. In certain jurisdictions, computer-readable media may not be an electrical carrier signal or a telecommunications signal in accordance with legislative and patent practice.
In the above embodiments, the descriptions of the respective embodiments have respective emphasis, and reference may be made to the related descriptions of other embodiments for parts that are not described or illustrated in a certain embodiment.
Those of ordinary skill in the art will appreciate that the various illustrative elements and algorithm steps described in connection with the embodiments disclosed herein may be implemented as electronic hardware or combinations of computer software and electronic hardware. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the implementation. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present application.
In the embodiments provided in the present application, it should be understood that the disclosed apparatus/network device and method may be implemented in other ways. For example, the above-described apparatus/network device embodiments are merely illustrative, and for example, the division of the modules or units is only one logical division, and there may be other divisions when actually implementing, for example, a plurality of units or components may be combined or integrated into another system, or some features may be omitted, or not implemented. In addition, the shown or discussed mutual coupling or direct coupling or communication connection may be an indirect coupling or communication connection through some interfaces, devices or units, and may be in an electrical, mechanical or other form.
The units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of network units. Some or all of the units can be selected according to actual needs to achieve the purpose of the solution of the embodiment.
The above-mentioned embodiments are only used for illustrating the technical solutions of the present application, and not for limiting the same; although the present application has been described in detail with reference to the foregoing embodiments, it should be understood by those of ordinary skill in the art that: the technical solutions described in the foregoing embodiments may still be modified, or some technical features may be equivalently replaced; such modifications and substitutions do not substantially depart from the spirit and scope of the embodiments of the present application and are intended to be included within the scope of the present application.
Claims (9)
1. A water affair data processing method is characterized by comprising the following steps:
acquiring a water affair data message uploaded by data acquisition equipment; the water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code;
determining a software protocol code corresponding to the hardware protocol code according to a preset communication protocol corresponding relation; the communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence;
generating a unique acquisition identifier corresponding to the water affair data according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code;
determining a water service equipment identifier according to a data acquisition equipment identifier, a data acquisition channel identifier and a preset first corresponding relation, and establishing an association relation between the water service equipment identifier and the unique acquisition identifier; the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier; determining a water service device identifier corresponding to the data acquisition device identifier and the data acquisition channel identifier in the first corresponding relation; associating the unique collection identification with the determined water service equipment identification;
and storing the water affair data and the corresponding association relation in a database.
2. The water data processing method of claim 1, wherein the method further comprises:
acquiring each water affair device and each data acquisition device in a target area; each data acquisition device comprises a plurality of data acquisition channels, and each water affair device corresponds to one data acquisition channel;
and establishing the first corresponding relation among the water service equipment, the data acquisition equipment and the data acquisition channel.
3. The water data processing method of claim 1, wherein the water data includes a parameter type, the method further comprising:
acquiring all hardware protocols corresponding to the water affair data of various parameter types acquired by the data acquisition equipment; each hardware protocol corresponds to a hardware protocol code;
respectively setting a corresponding software protocol for each hardware protocol; each software protocol corresponds to a software protocol code;
and forming the corresponding relation of the communication protocols according to the corresponding relation between each hardware protocol and each software protocol.
4. The water affair data processing method according to claim 1, wherein generating a unique collection identifier corresponding to the water affair data according to a data collection device identifier, a data collection channel identifier, and a software protocol code comprises:
combining a data acquisition equipment identifier, a data acquisition channel identifier and a software protocol code to obtain a unique acquisition identifier corresponding to the water affair data; or
And correspondingly setting a unique acquisition identifier consisting of numbers and/or letters for each group of data acquisition equipment identifier, data acquisition channel identifier and software protocol code.
5. The water data processing method of claim 1, wherein the water data comprises parameter types, values and acquisition times, the method further comprising:
acquiring an abnormal detection request, wherein the abnormal detection request comprises a target water service equipment identifier;
determining a target association relation containing the target water affair identifier in the database;
and acquiring the parameter type, the value and the acquisition time of the water service data corresponding to the target association relation, and determining whether the water service equipment corresponding to the target water service equipment identification is abnormal or not based on the parameter type, the value and the acquisition time.
6. The water affairs data processing method according to claim 5, wherein the determining whether an abnormality exists at a water affairs device corresponding to the target water affairs device identification based on the parameter type, the value, and the collection time includes:
acquiring a preset value range and a preset time period corresponding to the target water service equipment identification;
determining a value corresponding to the time and the preset value range according to the acquisition time and the preset time period;
and when the value corresponding to the time exceeds the preset value range, determining that the water service equipment corresponding to the target water service equipment identification is abnormal.
7. A water service data processing apparatus, comprising:
the message acquisition module is used for acquiring the water affair data message uploaded by the data acquisition equipment; the water affair data message comprises water affair data, a data acquisition equipment identifier, a data acquisition channel identifier and a hardware protocol code;
the software protocol code determining module is used for determining a software protocol code corresponding to the hardware protocol code according to a preset communication protocol corresponding relation; the communication protocol corresponding relation comprises hardware protocol codes and software protocol codes which are in one-to-one correspondence;
the acquisition identifier generation module is used for generating a unique acquisition identifier corresponding to the water service data according to the data acquisition equipment identifier, the data acquisition channel identifier and the software protocol code;
the incidence relation establishing module is used for determining a water service equipment identifier according to the data acquisition equipment identifier, the data acquisition channel identifier and a preset first corresponding relation and establishing the incidence relation between the water service equipment identifier and the unique acquisition identifier; the first corresponding relation comprises a corresponding water service equipment identifier, a corresponding data acquisition equipment identifier and a corresponding data acquisition channel identifier; determining a water service device identifier corresponding to the data acquisition device identifier and the data acquisition channel identifier in the first corresponding relation; associating the unique collection identification with the determined water service equipment identification;
and the storage module is used for storing the water affair data and the corresponding association relation into a database.
8. A terminal device comprising a memory, a processor and a computer program stored in the memory and executable on the processor, characterized in that the processor implements the method according to any of claims 1 to 6 when executing the computer program.
9. A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, carries out the method according to any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010453885.6A CN113032358B (en) | 2020-05-26 | 2020-05-26 | Water affair data processing method and device and terminal equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010453885.6A CN113032358B (en) | 2020-05-26 | 2020-05-26 | Water affair data processing method and device and terminal equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113032358A CN113032358A (en) | 2021-06-25 |
| CN113032358B true CN113032358B (en) | 2021-11-02 |
Family
ID=76458602
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010453885.6A Active CN113032358B (en) | 2020-05-26 | 2020-05-26 | Water affair data processing method and device and terminal equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113032358B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114971435B (en) * | 2022-08-01 | 2022-11-18 | 武汉易维科技股份有限公司 | Intelligent water affair cloud service method, device, equipment and medium |
| CN115685939A (en) * | 2022-11-04 | 2023-02-03 | 上海致景信息科技有限公司 | Preparation method, system, equipment and storage medium for pre-textile process monitoring |
| CN116630091B (en) * | 2023-07-20 | 2023-10-13 | 赛维斯智慧环境科技(山东)有限公司 | Industrial real-time data linkage analysis system |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109495492A (en) * | 2018-12-05 | 2019-03-19 | 四川奥地建筑设计有限公司 | Communication system for intelligent water utilities industry |
| CN110687865A (en) * | 2019-10-21 | 2020-01-14 | 福建锋冠科技有限公司 | Wisdom water utilities management platform |
Family Cites Families (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7218998B1 (en) * | 2005-07-11 | 2007-05-15 | Neale Stephen D | System and method for limiting power demand in an energy delivery system |
| US7664886B2 (en) * | 2006-09-08 | 2010-02-16 | Ricoh Co., Ltd. | System, method, and computer program product using an SNMP implementation to obtain vendor information from remote devices |
| JP5887851B2 (en) * | 2011-11-14 | 2016-03-16 | ソニー株式会社 | Specific device, control device, specific method, program, and specific system |
| CN108550034A (en) * | 2018-06-14 | 2018-09-18 | 赫普科技发展（北京）有限公司 | A kind of intelligent water meter system of the light wallet of band |
| CN109858725A (en) * | 2018-11-20 | 2019-06-07 | 华电电力科学研究院有限公司 | Collect regimental hydraulic power plant group economical operation integral system platform architecture |
-
2020
- 2020-05-26 CN CN202010453885.6A patent/CN113032358B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109495492A (en) * | 2018-12-05 | 2019-03-19 | 四川奥地建筑设计有限公司 | Communication system for intelligent water utilities industry |
| CN110687865A (en) * | 2019-10-21 | 2020-01-14 | 福建锋冠科技有限公司 | Wisdom water utilities management platform |
Non-Patent Citations (1)
| Title |
|---|
| "水务数字化管理模式在水务集团的应用";梅丹 等;《给水排水》;20141231;第395-397页 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113032358A (en) | 2021-06-25 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN113032358B (en) | Water affair data processing method and device and terminal equipment | |
| CN112788551B (en) | Message processing method and device, terminal equipment and storage medium | |
| CN110472109B (en) | Dynamic data quality analysis method and platform system | |
| CN107368500B (en) | Data extraction method and system | |
| CN109348434B (en) | Scene information sending method, sending device and terminal equipment | |
| CN111506641B (en) | Data management method, data acquisition platform, data management system and storage medium | |
| CN117892713A (en) | Method, device, electronic device and storage medium for determining report difference data | |
| CN116074215A (en) | Network quality detection method, device, equipment and storage medium | |
| CN111385379A (en) | Internet of things identification method and device for eSIM terminal | |
| CN112991578B (en) | Vehicle data stream processing method and device, electronic equipment and electronic control unit | |
| CN114115008A (en) | A method and system for data transmission of power equipment operation based on 5G network | |
| CN113794725A (en) | Electric digital data transmission method and system | |
| CN115001931B (en) | Message processing method, device, equipment, medium and program product | |
| CN114580674A (en) | Method for processing equipment operation information and electronic equipment | |
| CN113114718A (en) | Data transmission method and system in Internet of things, and Internet of things equipment and terminal | |
| CN113938926B (en) | Identification method, device, equipment, system and storage medium for 5G private network complaints | |
| CN115225609B (en) | User data processing method and device and server | |
| CN116303477B (en) | Method for processing data of energy consumption equipment | |
| CN113626296B (en) | A method, device and terminal for detecting system stability | |
| CN112199428B (en) | Application management system, method and terminal equipment of functional data block | |
| CN118828400A (en) | Tariff configuration method, device, equipment, medium and program product | |
| CN116804958A (en) | Freeswitch monitoring method and device | |
| CN108197346B (en) | Communication model synchronization method for main and standby heterogeneous systems based on open message bus | |
| CN115543445A (en) | Dynamic processing method and device for stream data, electronic equipment and storage medium | |
| CN114328664A (en) | Charging station operation and maintenance data acquisition method and system, electronic equipment and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| CP03 | Change of name, title or address |
Address after: 518000 3203, block D, building 1, Section 1, Chuangzhi Yuncheng, Liuxian Avenue, Xili community, Xili street, Nanshan District, Shenzhen, Guangdong Province Patentee after: Shenzhen Tuoan Trust Internet of Things Co.,Ltd. Address before: 518000 Tangtou community, Shiyan street, Bao'an District, Shenzhen City, Guangdong Province Patentee before: SHENZHEN ANSO MEASUREMENT & CONTROL INSTRUMENTS CO.,LTD. |
|
| CP03 | Change of name, title or address |