CN102376016B - Flow process integrated service device and utilize it to realize the method for system combination - Google Patents

Abstract

A method for realizing system integration by using a process integration server, comprising: receiving a txt file sent by a file adapter; querying required business data in a database server through a database query statement in the txt file; converting the queried business data into Business data conforming to the access format of the remote function call adapter; writing the business data conforming to the access format of the remote function calling adapter into the SAP system; receiving the log returned by the SAP system after executing the business data; and connecting the adapter to the Java database The log in the access format is sent to the database server, and the corresponding business data in the database server is updated by using the log. The present invention also provides a flow integration server, which can quickly write data from the database server to the SAP system and receive the execution result returned by the SAP system.

Description

Process integration server and method for realizing system integration by using it

technical field

The invention relates to a flow integration server, in particular to a flow integration server and a method for realizing system integration using the flow integration server.

Background technique

With the continuous advancement of information technology, more and more application systems have emerged within the enterprise, such as invoicing systems, purchasing systems, accounting systems, bonded systems, logistics systems and sales systems. Each application system has different data formats and adopts different data storage methods, for example, using a database (such as SQL server or VisualFox) to store data. When the SAP (Systems Applications and Products in Data Processing) system is introduced into the original application system, due to the difference in data format and data storage method, and when there are multiple forms in the database server, it is necessary to obtain the corresponding data from multiple forms and write them into SAP become difficult.

Contents of the invention

In view of the above, it is necessary to provide a process integration server, which can quickly write the business data in the database server into the SAP system, and receive the execution result returned by the SAP system.

It is also necessary to provide a method for realizing system integration by using the process integration server, which can quickly write the business data in the database server into the SAP system, and receive the execution result returned by the SAP system.

A process integration server, the process integration server is connected to a database server and a SAP system, a plurality of forms are stored in the database server, the process integration server includes a file adapter, a remote function call adapter and a Java database connection adapter, the process integration server Also includes: an acquisition module, used to receive the txt file sent by the file adapter, the content of the txt file is a database query statement; a query module, used to send the txt file to the database server, and through the database query statement in the txt file in the The database server queries the required business data; the acquisition module is also used to receive the query business data from the database server, and convert the query business data into business data conforming to the remote function call adapter access format; The writing module is used to write the business data conforming to the remote function call adapter access format into the SAP system; the receiving module is used to receive the log returned by the SAP system after executing the business data, and convert the log into conforming A log in the access format of the Java database connection adapter; and the sending module is also used to send the log conforming to the access format of the Java database connection adapter to the database server, and use the log to update the corresponding business data in the database server.

A method for realizing system integration by using a process integration server, the process integration server is connected to a database server and a SAP system, and includes a file adapter, a remote function call adapter and a Java database connection adapter, the method includes the following steps: receiving the txt file, the content of the txt file is a database query statement; send the txt file to the database server, and query the required business data in the database server through the database query statement in the txt file; receive the query result from the database server business data, and convert the business data inquired into business data conforming to the access format of the remote function call adapter; writing the business data conforming to the access format of the remote function calling adapter into the SAP system; receiving the SAP system to execute the business The log returned after the data, and the log is converted into a log that conforms to the access format of the Java database connection adapter; and the log that conforms to the access format of the Java database connection adapter is sent to the database server, and the corresponding business data in the database server is updated using the log.

Compared with the prior art, the process integration server and the method for realizing system integration by using it can search for business data in each form in the database that meets the query conditions according to user requirements, and the SAP system uses the functions provided by the process integration server to receive the query The received business data, and return the log of executing the business data to the database server, and update the data in the corresponding form in the database server.

Description of drawings

Fig. 1 is a schematic view of the operating environment of a preferred embodiment of the method for realizing system integration by using a process integration server in the present invention.

Fig. 2 is a flow chart of a preferred embodiment of the method for realizing system integration by using a process integration server in the present invention.

Description of main component symbols

Process Integration Server 1 File system 2 database server 3 SAP system 4 file adapter 10 Java database connection adapter 11 remote function call adapter 12 remote function call interface 40 get module 100 query module 101 sending module 102 write module 110 receiving module 111 transfer module 112

detailed description

As shown in FIG. 1 , it is a schematic diagram of the operating environment of a preferred embodiment of the method for realizing system integration by using a process integration server in the present invention. The process integration (PI) server 1 (hereinafter referred to as: PI server 1 ) is respectively connected to the file system 2 , the database server 3 and the SAP system 4 . The PI server 1 communicates with the database server 3 through a database connection, and the database connection may be Open Database Connectivity (ODBC), Java Database Connection (JavaDataBaseConnectivity, JDBC) and the like. In this embodiment, the database connection is JDBC. It should be pointed out that, in this embodiment, the process of receiving data from the database server 3 by the SAP system 4 is triggered by the PI server 1 at regular intervals, and requires synchronous return of data.

Multiple forms are stored in the database server 3, and multiple business data are stored in each form. The database server 3 can be set in the enterprise's internal purchase, sales and storage system, procurement system, accounting system, bonded system, logistics system and sales system.

The PI server 1 is used as the middleware between the database server 3 and the SAP system 4 for data transmission between the database server 3 and the SAP system 4 . The PI server 1 includes a file adapter (file adapter) 10, a JDBC adapter (JDBC adapter) 11 and a remote function call adapter (remote function call adapter, RFC adapter) 12. The fileadapter 10 is used to read a txt file from the file system 2, and the content of the txt file is a database query statement. The file system 2 is a file transfer protocol (File Transfer Protocol, FTP) server or a local file server. In this embodiment, the database query statement is a structured query language (StructuredQueryLanguage, SQL). The JDBC adapter 11 is used to send the query statement to the database server 3, and use the database query statement to query the required business data. The RFCadapter 12 is used for writing the business data into the SAP system 4, and receiving the logs returned by the SAP system 4 for executing the business data.

The SAP system 4 also includes an RFC interface 40, which serves as a communication interface between the PI server 1 and the SAP system 4, and is used for receiving the business data from the RFCadapter 12.

The JDBC adapter 11 in the PI server 1 includes: an acquisition module 100 , a query module 101 and a sending module 102 . The RF Adapter 12 includes: a writing module 110 , a receiving module 111 and a transmitting module 112 . The module is a software program segment with a specific function, and the software is stored in a computer-readable storage medium or other storage device, and can be executed by a computer or other computing device including a processor, so as to realize the implementation of the system using PI server 1 in the present invention. Integrated workflow.

The obtaining module 100 is used for receiving the txt file sent by the fileadapter10, the content of the txt file is a database query statement, and the format is in accordance with the format accessed by the JDBCadapter11.

The query module 101 is used to send the txt file to the database server 3, and query the required business data in the database server 3 through the database query statement in the txt file.

The acquisition module 100 is also used to receive the business data obtained from the query from the database server 3, and convert the business data obtained from the query into business data conforming to the access format of the RFCadapter12. Each business data has a corresponding identifier, and the identifier of each business data records the form where the business data is located and the field where the business data is located in the form.

The sending module 102 is configured to send the service data conforming to the access format of the RFCadapter12 to the RFCadapter12.

The writing module 110 is used to write the business data sent by the sending module 102 into the SAP system 4 through the RFC interface 40 .

The receiving module 111 is used to receive the log returned by the SAP system 4 after executing the business data, and the format of the log is in accordance with the format accessed by the RFCadapter12. In this embodiment, the log includes the execution result of executing each business data, and the execution result includes information about execution success or execution failure and reasons for execution failure. The receiving module 111 is also configured to convert the received log into a log conforming to the access format of JDBCadapter11.

The transmission module 112 is configured to transmit the log conforming to the JDBCadapter11 access format to the JDBCadapter11.

The sending module 102 is also configured to send the log sent by the sending module 112 to the database server 3, and use the execution result of each business data in the log to update the business data in the corresponding form in the database server 2. Specifically, the sending module 102 finds the corresponding field in the corresponding form in the database server 3 through the identifier corresponding to each business data in the log, and uses the execution result of each business data in the log to update the found field data in .

As shown in FIG. 2 , it is a flow chart of a preferred embodiment of the method for realizing system integration by using a process integration server in the present invention.

Step S30, the fileadapter 10 reads the txt file from the file system 2 according to the time interval set by the user, the content of the txt file is a database query statement, and expresses the txt file in a format conforming to JDBCadapter 11 access. In this embodiment, the time interval set by the user may be 1 day. In other embodiments, the time interval is not limited to 1 day, and it can be defined by the user.

Step S31 , the acquiring module 100 receives the txt file sent by the fileadapter 10 .

Step S32, the query module 101 sends the txt file to the database server 3, and queries the required business data in the database server 3 through the database query statement in the txt file.

Step S33, the acquisition module 100 receives the business data obtained from the query from the database server 3, and converts the business data obtained from the query into business data conforming to the access format of the RFCadapter12. Each business data has a corresponding identifier, and the identifier of each business data records the form where the business data is located and the field where the business data is located in the form.

In step S34, the sending module 102 sends the service data conforming to the access format of the RFCadapter12 to the RFCadapter12.

Step S35 , the writing module 110 writes the business data sent by the sending module 102 into the SAP system 4 through the RFC interface 40 .

Step S36 , the receiving module 111 receives the log returned by the SAP system 4 after executing the business data, and the format of the log is in accordance with the format accessed by the RFCadapter 12 . In this embodiment, the log includes the execution result of each business data, and the execution result includes information about execution success or execution failure and reasons for execution failure.

In step S37, the receiving module 111 converts the received log into a log conforming to the JDBC adapter 11 access format.

Step S38 , the sending module 102 sends the log sent by the sending module 112 to the database server 3 , and uses the execution result of each business data in the log to update the business data in the corresponding form in the database server 2 . Specifically, the sending module 102 finds the corresponding field in the corresponding form in the database server 3 through the identifier corresponding to each business data in the log, and uses the execution result of each business data in the log to update the found field data in .

Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention without limitation. Although the present invention has been described in detail with reference to the preferred embodiments, those of ordinary skill in the art should understand that the technical solutions of the present invention can be The scheme shall be modified or equivalently replaced without departing from the spirit and scope of the technical scheme of the present invention.

Claims (4)

1. A process integration server, the process integration server is connected to a database server and a SAP system, a plurality of forms are stored in the database server, the process integration server includes a file adapter, a remote function call adapter and a Java database connection adapter, its characteristics That is, the process integration server also includes: The obtaining module is used to receive a txt file with a suffix of txt sent by the file adapter, and the content of the txt file is a database query statement; The query module is used to send the txt file to the database server, and query the required business data in the database server through the database query statement in the txt file; The acquisition module is also used to receive the query business data from the database server, and convert the query business data into business data conforming to the access format of the remote function call adapter; A writing module, configured to write the business data conforming to the access format of the remote function call adapter into the SAP system; The receiving module is used to receive the log returned by the SAP system after executing the business data, and convert the log into a log conforming to the access format of the Java database connection adapter; and The sending module is further configured to send the log conforming to the access format of the Java database connection adapter to the database server, and use the log to update the corresponding business data in the database server. 2. The process integration server according to claim 1, wherein the log returned by the SAP system to execute the business data includes the information of execution success or execution failure of each business data and the reason for execution failure. 3. A method for utilizing a process integration server to realize system integration, the process integration server is connected to a database server and a SAP system, and includes a file adapter, a remote function call adapter and a Java database connection adapter, it is characterized in that the method includes the following steps : Receive the txt file whose suffix is txt sent by the file adapter, and the content of the txt file is a database query statement; Send the txt file to the database server, and query the required business data in the database server through the database query statement in the txt file; Receive the queried business data from the database server, and convert the queried business data into business data conforming to the access format of the remote function call adapter; Writing the business data conforming to the access format of the remote function call adapter into the SAP system; receiving the log returned by the SAP system after executing the business data, and converting the log into a log conforming to the access format of the Java database connection adapter; and Send the log conforming to the access format of the Java database connection adapter to the database server, and use the log to update the corresponding business data in the database server. 4. The method of utilizing a process integration server to realize system integration as claimed in claim 3, wherein the log returned by the SAP system to execute the business data includes the information of execution success or failure of execution of each business data and the reason for the execution failure.