Search

CN-121998575-A - Engineering progress monitoring method, electronic equipment, storage medium and program product

CN121998575ACN 121998575 ACN121998575 ACN 121998575ACN-121998575-A

Abstract

The embodiment of the application provides a monitoring method of engineering progress, electronic equipment, a storage medium and a program product. The method comprises the steps of collecting engineering progress data through a distributed sensor network and an application program interface gateway, carrying out fragment indexing on the engineering progress data based on project construction stages and data types, injecting risk level labels in a writing process to form labeled index data, carrying out stream synchronization on the labeled index data through a message queue, pushing the labeled index data to the front end in real time based on a full duplex communication protocol, dynamically loading a task list at the front end according to a user view range, and rendering a Gantt chart comprising a time axis and task bars, wherein scales of the time axis are dynamically generated according to a currently displayed time window, and the positions and colors of the task bars are determined according to the risk level labels and the time information.

Inventors

  • XIA YUXIN
  • WANG ZERONG

Assignees

  • 昆仑数智科技有限责任公司
  • 中国石油天然气集团有限公司

Dates

Publication Date
20260508
Application Date
20251226

Claims (10)

  1. 1. The method for monitoring the engineering progress is characterized by comprising the following steps of: Collecting engineering progress data through a distributed sensor network and an application program interface gateway; Performing fragment indexing on the engineering progress data based on project construction stages and data types, and injecting risk grade labels in the writing process to form labeled index data; Carrying out stream synchronization on the index data with the tag through a message queue, and pushing the index data to the front end in real time based on a full duplex communication protocol; Dynamically loading a task list at the front end according to the view range of a user, and rendering a Gantt chart comprising a time axis and task bars, wherein scales of the time axis are dynamically generated according to a currently displayed time window, and the positions and colors of the task bars are determined according to the risk grade labels and the time information.
  2. 2. The method of claim 1, wherein the project progress data is partitioned based on project construction stages and data categories, comprising: constructing a two-dimensional slicing key consisting of an item stage field and a data type field; Distributing similar monitoring data under the same construction stage to the same index fragment according to the two-dimensional fragment key; A new index is created by automatically scrolling daily or weekly in combination with a time series index template.
  3. 3. The method of claim 2, wherein constructing a two-dimensional shard key comprised of an item phase field and a data type field comprises: Acquiring a project stage identifier and a data type identifier corresponding to current project progress data; performing character string splicing or hash operation on the project stage identifier and the data type identifier to generate a unique fragment routing key; and distributing the engineering progress data to target fragments in a distributed index system based on the fragment routing key, so that the data of the same type under the same project stage are stored in the same physical fragment in a concentrated mode.
  4. 4. The method of claim 1, wherein injecting the risk level tag during writing comprises: Before the data is written into the index, judging whether the current progress data meets a preset risk condition or not through a rule engine; if yes, adding a risk grade label into the data, wherein the risk grade label comprises a high risk or serious risk identifier; wherein the risk condition includes a progress deviation rate exceeding a threshold or a sensor value exceeding a safe range.
  5. 5. The method of claim 1, wherein dynamically loading the task list at the front end according to the user view range and rendering the gatekeeper graph comprising the timeline and the task bar comprises: Calculating a row index range of the current visible area in a task list, and only creating page elements corresponding to the row index range, wherein the rest task rows are replaced by blank space occupying elements; mapping each task bar in the Gantt chart into a geometric primitive which can be processed by a graphic processor, wherein the transverse position of the task bar is obtained by converting the start-stop time of the task bar, and the longitudinal position of the task bar is determined by the line number of the task bar in a task list; Performing coordinate transformation on the geometric primitives through a vertex coloring unit of the graphics processor, and generating differentiated display colors through the vertex coloring unit according to risk grade labels of corresponding tasks; In response to a user scrolling or zooming operation, the visual line range of the task list and the task bar layout of the Gantt chart are synchronously updated, and the line alignment relationship of the visual line range and the task bar layout in the vertical direction is maintained.
  6. 6. The method of claim 1, wherein prior to rendering the gatekeeper graph comprising a timeline and a taskbar, the method further comprises: Pre-constructing an ordered array of all task time stamps; determining start and end time stamps of a currently displayed time window in response to a user scaling operation; utilizing binary search to quickly locate task nodes in the time window in the ordered array; And generating a time axis scale and a task bar layout under the current view only based on the task nodes.
  7. 7. A monitoring device for engineering progress, comprising: The acquisition module is used for acquiring engineering progress data through the distributed sensor network and the application program interface gateway; The indexing module is used for carrying out fragment indexing on the project progress data based on project construction stages and data types, and injecting risk grade labels in the writing process to form index data with labels; the pushing module is used for carrying out stream synchronization on the index data with the labels through a message queue and pushing the index data to the front end in real time based on a full duplex communication protocol; The rendering module is used for dynamically loading a task list at the front end according to the view range of the user and rendering a Gantt chart comprising a time axis and task bars, wherein scales of the time axis are dynamically generated according to a currently displayed time window, and the positions and colors of the task bars are determined according to the risk grade labels and the time information.
  8. 8. The monitoring equipment for the engineering progress is characterized by comprising a memory and a processor; The memory stores computer-executable instructions; the processor executing computer-executable instructions stored in the memory, causing the processor to perform the method of any one of claims 1-6.
  9. 9. A computer readable storage medium having stored therein computer executable instructions which when executed by a processor are adapted to carry out the method of any one of claims 1-6.
  10. 10. A computer program product comprising a computer program which, when executed by a processor, implements the method of any of claims 1-6.

Description

Engineering progress monitoring method, electronic equipment, storage medium and program product Technical Field The present application relates to the field of computer technologies, and in particular, to a method for monitoring engineering progress, an electronic device, a storage medium, and a program product. Background In the construction process of large infrastructure projects (such as subways, oil fields and nuclear power stations), engineering progress management depends on acquisition and analysis of massive real-time data, including construction task states, structural stress, equipment vibration and the like. The data has the characteristics of high frequency, high concurrency, strong time sequence and the like, dynamic comparison of 'physical flow' and 'planned flow' is realized on a unified platform, and decision is assisted by visual means such as Gantt chart and the like. Therefore, how to realize the synchronization of millisecond-level data and smooth interaction under the condition of ten thousand-level task amount becomes a core requirement of engineering digital management. Currently, the mainstream engineering management system mostly adopts a batch processing architecture, wherein a front end periodically polls a database or a cache layer to acquire progress data, and a back end uses a static slicing strategy to write the data into a general search engine. Gantt charts are commonly drawn based on a Document Object Model (DOM) or two-dimensional drawing interface. The scheme can still operate in a small-scale scene, but when high concurrency writing (such as thousands of sensor data per second) or large-scale task display (such as a hundred thousand-level construction procedure) is performed, serious performance bottlenecks are exposed, on one hand, static fragments are easy to form hot spots, so that writing delay is prolonged, on the other hand, DOM rendering is blocked due to node explosion, the scaling operation frame rate is lower than 10 frames/second, and the real-time interaction requirement of a large screen of a command center cannot be met. In summary, the prior art has the following main technical problems that in the high concurrency and large-scale engineering data scene, the real-time performance of data writing, the high efficiency of index inquiry and the smoothness of front-end visualization are difficult to be simultaneously considered, so that progress monitoring is delayed, risk early warning is delayed, and the overall management and control efficiency of a project is influenced. Disclosure of Invention The embodiment of the application provides a monitoring method of engineering progress, electronic equipment, a storage medium and a program product, which are used for achieving the integrated progress monitoring effects of high availability, low delay and strong interaction. The method for monitoring the engineering progress comprises the steps of collecting engineering progress data through a distributed sensor network and an application program interface gateway, conducting segment indexing on the engineering progress data based on project construction stages and data types, injecting risk grade labels in a writing process to form labeled index data, conducting stream synchronization on the labeled index data through a message queue, pushing the labeled index data to the front end in real time based on a full duplex communication protocol, dynamically loading a task list at the front end according to a user view range, and rendering a Gantt chart comprising a time axis and a task bar, wherein scales of the time axis are dynamically generated according to a currently displayed time window, and positions and colors of the task bar are determined according to the risk grade labels and time information. In one possible implementation, a two-dimensional slicing key consisting of an item stage field and a data type field is constructed, similar monitoring data in the same construction stage are distributed to the same index slicing according to the two-dimensional slicing key, and a new index is created by automatically rolling according to days or weeks in combination with a time sequence index template. In one possible implementation, a project stage identifier and a data type identifier corresponding to current project progress data are obtained, character string splicing or hash operation is carried out on the project stage identifier and the data type identifier to generate a unique segment routing key, and the project progress data are distributed to target segments in a distributed index system based on the segment routing key, so that data of the same type in the same project stage are stored in the same physical segment in a concentrated mode. In a possible implementation mode, before the data is written into the index, judging whether the current progress data meets a preset risk condition through a rule engine, and if so, adding a risk level label in the d