KR100503291B1 - A transaction united message processing system with a hierarchical structure for a process of analayzing and performing the realtime transaction-processing request message - Google Patents

Abstract

The present invention is a transaction integrated message processing system and processing for processing a message requesting a transaction from various external channels by layering the work for transaction processing into three layers to facilitate the development and maintenance of transaction-oriented tasks In more detail, a network connection control unit for receiving an external request message generated from an external channel, a message conversion unit for analyzing the external request message and converting it into TWA data of a workspace, and a workspace storage unit for storing TWA data An on-line business processing unit which calls a business processing program to perform TWA data to process a transaction and reflects the processing result to the TWA data to generate an external response message for the processing result; Import TWA data, if any To perform internal operations associated stand is characterized in that it comprises an internal business processing.

Therefore, developers can focus more on application applications, such as business work procedures or user convenience, and develop without knowledge of physical systems such as DB or network, and make maintenance easier, and classify priorities into external online work and internal offline work. In other cases, the appropriate allocation process enables fast response to customer processing requirements and increases the efficiency of system resource usage.

Description

A transaction united message processing system with a hierarchical structure for a process of analayzing and performing the realtime transaction-processing request message}

The present invention is a transaction integrated message processing system and processing for processing a message requesting a transaction from various external channels by layering the work for transaction processing into three layers to facilitate the development and maintenance of transaction-oriented tasks It is about a method.

Recently, with the activation of e-business, there is a growing demand for the development of a system that can operate transactions-oriented tasks such as bank account system, internet banking, CDMS, financial common network, corporate banking and e-commerce. In particular, as the needs of customers diversify, the demand for addition and change of new services increases, and accordingly, the cost of changes to the already developed system increases.

However, transaction processing, which is the core of these system developments, is mainly a unit for processing data input or transaction inquiry to the database, and must maintain a consistent state of the database. That is, the atomicity that allows a transaction to have all or none of its execution, but not some of its execution, the consistency of maintaining a consistent database state every time a transaction completes successfully, and The task must satisfy four conditions of inaccessibility: isolation, and durability, which in any case guarantees the outcome of a successful execution of a transaction.

Therefore, Online Transaction Processing (OLTP), a dedicated program that can safely and efficiently manage and manage transaction processing, is introduced. Existing OLTP acts as a data path for communication between client and server, maintains and manages the connected session between client and server, and finds the services required for client work requests. In addition, it finds programs scattered among multiple servers, routes requests from clients to the programs it finds, monitors server programs, manages database transactions, and coordinates with databases.

However, if the conventional technology is applied to the field to execute a transaction occurring in the e-business, there is a guarantee about the transaction performed in the system, but there is a problem that is not guaranteed for the troubled transaction occurring during the processing in the application. have.

In addition, since the conventional technology merely provides an API for a physical task for transaction processing, a lot of cost and time are required for the development or maintenance of the system. In particular, maintenance costs are significantly higher in today's environment where customer requirements vary and are constantly changing.

In addition, there are tasks that need to be processed immediately during operations for transaction processing, but tasks that do not need to be processed internally immediately, but the prior art does not provide a means for distinguishing these tasks, thereby reducing the efficiency of the system. There is a problem of delaying the response of a transaction's online work request.

In order to solve this problem, in the related art, a method of separating and operating a system or preparing a plurality of servers and processing a transaction according to a work request requested by a user has been proposed. However, since a plurality of systems or servers are used, hardware It has a problem that it is expensive.

The present invention has been made to solve the above problems, the developer can focus more on application applications, such as business tasks or user convenience, and can develop without knowledge of the sub-physical system such as DB or network, and also maintenance To make it convenient, it aims to provide a transaction integrated message processing system and processing method that provides a layered task for transaction processing in three or n layers, and provides a standard API for the interface between the layers. do.

In addition, in order to support rapid response to customer processing requests and to increase the efficiency of using system resources, external online tasks that need to be processed immediately and those that do not need to be processed immediately in conjunction with these online tasks are required. It aims to provide transaction integrated message processing system and processing method that can be processed with different priority by dividing into internal offline work.

In addition, the transaction integrated message processing system that provides an efficient method for the failure and backup by separating the flow of the transaction, and can be completed by reprocessing even if an error occurs in the process of processing the internal work of the transaction and The purpose is to provide a treatment method.

Transaction integrated message processing system of the present invention for achieving the above object,

A business processing program storage unit for storing business processing programs corresponding to each transaction;

A business logic execution module capable of performing the business logic of the business processing program in physical unit operations;

A network connection controller for receiving an external request message generated from an external channel;

A message conversion unit for analyzing the external request message and converting the external request message into TWA data including information of a work processing program to be performed and input data of the program; And

A workspace storage unit for storing TWA data;

An on-line business processing unit which calls a business processing program to perform TWA data to perform transaction processing, stores the TWA data in the work area storage by reflecting the processing result in the TWA data, and generates an external response message for the processing result;

Characterized in that it comprises a.

In addition, the present invention transaction integrated message processing method,

Receiving an external request message requesting a transaction processing operation from an external channel;

Analyzing the external request message and converting the external request message into TWA data including information of a work processing program to be performed and input data of the program;

Calling a business program to perform the TWA data to perform transaction processing and reflecting the processing result in the TWA data;

Generating an external response message for the transaction processing result; And

Transmitting the external response message to an external channel;

Characterized in that it comprises a.

Hereinafter, a transaction integrated message processing system and processing method of the present invention will be described in detail with reference to the accompanying drawings.

1 illustrates a configuration of a system for processing a transaction.

A transaction is usually a unit that handles data entry or transaction lookup for a database. As shown in FIG. 1, the client system 20 requesting such a transaction is connected to the network 10 to transmit a message requesting transaction processing to the transaction processing system 30. The client system 20 may be an internal server connected to an internal network, or a system of legacy and external organizations connected by a dedicated network or a network of the Internet. Therefore, the communication protocols supported by the network 10 may be X.25, TCP / IP, SNA, LU6.2, or the like.

The client system 20 may access the transaction processing system 30 on a web basis. In this case, the web server 40 is installed in front of the transaction processing system 30 to provide a web page to the client system 20, and receive the input values, extract the transaction request message, and process the transaction processing system 30. To send.

The transaction database server 50 is a server that manages a database that stores data and information related to transaction tasks. The final outcome of the transaction is to change, add, delete, or query the data in this database.

2A illustrates a hierarchical structure of a task for processing a message for requesting transaction processing according to the present invention. As shown in FIG. 2, the layer for processing a transaction request message of the present invention is divided into a physical layer, a business logic layer, and a client layer.

The physical layer consists of physical unit operations 260. Since the final physical work on the transaction request message is to change, add, delete, or query data in the transaction database, the physical unit work is mainly performed on the database such as DB query, DB insert, DB delete, DB update is included. Other tasks may include verifying that the input field value of the message is the correct input value.

The business logic layer is a layer that processes a message using the business logic 250, the business processing program 240, and the TWA data 230. The business logic 250 corresponds to a logical unit task that abstracts the physical unit tasks 260 of the physical layer. As shown in FIG. 2B, the business logic 250 may include a DB query, a DB insert, a DB delete, a DB update, and the like, which are physical unit operations 260, and may include tasks defined by a user. The user-defined class is composed of several physical unit operations 260 to define frequently used tasks.

The business processing program 240 is a program created by configuring a series of physical tasks for processing a transaction into the business logic 250. 2C shows that business process program 240 is implemented by a series of business logic 250. This allows developers to develop programs that process transactions without the need for knowledge of the capabilities of physical devices such as specific databases or networks. That is, the developer only needs to write a business processing program 240 for processing a transaction using only the business logic 250. In addition, the separation by this layer has the advantage that it is easy to change the physical system. For example, even if the database server 50 is upgraded or replaced with another product, such as Sybase, from the Oracle product, the business process program 240 can be used as it is.

TWA data 230 may be viewed as a standardized transaction request message. As shown in FIG. 2D, the TWA data 230 includes a transaction work common area 231, client session information 232, external input information 233, internal linkage information 234, internal ledger information 235, and the like. It consists of.

The transaction work common area 231 is information about an area that is commonly used in all projects, and includes information about the total length of the TWA data, the date of the transaction, the ID and name of the work processing program 240, the work processing screen number, and the like. Have

Client session information 232 includes basic information about the client system 20 that generated the transaction request message. For example, if the client system 20 is a financial terminal, an IP address, a MAC address, a terminal number, a terminal user ID, etc. of the financial terminal correspond. The external input information 233 has input data for input fields of a transaction requested by the client.

Internal interworking information 234 includes basic information on whether there is an internal task to be associated with this task when the online task of the transaction requested by the client is processed.

Internal ledger information 235 is information for storing informational data that may occur while processing a transaction requested by a client. That is, information for storing intermediate and final result values generated during transaction processing. When the online work for transaction processing is completed, the client system 20 refers to the information in the internal ledger information 235 to generate and pass a message about the result. In addition, the business processing program 240 may process the business without referring to a separate DB or file with reference to the internal ledger information 235. This can improve throughput by reducing unnecessary I / O.

In summary, the TWA data 230 includes not only information about the business processing program 240 for processing the requested transaction and input data of the program, but also information on the work involved, intermediate processing results, and final processing results. In addition, the work for processing the requested transaction is specifically defined data, and it is also a work area that records the state in which the work is actually performed.

The client layer is represented by an external request message 210. The external request message 210 is a message requesting a transaction from the client system 20 side, and the format of the external request message 210 may vary according to the type of the client system 20. 2E shows an example of an external request message 210 in accordance with one embodiment of the present invention.

In processing a message requesting transaction processing, by hierarchizing the external request message 210 of the client layer and the TWA data 230 of the business logic layer, maintenance of the system for a transaction is easy and system flexibility is secured. For example, it can process transaction request messages of various client systems 20, upgrade the transaction processing system 30 without changing many client systems 20, and upgrade numerous client systems 20 as a whole. When changing some of the client system 20, it is possible to change all the client system 20 in stages.

As described above, the present invention is divided into three steps to process the transaction processing. Next, I will explain the transaction integrated message processing system and processing method to specifically handle the three-layered work.

3 is a block diagram of a transaction integrated message processing system according to an embodiment of the present invention.

As shown in FIG. 3, the transaction integrated message processing system 300 includes a network connection controller 310, an online business processor 320, a message converter 330, a work area storage 340, and an internal business processor 350. ), A business processing program storage unit 360, and a business logic execution module 370.

The work processing program storage unit 360 stores the work processing program 240 described above. The work processing program 240 is a program written in the business logic 250 and processes a transaction.

The business logic execution module 370 analyzes the business processing program 240 to execute a series of business logic 250. The execution of the business logic 250 is handled by performing the physical unit work 260 corresponding to each business logic 250.

The network connection controller 310 receives the external request message 210 from the external channel 25. The external channel 25 corresponds to the client system 20 described above. From the point of view of the transaction integrated message processing system 300, since the client system 20 is connected through the network 10 to transmit an external request message 210, the transaction integrated message processing system 300 using one channel Can be seen as requesting). Therefore, the external channel 25 and the client system 20 are the same, and will be described later as the external channel 25.

As shown in FIG. 4A, the network connection controller 310 includes an external channel message receiver 311, a received message analyzer 312, an external channel information storage 313, a message processing result receiver 314, and an external channel. The message transmitter 315 is included.

The external channel information storage unit 313 stores in advance information on a message origin, a transaction type, a message destination, a message length, and the like, for each external channel 25.

4B illustrates a data structure diagram of external channel information 410 according to an embodiment of the present invention. As shown in FIG. 4B, the external channel information 410 is a process name capable of distinguishing a process such as an ID of a process connected to the external channel 25, a server waiting for an external connection as a processor, or C / S classification that indicates whether the client is waiting to be connected to the outside, company that requests transaction by connecting, company number, communication protocol, etc. to distinguish the type of input media such as mobile / ATM And information on a method (IPC) for transmitting the received data therein, information on a message type such as compression, encryption, or the like promised by the company's information.

The external channel message receiver 311 receives the external request message 210 from the external channel 25. The external channel message receiver 311 interfaces with an internal server, legacy and external organizations, and the communication protocol supports X.25, TCP / IP, SNA, and LU6.2. The type of interface between the external channel message receiver 311 and the external channel 25 includes an interface between the webgate and the network connection controller, an interface between the network connection controller, and an interface between the external organization and the network connection controller.

The reception message analyzer 312 uses the connection information of the external channel 25 such as a source of the external request message 210 received from the external channel 25 and a destination of the external response message 280 as a key. Reference is made to the external channel information of the external channel information storage unit 313. The referenced external channel information is added as channel header information before the external request message 210. The format of the external request message 210 according to the external channel 25 is different, and when processing other operations for a transaction, the channel of the external request message 210 is referred to in order to refer to information on the required external channel 25. Reference is made to the header information 420. 4C shows configuration information of the channel header information 420 according to an embodiment of the present invention. As shown in FIG. 4C, the channel header information 420 refers to the external channel information described above, and is required when analyzing the message and information such as a company code or IP address information that can identify the external system requested by the message. Information such as the type of message, and the like.

Finally, the received message analyzer 312 transmits the external request message 210 to which the channel header information is added, to the online business processor 320.

The message processing result receiving unit 314 receives the external response message 280 that is the processing result in the online business processing unit 320.

The external channel message transmitter 315 analyzes the channel header information of the external response message 290 to find the external channel 25 corresponding to the origin and destination of the message, and the external response message 290 to the found external channel 25. ).

The message conversion unit 330 analyzes the external request message 210 and converts the TWA data 230 including information of the work processing program 240 to be performed and input data of the program.

As shown in FIG. 5A, the message conversion unit 330 includes a reference map file search unit 331, a message mapping unit 332, a mapping CA storage unit 333, a reference map file storage unit 334, and mapping information. It consists of a storage unit 335.

The mapping CA storage unit 333 stores information that can be commonly used, such as branch network information, terminal information, business date, next business day, and network status required for online transactions. 5B illustrates information on mapping CA according to an embodiment of the present invention. As shown in FIG. 5B, the mapping CA information 510 stores the state information of the branch network (fault / normal, opening / closing), terminal state (fault / normal, start / closing), and network state (fault / normal) in the memory. For example, information such as the business date (if necessary, may be operated differently from the actual date), holiday classification, etc., is loaded into memory and referred to when generating TWA data.

The reference map file storage unit 334 stores a file that maps field values of the external request message 210 to field values of the TWA data 230.

The mapping information storage unit 335 stores information about the reference map file to be referred to according to the transaction type of the external request message 210.

The reference map file search unit 331 extracts the transaction type from the external request message 210 and references the mapping information storage unit 335 to refer to the reference when mapping from the external request message 210 to the TWA data 230. Search for the map file.

The message mapping unit 332 copies the mapping CA information 510 of the mapping CA storage unit 333 to the TWA data 230, and converts the external request message 200 to the TWA data 230 using the retrieved reference map file. ) To generate TWA data 230.

The work area storage unit 340 stores the TWA data 230.

As shown in FIG. 6, the workspace storage unit 340 includes a TWA data store 341, a TWA index store 342, an internal business process index store 343, and an internal business reprocessing index store 344. do.

The TWA data store 341 stores the actual TWA data 230 and stores the unique serial number information of the TWA data 230 in the TWA index store 342 as index information of the TWA data 230.

The internal task processing index storage 343 separately stores index information of the TWA data 230 in order to separately process the internal task when there is an internal task involved in the online task of the TWA data 230.

The internal business reprocessing index storage 344 separately stores index information of the TWA data 230 when an error occurs during internal business processing of the TWA data 230 and needs to be reprocessed again.

The online business processing unit 320 calls the business processing program 240 to perform the TWA data 230 to perform transaction processing, and reflects the processing result to the TWA data 230 to store the TWA data 230 in the work area storage unit. In operation 340, an external response message 280 for the processing result is generated and sent to the network connection controller 310. In addition, the online business processing unit 320 records that there is an internal work involved in the TWA data 230 when there is an internal work involved in the online work of the TWA data 230.

As shown in FIG. 7A, the online business processing unit 320 may include a message conversion management unit 321, a TWA data analysis unit 322, a business business processing unit 323, a transaction division processing unit 324, and an internal business information storage unit ( 325).

The internal task information storage unit 325 defines and stores the internal task involved according to the transaction type of the online task.

The message conversion management unit 321 causes the external request message 210 to be converted into the TWA data 230 by the message conversion unit 330.

The TWA data analysis unit 322 analyzes the TWA data 230 and searches for a corresponding business processing program 240.

The business task processing unit 323 executes the work processing program 240 by the business logic execution module 370, and reflects the result information into the TWA data 230 to apply the TWA data 260 to the work area storage unit 340. Stored in, and generates an external response message 280 and transmits to the network connection controller 310.

The transaction partition processing unit 324 refers to the internal task information storage unit 325 for each transaction and records that there is an internal task in the TWA data 230 when there is an accompanying internal task, and for the TWA data 230. The internal business process index information is stored in the work area storage unit 340.

The internal task processing unit 350 imports the TWA data 230 having the internal task involved in the work area storage unit 340 to perform the internal task involved.

8A shows the types of internal tasks involved in the online task of a transaction.

The internal task processor 350 provides a function to accumulate information or process a large amount of data in the same pattern to process an internal task associated with an online task of a transaction.

Internal work has the following principles compared to online work. The first is that it should not affect online work. This principle of conduct distinguishes and distinguishes between on-line work and the accompanying internal work. In other words, if it affects online work, it cannot be handled as an internal task, but must be handled as online work. Second, the accompanying internal tasks must be handled normally. As we saw earlier, a transaction must satisfy atomicity such that it has only all or none of its execution and some of its execution. Therefore, since the online work has already been performed and some work has been performed, the accompanying internal work must be performed.

Examples of processing internal tasks involved in the present invention include LUMP, BATH, DFRD, RQRS, and RQNS. LUMP is a task to support tasks that require batch processing such as bulk transfer or bulk file creation and processing. BATH (BATcH) is for handling batch tasks according to scheduling. There is a difference between processing online when a request is made and BATH being driven by scheduling. DFRD (DeFeReD) is an internal business function involved in the on-line processing of transactions. Its main purpose is to database information. Bank internal processing, which is not directly related to customers, is mainly used to build an informational database such as accounting information, customer (CRM) information and management (MIS) information. RQNS (ReQuestReSponse) is processed in accordance with the conditions while performing the business process program 240, and returns the result (return). Examples include constant monitoring, incident reporting, and limit management.

As shown in FIG. 8B, the internal business processing unit 350 includes a TWA data loader 351, a TWA data analysis unit 352, an internal business execution unit 353, and an internal business processing failure management unit 354.

The internal business processing unit 350 is operated until the internal business accompanying is necessarily processed, and is operated independently from the online business processing unit 320. Internal task processing unit 350 is performed at a predetermined interval according to the execution interval set in the execution environment information through the internal task processing initialization operation at startup. Normally, it is in the sleep state and waits for a certain time after the execution interval, and performs the task, and returns to the standby state when the execution is completed.

In the running state, the TWA index information to be processed is first read from the internal business processing index storage 343 or the internal business reprocessing index storage 344 of the workspace storage unit 340. That is, the TWA data loader 351 reads the TWA data 230 through internal task index information or internal task reprocessing index information of the TWA data 230 stored in the work area storage 340. The TWA data loader 351 reads the TWA data 230 from the TWA data store 341 of the workspace storage unit 340 using the TWA data index information as a key.

The TWA data analysis unit 352 analyzes the TWA data 230 and searches for a business processing program 240 to perform internal work.

The business internal task execution unit 353 executes the searched business process program 240. The input value of the work processing program 240 takes the input data of the TWA data 230 as input and executes the program by executing the physical unit work 260 through the business logic execution module 370.

If a failure occurs while processing an internal task in the business internal task performing unit 353, the internal task processing fault management unit 354 may provide the internal task reprocessing index information on the TWA data 270 that is being performed by the work area storage unit 340. The internal business reprocessing job index storage 344. As described above, the reprocessing job index information stored by the TWA data loader 351 is read to perform reprocessing of internal tasks. At this time, the stored reprocessing operation is repeatedly performed until normal processing.

9 is a flowchart illustrating a method of processing a transaction integration message according to an embodiment of the present invention.

As shown in FIG. 9, an external request message 210 for initially requesting a transaction processing operation is received from an external channel 25 (S110). When the external request message 210 is received, the external channel for the external channel 25 that transmits the message with reference to the external channel information stored in advance, such as the message source, the transaction type of the message, the destination of the message, the length of the message, and the like. Information is added to the external request message 210 as channel header information (S111).

After receiving the external request message 210, the received external request message 210 is analyzed and converted into TWA data 230 which is a work area for performing a transaction (S120). In more detail, the transaction type is extracted from the received external request message 210, the reference map file corresponding to the transaction type is searched (S121), and the external request message 210 is referred to with reference to the reference map file. Mapping to TWA data 230 is generated (S122), and finally, mapping CA information 510, which is common information for online business processing, is added to TWA data 230 (S123).

After converting the external request message 210 to the TWA data 230, the business program 240 to perform the TWA data 230 is called to perform transaction processing, and the processing result is reflected in the TWA data 230. (S130). In more detail, the TWA data 230 is analyzed to search for a corresponding business processing program 240 (S131), the business processing program 240 is performed by the business logic execution module 370, and the result information. This is reflected in the TWA data 230 (S132).

When the online work of the TWA data 230 is completed, it is determined whether there is an internal task involved in the online work of the TWA data 230 (S140).

If there is no accompanying internal task, it immediately generates an external response message 280 for the transaction processing result (S150). At this time, the channel header information of the external request message 210 is added to the external response message 280. When the external response message 210 is completed, the external response message 210 is transmitted (S160). At this time, the external channel 25 corresponding to the destination in the channel header information of the external response message 210 is checked, and the external response message 280 is transmitted to the external channel 25.

If there is an accompanying internal task, it records that there is an internal task in the TWA data 230, and stores internal task processing index information for the TWA data 230 (S170). After storing the index information, since the virtual online work is all completed, step S150 of generating an external response message 230 is performed.

The TWA data 230 is loaded with reference to the internal business process index information to process internal business (S180).

10 is a detailed flowchart of an internal business processing method among transaction integrated message processing methods according to an embodiment of the present invention.

As shown in FIG. 10, first, internal business processing index information or internal business reprocessing index information is searched for (S210). Internal task processing index information is information stored when there is an internal task when processing an online task, and in order to more easily find TWA data 230 that requires internal task processing, the index information of the TWA data 230 is collected. Index information to put. That is, the internal business process index information is collected and stored in one place, whereby TWA data 230 requiring internal business process can be directly found by referring to the index information only. The internal task reprocessing index information is information obtained by collecting index information of the corresponding TWA data 230 in one place so as to be processed again when an error occurs during internal task processing. Detailed description will be described later.

If the searched index information exists, the TWA data 230 corresponding to the index information is found and read (S220). Since the index information is index information of the TWA data 230, it can be immediately read.

With reference to the found TWA data 230, the task processing program 240 for processing the accompanying internal task is searched (S230). Information about the internal task to be processed according to the transaction is stored in advance, and the information of the task processing program 240 can be retrieved by referring to this information.

When the work processing program 240 to be performed is searched, the work processing program 240 is performed through the business logic execution module 370 using the input data of the TWA data 230 as an input (S240).

When a failure occurs in the process of performing the business process program 240, internal task reprocessing index information for the TWA data 230 being performed is stored (S250). Since internal tasks must be completed unconditionally, internal task reprocessing index information is stored for reprocessing. When the procedure for processing the internal task is executed again, the internal task reprocessing index information is referred to in step S210, so that the internal task is performed again.

The task of processing the internal task is in the waiting state for a predetermined time, wakes up and starts step S210 again (S280), and repeatedly performs the internal task processing.

As described above, according to the present invention, as a layer of work for transaction processing is layered into three or n layers and a standard API is provided for an interface between the layers, the developer focuses more on an application, that is, a business task or user convenience. In addition, it can be developed without knowledge of physical system such as DB or network, and it can be convenient to maintain.

In addition, by dividing it into external online work and internal offline work with different priorities, it is appropriately distributed and processed, supporting fast response to customer's processing request and improving efficiency of using system resources.

It also presents an efficient way to back up and trouble with the separation of transaction flows.

In addition, by layering and separating work for transaction processing and separating transactions into external on-line and internal offline tasks, the entire system can be simplified, structured, and standardized.

In addition, by modularizing business process programs and business logic, developers can induce more optimal development and decentralize and specialize in business development.

1 is a block diagram of a system for processing a transaction,

2A is a relationship diagram of a hierarchical structure of a task of processing a message for requesting transaction processing according to an embodiment of the present invention;

2B is a block diagram of business logic according to an embodiment of the present invention;

Figure 2c is an illustration of a business processing program according to an embodiment of the present invention,

2d is a block diagram of TWA data according to an embodiment of the present invention;

Figure 2e is an illustration of an external request message according to an embodiment of the present invention,

3 is a block diagram of a transaction integrated message processing system according to an embodiment of the present invention;

Figure 4a is a block diagram of a network connection control unit of a transaction integrated message processing system according to an embodiment of the present invention,

4B is a data structure diagram of external channel information of a network connection controller of a transaction integrated message processing system according to an embodiment of the present invention;

4C is configuration information of a channel header of a network connection controller of a transaction integrated message processing system according to an embodiment of the present invention;

5A is a block diagram of a message conversion unit of a transaction integrated message processing system according to an embodiment of the present invention;

5B is a configuration diagram of mapping CA information of a message conversion unit of a transaction integrated message processing system according to an embodiment of the present invention;

6 is a block diagram of a common area storage unit of a transaction integrated message processing system according to an embodiment of the present invention;

7 is a configuration diagram of an online business processing unit of a transaction integrated message processing system according to an embodiment of the present invention;

Figure 8a is an illustration of the type of internal work according to an embodiment of the present invention,

8B is a block diagram of an internal business processing unit of a transaction integrated message processing system according to an embodiment of the present invention;

9 is a flow chart of a transaction integrated message processing method according to an embodiment of the present invention.

10 is a detailed flowchart of the internal business processing method according to an embodiment of the present invention.

Explanation of symbols on the main parts of the drawings

10: network 20: client system

25: external channel 30: transaction processing system

40: transaction web server 50: transaction DB server

210: External request message 230: TWA data

240: business processing program 250: business logic

251: business logic unit command 260: physical unit work

280: external response message 310: network connection control unit

320: online business processing unit 330: message conversion unit

340: Work area storage unit 350: Internal business processing unit

360: business processing program storage unit 370: business logic execution module

Claims (13)

Abstracting the physical unit work for transaction processing to configure the business logic 250, and define the work to be performed for the processing of each transaction as a series of business logic (250) business processing program 240 for each transaction In the transaction integrated message processing system for processing the requested transaction by receiving the external request message 200 of the external channel 25, A work processing program storage unit 360 for storing work processing programs 240 corresponding to each transaction; A business logic execution module 370 capable of performing the business logic 250 of the business process program 240 as a physical unit work; A network connection controller 310 for receiving an external request message 210 generated from an external channel 25; A message conversion unit 330 for analyzing the external request message 210 and converting the external request message 210 into TWA data 230 including information of a business processing program 240 to be performed and input data of the program; And Work area storage unit 340 for storing the TWA data 230; Call the business processing program 240 to perform the TWA data 230 to perform transaction processing, and reflect the processing result to the TWA data 260 to store the TWA data 230 in the work area storage unit 340, An online business processing unit 320 generating an external response message 280 for the processing result; Transaction integrated message processing system comprising a. The method of claim 1, The transaction integrated message system further includes an internal business processing unit (350); The on-line business processing unit (320) records that there is an internal service associated with the TWA data (230) when there is an internal task involved in the online operation of the TWA data (230); The internal task processor 350 performs TWA data 270 having an internal task involved in the work area storage 340 to perform an internal task involved; Transaction integrated message processing system characterized by. The method of claim 1, wherein the TWA data, A transaction work common area 231 including information commonly used such as the total length of the TWA data, a transaction occurrence date, a work processing program 240 ID, and a work processing screen; Client session information 232 including basic information about an external request message 210, such as an IP address, MAC address, and terminal number of the client computer, and a user ID of the client; External input information 233 including input data; Internal interlocking information 234 including basic information on whether there is an accompanying internal task; And Internal ledger information 235 including information on business processing such as business process progress result or final result; Transaction integrated message processing system comprising a. The method of claim 1, The network connection control unit 310; An external channel information storage unit 313 for storing in advance information on a message source, a transaction type of a message, a destination of a message, a length of a message, and the like, for each external channel 25; An external channel message receiver 311 which receives an external request message 210 from the external channel 25; The connection information of the external channel 25 such as the origin of the external request message 210 and the destination of the external response message 280 is used as a key to the external channel 25 of the external channel information storage unit 313. A reception message analyzer 312 for adding channel header information before the external request message 210 and transmitting the added external request message 210 to the online business processor 320; A message processing result receiving unit 314 for receiving an external response message 280 that is a processing result in the online business processing unit 320; And Analyzing the channel header information of the external response message 280 to find the external channel 25 corresponding to the origin and destination of the message, the external channel message for sending the external channel response message 280 to the external channel 25 A transmitter 315; Transaction integrated message processing system comprising a. The method of claim 1, The message conversion unit 330 is; A mapping CA storage unit 333 for storing mapping CA information 510 which may be commonly used, such as branch network information, terminal information, business date, next business day, and network state necessary for an online transaction; A reference map file storage unit 334 for storing a file for mapping field values of the external request message 210 to field values of TWA data; A mapping information storage unit 335 for storing information about a reference map file to be referred to according to a transaction type of the external request message 210; Search for a reference map file that retrieves a reference map file to be referenced when mapping a transaction type from the external request message 210 and referring to the mapping information storage unit 335 to the TWA data 230 from the external request message 210. Part 331; And The mapping CA information 510 of the mapping CA storage unit 333 is copied to the TWA data 230, and the external request message 200 is mapped to the TWA data 230 by using the searched reference map file. A message mapping unit 332 generating 230; Transaction integrated message processing system comprising a. The method of claim 1, The work area storage unit 340, A TWA data store 341 that stores TWA data 230; A TWA index store (342) for storing index information of the TWA data (230); An internal business processing index storage 343 for storing an internal business index of the TWA data 230; An internal business reprocessing index storage 344 for storing internal business reprocessing index information of the TWA data 230; Transaction integrated message processing system comprising a. The method according to claim 1 and 2, The online business processing unit 320; An internal task information storage unit 325 for each transaction for defining and storing an internal task involved according to a transaction type of an online task; A message conversion management unit 321 for converting an external request message 210 into TWA data 230 by the message conversion unit 330; A TWA data analysis unit 322 for analyzing the TWA data 230 and searching for a corresponding business processing program 240; The task processing program 240 is executed by the business logic execution module 370, the result information is reflected in the TWA data 230, and the TWA data 230 is stored in the work area storage 340, and an external response message A business task processing unit 323 for generating 280; Referring to the internal task information storage unit 325 for each transaction, if there is an accompanying internal task, the TWA data 230 records that there is an internal task, and the internal task processing index information for the TWA data 230 is worked. A transaction partitioning unit 324 for storing in the area storage unit 340; Transaction integrated message processing system comprising a. The method according to claim 1 and 2, The internal business processing unit 350; Performing independently from the online business processing unit 320; A TWA data loader 351 for reading the TWA data 230 through internal task index information or internal task reprocessing index information for the TWA data 230 stored in the work area storage 340; An internal task TWA data analysis unit 352 analyzing the TWA data 230 to find a task processing program 240 to perform an internal task; A business internal task execution unit 353 which executes the business process program 240 through the business logic execution module 370 using the input data of the TWA data 230 as an input; An internal task processing failure management unit 354 for storing internal task reprocessing index information on the TWA data 230 being performed when a failure occurs while processing an internal task in the business internal task performing unit 353; Transaction integrated message processing system comprising a. Abstracting the physical unit work for transaction processing to configure the business logic 250, and define the work to be performed for the processing of each transaction as a series of business logic (250) business processing program 240 for each transaction In the transaction integrated message processing system for processing the requested transaction by receiving the external request message 200 of the external channel 25, Receiving an external request message 210 for requesting a transaction processing operation from an external channel 25 (S110); Analyzing the external request message 210 and converting the information into TWA data 230 including information of the work processing program 240 to be performed and input data of the program (S120); Calling a business program 240 to perform the TWA data 230 to process a transaction, and reflecting the processing result to the TWA data 230 (S130); Generating an external response message 280 for the transaction processing result (S150); And Transmitting the external response message (280) to an external channel (25); Transaction integrated message processing method comprising the. The method of claim 9, after the step S130, Determining whether there is an internal task involved in the online operation of the TWA data 230 (S140); If there is an accompanying internal task, recording that there is an internal task in the TWA data 230, and storing internal task processing index information for the TWA data 230 (S170); And Loading the TWA data 230 with reference to the internal business processing index information to process internal business (S180); Transaction integrated message processing method further comprising. The method of claim 9, After the step S110, by referring to the external channel information such as the message origin, the transaction type of the message, the destination of the message, the length of the message, and the like, the external channel information of the external channel 25 that transmitted the external request message 210 Further comprising the step (S111) to add to the external request message 210 as the channel header information, In step S150, the channel header information of the external request message 210 is added to the external response message 280, In step S160, transmitting the external response message 280 to the external channel 25 corresponding to the destination in the channel header information of the external response message 280, Transaction integrated message processing method characterized in that. The method according to claim 9 and 10, The step S120, Extracting a transaction type from an external request message 210 and retrieving a reference map file corresponding to the transaction type (S121); Mapping the external request message (210) to the TWA data (230) by referring to the reference map file (S122); And Adding mapping CA information 510, which is common information for on-line business processing, to the TWA data 230 (S123); Including, The step S130, Analyzing the TWA data 230 and searching for a corresponding business processing program 240 (S131); And And performing the work processing program 240 by the business logic execution module 370 and reflecting the result information in the TWA data 230 (S132). Transaction integrated message processing method characterized in that. The method of claim 10, wherein the step S180, Retrieving internal business processing index information or internal business reprocessing index information (S210); If the retrieved index information exists, finding and reading the TWA data 230 corresponding to the index information (S220); Searching for a work processing program 240 for processing the accompanying internal work with reference to the TWA data 230 (S230); Performing the business process program 240 through the business logic execution module 370 using the input data of the TWA data 230 as an input (S240); Storing internal task reprocessing index information on the TWA data 230 being performed when a failure occurs in the process of executing the task processing program 240 (S250); And In step S280 starting the standby state for a predetermined time again S210; Transaction integrated message processing method comprising the.