JP2019091197A - Information processing apparatus and method - Google Patents
Information processing apparatus and method Download PDFInfo
- Publication number
- JP2019091197A JP2019091197A JP2017218892A JP2017218892A JP2019091197A JP 2019091197 A JP2019091197 A JP 2019091197A JP 2017218892 A JP2017218892 A JP 2017218892A JP 2017218892 A JP2017218892 A JP 2017218892A JP 2019091197 A JP2019091197 A JP 2019091197A
- Authority
- JP
- Japan
- Prior art keywords
- batch
- data
- degree
- influence
- importance
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Landscapes
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
Description
本発明は、情報処理装置及び方法に関し、例えば、店舗管理システムに適用して好適なものである。 The present invention relates to an information processing apparatus and method, and is suitably applied to, for example, a store management system.
コンビニエンスストアなどの複数の店舗を展開する企業では、各店舗にそれぞれ設置された店舗端末からその店舗における売上実績を表す販売データが本部に設置された本部システムに日々送信される。そして本部システム側では、これらの販売データを参照する(入力とする)定期的なバッチ処理を実行することにより、店舗ごと、商品ごとの日別売上や販売実績などの集計データをそれぞれ生成し、生成したこれら集計データをそれぞれ異なるデータマートに格納して管理している。このようにして生成されたこれらのデータマートに格納された集計データは、この後、本部の経理部門における売上管理や、企画部門における販売企画などに活用される。 In a company that develops a plurality of stores, such as a convenience store, sales data representing sales results of the stores are transmitted daily from the store terminal installed in each store to the headquarters system installed in the headquarters. Then, the headquarters system side generates periodic data such as daily sales and sales results for each store and product by executing periodical batch processing that refers to (inputs) these sales data. These generated aggregated data are stored and managed in different data marts. The tabulated data stored in these data marts generated in this manner is thereafter utilized for sales management in the accounting department of the headquarters, sales planning in the planning department, and the like.
ところで、本部システムにおいて、あるバッチの処理が開始された後に当該バッチが参照する販売データやデータマートのデータ(以下、これらを元データと呼ぶ)が変更、追加又は削除された場合を考える。このような状況は、バッチ処理の開始後に店舗の担当者が入力ミスを修正した場合や、バッチ処理の開始後に返品があった場合などに発生する。 By the way, in the head office system, consider a case where sales data or data mart data (hereinafter referred to as original data) referred to by the batch is changed, added or deleted after processing of a certain batch is started. Such a situation occurs, for example, when a store representative corrects an input error after the start of batch processing, or when there is a return after the start of batch processing.
この場合、本部システム側では、変更等があった元データを参照するバッチを再実行する必要があるが、再実行によってそのバッチの完了時刻が遅れるため、当該バッチの処理結果を利用する後続の業務(経理部や企画部等における業務であり、以下、これを後続業務と呼ぶ)の開始時間までにそのバッチを完了させられない場合があった。 In this case, the headquarters system side needs to re-execute the batch referring to the original data that has been changed etc., but the completion time of the batch is delayed by the re-execution, so the subsequent process using the processing result of the batch In some cases, it is not possible to complete the batch by the start time of the work (the work in the accounting department, the planning department or the like, which will be referred to as a subsequent work hereinafter).
この点について、例えば、特許文献1には、バッチ対象データが確定していない状態でも、バッチ対象データが発生した段階でそのデータをロット化してバッチ処理を実行することにより、バッチ処理の終了時間を早め得る発明が開示されている。 In this regard, for example, in Patent Document 1, even if batch target data is not determined, the batch processing end time can be achieved by batching the batch target data when batch target data is generated. An invention is disclosed that can accelerate the
しかしながら、元データが変更等されたとしても、そもそもその変更等が後続業務に与える影響が小さい場合には、その元データを参照して処理を行うバッチを再実行する必要はない。よって、元データが変更等された場合、その変更等が後続業務に与える影響が大きい場合にのみそのバッチを再実行すればよい。ところが、元データの変更等が後続業務に与える影響の大きさを判断することは難しく、元データの変更等があった場合における対応するバッチの再実行の要否を容易には判断し得ない問題があった。 However, even if the original data is changed or the like, if the change or the like has little influence on the subsequent business, there is no need to re-execute a batch for processing with reference to the original data. Therefore, when the original data is changed or the like, the batch may be re-executed only when the change or the like has a large influence on the subsequent business. However, it is difficult to determine the magnitude of the impact of changes in the original data on subsequent operations, and it is not easy to determine whether it is necessary to re-execute the corresponding batch when there is a change in the original data, etc. There was a problem.
従って、元データの変更等があった場合に、本部システム側において、その変更等が後続業務に与える影響を判定すると共に、判定結果に基づいて対応するバッチの再実行の要否を判断し、本当に必要なバッチのみを再実行するようにできれば、バッチの再実行に起因して後続業務の開始時刻までにバッチ処理が完了しないといった事態の発生を極力抑制でき、後続業務の遂行を信頼性高く支援し得るものと考えられる。また、このような方法により、元データの変更が後続業務に与える影響を確認する作業も不要となり、システム管理者や後続業務担当者の負担を軽減させ得るものと考えられる。 Therefore, when there is a change or the like in the original data, the head office system side determines the influence of the change or the like on the subsequent business, and determines the necessity of re-execution of the corresponding batch based on the determination result, If it is possible to re-execute only the batch that is really necessary, it is possible to minimize the occurrence of a situation where batch processing is not completed by the start time of the subsequent business due to the re-execution of the batch, and reliable execution of the subsequent business It is thought that it can support. Further, it is considered that such a method makes it unnecessary to check the influence of the change of the original data on the subsequent work, and the burden on the system administrator and the subsequent work person can be alleviated.
本発明は以上の点を考慮してなされたもので、バッチの処理結果に基づいて遂行される後続業務を信頼性高く支援し得る情報処理装置及び方法を提案しようとするものである。 The present invention has been made in consideration of the above points, and an object of the present invention is to propose an information processing apparatus and method capable of reliably supporting subsequent work performed based on the batch processing result.
かかる課題を解決するため本発明においては、登録された各バッチをそれぞれ実行し、実行したバッチの処理結果をそれぞれ対応するデータマートに格納する情報処理装置において、各前記データマートの各レコードに対してそれぞれ重要度を設定する重要度設定部と、各前記バッチが処理時にそれぞれ参照するデータを監視し、いずれかの前記データが変更された場合に当該変更を検出する変更検出部と、前記変更検出部がいずれかの前記データの変更を検出した場合に、当該データの変更が後続業務に与える影響度を算出する影響度算出部と、変更された前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、前記影響度算出部により算出された前記影響度とに基づいて、必要に応じて当該データの変更を当該データマートに反映させるバッチ制御部とを設け、前記重要度ごとにそれぞれ前記影響度の許容範囲が予め設定され、前記バッチ制御部が、前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、前記影響度算出部により算出された前記影響度とに基づいて、前記影響度が前記許容範囲内にあるか否かを当該データマートの前記レコードごとにそれぞれ判定し、いずれかの前記レコードの前記影響度が前記許容範囲を超えている場合に、当該データの変更を当該データマートに反映させるようにした。 In the present invention, in order to solve the problem, in the information processing apparatus, each registered batch is executed, and the processing result of the executed batch is stored in the corresponding data mart, for each record of each data mart. The importance setting unit that sets the importance, the change detection unit that monitors data that each batch refers to during processing, and detects the change when any of the data is changed, and the change When the detection unit detects a change in any of the data, an influence calculation unit that calculates the degree of influence that the change in data has on subsequent operations, and the processing result of the batch that refers to the changed data is The importance degree set for each record of the data mart to be stored, and the influence degree calculated by the influence degree calculation unit Therefore, a batch control unit for reflecting the change of the data to the data mart is provided as necessary, and the allowable range of the influence degree is set in advance for each importance degree, and the batch control unit The degree of influence is based on the degree of importance set in each record of the data mart in which the processing result of the batch referring to is stored, and the degree of influence calculated by the influence degree calculation unit. It is determined for each record of the data mart whether or not it is within the allowable range, and when the degree of influence of any of the records exceeds the allowable range, the change of the data is determined as the data mart To reflect it.
また本発明においては、登録された各バッチをそれぞれ実行し、実行したバッチの処理結果をそれぞれ対応するデータマートに格納する情報処理装置により実行される情報処理方法において、各前記データマートの各レコードに対してそれぞれ重要度を設定する第1のステップと、各前記バッチが処理時にそれぞれ参照するデータを監視し、いずれかの前記データの変更を検出した場合に、当該データの変更が後続業務に与える影響度を算出する第2のステップと、変更された前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定した前記重要度と、算出した前記影響度とに基づいて、必要に応じて当該データの変更を当該データマートに反映させる第3のステップとを設け、前記重要度ごとにそれぞれ前記影響度の許容範囲が予め設定され、前記第3のステップにおいて、前記情報処理装置が、前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、算出した前記影響度とに基づいて、前記影響度が前記許容範囲内にあるか否かを当該データマートの前記レコードごとにそれぞれ判定し、いずれかの前記レコードの前記影響度が前記許容範囲を超えている場合に、当該データの変更を当該データマートに反映させるようにした。 Further, in the present invention, in the information processing method executed by an information processing apparatus that executes each registered batch and stores the processing result of the executed batch in the corresponding data mart, each record of each data mart The first step of setting the degree of importance for each and the data that each batch refers to at the time of processing is monitored, and when a change in any of the data is detected, the change of the data is a subsequent work The second step of calculating the degree of influence, and the degree of importance calculated for each of the records set in each record of the data mart in which the processing result of the batch referring to the changed data is stored And a third step of reflecting the change of the data in the data mart, as necessary, The allowable range of the influence degree is set in advance for each of the above, and in the third step, the information processing apparatus stores the processing result of the batch referring to the data in each record of the data mart. It is determined for each of the records of the data mart whether or not the degree of influence is within the allowable range based on the set degree of importance and the calculated degree of influence, and any one of the records When the degree of influence exceeds the allowable range, the change of the data is reflected in the data mart.
本情報処理装置及び方法によれば、バッチが参照するデータが更新された場合に、その変更が後続業務に与える影響が大きい場合にのみ、そのデータの変更が対応するデータマートに反映され、その変更が後続業務に与える影響が小さい場合には、そのデータの変更がそのデータマートに反映されない。従って、本当に必要な場合にのみ、かかるデータの変更が対応するデータマートに反映されることになるため、かかるデータの変更を対応するデータマートに反映させる処理が、後続業務の開始に間に合わないといった事態の発生を極力抑制することができる。 According to the information processing apparatus and method, when the data to which the batch refers is updated, the change of the data is reflected in the corresponding data mart only when the change has a large influence on the subsequent business. If the change has a small impact on follow-on operations, the change in the data is not reflected in the data mart. Therefore, only when it is really necessary, such data changes will be reflected in the corresponding data mart, so the process of reflecting such data changes in the corresponding data mart will not be in time for the start of the subsequent business Occurrence of a situation can be suppressed as much as possible.
本発明によれば、バッチの処理結果に基づいて遂行される後続業務を信頼性高く支援し得る情報処理装置及び方法を実現できる。 According to the present invention, it is possible to realize an information processing apparatus and method that can reliably support subsequent work to be performed based on batch processing results.
以下図面について、本発明の一実施の形態を詳述する。 An embodiment of the present invention will now be described in detail with reference to the drawings.
(1)本実施の形態による店舗管理システムの構成
図1において、1は全体として本実施の形態による店舗管理システムを示す。この店舗管理システム1は、コンビニエンスストアやファミリーレストランなどの複数の店舗2を営業する企業において、各店舗2の売上等を管理するために利用されるシステムである。
(1) Configuration of Store Management System According to the Present Embodiment In FIG. 1, reference numeral 1 generally denotes a store management system according to the present embodiment. The store management system 1 is a system used to manage sales and the like of each store 2 in a company operating a plurality of stores 2 such as a convenience store and a family restaurant.
この店舗管理システム1は、各店舗2にそれぞれ設置された店舗端末3と、本部に設置されたウェブサーバ4、アプリケーションサーバ5、データベースサーバ6及び複数のホスト装置7からなる本部システム8とを備えて構成される。 The store management system 1 includes a store terminal 3 installed in each store 2, and a head office system 8 including a web server 4 installed in the head office, an application server 5, a database server 6, and a plurality of host devices 7. Is configured.
店舗端末3は、その店舗2における売上状況を管理するために利用されるPOS(Point Of Sales)端末などのコンピュータ装置であり、CPU(Central Processing Unit)10、メモリ11、記憶装置12及び通信装置13などを備えて構成される。 The store terminal 3 is a computer device such as a POS (Point Of Sales) terminal used to manage the sales situation in the store 2 and includes a central processing unit (CPU) 10, a memory 11, a storage device 12, and a communication device. It comprises 13 and so on.
CPU10は、店舗端末3全体の動作制御を司るプロセッサである。またメモリ11は、必要なプログラムを一時的に保持するために利用されるほか、CPU10のワークメモリとしても利用される。メモリ11に格納されたプログラムをCPU10が実行することにより、店舗端末3全体としての各種処理が行われる。 The CPU 10 is a processor that controls the operation of the entire shop terminal 3. The memory 11 is also used as a work memory for the CPU 10 in addition to being used to temporarily hold necessary programs. The CPU 10 executes the program stored in the memory 11 to perform various processes of the entire shop terminal 3.
また記憶装置12は、例えばハードディスク装置やSSD(Solid State Drive)などの大容量の不揮発性記憶装置から構成され、プログラムや日々の販売データ14などの必要な情報を長期間保持するために利用される。さらに通信装置13は、NIC(Network Interface Card)などから構成され、本部システム8との通信時におけるプロトコル制御を行う。 The storage device 12 is composed of a large-capacity non-volatile storage device such as a hard disk drive or a solid state drive (SSD), for example, and is used to hold necessary information such as programs and daily sales data 14 for a long time. Ru. Furthermore, the communication device 13 is configured by a NIC (Network Interface Card) or the like, and performs protocol control at the time of communication with the head office system 8.
ウェブサーバ4は、各店舗2の店舗端末3とインターネットなどから構成されるネットワーク9Aを介して接続され、これら店舗端末3から日々送信されてくる毎日の販売実績を表す販売データ14をアプリケーションサーバ5に転送する機能を有する汎用のサーバ装置である。ウェブサーバ4は、CPU20、メモリ21、記憶装置22及び通信装置23等の情報処理資源を備えて構成される。これらCPU20、メモリ21及び記憶装置22及び通信装置23は、店舗端末3のCPU10、メモリ11、記憶装置12及び通信装置13とほぼ同様の機能及び構成を有するものであるため、ここでの説明は省略する。 The web server 4 is connected to the store terminal 3 of each store 2 via the network 9A including the Internet and the like, and the sales data 14 representing daily sales results transmitted daily from the store terminal 3 is stored in the application server 5 It is a general purpose server device having a function of transferring to The web server 4 is configured to include information processing resources such as a CPU 20, a memory 21, a storage device 22, and a communication device 23. The CPU 20, the memory 21, the storage device 22, and the communication device 23 have almost the same functions and configurations as the CPU 10, the memory 11, the storage device 12, and the communication device 13 of the shop terminal 3, and therefore I omit it.
アプリケーションサーバ5は、インストールされたアプリケーションプログラム34(図7)に従った各種処理を実行する機能を有するサーバ装置である。アプリケーションサーバ5は、CPU30、メモリ31、記憶装置32及び通信装置33等の情報処理資源を備える汎用のサーバ装置から構成される。CPU30、メモリ31、記憶装置32及び通信装置33は、ウェブサーバ4のCPU20、メモリ21、記憶装置22及び通信装置23とほぼ同様の機能及び構成を有するものであるため、ここでの説明は省略する。 The application server 5 is a server device having a function of executing various processes in accordance with the installed application program 34 (FIG. 7). The application server 5 is configured of a general-purpose server device including information processing resources such as a CPU 30, a memory 31, a storage device 32, and a communication device 33. The CPU 30, the memory 31, the storage device 32, and the communication device 33 have substantially the same functions and configurations as the CPU 20, the memory 21, the storage device 22, and the communication device 23 of the web server 4, and thus the description thereof is omitted. Do.
アプリケーションサーバ5のメモリ31には、アプリケーションプログラム34(図7)のほか、本部の各部門の担当者によりそれぞれ登録された複数のバッチ35(図7)が格納される。アプリケーションプログラム34は、各店舗端末3からウェブサーバ4を介して転送されてきた販売データ14をデータベースサーバ6が保持するデータベース40に格納したり、データベースサーバ6が保持するデータマート41に格納されたデータをホスト装置7からの要求に応じて読み出してそのホスト装置7に転送する機能を有するプログラムである。またバッチ35は、1つ以上のデータを入力して処理を実行し、その処理結果に基づいて1つ以上のデータマート41を更新するプログラムである。 The memory 31 of the application server 5 stores, in addition to the application program 34 (FIG. 7), a plurality of batches 35 (FIG. 7) respectively registered by persons in charge of each division of the head office. The application program 34 stores the sales data 14 transferred from each shop terminal 3 via the web server 4 in the database 40 held by the database server 6 or stored in the data mart 41 held by the database server 6 It is a program having a function of reading data in response to a request from the host device 7 and transferring the data to the host device 7. The batch 35 is a program that inputs one or more data and executes processing, and updates one or more data marts 41 based on the processing result.
データベースサーバ6は、データベース40を管理及び保持する機能を有するサーバ装置である。データベースサーバ6は、CPU、メモリ、記憶装置及び通信装置(いずれも図示せず)等の情報処理資源を備える汎用のサーバ装置から構成される。これらCPU、メモリ、記憶装置及び通信装置は、ウェブサーバ4のCPU20、メモリ21、記憶装置22及び通信装置23とほぼ同様の機能及び構成を有するものであるため、ここでの説明は省略する。データベースサーバ6の記憶装置には、各店舗2からの販売データ14が登録されるデータベース40と、各バッチ35(図7)の処理結果がそれぞれ登録される複数のデータマート41となどが格納される。 The database server 6 is a server device having a function of managing and maintaining the database 40. The database server 6 is configured of a general-purpose server device provided with information processing resources such as a CPU, a memory, a storage device, and a communication device (all not shown). The CPU, the memory, the storage device and the communication device have almost the same functions and configurations as the CPU 20, the memory 21, the storage device 22 and the communication device 23 of the web server 4, and thus the description thereof is omitted here. The storage device of the database server 6 stores a database 40 in which sales data 14 from each store 2 is registered, and a plurality of data marts 41 in which the processing results of each batch 35 (FIG. 7) are respectively registered. Ru.
ホスト装置7は、本部の経理部、企画部及び総務部などの各部門の担当者にそれぞれ貸与されたコンピュータ装置であり、それぞれ社内LAN(Local Area Network)などのネットワーク9Bを介してアプリケーションサーバ5と接続されている。各部門の担当者は、自己のホスト装置7を用いてアプリケーションサーバ5にアクセスし、当該アプリケーションサーバ5に所定の処理を実行するバッチ35(図7)を登録したり、所望するデータマート41のデータをアプリケーションサーバ5を介してデータベースサーバ6から取得する。 The host device 7 is a computer device lent to each person in charge of each department such as the accounting department, the planning department and the general affairs department in the head office, and each application server 5 is connected via a network 9B such as an in-house LAN (Local Area Network). And connected. The person in charge of each department accesses the application server 5 by using the host device 7 of its own, registers the batch 35 (FIG. 7) for executing predetermined processing in the application server 5, or makes a desired data mart 41 Data is acquired from the database server 6 via the application server 5.
(2)本実施の形態によるバッチ管理機能
次に、本実施の形態のアプリケーションサーバ5に搭載されたバッチ管理機能について説明する。これに際して、まず、本店舗管理システム1における業務の流れについて、図2を参照して説明する。
(2) Batch Management Function According to this Embodiment Next, the batch management function installed in the application server 5 according to this embodiment will be described. On this occasion, first, the flow of operations in the store management system 1 will be described with reference to FIG.
本店舗管理システム1において、各店舗2の担当者45は、売上に関する情報(売上情報)を逐次店舗端末3に入力する。そして店舗端末3は、入力された売上情報に基づいて例えば図3(A)に示すような販売データ14を日々生成し、生成した販売データ14をその店舗端末3内の記憶装置12(図1)に格納する。また店舗端末3は、記憶装置12に格納している販売データ14を毎日定時にネットワーク9Aを介して本部システム8に送信する。 In the present store management system 1, the person in charge 45 of each store 2 sequentially inputs information on sales (sales information) to the store terminal 3. Then, the shop terminal 3 generates, for example, sales data 14 as shown in FIG. 3A daily based on the input sales information, and the generated sales data 14 is stored in the storage device 12 in the shop terminal 3 (FIG. Store in). The store terminal 3 also transmits the sales data 14 stored in the storage device 12 to the head office system 8 via the network 9A on a regular basis every day.
本部システム8側では、各店舗端末3からそれぞれ送信されてきた販売データ14がウェブサーバ4(図1)を介してアプリケーションサーバ5に与えられる。そしてアプリケーションサーバ5は、これら販売データ14をデータベースサーバ6(図1)が保持するデータベース40(図1)に格納して管理する。またアプリケーションサーバ5は、予め本部の各部門の担当者46A〜46Cによりそれぞれ登録された各バッチ35(図7)の実行タイミングをそれぞれ規定したスケジュール(以下、これをバッチ実行スケジュールと呼ぶ)を作成し、当該バッチ実行スケジュールに従って各バッチ35をそれぞれ実行する。 On the head office system 8 side, the sales data 14 transmitted from each shop terminal 3 is given to the application server 5 via the web server 4 (FIG. 1). Then, the application server 5 stores and manages the sales data 14 in the database 40 (FIG. 1) held by the database server 6 (FIG. 1). In addition, the application server 5 creates a schedule (hereinafter referred to as a batch execution schedule) which defines the execution timing of each batch 35 (FIG. 7) registered in advance by persons in charge 46A to 46C of each division of the head office respectively. And each batch 35 is executed according to the batch execution schedule.
ここでは、アプリケーションサーバ5に、経理部の担当者46Aにより作成された第1の集計バッチ35A(「集計バッチ1」)と、企画部の担当者46Bにより作成された第2及び第3の集計バッチ35B,35C(「集計バッチ2」及び「集計バッチ3」)と、総務部の担当者46Cにより作成された第4の集計バッチ35D(「集計バッチ4」)とが登録されているものとする。 Here, in the application server 5, the first tabulated batch 35A ("tabulated batch 1") created by the person in charge 46A of the accounting department and the second and third tabulations created by the person in charge 46B of the planning department The batches 35B and 35C ("totaling batch 2" and "totaling batch 3") and the fourth totaling batch 35D ("totaling batch 4") created by the person in charge 46C of the general affairs department are registered. Do.
第1の集計バッチ35Aは、各店舗2の日々の売上をそれぞれ集計するバッチであり、この第1の集計バッチ35Aにより店舗2ごとの日別の売上が算出され、算出結果をデータベースサーバ6が保持する例えば図3(B)に示すような構成のデータマート41(日別売上マート41A)に格納される。かくして、経理部の担当者46Aは、自己のホスト装置7(図1)を用いてこの日別売上マート41Aに格納された各店舗の日別の売上データを取得し、取得した売上データに基づいて各店舗2の毎日の売上を管理する業務を行う。 The first tabulated batch 35A is a batch for tabulating the daily sales of each store 2. The daily tabulated sales for each store 2 are calculated by this first tabulated batch 35A, and the calculation result is stored in the database server 6 For example, it is stored in the data mart 41 (daily sales mart 41A) configured as shown in FIG. 3 (B). Thus, the person in charge 46A of the accounting department acquires daily sales data of each store stored in the daily sales mart 41A using its own host device 7 (FIG. 1), and based on the acquired sales data Work to manage daily sales of each store 2.
また第2の集計バッチ35Bは、商品ごとの販売実績を集計するためのバッチであり、この第2の集計バッチ35Bにより日別の商品ごとの販売数が算出され、算出結果をデータベースサーバ6が保持する例えば図3(C)に示すようなデータマート41(販売実績マート41B)に格納される。かくして企画部の担当者46Bは、自己のホスト装置7を用いてこの販売実績マート41Bに格納された商品ごとの販売数を取得し、取得した商品ごとの販売数に基づいて、例えば各店舗2が販売強化指定商品の販売ノルマを達成しているか否かを管理したり、各店舗2に対する各商品の出荷数量を調整するなどの業務を行う。 Further, the second tabulation batch 35B is a batch for tabulating the sales results for each product, and the number of sales per product per day is calculated by this second tabulation batch 35B, and the calculation result is stored in the database server 6 For example, it is stored in the data mart 41 (sales performance mart 41 B) as shown in FIG. Thus, the person in charge 46B of the planning department acquires the number of sales for each product stored in the sales performance mart 41B using the host device 7 of its own, and based on the acquired number of sales for each product, for example, each store 2 The management of whether or not the sales quota of the sales reinforcement designated product has been achieved, and the operation of adjusting the shipment quantity of each product to each store 2 are performed.
さらに第3の集計バッチ35Cは、各店舗2の人気商品を特定するバッチであり、この第3の集計バッチ35Cにより各店舗2において販売数が最も多い商品が抽出され、抽出結果をデータベースサーバ6が保持する例えば図3(D)に示すようなデータマート41(人気商品マート41C)に格納される。かくして企画部の担当者46Bは、自己のホスト装置7を用いてこの人気商品マート41Cに格納された店舗ごとの最も販売数が多い商品を取得し、取得したこの情報に基づいて販売キャンペーンを企画するなどの業務を行う。 Furthermore, the third tabulation batch 35C is a batch for identifying the popular products of each store 2. By this third tabulation batch 35C, the product with the largest number of sales in each shop 2 is extracted, and the extraction result is stored in the database server 6 Are stored in, for example, the data mart 41 (popular product mart 41C) as shown in FIG. Thus, the person in charge 46B of the planning department uses the host device 7 of its own to acquire the product with the largest number of sales for each store stored in the popular product mart 41C, and plans a sales campaign based on the acquired information. Perform tasks such as
さらに第4の集計バッチ35Dは、店舗2の売上ランキングを算出するバッチであり、この第4の集計バッチにより売上の多い順に店舗2がソートされ、そのソート結果をデータベースサーバ6が保持する例えば図3(E)に示すようなデータマート41(売上順位マート41D)に格納される。かくして総務部の担当者46Cは、自己のホスト装置7を用いてこの店舗売上順位マート41Dに格納された各店舗2の売上ランキングの情報を取得し、取得したこの情報に基づいて売上が多い上位数店舗を表彰するなどの業務を行う。 Furthermore, the fourth tabulation batch 35D is a batch for calculating the sales ranking of the shop 2, the shop 2 is sorted in descending order of sales by this fourth tabulation batch, and the sort result is held by the database server 6, for example 3 (E) are stored in the data mart 41 (sales order mart 41D). Thus, the person in charge 46C of the general affairs department acquires the sales ranking information of each store 2 stored in the store sales order mart 41D using the host device 7 of its own, and based on the acquired information, the top sales are high Do business such as awarding several stores.
ところで、上述の第1〜第4の集計バッチ35A〜35Dの処理開始後にその第1〜第4の集計バッチ35A〜35Dが参照する販売データ14が変更された場合に、常にその第1〜第4の集計バッチ35A〜35Dを再実行するものとすると、その第1〜第4の集計バッチ35A〜35Dの完了が後続業務(管理部、企画部又は総務部などの業務)の開始時刻に間に合わなくなる場合がある。 By the way, when the sales data 14 to which the first to fourth totalized batches 35A to 35D refer is changed after the processing of the first to fourth totalized batches 35A to 35D is started, the first to fourth always Assuming that the aggregation batches 35A to 35D of No. 4 are to be re-executed, the completion of the first to fourth aggregation batches 35A to 35D is in time for the start time of the subsequent operation (operation such as the administration department, the planning department or the general affairs department) It may disappear.
また、その再実行すべきバッチ(第1のバッチとする)の処理結果を第2のバッチが利用し、第2のバッチの処理結果を第3のバッチが利用し、……というように複数のバッチが数珠繋ぎに実行されるような設定がなされている場合(以下、第2のバッチ以降の各バッチを、適宜、第1のバッチの後続バッチと呼ぶ)、後続バッチ35を特定したり、どの後続バッチ35まで再実行すべきかを判断することも難しい。 In addition, the second batch uses the processing result of the batch to be re-executed (referred to as the first batch), the third batch uses the processing result of the second batch, and so on. If a setting is made such that each batch is executed in a row (hereinafter, each batch after the second batch is appropriately referred to as a subsequent batch of the first batch), the subsequent batch 35 is identified, or It is also difficult to determine which subsequent batch 35 to rerun.
そこで本店舗管理システム1では、バッチ35(図7)の処理開始後にそのバッチ35が参照する販売データ14やデータマート41のデータ(元データ)が変更された場合に、そのバッチ35の後続バッチ35を特定し、これらバッチ35及び後続バッチ35について、元データの変更の後続業務への影響度を算出し、算出した影響度の大きさを評価し、その評価結果に基づいてそのバッチ35や後続バッチ35を再実行するか否かを判定するバッチ管理機能がアプリケーションサーバ5に搭載されている。 Therefore, in the present store management system 1, when the sales data 14 referred to by the batch 35 (FIG. 7) and the data (original data) of the data mart 41 referred to by the batch 35 are changed, the subsequent batch of the batch 35 35, identify the degree of influence of the change of the original data on the subsequent work for these batch 35 and the subsequent batch 35, and evaluate the magnitude of the calculated degree of influence, and based on the evaluation result, the batch 35 or The application server 5 is equipped with a batch management function that determines whether or not to execute the subsequent batch 35 again.
実際上、アプリケーションサーバ5は、自己に登録された各バッチ35がそれぞれ参照(入力)するデータと、処理結果を格納(出力)するデータマート41とを図12について後述する入出力管理テーブル63に登録して管理している。またアプリケーションサーバ5は、データベースサーバ6が保持するデータベース40(図1)に格納された各店舗2からの販売データ14と、各データマート41(図1)の各レコードのデータとをそれぞれ監視している。 In practice, the application server 5 refers to data which each batch 35 registered in itself refers (inputs) and a data mart 41 which stores (outputs) processing results in an input / output management table 63 described later with reference to FIG. Registered and managed. The application server 5 also monitors sales data 14 from each store 2 stored in the database 40 (FIG. 1) held by the database server 6 and data of each record of each data mart 41 (FIG. 1). ing.
そしてアプリケーションサーバ5は、これら販売データ14及び各データマート41のデータのうちのいずれかのデータが変更された場合に、その変更されたデータを参照する(そのデータを元データとして入力とする)すべてのバッチ35及びその後続バッチ35をかかる入出力管理テーブル63を参照して特定する。またアプリケーションサーバ5は、特定した各バッチ35及びその後続バッチ35を再実行するための空き時間があるか否かを、バッチ実行スケジュールを参照して判定する。以下においては、この判定をスケジュール空き判定と呼ぶものとする。 Then, when one of the sales data 14 and the data of each data mart 41 is changed, the application server 5 refers to the changed data (the data is used as the original data). All batches 35 and their subsequent batches 35 are identified with reference to the input / output management table 63. Further, the application server 5 determines whether there is free time for re-executing each specified batch 35 and its subsequent batch 35 with reference to the batch execution schedule. Hereinafter, this determination will be referred to as schedule vacancy determination.
またアプリケーションサーバ5は、かかるスケジュール空き判定と並行して、かかる元データの変更が後続業務に与える影響度が許容範囲内であるか否かを、当該元データを参照して処理を実行するバッチ35の処理結果が格納されるデータマート41のレコードごとにそれぞれ判定(以下、この判定を影響度判定と呼ぶ)する。 Further, in parallel with the schedule availability judgment, the application server 5 executes the processing with reference to the original data and determines whether the degree of influence of the change of the original data on the subsequent work is within an allowable range. A determination is made on each of the records of the data mart 41 in which the processing result of 35 is stored (hereinafter, this determination is referred to as “impact determination”).
このような影響度判定を行うための手段として、アプリケーションサーバ5には、各バッチ35の処理内容に応じた複数種類の影響度算出ルールが予め登録されている。そしてアプリケーションサーバ5は、影響度判定を行う場合、まず、かかる元データを参照するバッチ35に対応付けられた影響度算出ルールに従って当該元データの変更が後続業務に与える影響度を算出する。 As means for performing such impact determination, a plurality of types of impact calculation rules are registered in advance in the application server 5 according to the processing content of each batch 35. Then, when performing the influence degree determination, first, the application server 5 calculates the influence degree of the change of the original data on the subsequent work according to the influence calculation rule associated with the batch 35 referring to the original data.
例えば、かかる元データを入力として実行されるバッチ35が上述の第1の集計バッチ35Aや第2の集計バッチ35Bであり、これら第1の集計バッチ35Aや第2の集計バッチ35Bのように集計処理を含むバッチ35に対して予め用意された影響度算出ルール(以下、これを第1の影響度算出ルールと呼ぶ)が、『変更された元データを参照して実行されるバッチの処理結果を格納するデータマートのレコードのデータについて、元データの変更に伴って変更される当該データの変更後の値と、当該データの変更前の値との差分の絶対値を当該データの変更前の値で除算(|変更前の値−変更後の値|/変更前の値)することにより、かかる影響度を算出する』というルールであるものとする。 For example, the batch 35 executed with such original data as an input is the above-described first aggregation batch 35A or second aggregation batch 35B, and aggregation is performed as in the first aggregation batch 35A or second aggregation batch 35B. The influence calculation rule (hereinafter referred to as a first influence calculation rule) prepared in advance for the batch 35 including the process is referred to as “the processing result of the batch executed with reference to the changed original data. Of the data of the data mart storing the data, the absolute value of the difference between the value after the change of the data to be changed with the change of the original data and the value before the change of the data before the change of the data It is assumed that such a degree of influence is calculated by dividing by a value (| value before change−value after change | value before change).
また図4(A)に示すように、「店舗1」という店舗2の販売データ14における「2017/2/1 11:00」に販売された商品名「チョコレート」の販売数量が「2」から「3」に、また「2017/2/2 12:00」に販売された商品名「ビール」の単価が「200」から「300」に変更されたものとする。 Also, as shown in FIG. 4A, the sales volume of the product name "chocolate" sold to "2017/2/1 11:00" in the sales data 14 of the store 2 "store 1" is "2" It is assumed that the unit price of the product name "beer" sold to "3" and "2017/2/2 12:00" is changed from "200" to "300".
この場合、対応するデータマート41(日別売上マート41A)の内容が、図4(B)のように「2/1」の売上が「380,000円」、「2/2」の売上が「390,000円」となっている状態から、図4(C)のように「2/1」の売上が「380,800円」、「2/2」の売上が「390,100円」に変更されることになるため、かかる「2/1」の販売データ14(元データ)の変更が後続業務に与える影響度は、次式
また、かかる元データを参照するバッチ35が上述の第3の集計バッチ35Cであり、この第3の集計バッチ35Cのように最大値を算出するバッチ35に対して予め用意された影響度算出ルール(以下、これを第2の影響度算出ルールと呼ぶ)が、『元データの変更後に、当該元データの変更前の最大値を超えた最大値が算出される場合には第1の影響度算出ルールと同様の演算方法により影響度を算出し、これ以外の場合には影響度を常に「0」とする』というルールであるものとする。また図5(A)に示すように、「店舗1」という店舗2の販売データにおける「2017/2/1 11:00」に販売された商品名「チョコレート」の販売数量が「2」から「5」に変更されたものとする。 In addition, the batch 35 which refers to the original data is the above-mentioned third aggregation batch 35C, and the influence calculation rule prepared in advance for the batch 35 which calculates the maximum value like this third aggregation batch 35C. (Hereafter, this is referred to as a second influence calculation rule) “If the original data is changed, the maximum value exceeding the maximum value before the change of the original data is calculated, the first influence The influence degree is calculated by the same calculation method as the calculation rule, and in other cases, the influence degree is always set to “0”. Further, as shown in FIG. 5A, the sales volume of the product name "chocolate" sold to "2017/2/11 11:00" in the sales data of the store 2 "store 1" is from "2" to "2 It shall be changed to 5 ".
この場合、対応するデータマート41(人気商品マート41C)の内容が図5(B)の状態から図5(C)に変更されることになる。従って、この場合における販売データ14(元データ)の変更が後続業務に与える影響度は、次式
さらに、元データを参照するバッチ35が上述の第4の集計バッチ35Dであり、この第4の集計バッチ35Dのように並替え処理を含むバッチ35に対して予め用意された影響度算出ルール(以下、これを第3の影響度算出ルールと呼ぶ)が、『元データの変更後に値が変更されるデータマートのレコードの変更前の順位nと、当該レコードの変更後の順位mとの差分の絶対値を変更後の当該データマートの全体の行数Sで除算(|n−m|/S)することにより、かかる影響度を算出する』というルールであるものとする。 Furthermore, the batch 35 which refers to the original data is the fourth totalization batch 35D described above, and the influence level calculation rule prepared in advance for the batch 35 including the rearrangement process as in the fourth totalization batch 35D Hereinafter, this will be referred to as the third influence calculation rule) “The difference between the rank n before the change of the record of the data mart whose value is changed after the change of the original data and the rank m after the change of the record This influence degree is calculated by dividing the absolute value of by the number of rows S of the entire data mart after the change (| n−m | / S) to calculate the degree of influence.
また図6(A)に示すように、「店舗1」の販売データ14における「2017/2/1 11:00」に販売された商品名「チョコレート」の販売数量が「2」から「3」に変更され、これに伴って、対応するデータマート41(店舗売上順位マート41D)の内容が図6(B)の状態から図6(C)に変更されることになるものとする。 Further, as shown in FIG. 6 (A), the sales volume of the product name "chocolate" sold to "2017/2/1 11:00" in the sales data 14 of "store 1" is "2" to "3". In accordance with this, the content of the corresponding data mart 41 (store sales order mart 41D) is to be changed from the state of FIG. 6 (B) to FIG. 6 (C).
この場合、元データの変更後に値が変更されるデータマート41のレコードの変更前の順位nが「3」、当該レコードの変更後の順位mが「2」、当該データマート41の全体の行数Sが「100」であるため、かかる元データの変更が後続業務に与える影響度は、次式
一方、かかる元データの変更が後続業務に与える「影響度が許容範囲内」であるか否かの判定は、その元データを参照するバッチの処理結果が格納されるデータマート41の各レコードのデータに対してそれぞれ設定されたそのデータの重要度に応じて行われる。本実施の形態の場合、このようにデータマート41の各レコードのデータの重要度を設定するためのルール(以下、これを重要度設定ルールと呼ぶ)として、各種バッチの処理内容に応じた複数種類の重要度設定ルールが予め幾つかアプリケーションサーバ5に登録されている。 On the other hand, the determination as to whether or not the change in the original data has an influence on the subsequent operation “the degree of influence is within the allowable range” depends on each record of the data mart 41 storing the processing result of the batch referring to the original data. It is performed according to the importance of the data set for each data. In the case of the present embodiment, a plurality of rules according to the processing content of various batches are set as rules for setting the degree of importance of the data of each record of the data mart 41 in this manner (hereinafter referred to as the importance degree setting rule). Several types of importance setting rules are registered in advance in the application server 5.
そして新たなバッチ35(第1〜第4の集計バッチ35A〜35D)をアプリケーションサーバ5に登録しようとする後続業務の担当者46A〜46Cは、そのバッチ35の処理結果が格納されるデータマート41(41A〜41D)の各レコードのデータの重要度をどの重要度設定ルールを用いて設定するかを、そのバッチ35をアプリケーションサーバ5に登録する際に決定して設定する。 Then, the persons 46A to 46C in charge of the follow-on operations trying to register a new batch 35 (first to fourth totalized batches 35A to 35D) in the application server 5 are the data mart 41 in which the processing result of the batch 35 is stored. The importance setting rule used to set the importance of the data of each record (41A to 41D) is determined and set when the batch 35 is registered in the application server 5.
例えば、第1の集計バッチ35Aや第2の集計バッチ35Bについて設定された重要度設定ルールが、『頻繁に参照されるレコードのデータの需要度を高く設定する』というルール(以下、これを第1の重要度設定ルールと呼ぶ)であるものとする。 For example, the importance level setting rule set for the first aggregation batch 35A and the second aggregation batch 35B is a rule that "the demand degree of data of frequently referenced records is set high" (hereinafter referred to as It is assumed that it is called "importance setting rule of 1."
この場合、アプリケーションサーバ5は、その第1の集計バッチ35Aや第2の集計バッチ35Bの処理結果が格納される日別売上マート41A(図3(B))や販売実績マート41B(図3(C))については、参照回数が多い上位20%の各レコードのデータの重要度をそれぞれ「A」、参照回数が上位20〜40%の各レコードのデータの重要度をそれぞれ「B」、参照回数が上位40〜60%の各レコードのデータの重要度をそれぞれ「C」、参照回数が上位60〜100%の各レコードのデータの重要度をそれぞれ「D」、重要度が「A」〜「D」のいずれにも該当しない(つまり一度も参照されたことがない)各レコードのデータの重要度をそれぞれ「E」のように、レコードごと(データごと)の重要度をそれぞれ設定する。 In this case, the application server 5 stores the daily sales mart 41A (FIG. 3 (B)) and the sales result mart 41B (FIG. 3 (FIG. 3 (FIG. 3)) in which the processing results of the first tabulation batch 35A and the second tabulation batch 35B are stored. As for C), the importance of the data of the top 20% records with many references is “A”, and the importance of the data of the top 20-40% of records is “B” The importance of the data in each of the top 40 to 60% records is "C", the importance of the data in each of the top 60 to 100% records is "D", and the degree of importance is "A" The importance of the data of each record which does not correspond to any of "D" (that is, never referred to) is set as "E", and the importance of each record (each data) is respectively set.
また、例えば、第3の集計バッチ35Cや第4の集計バッチ35Dについて設定された重要度設定ルールが、『他のレコードと数値の傾向が異なるレコードのデータの重要度を高く設定する』というルール(以下、これを第2の重要度設定ルールと呼ぶ)であるものとする。 Also, for example, the importance level setting rule set for the third aggregation batch 35C and the fourth aggregation batch 35D is a rule that “importance level of data of records having different numerical tendencies with other records is set high”. (Hereinafter, this will be referred to as a second importance level setting rule).
この場合、アプリケーションサーバ5は、その第3の集計バッチ35Cや第4の集計バッチ35Dの処理結果が格納される人気商品マート41C(図3(D))や売上順位マート41D(図3(E))については、そのデータマート41のレコードごとに、そのレコードの数値と、そのデータマート41の各レコードの数値の平均値との差分の絶対値をそのレコードの偏差としてそれぞれ求め、偏差の大きい上位20%の各レコードのデータの重要度をそれぞれ「A」、上位20〜40%の各レコードのデータの重要度をそれぞれ「B」、上位40〜60%の各レコードのデータの重要度をそれぞれ「C」、上位60〜100%の各レコードのデータの重要度をそれぞれ「D」のように、レコードごと(データごと)の重要度をそれぞれ設定する。 In this case, the application server 5 stores the popular commodity mart 41C (FIG. 3D) and the sales order mart 41D (FIG. 3E (E), in which the processing results of the third totalization batch 35C and the fourth totalization batch 35D are stored. )) For each record of the data mart 41, the absolute value of the difference between the numerical value of the record and the average value of the values of each record of the data mart 41 is determined as the deviation of the record, and the deviation is large Importance of data of top 20% of each record is "A", importance of data of top 20 to 40% of each record is "B" and importance of data of top 40 to 60% of each record The degree of importance of the data of each of the top 60 to 100% records of “C” and “D” respectively, and the degree of importance of each record (each data) are respectively set.
そしてアプリケーションサーバ5は、例えば、重要度が「A」のレコードのデータについては、影響度が「0」以内の場合に「影響度が許容範囲内」であると判定し、重要度が「B」のレコードのデータについては、影響度が「0.5」以内の場合に「影響度が許容範囲内」であると判定する。またアプリケーションサーバ5は、重要度が「C」のレコードのデータについては、影響度が「1」以内の場合に「影響度が許容範囲内」であると判定し、重要度が「D」のレコードのデータについては、影響度が「10」以内の場合に「影響度が許容範囲内」であると判定する。さらにアプリケーションサーバ5は、重要度が「A」〜「D」に該当しないレコードのデータについては、影響度の値に関わりなく(無制限)、常に「影響度が許容範囲内」であると判定する。 Then, for example, with respect to the data of the record having the importance “A”, the application server 5 determines that “the influence is within the allowable range” when the influence is “0” or less, and the importance “B”. With regard to the data of the record of “1”, when the degree of influence is “0.5” or less, it is determined that “the degree of influence is within the allowable range”. Further, the application server 5 determines that the “impact is within the allowable range” when the impact is “1” or less for the data of the record having the importance “C”, and the importance is “D”. For the data of the record, if the degree of influence is "10" or less, it is determined that "the degree of influence is within the allowable range". Furthermore, the application server 5 always determines that the “impact is within the allowable range” regardless of the value of the impact (unlimited) for the data of the record that does not correspond to the importance “A” to “D”. .
従って、第1の集計バッチ35Aや第2の集計バッチ35Bについて上述したように、影響度が「0.002」と算出されたレコードのデータの重要度が「A」であった場合には、元データの変更が後続業務に与える影響度は許容範囲を超えると判定され、当該データの重要度が「B」〜「E」であった場合には、元データの変更が後続業務に与える影響度は許容範囲内であるとの判定されることになる。 Therefore, as described above for the first aggregation batch 35A and the second aggregation batch 35B, when the importance of the data of the record whose influence degree is calculated as "0.002" is "A", the original data It is determined that the impact of the change on subsequent work exceeds the allowable range, and if the importance of the data is “B” to “E”, the impact on the subsequent work of the change of the original data is It will be determined that it is within the allowable range.
なお本実施の形態の場合、上述のようにデータマート41の各レコードのデータの重要度がそのレコードのデータの参照回数や平均値からの偏差の大きさといった、経時的に変化する当該データに関する所定値に応じて設定されるため、各レコード(各データ)の重要度をなるべく最新の情報に基づいて設定する必要がある。このためアプリケーションサーバ5は、個々のレコード(データ)の重要度を定期的(例えば、毎日)に更新する。 In the case of the present embodiment, as described above, the importance of the data of each record of the data mart 41 relates to the data which changes with time, such as the number of times of reference to the data of the record and the magnitude of deviation from the average value. Since it is set according to a predetermined value, it is necessary to set the importance of each record (each data) based on the latest information as much as possible. Therefore, the application server 5 periodically (for example, every day) updates the importance of each record (data).
そしてアプリケーションサーバ5は、上述のスケジュール空き判定の判定結果と、上述の影響度判定の判定結果とに基づいて、例えば、元データの変更が後続業務に与える影響度が許容範囲内にあるか否かを、元データの変更の影響を受けるデータマート41(つまり元データを参照するバッチ35の処理結果が登録されるデータマート41)のレコードごとにそれぞれ判定する。そしてアプリケーションサーバ5は、かかる影響度が許容範囲を超えるレコードが存在する場合には、そのデータマート41に処理結果を格納するバッチ35を再実行すべきと判断する。 Then, based on the determination result of the above-mentioned schedule vacancy determination and the above determination result of the impact determination, the application server 5 determines, for example, whether or not the influence of the change of the original data on the subsequent operation is within the allowable range. Is determined for each record of the data mart 41 (that is, the data mart 41 in which the processing result of the batch 35 referring to the original data is registered) which is affected by the change of the original data. Then, when there is a record in which the degree of influence exceeds the allowable range, the application server 5 determines that the batch 35 storing the processing result in the data mart 41 should be re-executed.
またアプリケーションサーバ5は、元データの変更により影響度が許容範囲を超えたレコードが存在しない場合でも、そのデータマート41に処理結果を格納するバッチ35を再実行できる空き時間があるときにはそのバッチ35を再実行すべきと判断し、そのような空き時間がない場合にはそのバッチ35を再実行すべきでないと判断する。 Further, even if there is no record whose degree of influence exceeds the allowable range due to the change of the original data, the application server 5 has a vacant time when the data mart 41 can execute the batch 35 storing the processing result again. Is determined to be re-executed, and it is determined that the batch 35 should not be re-executed if there is no such free time.
そしてアプリケーションサーバ5は、バッチ35を再実行すべきと判断した場合には、そのバッチ35の再実行するようバッチ実行スケジュールを変更し、変更したバッチ実行スケジュールに従ってそのバッチ35を再実行する。 When the application server 5 determines that the batch 35 should be re-executed, the application server 5 changes the batch execution schedule to re-execute the batch 35, and re-executes the batch 35 according to the changed batch execution schedule.
以上のような本実施の形態によるバッチ再実行要否判定機能を実現するための手段として、図7に示すように、アプリケーションサーバ5のメモリ31には、バッチ解析部50、バッチスケジュール管理部51、履歴管理部52、重要度設定部53、変更検出部54、影響度算出部55、バッチ制御部56及び反映通知部57が格納されている。またアプリケーションサーバ5の記憶装置32には、影響度算出ルール決定テーブル60、重要度設定ルール決定テーブル61、担当者連絡先テーブル62、入出力管理テーブル63、バッチ実行条件管理テーブル64、バッチ実行スケジュールテーブル65、バッチ優先順位管理テーブル66、リソース管理テーブル67、バッチ実行履歴管理テーブル68、マート参照履歴管理テーブル69、参照頻度管理テーブル70及び重要度管理テーブル71と、それぞれ複数の影響度算出ルール72及び重要度設定ルール73とが格納されている。 As means for realizing the batch re-execution necessity determination function according to the present embodiment as described above, as shown in FIG. 7, the memory 31 of the application server 5 includes a batch analysis unit 50 and a batch schedule management unit 51. A history management unit 52, an importance setting unit 53, a change detection unit 54, an influence calculation unit 55, a batch control unit 56, and a reflection notification unit 57 are stored. The storage unit 32 of the application server 5 also includes an impact degree calculation rule determination table 60, an importance level setting rule determination table 61, a person-in-charge contact table 62, an input / output management table 63, a batch execution condition management table 64, and a batch execution schedule. Table 65, Batch priority management table 66, Resource management table 67, Batch execution history management table 68, Mart reference history management table 69, Reference frequency management table 70, Importance management table 71, and a plurality of impact calculation rules 72 respectively And an importance setting rule 73 is stored.
そして図8に示すように、バッチ解析部50は、影響度算出ルール決定テーブル60、重要度設定ルール決定テーブル61、担当者連絡先テーブル62及び入出力管理テーブル63を管理し、バッチスケジュール管理部51は、バッチ実行条件管理テーブル64、バッチ実行スケジュールテーブル65、バッチ優先順位管理テーブル66及びリソース管理テーブル67を管理している。また履歴管理部52は、バッチ実行履歴管理テーブル68及びマート参照履歴管理テーブル69を管理し、重要度設定部53は、参照頻度管理テーブル70、重要度管理テーブル71及びシステム管理者等により予め登録された幾つかの重要度設定ルール73を管理し、影響度算出部55は、システム管理者等により予め登録された幾つかの影響度算出ルール72を管理している。 Then, as shown in FIG. 8, the batch analysis unit 50 manages the influence degree calculation rule determination table 60, the importance degree setting rule determination table 61, the person-in-charge contact table 62 and the input / output management table 63, and the batch schedule management unit 51 manages a batch execution condition management table 64, a batch execution schedule table 65, a batch priority management table 66, and a resource management table 67. Further, the history management unit 52 manages the batch execution history management table 68 and the mart reference history management table 69, and the importance setting unit 53 registers in advance by the reference frequency management table 70, the importance management table 71, the system administrator, etc. The several importance setting rules 73 are managed, and the influence calculation unit 55 manages several influence calculation rules 72 registered in advance by a system administrator or the like.
バッチ解析部50は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際に、そのバッチ35の実行条件を入力させる機能を有するプログラムである。実際上、バッチ解析部50は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際、図21について後述するバッチ登録画面80をその担当者のホスト装置7に表示させる。 The batch analysis unit 50 is a program having a function of inputting an execution condition of the batch 35 when a person in charge of the subsequent business registers the batch 35 in the application server 5. In practice, when the person in charge of the subsequent business registers the batch 35 in the application server 5, the batch analysis unit 50 causes the host device 7 of the person in charge to display a batch registration screen 80 described later with reference to FIG.
そしてバッチ解析部50は、かかる担当者がこのバッチ登録画面80を用いて登録したそのバッチの実行頻度(毎日、毎週又は毎月など)と、「午前0時以降に実行」、「バッチA完了後に開始」などのそのバッチ35を開始するために満たすべき条件(以下、これを開始条件と呼ぶ)と、そのバッチ35を完了させておかなければならない時刻などの条件(以下、これを完了条件と呼ぶ)と、そのバッチ35を開始してから終了するまでに要すると想定される所要時間(以下、これを想定所要時間と呼ぶ)と、そのバッチ35を実行するために割り当てるべきリソースとをそのバッチ35の実行条件として取得し、取得したその実行条件をバッチ実行条件管理テーブル64に登録する。 The batch analysis unit 50 then executes the execution frequency (daily, weekly, monthly, etc.) of the batch registered by the person in charge using the batch registration screen 80, “execute after midnight”, “after the batch A is completed. "Conditions to be met to start the batch 35 such as" Start "(hereinafter referred to as" start conditions ") and conditions such as the time when the batch 35 must be completed (hereinafter referred to as" completion conditions " Call), the required time required to start and complete the batch 35 (hereinafter referred to as the estimated required time), and the resources to be allocated for executing the batch 35. Acquired as an execution condition of the batch 35, and register the acquired execution condition in the batch execution condition management table 64.
またバッチ解析部50は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録したときにそのバッチ35の処理内容を解析し、そのバッチ35に適用すべき上述の影響度算出ルール72を決定する。例えば、バッチ解析部50は、そのバッチ35が実行するバッチ処理が集計処理を含む場合には上述の第1の影響度算出ルールを、またそのバッチ35が実行するバッチ処理が最大値を算出する処理を含む場合には上述の第2の影響度算出ルールを、さらにそのバッチ35が実行するバッチ処理がソート処理を含む場合には上述の第3の影響度算出ルールをそのバッチ35に適用すべき影響度算出ルール72として決定する。そしてバッチ解析部50は、決定した影響度算出ルール72をそのバッチ35と対応付けて影響度算出ルール決定テーブル60に登録する。 Further, when the person in charge of the subsequent business registers the batch 35 in the application server 5, the batch analysis unit 50 analyzes the processing content of the batch 35, and determines the above-described influence calculation rule 72 to be applied to the batch 35. Do. For example, when the batch process executed by the batch 35 includes tallying, the batch analysis unit 50 calculates the above-described first influence degree calculation rule, and the batch process executed by the batch 35 calculates the maximum value. When the process is included, the second impact degree calculation rule described above is applied, and when the batch process executed by the batch 35 further includes a sort process, the third impact degree calculation rule described above is applied to the batch 35 It is determined as the power of influence calculation rule 72. Then, the batch analysis unit 50 registers the determined impact degree calculation rule 72 in association with the batch 35 in the impact degree calculation rule determination table 60.
さらにバッチ解析部50は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際、図22について後述する重要度設定ルール決定画面90と、図23について後述する担当者連絡先登録画面100とを順番にその担当者のホスト装置7に表示させる。そしてバッチ解析部50は、重要度設定ルール決定画面90を用いて担当者により設定されたそのバッチ35に適用すべき上述の重要度設定ルールを重要度設定ルール決定テーブル61に登録して管理する。またバッチ解析部50は、担当者連絡先登録画面100を用いて担当者により登録されたその担当者の連絡先を担当者連絡先テーブル62に登録して管理する。 Furthermore, when the person in charge of the subsequent work registers the batch 35 in the application server 5, the batch analysis unit 50 sets the importance level setting rule determination screen 90 described later with reference to FIG. 22 and the person in charge contact registration screen 100 described later with reference to FIG. And in order to be displayed on the host device 7 of the person in charge. Then, the batch analysis unit 50 registers the above-mentioned importance setting rule to be applied to the batch 35 set by the person in charge using the importance setting rule determination screen 90 in the importance setting rule determination table 61 and manages it. . Further, the batch analysis unit 50 registers the contact address of the person in charge registered by the person in charge using the person-in-charge contact registration screen 100 in the person-in-charge contact table 62 and manages it.
加えて、バッチ解析部50は、アプリケーションサーバ5にバッチ35が登録されるごとに、そのバッチ35が参照するテーブル(データベース40又はデータマート41)と、処理結果を格納するデータマート41とを特定し、特定結果を入出力管理テーブル63に登録して管理する。そしてバッチ解析部50は、例えば、販売データ14やデータマート41(元データ)が変更されたときに、後述のようなバッチ制御部56からの要求に応じて、かかる入出力管理テーブル63を参照してその変更の影響を受けるバッチ35やデータマート41のレコードを特定する。 In addition, each time the batch 35 is registered in the application server 5, the batch analysis unit 50 specifies the table (the database 40 or the data mart 41) to which the batch 35 refers and the data mart 41 storing the processing result. And registers and manages the specific result in the input / output management table 63. Then, for example, when the sales data 14 or the data mart 41 (original data) is changed, the batch analysis unit 50 refers to the input / output management table 63 in response to a request from the batch control unit 56 as described later. The records of the batch 35 and the data mart 41 that are affected by the change are identified.
バッチスケジュール管理部51は、上述のバッチ実行スケジュールを作成して管理する機能を有するプログラムである。実際上、バッチスケジュール管理部51は、後続業務の担当者により新たなバッチ35がアプリケーションサーバ5に登録された場合、上述したそのバッチ35の実行条件と、図15について後述する各バッチ35の優先順位とに基づいてそのバッチ35の実行タイミングを決定し、決定した実行タイミングをバッチ実行スケジュールテーブル65に登録して管理する。なおバッチスケジュール管理部51は、かかるシステム管理者等により設定されたアプリケーションサーバ5に登録された各バッチ35の優先順位をバッチ優先順位管理テーブル66に登録して管理する。 The batch schedule management unit 51 is a program having a function of creating and managing the above-mentioned batch execution schedule. In practice, when a new batch 35 is registered in the application server 5 by the person in charge of the subsequent work, the batch schedule management unit 51 executes the above-described execution condition of the batch 35 and the priority of each batch 35 described later with reference to FIG. The execution timing of the batch 35 is determined based on the order and the determined execution timing is registered in the batch execution schedule table 65 and managed. The batch schedule management unit 51 registers and manages, in the batch priority management table 66, the priority of each batch 35 registered in the application server 5 set by the system administrator or the like.
またバッチスケジュール管理部51は、アプリケーションサーバ5のリソースをリソース管理テーブル67に登録して管理しており、後述のようにバッチ制御部56からバッチ35を指定してその再実行が可能であるか否かの問い合わせが与えられた場合には、かかるリソース管理テーブル67と、バッチ実行スケジュールテーブル65とを参照して、リソース的及び時間的にそのバッチ35を再実行できるか否かを判定し、判定結果をバッチ制御部56に通知する。この場合、バッチスケジュール管理部51は、そのバッチ35の再実行が可能であると判定した場合には、そのバッチ35の再実行するための実行スケジュールを組み込むようバッチ実行スケジュールを更新(つまりその実行スケジュールをバッチ実行スケジュールテーブル65に登録)する。 Further, the batch schedule management unit 51 registers and manages the resources of the application server 5 in the resource management table 67, and as described later, can the batch control unit 56 designate the batch 35 and re-execute it? If an inquiry as to whether or not it has been issued is given, the resource management table 67 and the batch execution schedule table 65 are referenced to determine whether or not the batch 35 can be re-executed in terms of resources and time. The determination result is notified to the batch control unit 56. In this case, if the batch schedule management unit 51 determines that the batch 35 can be re-executed, the batch execution schedule is updated to incorporate the execution schedule for re-executing the batch 35 (that is, the execution is performed). The schedule is registered in the batch execution schedule table 65).
履歴管理部52は、アプリケーションサーバ5に登録された各バッチ35の実行履歴や、後続業務の担当者が自己のホスト装置7を用いてアプリケーションサーバ5を介して行ったデータマート41の各レコードの参照履歴を管理する機能を有するプログラムである。履歴管理部52は、アプリケーションサーバ5に登録されたバッチ35が実行されるごとに、そのバッチ35の実行履歴をバッチ実行履歴管理テーブル68に登録して管理すると共に、いずれかのデータマート41のレコードのデータが後続業務の担当者により参照されるごとに、その参照履歴をマート参照履歴管理テーブル69に登録して管理する。 The history management unit 52 executes the execution history of each batch 35 registered in the application server 5 or each record of the data mart 41 performed by the person in charge of the subsequent business using the host device 7 of the own via the application server 5. It is a program having a function of managing reference history. The history management unit 52 registers and manages the execution history of the batch 35 in the batch execution history management table 68 each time the batch 35 registered in the application server 5 is executed, and at the same time, the history management unit 52 Each time the record data is referred to by the person in charge of the subsequent work, the reference history is registered and managed in the mart reference history management table 69.
重要度設定部53は、データマート41ごとにそのデータマート41の各レコードの重要度をそれぞれ設定すると共に、これらの重要度を定期的に更新する機能を有するプログラムである。実際上、重要度設定部53は、履歴管理部52が管理するマート参照履歴管理テーブル69を参照してデータごとの参照頻度を参照頻度管理テーブル70に登録して管理する。そして重要度設定部53は、新たなバッチ35が登録された場合、そのバッチ35について設定された重要度設定ルール73(図7)を重要度設定ルール決定テーブル61から取得し、取得した重要度設定ルール73と、上述の参照頻度管理テーブル70とを参照して、そのバッチ35の処理結果が登録されるデータマート41の各レコード(各データ)の重要度をそれぞれ設定する。また重要度設定部53は、上述のようにして設定したデータマート41の各レコードの重要度を定期的に更新する。 The degree of importance setting unit 53 is a program having a function of setting the degree of importance of each record of the data mart 41 for each data mart 41 and updating the degree of importance periodically. In practice, the importance setting unit 53 refers to the mart reference history management table 69 managed by the history management unit 52, and registers and manages the reference frequency for each data in the reference frequency management table 70. Then, when a new batch 35 is registered, the importance setting unit 53 acquires the importance setting rule 73 (FIG. 7) set for the batch 35 from the importance setting rule determination table 61, and acquires the acquired importance The importance of each record (each data) of the data mart 41 in which the processing result of the batch 35 is registered is set with reference to the setting rule 73 and the reference frequency management table 70 described above. Further, the importance setting unit 53 periodically updates the importance of each record of the data mart 41 set as described above.
変更検出部54は、データベース40(図1)に格納されている各店舗端末3からの販売データ14及び各データマート41の各レコードのデータをそれぞれ監視し、いずれかの販売データ14又はデータマート41のデータが更新された場合にこれを検出する機能を有するプログラムである。変更検出部54は、販売データ14やデータマート41のデータの変更を検出した場合、入出力管理テーブル63を参照してその販売データ14やそのデータマート41のレコードのデータを参照するバッチ35をすべて特定し、これらバッチ35のバッチ名と、変更された販売データ14やデータマート41のレコードのデータの変更前後の値とをバッチ制御部56に通知する。 The change detection unit 54 monitors each of the sales data 14 from each store terminal 3 and the data of each record of each data mart 41 stored in the database 40 (FIG. 1), and either the sales data 14 or the data mart This is a program having a function of detecting the 41 data when it is updated. When the change detection unit 54 detects a change in the sales data 14 or data in the data mart 41, the change detection unit 54 refers to the input / output management table 63 to refer to the batch 35 referring to the sales data 14 or the data of the record in the data mart 41. The batch control unit 56 is notified of the batch names of the batches 35 and the values before and after the change of the sales data 14 and the data of the data mart 41 records.
影響度算出部55は、販売データ14又はデータマート41のデータが変更された場合に、その変更が後続業務に与える影響度を算出する機能を有するプログラムである。影響度算出部55は、変更されたデータ(元データ)を参照するバッチ35ごとに、そのバッチ35について設定された影響度算出ルール72を影響度算出ルール決定テーブル60から取得し、取得した影響度算出ルール72に従って、かかる元データの変更が後続業務に与える影響を算出する。 The influence degree calculation unit 55 is a program having a function of calculating the degree of influence of the change on the subsequent business when the sales data 14 or the data of the data mart 41 is changed. The influence calculation unit 55 acquires the influence calculation rule 72 set for the batch 35 from the influence calculation rule determination table 60 for each batch 35 referring to the changed data (original data), and acquires the influence According to the degree calculation rule 72, the influence of the change of the original data on the subsequent work is calculated.
バッチ制御部56は、通常時にはバッチスケジュール管理部51が管理しているバッチ実行スケジュールに従って各バッチ35を起動して実行させる機能を有するプログラムである。またバッチ制御部56は、変更検出部54により販売データ14やデータマート41のデータ(元データ)の変更が検出された場合には、変更された元データを入力とするバッチ35の特定をバッチ解析部50に依頼する。 The batch control unit 56 is a program having a function of starting and executing each batch 35 in accordance with a batch execution schedule managed by the batch schedule management unit 51 under normal conditions. When the change detection unit 54 detects a change in the sales data 14 or the data (original data) of the data mart 41, the batch control unit 56 batch-specifies the batch 35 to which the changed original data is input. The analysis unit 50 is requested.
そしてバッチ制御部56は、バッチ解析部50により特定されたバッチ35を再実行する空き時間があるか否かの判定(スケジュール空き判定)をバッチスケジュール管理部51に依頼する。またバッチ制御部56は、かかる元データの変更が後続業務に与える影響度の算出を影響度算出部55に依頼し、その算出結果に基づいて、かかる元データの変更が後続業務に与える影響度が許容範囲内であるか否か元データの影響を受けるデータマート41のレコードごとにそれぞれ判定(影響度判定)する。 Then, the batch control unit 56 requests the batch schedule management unit 51 to determine whether there is an idle time for re-executing the batch 35 specified by the batch analysis unit 50 (schedule availability determination). Further, the batch control unit 56 requests the influence degree calculation unit 55 to calculate the degree of influence of the change of the original data on subsequent work, and based on the calculation result, the degree of influence of the change of the original data on subsequent work Is judged to be within the allowable range for each record of the data mart 41 affected by the original data (impact determination).
そしてバッチ制御部56は、上述のスケジュール空き判定の判定結果及び影響度判定の判定結果に基づいて、かかる影響度が許容範囲を超えるレコードがある場合には、そのデータマート41に処理結果を格納するバッチ35を再実行すべきと判定し、バッチスケジュール管理部51及び反映通知部57にそのバッチ35の再実行を通知する。 The batch control unit 56 stores the processing result in the data mart 41 when there is a record in which the degree of influence exceeds the allowable range, based on the judgment result of the above-mentioned schedule vacancy judgment and the judgment result of the influence degree judgment. It is determined that the batch 35 to be executed should be re-executed, and the batch schedule management unit 51 and the reflection notification unit 57 are notified of re-execution of the batch 35.
反映通知部57は、バッチ35の再実行をそのバッチを登録した後続業務の担当者に通知する機能を有するプログラムである。実際上、反映通知部57は、バッチ35の再実行がバッチ制御部56から通知された場合に、そのバッチ35を登録した担当者の連絡先を担当者連絡先テーブル62から取得し、かかるバッチ35を再実行する旨の通知をその連絡先に送信する。 The reflection notifying unit 57 is a program having a function of notifying the person in charge of the subsequent business who has registered the batch of the re-execution of the batch 35. In fact, when the re-execution of the batch 35 is notified from the batch control unit 56, the reflection notification unit 57 acquires the contact information of the person who has registered the batch 35 from the person-in-charge contact table 62, and the batch Send a notification to that contact to re-execute 35.
一方、影響度算出ルール決定テーブル60は、アプリケーションサーバ5に登録された各バッチ35に対してバッチ解析部50が設定した影響度算出ルール72を管理するために利用されるテーブルであり、図9に示すように、対象バッチ欄60A及び影響度算出ルール欄60Bを備えて構成される。 On the other hand, the influence degree calculation rule determination table 60 is a table used to manage the influence degree calculation rules 72 set by the batch analysis unit 50 for each batch 35 registered in the application server 5, as shown in FIG. As shown in FIG. 6, the target batch field 60A and the influence degree calculation rule field 60B are provided.
そして対象バッチ欄60Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納され、影響度算出ルール欄60Bには、対応するバッチ35に対して設定された影響度算出ルール72の識別子が格納される。 The batch name of each batch 35 registered in the application server 5 is stored in the target batch field 60A, and the impact degree calculation rule 72 set for the corresponding batch 35 is stored in the impact degree calculation rule field 60B. The identifier of is stored.
従って図9の例の場合、例えば、「集計バッチ1」及び「集計バッチ2」に対しては影響度算出ルール72として「影響度算出ルール1」がそれぞれ設定され、「集計バッチ3」に対しては影響度算出ルール72として「影響度算出ルール2」が設定され、「集計バッチ3」に対しては影響度算出ルール72として「影響度算出ルール3」が設定されていることが示されている。 Therefore, in the case of the example of FIG. 9, for example, “impact calculation rule 1” is set as “impact calculation rule 72” for “total batch 1” and “total batch 2”, and “coarse batch 3” "Influence calculation rule 2" is set as the influence degree calculation rule 72, and "influence calculation rule 3" is set as the influence calculation rule 72 for "total batch 3". ing.
また重要度設定ルール決定テーブル61は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際に設定したそのバッチ35の処理結果を登録するデータマート41の各レコードに対する重要度の設定ルール(重要度設定ルール73)を管理するために利用されるテーブルである。この重要度設定ルール決定テーブル61は、図10に示すように、対象バッチ欄61A、重要度設定ルール欄61B及び起動条件欄61Cを備えて構成される。 Further, the importance level setting rule determination table 61 is a setting rule of the importance level for each record of the data mart 41 which registers the processing result of the batch 35 set when the person in charge of the subsequent business registers the batch 35 in the application server 5 It is a table used to manage (the importance setting rule 73). As shown in FIG. 10, the importance level setting rule determination table 61 is configured to include a target batch column 61A, an importance level setting rule column 61B, and a start condition column 61C.
そして対象バッチ欄61Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納され、重要度設定ルール欄61Bには、対応するバッチ35に対して設定された重要度設定ルール73の識別子が格納される。また起動条件欄61Cには、対応するバッチ35が登録された際に設定された、そのバッチ35が処理結果を格納するデータマート41の各レコードの重要度を更新する処理を実行する条件(起動条件)が格納される。 The batch name of each batch 35 registered in the application server 5 is stored in the target batch column 61A, and the importance level setting rule 73 set for the corresponding batch 35 is stored in the importance level setting rule column 61B. The identifier of is stored. Further, the condition for executing the process of updating the importance of each record of the data mart 41 in which the batch 35 stores the processing result, which is set when the corresponding batch 35 is registered in the start condition column 61C Condition) is stored.
従って図10の例の場合、例えば、「集計バッチ1」に対しては、重要度設定ルール73として「重要度設定ルール1」が設定されると共に、その「集計バッチ1」が処理結果を格納するデータマート41の各レコードのデータに対して設定された重要度を「毎日午前0時」に更新すべき旨の設定がなされていることが示されている。 Therefore, in the case of the example of FIG. 10, for example, "importance setting rule 1" is set as the importance setting rule 73 for "aggregate batch 1", and the "aggregate batch 1" stores the processing result. It is shown that the importance set for the data of each record of the data mart 41 to be updated is set to be updated to “every day at midnight”.
担当者連絡先テーブル62は、後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際に設定されたその担当者への連絡先(以下、メールアドレスとする)を管理するために利用されるテーブルであり、図11に示すように、対象バッチ欄62A及びメールアドレス欄62Bを備えて構成される。 The person-in-charge contact table 62 is used to manage contacts (hereinafter referred to as e-mail addresses) to the person-in-charge set when the person-in-charge in the subsequent business registers the batch 35 in the application server 5. And, as shown in FIG. 11, is configured to include a target batch field 62A and an e-mail address field 62B.
そして対象バッチ欄62Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納され、メールアドレス欄62Bには、対応するバッチ35をアプリケーションサーバ5に登録した担当者のメールアドレスが格納される。 The batch name of each batch 35 registered in the application server 5 is stored in the target batch field 62A, and the e-mail address field 62B stores the e-mail address of the person who registered the corresponding batch 35 in the application server 5. Stored.
従って図11の例の場合、例えば、「集計バッチ1」をアプリケーションサーバ5に登録した担当者のメールアドレスは「batch1_tantou@gyoumu.com」、「集計バッチ2」をアプリケーションサーバ5に登録した担当者のメールアドレスは「batch2_tantou@gyoumu.com」であり、「集計バッチ3」をアプリケーションサーバ5に登録した担当者のメールアドレスは「batch3_tantou@gyoumu.com」、「集計バッチ4」をアプリケーションサーバ5に登録した担当者のメールアドレスは「batch4_tantou@gyoumu.com」であることが示されている。 Therefore, in the case of the example of FIG. 11, for example, the e-mail address of the person in charge who has registered "aggregate batch 1" in the application server 5 is "person" who registered "batch1_tantou@gyoumu.com" and "aggregate batch 2" in the application server 5 'S email address is "batch2_tantou@gyoumu.com", and the email address of the person in charge who has registered "aggregate batch 3" in application server 5 is "batch3_tantou@gyoumu.com", "aggregate batch 4" in application server 5 It is shown that the registered person's email address is "batch4_tantou@gyoumu.com".
入出力管理テーブル63は、アプリケーションサーバ5に登録された各バッチ35がそれぞれ処理を実行する際に参照するテーブル(データベース40のテーブル又はデータマート41)と、処理結果を格納するデータマート41とを管理するために利用されるテーブルであり、図12に示すように、バッチ名欄63A、参照テーブル欄63B及び更新テーブル欄63Cを備えて構成される。 The input / output management table 63 includes a table (a table of the database 40 or the data mart 41) to be referred to when each batch 35 registered in the application server 5 executes a process, and a data mart 41 for storing the processing result. This table is used for management, and as shown in FIG. 12, is configured to include a batch name column 63A, a reference table column 63B, and an update table column 63C.
そしてバッチ名欄63Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納される。また参照テーブル欄63Bには、対応するバッチ35が処理を実行する際に参照するテーブルの識別子が格納され、更新テーブル欄63Cには、そのバッチ35が処理結果を登録するデータマート41の識別子が格納される。 Then, the batch name of each batch 35 registered in the application server 5 is stored in the batch name column 63A. The reference table column 63B stores the identifier of the table to be referred to when the corresponding batch 35 executes the processing, and the update table column 63C stores the identifier of the data mart 41 whose batch 35 registers the processing result. Stored.
従って、図12の例の場合、例えば、「集計バッチ1」というバッチ35は、「店舗1 販売データ(コピー)」というテーブル(データベース40のテーブル)に格納されたデータを入力として処理を実行し、処理結果を「日別売上マート」というデータマート41に格納することが示されている。 Therefore, in the case of the example of FIG. 12, for example, the batch 35 "total batch 1" executes processing with data stored in a table (table of the database 40) "store 1 sales data (copy)" as an input. It is shown that the processing result is stored in a data mart 41 called “daily sales mart”.
バッチ実行条件管理テーブル64は、上述のように後続業務の担当者がバッチ35をアプリケーションサーバ5に登録する際に登録したそのバッチ35の実行条件を管理するために利用されるテーブルである。このバッチ実行条件管理テーブル64は、図13に示すように、バッチ名欄64A、実行頻度欄64B、開始条件欄64C、完了条件欄64D、想定所要時間欄64E及び割当てリソース欄64Fを備えて構成される。 The batch execution condition management table 64 is a table used to manage the execution conditions of the batch 35 registered by the person in charge of the subsequent business when registering the batch 35 in the application server 5 as described above. As shown in FIG. 13, the batch execution condition management table 64 comprises a batch name column 64A, an execution frequency column 64B, a start condition column 64C, a completion condition column 64D, an estimated required time column 64E, and an allocated resource column 64F. Be done.
そしてバッチ名欄64Aには、対応するバッチ35が登録される際にそのバッチ35を登録した担当者により設定されたそのバッチ35の名称(バッチ名)が格納され、実行頻度欄64Bには、その担当者により設定されたそのバッチ35の実行頻度が格納される。また開始条件欄64Cには、その担当者により設定されたそのバッチ35の開始条件が格納され、完了条件欄64Dには、その担当者により設定されたそのバッチ35の完了条件が格納される。 The batch name field 64A stores the name (batch name) of the batch 35 set by the person in charge of registering the corresponding batch 35 when the corresponding batch 35 is registered, and the execution frequency field 64B stores the name. The execution frequency of the batch 35 set by the person in charge is stored. The start condition column 64C stores the start condition of the batch 35 set by the person in charge, and the completion condition column 64D stores the completion condition of the batch 35 set by the person in charge.
さらに想定所要時間欄64Eには、その担当者により登録されたそのバッチ35の想定所要時間が格納され、割当てリソース欄64Fには、その担当者により登録されたそのバッチ35を実行する際に割り当てるべきリソースが格納される。 Furthermore, the estimated required time of the batch 35 registered by the person in charge is stored in the estimated required time column 64E, and allocated in the allocated resource column 64F when the batch 35 registered by the person in charge is executed. The resources to be stored are stored.
従って、図13の例の場合、「集計バッチ1」というバッチ35については、想定所要時間が「3時間」であり、「毎日」、「午前0時以降」に処理を開始し、「翌午前9時」までに処理を完了させる必要があり、処理実行時には1つのCPU及び2GB分のメモリ(「CPU=1、メモリ=2GB」)を割り当てるべき旨の登録がなされていることが示されている。 Therefore, in the case of the example of FIG. 13, for the batch 35 “total batch 1”, the estimated required time is “3 hours”, and processing is started “daily”, “after midnight”, “next morning It is shown that it is necessary to complete the process by 9 o'clock, and that at the time of process execution, it is registered that one CPU and 2 GB worth of memory (“CPU = 1, memory = 2 GB”) should be allocated. There is.
またバッチ実行スケジュールテーブル65は、アプリケーションサーバ5に登録された各バッチ35の実行スケジュールをそれぞれ管理するためにバッチスケジュール管理部51(図7、図8)により作成されるテーブルであり、図14に示すように、バッチ名欄65A及び実行タイミング欄65Bを備えて構成される。 Also, the batch execution schedule table 65 is a table created by the batch schedule management unit 51 (FIGS. 7 and 8) for managing the execution schedule of each batch 35 registered in the application server 5, respectively. As shown, a batch name field 65A and an execution timing field 65B are provided.
そしてバッチ名欄65Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納され、実行タイミング欄65Bには、バッチスケジュール管理部51によりスケジュールされた対応するバッチ35の実行タイミング(そのバッチ35の開始日時)が格納される。 The batch name column 65A stores the batch name of each batch 35 registered in the application server 5, and the execution timing column 65B stores the execution timing (corresponding to the corresponding batch 35 scheduled by the batch schedule management unit 51). The start date and time of the batch 35 is stored.
従って、図14の例の場合、例えば、「集計バッチ1」というバッチ35は、「毎日」、「午前0時」に実行するようスケジュールされ、「集計バッチ2」というバッチ35は、「毎週金曜日」の「午前3時」に実行するようスケジュールされていることが示されている。 Thus, in the case of the example of FIG. 14, for example, the batch 35 "total batch 1" is scheduled to be executed at "everyday", "midnight", and the batch 35 "total batch 2" is "every Friday" It is shown that it is scheduled to run at "3 am".
バッチ優先順位管理テーブル66は、アプリケーションサーバ5に登録された各バッチ35についてシステム管理者等により設定されたバッチ35ごとの優先順位を管理するために利用されるテーブルであり、図15に示すように、バッチ名欄66A及び優先順位欄66Bを備えて構成される。 The batch priority management table 66 is a table used to manage the priority of each batch 35 set by the system administrator or the like for each batch 35 registered in the application server 5, as shown in FIG. , A batch name field 66A and a priority order field 66B.
そしてバッチ名欄66Aには、アプリケーションサーバ5に登録された各バッチ35のバッチ名がそれぞれ格納され、優先順位欄66Bには、対応するバッチ35に対してシステム管理者等により設定されたそのバッチ35の優先順位が格納される。なお、あるバッチ35の後続バッチ35は、そのバッチ35よりも優先順位が低く設定される。 The batch name column 66A stores the batch name of each batch 35 registered in the application server 5, and the priority column 66B stores the batch set for the corresponding batch 35 by the system administrator or the like. The 35 priorities are stored. Note that the subsequent batch 35 of a certain batch 35 is set to have a lower priority than the batch 35.
従って、図15の例の場合、アプリケーションサーバ5に登録されたバッチ35の中では「集計バッチ2」が最も優先順位が高く、その後、「集計バッチ3」、「集計バッチ4」及び「集計バッチ1」の順番で優先順位が低くなるよう「集計バッチ1」〜「集計バッチ4」の優先順位が設定されていることが示されている。 Accordingly, in the case of the example of FIG. 15, “total batch 2” has the highest priority among the batches 35 registered in the application server 5, and thereafter “total batch 3”, “total batch 4” and “total batch It is shown that the priorities of “aggregate batch 1” to “aggregate batch 4” are set such that the priority is lowered in the order of “1”.
リソース管理テーブル67は、アプリケーションサーバ5のリソースを管理するために利用されるテーブルであり、図16に示すように、リソース名欄67A及びリソース量欄67Bを備えて構成される。 The resource management table 67 is a table used to manage the resources of the application server 5 and, as shown in FIG. 16, is configured to include a resource name column 67A and a resource amount column 67B.
そしてリソース名欄67Aには、アプリケーションサーバ5が保有するリソースのうち、バッチ35の実行に必要な各リソースのリソース名が格納され、リソース量欄67Bには、対応するリソースのリソース量が格納される。 The resource name column 67A stores the resource name of each resource necessary for executing the batch 35 among the resources held by the application server 5, and the resource amount column 67B stores the resource amount of the corresponding resource. Ru.
従って、図16の例の場合、アプリケーションサーバ5は、かかるリソースとして「CPU」については「12」個(正確にはCPUのコア数が12個)、「メモリ」として「32」GBを保有していることが示されている。 Therefore, in the case of the example of FIG. 16, the application server 5 holds “12” (correctly, the number of CPU cores is 12) “CPU” as the resource and “32” GB as the “memory”. Is shown.
バッチ実行履歴管理テーブル68は、アプリケーションサーバ5に登録された各バッチ35の実行履歴を管理するために利用されるテーブルであり、図17に示すように、バッチ名欄68A、開始日時欄68B及び終了日時欄68Cを備えて構成される。 The batch execution history management table 68 is a table used to manage the execution history of each batch 35 registered in the application server 5, and as shown in FIG. 17, the batch name column 68A, the start date and time column 68B, and It is configured to have an end date and time field 68C.
そしてバッチ名欄68Aには、アプリケーションサーバ5に登録された各バッチ35のうち、実行されたバッチ35のバッチ名が格納される。また開始日時欄68Bには、そのバッチ35の実行が開始された日時が格納され、終了日時欄68Cにはそのバッチ35が終了した日時が格納される。 The batch name column 68A stores the batch name of the executed batch 35 among the batches 35 registered in the application server 5. The start date and time column 68B stores the date and time when the execution of the batch 35 was started, and the end date and time column 68C stores the date and time when the batch 35 ended.
従って、図17の例の場合、「集計バッチ1」というバッチ35は「2017/2/3 1:00」に実行が開始され、「2017/2/2 4:05」に処理が完了し、「集計バッチ2」というバッチ35は「2017/2/3 3:00」に実行が開始され、「2017/2/3 5:21」に処理が完了したことが示されている。 Accordingly, in the case of the example of FIG. 17, the execution of the batch 35 "aggregate batch 1" is started at "2017/2/3 1:00", and the process is completed at "2017/2/2 4:05", The execution of the batch 35 "aggregate batch 2" is started at "2017/2/3 3:00", and "2017/2/3 5:21" indicates that the processing is completed.
マート参照履歴管理テーブル69は、データベースサーバ6が保持するデータマート41に対する後続業務の担当者等の参照履歴を管理するために利用されるテーブルであり、図18に示すように、対象マート欄69A、対象カラム欄69B、対象値欄69C及び参照日時欄69Dを備えて構成される。 The mart reference history management table 69 is a table used to manage the reference history of persons in charge of subsequent operations to the data mart 41 held by the database server 6, and as shown in FIG. 18, the target mart field 69A , Target column column 69B, target value column 69C, and reference date and time column 69D.
そして対象マート欄69Aには、参照されたデータマート41の名称が格納され、参照日時欄69Dには、その参照が行われた日時が格納される。また対象カラム欄69Bには、そのデータマート41におけるそのとき参照されたカラム(欄)の名称が格納され、対象値欄69Cには、そのカラム内のそのとき参照された値の名称が格納される。 The target mart field 69A stores the name of the referenced data mart 41, and the reference date and time field 69D stores the date and time when the reference was made. Also, in the target column field 69B, the name of the column (field) referenced at that time in the data mart 41 is stored, and in the target value field 69C, the name of the value referenced at that time in that column is stored. Ru.
従って、図18の例の場合、「販売実績マート」の「商品名」というカラム(商品名欄)の「チョコレート」という商品名に対する参照が「2017/2/2 9:00」に行われたことが示されている。 Therefore, in the case of the example of FIG. 18, reference to the product name “chocolate” in the column “product name” of the “sales performance mart” is performed on “2017/2/2 9:00” It is shown.
参照頻度管理テーブル70は、後続業務の担当者等が所望するデータマート41に格納されたデータを参照する際に利用したキーワードごとの参照回数を管理するために利用されるテーブルであり、図19に示すように、対象マート欄70A、対象カラム欄70B、対象値欄70C、複合キー欄70D及び参照回数欄70Eを備えて構成される。 The reference frequency management table 70 is a table used to manage the number of times of reference for each keyword used when referring to the data stored in the data mart 41 desired by the person in charge of the subsequent work or the like. As shown in the figure, the object mart field 70A, the object column field 70B, the object value field 70C, the composite key field 70D, and the reference frequency field 70E are provided.
そして対象マート欄70Aには、そのとき検索対象とされたデータマート41の識別子が格納され、対象値欄70Cには、その検索で使用されたキーワードが対象値として格納される。 Then, in the target mart field 70A, the identifier of the data mart 41 that is to be searched at that time is stored, and in the target value field 70C, the keyword used in the search is stored as the target value.
また対象カラム欄70Bには、そのデータマート41におけるかかる対象値に対応するカラム(欄)の識別子が格納され、参照回数欄70Eには、そのデータマート41のその対象値が参照された回数が格納される。 Also, the identifier of the column corresponding to the target value in the data mart 41 is stored in the target column column 70B, and the number of times the target value of the data mart 41 is referred to in the reference frequency column 70E. Stored.
さらに複合キー欄70Dには、検索で使用されたキーワードの種類ごとにそれぞれ異なる数値が格納される。この場合、複数のキーワードを組み合せて検索が行われた場合には、これら複数のキーワードの複合キー欄にそれぞれ同じ数値が格納される。 Furthermore, in the composite key field 70D, different numerical values are stored for each type of keyword used in the search. In this case, when a search is performed by combining a plurality of keywords, the same numerical value is stored in the composite key field of the plurality of keywords.
従って図19の例の場合、「販売実績」というデータマート41を対象として、「チョコレート」及び「2/1〜2/28」という2つのキーワードの組み合せ(2つのキーワードのアンド条件)で行われた検索が「10」回あったことが示されている。 Therefore, in the case of the example of FIG. 19, the data mart 41 of “sales record” is used as a combination of two keywords “chocolate” and “2/1 to 2/28” (two keywords and condition). It has been shown that there have been 10 searches.
重要度管理テーブル71は、重要度設定部53(図7、図8)が設定したデータマート41の各レコードの重要度を管理するために利用されるテーブルであり、図20に示すように、重要度ID欄71A、対象マート欄71B、対象カラム欄71C、対象値欄71D、重要度欄71E及び設定日時欄71Fを備えて構成される。 The importance management table 71 is a table used to manage the importance of each record of the data mart 41 set by the importance setting unit 53 (FIGS. 7 and 8), as shown in FIG. An importance level ID column 71A, an object mart column 71B, an object column column 71C, an object value column 71D, an importance level column 71E, and a setting date and time column 71F are provided.
そして対象マート欄71B、対象カラム欄71C及び対象値欄71Dには、それぞれ参照頻度管理テーブル70の対象マート欄70A、対象カラム欄70B及び対象値欄70Cに格納された情報と同様の情報がそれぞれ格納され、重要度ID欄71Aには、参照頻度管理テーブル70の複合キー欄70Dと同様の情報が格納される。また重要度欄71Eには、対象値欄71Dに格納された対象値のレコード(データ)に対して設定された重要度が格納され、設定日時欄71Fには、その重要度が設定された日時が格納される。 In the target mart column 71B, the target column column 71C, and the target value column 71D, the same information as the information stored in the target mart column 70A, the target column column 70B, and the target value column 70C of the reference frequency management table 70 respectively The same information as that of the compound key field 70D of the reference frequency management table 70 is stored in the importance level ID field 71A. The importance degree column 71E stores the importance degree set for the record (data) of the target value stored in the target value column 71D, and the setting date and time column 71F stores the date and time when the importance degree is set. Is stored.
従って、図20の例の場合、「販売実績」というデータマート41について、例えば、「売上日」が「2/1〜2/28」の期間内の「商品名」が「チョコレート」に関するレコード(データ)の重要度が「2017/2/12」に「A」に設定されたことが示されている。 Therefore, in the case of the example of FIG. 20, for the data mart 41 of "sales record", for example, a record in which "product name" is "chocolate" within a period of "sales day" It is shown that the importance level of “data” is set to “A” on “2017/2/12”.
なお各データマート41の各レコードの重要度を、そのデータマート41に処理結果を登録するバッチ35をアプリケーションサーバ5に登録した後続業務の担当者や、本店舗管理システム1のシステム管理者等が自由に設定及び変更できるようにしてもよい。 In addition, the person in charge of the succeeding business who registered the batch 35 for registering the processing result in the data mart 41 in the application server 5 or the system administrator of the store management system 1 etc. It may be freely set and changed.
(3)各種画面の構成
図21は、後続業務の担当者が自己のホスト装置7を用いてアプリケーションサーバ5に新たなバッチ35を登録するための所定操作を行ったときにそのホスト装置7に表示されるバッチ登録画面80の概略構成を示す。このバッチ登録画面80は、バッチ本体登録方法指定フィールド81、バッチ名設定フィールド82及びバッチ実行条件設定フィールド83と、OKボタン84及びキャンセルボタン85とを備えて構成される。
(3) Configuration of Various Screens FIG. 21 shows that when the person in charge of the subsequent business has performed a predetermined operation for registering a new batch 35 in the application server 5 using the host device 7 of its own, the host device 7 The schematic structure of the batch registration screen 80 displayed is shown. The batch registration screen 80 is configured to include a batch main body registration method designation field 81, a batch name setting field 82, a batch execution condition setting field 83, an OK button 84, and a cancel button 85.
バッチ本体登録方法指定フィールド81は、そのとき対象としているバッチ35の本体をどのような方法によりアプリケーションサーバ5に登録するかを指定するためのフィールドであり、登録方法指定欄81A及びプルダウンボタン81Bを備える。 The batch main body registration method designation field 81 is a field for designating how to register the main body of the batch 35 which is the object at that time with the application server 5, and the registration method designation column 81A and the pull-down button 81B Prepare.
そしてバッチ本体登録方法指定フィールド81では、プルダウンボタン81Bをクリックすることにより、対象とするバッチ35をアプリケーションサーバ5に登録する方法として利用可能な幾つかの方法が掲載された図示しないプルダウンメニューを表示させることができる。かくして担当者は、このプルダウンメニューに掲載された登録方法の中から所望する方法を選択することにより、そのとき対象としているバッチ35のアプリケーションサーバ5への登録方法としてその登録方法を指定することができる。そしてこのとき指定した登録方法が登録方法指定欄81Aに表示される。 Then, in the batch main body registration method designation field 81, by clicking the pull-down button 81B, a pull-down menu (not shown) is displayed on which several methods available for registering the target batch 35 in the application server 5 are listed. It can be done. Thus, the person in charge can designate the registration method as the registration method of the target batch 35 to the application server 5 by selecting the desired method from the registration methods listed in the pull-down menu. it can. Then, the registration method designated at this time is displayed in the registration method designation column 81A.
またバッチ名設定フィールド82は、そのとき登録しようとするバッチ35のバッチ名を指定するためのフィールドであり、当該バッチ名を入力するためのバッチ名入力テキストボックス82Aが設けられている。 The batch name setting field 82 is a field for specifying a batch name of the batch 35 to be registered at that time, and a batch name input text box 82A for inputting the batch name is provided.
さらにバッチ実行条件設定フィールド83は、そのとき登録しようとするバッチ35の実行条件を設定するためのフィールドであり、そのバッチ35の実行頻度、開始条件及び完了条件や、そのバッチ35の想定所要時間、並びに、そのバッチ35に割り当てるべきリソースを指定できるようになされている。 Further, the batch execution condition setting field 83 is a field for setting the execution condition of the batch 35 to be registered at that time, and the execution frequency of the batch 35, the start condition and the completion condition, and the estimated required time of the batch 35 , And the resource to be allocated to the batch 35 can be specified.
かくして後続業務の担当者は、そのとき登録しようとするバッチ35のアプリケーションサーバ5への登録方法を上述のようにして登録方法指定欄81Aに表示させると共に、そのバッチ35のバッチ名をバッチ名入力テキストボックス82Aに入力し、さらにそのバッチ35の実行条件をバッチ実行条件設定フィールド83で設定した後、OKボタン84をクリックすることにより、そのバッチ35をアプリケーションサーバ5に登録することができる。 Thus, the person in charge of the follow-up operation causes the registration method designation column 81A to display the registration method of the batch 35 to be registered at that time in the application server 5 as described above, and enters the batch name of the batch 35 as the batch name. The batch 35 can be registered in the application server 5 by entering the text box 82A and setting the execution condition of the batch 35 in the batch execution condition setting field 83 and clicking the OK button 84.
このときアプリケーションサーバ5では、バッチ解析部50(図7、図8)の制御のもとに、そのバッチ35本体のデータが取り込まれて記憶装置32(図1、図7)に格納されると共に、バッチ登録画面80において後続業務の担当者により設定されたそのバッチ35の実行条件がバッチ実行条件管理テーブル64(図13)に格納される。 At this time, in the application server 5, under control of the batch analysis unit 50 (FIGS. 7 and 8), data of the batch 35 is taken in and stored in the storage device 32 (FIGS. 1 and 7). The execution condition of the batch 35 set by the person in charge of the succeeding operation on the batch registration screen 80 is stored in the batch execution condition management table 64 (FIG. 13).
また後続業務の担当者は、キャンセルボタン85をクリックすることにより、そのときバッチ登録画面80上で行われた各設定をすべてキャンセルした上で、このバッチ登録画面80を閉じさせることができる。 Also, the person in charge of the subsequent job can close the batch registration screen 80 after canceling all the settings performed on the batch registration screen 80 by clicking the cancel button 85.
一方、図22は、後続業務の担当者がかかるバッチ登録画面80を用いてバッチ35をアプリケーションサーバ5に登録した後にホスト装置7に表示される重要度設定ルール決定画面90の概略構成を示す。この重要度設定ルール決定画面90は、そのとき登録されたバッチ35に対する重要度設定ルール73を決定するための画面である。この重要度設定ルール決定画面90は、重要度設定ルール決定フィールド91及び起動条件設定フィールド92と、OKボタン93及びキャンセルボタン94とを備えて構成される。 On the other hand, FIG. 22 shows a schematic configuration of the importance level setting rule determination screen 90 displayed on the host device 7 after registering the batch 35 in the application server 5 using the batch registration screen 80 of the person in charge of the subsequent business. The importance level setting rule determination screen 90 is a screen for determining the importance level setting rule 73 for the batch 35 registered at that time. The importance level setting rule determination screen 90 is configured to include an importance level setting rule determination field 91, a start condition setting field 92, an OK button 93, and a cancel button 94.
重要度設定ルール決定フィールド91は、そのとき登録したバッチ35に対する重要度設定ルールを決定及び設定するためのフィールドであり、予めシステム管理者等により登録されているすべての重要度設定ルール73の名称(以下、これを重要度設定ルール名と呼ぶ)91Aと、その重要度設定ルールの簡単な解説91Bと、各重要度設定ルール名の左側にそれぞれ配置されたトグルボタン91Cとが表示される。 The importance setting rule determination field 91 is a field for determining and setting the importance setting rule for the batch 35 registered at that time, and the names of all the importance setting rules 73 registered in advance by the system administrator or the like. (Hereinafter, this will be referred to as an importance setting rule name) 91A, a brief explanation 91B of the importance setting rule, and a toggle button 91C arranged on the left side of each importance setting rule name are displayed.
かくして担当者は、重要度設定ルール決定画面90内のそのバッチ35に対して適切と考える重要度設定ルール73の名称(重要度設定ルール名91A)の前に表示されたトグルボタン91Cをオンに設定した上でOKボタン93をクリックすることにより、その重要度設定ルール73をそのバッチ35に適用すべき重要度設定ルールとして指定することができる。 Thus, the person in charge turns on the toggle button 91C displayed in front of the name (importance setting rule name 91A) of the importance setting rule 73 considered to be appropriate for the batch 35 in the importance setting rule determination screen 90. By setting an OK button 93 after setting, the importance level setting rule 73 can be specified as an importance level setting rule to be applied to the batch 35.
また起動条件設定フィールド92は、そのとき選択したバッチ35が処理結果を登録するデータマート41の各レコードの重要度を更新する周期を設定するためのフィールドであり、かかる更新の頻度や日時を指定できるようになされている。 The start condition setting field 92 is a field for setting a cycle for updating the importance of each record of the data mart 41 in which the batch 35 selected at that time registers the processing result, and specifies the frequency and date and time of the update. It is made to be able.
かくして、担当者は、そのときアプリケーションサーバ5に登録したバッチ35に適用すべき重要度設定ルール73を重要度設定ルール決定フィールド91で指定し、さらにその重要度設定ルール72に従って対応するデータマート41の各レコードの重要度の更新周期を起動条件設定フィールド92で指定した後、OKボタン93をクリックすることにより、かかるバッチ35に対する重要度設定ルール73を決定及び設定できる。 Thus, the person in charge designates the importance setting rule 73 to be applied to the batch 35 registered in the application server 5 at that time in the importance setting rule determination field 91, and further the corresponding data mart 41 according to the importance setting rule 72. By specifying the update cycle of the importance of each record in the start condition setting field 92 and clicking the OK button 93, the importance setting rule 73 for the batch 35 can be determined and set.
このときアプリケーションサーバ5では、バッチ解析部50の制御のもとに、この重要度設定ルール決定画面90を用いて担当者により設定されたそのバッチ35に対する重要度設定ルール73が当該バッチ35と対応付けて重要度設定ルール決定テーブル61(図10)に格納される。 At this time, in the application server 5, under the control of the batch analysis unit 50, the importance setting rule 73 for the batch 35 set by the person in charge using the importance setting rule determination screen 90 corresponds to the batch 35. And stored in the importance level setting rule determination table 61 (FIG. 10).
また、かかる担当者は、キャンセルボタン94をクリックすることにより、そのとき重要度設定ルール決定画面90上で行われた各設定をすべてキャンセルした上で、この重要度設定ルール決定画面90を閉じさせることができる。 Also, the person in charge may close the importance level setting rule determination screen 90 after canceling all the settings performed on the importance level setting rule determination screen 90 by clicking the cancel button 94. be able to.
他方、図23は、後続業務の担当者がかかる重要度設定ルール決定画面90を用いてそのとき登録したバッチ35の重要度設定ルール73を決定した後にホスト装置7に表示される担当者連絡先登録画面100の概略構成を示す。 On the other hand, FIG. 23 shows the contact information of the person in charge displayed on the host apparatus 7 after the person in charge of the succeeding operation decides the importance degree setting rule 73 of the batch 35 registered at that time using the importance degree setting rule determination screen 90 The schematic structure of the registration screen 100 is shown.
この担当者連絡先登録画面100では、かかる担当者が自己のメールアドレスを入力するための担当者連絡先入力テキストボックス101と、OKボタン102及びキャンセルボタン103とが表示される。 In the person-in-charge contact registration screen 100, a person-in-charge contact input text box 101 for the person in charge to input his / her e-mail address, an OK button 102, and a cancel button 103 are displayed.
かくして、かかる担当者は、担当者連絡先入力テキストボックス101に自己のメールアドレスを入力した後、OKボタン102をクリックすることにより、自己のメールアドレスを登録することができる。この場合、アプリケーションサーバ5では、バッチ解析部50の制御のもとに、かかる担当者連絡先入力テキストボックス101に入力されたメールアドレスがそのとき登録されたバッチ35と対応付けて担当者連絡先テーブル62に登録される。 Thus, the person in charge can register his / her e-mail address by clicking the OK button 102 after inputting his / her e-mail address in the person-in-charge contact input text box 101. In this case, in the application server 5, under the control of the batch analysis unit 50, the e-mail address entered in the contact person contact address input text box 101 is associated with the batch 35 registered at that time, and the contact person in charge is contact person. It is registered in the table 62.
また、かかる担当者は、キャンセルボタン103をクリックすることにより、自己のメールアドレスをアプリケーションサーバ5に登録することなく、この担当者連絡先登録画面100を閉じることができる。 Further, by clicking the cancel button 103, the person in charge can close the person-in-charge contact registration screen 100 without registering his / her e-mail address in the application server 5.
(4)本実施の形態によるバッチ管理機能に関連する各種処理
次に、本実施の形態によるバッチ管理機能に関連してアプリケーションサーバ5において実行される各種処理について、「新規バッチの登録時に実行される各種処理」、「通常運行時に実行される各種処理」及び「データ変更が検出された場合に実行される各種処理」に分けて、この順番で説明する。
(4) Various processes related to the batch management function according to the present embodiment Next, as to various processes to be executed in the application server 5 in relation to the batch management function according to the present embodiment These processes will be described in this order, divided into “various processes”, “various processes performed during normal operation”, and “various processes performed when data change is detected”.
なお、以下においては、各種処理の処理主体をプログラム(「〜部」)として説明するが、実際上は、そのプログラムに基づいてアプリケーションサーバ5のCPU30(図1)がその処理を実行する。 In the following, although the processing subject of various types of processing will be described as a program ("~ unit"), in practice, the CPU 30 (Fig. 1) of the application server 5 executes the processing based on the program.
(4−1)新規バッチの登録時に実行される各種処理
(4−1−1)第1の新規バッチ登録処理
図24は、後続業務の担当者の所定操作に応じていずれかのホスト装置(以下、これを対象ホスト装置と呼ぶ)7から新規のバッチ35を登録したい旨の要求(以下、これを新規バッチ登録要求と呼ぶ)がアプリケーションサーバ5に与えられた場合にバッチ解析部50(図7、図8)により実行される第1の新規バッチ登録処理の処理手順を示す。
(4-1) Various types of processing executed at registration of new batch (4-1-1) First new batch registration processing FIG. 24 shows one of the host devices (FIG. 24) according to the predetermined operation of the person in charge of the subsequent business. Hereinafter, when a request to register a new batch 35 (hereinafter, this will be referred to as a new batch registration request) is given to the application server 5 from the target host device 7, the batch analysis unit 50 (see FIG. 7, FIG. 8) shows a processing procedure of the first new batch registration processing.
バッチ解析部50は、かかる新規バッチ登録要求が与えられるとこの図24に示す第1の新規バッチ登録処理を開始し、まず、図21について上述したバッチ登録画面80をその対象ホスト装置7に表示させる(S1)。またバッチ解析部50は、担当者がこのバッチ登録画面80を用いて登録対象のバッチ(以下、これを登録対象バッチと呼ぶ)35の実行条件等の必要な設定が完了するのを待ち受ける(S2)。 The batch analysis unit 50 starts the first new batch registration process shown in FIG. 24 when such a new batch registration request is given, and first displays the batch registration screen 80 described above with reference to FIG. (S1). Further, the batch analysis unit 50 waits for the person in charge to complete necessary settings such as execution conditions of the batch 35 to be registered (hereinafter referred to as a registration target batch) using the batch registration screen 80 (S2) ).
そしてバッチ解析部50は、やがて登録対象バッチ35に対する必要な設定が完了すると、そのときバッチ登録画面80に入力されたその登録対象バッチ35の実行条件をバッチ実行条件管理テーブル64(図13)に格納する(S3)。 When the necessary setting for the registration target batch 35 is eventually completed, the batch analysis unit 50 executes the execution conditions of the registration target batch 35 input to the batch registration screen 80 in the batch execution condition management table 64 (FIG. 13). Store (S3).
続いて、バッチ解析部50は、かかる実行条件を満たすように登録対象バッチ35を実行する空き時間が存在するか否かをバッチスケジュール管理部51(図7、図8)に問い合わせる(S4)。そしてバッチ解析部50は、かかる問合せの結果がバッチスケジュール管理部51から通知されると、通知された問合せ結果に基づいて、かかる登録対象バッチ35を実行する空き時間がある否かを判断する(S5)。 Subsequently, the batch analysis unit 50 inquires of the batch schedule management unit 51 (FIGS. 7 and 8) whether or not there is an idle time for executing the registration target batch 35 so as to satisfy the execution condition (S4). Then, when the batch schedule management unit 51 notifies the batch analysis unit 50 of the result of the inquiry, the batch analysis unit 50 determines whether there is an idle time to execute the registration target batch 35 based on the notified inquiry result ( S5).
バッチ解析部50は、この判断で否定結果を得ると、現在の実行条件ではその登録対象バッチ35を登録できない旨のエラー表示を対象ホスト装置に表示させると共に、ステップS3でバッチ実行条件管理テーブル64に登録したその登録対象バッチ35の実行条件をバッチ実行条件管理テーブル64から削除する(S6)。そしてバッチ解析部50は、この後、この第1の新規バッチ登録処理を終了する。 If the batch analysis unit 50 obtains a negative result in this determination, it causes the target host device to display an error display indicating that the registration target batch 35 can not be registered under the current execution condition, and the batch execution condition management table 64 in step S3. The execution condition of the registration target batch 35 registered in is deleted from the batch execution condition management table 64 (S6). After that, the batch analysis unit 50 ends the first new batch registration process.
これに対して、バッチ解析部50は、ステップS5の判断で肯定結果を得ると、登録対象バッチ35を解析することにより必要な情報を抽出し、抽出した情報を入出力管理テーブル63(図12)及び影響度算出ルール決定テーブル60(図9)にそれぞれ登録する(S7)。 On the other hand, when the batch analysis unit 50 obtains a positive result in the determination of step S5, it analyzes the registration target batch 35 to extract necessary information, and the extracted information is input / output management table 63 (FIG. 12 (FIG. 12). And the influence degree calculation rule determination table 60 (FIG. 9) (S7).
具体的に、バッチ解析部50は、登録対象バッチ35を解析することにより、当該登録対象バッチ35が参照するデータと、処理結果を出力するデータマート41とを検出し、検出結果をその登録対象バッチ35と対応付けて入出力管理テーブル63に登録する。またバッチ解析部50は、その登録対象バッチ35の処理内容(集計処理を含む、最大値の算出処理を含む、又は、ソート処理を含むなど)に基づいて、その登録対象バッチ35に適用すべき影響度算出ルール72を決定し、決定した影響度算出ルール72をその登録対象バッチ35と対応付けて影響度算出ルール決定テーブル60(図9)に登録する。 Specifically, the batch analysis unit 50 analyzes the registration target batch 35 to detect the data referred to by the registration target batch 35 and the data mart 41 outputting the processing result, and the detection result is the registration target It is registered in the input / output management table 63 in association with the batch 35. Further, the batch analysis unit 50 should apply the registration target batch 35 to the registration target batch 35 based on the processing content of the registration target batch 35 (including the aggregation processing, the calculation processing of the maximum value, or the sorting processing). The influence calculation rule 72 is determined, and the determined influence calculation rule 72 is associated with the registration target batch 35 and registered in the influence calculation rule determination table 60 (FIG. 9).
続いて、バッチ解析部50は、図22について上述した重要度設定ルール決定画面90を対象ホスト装置7に表示させる(S8)。またバッチ解析部50は、この後、この重要度設定ルール決定画面90を用いてその登録対象バッチ35に適用すべき重要度設定ルール73が担当者により設定されるのを待ち受ける(S9)。 Subsequently, the batch analysis unit 50 causes the target host device 7 to display the importance level setting rule determination screen 90 described above with reference to FIG. 22 (S8). The batch analysis unit 50 then waits for the importance level setting rule 73 to be applied to the registration target batch 35 to be set by the person in charge using the importance level setting rule determination screen 90 (S9).
そしてバッチ解析部50は、やがてその登録対象バッチ35に適用すべき重要度設定ルールが担当者により設定されると、そのとき設定された重要度設定ルール73をその登録対象バッチ35と対応付けて重要度設定ルール決定テーブル61(図10)に登録する(S10)。 Then, when the importance level setting rule to be applied to the registration target batch 35 is set by the person in charge, the batch analysis unit 50 associates the importance level setting rule 73 set at that time with the registration target batch 35. The importance level setting rule determination table 61 (FIG. 10) is registered (S10).
次いで、バッチ解析部50は、図23について上述した担当者連絡先登録画面100を対象ホスト装置7に表示させる(S11)。またバッチ解析部50は、この後、この担当者連絡先設定画面100を用いてその登録対象バッチ35をアプリケーションサーバ5に登録した後続業務の担当者の連絡先(メールアドレス)が設定されるのを待ち受ける(S12)。 Next, the batch analysis unit 50 causes the target host device 7 to display the person-in-charge contact address registration screen 100 described above with reference to FIG. 23 (S11). Further, after that, the batch analysis unit 50 uses the person-in-charge contact setting screen 100 to set the contact address (e-mail address) of the person-in-charge of the subsequent business who registered the registration target batch 35 in the application server 5. Wait for (S12).
そしてバッチ解析部50は、やがてその登録対象バッチ35を登録した担当者の連絡先が設定されると、そのとき設定された連絡先をその登録対象バッチ35と対応付けて担当者連絡先テーブル62(図11)に登録する(S13)。そしてバッチ解析部50は、この後、この第1の新規バッチ登録処理を終了する。 Then, when the contact address of the person in charge who has registered the registration target batch 35 is set, the batch analysis unit 50 associates the contact address set at that time with the registration target batch 35, and the contact person contact address table 62 (FIG. 11) is registered (S13). After that, the batch analysis unit 50 ends the first new batch registration process.
(4−1−2)第2の新規バッチ登録処理
一方、図25は、図24について上述した第1の新規バッチ登録処理のステップS4においてバッチ解析部50から登録対象バッチ35を実行する空き時間が存在するか否かを問い合わせられたバッチスケジュール管理部51(図7、図8)により実行される第2の新規バッチ登録処理の処理手順を示す。
(4-1-2) Second New Batch Registration Process On the other hand, FIG. 25 shows idle time for executing the registration target batch 35 from the batch analysis unit 50 in step S4 of the first new batch registration process described above with reference to FIG. The process procedure of the 2nd new batch registration process performed by the batch schedule management part 51 (FIG. 7, FIG. 8) inquired whether or not exists is shown.
バッチスケジュール管理部51は、かかる問合せがバッチ解析部50から与えられるとこの図25に示す第2の新規バッチ登録処理を開始し、まず、かかる問合せに含まれる登録対象バッチ35のバッチ名を取得する(S20)。 The batch schedule management unit 51 starts the second new batch registration process shown in FIG. 25 when such a query is given from the batch analysis unit 50, and first obtains the batch name of the registration target batch 35 included in the query. To do (S20).
続いて、バッチスケジュール管理部51は、ステップS20で取得したバッチ名をキーワードとしてバッチ実行条件管理テーブル64(図13)を検索することによりその登録対象バッチ35の実行条件を取得する(S21)。またバッチスケジュール管理部51は、この後、バッチ実行スケジュールテーブル65(図14)を参照して、その登録対象バッチ35の実行条件を満たす空き時間を探索する(S22)。 Subsequently, the batch schedule management unit 51 acquires the execution condition of the registration target batch 35 by searching the batch execution condition management table 64 (FIG. 13) using the batch name acquired in step S20 as a keyword (S21). Further, after that, the batch schedule management unit 51 refers to the batch execution schedule table 65 (FIG. 14) to search for free time that satisfies the execution condition of the registration target batch 35 (S22).
次いで、バッチスケジュール管理部51は、ステップS22の探索により登録対象バッチ35の実行条件を満たす空き時間を検出できたか否かを判断する(S23)。そしてバッチスケジュール管理部51は、この判断で否定結果を得ると、その登録対象バッチ35をバッチ実行スケジュールに登録できない旨を問合せ結果としてバッチ解析部50に通知し(S24)、この後、この第2の新規バッチ登録処理を終了する。 Next, the batch schedule management unit 51 determines whether a vacant time satisfying the execution condition of the registration target batch 35 has been detected by the search of step S22 (S23). When the batch schedule management unit 51 obtains a negative result in this determination, it notifies the batch analysis unit 50 that the registration target batch 35 can not be registered in the batch execution schedule as a query result (S24), and thereafter, End the new batch registration process of 2.
これに対して、バッチスケジュール管理部51は、ステップS23の判断で肯定結果を得ると、その登録対象バッチ35をバッチ実行スケジュールに登録できる旨をバッチ解析部50に通知する。またバッチスケジュール管理部51は、その登録対象バッチ35の開始時刻等を決定して当該登録対象バッチ35の実行スケジュールをバッチ実行スケジュールに組み込むようバッチ実行スケジュールテーブル65を更新(つまり登録対象バッチ35の実行スケジュールをバッチ実行スケジュールテーブル65に登録)する(S25)。そしてバッチスケジュール管理部51は、この後、この第2の新規バッチ登録処理を終了する。 On the other hand, when the batch schedule management unit 51 obtains a positive result in the determination of step S23, it notifies the batch analysis unit 50 that the registration target batch 35 can be registered in the batch execution schedule. Further, the batch schedule management unit 51 updates the batch execution schedule table 65 to determine the start time and the like of the registration target batch 35 and incorporate the execution schedule of the registration target batch 35 into the batch execution schedule (that is, the registration target batch 35 The execution schedule is registered in the batch execution schedule table 65) (S25). Then, the batch schedule management unit 51 ends this second new batch registration process.
(4−2)通常運行時に実行される各種処理
(4−2−1)通常運行処理
図26は、アプリケーションサーバ5の通常運行時にバッチ制御部56(図7、図8)により実行される通常運行処理の処理手順を示す。バッチ制御部56は、アプリケーションサーバ5が起動されるとこの通常運行処理を開始し、まず、バッチ実行スケジュールテーブル65(図14)を参照して(S30)、現在時刻に開始すべきバッチ35が存在するか否かを判断する(S31)。
(4-2) Various processing executed during normal operation (4-2-1) Normal operation processing FIG. 26 shows the normal operation executed by the batch control unit 56 (FIG. 7, FIG. 8) during normal operation of the application server 5. The processing procedure of operation processing is shown. When the application server 5 is started, the batch control unit 56 starts this normal operation processing, and first, referring to the batch execution schedule table 65 (FIG. 14) (S30), the batch 35 to be started at the current time is It is determined whether it exists (S31).
バッチ制御部56は、この判断で否定結果を得るとステップS30に戻り、この後、ステップS31で肯定結果を得るまでステップS30−ステップS31−ステップS30のループを繰り返す。 If the batch control unit 56 obtains a negative result in this determination, the process returns to step S30, and thereafter repeats the loop of step S30-step S31-step S30 until a positive result is obtained in step S31.
そしてバッチ制御部56は、やがて現在時刻に実行すべきバッチ35をバッチ実行スケジュールテーブル65上で検出することによりステップS31で肯定結果を得ると、そのバッチ35が参照すべきデータ(販売データ14又はデータマート41のレコードのデータ)の前回実行時からの差分データをデータベースサーバ6(図1)から取得する。またバッチ制御部56は、取得した差分データを入力としてそのバッチ35を実行し、実行結果を対応するデータマート41に格納する(S32)。 Then, when the batch control unit 56 obtains a positive result in step S31 by detecting the batch 35 to be executed at the current time on the batch execution schedule table 65, the data to be referred to by the batch 35 (sales data 14 or The difference data from the previous execution time of the data of the record of the data mart 41 is acquired from the database server 6 (FIG. 1). Further, the batch control unit 56 executes the batch 35 with the acquired difference data as an input, and stores the execution result in the corresponding data mart 41 (S32).
さらにバッチ制御部56は、バッチスケジュール管理部51にそのバッチ35の実行が完了した旨を通知し、そのバッチ35の次回の実行スケジュールをバッチ実行スケジュールテーブル65に登録させる(S33)。そしてバッチ制御部56は、ステップS30に戻り、この後、ステップS30以降の処理を繰り返す。 Further, the batch control unit 56 notifies the batch schedule management unit 51 that the execution of the batch 35 is completed, and registers the next execution schedule of the batch 35 in the batch execution schedule table 65 (S33). Then, the batch control unit 56 returns to step S30, and thereafter repeats the processing after step S30.
(4−2−2)重要度管理テーブル更新処理
図27は、通常運行時に、図26について上述した通常運行処理と並行して重要度設定部53(図7、図8)により実行される重要度管理テーブル更新処理の処理手順を示す。
(4-2-2) Importance Management Table Update Processing FIG. 27 shows the importance executed by the importance setting unit 53 (FIG. 7, FIG. 8) in parallel with the normal operation processing described above with reference to FIG. The processing procedure of degree management table update processing is shown.
重要度設定部53は、アプリケーションサーバ5が起動されるとこの図27に示す重要度設定処理を開始し、まず、重要度設定ルール決定テーブル61(図10)を参照して、アプリケーションサーバ5に登録されている各バッチ35に対してそれぞれ設定された各重要度設定ルールの起動条件をそれぞれ確認する(S40)。 The importance degree setting unit 53 starts the importance degree setting process shown in FIG. 27 when the application server 5 is started, and first, the importance degree setting rule determination table 61 (FIG. 10) is referred to. The activation conditions of the respective importance setting rules set respectively for the registered batches 35 are confirmed (S40).
続いて、重要度設定部は53、ステップS40の確認結果に基づいて、現在時刻において起動条件を満たす重要度設定ルールが存在するか否かを判断する(S41)。そして重要度設定部53は、ステップS41の判断で否定結果を得るとステップS40に戻り、この後、ステップS40−ステップS41−ステップS40のループを繰り返す。 Subsequently, the importance level setting unit 53 determines, on the basis of the check result in step S40, whether or not there is an importance level setting rule that satisfies the activation condition at the current time (S41). When the importance degree setting unit 53 obtains a negative result in the determination of step S41, the process returns to step S40, and thereafter repeats the loop of step S40-step S41-step S40.
また重要度設定部53は、やがていずれかの重要度設定ルールの起動条件が満たされることによりステップS41で肯定結果を得ると、その重要度設定ルールに従って対応するバッチ35の処理結果が格納されるデータマート(以下、これを対象データマートと呼ぶ)41の各レコードの重要度をそれぞれ算出し、算出結果に従って重要度管理テーブル71(図19)を更新する(S42)。 When the importance setting unit 53 obtains an affirmative result in step S41 due to the fact that the activation condition of any of the importance setting rules is eventually satisfied, the processing result of the corresponding batch 35 is stored according to the importance setting rule. The importance of each record of the data mart (hereinafter referred to as target data mart) 41 is calculated, and the importance management table 71 (FIG. 19) is updated according to the calculation result (S42).
例えば、起動条件を満たした重要度設定ルールが上述の第1の重要度設定ルールであった場合、重要度設定部53は、そのときのマート参照履歴管理テーブル69(図18)に基づいて参照頻度管理テーブル70(図19)を更新する。また重要度設定部53は、更新した参照頻度管理テーブル70に基づいて、対象データマート41ごとに、それぞれ参照回数が多い上位20%の各レコードのデータの重要度を「A」、参照回数が上位20〜40%の各レコードのデータの重要度を「B」、参照回数が上位40〜60%の各レコードのデータの重要度を「C」、参照回数が上位60〜100%の各レコードのデータの重要度を「D」とするように重要度管理テーブル71(図20)を更新する(S43)。 For example, if the importance level setting rule satisfying the start condition is the first importance level setting rule described above, the importance level setting unit 53 refers to the mart reference history management table 69 (FIG. 18) at that time. The frequency management table 70 (FIG. 19) is updated. Further, the importance setting unit 53 sets the importance of the data of each of the top 20% records having a large number of references to “A” for each target data mart 41 based on the updated reference frequency management table 70. The importance of data in the top 20 to 40% records is "B", the importance of data on each top 40 to 60% records is "C", and the number of references is top 60 to 100% The importance degree management table 71 (FIG. 20) is updated so that the importance degree of the data in (4) is "D" (S43).
また起動条件を満たした重要度設定ルールが上述の第2の重要度設定ルールであった場合、重要度設定部53は、対象データマート41(例えば図3(E)に示すものであるとする)をコピーした図28に示すような算出用テーブル111を作成した後、各レコードの対象値(売上欄111Cに格納された数値)の平均値を算出する。また重要度設定部53は、算出した平均値を利用して、レコードごとにそのレコードの対象値と、平均値との差分の絶対値をそのレコードの偏差欄111Dに格納する。 If the importance level setting rule satisfying the start condition is the second importance level setting rule described above, the importance level setting unit 53 determines that the target data mart 41 (for example, one shown in FIG. 3E). After creating the calculation table 111 as shown in FIG. 28 obtained by copying B), an average value of target values (numerical values stored in the sales column 111C) of each record is calculated. Further, the importance setting unit 53 stores the absolute value of the difference between the target value of the record and the average value for each record in the deviation column 111D of the record using the calculated average value.
そして重要度設定部53は、上述のようにして求めたレコードごとの偏差に基づいて、偏差が大きい上位20%のレコードの重要度を「A」、上位20〜40%のレコードの重要度を「B」、上位40〜60%のレコードの重要度を「C」、上位60〜80%のレコード重要度を「D」とするように重要度管理テーブル71を更新する。 Then, based on the deviation for each record obtained as described above, the importance degree setting unit 53 sets the importance degree of the top 20% records with large deviation to “A”, and the importance degree of the top 20 to 40% records. The importance management table 71 is updated so that “B”, the top 40 to 60% of the record importance is “C”, and the top 60 to 80% of the record importance is “D”.
次いで、重要度設定部53は、上述のようにして更新した重要度管理テーブル71の各レコードを設定日時欄71Fに格納された設定日時の新しい順にソートし、下位x%の重要度を1つ下の重要度にそれぞれ再設定する。なお「x」は予め設定された値である。従って、対象となったレコードは、例えば、それまでの重要度が「A」であれば「B」に、「B」であれば「C」に、「C」であれば「D」に再設定されることになる。 Next, the importance level setting unit 53 sorts the records of the importance level management table 71 updated as described above in the descending order of the setting date and time stored in the setting date and time column 71F, and one lower x% importance level Reset each to the lower importance. Note that "x" is a preset value. Therefore, for example, the target record is re-selected as "B" if the previous importance is "A", "C" if "B", and "D" if "C". It will be set.
そして重要度設定部53は、この後、この重要度設定処理を終了する。 Then, the importance setting unit 53 ends the importance setting processing.
(4−2−3)変更検出処理
図29は、通常運行時に変更検出部54(図7、図8)により実行される変更検出処理の処理手順を示す。変更検出部54は、アプリケーションサーバ5が起動されるとこの図29に示す重要度設定処理を開始し、まず、データベースサーバ6(図1)のデータベース40(図1)に登録された販売データ14と、各データマート41の各レコードのデータとについて、そのデータの変更の有無を当該データへのアクセスログ等に基づいて順番に確認する(S50)。
(4-2-3) Change Detection Processing FIG. 29 shows a processing procedure of change detection processing executed by the change detection unit 54 (FIGS. 7 and 8) during normal operation. When the application server 5 is activated, the change detection unit 54 starts the importance level setting process shown in FIG. 29, and first, the sales data 14 registered in the database 40 (FIG. 1) of the database server 6 (FIG. 1). With respect to the data of each record of each data mart 41, the presence or absence of the change of the data is sequentially confirmed based on the access log or the like to the data (S50).
続いて、変更検出部54は、ステップS50の確認結果に基づいて、いずれかのデータが変更されたか否かを判断する(S51)。そして変更検出部54は、この判断で否定結果を得るとステップS50に戻り、この後、ステップS50−ステップS51−ステップS50のループを繰り返す。 Subsequently, the change detection unit 54 determines whether or not any data has been changed based on the confirmation result of step S50 (S51). When the change detection unit 54 obtains a negative result in this determination, the process returns to step S50, and thereafter repeats the loop of step S50-step S51-step S50.
また変更検出部54は、やがていずれかのデータが変更されることによりステップS51で肯定結果を得ると、変更されたデータを指定して、そのデータが変更された旨の通知(以下、これを変更検出通知と呼ぶ)をバッチ制御部56(図7、図8)に送信する(S52)。なお、この変更検出通知には、そのデータの変更内容を表す情報も含まれる。そして変更検出部54は、ステップS50に戻り、この後、ステップS50以降の処理を繰り返す。 In addition, when the change detection unit 54 obtains an affirmative result in step S51 due to any data being changed in advance, a notification indicating that the data has been changed is designated (hereinafter referred to as “changed data”). The notification of change detection is sent to the batch control unit 56 (FIG. 7, FIG. 8) (S52). The change detection notification also includes information representing the change content of the data. Then, the change detection unit 54 returns to step S50, and thereafter repeats the processing after step S50.
(4−3)データ変更が検出された場合に実行される各種処理
(4−3−1)バッチ再実行判定処理
一方、図30は、上述の変更検出通知がバッチ制御部56に与えられた場合に当該バッチ制御部56により実行されるバッチ再実行判定処理の処理手順を示す。バッチ制御部56は、変更検出部からかかる変更検出通知が与えられるとこの図30に示すバッチ再実行判定処理を開始し、まず、入出力管理テーブル63(図12)を参照して、変更されたデータを参照するすべてのバッチ35と、これらバッチ35がそれぞれ処理結果を格納するすべてのデータマート41のレコードとを特定する(S60)。
(4-3) Various processing executed when data change is detected (4-3-1) Batch reexecution determination processing On the other hand, in FIG. 30, the above-mentioned change detection notification is given to the batch control unit 56. The processing procedure of the batch re-execution determination processing executed by the batch control unit 56 will be described. When the change detection unit receives the change detection notification from the change detection unit, the batch control unit 56 starts the batch re-execution determination process shown in FIG. 30, and first changes are made with reference to the input / output management table 63 (FIG. 12). All the batches 35 which refer to the data and the records of all the data marts 41 in which the batches 35 respectively store the processing results are specified (S60).
続いて、バッチ制御部56は、ステップS60で特定した各バッチ35の中から1つのバッチ35を選択し(S61)、選択したバッチ(以下、これを選択バッチと呼ぶ)35を再実行する空き時間が存在するか否かをバッチスケジュール管理部51に問い合わせると共に(S62)、かかるデータの変更が後続業務に与える影響度の算出を要求する影響度算出要求を影響度算出部55(図7、図8)に送信する(S63)。なお、この影響度算出要求には、変更されたデータの変更内容と、ステップS60で特定した選択バッチ35の情報とが含まれる。 Subsequently, the batch control unit 56 selects one batch 35 from each of the batches 35 specified in step S60 (S61), and frees the selected batch (hereinafter referred to as a selected batch) 35 to be re-executed. While inquiring of the batch schedule management unit 51 whether or not time exists (S62), the influence calculation request for requesting the calculation of the influence of the change of the data on the subsequent business is the influence calculation unit 55 (FIG. 7, FIG. FIG. 8) is sent (S63). The influence calculation request includes the change content of the changed data and the information of the selected batch 35 identified in step S60.
次いで、バッチ制御部56は、かかる影響度算出要求に対する影響度算出部55からの回答(つまりステップS60で特定したデータマート41のレコードごとの影響度)を受領するのを待ち受け(S64)、やがてかかる回答を受領すると、ステップS60で特定した各データマート41のうち、選択バッチ35が処理結果を登録するデータマート41のレコードの重要度を重要度管理テーブル71(図20)からそれぞれ取得する(S65)。なお、このときバッチ制御部56は、当該データマート41のレコードのデータのうち、重要度管理テーブル71において重要度が設定されていないデータについては、重要度を「E」に設定する。 Next, the batch control unit 56 waits for receipt of the response from the impact degree calculation unit 55 to the impact degree calculation request (that is, the impact degree of each record of the data mart 41 identified in step S60) (S64). When such an answer is received, the importance of the record of the data mart 41 in which the selected batch 35 registers the processing result among the data mart 41 specified in step S60 is acquired from the importance degree management table 71 (FIG. 20). S65). At this time, the batch control unit 56 sets the importance to “E” for the data of which the importance is not set in the importance management table 71 among the data of the record of the data mart 41.
さらにバッチ制御部56は、ステップS63の影響度算出要求に応じて影響度算出部55により算出された影響度と、ステップS65で取得した該当するデータマート41のレコードごとの重要度とに基づいて、選択バッチ35を再実行する必要があるか否かを判断する(S66)。この判断は、影響度が許容範囲を超えるレコードが存在するか否かを判断することにより行われる。 Furthermore, the batch control unit 56 determines the degree of importance calculated for the corresponding data mart 41 obtained in step S65 and the degree of importance for each record of the corresponding data mart 41 acquired in step S65. It is determined whether it is necessary to re-execute the selection batch 35 (S66). This determination is made by determining whether there is a record whose influence exceeds the allowable range.
そしてバッチ制御部56は、この判断で肯定結果を得ると、選択バッチ35を再実行すべき旨をバッチスケジュール管理部51に通知する(S68)。またバッチ制御部56は、反映通知部57にも選択バッチ35を再実行する旨を通知し(S69)、この後、ステップS72に進む。かくして、この通知を受信した反映通知部57は、選択バッチ35を登録した担当者の連絡先を担当者連絡先テーブル62(図11)から取得し、その連絡先に選択バッチ35を再実行する旨を通知する。 When the batch control unit 56 obtains a positive result in this determination, it notifies the batch schedule management unit 51 that the selected batch 35 should be re-executed (S68). The batch control unit 56 also notifies the reflection notifying unit 57 that the selected batch 35 is to be re-executed (S69), and then the process proceeds to step S72. Thus, the reflection notification unit 57 that receives this notification acquires the contact of the person in charge who has registered the selected batch 35 from the person-in-charge contact table 62 (FIG. 11), and re-executes the selected batch 35 for that contact. Notify that.
これに対して、バッチ制御部56は、ステップS66の判断で否定結果を得ると、ステップS62の問合せに対するバッチスケジュール管理部51からの回答に基づいて、選択バッチ35を再実行したとしても、アプリケーションサーバ5に登録された他のすべてのバッチ35がその実行条件で定められた完了期限に間に合うか否かを判断する(S67)。なお、ステップS62の問合せに対するバッチスケジュール管理部51からの回答の内容については、後述する(図31のステップS90)。 On the other hand, if the batch control unit 56 obtains a negative result in the determination of step S66, the application is executed even if the selected batch 35 is re-executed based on the answer from the batch schedule management unit 51 to the inquiry of step S62. It is determined whether all the other batches 35 registered in the server 5 are in time for the completion deadline defined by the execution condition (S67). The contents of the response from the batch schedule management unit 51 to the inquiry in step S62 will be described later (step S90 in FIG. 31).
そしてバッチ制御部56は、この判断で肯定結果を得るとステップS68に進み、この後、ステップS68及びステップS69を上述と同様に処理した後、ステップS72に進む。 When the batch control unit 56 obtains a positive result in this determination, the process proceeds to step S68, and thereafter processes step S68 and step S69 in the same manner as described above, and then proceeds to step S72.
これに対して、バッチ制御部56は、ステップS67の判断で否定結果を得ると、選択バッチ35の再実行を行わず、選択バッチ35の次回の実行時にかかるデータの変更を対応するデータマート41に反映させる旨の決定を行い(S70)、その旨をバッチスケジュール管理部51に通知する(S71)。 On the other hand, when the batch control unit 56 obtains a negative result in the determination of step S67, it does not re-execute the selected batch 35, and the data mart 41 corresponds to the change of the data at the next execution of the selected batch 35. (S70), and notifies the batch schedule management unit 51 to that effect (S71).
この後、バッチ制御部56は、ステップS60で特定したすべてのバッチ35について、ステップS61以降の処理を実行し終えたか否かを判断する(S72)。そしてバッチ制御部56は、この判断で否定結果を得るとステップS61に戻り、この後、ステップS61で選択するバッチ35を未処理の他のバッチ35に順次切り替えながら、ステップS61以降の処理を繰り返す。 Thereafter, the batch control unit 56 determines whether or not the processing after step S61 has been completed for all the batches 35 identified in step S60 (S72). Then, when the batch control unit 56 obtains a negative result in this determination, the process returns to step S61, and thereafter repeats the processing after step S61 while sequentially switching the batch 35 selected in step S61 to another unprocessed batch 35. .
そしてバッチ制御部56は、やがてステップS60で特定したすべてのバッチ35についてステップS61以降の処理を実行し終えることによりステップS72で肯定結果を得ると、このバッチ再実行判定処理を終了する。 When the batch control unit 56 obtains an affirmative result in step S72 by completing the processing in step S61 and subsequent steps on all the batches 35 identified in step S60, the batch re-execution determination processing ends.
なお、バッチ35が再実行された場合、既にそのバッチ35の処理が完了してその処理結果が対応するデータマート41に登録されているときには、当該バッチ35の再実行に伴ってそのデータマート41に格納されているそのバッチ35の処理結果も更新されることになる。そして、この場合には、このデータマート41のデータの変更が変更検出部54により検出されるため、この処理結果を参照して処理を実行するそのバッチ35の後続バッチ35についても同様のバッチ再実行判定処理が実行される。 When the batch 35 is re-executed, if the processing of the batch 35 is already completed and the processing result is registered in the corresponding data mart 41, the data mart 41 is executed along with the re-execution of the batch 35. The processing result of the batch 35 stored in is also updated. And in this case, since the change of data of this data mart 41 is detected by the change detection unit 54, the same batch re-execution is carried out also for the subsequent batch 35 of the batch 35 which executes the process with reference to the processing result. Execution determination processing is executed.
このようにあるバッチ35について再実行が決定された場合、そのバッチ35の既に処理が完了した各後続バッチ35については、直前の後続バッチ35について再実行しない旨の決定がなされるまでバッチ再実行判定処理がそれぞれ実行されることとなる。 Thus, if it is determined that a rerun is performed for a certain batch 35, the batch rerun is performed for each subsequent batch 35 for which processing of the batch 35 has already been completed, until it is determined that rerun is not performed for the immediately subsequent batch 35. The determination process is to be executed.
(4−3−2)空き時間探索処理
他方、図31は、図30について上述したバッチ再実行判定処理のステップS62において、当該バッチ再実行判定処理のステップS61で選択されたバッチ35(選択バッチ35)を再実行する空き時間が存在するか否かを問い合わせられたバッチスケジュール管理部51(図7、図8)により実行される空き時間探索処理の処理手順を示す。
(4-3-2) Free time search process On the other hand, FIG. 31 shows the batch 35 (selected batch selected in step S61 of the batch reexecution determination process in step S62 of the batch reexecution determination process described above with reference to FIG. The processing procedure of the idle time search process executed by the batch schedule management unit 51 (FIG. 7, FIG. 8) inquired whether there is an idle time for re-executing 35) is shown.
バッチスケジュール管理部51は、かかる問合せが与えられると、この空き時間探索処理を開始し、まず、この問合せに含まれる選択バッチ35のバッチ名を取得する(S80)。またバッチスケジュール管理部51は、選択バッチ35の実行条件をバッチ実行条件管理テーブル64(図13)から取得する(S81)。 When the query is given, the batch schedule management unit 51 starts this free time search process, and first acquires the batch name of the selected batch 35 included in the query (S80). Further, the batch schedule management unit 51 acquires the execution condition of the selected batch 35 from the batch execution condition management table 64 (FIG. 13) (S81).
続いて、バッチスケジュール管理部51は、バッチ実行スケジュールテーブル65(図14)を参照して、ステップS81で取得した実行条件を満たす空き時間を探索し(S82)、そのような空き時間を検出できたか否かを判断する(S83)。 Subsequently, the batch schedule management unit 51 refers to the batch execution schedule table 65 (FIG. 14) to search for free time that satisfies the execution condition acquired in step S81 (S82), and can detect such free time. It is determined whether or not it is (S83).
そしてバッチスケジュール管理部51は、この判断で肯定結果を得ると、その空き時間にその選択バッチ35を再実行するよう選択バッチ35の開始タイミングをバッチ実行スケジュールテーブル65に追加する(S89)。またバッチスケジュール管理部51は、選択バッチ35を再実行したとしても、すべてのバッチ35をその実行条件で定められた完了期限までに完了できる旨の回答をバッチ制御部56に送信した後(S90)、この空き時間探索処理を終了する。 When the batch schedule management unit 51 obtains a positive result in this determination, it adds the start timing of the selected batch 35 to the batch execution schedule table 65 so as to re-execute the selected batch 35 in the idle time (S89). In addition, even if the batch schedule management unit 51 transmits to the batch control unit 56 a response to the effect that all the batches 35 can be completed by the completion deadline determined by the execution condition even if the selected batch 35 is re-executed (S90 ), End this free time search process.
これに対して、バッチスケジュール管理部51は、ステップS83の判断で否定結果を得ると、バッチ優先順位管理テーブル66(図15)を参照して、そのときバッチ実行スケジュールテーブル65に実行スケジュールが登録されているバッチ35のうち、優先順位が最も低いバッチ35を特定する(S84)。 On the other hand, when the batch schedule management unit 51 obtains a negative result in the determination of step S83, it refers to the batch priority management table 66 (FIG. 15) and registers the execution schedule in the batch execution schedule table 65 at that time. Among the batches 35 being processed, the batch 35 having the lowest priority is identified (S84).
次いで、バッチスケジュール管理部51は、ステップS84で特定したバッチ35の実行時間を当該バッチ35の実行条件の範囲内において遅延させることにより、選択バッチ35を再実行するための空き時間を捻出できるか否かを判断する(S85)。この際、バッチスケジュール管理部51は、選択バッチ35に後続バッチ35が存在する場合には、その後続バッチ35の実行条件をも考慮して、選択バッチ35を再実行するための空き時間を捻出できるか否かを判断する。 Next, whether the batch schedule management unit 51 can unlead a vacant time for re-executing the selected batch 35 by delaying the execution time of the batch 35 specified in step S84 within the range of the execution condition of the batch 35 It is determined whether or not it is (S85). At this time, if there is a subsequent batch 35 in the selected batch 35, the batch schedule management unit 51 determines an idle time for re-executing the selected batch 35, also taking into consideration the execution conditions of the subsequent batch 35. Determine if you can.
そしてバッチスケジュール管理部51は、この判断で肯定結果を得るとステップS89に進み、このステップS89を上述のように処理した後に、選択バッチ35を再実行したとしても、すべてのバッチ35をその実行条件で定められた完了期限までに完了できる旨の回答をバッチ制御部56に送信する(S90)。そしてバッチスケジュール管理部51は、この後、この空き時間探索処理を終了する。 When the batch schedule management unit 51 obtains a positive result in this determination, the process proceeds to step S89, and after processing step S89 as described above, all batches 35 are executed even if the selected batch 35 is re-executed. A response to the effect that the completion can be completed by the completion deadline determined by the conditions is transmitted to the batch control unit 56 (S90). Then, the batch schedule management unit 51 ends this free time search process.
これに対して、バッチスケジュール管理部51は、ステップS85の判断で否定結果を得ると、バッチ実行スケジュールテーブル65に実行スケジュールが登録されたすべてのバッチ35についてステップS85の処理を実行し終えたか否かを判断する(S86)。 On the other hand, when the batch schedule management unit 51 obtains a negative result in the determination of step S85, whether or not the process of step S85 has been executed for all batches 35 for which the execution schedule is registered in the batch execution schedule table 65. It is determined (S86).
そしてバッチスケジュール管理部51は、この判断で否定結果を得ると、バッチ優先順位管理テーブル66を参照して、ステップS84で特定したバッチ35よりも優先順位が1つ高いバッチ35を選択した後(S87)、ステップS85に戻り、この後、ステップS85又はステップS86で肯定結果を得るまでステップS85〜ステップS87の処理を繰り返す。 Then, if the batch schedule management unit 51 obtains a negative result in this determination, it selects a batch 35 whose priority is higher by one than the batch 35 identified in step S 84 with reference to the batch priority management table 66 ( S87), returns to step S85, and thereafter repeats the processing of step S85 to step S87 until an affirmative result is obtained in step S85 or step S86.
そしてバッチスケジュール管理部51は、やがてバッチ実行スケジュールテーブル65に実行スケジュールが登録されたすべてのバッチ35についてステップS85の処理を実行し終えることによりステップS86で肯定結果を得た場合には、そのときバッチ実行スケジュールテーブル65に実行スケジュールが登録されているバッチ35のうち、優先順位が最も低いバッチ35の実行時間をそのバッチ35の実行条件を考慮せずに遅延させることにより選択バッチ35を実行するための空き時間を捻出する(S88)。 Then, if the batch schedule management unit 51 obtains an affirmative result in step S86 by completing the processing of step S85 for all the batches 35 for which the execution schedule is registered in the batch execution schedule table 65 in the end, The selected batch 35 is executed by delaying the execution time of the batch 35 having the lowest priority among the batches 35 for which the execution schedule is registered in the batch execution schedule table 65 without considering the execution conditions of the batch 35. Unoccupied the free time for (S88).
そしてバッチスケジュール管理部51は、この後、ステップS89に進み、このステップS89を上述のように処理した後に、1つ以上のバッチ35の完了時刻をその実行条件で定められた完了期限よりも遅らせることにより選択バッチ35を実行できる旨の回答をバッチ制御部56に送信する(S90)。そしてバッチスケジュール管理部51は、この後、この空き時間探索処理を終了する。 After that, the batch schedule management unit 51 proceeds to step S89, and after processing step S89 as described above, delays the completion time of one or more batches 35 more than the completion time limit defined by the execution condition. Thus, the response to the effect that the selected batch 35 can be executed is sent to the batch control unit 56 (S90). Then, the batch schedule management unit 51 ends this free time search process.
なおバッチスケジュール管理部51は、この後、図30について上述したバッチ再実行処理のステップS71の通知を受信した場合には、ステップS89でバッチ実行スケジュールテーブル65に登録した選択バッチ35の再実行の実行タイミングをバッチ実行スケジュールテーブル65から削除すると共にバッチ実行スケジュールテーブル65をステップS89の更新前の状態に戻す。 When the batch schedule management unit 51 receives the notification of step S71 of the batch re-execution process described above with reference to FIG. 30, the batch schedule management unit 51 re-executes the selected batch 35 registered in the batch execution schedule table 65 in step S89. The execution timing is deleted from the batch execution schedule table 65, and the batch execution schedule table 65 is returned to the state before the update in step S89.
(4−3−3)影響度算出処理
他方、図32は、図30について上述したバッチ再実行判定処理のステップS63において、バッチ制御部56から上述の影響度算出要求が与えられた影響度算出部55(図7、図8)により実行される影響度算出処理の処理手順を示す。
(4-3-3) Influence calculation process On the other hand, FIG. 32 shows the influence calculation to which the above-mentioned influence calculation request is given from the batch control unit 56 in step S63 of the batch reexecution judgment process described above with reference to FIG. The processing procedure of the influence degree calculation process performed by the part 55 (FIG. 7, FIG. 8) is shown.
影響度算出部55は、かかる影響度算出要求がバッチ制御部56から与えられるとこの影響度算出処理を開始し、まず、影響度算出ルール決定テーブル60(図9)を参照して、影響度算出要求において指定された選択バッチ35に適用すべき影響度算出ルールを特定する(S100)。 The influence degree calculation unit 55 starts the influence degree calculation processing when the influence degree calculation request is given from the batch control unit 56, and firstly, the influence degree calculation unit 60 refers to the influence degree calculation rule determination table 60 (FIG. 9). An influence degree calculation rule to be applied to the selected batch 35 specified in the calculation request is specified (S100).
続いて、影響度算出部55は、ステップS100で特定した影響度算出ルールに従って、影響度算出要求に含まれるデータの変更が後続業務に与える影響度を算出する(S101)。なお、この影響度の算出手法は、図4〜図6について上述した通りであるため、ここでの再度の説明は省略する。 Subsequently, the influence degree calculation unit 55 calculates the influence degree that the change of the data included in the influence degree calculation request has on the subsequent work according to the influence degree calculation rule specified in step S100 (S101). In addition, since the calculation method of this influence degree is as having mentioned above about FIGS. 4-6, the description for the second time here is abbreviate | omitted.
そして影響度算出部55は、この後、算出した影響度をバッチ制御部56に通知し(S102)、この後、この影響度算出処理を終了する。 Then, the influence degree calculation unit 55 notifies the batch control unit 56 of the calculated influence degree (S102), and thereafter ends the influence degree calculation processing.
(5)本実施の形態の効果
以上のように本実施の形態の店舗管理システム1では、バッチ35の処理開始後にそのバッチ35が参照する元データ(販売データ14やデータマート41のデータ)が変更された場合に、アプリケーションサーバ5が、その変更の後続業務への影響度を算出し、算出した影響度が許容範囲内であるか否かを該当するデータマート41のレコードごとにそれぞれ判定し、影響度が許容範囲を超えているレコードがある場合にのみそのバッチ35を再実行する。
(5) Effects of the Present Embodiment As described above, in the store management system 1 of the present embodiment, the original data (data of the sales data 14 and the data mart 41) to which the batch 35 refers after the processing of the batch 35 starts. When the change is made, the application server 5 calculates the degree of influence of the change on the subsequent business, and determines whether or not the calculated degree of influence falls within the allowable range for each record of the corresponding data mart 41. , Re-execute the batch 35 only when there is a record whose influence exceeds the allowable range.
従って、本店舗管理システム1によれば、元データが変更された場合、その変更が後続業務に与える影響が大きい場合にのみ対応するバッチ35が再実行され、その変更が後続業務に与える影響が小さい場合にはそのバッチ35が再実行されないため、バッチの再実行に起因して後続業務の開始時刻までにバッチ処理が完了しないといった事態の発生を極力抑制でき、後続業務の遂行を信頼性高く支援することができる。 Therefore, according to the present store management system 1, when the original data is changed, the corresponding batch 35 is re-executed only when the change has a large influence on the subsequent business, and the change has an influence on the subsequent business. If the size is small, the batch 35 is not re-executed, so occurrence of a situation where batch processing is not completed by the start time of the subsequent work due to the re-execution of the batch can be suppressed as much as possible, and the execution of the subsequent work is highly reliable. Can help.
(6)他の実施の形態
なお上述の実施の形態においては、本発明を図1のように構成された店舗管理システム1に適用するようにした場合について述べたが、本発明はこれに限らず、この他種々の構成の情報処理システムに広く適用することができる。
(6) Other Embodiments In the above embodiment, the present invention is applied to the store management system 1 configured as shown in FIG. 1, but the present invention is limited to this. However, the present invention can be widely applied to information processing systems of various other configurations.
また上述の実施の形態においては、本部システム8をウェブサーバ4、アプリケーションサーバ5及びデータベースサーバ6により構成するようにした場合について述べたが、本発明はこれに限らず、本部システム8を1つのサーバ装置により構成するようにしてもよい。また上述の実施の形態においては、ネットワーク9Aをインターネット等により構成し、ネットワーク9Bを社内LAN等により構成するようにした場合について述べたが、本発明はこれに限らず、これらネットワーク9A,9BをWAN(Wide Area Network)や、専用回線又は無線通信回線等により構成するようにしてもよく、ネットワーク9A,9Bの構成としてはこの他種々の構成を広く適用することができる。 In the above embodiment, although the case where the head office system 8 is configured by the web server 4, the application server 5, and the database server 6 has been described, the present invention is not limited to this. You may make it comprise with a server apparatus. In the above embodiment, the network 9A is configured by the Internet or the like, and the network 9B is configured by the in-house LAN or the like. However, the present invention is not limited thereto, and the networks 9A and 9B can be configured. A wide area network (WAN), a dedicated line, a wireless communication line, or the like may be used, and various other configurations can be widely applied as the configuration of the networks 9A and 9B.
さらに上述の実施の形態においては、データの変更を対応するデータマートに反映させる方法として、対応するバッチ35を再実行するようにした場合について述べたが、本発明はこれに限らず、例えば、特開2010−122880号公報に開示された方法によりデータの変更を対応するデータマートに反映するようにしてもよく、データの変更を対応するデータマートに反映させる方法としては、この他種々の方法を広く適用することができる。 Furthermore, in the above-described embodiment, as a method of reflecting the change of data in the corresponding data mart, the case where the corresponding batch 35 is re-executed has been described, but the present invention is not limited to this. The data change may be reflected on the corresponding data mart by the method disclosed in JP 2010-122880 A, and various other methods may be used to reflect the data change on the corresponding data mart. Can be widely applied.
本発明は、登録された各バッチをそれぞれ実行し、実行したバッチの処理結果をそれぞれ対応するデータマートに格納する種々の構成の情報処理装置に広く適用することができる。 The present invention can be widely applied to information processing apparatuses of various configurations that execute each registered batch and store the processing result of the executed batch in the corresponding data mart.
1……店舗管理システム、2……店舗、3……店舗端末、5……アプリケーションサーバ、6……データベースサーバ、7……ホスト装置、8……本部システム、10,30……CPU、14……販売データ、35,35A〜35D……バッチ、40……データベース、41,41A〜41D……データマート、50……バッチ解析部、51……バッチスケジュール管理部、52……履歴管理部、53……重要度設定部、54……変更検出部、55……影響度算出部、56……バッチ制御部、57……反映通知部、60……影響度算出ルール決定テーブル、61……重要度設定ルール決定テーブル、62……担当者連絡先テーブル、63……入出力管理テーブル、64……バッチ実行条件管理テーブル、65……バッチ実行スケジュールテーブル、66……バッチ優先順位管理テーブル、67……リソース管理テーブル、68……バッチ実行履歴管理テーブル、69……マート参照履歴管理テーブル、70……参照頻度管理テーブル、71……重要度管理テーブル、72……影響度算出ルール、73……重要度設定ルール。
1 ... store management system, 2 ... store, 3 ... store terminal, 5 ... application server, 6 ... database server, 7 ... host device, 8 ... head office system, 10, 30 ... CPU, 14 ...... Sales data, 35, 35A to 35D ...... batch, 40 ...... database, 41, 41A to 41 D ...... data mart, 50 ...... batch analysis unit, 51 ...... batch schedule management unit, 52 ...... history management unit 53: importance setting unit 54: change detection unit 55: influence calculation unit 56: batch control unit 57: reflection notification unit 60: influence calculation rule determination table 61 ... Importance setting rule determination table, 62 ... Contact person in charge contact table, 63 ... I / O management table, 64 ... Batch execution condition management table, 65 ... Batch execution schedule table 66, batch priority management table 67, resource management table 68, batch execution history management table 69, mart reference history management table 70, reference frequency management table 71, importance management Table 72: Impact calculation rule 73: Importance setting rule.
Claims (12)
各前記データマートの各レコードに対してそれぞれ重要度を設定する重要度設定部と、
各前記バッチが処理時にそれぞれ参照するデータを監視し、いずれかの前記データが変更された場合に当該変更を検出する変更検出部と、
前記変更検出部がいずれかの前記データの変更を検出した場合に、当該データの変更が後続業務に与える影響度を算出する影響度算出部と、
変更された前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、前記影響度算出部により算出された前記影響度とに基づいて、必要に応じて当該データの変更を当該データマートに反映させるバッチ制御部と
を備え、
前記重要度ごとにそれぞれ前記影響度の許容範囲が予め設定され、
前記バッチ制御部は、
前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、前記影響度算出部により算出された前記影響度とに基づいて、前記影響度が前記許容範囲内にあるか否かを当該データマートの前記レコードごとにそれぞれ判定し、いずれかの前記レコードの前記影響度が前記許容範囲を超えている場合に、当該データの変更を当該データマートに反映させる
ことを特徴とする情報処理装置。 In an information processing apparatus that executes each registered batch and stores the processing result of the executed batch in the corresponding data mart,
An importance setting unit that sets an importance for each record of each data mart;
A change detection unit that monitors data that each of the batches refers to at the time of processing, and detects the change when any of the data is changed;
An influence degree calculation unit that calculates an influence degree that the change of the data has on subsequent work when the change detection unit detects any change of the data;
Based on the degree of importance set in each of the records of the data mart in which the processing result of the batch referring to the changed data is stored, and the degree of influence calculated by the influence degree calculation unit , And a batch control unit for reflecting the change of the data in the data mart as needed;
The allowable range of the influence degree is set in advance for each of the importance degrees,
The batch control unit
The influence based on the degree of importance set in each record of the data mart in which the processing result of the batch referring to the data is stored, and the degree of influence calculated by the influence degree calculation unit It is determined for each record of the data mart whether or not the degree is within the allowable range, and when the degree of influence of any of the records exceeds the allowable range, the change of the data is determined An information processing apparatus characterized by reflecting on a data mart.
前記データマートのいずれかの前記レコードの前記影響度が前記許容範囲を超えている場合には、当該データマートに処理結果を格納する前記バッチを再実行させることにより、当該バッチが参照する前記データの変更を当該データマートに反映させる
ことを特徴とする請求項1に記載の情報処理装置。 The batch control unit
When the degree of influence of any of the records in the data mart exceeds the allowable range, the data referred to by the batch is re-executed by storing the processing result in the data mart. The information processing apparatus according to claim 1, wherein the change of is reflected in the data mart.
前記データマートのいずれの前記レコードも前記影響度が前記許容範囲を超えていない場合には、当該バッチを再実行したとしても、登録された他のすべての前記バッチが当該バッチについて設定された完了期限に間に合う場合に当該バッチを再実行させる
ことを特徴とする請求項2に記載の情報処理装置。 The batch control unit
If none of the records in the data mart has the impact degree exceeding the allowable range, all other registered batches are set for the batch even if the batch is re-executed. The information processing apparatus according to claim 2, wherein the batch is re-executed when the time limit is reached.
前記バッチ制御部は、
前記変更検出部がいずれかの前記データの変更を検出した場合に、当該データを参照する前記バッチを再実行する空き時間が存在するか否かを前記バッチスケジュール管理部に問い合わせ、
前記バッチスケジュール管理部は、
前記バッチ制御部から問い合わされた前記バッチを再実行する前記空き時間が存在しない場合には、登録された他の前記バッチの実行時間を当該バッチについて設定された前記完了期限を含む実行条件の範囲内において遅延させることにより前記バッチ制御部から問い合わされた前記バッチを再実行するための前記空き時間を捻出し、捻出した前記空き時間に当該バッチを再実行させるよう前記実行スケジュールを更新する
ことを特徴とする請求項3に記載の情報処理装置。 A batch schedule management unit that manages an execution schedule of each of the registered batches;
The batch control unit
When the change detection unit detects any change in the data, the batch schedule management unit is inquired as to whether there is an idle time for re-executing the batch referring to the data;
The batch schedule management unit
If there is no free time to re-execute the batch inquired from the batch control unit, a range of execution conditions including the completion time limit set for the batch for the execution time of the other registered batch By delaying the delay in the memory and unrolling the idle time for re-executing the batch inquired from the batch control unit, and updating the execution schedule to re-execute the batch in the unoccupied idle time The information processing apparatus according to claim 3, characterized in that
各前記データマートの各レコードの前記重要度を、当該レコードに格納された前記データに関する経時的に変化する所定値に基づいて設定し、
設定した前記レコードごとの前記重要度を定期的に更新する
ことを特徴とする請求項1に記載の情報処理装置。 The importance setting unit is
Setting the importance of each record of each data mart on the basis of a predetermined value which changes with time for the data stored in the record;
The information processing apparatus according to claim 1, wherein the importance of each set record is periodically updated.
前記影響度算出部は、
前記バッチの登録の際に当該バッチについて設定された前記影響度算出ルールに従って当該バッチの前記影響度を算出する
ことを特徴とする請求項1に記載の情報処理装置。 A plurality of types of influence calculation rules corresponding to the processing content of each of the batches are registered in advance,
The influence degree calculation unit
The information processing apparatus according to claim 1, wherein the influence degree of the batch is calculated according to the influence degree calculation rule set for the batch at the time of registration of the batch.
各前記データマートの各レコードに対してそれぞれ重要度を設定する第1のステップと、
各前記バッチが処理時にそれぞれ参照するデータを監視し、いずれかの前記データの変更を検出した場合に、当該データの変更が後続業務に与える影響度を算出する第2のステップと、
変更された前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定した前記重要度と、算出した前記影響度とに基づいて、必要に応じて当該データの変更を当該データマートに反映させる第3のステップと
を備え、
前記重要度ごとにそれぞれ前記影響度の許容範囲が予め設定され、
前記第3のステップにおいて、前記情報処理装置は、
前記データを参照する前記バッチの処理結果が格納される前記データマートの各前記レコードにそれぞれ設定された前記重要度と、算出した前記影響度とに基づいて、前記影響度が前記許容範囲内にあるか否かを当該データマートの前記レコードごとにそれぞれ判定し、いずれかの前記レコードの前記影響度が前記許容範囲を超えている場合に、当該データの変更を当該データマートに反映させる
ことを特徴とする情報処理方法。 In an information processing method executed by an information processing apparatus, which executes each registered batch and stores processing results of the executed batch in corresponding data marts,
A first step of setting an importance level for each record of each data mart;
A second step of monitoring data referred to at the time of processing by each of the batches, and calculating a degree of influence of the change of the data on the subsequent work when any change of the data is detected;
Based on the degree of importance set in each of the records of the data mart in which the processing result of the batch referring to the changed data is stored, and based on the calculated degree of influence, if necessary, the data And a third step of reflecting the change in the data mart.
The allowable range of the influence degree is set in advance for each of the importance degrees,
In the third step, the information processing apparatus
The degree of influence falls within the allowable range based on the degree of importance set for each record of the data mart in which the processing result of the batch referring to the data is stored, and the calculated degree of influence It is determined for each record of the data mart whether or not there is any, and when the degree of influence of any of the records exceeds the allowable range, the change of the data is reflected in the data mart. Characteristic information processing method.
前記データマートのいずれかの前記レコードの前記影響度が前記許容範囲を超えている場合には、当該データマートに処理結果を格納する前記バッチを再実行させることにより、当該バッチが参照する前記データの変更を当該データマートに反映させる
ことを特徴とする請求項7に記載の情報処理方法。 In the third step, the information processing apparatus
When the degree of influence of any of the records in the data mart exceeds the allowable range, the data referred to by the batch is re-executed by storing the processing result in the data mart. The information processing method according to claim 7, wherein the change of is reflected in the data mart.
前記データマートのいずれの前記レコードも前記影響度が前記許容範囲を超えていない場合には、当該バッチを再実行したとしても、登録された他のすべての前記バッチが当該バッチについて設定された完了期限に間に合う場合に当該バッチを再実行させる
ことを特徴とする請求項8に記載の情報処理方法。 In the third step, the information processing apparatus
If none of the records in the data mart has the impact degree exceeding the allowable range, all other registered batches are set for the batch even if the batch is re-executed. The information processing method according to claim 8, wherein the batch is re-executed when the time limit is met.
登録された各前記バッチの実行スケジュールを管理し、
前記第3のステップにおいて、前記情報処理装置は、
いずれかの前記データの変更を検出した場合に、当該データを参照する前記バッチを再実行する空き時間が存在するか否かを前記実行スケジュールに基づいて判定し、
当該バッチを再実行する前記空き時間が存在しない場合には、登録された他の前記バッチの実行時間を当該バッチについて設定された前記完了期限を含む実行条件の範囲内において遅延させることにより、変更された前記データを参照する前記バッチを再実行するための前記空き時間を捻出し、捻出した前記空き時間に当該バッチを再実行させるよう前記実行スケジュールを更新する
ことを特徴とする請求項9に記載の情報処理方法。 The information processing apparatus is
Manage the execution schedule of each registered batch,
In the third step, the information processing apparatus
When a change in any of the data is detected, it is determined based on the execution schedule whether there is an idle time for re-executing the batch that refers to the data.
If there is no free time to re-execute the batch, change the execution time of the other registered batch by delaying within the range of execution conditions including the completion deadline set for the batch. The execution schedule is updated so as to find out the idle time for re-executing the batch referring to the stored data, and to re-execute the batch in the excavated free time. Information processing method described.
各前記データマートの各レコードの前記重要度を、当該レコードに格納された前記データに関する経時的に変化する所定値に基づいて設定し、
設定した前記レコードごとの前記重要度を定期的に更新する
ことを特徴とする請求項7に記載の情報処理方法。 The information processing apparatus is
Setting the importance of each record of each data mart on the basis of a predetermined value which changes with time for the data stored in the record;
8. The information processing method according to claim 7, wherein the importance level of each set record is periodically updated.
前記第2のステップにおいて、前記情報処理装置は、
前記バッチの登録の際に当該バッチについて設定された前記影響度算出ルールに従って当該バッチの前記影響度を算出する
ことを特徴とする請求項7に記載の情報処理方法。
A plurality of types of influence calculation rules corresponding to the processing content of each of the batches are registered in advance,
In the second step, the information processing apparatus
The information processing method according to claim 7, wherein the influence degree of the batch is calculated according to the influence calculation rule set for the batch at the time of registration of the batch.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2017218892A JP6530469B1 (en) | 2017-11-14 | 2017-11-14 | INFORMATION PROCESSING APPARATUS AND METHOD |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2017218892A JP6530469B1 (en) | 2017-11-14 | 2017-11-14 | INFORMATION PROCESSING APPARATUS AND METHOD |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP6530469B1 JP6530469B1 (en) | 2019-06-12 |
| JP2019091197A true JP2019091197A (en) | 2019-06-13 |
Family
ID=66821643
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2017218892A Active JP6530469B1 (en) | 2017-11-14 | 2017-11-14 | INFORMATION PROCESSING APPARATUS AND METHOD |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP6530469B1 (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH09198291A (en) * | 1996-01-17 | 1997-07-31 | Toshiba Corp | Concurrent engineering support system and concurrent engineering support method |
| JP2008217285A (en) * | 2007-03-02 | 2008-09-18 | Hitachi Ltd | Operation management apparatus and operation management method for information processing system |
| JP2011103030A (en) * | 2009-11-10 | 2011-05-26 | Hitachi Ltd | Incident management method and operation management server |
| WO2012063339A1 (en) * | 2010-11-10 | 2012-05-18 | 株式会社日立製作所 | Computer system, job execution management method, and program |
| WO2013114911A1 (en) * | 2012-02-01 | 2013-08-08 | 日本電気株式会社 | Risk assessment system, risk assessment method, and program |
-
2017
- 2017-11-14 JP JP2017218892A patent/JP6530469B1/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH09198291A (en) * | 1996-01-17 | 1997-07-31 | Toshiba Corp | Concurrent engineering support system and concurrent engineering support method |
| JP2008217285A (en) * | 2007-03-02 | 2008-09-18 | Hitachi Ltd | Operation management apparatus and operation management method for information processing system |
| JP2011103030A (en) * | 2009-11-10 | 2011-05-26 | Hitachi Ltd | Incident management method and operation management server |
| WO2012063339A1 (en) * | 2010-11-10 | 2012-05-18 | 株式会社日立製作所 | Computer system, job execution management method, and program |
| WO2013114911A1 (en) * | 2012-02-01 | 2013-08-08 | 日本電気株式会社 | Risk assessment system, risk assessment method, and program |
Also Published As
| Publication number | Publication date |
|---|---|
| JP6530469B1 (en) | 2019-06-12 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP7737676B2 (en) | Computer systems and computer programs for machine learning | |
| CN1783132B (en) | Synchronization of runtime and application state via batching of workflow transactions | |
| US9223841B2 (en) | System and method for providing high availability data | |
| US10101991B2 (en) | Managing a software-patch submission queue | |
| AU2002340375B2 (en) | Methods, systems, and articles of manufacture for providing product availability information | |
| US20140188668A1 (en) | Recovery of E-Commerce Orders | |
| AU2002340375A1 (en) | Methods, systems, and articles of manufacture for providing product availability information | |
| US10825078B2 (en) | System and method for routing order lookups from retail systems | |
| JP6299599B2 (en) | Information system construction support apparatus, information system construction support method, and information system construction support program | |
| US9146952B1 (en) | System and method for distributed back-off in a database-oriented environment | |
| US10812322B2 (en) | Systems and methods for real time streaming | |
| WO2016033353A1 (en) | Systems and methods for biasing task assistance auto-complete suggestions | |
| JP5420385B2 (en) | Business support device | |
| JP6530469B1 (en) | INFORMATION PROCESSING APPARATUS AND METHOD | |
| JP7508829B2 (en) | Information processing device and program | |
| US20180285365A1 (en) | Customized application programming interface presentation | |
| WO2015145525A1 (en) | Information processing device, information processing method, and program | |
| JP6131725B2 (en) | Information processing apparatus and information processing program | |
| JP5215929B2 (en) | Data processing method and data processing system | |
| CN114997681A (en) | Task issuing method and device, storage medium and computer equipment | |
| JP2006277644A (en) | Data migration support system and data migration support program | |
| JP6751366B2 (en) | Information management system, information management method, and information management program | |
| JP2003281357A (en) | Contractor selection device, contractor selection system, contractor selection method and contractor selection program | |
| JP2008129973A (en) | Service management device | |
| Yang et al. | Satisfying quality requirements in the design of a partition‐based, distributed stock trading system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20180727 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20190315 |
|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20190423 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20190516 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 6530469 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 |