CN111611337B - Terminal data processing system - Google Patents
Terminal data processing system Download PDFInfo
- Publication number
- CN111611337B CN111611337B CN202010394749.4A CN202010394749A CN111611337B CN 111611337 B CN111611337 B CN 111611337B CN 202010394749 A CN202010394749 A CN 202010394749A CN 111611337 B CN111611337 B CN 111611337B
- Authority
- CN
- China
- Prior art keywords
- terminal
- time
- node
- priority
- terminals
- 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
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/29—Geographical information databases
-
- 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
- G06F16/2282—Tablespace storage structures; Management thereof
-
- 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/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
- G06F16/2462—Approximate or statistical queries
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F3/00—Input arrangements for transferring data to be processed into a form capable of being handled by the computer; Output arrangements for transferring data from processing unit to output unit, e.g. interface arrangements
- G06F3/14—Digital output to display device ; Cooperation and interconnection of the display device with other functional units
- G06F3/1454—Digital output to display device ; Cooperation and interconnection of the display device with other functional units involving copying of the display data of a local workstation or window to a remote workstation or window so that an actual copy of the data is displayed simultaneously on two or more displays, e.g. teledisplay
-
- G—PHYSICS
- G16—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
- G16H—HEALTHCARE INFORMATICS, i.e. INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR THE HANDLING OR PROCESSING OF MEDICAL OR HEALTHCARE DATA
- G16H50/00—ICT specially adapted for medical diagnosis, medical simulation or medical data mining; ICT specially adapted for detecting, monitoring or modelling epidemics or pandemics
- G16H50/80—ICT specially adapted for medical diagnosis, medical simulation or medical data mining; ICT specially adapted for detecting, monitoring or modelling epidemics or pandemics for detecting, monitoring or modelling epidemics or pandemics, e.g. flu
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Mining & Analysis (AREA)
- Public Health (AREA)
- Health & Medical Sciences (AREA)
- Software Systems (AREA)
- Probability & Statistics with Applications (AREA)
- Medical Informatics (AREA)
- Pathology (AREA)
- Fuzzy Systems (AREA)
- Biomedical Technology (AREA)
- Mathematical Physics (AREA)
- Computational Linguistics (AREA)
- Epidemiology (AREA)
- General Health & Medical Sciences (AREA)
- Primary Health Care (AREA)
- Human Computer Interaction (AREA)
- Remote Sensing (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention provides a terminal data processing system, which comprises a server, a database, a storage file and a storage medium for storing a computer program, wherein the server is in communication connection with the database; the database stores terminal data, and the terminal data comprise a terminal ID, a historical grid of the terminal, uploading time t1 of the historical grid, a WIFI-ID connected with the terminal and uploading time t2 of the WIFI-ID; the storage file stores M node terminals including terminal IDs, the M node terminals include N priorities, and the number of the x-th priority node terminals is MxThe node terminal in the x +1 th priority is determined according to the node terminal in the x-th priority; the storage file is also stored with a corresponding XiZ mesh sets and z WIFI sets.
Description
Technical Field
The invention relates to the technical field of computers, in particular to a terminal data processing system.
Background
With the development of computer technology, people often use computers to process and visually display related data. Existing data processing systems typically include a data input system, a processing subsystem, and an output display system. The input system can receive input data of a user, sensor data, data stored in a database and the like, the output display system is used for displaying data processing results to the user, and the processing subsystem is the core of the data processing system and comprises a processing server or a server cluster capable of running a data processing program.
With the increasing number of data records stored in a database, some data records can reach billion levels or higher orders of magnitude, data fields have more and more abundant dimensionalities, and some data records can reach thousand levels or higher orders, the incidence relation among different data records and/or fields is explored, data can be efficiently processed according to the incidence relation, and the method becomes a technical research focus of a data processing system.
In addition, data processing systems have been widely used in many areas of technology, but some areas of technology present new challenges. For example, in the field of research on the source tracing and genetic variation of infectious viruses, an important technical node is to acquire a virus propagation path and find a patient with a zero number and infectors such as generations 1, 2, 3 and 4, thereby realizing the source tracing of viruses. Furthermore, the genetic variation of the virus can be obtained by genetic analysis of virus samples of infected individuals of each generation. However, viruses similar to the 2019 novel coronavirus (2019-nCoV) have the characteristics of easy transmission, long latency period, existence of more asymptomatic infectors and the like, and the prior technical and non-technical means for acquiring a virus transmission path are difficult to deal with.
Disclosure of Invention
The technical problem is not solved, and the invention provides a terminal data system.
According to one aspect of the present invention, a data processing system includes a server, a database, a storage file, and a storage medium storing a computer program, the server being communicatively coupled to the database; the database stores terminal data, the terminal data comprises a terminal ID, a history grid of the terminal, uploading time t1 of the history grid, and the terminalConnected WIFI-ID and uploading time t2 of the WIFI-ID; the storage file stores M node terminals including terminal IDs, the M node terminals include N priorities, and the number of the x-th priority node terminals is MxThe node terminal in the x +1 th priority is determined according to the node terminal in the x-th priority; the storage file is also stored with a corresponding XiZ mesh sets and z WIFI sets. By executing the computer program, the invention can acquire and present the priority relations of different node terminals according to the data in the database and the storage file.
According to another aspect of the invention, in some application scenarios, these priority relationships identify particular virus propagation paths.
According to a further aspect of the invention, in some application scenarios, the mobile terminal held by an asymptomatic infected person of a particular virus can be obtained by a priority relationship.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the drawings that need to be used are briefly described below, and it is obvious that the drawings in the following description are only some embodiments of the present invention, and it is obvious for those skilled in the art that other drawings can be obtained according to these drawings without creative efforts.
FIG. 1 illustrates a node terminal according to one embodiment of the present invention;
FIG. 2A shows a treemap of an infection path tree according to one embodiment of the present invention;
FIG. 2B shows a treemap of an infection path tree according to another embodiment of the present invention;
FIG. 3 shows a treemap of an infection path tree according to yet another embodiment of the present invention.
Detailed Description
For better understanding of the technical solutions of the present invention, the following detailed descriptions of the embodiments of the present invention are provided with reference to the accompanying drawings. It should be understood that the described embodiments are only some embodiments of the invention, and not all embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
The terminology used in the embodiments of the invention is for the purpose of describing particular embodiments only and is not intended to be limiting of the invention. As used in the examples of the present invention and the appended claims, the singular forms "a," "an," and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise.
According to the invention, a terminal data processing system is provided, comprising a server, a database and a storage medium storing a computer program, wherein the server is connected with the database in a communication way. Those skilled in the art will appreciate that the server and database are not limited to a hardware device and/or a software device, and may be a server cluster, a storage cluster, or the like. In other words, any computing device or combination of computing devices capable of data processing can be considered a server, and any storage device or combination of storage devices capable of data storage can be considered a database. The server and the database may be separate devices or may share one or more separate devices.
Preferably, the server is further in communication connection with a plurality of mobile terminals, receives and processes data uploaded by the mobile terminals, and stores the processed data in the database. In one example, the mobile terminals in the database are on the order of billions to billions, and the mobile terminals upload data on a daily basis on the order of billions.
According to the invention, the uploading content uploaded to the server by the mobile terminal comprises the following steps: the terminal ID, the terminal position P, the WIFI-ID of the terminal connection and/or the uploading time t.
According to the invention, the data uploading mode of the mobile terminal comprises the following steps: configurable polling and/or interrupt modes. The polling mode is that the terminal uploads data to the server at regular intervals; the interruption mode is that data is uploaded to the server when the state of the terminal changes, for example, when the terminal is connected or disconnected to a certain WIFI-ID, or when the terminal is changed from the coverage of the base station a to the coverage of the base station b, or when the terminal starts or closes the APP. The present invention does not limit the uploading path of the terminal data. For example, the terminal information uploaded by the APP installed in the mobile terminal, or the terminal information uploaded by the base station through which the mobile terminal is connected to the base station via communication, or the terminal information uploaded by the SDK integrated in the APP in the mobile terminal, etc. may be used. Illustratively, the travel APP identifies and uploads the real-time position of the mobile terminal in the process of using the travel APP by the mobile terminal.
According to the present invention, the terminal ID is a unique code that can be used to distinguish different mobile terminals. Illustratively, the terminal ID may be any one of or a combination of an IMEI, an IMSI, a MAC address, a SIM card number of the mobile terminal, or any one of or a combination of an IMEI, an IMSI, a MAC address, a SIM card number of the mobile terminal that is encrypted (e.g., MD5 encrypted).
According to the present invention, the terminal position P may be obtained by any one or any combination of the following: (1) obtaining through a GPS of the mobile terminal; (2) obtaining through WIFI connected or scanned by the mobile terminal; (3) and obtaining the data through a base station connected with the mobile terminal. The format of the terminal position P may be a longitude and latitude coordinate of the terminal, or a geographical grid, such as a Geohash grid, obtained by transforming the longitude and latitude coordinate.
According to the invention, the sampling characteristics of the data uploaded to the server by the mobile terminal comprise: first, a high sampling rate, about 30% in the "daily" time period, and more than 80% in the "monthly" time period. Secondly, sampling is uneven and is influenced by the use condition and environment of the mobile terminal, for example, the terminal position P is uploaded once in a few seconds during map navigation; when the mobile terminal is not used, the data is uploaded for one time within 0.5-2 hours; where the signal is not good, data will not be uploaded, etc.
Preferably, the processing of the uploaded data by the server includes:
and S1, merging the terminal IDs, namely merging the terminal IDs which often and simultaneously appear at the nearby position into one terminal ID, and eliminating the conditions of one-man double-machine/multiple-machine/testing machine/engineering machine/mobile phone farm and the like. The specific combination method can be carried out by adopting the prior art mode or the technology specific to the applicant.
And S2, performing lossy compression on the uploaded data according to the preset grids and the preset time period. When the uploaded terminal position P is a longitude and latitude coordinate, coordinate transformation can be performed according to the terminal position P to determine a unique grid, and the invention does not exclude that the terminal completes coordinate transformation locally before uploading. The time period is a configurable time period, preferably 1 hour, namely 00:00:00-00:00:59 is a first time period, 01:00:00-01:00:59 is a second time period, and the like; of course, it may be 0.5 hour, 2 hours, 24 hours (i.e., days), etc.
In the present invention, unless otherwise defined or specifically indicated: the term "grid" refers to a rectangular arrangement of geospatial regions; the grid is preferably a Geohash grid or a plurality of adjacent Geohash grids, for example, a 7-bit or 8-bit Geohash grid, which is uniquely identified as a 7-bit or 8-bit string. In an exemplary embodiment, the grid is a 7-bit Geohash grid, and in another exemplary embodiment, the grid is two adjacent 8-bit Geohash grids forming (approximate) squares. A "grid set" refers to one or more grids that do not have overlapping geospatial regions, e.g., the same grid exists between two grid sets, and an intersection can be considered to exist between the two grid sets. "region" may refer to an administrative area, such as Beijing; it is also possible that only user-defined areas, such as areas that the user has circled on the electronic map; for the administrative region, the terminal data processing system stores the mapping relation between the administrative region and the grid set, such as the grid set corresponding to Beijing City; for a user-defined region, the terminal data processing system may convert the region into a corresponding plurality of grid sets via a coordinate transformation program.
The lossy compression method is to compress a plurality of pieces of data, which are processed in S1 and appear in the same mesh in the same time slot, into one piece of data, and to compress a plurality of pieces of data, which are connected to the same WIFI-ID in the same time slot, into one piece of data. For example, the data uploaded by the terminal ID1 (illustrated in cvs format) includes:
1. ID1, XXXX, XX, month XX, 07:00:03, P1;
2. ID1, XXXX, XX, month XX, 07:10:23, P2;
3. ID1, XXXX, XX, month XX, 07:33:26, P3.
If P1, P2, P3 are located within the same geographic grid G1, data 1-3 are compressed as:
1. ID1, XXXX, XX, month XX, day 07, G1.
The upload data, post-processed through step S2, may be stored in a database. That is, the database stores the terminal ID (for example, ID1) of the mobile terminal, the terminal history grid (for example, G1) corresponding to the terminal location P, and the upload time t1 of the history grid (for example, XXXX month XX day 07 in XXXX year).
After the lossy compression processing in step S2, the following technical effects can be achieved: (1) the data volume is greatly reduced, the storage space is saved, and the query efficiency is improved; (2) the time in the data is changed from variable length to fixed length, and the query and processing efficiency is improved.
The processing mode of the WIFI-ID is similar to that of the WIFI-ID, and is not described in detail.
And S3, forming the data after lossy compression into terminal data and storing the terminal data in a database. The terminal data includes: the method comprises the steps of a terminal ID, a terminal historical grid, uploading time (section) t1 of the historical grid, WIFI-ID connected with the terminal and uploading time (section) t2 of the WIFI-ID. The database can be stored by adopting the existing database, such as the database comprising Hbase supporting the column family; the mobile terminal location data may be stored in one table or in a plurality of data tables associated with each other, and the present invention is not limited to a specific storage method.
It is apparent that the server may back up the original data to a database or other database before lossy compression.
In the present invention, the detailed description will be given by way of a plurality of embodiments, and the technical contents of the embodiments are cited as each other unless otherwise specified.
Example one
According to the invention, the terminal data processing system further comprises a storage file. It will be appreciated by those skilled in the art that the storage file may be stored on any type of media, including media that is not lost after a power outage, such as a hard disk, and also includes mechanisms that are lost after a power outage, such as memory. It will also be understood by those skilled in the art that the type of file and the file storage format in which the file is stored do not limit the scope of the present invention.
Further, the storage file stores M node terminals including terminal IDs, the M node terminals include N priorities, and the number of the node terminals with the xth priority is MxThe node terminal in the x +1 th priority is determined according to the node terminal in the x priority, the value of x is 0 to N-1, the value of N is more than or equal to 1, and
for the propagation of a particular virus, for example a 2019 new coronavirus (hereinafter 2019-nCoV), the node terminal may be an infected terminal. According to the invention, the infected terminal can be a mobile terminal designated by a user; generally, a user can designate a terminal carried by a medically diagnosed specific virus infected person within a time window; a mobile terminal that an infected person has the rights to but does not carry with him within a time window would not be considered an infected terminal. For example, if the time window is 2 months 1 day to 14 days and the infected person changes the old mobile terminal a to the new mobile terminal B on 2 months 15 days, the mobile terminal a can be regarded as the infected terminal and B cannot be regarded as the infected terminal. The priority of the node terminals may be set to the transmission agent of the virus between the terminal holders. For ease of understanding, M node terminals may be illustrated in fig. 1, for example. Those skilled in the art will appreciate that the dissemination agent is only one exemplary scenario application of the node terminal priorities and does not mean that the priorities can only be applied to the dissemination agent.
Further, the node terminal of the 0 th priority is determined according to the user input. Because the node terminal in the x +1 priority is determined according to the node terminal in the x priority, after the user inputs the node of the 0 priority, the node of the 1 priority can be recursively acquired, the node of the 2 priority can be recursively acquired according to the node of the 1 priority, and the node of the N priority can be recursively acquired.
Further, the storage file also stores the data corresponding to XiZ mesh sets and z WIFI sets, XiFor the ith node terminal in the x-th priority, the value of i is 1 to Mx. Wherein, z is TL1/TL2, TL1 is the time length of the time window, TL2 is the time length of the time unit. As can be seen, the time window comprises z time units.
Further, the duration TL1 of the time window may be input or specified by the user. Preferably, however, TL1 is determined by the latency of a medically recognized specific virus, which may be set to 14 days, for example, for 2019-nCoV, or to a slightly longer time than 14 days.
Further, the start time of the time window may be set to the current time minus the duration. According to the invention, the current time has the following characteristics: the first, current time is the time that can be received and processed by the terminal data processing system specified by the user, and the current time may be input by the user through an input device, or may be automatically obtained by the terminal data processing system, for example, from a time server. Secondly, the units of the current time are consistent with the units of the time window, such as all "days" or all "hours" and the like; if the current time input by the user or the automatically acquired current time is not consistent with the unit of the time window, the unit can be converted into consistency by adopting any time unit conversion method. It is noted that the current time is not absolutely "that day", "today", or "then-day", for example, today is 20/2/2020, and the current time may be 15/2/2020. For the propagation agent of 2019-nCoV, the current time may be set to the time when the infected terminal holder is medically diagnosed or medically proven to present an infection symptom (i.e., node symptom time st); obviously, for any node terminal, the node symptom time st may be determined according to user input, and the starting time of the time window may be determined according to the node symptom time st and the duration of the time window. In this application scenario, for M node terminals, there may be a maximum starting time that does not exceed M time windows.
Further, the duration TL2 of the time unit may also be input or specified by the user. Preferably, however, TL2 is determined by the survival time of the medically recognized specific virus, more preferably, TL2 is positively correlated with (and exceeds) the survival time of the medically recognized specific virus; i.e. the longer the survival time, the larger the TL2, the shorter the survival time, the smaller the TL 2. Further, the TL2 is also related to the sampling rate of data uploaded by the mobile terminal to the server; for example, the higher the sampling rate, the smaller the difference between TL2 and time-to-live, the lower the sampling rate, and the larger the difference between TL2 and time-to-live.
Further, each grid set comprises historical grids matched with the corresponding time unit at the uploading time t1, and each WIFI set comprises WIFI-IDs matched with the corresponding time units at the uploading time t 2.
Further, the size of the history grid may be input or specified by a user. Preferably, however, the size of the history grid is determined according to the propagation distance of the medically recognized specific virus, and more preferably, the size of the history grid is positively correlated with the propagation distance of the medically recognized specific virus; i.e., the farther the propagation distance, the larger the history grid, and the closer the propagation distance, the smaller the history grid. Furthermore, the size of the historical grid is also related to the sampling rate of data uploaded to the server by the mobile terminal; for example, the higher the sampling rate, the closer the size of the history grid is to the propagation distance, and vice versa. For 2019-nCoV, the history grid may be set to a square or near-square contiguous 8-bit Geohash grid, as an example.
For convenience of technical understanding, for example, when the time window is from 0 at 3 month and 1 day of 2020 to 23 at 3 month and 14 days of 2020, TL1 is 14 days, and TL2 is 1 hour, the value of z is 336, that is, each of the M node terminals corresponds to 336 mesh sets and 336 WIFI sets. The grid set 1 includes historical grids when t1 is 3, month, 1 and 00 in 2020, the WIFI set 1 includes WIFI-IDs when t2 is 3, month, 1 and 00 in 2020, and so on, the grid set 336 includes zero, one or more historical grids when t1 is 3, month, 14 and 23 in 2020, and the WIFI set 336 includes zero, one or more WIFI-IDs when t2 is 3, month, 14 and 23 in 2020.
Further, the server executes the computer program to acquire the node terminal with the x +1 th priority from the x-th priority, wherein the processing for any node terminal S not belonging to the 0-x-th priority comprises the following steps:
s100, searching the database for X corresponding to the terminal S according to the terminal IDiA grid set and a WIFI set of time windows.
S120, at S1jAnd XiHas an intersection, or at S2jAnd XiWhen the jth WIFI set has an intersection, the node terminal S is used as the node terminal with the x +1 priority; wherein, S1jUpload time t1 and X for terminal SiThe j-th time cell matched grid set in the time window of (1), S2jUpload time t2 and X for terminal SiThe value range of j is j1 to j2, and j1 is greater than or equal to 1.
In one embodiment, the number of the mesh sets and the WIFI sets in step S100 may be z. Illustratively, the example of 2019-nCoV continues, as XiThe time of the symptoms of obvious virus infection is 2 months and 15 days, the diagnosis time is 2 months and 20 days, but 2 months and 15 days to 19 days are in a medical isolation state, and XiMay be set to 2 months 1 day-2 months 14 days, and in the case of a time unit of 1 hour, z is 336. Time unit of terminal S at 2 months 2 days 08 and XiLocated on the same grid or connected to the same WIFI, i.e. terminals S and XiHas an intersection, which indicates that the holder of the terminal S has a higher probability of being X-connectediSo that the node terminal S is regarded as the node terminal of the x +1 th priority.
Obviously, in this embodiment, the node terminal of the x +1 th priority can be efficiently acquired. But the following situations, which may occur in small numbers, cannot be handled more accurately: such as XiThe time window of (1) is 2 months to 14 months, the node symptom time of S is 2 months to 20 days, then 2 months to 1 day to 6 days, even if S and X areiThe existence of intersection of S also cannot indicate that the holder of S has a high probability of being XiInfection of the holder of (1); as another example, XiThe time window of (A) is 2 months 1 day to 2 months 14 days, and the node symptom time of S is 2 months 10 days, then it is clear that 2 months 11 days to 14 days, even if S and X areiThe existence of intersection of S also cannot indicate that the holder of S has a high probability of being XiIs infected by the holder of (1).
Therefore, in another embodiment, the number of the grid sets and the WIFI sets in step S100 may be j2-j1+ 1. Further, j1 and/or j2 are based on node terminal S and/or XiThe node symptom time st of (1). For example, j1 is based on node terminals S and XiThe later node symptom time st and the duration TL1 of the time window, j2 is determined according to the node symptom time st of the node terminal S.
S140, optionally, associating the storage node terminal S, XiAnd the jth time cell.
According to the present invention, after the user inputs the node terminal with the 0 th priority, the steps S100 to S140 are performed in a loop, and N priorities of M node terminals can be obtained.
According to the invention, the execution of the computer program by the server also realizes the following steps:
s200, mixing M (or)) The node terminals are presented to the user in the form of a tree graph comprising M0Root node, leaf node of N-1 layer.
As shown in fig. 2A, the root node corresponds to a node terminal presenting a 0 th priority, and the xth leaf node corresponds to a node terminal presenting an xth priority. And the connection between the nodes is determined according to the node terminals and the time units which are stored in an associated mode. Optionally, a connection line between the nodes is marked with a propagation time determined according to the time unit.
Further, when a user operates a node terminal on the tree diagram (for example, touches, clicks or mouse-hovers a humanoid graphic element in fig. 2A), the user may be presented with relevant information of the node terminal; when the user operates the relationship of the node terminals on the tree graph (e.g., touches, clicks, or mouse-hovers the directional line segment primitive in fig. 2A), the user may be presented with the time units of the two node terminals stored in association in step S140.
Further, in the step S120, if the terminals S and X are connectediWhen the grid sets corresponding to the multiple time units have an intersection, the directed line segment primitives of the two node terminals are optionally thickened, as shown by the 1 st node of the 0 th priority and the 1 st node of the 1 st priority in fig. 2A.
According to the present invention, optionally, in the step S120, if the terminals S and X are connectediHave an intersection with the grid set corresponding to the multiple time cells, then the S and X are obtainediThe earliest time unit tu1 of the plurality of time units; in step S140, the storage node terminal S, X is associated withiAnd time unit tu 1.
According to the present invention, preferably, in step S120, if the terminal S has an intersection with the grid sets corresponding to the time cells of the terminals in the xth priority level, the earliest time cell tu2 of the time cells of the terminal S and the terminals in the xth priority level is obtained; in step S140, the storage node terminal S, X is associated withi0And time unit tu2, where Xi0Is the terminal in the xth priority corresponding to tu 2. For high-infectivity viruses similar to 2019-nCoV, by adopting the preferred mode, the node terminal with the x +1 th priority can be more accurately known by taking the earliest time of intersection existence as the infection time. As shown in fig. 2A, the 2 nd node terminal of the 1 st priority and the 3 rd node terminal of the 2 nd priority intersect with the node terminals of the two previous priorities, and according to the preferred embodiment, only the terminal corresponding to the earliest time unit tu2 is retained. In the preferred mode, the propagation path can be accurately acquired for the high-infectivity virus similar to 2019-nCoV.
By executing the computer program, the invention can acquire and present the priority relations of different node terminals according to the data in the database and the storage file, and in some application scenes, the priority relations mark virus propagation paths.
Example two
Continuing and according to the first embodiment, after completing the processing of the M node terminals, optionally, the M node terminals are divided into two types, i.e., a first node terminal E1 and a second node terminal E2, E1 is a terminal with N priorities among the M node terminals (for example, may be presented on the propagation path tree diagram of fig. 2A or 2B), and E2 is a terminal without N priorities among the M node terminals (for example, is not presented on the propagation path tree diagram of fig. 2A or 2B). Obviously, E1 and E2 may include zero, one or more node terminals, and the sum of the number of node terminals in E1, E2 is M.
When E1 and E2 each include at least one node terminal, according to the present invention, the server executes the computer program to acquire the ith first node terminal E1iAnd a jth second node terminal E2jThe specific processing of the associated relay node terminal comprises the following steps:
s400, according to E1iIn the database, search for the terminal ID corresponding to E1iA first set of intermediate terminals of the time window of (a); wherein each terminal in the k1 th first intermediate terminal set satisfies the following condition: at E1iThe k1 th time unit of the time window of (1) is matched with the uploading time t1, and the historical grid set corresponding to the terminal ID is matched with the E1iThe history grid sets corresponding to the terminal IDs have intersection; and/or, at E1iThe k1 th time unit of the time window is matched with the uploading time t2, and the WIFI set corresponding to the terminal ID is matched with the E1iThe WIFI sets corresponding to the terminal IDs have intersection.
S420, similar to S400, according to E2jCorresponding to E2 in the databasejA second set of intermediate terminals of the time window of (a); wherein each terminal in the k2 th second set of intermediate terminals satisfies the following condition: at E2jThe k2 th time unit of the time window of (1) is matched with the uploading time t1, and the historical grid set corresponding to the terminal ID is matched with the uploading time E2jThe history grid sets corresponding to the terminal ID have intersection(ii) a And/or, at E2jThe k2 th time unit of the time window is matched with the uploading time t2, and the WIFI set corresponding to the terminal ID is matched with the E2jThe WIFI sets corresponding to the terminal IDs have intersection.
S440, acquiring the relay node terminal according to the first and second intermediate terminal sets; the relay node terminal is a node terminal which exists in an l1(1 & ltl 1 & lt z & gt) th first intermediate terminal set and exists in an l2(1 & ltl 2 & lt z & gt) th second intermediate terminal set, wherein a time unit corresponding to the l1 th first intermediate terminal set is earlier than a time unit corresponding to the l2 th second intermediate terminal set.
Further, the number of the first and second intermediate terminal sets in steps S400 and S420 may be z, where 1 ≦ k1 ≦ z, and 1 ≦ k2 ≦ z.
Further, in step S440, the time unit corresponding to the l1 th first intermediate terminal set and the time unit corresponding to the l2 th second terminal set are both in E1iNode symptom time sum of E2jThe node symptom time of (a) is less advanced.
S460, optionally, storing the first node terminal, the second node terminal, the relay node terminal, and the time units corresponding to the l1 th first intermediate terminal set and the l2 th second intermediate terminal set in an associated manner.
According to the present invention, by performing steps S400-S440 in a loop, all relay node terminals of E1 and E2 can be acquired.
For the propagation of a particular virus, e.g., 2019-nCoV, the relay node terminal has a higher probability of being a mobile terminal used by an asymptomatic infected person. Therefore, the invention can provide a technical scheme for accurately assisting in obtaining the mobile terminal used by the asymptomatic infected person.
Further, on the basis of S200, the server executing the computer program further realizes the following steps:
and S500, presenting the relay node terminal and the second node terminal on the tree diagram in a page node mode. The previous priority of the relay node terminal is the first node terminal, and the next priority of the relay node terminal is the second node terminal.
Further, the relay node terminal and the first and second node terminals are presented in different forms, for example, in different colors or shapes, so as to facilitate user identification. For example, the circular primitives shown in fig. 3 are relay node terminals.
It should be understood that the term "and/or" as used herein is merely a relationship that describes an associated object, meaning that three relationships may exist, e.g., a and/or B, may represent: a exists alone, A and B exist simultaneously, and B exists alone. In addition, the character "/" herein generally indicates that the former and latter related objects are in an "or" relationship.
It should be understood that although the terms first, second, etc. may be used to describe XXX in embodiments of the present invention, these XXX should not be limited to these terms. These terms are only used to distinguish XXX from each other. For example, a first XXX may also be referred to as a second XXX, and similarly, a second XXX may also be referred to as a first XXX, without departing from the scope of embodiments of the present invention.
It should be understood that although the steps are numbered in the present invention, these numbers are for descriptive convenience only, and the sizes of the numbers cannot be understood as the order of execution of the steps in the case of not being explicitly indicated or having a sequence relationship technically necessary.
The word "if" as used herein may be interpreted as "at … …" or "when … …" or "in response to a determination" or "in response to a detection", depending on the context. Similarly, the phrases "if determined" or "if detected (a stated condition or event)" may be interpreted as "when determined" or "in response to a determination" or "when detected (a stated condition or event)" or "in response to a detection (a stated condition or event)", depending on the context.
In the embodiments provided in the present invention, it should be understood that the disclosed system, apparatus and method may be implemented in other ways. For example, the above-described apparatus embodiments are merely illustrative, and for example, the division of the units is only one type of logical functional division, and other divisions may be realized in practice, for example, multiple units or components may be combined or integrated into another system, or some features may be omitted, or not executed. 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.
In addition, functional units in the embodiments of the present invention may be integrated into one processing unit, or each unit may exist alone physically, or two or more units are integrated into one unit. The integrated unit can be realized in a form of hardware, or in a form of hardware plus a software functional unit.
The integrated unit implemented in the form of a software functional unit may be stored in a computer readable storage medium. The software functional unit is stored in a storage medium and includes several instructions for causing a computer device (which may be a personal computer, a server, or a network device) or a Processor (Processor) to execute some steps of the methods according to the embodiments of the present invention. And the aforementioned storage medium includes: a U-disk, a removable hard disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a magnetic disk, an optical disk, or other various media capable of storing program codes.
The above description is only for the purpose of illustrating the preferred embodiments of the present invention and is not to be construed as limiting the invention, and any modifications, equivalents, improvements and the like made within the spirit and principle of the present invention should be included in the scope of the present invention.
Claims (9)
1. A terminal data processing system comprises a server, a database, a storage file and a storage medium storing a computer program, wherein the server is in communication connection with the database; it is characterized in that the preparation method is characterized in that,
the database stores terminal data, and the terminal data comprise a terminal ID, a historical grid of the terminal, uploading time t1 of the historical grid, a WIFI-ID connected with the terminal and uploading time t2 of the WIFI-ID;
the storage file stores M node terminals including terminal IDs, the M node terminals include N priorities, and the number of the x-th priority node terminals is MxThe node terminal in the x +1 th priority is determined according to the node terminal in the x priority, and the value of x is 0 to N-1;
the storage file also stores the data corresponding to Xiz-TL 1/TL2, TL1 being the duration of a time window, TL2 being the duration of a time unit, said time window comprising z time units; each grid set comprises historical grids matched with corresponding time units at uploading time t1, and each WIFI set comprises WIFI-IDs matched with corresponding time units at uploading time t 2; xiFor the ith node terminal in the x-th priority, the value of i is from 1 to MxThe time length TL1 of the time window is determined according to the latency time of the medically recognized specific virus, the time length TL2 of the time unit is determined according to the survival time of the medically recognized specific virus, and the size of the historical grid is determined according to the propagation distance of the medically recognized specific virus;
the server executes the computer program to acquire the node terminal with the x +1 th priority from the x-th priority, wherein the processing for any node terminal S which does not belong to the 0-x-th priority comprises the following steps:
s100, searching the database for X corresponding to the terminal S according to the terminal IDiA mesh set and a WIFI set of the time window of (a);
s120, at S1jAnd XiHas an intersection, or at S2jAnd XiWhen the jth WIFI set has an intersection, the node terminal S is used as a node terminal with the x +1 priority; wherein, S1jUpload time t1 and X for terminal SiThe j-th time cell matched grid set in the time window of (1), S2jUpload time t2 and X for terminal SiThe value range of j is j1 to j2, and j1 is more than or equal to 1;
s140, associating storage node terminal S, XiAnd the jth time cell.
2. The terminal data processing system of claim 1, wherein the node terminal further comprises a node symptom time st, the node symptom time st determined from user input;
the starting time of the time window is determined according to the node symptom time and the duration of the time window.
3. The terminal data processing system of claim 2, wherein in step S120, if the terminals S and X are in the same stateiHave an intersection with the grid set corresponding to the multiple time cells, then the S and X are obtainediThe earliest time unit tu1 of the plurality of time units; in step S140, the storage node terminal S, X is associated withiAnd time unit tu 1.
4. The terminal data processing system according to claim 2, wherein in step S120, if terminal S has an intersection with the grid sets corresponding to the time cells of the plurality of terminals in the x-th priority, the earliest time cell tu2 of the time cells of terminal S and the plurality of terminals in the x-th priority is obtained; in step S140, the storage node terminal S, X is associated withi0And time unit tu2, where Xi0Is the terminal in the xth priority corresponding to tu 2.
5. A terminal data processing system according to any one of claims 2-3, wherein execution of the computer program by the server further effects the steps of:
s200, presenting M node terminals to a user in a tree diagram form, wherein the tree diagram comprises M0Root nodes and leaf nodes of the N-1 layer;
the root node corresponds to a node terminal presenting the 0 th priority, and the x-th layer leaf node corresponds to a node terminal presenting the x-th priority;
and the connection between the nodes is determined according to the node terminals and the time units which are stored in an associated mode.
6. Terminal data processing system according to any of claims 2 to 4, characterized in that j1 and/or j2 are based on node terminals S and/or XiThe node symptom time st of (1).
7. The terminal data processing system of claim 6, wherein j1 is based on node terminals S and XiThe later node symptom time st and the duration TL1 of the time window.
8. The terminal data processing system of claim 6, wherein j2 is determined based on a node symptom time st of node terminal S.
9. A terminal data processing system according to any one of claims 1 to 4, characterised in that the node terminal of priority 0 is determined in response to user input.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010394749.4A CN111611337B (en) | 2020-05-11 | 2020-05-11 | Terminal data processing system |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202010394749.4A CN111611337B (en) | 2020-05-11 | 2020-05-11 | Terminal data processing system |
Publications (2)
Publication Number | Publication Date |
---|---|
CN111611337A CN111611337A (en) | 2020-09-01 |
CN111611337B true CN111611337B (en) | 2022-06-24 |
Family
ID=72200203
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202010394749.4A Active CN111611337B (en) | 2020-05-11 | 2020-05-11 | Terminal data processing system |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN111611337B (en) |
Families Citing this family (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN112383625B (en) * | 2020-11-16 | 2023-06-20 | 每日互动股份有限公司 | Regional population quantity prediction method, regional population quantity prediction device, computer equipment and storage medium |
Family Cites Families (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US20030105973A1 (en) * | 2001-12-04 | 2003-06-05 | Trend Micro Incorporated | Virus epidemic outbreak command system and method using early warning monitors in a network environment |
US7519726B2 (en) * | 2003-12-12 | 2009-04-14 | International Business Machines Corporation | Methods, apparatus and computer programs for enhanced access to resources within a network |
US7792776B2 (en) * | 2007-02-26 | 2010-09-07 | International Business Machines Corporation | System and method to aid in the identification of individuals and groups with a probability of being distressed or disturbed |
CN103841255A (en) * | 2012-11-27 | 2014-06-04 | 上海斐讯数据通信技术有限公司 | Mobile terminal and mobile terminal data access method |
CN106878445B (en) * | 2017-03-09 | 2020-09-11 | 腾讯科技(深圳)有限公司 | Resource file updating method and device |
-
2020
- 2020-05-11 CN CN202010394749.4A patent/CN111611337B/en active Active
Also Published As
Publication number | Publication date |
---|---|
CN111611337A (en) | 2020-09-01 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN107547633B (en) | User constant standing point processing method and device and storage medium | |
US9313233B2 (en) | Systems and methods for detecting associated devices | |
US10311747B2 (en) | Empirical expert determination and question routing system and method | |
US11755675B2 (en) | Method and apparatus for managing region tag | |
JP6689515B2 (en) | Method and apparatus for identifying the type of user geographic location | |
CN106210163B (en) | IP address-based localization method and device | |
CN101933026A (en) | Public information transmission method, public information transmission system, central processing unit, and program | |
WO2021114615A1 (en) | Method, apparatus, and device for visualization of behavior risk identification, and storage medium | |
CN111459723B (en) | Terminal data processing system | |
CN110807546A (en) | Community grid population change early warning method and system | |
CN111242723B (en) | User child and child condition judgment method, server and computer readable storage medium | |
CN109271453A (en) | A kind of determination method and apparatus of database volume | |
CN111611337B (en) | Terminal data processing system | |
US11075953B2 (en) | Cyber attack information processing apparatus and method | |
CN111611336B (en) | Terminal data processing system | |
WO2023087722A1 (en) | Object gathering method and apparatus, and electronic device and storage medium | |
CN104050168A (en) | Information processing method, electronic equipment and lexicon server | |
CN112507046B (en) | Terminal data processing system | |
CN111831760B (en) | Method of processing position data, corresponding device, computer readable storage medium | |
CN112507044B (en) | Terminal data processing system | |
CN112148818B (en) | Terminal data processing system | |
CN112507045B (en) | Terminal data processing system | |
CN110784891B (en) | Data processing method and device | |
CN112052302B (en) | Method, system, device and storage medium for dynamically generating position word stock | |
CN112507043B (en) | Terminal data processing system |
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 | ||
CB02 | Change of applicant information |
Address after: 310012 Room 418, West District, Building A, 525 Xixi Road, Xihu District, Hangzhou City, Zhejiang Province Applicant after: Daily interactive Co.,Ltd. Applicant after: Shulan (Hangzhou) hospital Co., Ltd Address before: 310012 Room 418, West District, Building A, 525 Xixi Road, Xihu District, Hangzhou City, Zhejiang Province Applicant before: ZHEJIANG MEIRI INTERDYNAMIC NETWORK TECHNOLOGY Co.,Ltd. Applicant before: Shulan (Hangzhou) hospital Co., Ltd |
|
CB02 | Change of applicant information | ||
GR01 | Patent grant | ||
GR01 | Patent grant |