Background
The production equipment is the foundation of the enterprise for production and operation and is an important asset of the enterprise. The production equipment is a special asset, depreciates with time, and within a limited time, the utilization rate of the production equipment is improved, and the enterprise value can be effectively improved. Good equipment plays an important role in improving product quality, reducing defective rate and improving yield.
The manufacturing execution system is an important management system for connecting the upper-layer plan and the workshop production management, and the whole production management process is effectively optimized. Production equipment management and production equipment monitoring are two important modules of a manufacturing execution system. The production equipment management is responsible for operation and maintenance of the production equipment, and good operation of the production equipment is ensured by establishing point inspection, routing inspection, periodic inspection and other modes. The production equipment monitoring is in charge of monitoring and recording the running state of the production equipment in real time, so that the equipment fault can be effectively early warned, the product quality is improved, and the defective rate is reduced, so that the timely response to the equipment state becomes an important check point for monitoring the production equipment.
The processing and manufacturing enterprises have various and large number of production equipment types, so that the equipment state acquisition modes are different, the acquired information difference is large, and the types are various. The collection modes mainly comprise modes such as PLC, DCS, SCADA and the like, and the types of the collected data comprise equipment startup, equipment shutdown, equipment operation, temperature, air pressure, humidity, rotating speed and the like. Therefore, a uniform data information format and a data transmission mode need to be established.
Therefore, the multi-service cluster design method for realizing the real-time monitoring of the state of the production equipment has very important significance. The data information format and the data transmission mode are abstracted and summarized, the data information format and the data transmission mode are in butt joint with OPC service, and more equipment types and collected information can be covered. The three-level layered Service cluster and the load balancing mechanism can realize the timely response to the equipment state signal, and the release and subscription mechanism of Event Service and Present Service and the release and subscription mechanism of Present Service and presence terminal can realize the equipment state update at the terminal at the first time.
Disclosure of Invention
Aiming at the defects of the prior art, the invention provides a multi-service cluster design method for realizing real-time monitoring of the state of production equipment, and solves the problem of difficult development and maintenance caused by diversified state information of the production equipment.
The technical scheme adopted by the invention for realizing the purpose is as follows:
a multi-service cluster design method for realizing real-time monitoring of production equipment state,
step 1: summarizing and abstracting the equipment state information, and defining the format, the content, the packaging method and the analysis method of the equipment state information;
step 2: defining a service cluster and a load balancing algorithm of the service cluster;
and step 3: summarizing and abstracting a data acquisition information transmission mode, and defining a production equipment monitoring service subscription interface specification and a subscription interface specification of a presentation service module;
and 4, step 4: the OPC Service encapsulates the equipment state information change, simultaneously triggers a production equipment monitoring Service interface, and a production equipment monitoring Service module analyzes the encapsulated information and issues monitoring information of a production process to an event processing Service module according to a load balancing algorithm;
and 5: and the event processing service module sends the processed business to the business presentation service module, and the business presentation service module pushes presentation information to the subscribed presentation terminal according to the subscription interface specification of the presentation service module, and the presentation terminal updates the equipment state information in real time.
The service cluster includes:
the production equipment monitoring service module receives the production equipment state monitoring information, determines the type of the production equipment state monitoring information according to the attribute of the production equipment state monitoring information, identifies the production equipment state monitoring information, and generates an attribute set of the monitoring information;
the event processing service module is responsible for processing the business events of the production equipment, subscribes to the production equipment monitoring service module and receives the production equipment state monitoring information issued by the production equipment monitoring service module;
the service presentation service module is used for receiving the instruction information of the event processing service module and updating the presentation of the state monitoring information of the production equipment on the terminal according to the instruction information;
and the presentation terminal presents the state monitoring information of the production equipment in different application forms, subscribes to the service presentation service module and receives the instruction issued by the service presentation service module.
The attribute set of the monitoring information comprises a production equipment unique identifier, a collection site unique identifier, an information type, an information value and a timestamp.
The load balancing algorithm is as follows:
Min(T(SEi))=>SEi,i∈{1,N}
wherein, T (SE)i) For the ith Event Service execution completionTime spent on tasks, T (SE)ij) The time taken for the ith Event Service to execute the jth task;
and the new task is distributed to the Event Service with the minimum time required for executing all the tasks in all the current Event services.
The attribute set of the monitoring information is as follows:
wherein, IiFor monitoring information, N is a natural number.
The subscription interface specification of the production equipment monitoring service module is as follows:
the event processing service module subscribes to the production equipment monitoring service module, and after the subscription is successful, the production equipment monitoring service module actively pushes monitoring information to the event processing service module, which is expressed as: SUBe=f(P,Ii) Wherein P represents Event Service, IiIndicating monitoring information.
The subscription interface specification of the presence service module is as follows:
the presence terminal subscribes to the service presence service module, and after the subscription is successful, the service presence service module actively pushes monitoring information to the presence terminal, which is expressed as: SUBc=f(Q,QIi) Wherein Q denotes a service presence service Module, QIiRepresenting service presence information.
The invention has the following beneficial effects and advantages:
1. the three-level layered service cluster and the load balancing mechanism can realize the timely response to the equipment state signal;
and 2, the release and subscription mechanism of the Event Service and the Present Service and the release and subscription mechanism of the Present Service and the presence terminal can realize the equipment state updating at the terminal at the first time.
Detailed Description
The present invention will be described in further detail with reference to the accompanying drawings and examples.
In order to make the aforementioned objects, features and advantages of the present invention more comprehensible, embodiments accompanying the drawings are described in detail below. In the following description, numerous specific details are set forth in order to provide a thorough understanding of the present invention. This invention may, however, be embodied in many different forms and should not be construed as limited to the embodiments set forth herein, but rather should be construed as modified in the spirit and scope of the present invention as set forth in the appended claims.
Unless defined otherwise, all technical and scientific terms used herein have the same meaning as commonly understood by one of ordinary skill in the art to which this invention belongs. The terminology used in the description of the invention herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the invention.
As shown in fig. 1, a multi-service cluster design method for real-time monitoring of the status of production equipment includes the following steps:
step 1: summarizing and abstracting the equipment state information, and defining the format, the content, the packaging method and the analysis method of the equipment state information;
step 2: defining the hierarchical relation of (Trace Service, Event Service and Present Service) Service clusters, and defining the Service ranges of Trace Service, Event Service and Present Service;
and step 3: defining a load balancing algorithm of (Trace Service, Event Service and Present Service) Service clusters, improving the real-time response capability to the equipment state information change and reducing the delay;
and 4, step 4: summarizing and abstracting a data acquisition information transmission mode, and defining interface specifications of OPC Service and Trace Service;
and 5: defining interface specifications of a Present Service and a presentation terminal;
step 6: the method comprises the steps that OPC Service encapsulates equipment state information change, meanwhile, a Trace Service interface is triggered, Trace Service analyzes encapsulated information, Event Service processing is arranged according to a load balancing algorithm, after the Event Service performs Service processing, Present Service is called to perform information presentation, the Present Service pushes presentation information to a subscribed terminal according to interface specifications, and the presentation terminal updates equipment state information in real time.
The attribute set of the monitoring information is as follows: { production equipment unique identifier, acquisition site unique identifier, information type, information value, and timestamp }.
Hierarchical relationship of the service cluster:
the first-level Service Trace Service is triggered by the OPC Service, is responsible for receiving equipment state information sent by the OPC Service in real time, analyzing the equipment state information and transmitting the analyzed information to Event Service according to a load balancing algorithm, wherein the number of the services is 1;
second-tier Service Event Service set, denoted as
Wherein SE
iEach Event Service is triggered by the Trace Service, and is responsible for receiving data information sent by the Trace Service, performing Service logic processing and triggering the Present Service to update the equipment state;
a third tier Service Present Service set, denoted as
Wherein SP
iThe Service is a basic Present Service, is triggered by the Event Service, is responsible for receiving data information sent by the Event Service, and pushes presentation information to a subscribed terminal according to interface specifications.
The load balancing algorithm of the (Trace Service, Event Service, Present Service) Service cluster comprises the following steps:
(2)Min(T(SEi))=>SEi,i∈{1,N}
equation 1: wherein T (SE)i) For the ith EventThe time it takes for Service to complete all tasks, T (SE)ij) The time it takes to execute the jth task for the ith Event Service.
Equation 2: and the new task is distributed to the Event Service with the minimum time required for executing all the tasks in all the current Event services.
The triggering mechanism of the service cluster comprises the following steps:
the method comprises the steps that OPC Service encapsulates equipment state information change, meanwhile, a Trace Service interface is triggered, Trace Service analyzes encapsulated information, Event Service processing is arranged according to a load balancing algorithm, after the Event Service performs Service processing, Present Service is called to perform information presentation, the Present Service pushes presentation information to a subscribed terminal according to interface specifications, and the presentation terminal updates equipment state information in real time.
Table 1 describes the production equipment status change. 5 devices are set, and each device has 3 state acquisition points.
TABLE 1
Table 2 describes the Event Service set, and assuming that three Event services are provided, the time taken for the Event services to execute a single task is set to 1 second, and when the three Event services are simultaneously selectable, the three Event services are selected in the order of priority from small to large.
TABLE 2
Time: 2018-03-0808: 00:00, no executable task exists in an Event Service set { SE01, SE02 and SE03}, a queue is empty, three acquired signals { E1001, E2001 and E1002}, the acquired signals enter an SE01 queue according to a calculation method E1001, the occupied capacity of the SE01 queue is 1, the occupied capacity of the E2001 entering queue is SE02, the occupied capacity of the SE02 queue is 1, the E1002 entering queue 03 and the occupied capacity of the SE03 queue is 1;
time: 2018-03-0808: 00:01, E1001 completes execution, leaves the SE01 queue, the occupied capacity of the SE01 queue is 0, E2001 completes execution, leaves the SE02, the occupied capacity of the SE02 queue is 0, E1002 completes execution, leaves the SE03, and the occupied capacity of the SE03 queue is 0. No acquisition signal is generated, and no enqueue distribution is performed;
time: 2018-03-0808: 00:05, E2002 generates signals, Event Service sets { SE01, SE02 and SE03} have no executable tasks, queues are empty, the Event Service sets enter an SE01 queue according to a calculation method E2002, and the occupied capacity of the SE01 queue is 1;
time: 2018-03-0808: 00:06, E3001 generates signals, E2002 is executed completely, the E3001 leaves an SE01 queue, the occupied capacity of an SE01 queue is 0, the E3001 enters an SE01 queue according to a calculation method, and the occupied capacity of an SE01 queue is 1;
time: 2018-03-0808: 00:07, E3002 generates signals, E3001 completes execution, the signals leave an SE01 queue, the occupied capacity of an SE01 queue is 0, the signals enter an SE01 queue according to a calculation method, and the occupied capacity of an SE01 queue is 1;
time: 2018-03-0808: 00:08, E3002 completes execution, leaves the SE01 queue, and the occupied capacity of the SE01 queue is 0. No acquisition signal is generated, and no enqueue distribution is performed;
time: 2018-03-0808: 00:10, an E2003 generates signals, no executable task exists in an Event Service set { SE01, SE02 and SE03}, a queue is empty, the E2003 enters an SE01 queue according to a calculation method, and the occupied capacity of the SE01 queue is 1;
time: 2018-03-0808: 00:11, E2003 execution is completed, and leaves the SE01 queue, and the occupied capacity of the SE01 queue is 0. No acquisition signal is generated, and no enqueue distribution is performed;
time: 2018-03-0808: 00:15, E1003 generates signals, no executable task exists in an Event Service set { SE01, SE02 and SE03}, a queue is empty, the Event Service set enters an SE01 queue according to a calculation method E1003, and the occupied capacity of the SE01 queue is 1;
time: 2018-03-0808: 00:16, the E4001 generates signals, the E1003 is executed completely, the E1003 leaves an SE01 queue, the occupied capacity of an SE01 queue is 0, the E4001 enters an SE01 queue according to a calculation method, and the occupied capacity of an SE01 queue is 1;
time: 2018-03-0808: 00:17, the E5001 generates signals, the execution of the E4001 is completed, the E4001 leaves an SE01 queue, the occupied capacity of an SE01 queue is 0, the E5001 enters an SE01 queue according to the calculation method, and the occupied capacity of an SE01 queue is 1;
time: 2018-03-0808: 00:18, the E4002 generates signals, the E5001 completes execution, the E5001 leaves an SE01 queue, the occupied capacity of an SE01 queue is 0, the E4002 enters an SE01 queue according to a calculation method, and the occupied capacity of an SE01 queue is 1;
time: 2018-03-0808: 00:19, E4002 completes execution, leaves the SE01 queue, and the occupied capacity of the SE01 queue is 0. No acquisition signal is generated, and no enqueue distribution is performed;
time: 2018-03-0808: 00:30, wherein an Event Service set { SE01, SE02 and SE03} has no executable task, a queue is empty, four acquired signals { E4003, E5002, E5003 and E3001} exist, the acquired signals enter an SE01 queue according to a calculation method E4003, the occupied capacity of the SE01 queue is 1, the occupied capacity of the E5002 entering queue is SE02, the occupied capacity of the SE02 queue is 1, the E5003 enters the queue SE03, the occupied capacity of the SE03 queue is 1, the E3001 enters an SE01 queue, and the occupied capacity of the SE01 queue is 2;
time: 2018-03-0808: 00:31, E4003 completes execution, leaves the SE01 queue, the occupied capacity of the SE01 queue is 1, E5002 completes execution, leaves the SE02, the occupied capacity of the SE02 queue is 0, E5003 completes execution, leaves the SE03, and the occupied capacity of the SE03 queue is 0. No acquisition signal is generated, and no enqueue distribution is performed;
time: 2018-03-0808: 00:32, E3001 completes execution, leaves the SE01 queue, and the occupied capacity of the SE01 queue is 0. No acquisition signal occurs, and no enqueue allocation is performed.