JP4485872B2 - データ中継装置 - Google Patents

Description

本発明は、各店舗の売上データを本部で集計する販売店システムの店舗側装置と本部側装置との間のデータ通信を中継するデータ中継装置に関する。

例えば大規模なスーパーマーケットやコンビニエンスストア等のように各地の店舗を本部で一元的に管理する仕組みの販売店では、各店舗のＰＯＳ（Point Of Sales）端末で発生した商品等の売上データを本部のコンピュータシステムが収集し、該コンピュータシステムによって管理されるデータベース上で集計することが行われている。この場合において、本部のコンピュータシステムがＰＯＳ端末から売上データを収集する方法としては、ＦＴＰ（File Transfer Protocol）手順を使用したファイル転送方式を利用するのが一般的であった。

しかしながらこの種のファイル転送方式を利用した場合には、本部のコンピュータシステムは売上データのファイルが送られてくるかどうかを常に監視している必要があり、従来はファイル監視プログラムを一定の間隔で繰返し起動して監視していた。また、ファイル監視プログラムは、売上データのファイルを受信するとその受信ファイル中の売上データをデータベース管理プログラムが処理可能なデータ形式に変換して該データベース管理プログラムに提供し、これにより該データベース管理プログラムがデータベースを更新していた。このため、本部コンピュータシステムの処理負荷が大きく、処理に時間を要するという問題があった。

これに関連する従来技術としては、サーバが混み合っているときのクライアントの待ち時間を可及的に少なくするために、クライアントが作成したデータをサーバに設けられた入力用キューテーブルへ転送し、入力用キューテーブルに書き込まれたデータに基づいて更新指示情報を作成して更新指示用キューテーブルに書き込み、更新指示用キューテーブルに書き込まれたデータに基づいて更新受付プログラムがアプリケーションの更新処理を起動するようにしたクライアント・サーバシステムにおけるデータ更新方法がある（例えば、特許文献１参照）。
特開２００１−３１８８１５公報

近年、データベースに対する一連の処理を一つのプログラムにまとめ、これをデータベース管理システムに保存したストアドプロシージャと呼ばれる技術が知られている。この技術を利用することにより、本部のコンピュータシステムでは売上データの受信監視処理が不要となるので処理負荷を軽減でき、処理時間を短縮できる効果を奏する。

本発明はこのような事情に基づいてなされたもので、その目的とするところは、各店舗で発生した商品等の売上データを本部のコンピュータシステムが管理するデータベースにストアドプロシージャの技術を利用して集計することにより、本部コンピュータシステムの処理負荷の軽減及び処理時間の短縮を図ることができるデータ中継装置を提供しようとするものである。

本発明は、店舗で発生した商品等の売上データを生成する店舗側装置と、各店舗の売上データを集計するためのデータベースを管理する本部側装置との間のデータ通信を中継するデータ中継装置であって、売上データファイル、スケジュールテーブル及び処理結果テーブルを有する記憶部、店舗側装置で生成された売上データを収集し、この売上データを売上データファイルに保存するとともに、この売上データを識別するための一意の売上データ識別コードを生成し、さらにこの売上データ識別コードと未更新情報とからなるスケジュールデータと同売上データ識別コードと未処理情報とからなる処理結果データとを生成して、スケジュールデータをスケジュールテーブルに生成順に格納し、処理結果データを処理結果テーブルに生成順に格納する売上データ収集手段、スケジュールテーブルを監視して、スケジュールデータが格納されると、そのスケジュールデータから売上識別コードを取得して更新用データの作成を依頼するスケジュール管理手段、更新用データの作成依頼を受けると、その依頼のあった更新用データの売上識別コードで識別される売上データを売上データファイルから読み取り、この売上データに基づいてデータベースに対する売上データ集計処理のストアドプロシージャに対応した更新用データを生成する更新用データ生成手段、更新用データを引数としてストアドプロシージャの実行を本部側装置に要求するストアドプロシージャ実行要求手段、ストアドプロシージャの処理結果を示す戻り値を本部側装置から受信する戻り値受信手段、及び更新用データ生成手段により生成された更新用データを引数として実行が要求されたストアプロシージャの処理結果を示す戻り値が正常を示すときには、処理結果テーブルの当該更新用データに該当する売上データ識別コードを含む処理結果データの未処理情報を正常終了情報に更新し、異常を示すときには異常終了情報に更新する処理結果更新手段を備えたものである。

かかる手段を講じた本発明によれば、各店舗で発生した商品等の売上データを本部のコンピュータシステムが管理するデータベースにストアドプロシージャの技術を利用して集計することができるので、本部コンピュータシステムの処理負荷の軽減及び処理時間の短縮を図ることができる。

以下、本発明の実施の形態を図面を用いて説明する。
なお、この実施の形態は、複数の店舗を本部が統轄する販売店システムの中継サーバを本発明のデータ中継装置として適用した場合である。

図１は本実施の形態における販売店システムの全体構成を示す図である。同図において、符号１は各店舗にそれぞれ構築されるＰＯＳシステムを示しており、符号２は本部のコンピュータシステムである本部サーバを示しており、符号３は本発明に係わる中継サーバを示している。本部サーバ２には、第１のネットワーク４を介して複数の中継サーバ３が接続されている。各中継サーバ３には、それぞれ第２のネットワーク５を介して複数のＰＯＳシステム１が接続されている。第１のネットワーク４と第２のネットワーク５は、ＩＳＤＮ（Integrated Services Digital Network），インターネット，公衆電話回線，専用回線等の通信媒体であり、第１のネットワーク４及び第２のネットワーク５として同一の通信媒体が使用されていてもよいし、異なる通信媒体が使用されていてもよい。

各ＰＯＳシステム１は、複数のＰＯＳ端末１１とその上位機であるストアコントローラ１２とから構成されている。各ＰＯＳ端末１１とストアコントローラ１２とは、例えばＬＡＮ（Local Area Network）１３で接続されている。ＰＯＳ端末１１は、商品に付されたバーコード等から価格データを検索して売上を計上する。ストアコントローラ１２は、各ＰＯＳ端末１１で計上された売上に基づいて商品等の売上データを生成する。

ＰＯＳシステム１で生成された売上データは、第２のネットワーク５，中継サーバ３及び第１のネットワーク４を介して本部サーバ２に送られ、売上集計データベース２１上で集計される。本部サーバ２には、売上集計データベース２１を管理し、当該データベース２１におけるデータのアクセス要求に応じるソフトウェアとしてデータベース管理プログラム２２が実装されている。また、売上集計データベース２１に対する一連の処理手順を一つのプログラムにまとめたストアドプロシージャ２３が、上記データベース管理プログラム２２に保存されている。

図２は中継サーバ３の主要な機能構成を示すブロック図である。中継サーバ３は、売上データファイル３１，スケジュールテーブル３２及び処理結果テーブル３３の記憶部と、対店舗通信部３４及び対本部通信部３５のインターフェイス部と、売上データ格納部３６，スケジュール管理部３７，更新用データ作成部３８及びストアドプロシージャ実行部３９の情報処理部とから構成されている。

売上データファイル３１は、各ＰＯＳシステム１から収集した売上データを一時的に保存する記憶エリアである。スケジュールテーブル３２は、図３に示すように、売上データファイル３１に保存された売上データを識別するための一意の売上データ識別コードと更新済フラグとからなるスケジュールデータを一連番号順に蓄積記憶する記憶エリアである。処理結果テーブル３３は、図４に示すように、前記売上データ識別コードと処理結果フラグとからなる処理結果データを一連番号順に蓄積記憶する記憶エリアである。

対店舗通信部３４は、第２のネットワーク５を介して接続された１乃至複数のＰＯＳシステム１と当該中継サーバ３との間のデータ送受信を司るものである。対本部通信部３５は、第１のネットワーク４を介して接続された本部サーバ２と当該中継サーバ３との間のデータ送受信を司るものである。

売上データ格納部３６は、図５に示すように、前記対店舗通信部３４でＰＯＳシステム１からの売上データを受信するのを待機している。そして、売上データを受信したならば（Ｓ５１のＹＥＳ）、この売上データを識別するための一意の売上データ識別コードを生成する（Ｓ５２）。そして、この売上データ識別コードと関連付けて当該売上データを売上データファイル３１に保存する（Ｓ５３）。また、この売上データ識別コードと更新済フラグ＝０（未更新）とからなるスケジュールデータと、同売上データ識別コードと処理結果フラグ＝０（未処理）とからなる処理結果データとを生成し、それぞれスケジュールテーブル３２と処理結果テーブル３３に番号順に追加する（Ｓ５４）。

ここに、対店舗通信部３４，売上データ格納部３６及び売上データファイル３１は、店舗側装置であるＰＯＳシステム１で生成された売上データを収集する売上データ収集手段を構成する。

スケジュール管理部３７は、図６に示すように、スケジュールテーブル３２を常時監視している。そして、更新済フラグが“０”の更新待ちスケジュールデータが格納されたならば（Ｓ６１のＹＥＳ）、その更新待ちスケジュールデータを“１”（更新済）に変更する（Ｓ６２）。また、その更新待ちスケジュールデータから売上データ識別コードを取得する（Ｓ６３）。そして、この売上データ識別コードを更新用データ作成部３８に与えて、更新用データの作成を依頼する（Ｓ６４）。

更新用データ作成部３８は、図７に示すように、スケジュール管理部３７からの更新用データ作成依頼を待機している。そして、更新用データ作成依頼を受取ったならば（Ｓ７１のＹＥＳ）、作成依頼があった更新用データの売上データ識別コードを検知し、この売上データ識別コードと関連付けられて保存された売上データを売上データファイル３１から読み取る（Ｓ７２）。そして、この売上データに基づいて売上集計データベース２１に対する売上データ集計処理のストアドプロシージャ２３に対応した更新用データを生成する（Ｓ７３）。更新用データは、ストアドプロシージャ２３実行時の引数として本部サーバ２に渡すために、売上データを合計部と明細部とに分割したデータである。しかる後、ストアドプロシージャ実行部３９に対してストアドプロシージャ２３の実行を依頼する（Ｓ７４）。

ここに、更新用データ作成部３８のＳ７２，Ｓ７３の各処理は、店舗側装置であるＰＯＳシステム１から収集した売上データに基づいて売上集計データベース２１に対する売上データ集計処理のストアドプロシージャ２３に対応した更新用データを生成する更新用データ生成手段を構成する。

ストアドプロシージャ実行部３９は、図８に示すように、更新用データ作成部３８からのストアドプロシージャ実行依頼を待機している。そして、ストアドプロシージャ実行依頼を受取ったならば（Ｓ８１のＹＥＳ）、リトライカウンタＲを“０”にリセットする（Ｓ８２）。次いで、更新用データ作成部３８にて作成された更新用データをストアドプロシージャ２３で処理される引数として本部サーバ２に対本部通信部３５を介して転送し、ストアドプロシージャ２３の実行を要求する（Ｓ８３）。

これにより本部サーバ２では、更新用データを引数とするストアドプロシージャ２３が実行され、更新用データの内容を基に売上データが売上集計データベース２１にて集計される。このとき、ストアドプロシージャ２３から処理結果を示す戻り値が第１のネットワーク４を通じてストアドプロシージャ実行要求元の中継サーバ３に送られる。

そこでストアドプロシージャ実行部３９は、対本部通信部３５を介して本部サーバ２から送られてくるストアドプロシージャ２３の戻り値を確認する（Ｓ８４）。ここで、戻り値が正常を示す値であった場合には、処理結果テーブル３３の該当する売上データ識別コードを含む処理結果データの処理結果フラグを未処理を示す“０”から正常終了を示す“１”に更新する（Ｓ８５）。

これに対し、戻り値が異常を示す値であった場合には、前記リトライカウンタＲを“１”だけカウントアップする（Ｓ８６）。そして、リトライカウンタＲが予め設定された上限値Ｒｍ（例えば“３”）を越えたかどうか確認する（Ｓ８７）。ここで、リトライカウンタＲが上限値Ｒｍを超えていない場合には、同更新用データでストアドプロシージャ２３の実行を再度要求する（Ｓ８３）。これに対し、リトライカウンタＲが上限値Ｒｍを超えてしまった場合には、処理結果テーブル３３の該当する売上データ識別コードを含む処理結果データ３３の処理結果フラグを未処理を示す“０”から異常終了を示す“９”に更新する（Ｓ８８）。

ここに、ストアドプロシージャ実行部３９のＳ８１，Ｓ８３の処理は、更新用データを引数として前記ストアドプロシージャの実行を前記本部側装置に要求するストアドプロシージャ実行要求手段を構成する。また、ストアドプロシージャ実行部３９のＳ８４の処理は、ストアドプロシージャ２３の処理結果を示す戻り値を本部側装置である本部サーバ２から受信する戻り値受信手段を構成する。また、ストアドプロシージャ実行部３９のＳ３２，Ｓ３４，Ｓ３５，Ｓ３６，Ｓ３３の各処理は、本部側装置である本部サーバ２から受信した戻り値が異常を示すときストアドプロシージャ２３の再実行を本部サーバ２に要求するリトライ要求手段を構成する。

このように本実施の形態においては、本部サーバ２によって管理されている売上集計データベース２１に対する売上データ集計処理のストアドプロシージャ２３がデータベース管理プログラム２２に保存されている。一方、中継サーバ３では、ＰＯＳシステム１から第２のネットワーク５を通じて売上データを受信する毎に、その売上データに基づいて上記ストアドプロシージャ２３に対応した更新用データが生成される。そして、この更新用データを引数としてストアドプロシージャ２３の実行を要求する指令が第１のネットワーク４を通じて本部サーバ２に送信される。

この指令を受けた本部サーバ２では、データベース管理プログラム２２内でストアドプロシージャ２３が実行される。そして、更新用データの内容が売上集計データベース２１に反映され、結果的に、ＰＯＳシステム１からの売上データが略リアルタイムに売上集計データベース２１に集計される。

その後、ストアドプロシージャ２３の実行結果を示す戻り値が、本部サーバ２から第１のネットワーク４を通じてストアドプロシージャ実行要求元の中継サーバ３に返される。これにより、中継サーバ３では戻り値が解析される。ここで、戻り値が正常を示す値であった場合には、当該売上データの処理結果が正常であることを示す処理結果データが処理結果テーブル３３にて保存される。

これに対し、戻り値が異常示す値の場合には、当該更新用データを引数とするストアドプロシージャ２３の実行要求が本部サーバ２に再度指令される。このような要求のリトライはリトライカウンタＲが上限値Ｒｍを超えるまで繰り返し実行される。そして、上限値Ｒｍ回数分のリトライを行っても正常を示す戻り値を受信できなかった場合には、当該売上データの処理結果が異常であることを示す処理結果データが処理結果テーブル３３にて保存される。

このように本実施の形態によれば、各店舗のＰＯＳシステム１で発生した商品等の売上データを本部サーバ２が管理する売上集計データベース２１にストアドプロシージャ２３の技術を利用して集計することができるので、本部サーバ２の処理負荷を大幅に軽減することができる。また、処理時間の短縮も図ることができる。

なお、この発明は前記実施形態そのままに限定されるものではなく、実施段階ではその要旨を逸脱しない範囲で構成要素を変形して具体化できる。

例えば、前記実施の形態では店舗側装置をＰＯＳシステム１としたが、ＰＯＳ端末１１単体を店舗側装置としてもよい。

また、前記実施の形態では、中継サーバ３と本部サーバ２とを別々のコンピュータとして説明したが、１つのサーバ用コンピュータが本部サーバ２としての機能と中継サーバ３としての機能を兼用してもよい。

この他、前記実施形態に開示されている複数の構成要素の適宜な組合せにより種々の発明を形成できる。例えば、実施形態に示される全構成要素から幾つかの構成要素を削除してもよい。さらに、異なる実施形態に亘る構成要素を組み合わせてもよい。

本発明の一実施の形態である販売店システムの全体構成を示す図。 同実施の形態における中継サーバの主要な機能構成を示すブロック図。 図２におけるスケジュールテーブルのデータ構造例を示す模式図。 図２における処理結果テーブルのデータ構造例を示す模式図。 図２における売上データ格納部の処理手順を示す流れ図。 図２におけるスケジュール管理部の処理手順を示す流れ図。 図２における更新用データ作成部の処理手順を示す流れ図。 図２におけるストアドプロシージャ実行部の処理手順を示す流れ図。

符号の説明

１…ＰＯＳシステム、２…本部サーバ、３…中継サーバ、４，５…第１及び第２のネットワーク、１１…ＰＯＳ端末、１２…ストアコントローラ、２１…売上集計データベース、２２…データベース管理プログラム、２３…ストアドプロシージャ、３１…売上データファイル、３２…スケジュールテーブル、３３…処理結果テーブル、３４…体店舗通信部、３５…体本部通信部、３６…売上データ格納部、３７…スケジュール管理部、３８…更新用データ作成部、３９…ストアドプロシージャ実行部。

Claims (2)

1. 店舗で発生した商品等の売上データを生成する店舗側装置と、各店舗の売上データを集計するためのデータベースを管理する本部側装置との間のデータ通信を中継するデータ中継装置において、
   売上データファイル、スケジュールテーブル及び処理結果テーブルを有する記憶部と、
   前記店舗側装置で生成された売上データを収集し、この売上データを前記売上データファイルに保存するとともに、この売上データを識別するための一意の売上データ識別コードを生成し、さらにこの売上データ識別コードと未更新情報とからなるスケジュールデータと同売上データ識別コードと未処理情報とからなる処理結果データとを生成して、前記スケジュールデータを前記スケジュールテーブルに生成順に格納し、前記処理結果データを前記処理結果テーブルに生成順に格納する売上データ収集手段と、
   前記スケジュールテーブルを監視して、前記スケジュールデータが格納されると、そのスケジュールデータから売上識別コードを取得して更新用データの作成を依頼するスケジュール管理手段と、
   前記更新用データの作成依頼を受けると、その依頼のあった更新用データの前記売上識別コードで識別される売上データを前記売上データファイルから読み取り、この売上データに基づいて前記データベースに対する売上データ集計処理のストアドプロシージャに対応した更新用データを生成する更新用データ生成手段と、
   前記更新用データを引数として前記ストアドプロシージャの実行を前記本部側装置に要求するストアドプロシージャ実行要求手段と、
   前記ストアドプロシージャの処理結果を示す戻り値を前記本部側装置から受信する戻り値受信手段と、
   前記更新用データ生成手段により生成された更新用データを引数として実行が要求された前記ストアプロシージャの処理結果を示す戻り値が正常を示すときには、前記処理結果テーブルの当該更新用データに該当する売上データ識別コードを含む処理結果データの未処理情報を正常終了情報に更新し、異常を示すときには異常終了情報に更新する処理結果更新手段と、
   を具備したことを特徴とするデータ中継装置。
2. 前記更新用データ生成手段により生成された更新用データを引数として実行が要求された前記ストアプロシージャの処理結果を示す戻り値が異常を示すとき前記ストアドプロシージャの再実行を前記本部側装置に要求するリトライ要求手段と、
   このリトライ要求手段のリトライ回数をカウントするリトライカウンタと、
   をさらに具備し、
   前記処理結果更新手段は、前記リトライカウンタで計数されるリトライ回数が予め設定した上限値を超えると、前記処理結果テーブルの当該更新用データに該当する売上データ識別コードを含む処理結果データの未処理情報を異常終了情報に更新することを特徴とする請求項１記載のデータ中継装置。

Images