[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

CN112148818B - Terminal data processing system - Google Patents

Terminal data processing system Download PDF

Info

Publication number
CN112148818B
CN112148818B CN202010394414.2A CN202010394414A CN112148818B CN 112148818 B CN112148818 B CN 112148818B CN 202010394414 A CN202010394414 A CN 202010394414A CN 112148818 B CN112148818 B CN 112148818B
Authority
CN
China
Prior art keywords
terminal
grid
area
region
infection
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Active
Application number
CN202010394414.2A
Other languages
Chinese (zh)
Other versions
CN112148818A (en
Inventor
叶新江
陈津来
董霖
尹雅露
宋明辉
方毅
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Merit Interactive Co Ltd
Original Assignee
Merit Interactive Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Merit Interactive Co Ltd filed Critical Merit Interactive Co Ltd
Priority to CN202010394414.2A priority Critical patent/CN112148818B/en
Publication of CN112148818A publication Critical patent/CN112148818A/en
Application granted granted Critical
Publication of CN112148818B publication Critical patent/CN112148818B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/29Geographical information databases
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/22Indexing; Data structures therefor; Storage structures
    • G06F16/2282Tablespace storage structures; Management thereof
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24Querying
    • G06F16/245Query processing
    • G06F16/2458Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
    • G06F16/2462Approximate or statistical queries
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F3/00Input 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/14Digital output to display device ; Cooperation and interconnection of the display device with other functional units
    • G06F3/1454Digital 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
    • GPHYSICS
    • G16INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
    • G16HHEALTHCARE INFORMATICS, i.e. INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR THE HANDLING OR PROCESSING OF MEDICAL OR HEALTHCARE DATA
    • G16H50/00ICT specially adapted for medical diagnosis, medical simulation or medical data mining; ICT specially adapted for detecting, monitoring or modelling epidemics or pandemics
    • G16H50/80ICT 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
    • YGENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
    • Y02TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
    • Y02DCLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
    • Y02D10/00Energy efficient computing, e.g. low power processors, power management or thermal management

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • Databases & Information Systems (AREA)
  • Data Mining & Analysis (AREA)
  • General Engineering & Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Health & Medical Sciences (AREA)
  • Public Health (AREA)
  • Probability & Statistics with Applications (AREA)
  • Medical Informatics (AREA)
  • Software Systems (AREA)
  • Computational Linguistics (AREA)
  • Mathematical Physics (AREA)
  • Biomedical Technology (AREA)
  • Fuzzy Systems (AREA)
  • Pathology (AREA)
  • Epidemiology (AREA)
  • General Health & Medical Sciences (AREA)
  • Primary Health Care (AREA)
  • Remote Sensing (AREA)
  • Human Computer Interaction (AREA)
  • Mobile Radio Communication Systems (AREA)
  • Telephonic Communication Services (AREA)

Abstract

The invention provides a terminal data processing system, which comprises a server, a database and a storage medium for storing a computer program, wherein the server is in communication connection with the database; the method is characterized in that terminal data are stored in the database, the terminal data comprise a terminal ID, a terminal historical grid, historical grid uploading time t1, a terminal connected WIFI-ID and WIFI-ID uploading time t2, and the server executes the computer program to complete corresponding steps and achieve corresponding functions.

Description

Terminal data processing system
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, 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, and when a relatively small amount of data is processed, almost all computing devices can process the data in real time.
However, in many application scenarios, a large amount of dynamic data needs to be processed, in such a scenario, real-time data related to processing each day reaches billions, real-time performance of a processing subsystem is greatly reduced, processing speed can be linearly increased by increasing the number of hardware or adopting higher-speed hardware equipment, and the problem of real-time performance is partially alleviated, but cost is greatly increased, and a large amount of time is required to be spent on arranging and debugging a large amount of newly added hardware equipment, so how to increase real-time performance of processing a large amount of dynamic data on existing hardware equipment becomes a technical problem to be solved urgently.
Disclosure of Invention
The embodiment of the invention provides a terminal data processing method and device, electronic equipment and a storage medium, and aims to solve the technical problems of low efficiency and accuracy of a mode for identifying people who go through a disaster area in the related art.
The invention provides a terminal data processing system, which comprises a server, a database and a storage medium for storing a computer program, wherein the server is in communication connection with the database; the method is characterized in that terminal data are stored in the database, the terminal data comprise a terminal ID, a terminal historical grid, historical grid uploading time t1, a terminal connected WIFI-ID and WIFI-ID uploading time t2, and the server executes the computer program to complete corresponding steps and achieve corresponding functions.
Through the technical scheme, whether all mobile terminals in the current geographical area pass through the historical positions in the designated geographical area or not in the designated time period can be automatically and efficiently judged, in other words, whether the holder of the mobile terminal automatically identified passes through the disaster area or not in the designated time period can be quickly and accurately judged. Therefore, the data processing efficiency is greatly improved, and the time cost and the labor cost are saved. Due to the fact that the time consumption of the technical scheme is shorter than that of a data processing mode in the related technology, the method and the device can adapt to real-time change of disaster area distribution, recognition of the object to be controlled can be carried out at any time according to the real-time change of the disaster area distribution, and efficiency and effectiveness of disaster management and control are greatly improved.
Detailed Description
In order to better understand the technical scheme of the invention, the following detailed description of the embodiment of the invention. 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, 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 or a combination of an IMEI, an IMSI, a MAC address, a SIM card number of the mobile terminal, and/or any one 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 0.5 to 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 periods can be configured, preferably configured to be 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 region; it is also possible that only user-defined areas, such as areas that the user has circled on the electronic map; for an administrative region, a mapping relation between the administrative region and a grid set is stored in a terminal data processing system; 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 uploaded 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 using the current database, such as a database including 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 present invention, the calculation and program stored in the storage medium include a first computer program. For each terminal data stored in the database, the server executes the first computer program to realize the following processing steps:
s102, a first grid set of terminal data is obtained, wherein the first grid set comprises historical grids of which the uploading time t1 is within a first historical time window. The first historical time window includes a start time and a time window length that may be specified by a user. For example, the first historical time window may be set to 5 days from day B of month a of XXXX to day B +5 of month a of XXXX, i.e., the starting time is day B of month a and the length is 5 days; the first historical time window may also be set to 24 hours XXXX year C month D day, i.e. a length of 24 hours when the starting time is C month D day 00. Preferably, the length of the first historical time window is determined according to the latency time of the infectious disease virus, and the length of the first historical time window is set to be 5 days; the start time of the first historical time window is set to the current time minus the length. 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 historical 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 historical time window, the unit can be converted into consistency by adopting any time unit conversion method. It is worth noting that the current time is not absolutely "that day", "today", or "then".
S104, when the intersection exists between the first grid set and the appointed grid set, the state of the mobile terminal is set as a first mark, otherwise, the state of the mobile terminal is set as a second mark. Wherein the specified set of grids includes grids of a specified geographic area. Further, the first and second marks are preferably bit marks, for example, the first mark may be 1, and the second mark may be 0; of course, the first flag and the second flag may also be set to any other type of flag.
S106, optionally, storing the terminal ID and the state association in the terminal data in the database.
As can be seen from steps S102 and S104, if the state of the mobile terminal is the first flag, that is, the first grid set and the designated grid set have an intersection, it is described that the mobile terminal uploaded the terminal position P within the designated geographical area within the first historical time window, and therefore, it is estimated that the owner of the mobile terminal has a very high probability of going through the designated geographical area within the first historical time window. Conversely, if the state of the mobile terminal is the second flag, that is, there is no intersection between the first grid set and the second grid set, it indicates that the mobile terminal has not uploaded the terminal location P in the specified geographic area in the first historical time window. Thus, it can be assumed that the holder of the mobile terminal has a very high probability of not having traveled the designated geographical area within the first historical time window.
According to the present invention, optionally, the database further associates and stores a terminal ID with a state of the first flag and a history grid ll (last location) that the mobile terminal last uploaded in the first history time window.
The server executing the first computer program further realizes the following processing steps:
s110, receiving a query area grid set input by a user; the query area is an area selected by a user.
And S112, in the database, if the LL of the terminal ID is located in the query area grid set and the state corresponding to the terminal ID is the first identifier, taking the terminal ID and/or the number of the terminal ID as a query result.
Because the processing of steps S102 and S104 is performed on the terminal data of hundred million to billion in the database, whether all mobile terminals in a certain geographic area upload past historical positions in a specified geographic area in a specified time period can be automatically and efficiently judged, the judgment efficiency is improved, the time is saved, and the method is more suitable for global real-time processing after a major event occurs.
For the purpose of facilitating an understanding of the invention, reference will now be made in detail to an exemplary application scenario. Those skilled in the art will appreciate that tables 1-4 in the application scenario are exemplary, and that data tables of other formats may be used in the present invention without affecting the scope of the present invention.
For example, day 6 of XXXX year a month, the status of all mobile terminals in the database is determined according to a first historical time window XXXX year a month 1 day to XXXX year a month 5 days and a specified geographical area.
In an optional embodiment, the database includes table 1, and the uploading time and the terminal history grid in the form of a data pair are stored, and subscripts of t and L in table 1 identify specific time and history grid. Obviously, as the mobile terminal uploads data in real time, the data pairs are also updated in real time.
TABLE 1
Terminal ID (upload time, terminal history grid)
ID1 (t 11 ,L 11 ),(t 12 ,L 12 ),……
ID2 (t 21 ,L 21 ),(t 22 ,L 22 ),……
…… ……
IDn (t n1 ,L n1 ),(t n2 ,L n2 ),……
For each terminal ID in the database, all the historical grids L corresponding to the terminal ID and having upload times within the period from XXXX year a month 1 to XXXX year a month 5 are obtained as a first grid set.
Likewise, a plurality of grids of the designated geographic area are grouped into a designated grid set.
If the first grid set and the designated grid set do not intersect, the state of the mobile terminal may be set to 0. If there is an intersection, the state of the mobile terminal may be set to 1.
To this end, the states of the mobile terminal may be added illustratively in table 1 of the database, forming table 2.
TABLE 2
Terminal ID (upload time, terminal history grid) Status of state
ID1 (t 11 ,L 11 ),(t 12 ,L 12 ),…… 0
ID2 (t 21 ,L 21 ),(t 22 ,L 22 ),…… 1
…… …… ……
IDn (t n1 ,L n1 ),(t n2 ,L n2 ),…… 1
A temporary data table in the format shown in table 3 may be additionally added to the database. Only the terminal ID and status are included in table 3.
TABLE 3
Figure GDA0002758880180000061
Figure GDA0002758880180000071
Preferably, the above steps may be automatically performed by the server starting every morning. The computing power of the server or server cluster is configured to process all terminal IDs in the completion database within a predetermined time (e.g., within about 4 hours) and obtain a corresponding status that data processing in days a-month 1-5 is completed in about 4:00 am, 6 days a-month.
Thus, by querying the status of each mobile terminal in the database, it can be determined whether the owner of the mobile terminal has traveled through the designated geographic area during the period from XXXX year a month 1 to XXXX year a month 5.
Further, in step 108, for each mobile terminal with state 1 in the database, the last uploaded history grid LL of the mobile terminal, that is, the terminal history grid with the latest uploading time in the data pair, is obtained according to the data pair in table 2, and the history grid is used as the current position of the mobile terminal, so as to form table 4. So far, there may be terminal IDs of the order of 1 to 10 billion in table 3, and only terminal IDs of specified geographical areas remain in table 4. Step 108 is also completed within the predetermined time.
TABLE 4
Terminal ID LL Status of state
ID2 LL 2 1
…… …… ……
IDn LL n 1
S110 may further include receiving a grid set corresponding to the query region input by the user. For example, the query area is selected by electronic map selection, so as to obtain the corresponding grid set.
S112 may further include retrieving in the LLs of Table 4 if a certain LL (e.g., LL) 2 ) In a grid set of query regions, then LL is obtained 2 The corresponding terminal ID2 as a result of the search.
The retrieval result can also comprise the number of the terminal IDs with the states of 1, and the number can identify the number of the mobile terminals which upload data in the designated geographic area from 1 day to 5 days of A month in the query area.
Through the technical scheme, the method comprises the following steps of 4: about 00 databases can be updated, so that in practical use, users in each province, city and county can query in the data table with the low order of magnitude of table 4, and how many people go through the query area can be obtained in real time. Therefore, the query efficiency is improved, and the query time is saved; the sampling rate is greatly improved, and the accuracy of the query result is improved accordingly.
Example two
In a first embodiment, the duration of the first historical time window is determined based on the latency of the infectious disease virus. With longer latency, daily updates require backtracking through all historical meshes of the past first historical time window. This puts a high demand on the computing power of the server, and to solve this technical problem, the present invention also provides an embodiment two.
According to the present invention, the first history time window is composed of a specified number of the plurality of second history time windows; preferably, the duration of the second historical time window is the same as the state update period of the terminal in the terminal data processing system. In an exemplary example, when the duration of the first historical time window is 5 days, the duration of the second historical time window may be set to be 1 day, that is, the state update period of the mobile terminal is 1 day.
Further, the storage medium further stores a second computer program, and the server executes the second computer program to realize the following processing steps:
s202, a second grid set of the terminal data is obtained, wherein the second grid set comprises historical grids which correspond to the terminal ID and are located in a second historical time window at the uploading time t 1.
S204, when the second grid set and the designated grid set have intersection, setting the state bit of the mobile terminal as a first mark, otherwise, setting the state bit as a second mark.
According to the invention, the number of bits of the status bits is the same as the specified number of the second historical time window, in the illustrative example the number of bits of the status bits is 5 bits.
For the convenience of understanding the technical solution of the present invention, the mobile terminal is still described by taking the example from XXXX year a month 1 to XXXX year a month 5. If the second historical grid set for day 3 of month A of the mobile terminal intersects the specified grid set, but there are no intersections for any other dates, then the status bit for the mobile terminal is "00100000000000".
S206, preferably, the first and second flags are bit flags, so that an or operation may be performed on status bits corresponding to all the second historical time windows in the first historical time window, and a result of the or operation is set as the status of the mobile terminal.
If the status bit is "00100000000000", the status bitwise or operation of the mobile terminal will result in "1".
Further, the server executing the second computer program further realizes the following updating steps:
and S208, acquiring a second historical time window of the previous updated mobile terminal state period which is not updated based on the current time. Continuing with the previous example, when the current time is XXXX year day 7/a month, the system updates the mobile terminal status in the database and may obtain a second historical time window that is not updated for day 6/a month.
S210, acquiring the historical grids of which the uploading time t1 of the terminal data is in the un-updated second historical time window as an un-updated second historical grid set.
S212, when the intersection exists between the second history grid set which is not updated and the appointed grid set, setting the newly added state bit of the mobile terminal as a first mark, otherwise, setting the newly added state bit as a second mark.
S214, deleting the first bit in the status bits of the mobile terminal.
For example, the aforementioned first historical grid set of the mobile terminal on day 6 of a month intersects with the second grid set, then "00100000000000" is updated to "0100000000001" through steps 212 and 214.
S216, optionally, performing a logical or operation on the updated status bit of the mobile terminal according to bits, thereby updating the status of the mobile terminal. Obviously, the state of the mobile terminal still comprises 5 first and second flags. If the status bit is "0100000000001", the status of the mobile terminal is "1".
Through the technical scheme, only the data of the mobile terminal in the second historical time window need to be backtracked for each updating, the data in the first historical time window does not need to be backtracked, and the data processing efficiency is further improved. As known to those skilled in the art, the query process after completing the status flag of the mobile terminal in the second embodiment is the same as that in the first embodiment, and is not described herein again.
EXAMPLE III
According to the present invention, the designated geographical area includes a target area, which is an area where an infectious disease virus begins to be prevalent. As virus spread progresses, the designated geographical area expands on a target area basis, whereas as virus spread is blocked, the designated geographical area shrinks, i.e., a reasonable designated geographical area is dynamically changed. In order to ensure timeliness of the acquisition of the terminal status, it is preferable that the designated geographical area further includes an adjacent area determined according to the target area.
According to the present invention, the storage medium further stores a third computer program, and the server executes the third computer program to realize the processing steps of:
s302, acquiring target terminal data in a database; the target terminal is a terminal of which the uploading time t1 is within the first historical time window and the historical grid set corresponding to the uploading time t1 and the target area grid set have an intersection.
S304, acquiring a third history time window grid set and the position number of the target terminal in each third history time window grid in the database; and the third history time window grid is the history grid of the target terminal in the third history time window corresponding to the target terminal data.
Wherein the first historical time window is determined according to the time when the infectious disease virus starts to be prevalent, and the third historical time window is determined according to the time when the infectious disease virus starts to be the third historical time window.
To facilitate understanding of the present invention, the first historical time window may be set to the time at which the virus began to become prevalent, e.g., XXXX year X month A day-XXXXXXX year X month B day, and the third historical time window may be set to XXXXXX year X month C day-D day, C may be less than B, but is preferably B + 1. Thus, through steps S302 and 304, it is possible to know where the third history time window has arrived during XXXX year X month C day-D day for the mobile terminal that appears in the target area between XXXX year X month a day-XXXX year X month B day. Obviously, the target area and/or the adjacent area may be a continuous area or a discrete area geographically.
S306, determining the adjacent area based on the third history time window grid set and the position number of the target terminal in each third history time window grid. According to the present invention, the number of positions is the number of target terminal data appearing in the third history time window grid, or the number of times of target terminal data.
The region with a large number of positions in the third history time window mesh set objectively becomes another virus infection high-incidence region outside the target region, and such a region can be considered as a neighboring region of the target region.
In one possible design, in the third historical time window grid set, a grid with a number of positions greater than or equal to a first specified number is selected to constitute the contiguous region. That is, when the number of target terminals in a grid is greater than or equal to a first specified number, i.e., the grid has enough mobile terminals from the target area, there is a greater probability that a virus will develop within the geographic area to which the grid belongs. At this time, the mesh is assigned to the adjacent area of the target area.
In another possible design, in the third history time window grid set, a grid with the number of distributed target history positions ranked as the first specified number is selected to form the adjacent area. That is, the grids in the third history time window grid set are sorted by the number of the distributed target history positions. The more forward the ranking, the more target mobile terminals in the geographic area it is, the greater the likelihood that it is a contiguous area of the target area.
Preferably, however, step S306 further comprises:
s3062, generating a thermodynamic diagram based on the third history time window grid set and the position number of the target terminal in each third history time window grid.
S3064, a selection operation for the thermodynamic diagram is obtained.
S3066, determining the adjoining region based on the selecting operation.
Through steps S3062-3066. The user can visually see the degree of the third history time window of the mobile terminal in the target area, and an area with a higher thermal value can be circled in the thermodynamic diagram as an adjacent area through simple selection operation.
According to another alternative specific implementation of this embodiment, the target region has contiguous regions with a priority of 1 to k, i.e. the contiguous regions include k priorities, such as 1 st contiguous region, 2 nd contiguous region,. and k < th > contiguous region, preferably, the priorities of these contiguous regions decrease from 1 to k. Obviously, the ith adjacent area may be a continuous area geographically or may be a discrete area. Preferably, there is no intersection between the target region and/or the set of meshes of the k-th order neighboring region.
The j +1 th adjacent region may be obtained according to the j th adjacent region, and is specifically implemented as follows.
According to the invention, the execution of the third computer program by the server further realizes the following processing steps:
s320, acquiring the ID of the target adjacent j terminal in a database; the target adjacent terminal is a terminal of which the uploading time t1 is within a first historical time window and the historical grid set corresponding to the uploading time t1 and the jth adjacent area grid set have intersection;
s322, acquiring a third history time window j grid set and the position number of target adjacent j terminals in each third history time window j grid in a database; the third history time window j grid is the history grid of the target terminal in the history time window of the third history time window j corresponding to the ID of the target adjacent j terminal;
s324, determining a j +1 th adjacent area based on the third history time window j grid set and the position number of the target terminal in each third history time window j grid; the specific obtaining manner is the same as the aforementioned manner of obtaining the adjacent region according to the target region, and is not described in detail.
Wherein j ranges from 1 to k-1. The third history time window j the history time window is determined based on the third history time window time of the infectious disease virus at the specific stage.
Example four
According to the present invention, the storage medium of the terminal data processing system further stores a first portrait program for portraying a specific geographical area designated by a user. The representation can assist in determining the potential status of a virus within a particular geographic area.
Specifically, the server executes the first portrait program to realize the following processing steps:
s402, acquiring an input grid set to be portrait. Optionally, there may be one or more input grids.
S404, the terminal ID corresponding to the input grid is retrieved from the database, and the obtained history grid LL is the last uploaded history grid at the uploading time t1 in the first history time window of the terminal, as defined in the previous embodiment. Obviously, the terminal ID may be one or more.
S406, acquiring the terminal weight according to the terminal ID. Optionally, the database stores the terminal ID and the terminal weight in a correlated manner, so that the terminal weight can be obtained according to the terminal ID search. According to the invention, the grid set of targets and/or adjacent regions is M, the region weight of the ith target and/or adjacent region is w i The terminal weight is further based on w i Determining a first grid set, M targets and/or a contiguous area grid set; wherein M is>1, i takes the value 1. In the same manner as the defining or acquiring method in the foregoing embodiment, the first grid set includes historical grids that correspond to the terminal ID and are located within a first historical time window at upload time t 1; the target area is an area where infectious disease virus begins to spread, and the adjacent area is obtained according to the target area.
Optionally, the step S406 further includes:
s4062, initializing the terminal weight to 0;
s4064, traversing M eyesAnd a target and/or adjacent area grid set, wherein when the first grid set and the ith target and/or adjacent area grid set have intersection, the terminal weight corresponding to the ID of the mobile terminal is increased by w i (ii) a Until the traversal of the M target and/or neighbor area mesh sets is completed.
Optionally, the step S406 further includes:
s4066, initializing the terminal weight to 0;
s4068, traversing M target and/or adjacent area grid sets, and increasing the terminal weight corresponding to the mobile terminal ID by w when the first grid set has intersection with the ith first and/or adjacent area grid set i (ii) a The traversal is terminated.
In one possible design, each region weight w i All the same, the terminal weight is now implemented as or similar to the terminal state.
In another possible design, each region weight w i The designation may be by user input.
In yet another possible design, the M targets and/or adjacent regions include M 0 A target area, M 1 A 1 st adjacent region, M 2 A 2 nd adjoining region, M k A k-th adjacent region, wherein M 0 +M 1 +M 2 +...+M k =M,M 0 ,...,M k Has a minimum value of 1; m 0 The region weights of the target regions are the same and are m 0 And is greater than the region weight of the adjacent region; m j The j adjacent regions have the same region weight and are m j And is greater than the region weight of the j +1 th adjacent region; the value range of j is 1.
In a preferred embodiment of the method of the invention,
Figure GDA0002758880180000123
wherein, N is selectable as the number of infected persons in the reference area within the preset time period, and those skilled in the art know that the number of infected persons can be automatically obtained from the public website by adopting the prior art.
N 0 For the reference area grid in the preset time period in the databaseThe number of terminal IDs in the intersection of the set of terminal IDs corresponding to the set and the set of terminal IDs corresponding to the target area grid set.
Figure GDA0002758880180000121
Wherein, N x And the number of the terminal IDs in the intersection of the terminal ID set corresponding to the reference area grid set and the terminal ID set corresponding to the x-th adjacent area grid set in the database in a preset time period is determined.
Optionally, the reference region is a region selected by the user, and a grid set of the region may be the same as or different from the input grid set. Preferably, the number of infected persons in the reference area is greater than a preset first threshold value,
Figure GDA0002758880180000122
the first and second threshold values are set to meet the minimum statistical value requirement of medicine and statistics, so that the precision of weight calculation is ensured. See example five for another way to determine the reference region.
To facilitate understanding of the present invention, for example, the number of infected persons in the reference area input by the user is 1000, and the terminal is 40000 in the first-level neighboring area (not including the first-level neighboring area) and the second-level neighboring area (not including the first-level neighboring area) at the intersection of the first grid set of the reference area and the grid set of the target area within the preset time period; the target area weight is 1000/2000, i.e. assuming that all the infected persons are due to the target area, the first-level neighboring area weight is 1000/(2000+20000), i.e. assuming that all the infected persons are due to the target area and the first neighboring area, and the second-level neighboring area weight is 1000/(2000+20000+40000), i.e. assuming that all the infected persons are due to the target area and the first and second neighboring areas. Obviously, the region weight of the target and/or the adjacent region may be dynamically updated according to the change of the preset time period, but preferably, the region weight is set to a static value after the preset time period is determined, so as to avoid consuming excessive calculation power of the server.
In a preferred design, the regional weights are determined according to the basic rules of epidemiology of viral transmission, and the continuously observed data proves that the regional images have higher accuracy.
S408, the first region image of the input grid is determined according to the terminal weight. Further, the first region representation includes a sum of terminal weights corresponding to all terminal IDs of the input grid.
Further, the first region is represented by
Figure GDA0002758880180000131
Where Ic is the number of infected persons in the input grid, Iw is the predefined infection weight, Tw i The weight of the ith terminal corresponding to the input grid is obtained, and TN is the number of terminal IDs in the input grid. Preferably, the infection weight Iw is greater than the regional weight of the target region, for example Iw may be set to 1.
According to this embodiment, the terminal data processing system of the present invention is capable of obtaining a first region representation of the corresponding region of the input grid reflecting the number of weightings in the corresponding region from the mobile terminal input from the target region and/or the neighboring region. In a virus propagation scene, an infected person can potentially propagate viruses, and an input mobile terminal holder can also potentially propagate the viruses, so that the first area image can reflect the state of latent propagation of the viruses in the area.
EXAMPLE five
Epidemiology considers that the virus is not spread differentially, so that a positive correlation exists between early diagnosis of the spread and the first region image, and the number of infected persons actually published in a part of regions (especially the number of infected persons published in the early stage) is limited by management measures and detection technical measures, and has hysteresis.
In order to solve the above technical problem, the storage medium of the terminal data processing system of the present invention further stores a regional infection prediction program, and the server executes the regional infection prediction program to implement the following processing steps:
s502, acquiring a reference area grid set and a non-reference area grid set. Preferably, the reference region does not intersect with the mesh set of non-reference regions. Optionally, the non-reference region is also a region selected by the user. Further, the non-reference area is an area with a geographic area exceeding a preset area threshold, so that enough population is carried in the non-reference area. Optionally, the non-reference area grid satisfies the following condition: the terminal ID of the corresponding mobile terminal is retrieved in the first historical time window in the database according to the non-reference area grid set, if the terminal state is that the number of the terminal IDs of the first identifier exceeds a preset input threshold value, the non-reference area meets the conditions, the basis of area infection prediction exists, otherwise, the condition is not met, and for example, the user can be prompted through a user interface of the terminal data processing system. For example, the non-reference area is typically selected to be the geographical area where provincial/city/prefecture administrative districts are located.
S504, the number of the infected persons in the non-reference area is determined according to the number of the infected persons in the reference area, the first area image of the reference area acquired at the current time and the first area image of the non-reference area.
As shown in the fourth embodiment, the first area representation of the reference area may be determined according to the grid set of the reference area, the terminal ID, the history grid of the terminal, the uploading time t1 of the history grid, and the terminal weight; the first region representation of the non-reference region may be determined based on the set of non-reference region grids, the terminal ID, the historical grid of the terminal, the upload time t1 of the historical grid, and the terminal weight. That is, the first region images of the reference region and/or the non-reference region can be acquired by using the grid set of the reference region and/or the non-reference region as the input grid of the fourth embodiment.
Specifically, in step S504, determining the first region representation of the reference region and/or the non-reference region may include:
s5042, searching and acquiring a terminal ID of a grid set of which the history grid LL belongs to a reference area and/or a non-reference area in a database, and acquiring a terminal weight corresponding to the terminal ID; preferably, the number of terminal IDs is also acquired simultaneously.
S5044, a first region image of the reference region and/or the non-reference region is determined based on the terminal weight.
Alternatively, according to the present invention, the database may further store the first region portraits of all grids acquired in advance at the current time, without storing the terminal data and the terminal weight. The reference region and/or first region representation is determined from the first region representations of all meshes of the reference region and/or non-reference region mesh set, for example as the sum of the first region representations of all meshes.
Preferably, the number of persons infected with the non-reference region/the non-reference region first region image is equal to the number of persons infected with the reference region/the reference region first region image.
S506, optionally, the infection density of the non-reference area is also determined as the number of infected persons in the non-reference area/the number of terminal IDs of the grid set of which the historical grid LL belongs to the non-reference area.
According to the invention, the number of the predicted infected persons in step S504 and the infection density in step S506 can be visually presented on the electronic map, so that the user can clearly and quickly know the infection state in the area.
According to the invention, the reference area is determined from one or more alternative areas selected by the user, and the server executes the area infection prediction program to realize the following processing steps:
s520, if the number of infected persons in the candidate area is greater than the preset first threshold, then step S522 is performed.
S522, the infection ratios of the plurality of candidate areas are obtained, and the infection ratios are determined according to the number of infected persons in the candidate areas and the first area image, for example, the infection ratio is the number of infected persons/the first area image. Further, there is no intersection between the candidate area grid sets.
S524, displaying the information to the user in a descending order according to the infection proportion, wherein the display content comprises a candidate area and the infection proportion, and optionally the number of infected people; illustratively, the display is to the user through a user interface of the terminal data processing system.
S526, receiving a selection instruction of a user, and selecting one or more candidate areas as reference areas according to the selection instruction.
Optionally, in step S524, the infection rates of some descending orders are displayed in a first display mode, and the infection rates of other descending orders are displayed in a second display mode, where the infection rates displayed in the first display mode are all larger than the infection rates displayed in the second display mode. The first and second display modes are, for example, different colors. In particular, if
Figure GDA0002758880180000141
Greater than a preset threshold (e.g., 25%), then the infection rates in descending order 1 to i are presented in a first display mode and the infection rates after the (i + 1) th are presented in a second display mode, where S i Infection proportion of the ith descending order, S i+1 Infection rate was i +1 descending order. Through the step, the candidate areas can be distinguished obviously according to the fault of the infection ratio, and a user can select the reference area and the non-reference area conveniently.
According to the steps S522 to S526, the user can be assisted to use one or more candidate areas with the highest correlation and the sampling basis as the reference area, so that the number of infected persons in the non-reference area can be predicted relatively accurately. For example, according to this embodiment, the candidate area is set as the geographical area where the provincial government district is located, and after S520 to 526 are executed by representing the first area of the candidate area and the number of the public infected persons, several provincial government districts are determined as reference areas, and the number of the infected persons in other non-reference areas is predicted. According to the number of infected persons published in the non-reference area within a period of time after observation and prediction, the prediction accuracy is very high.
EXAMPLE six
The storage medium of the terminal data processing system of the invention also stores a zone activity program, and the server executes the zone activity program to realize the following processing steps:
s610, acquiring an input area grid set and a third time window. The input area may be user specified, but preferably the input area is the area where a significant event occurs. The third time window may be specified by the user, but preferably, the third time window is a time window after the time point or the time period of the occurrence of the significant event, the starting time of the third time window is preferably zero, and the length of the third time window is preferably 7 days or 24 hours.
Further, the third time window is a dynamic window that changes according to the current time, that is, the starting time of the third time window is determined according to the current time. Illustratively, on the basis of a length of 24 hours and a starting time of zero, the current time is 3 months and 2 days, then the starting time is 3 months and 1 day zero, and the current time is 3 months and 3 days, then the starting time is 3 months and 2 days zero.
And S612, acquiring p terminal IDs (identity) of the historical grids LL which are uploaded by the preset type terminals at last and belong to the input area grid set in a third time window in the database, wherein p > is 1. The preset types of terminals include any one or more of all terminals in the database, an infected terminal, a terminal with a state of the first mark, and a terminal with close contact with the infected terminal in the time space (see the following embodiments for a specific obtaining method). According to the invention, the infected terminal is a mobile terminal designated by the user; generally, a user can designate a terminal carried by a medically diagnosed specific virus infector within a historical time window; a mobile terminal that an infected person has the rights to but does not carry with him within a historical time window will not be considered an infected terminal. For example, if the historical time window is 2 months 1 day to 5 days and the infected person changes the old mobile terminal a to the new mobile terminal B on 2 months 6 days, the mobile terminal a can be regarded as the infected terminal and B cannot be regarded as the infected terminal.
S614, acquiring an ith third history grid set corresponding to the ith terminal ID in the database; the third grid set comprises historical grids in terminal data corresponding to the terminal ID, wherein the uploading time t1 is in a third historical time window; i ranges from 1 to p.
S616, obtaining the quantity Q of the history grids in the intersection of the ith third history grid set and the input area grid set i
S618, inputting the activity of the area
Figure GDA0002758880180000161
Presented to the user. Illustratively, the display is to the user through a user interface of the terminal data processing system.
According to the invention, when the preset type terminal comprises multiple types, the region activity degrees corresponding to the preset types need to be respectively obtained and presented to the user in a comparison mode; the comparison can be realized by a bar chart or a line chart and the like. For example, when the preset type of terminals at least include all terminals in the database and the terminal whose status is the first mark, the input area activity of all terminals and the terminal with the first mark are respectively obtained.
Further, when the preset types are all terminals, the reference region activity is also presented to the user in S618.
The activity of the reference region is
Figure GDA0002758880180000162
Wherein p is 0 The number of terminal IDs of which the history grid LL uploaded by the terminal last belongs to the input area grid set is within the reference time window. The reference time window may be specified by the user, but preferably the reference time window is a time window before the point in time or time period at which the significant event occurred, and the length of the reference time window is the same as the length of the third time window. Q 0j The number of the history grids in the intersection of the jth reference history grid set and the input area grid set is the jth reference history grid set, the jth reference history grid set comprises the history grids in the jth terminal data corresponding to the jth terminal ID, the uploading time t1 is in the reference time window, and the value range of j is 1 to p 0
Further, the reference time window is a static window that does not change according to the current time. Continuing with the previous example, for example, if the reference time window is 1 month and 6 days, then the reference time window is 1 month and 6 days regardless of whether the current time is 3 months and 2 days, or 3 months and 3 days.
Further, the terminal data processing systemThe system also comprises a configuration file, wherein the activity of the reference area is stored in the configuration file
Figure GDA0002758880180000163
The zone activity program, when executed, is capable of reading the base zone activity from a configuration file.
Further, it is noted in the above S612 that when the preset types of the terminals of S612 are not all the terminals, the reference region activity does not need to be presented to the user in S618.
According to the embodiment, the invention can achieve the following technical effects: (1) the method can acquire the activity degrees of different preset types of terminals in an input area in real time and visually display the activity degrees; (2) the terminal activity degree of the input area can be acquired in real time and is displayed in comparison with the activity degree of the reference area. Therefore, before and after the occurrence of the major event, the influence of the major event on the input area can be observed in real time by using the technical scheme of the invention.
EXAMPLE seven
For a specific virus with high infectivity, the active area of the infected person is not limited because the infected person cannot clearly know that the infected person is infected during the virus latency period; or the infected person knows that the infected person is infected by the infected person due to a special reason, but the activity area of the infected person is still not limited. In these cases, it is possible that non-infected persons will appear in the same time and space as infected persons, i.e. at (substantially) the same time and in the same (substantially) geographical area, thus giving rise to a probability of being infected by the virus. Therefore, it is desirable for a non-infected person to know whether or not the person is co-current with the infected person. One technical means for solving the problem is to recall the location where the infected person appears at different times after the infected person is diagnosed, and store the time and the location in a cloud database, for example, the person takes XXXXXX flights in XX days, so that any other non-infected person user can conveniently inquire and know whether the time and the location are the same as the time and the space of the infected person. However, the technical means also has disadvantages, such as incomplete and inaccurate query results caused by incomplete and inaccurate memories of infected persons; for another example, the user who is not an infected person can obtain the information of the user only when starting the query, which is limited by the popularization of the query tool, and the whole situation of the infected person in the same time and space cannot be obtained.
In view of the above technical problem, according to the present invention, a storage medium of a terminal data processing system further stores a first terminal simultaneous blank state determination program, and the server executes the first terminal simultaneous blank state determination program to implement the following processing steps:
s710, an ith second grid set in a first historical time window of the second terminal is obtained, and the second grid set comprises historical grids which correspond to the terminal ID of the second terminal and are located in the ith second historical time window at the uploading time t 1. As described in the second embodiment, the first historical time window is composed of a specified number of second historical time windows, and the value of i ranges from 1 to the specified number.
S720, determining a simultaneous empty state corresponding to the terminal ID of the second terminal according to the intersection relation between the ith second grid set of the second terminal and the ith second grid set of the V first terminals; the ith second grid set of the first terminal includes the historical grids corresponding to the terminal ID of the first terminal and having the upload time t1 within the second historical time window. It is clear that V has a value greater than or equal to 1.
Further, the database stores a terminal ID of the second terminal and a same grid counter in association with each other, and the same grid counter is initialized to 0.
In one possible design, the step S720 further includes:
s722, at
Figure GDA0002758880180000171
And when the terminal ID of the second terminal has intersection with the ith second grid set of the second terminal, adding 1 to the same grid counter corresponding to the terminal ID of the second terminal. Wherein A is j And j is the ith second grid set of the jth target terminal, and the value range of j is 1 to V.
In another possible design, the step S720 further includes:
s724, at A j Ith second terminalAnd when the grid set has intersection, adding 1 to the counter of the same grid corresponding to the terminal ID. Wherein A is j And j is the ith second grid set of the jth target terminal, and the value range of j is 1 to V.
To more concisely understand the technical solution in the design, the following example is given, in which both terminal 1 and terminal 2 are target terminals; terminal a is the second terminal.
The ith second grid set of terminal 1 is { G1, G2, G4 };
the ith second set of grids for terminal 2 is { G1, G3, G5 };
the ith second mesh set of terminal a is { G1, G2, G3 };
Figure GDA0002758880180000181
is { G1, G2, G3, G4, G5 }.
According to S722, the counter of terminal a is incremented by 1.
According to S724, the counter of terminal a is incremented by 2.
Optionally, the simultaneous empty state is determined according to the value of the same-grid counter. For example, the simultaneous empty state is the value of the same trellis counter; for another example, when the value of the same-grid counter is greater than or equal to a preset counting threshold, the simultaneous empty state is set as a first identifier, otherwise, the simultaneous empty state is set as a second identifier.
According to this embodiment, the size of the grid is determined according to the propagation distance of the infectious disease virus, and for example, two adjacent 8-bit Geohash grids constituting (approximately) a square may be provided. The duration of the first historical time window is the same as that in the first embodiment, i.e. determined according to the latency of the infectious disease virus, and may be set to 5 days, for example. The duration of the second historical time window is determined by the survival time of the infectious disease virus and may be set to 1 hour or 1 day, for example.
S730, optionally, the terminal ID of the second terminal and the simultaneous empty state are stored in the database in an associated manner. That is, the database stores the terminal IDs of all the second terminals and the simultaneous null states of the terminals and the first terminal.
The present invention further provides another technical solution to the technical problem of the embodiment, and specifically provides a terminal data processing system, which includes a server, a database, and a storage medium storing a computer program, where the server is in communication connection with the database. The database stores terminal data, and the terminal data comprise a terminal ID, a WIFI-ID connected with the terminal and time t2 for uploading the WIFI-ID. The storage medium of the terminal data processing system also stores a second terminal simultaneous air state judgment program, and the server executes the second terminal simultaneous air state judgment program to realize the following processing steps:
and S750, acquiring an ith second WIFI-ID set in the first historical time window of the second terminal, wherein the second WIFI-ID set comprises WIFI-IDs which correspond to the terminal ID of the second terminal and are in the ith second historical time window at the uploading time t 2. As described in the second embodiment, the first historical time window is composed of a specified number of second historical time windows, and the value of i ranges from 1 to the specified number.
S760, determining a simultaneous empty state corresponding to the terminal ID of the second terminal according to the intersection relation between the ith second WIFI-ID set of the second terminal and the ith second WIFI-ID sets of the V target terminals; the ith second grid set of the target terminal comprises historical grids corresponding to the terminal ID of the target terminal and with the uploading time t2 in the second historical time window. It is clear that V has a value greater than or equal to 1.
Further, the database stores a terminal ID of the second terminal and a WIFI-compatible counter in a correlated manner, and the WIFI-compatible counter is initialized to 0.
In one possible design, the step S750 further includes:
s752, in
Figure GDA0002758880180000191
And when the terminal ID of the second terminal has intersection with the ith second WIFI-ID set of the second terminal, adding 1 to the same WIFI counter corresponding to the terminal ID of the second terminal. Wherein B is j The value range of j is 1 to V, and the value range is the ith second WIFI-ID set of the jth first terminal.
In another possible design, the step S750 further includes:
s754, in B j And when the terminal ID has intersection with the ith second WIFI-ID set of the second terminal, adding 1 to the same WIFI counter corresponding to the terminal ID. Wherein B is j The value range of j is 1 to V, and the value range is the ith second WIFI-ID set of the jth first terminal.
Optionally, the simultaneous empty state is determined according to the value of the WIFI counter. For example, the simultaneous empty state is a value of the same WIFI counter; for another example, when the value of the WIFI counter is greater than or equal to a preset counting threshold, the simultaneous null state is set as a first identifier, otherwise, the simultaneous null state is set as a second identifier.
S770, optionally, storing the terminal ID of the second terminal and the simultaneous null state association in the database. That is, the database stores the terminal IDs of all the second terminals and the simultaneous empty states of the terminals and the first terminal.
In this embodiment, the grid in the seventh embodiment is replaced with the WIFI connected to the terminal, so that the co-temporal judgment is more accurate on the basis of determining the second terminal having the co-temporal space (grid) with the first terminal in real time, for the following specific reasons: (1) the WIFI network signal has a certain coverage range, and the general WIFI coverage range has greater similarity to the propagation range of the virus in the air; (2) the multiple mobile terminal holders capable of being connected with the same WIFI at the same time have high-probability spatial affinity, and for example, family members or colleagues often located in the same space are easy to propagate.
Example eight
According to the present invention, continuing with embodiment seven and similar to embodiment four, a second portrait program is also stored in the storage medium of the terminal data processing system for portraying a user-specified geographic area. For example, the representation can assist in determining the potential status of a virus within a particular geographic area.
Specifically, the server executes the second portrait program to realize the following processing steps:
s802, an input grid set of the to-be-portrait is obtained. Optionally, there may be one or more input grids.
S804, the terminal ID corresponding to the input grid is retrieved from the database, and the obtained history grid LL is the last uploaded history grid at the uploading time t1 in the first history time window of the terminal, as defined in the foregoing embodiment. Obviously, the terminal ID may be one or more.
And S806, acquiring the terminal simultaneous null weight according to the terminal ID. Optionally, the database stores the terminal ID and the terminal simultaneous null weight in a correlated manner, so that the terminal weight can be obtained according to the terminal ID search.
Preferably, the terminal ID is a terminal ID of the second terminal. The judgment of the second terminal and the first terminal can adopt any technical means. For example, a first terminal ID is stored in the profile, and for any terminal ID retrieved in the database, the first terminal ID in the profile is compared, and if there is a match, the terminal ID is considered to be the first terminal ID, otherwise the terminal ID is considered to be the second terminal ID. As another example, for the first terminal ID, a first terminal flag is set in the database, and the second terminal does not set a flag or the like.
Further, the terminal simultaneous null weight is determined according to values Y1 of U1 first weights and values Y2 of U2 second weights, and it is apparent that Y1 includes U1 values and Y2 includes U2 values. The value Y1 of the first weight is determined according to the duration of a second historical time window, the value of a grid counter and a preset counting threshold of the grid counter; and the value Y2 of the second weight is determined according to the duration of the second historical time window, the value of the WIFI counter and a preset counting threshold of the WIFI counter. The value of the same grid counter and the value of the same WIFI counter are the same as those described in the seventh embodiment, and are not described again. According to the setting mode, the different first weight and second weight can reflect the contact degree of the second terminal and the first terminal at the same time and space, for example, in the case that the first terminal is an infected terminal, the contact degree reflects the probability of the infection of the second terminal holder, and the omission caused by the terminal data sampling rate in the database can be effectively eliminated.
Further, when the value of the same grid counter is smaller than the preset counting threshold of the grid counter, Y1 is set to 0; the value of the WIFI counter is less than the WIFI counter preset count threshold, Y2 is set to 0.
Preferably, the terminal simultaneous null weight is
Figure GDA0002758880180000201
Wherein, Y1 i The value of the ith first weight is taken; y2 j Is the value of the jth second weight.
Preferably, when the duration of the second historical time window is the same, and the preset count thresholds of the grid counter and the WIFI counter are also the same, Y1 is smaller than Y2.
Preferably, Y1 is inversely related to the duration of the second historical time window and positively related to a preset count threshold of the grid counter. That is, the longer the period of time, the lower Y1, the larger the count threshold, and the higher Y1, all other conditions being equal.
Similarly, Y2 is inversely related to the duration of the second historical time window and positively related to the preset count threshold of the WIFI counter. That is, the longer the period of time, the lower Y2, the larger the count threshold, and the higher Y2, all other conditions being equal.
Illustratively, the value of U1 is 3, specifically:
when the duration of the second historical time window is 1 hour and the preset counting threshold of the grid counter is 3, the second simultaneous empty weight corresponding to the terminal ID is set to be Y1 1
When the duration of the second historical time window is 1 day and the preset counting threshold of the grid counter is 3; the third simultaneous null weight corresponding to the terminal ID is set to Y1 2
When the duration of the second historical time window is 1 day and the preset counting threshold of the grid counter is 1, the fourth simultaneous empty weight corresponding to the terminal ID is set to be Y1 3
Illustratively, the value of U2 is 1, specifically:
when the duration of the second historical time window is 1 day, presetting of the WIFI counterWhen the counting threshold value is 1, the first space-time weight corresponding to the terminal ID is set as Y2 1
S808, determining a second area portrait of the input grid according to the terminal simultaneous space weight. Further, the second region representation includes a sum of terminal-to-spatio-temporal weights corresponding to all terminal IDs of the input mesh.
According to this embodiment, the terminal data processing system of the present invention is capable of obtaining a second region representation of the corresponding region of the input grid reflecting the weighted number of mobile terminals in the corresponding region that are co-temporal with the infected terminal. In the virus transmission scenario, the infected person may potentially transmit the virus, and the mobile terminal holder who is in the same time as the infected terminal may potentially transmit the virus due to the infection by the infected person, so that the second region image may reflect the state of latent transmission of the virus in the region.
Example nine
According to the present invention, the storage medium of the terminal data processing system further stores a close-contact image program for imaging a specific geographical area designated by a user. For example, the representation may be used to assist in determining the potential status of a virus in a particular geographic region based on a first representation of the region, a second representation of the region, infected terminals within the region, region liveness, and a reference region liveness weighting of the input region.
Specifically, the server executes the close-contact image program to realize the following processing steps:
s910, acquiring an input grid set of an input area to be imaged and the number of infected terminals.
S920, the terminal ID of the acquisition history grid LL corresponding to the input grid set is retrieved from the database.
S930, acquiring a latent state according to the terminal ID; the latent state is determined according to the terminal weight corresponding to the terminal ID, the terminal simultaneous null weight and the number of infected terminals in a weighting mode; wherein the weight of the infected terminal is greater than the terminal weight and the terminal simultaneous null weight.
The specific technical scheme for obtaining the terminal weight can be referred to as embodiment four of the present invention, and the specific technical scheme for obtaining the terminal simultaneous null weight can be referred to as embodiment seven of the present invention, which is not described again.
S940, acquiring a control state according to the input area, wherein the control state is determined according to the area activity of the input area and the reference area activity; the control state is positively correlated with the reference region activity of the input region and inversely correlated with the region activity of the input region. The specific technical scheme for acquiring the region activity and the reference region activity can be referred to in the sixth embodiment of the present invention, and is not described again.
S950, determining a close-contact image of the input area according to the latent state and the control state; the close-contact image is positively correlated with the latent state and inversely correlated with the management state.
Example ten
According to the present invention, a program for acquiring a health status is also stored in the storage medium of the terminal data processing system for acquiring a health status of a holder of a specific terminal that may be infected with a virus. The server executes the program for acquiring the health status to realize the following processing steps:
s1010, acquiring the terminal ID. The terminal ID may be input by the user, or may be automatically acquired according to information when the user registers an APP such as a payment treasure.
And S1020, if the terminal ID is the terminal ID of the infected terminal, setting the health state as the weight of the infected terminal.
S1030, if the terminal ID is not the terminal ID of the infected terminal, acquiring the first, second and third health states according to the terminal ID.
The first health status of the terminal is determined according to the following steps:
s1052, acquiring a frequently-existing grid of the uploading time t corresponding to the terminal ID in a specified time period in a database; optionally, the frequent grid may be the historical grid LL or the historical grid with the largest number of occurrences.
S1054, a close contact image of the grid is obtained.
S1056, obtaining the predicted number of infected people in the first, second and third geo-fenced areas. The first geo-fenced area comprises the second geo-fenced area, which comprises a third geo-fenced area, which comprises the ubiquitous grid. Illustratively, the first, second and third geo-fenced areas are the geographical areas where provincial, city and county administrative districts, where grids are often located, respectively.
The concrete technical scheme for obtaining the predicted number of infected people can be seen in the fifth embodiment of the invention, and is not described again.
S1056, according to the close contact image of the grid and the predicted infected people number of the first, second and third geo-fence areas, determining the first health state of the terminal.
The second health status of the terminal is determined according to the following steps:
s1062, acquiring historical grids and the number of the historical grids in a specified time period of the uploading time t corresponding to the terminal ID from the database.
S1064, acquiring close contact images of each history grid.
S1066; and determining the second health state of the terminal according to the number of the historical grids and the close contact image.
And the third health state of the terminal is determined according to the terminal weight and the terminal co-space-time weight.
It should be understood that the term "and/or" as used herein is merely one type of association that describes an associated object, meaning that three relationships may exist, e.g., a and/or B may mean: 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 used only 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, the 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 where there is no explicit indication or technically inevitable order relationship.
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 logical division, and there may be other divisions in actual implementation, for example, a plurality of 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: various media capable of storing program codes, such as a usb disk, a removable hard disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a magnetic disk, or an optical disk.
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 (10)

1. A terminal data processing system comprises a server, a database and a storage medium storing a regional infection prediction program, wherein the server is in communication connection with the database; the method is characterized in that: the database stores terminal data, the terminal data comprise a terminal ID, a terminal history grid and uploading time t1 of the history grid, and the database also stores the terminal ID and terminal weight in a correlated manner;
the server executes the regional infection prediction program to realize the following processing steps:
s502, acquiring a grid set of a reference area and a grid set of a non-reference area, wherein the grid sets of the reference area and the non-reference area are not intersected;
s504, determining the predicted number of infected persons in the non-reference area according to the number of infected persons in the reference area, the first area image of the reference area acquired at the current time and the first area image of the non-reference area; determining a first region image of the reference region according to the grid set of the reference region, the terminal ID, the historical grid of the terminal, the uploading time t1 of the historical grid and the terminal weight; determining a first region image of the non-reference region according to the non-reference region grid set, the terminal ID, the historical grid of the terminal, the uploading time t1 of the historical grid and the terminal weight; wherein the first region representation comprises a sum of terminal weights corresponding to all terminal IDs of the input grid;
wherein the number of infected persons in the reference area is greater than a preset first threshold value.
2. The data processing system of claim 1, wherein the non-reference region is a user-selected region having a geographic area exceeding a preset area threshold.
3. The data processing system of claim 1, wherein determining a first region representation of a reference region and/or a non-reference region in step S504 comprises:
s5042, searching and acquiring a terminal ID of a grid set of which the history grid LL belongs to a reference area and/or a non-reference area in a database, and acquiring a terminal weight corresponding to the terminal ID;
s5044, a first region image of the reference region and/or the non-reference region is determined based on the terminal weight.
4. The data processing system of claim 3, wherein the non-reference region predicts a number of infected persons/non-reference region first region representation-reference region infected persons/reference region first region representation.
5. The terminal data processing system according to claim 3, wherein the step S5042 further comprises: searching and acquiring the number of terminal IDs of a grid set of which the history grid LL belongs to a non-reference area in a database;
the server executing the regional infection prediction program further realizes the following processing steps:
s506, the infection density of the non-reference area is determined as the number of infected persons in the non-reference area/the number of terminal IDs of the grid set in which the history grid LL belongs to the non-reference area.
6. The terminal data processing system of claim 1, wherein the reference region is determined from one or more alternative regions selected by a user; the server executing the regional infection prediction program further realizes the following processing steps:
s520, if the number of infected persons in the alternative area is larger than a preset first threshold value, executing the step S522; no intersection exists between the candidate area grid sets;
s522, acquiring infection ratios of a plurality of candidate areas, wherein the infection ratios are determined according to the number of infected persons in the candidate areas and the first area image;
s524, displaying the contents to a user in a descending order according to the infection proportion, wherein the displayed contents comprise an alternative area and the infection proportion;
s526, receiving a selection instruction of a user, and selecting one or more candidate areas as reference areas according to the selection instruction.
7. The terminal data processing system of claim 6, wherein the infection ratio is the number of infected persons/first region representation.
8. The terminal data processing system of claim 6, wherein in step S524, the infection rates of some of the descending orders are displayed in a first display manner, and the infection rates of other descending orders are displayed in a second display manner, and the infection rates displayed in the first display manner are all larger than the infection rates displayed in the second display manner.
9. The terminal data processing system of claim 8, wherein if, the data processing system is configured to perform the method further comprises
Figure FDA0003697750380000021
If the infection rate is greater than the preset threshold value, presenting the infection rates of the 1 st to the i th descending orders in a first display mode, and presenting the infection rates after the i +1 th order in a second display mode, wherein S i Infection proportion of the ith descending order, S i+1 Infection rate was i +1 descending order.
10. A terminal data processing system comprises a server, a database and a storage medium storing a regional infection prediction program, wherein the server is in communication connection with the database; the method is characterized in that first area portraits of all grids acquired in advance at the current time are stored in a database;
the server executes the regional infection prediction program to realize the following processing steps:
s502, acquiring a grid set of a reference area and a grid set of a non-reference area, wherein the grid sets of the reference area and the non-reference area are not intersected;
s504, determining the predicted number of infected persons in the non-reference area according to the number of infected persons in the reference area, the first area image of the reference area acquired at the current time and the first area image of the non-reference area; determining a first region image of the reference region according to the grid set of the reference region, the terminal ID, the historical grid of the terminal, the uploading time t1 of the historical grid and the terminal weight; determining a first region image of the non-reference region according to the non-reference region grid set, the terminal ID, the historical grid of the terminal, the uploading time t1 of the historical grid and the terminal weight; wherein the first region representation comprises a sum of terminal weights corresponding to all terminal IDs of the input grid;
wherein the number of infected persons in the reference area is greater than a preset first threshold value.
CN202010394414.2A 2020-05-11 2020-05-11 Terminal data processing system Active CN112148818B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202010394414.2A CN112148818B (en) 2020-05-11 2020-05-11 Terminal data processing system

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202010394414.2A CN112148818B (en) 2020-05-11 2020-05-11 Terminal data processing system

Publications (2)

Publication Number Publication Date
CN112148818A CN112148818A (en) 2020-12-29
CN112148818B true CN112148818B (en) 2022-09-16

Family

ID=73891851

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202010394414.2A Active CN112148818B (en) 2020-05-11 2020-05-11 Terminal data processing system

Country Status (1)

Country Link
CN (1) CN112148818B (en)

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2011191236A (en) * 2010-03-16 2011-09-29 Hitachi Solutions Ltd System and method for providing information on protection against infectious diseases
CN102945310A (en) * 2012-09-27 2013-02-27 吉林大学 Epidemic propagation network modeling and inference of based on autonomic computing
KR101925506B1 (en) * 2017-12-12 2018-12-06 한국과학기술정보연구원 Method and apparatus for predicting the spread of an infectious disease
CN109190375A (en) * 2018-08-02 2019-01-11 北京北信源信息安全技术有限公司 Analyze the equation group and rogue program DIFFUSION PREDICTION method of rogue program propagation law
CN109817343A (en) * 2019-01-31 2019-05-28 关强 Monitoring of infectious disease system
CN110959181A (en) * 2017-07-28 2020-04-03 皇家飞利浦有限公司 Monitoring direct and indirect transmission of infections in healthcare facilities using real-time localization systems

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2011191236A (en) * 2010-03-16 2011-09-29 Hitachi Solutions Ltd System and method for providing information on protection against infectious diseases
CN102945310A (en) * 2012-09-27 2013-02-27 吉林大学 Epidemic propagation network modeling and inference of based on autonomic computing
CN110959181A (en) * 2017-07-28 2020-04-03 皇家飞利浦有限公司 Monitoring direct and indirect transmission of infections in healthcare facilities using real-time localization systems
KR101925506B1 (en) * 2017-12-12 2018-12-06 한국과학기술정보연구원 Method and apparatus for predicting the spread of an infectious disease
CN109190375A (en) * 2018-08-02 2019-01-11 北京北信源信息安全技术有限公司 Analyze the equation group and rogue program DIFFUSION PREDICTION method of rogue program propagation law
CN109817343A (en) * 2019-01-31 2019-05-28 关强 Monitoring of infectious disease system

Also Published As

Publication number Publication date
CN112148818A (en) 2020-12-29

Similar Documents

Publication Publication Date Title
CN111459723B (en) Terminal data processing system
Yuan et al. Measuring similarity of mobile phone user trajectories–a Spatio-temporal Edit Distance method
JP5560026B2 (en) Map display device, map display method, and map display program
JP7407209B2 (en) Information push method and device
CN111639092B (en) Personnel flow analysis method and device, electronic equipment and storage medium
CN107291784B (en) Method and device for acquiring geo-fence categories and business equipment
CN107835486A (en) Traffic trip amount computational methods and device
CN110019989A (en) A kind of data processing method and device
CN111242723B (en) User child and child condition judgment method, server and computer readable storage medium
JPWO2006059629A1 (en) Area information management device/method/program
CN109977324B (en) Interest point mining method and system
CN112148818B (en) Terminal data processing system
CN112115382B (en) Data processing method and device, storage medium and electronic device
CN112507046B (en) Terminal data processing system
CN112507044B (en) Terminal data processing system
CN112507045B (en) Terminal data processing system
CN112507043B (en) Terminal data processing system
CN117010537A (en) Target area prediction method, device, computer equipment and storage medium
CN111611337B (en) Terminal data processing system
WO2023087722A1 (en) Object gathering method and apparatus, and electronic device and storage medium
CN107801418B (en) Floating population estimation device and method using map search record
CN115658779A (en) Population data display method and device
CN111611336B (en) Terminal data processing system
JP5900487B2 (en) Mobile object management system, mobile object management server, mobile object management method, and mobile object management program
JP2005218028A (en) User terminal, investigation terminal, server, program, and distribution 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.

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.

CB02 Change of applicant information
GR01 Patent grant
GR01 Patent grant