CN-122019670-A - Cloud edge fusion calculation-based real-time synchronous management method and system for distributed building resources

CN122019670ACN 122019670 ACN122019670 ACN 122019670ACN-122019670-A

Abstract

The invention discloses a cloud edge fusion calculation-based real-time synchronous management method and a cloud edge fusion calculation-based real-time synchronous management system for distributed house sources of a building, which belong to the technical field of edge calculation and specifically comprise the steps of constructing a local data copy for each house source based on a cloud of a total system of the building; based on the local data copy, acquiring a room source operation, packaging the room source operation into a structured event object, calculating a two-dimensional priority vector, adding the two-dimensional priority vector to the event object to obtain a marked synchronous event, executing an edge and cloud dual-track mechanism in parallel based on the marked synchronous event to finally generate a scheduling instruction, issuing the finally generated scheduling instruction to execute data synchronization, and constructing a lightweight analysis mechanism to provide scheduling suggestions. By introducing a bidirectional quantization priority synchronization algorithm and an idle-hot spot edge triggering mechanism, real-time synchronization of the house source state and cross-node dynamic scheduling are realized, and sales efficiency and customer experience are improved.

Inventors

FU DUNBIAO
FU DUNJIE
SUN GUI

Assignees

佛山市大迈信息科技有限公司

Dates

Publication Date: 20260512
Application Date: 20260202

Claims (10)

1. A real-time synchronous management method of a distributed house source of a sales building based on cloud edge fusion calculation is characterized by comprising the following steps: Based on the cloud of the total system of the vending building, a local data copy is built for each house source and is issued to each edge node; Based on the local data copy, acquiring a house source operation, packaging the house source operation into a structured event object, calculating a two-dimensional priority vector and attaching the two-dimensional priority vector to the event object to acquire a synchronous event with a mark; according to the marked synchronous event, an edge and cloud dual-track parallel mechanism is constructed, the marked synchronous event is processed, and finally a scheduling instruction is generated; And sending the scheduling instruction to each edge node, executing data synchronization, constructing a lightweight analysis mechanism, providing scheduling suggestions and feeding back.
2. The cloud edge fusion calculation-based real-time synchronization management method for a distributed house source of a sales building, according to claim 1, is characterized in that the construction of local data copies comprises the following steps: S1, acquiring a global unique house identifier, a global version number, a physical state, an attribution edge node ID, a basic base price and a synchronous time stamp from a cloud of a total system of a vending building to form a core state field set; s2, based on the cloud end of the total system of the vending building and the edge nodes, cooperatively calculating local recommended heat and estimated trading period to form an edge derivative field set; And S3, combining the core state field set and the edge derivative field set to form a local data copy.
3. The cloud edge fusion computing-based real-time synchronization management method for a distributed house source of a building, according to claim 2, wherein the steps of obtaining house source operations and packaging the house source operations into a structured event object include the following steps: S1, capturing a service request initiated by a worker from a cloud end of a total system of a sales building, and analyzing key parameters from the service request, wherein the key parameters comprise a target house source identifier, a requested operation type, a new value attached to the operation and a service context; S2, the edge node queries a core state field set in the local data copy by utilizing a target house source identifier in the key parameter; And S2, based on a core state field set in the local data copy, performing front-end service verification and judgment, when verification passes, creating and packaging a structured event object by the edge node, and when verification fails, returning an error code to the cloud of the total sales system.
4. A method for real-time synchronization management of a distributed building source based on cloud edge fusion computing as defined in claim 3, wherein computing a two-dimensional priority vector and attaching to an event object comprises the steps of: the method comprises the steps that S1, a priority computing engine is deployed, an edge node calls the priority computing engine, and a two-dimensional priority vector is computed for a structured event object, wherein the two-dimensional priority vector comprises a business priority vector comprehensive score and a time topology priority vector; S2, adding the business priority vector comprehensive score and the time topology priority vector into a structured event object to obtain a marked synchronous event, and storing the marked synchronous event into a local event log in a lasting manner; and S3, pushing the synchronous event with the mark to the cooperative network by using a parallel pushing method.
5. The cloud edge fusion calculation-based real-time synchronous management method for distributed building resources of a building is characterized in that the construction of an edge-cloud double-track parallel mechanism comprises the following steps: S1, constructing a verification and classification mechanism, verifying the data integrity of the marked synchronous event, classifying the new version and the old version of the event, putting the new version of event into an instant processing queue, and putting the old version of event into a history patch queue; S2, for events aiming at the same house source in the instant processing queue, the cloud end classifies the events into the same synchronous window, sets a synchronous window closing condition, and closes the synchronous window when the window opening time exceeds a dynamic threshold Q, the number of the events N in the window reaches an upper limit and a presynchronization ready signal from any relevant edge node is received; and S3, switching the window state into 'closed' and finally obtaining the closed synchronous window of each room source.
6. The cloud edge fusion calculation-based real-time synchronous management method for distributed building resources of a building, according to claim 5, is characterized in that the construction of an edge-cloud double-track parallel mechanism further comprises the following steps: s1, based on a marked synchronous event and a local data copy, performing edge side instant presynchronization and conflict presynchronization, wherein the process comprises causal consistency check, presynchronization conflict presynchronization and synchronous response generation, and an obtained synchronous response signal is used as additional information and is imported into a synchronous window of a corresponding house source; and S2, carrying out cloud multidimensional arbitration and scheduling instruction generation based on the closed version synchronization window and the related edge pre-synchronization response, wherein the process comprises conflict graph construction, arbitration calculation and scheduling instruction generation, and the scheduling instruction of each room source is obtained.
7. The cloud edge fusion computing-based real-time synchronization management method for a distributed building source of a sales building of claim 6, wherein the scheduling instruction is issued to each edge node, and the data synchronization is performed by the following steps: s1, carrying out version verification on a dispatching instruction of each house source, converting the dispatching instruction into a global confirmation event through the verified dispatching instruction, and directly discarding the global confirmation event if the dispatching instruction does not pass the verification to obtain and store the global confirmation event; s2, packaging and issuing the global confirmation event to each edge node, pre-checking by the edge nodes, and sending a 'receiving confirmation message' to the cloud after the pre-checking to obtain a task queue passing the pre-checking; And S3, each edge node performs sequencing execution according to the global sequence number sequence through the instructions in the pre-checked task queue, performs conflict resolution detection processing and data synchronous refreshing, and finally performs version consistency verification to complete data synchronization.
8. The cloud edge fusion calculation-based real-time synchronous management method for distributed building resources of a building according to claim 7, wherein the construction of a lightweight analysis mechanism comprises the following steps: s1, setting a lightweight analysis mechanism, calculating a house source idle index and a demand index in real time at an edge node, and reporting the data house source idle index, the demand index and a scheduling request to a cloud end of a total system of the vending building; S2, receiving a house source idle index, a demand index and a scheduling request by a cloud end of a total system of the building, and calculating a house source matching degree for each idle node A and each demand-intensive node B; and S3, generating a proposal draft based on the matching degree of the house sources, and storing the draft into a cloud scheduling proposal pool.
9. The cloud edge fusion calculation-based real-time synchronous management method for distributed building resources of a building according to claim 8, wherein the construction of a lightweight analysis mechanism further comprises the following steps: S1, extracting a proposal draft from a cloud proposal pool, and calculating an execution priority for each proposal by the cloud; And S2, setting an automatic triggering and manual auditing mechanism based on the execution priority, judging the execution and triggering of the scheduling instructions, and recording the execution effect of each scheduling instruction.
10. A cloud edge fusion calculation-based real-time synchronous management system for a distributed house source of a sales building is characterized by comprising the following steps: The first module is used for constructing a local data copy for each house source and transmitting the local data copy to each edge node; The second module is used for acquiring the house source operation based on the local data copy, packaging the house source operation into a structured event object, calculating a two-dimensional priority vector and attaching the two-dimensional priority vector to the event object to acquire a marked synchronous event; the third module is used for constructing an edge and cloud dual-track parallel mechanism according to the marked synchronous event, processing the marked synchronous event and finally generating a scheduling instruction; And the fourth module is used for issuing a scheduling instruction to each edge node, executing data synchronization, constructing a lightweight analysis mechanism, providing scheduling advice and feeding back.

Description

Cloud edge fusion calculation-based real-time synchronous management method and system for distributed building resources Technical Field The invention relates to the technical field of edge computing, in particular to a real-time synchronous management method and system for a distributed building selling source based on cloud edge fusion computing. Background With the transformation of the real estate industry from extensive growth to refined operation, the commercial building source management is taken as a core business link, the technical system is continuously and iteratively upgraded along with the development of the industry, from single-disk operation to cross-region large-scale layout, from off-line traditional marketing to on-line off-line fusion mode, the evolution of the business state continuously promotes the real estate management system to upgrade to the intelligent, networked and collaborative directions, and solid technical support is provided for the efficient operation of the industry. Early-stage building selling source management relies on a purely manual recording mode, workers register data such as house source information, sales states and customer intentions through paper accounts, house source allocation and information synchronization completely depend on manual transmission, and the mode can meet the most basic management requirements, but has the problems of information update lag, low query efficiency, easy data error loss and the like, is only suitable for small-scale and single-place building selling business, and is difficult to adapt to the requirements of large-scale development of the real estate industry. In recent years, the real-time property industry enters a high-quality development stage, new business states such as online watching and intelligent marketing are continuously emerging, and higher requirements are put on real-time property and localization response capability of house source management. However, in the prior art, a centralized database is mainly adopted in a house source management mode, each building selling part directly performs data interaction with a headquarter central server through the internet, the problem of poor real-time data can be caused due to high pressure of the central server, and the problem of insufficient intelligent level is caused due to the fact that transregional allocation of house sources depends on manual experience. Disclosure of Invention The invention aims to provide a real-time synchronous management method and a real-time synchronous management system for a distributed building selling source based on cloud edge fusion calculation, which are based on a main system of a building selling part, are differentiated and built into a cloud end and edge node double-end data synchronous mechanism, and the real-time synchronous and cross-node dynamic scheduling of the state of the building source is realized from the acquisition and priority judgment of the data of the building source to an idle-hot point edge triggering mechanism, so that the problems of poor real-time performance of the data caused by high pressure of a central server and insufficient intelligent level caused by the fact that cross-region allocation of the building source depends on manual experience are solved. The invention provides the following technical scheme: The invention discloses a cloud edge fusion calculation-based real-time synchronous management method for a distributed building source, which specifically comprises the following steps: Based on the cloud of the total system of the vending building, a local data copy is built for each house source and is issued to each edge node; Based on the local data copy, acquiring a house source operation, packaging the house source operation into a structured event object, calculating a two-dimensional priority vector and attaching the two-dimensional priority vector to the event object to acquire a synchronous event with a mark; according to the marked synchronous event, an edge and cloud dual-track parallel mechanism is constructed, the marked synchronous event is processed, and finally a scheduling instruction is generated; And sending the scheduling instruction to each edge node, executing data synchronization, constructing a lightweight analysis mechanism, providing scheduling suggestions and feeding back. Further, the construction of the local data copy comprises the following steps: S1, acquiring a global unique house identifier, a global version number, a physical state, an attribution edge node ID, a basic base price and a synchronous time stamp from a cloud of a total system of a vending building to form a core state field set; s2, based on the cloud end of the total system of the vending building and the edge nodes, cooperatively calculating local recommended heat and estimated trading period to form an edge derivative field set; And S3, combining the core state field set and the edge derivative f