001/*
002 * Copyright (c) 2009 The openGion Project.
003 *
004 * Licensed under the Apache License, Version 2.0 (the "License");
005 * you may not use this file except in compliance with the License.
006 * You may obtain a copy of the License at
007 *
008 *     http://www.apache.org/licenses/LICENSE-2.0
009 *
010 * Unless required by applicable law or agreed to in writing, software
011 * distributed under the License is distributed on an "AS IS" BASIS,
012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
013 * either express or implied. See the License for the specific language
014 * governing permissions and limitations under the License.
015 */
016package org.opengion.fukurou.transfer;
017
018import org.opengion.fukurou.util.StringUtil;
019
020/**
021 * 伝送要求に対してのHTTP経由で旧伝送DB(CB01)の読取を行います。
022 *
023 * 読取対象は、(データコード) (送り先) (テキスト種別) ([プロトコル]://[ホスト名]:[ポート番号]/[コンテキスト名]/)
024 * の形式で指定します。
025 *
026 * 例)読取対象 : 3 D9 B991 http://localhost:8824/gf/
027 *
028 * その他の処理内容については、{@link org.opengion.fukurou.transfer.TransferRead_HTTP}及び
029 * {@link org.opengion.fukurou.transfer.TransferRead_CB01}のJavaDocを参照して下さい。
030 *
031 * @og.group 伝送システム
032 *
033 * @version  5.0
034 * @author   Hiroki.Nakamura
035 * @since    JDK1.6
036 */
037public class TransferRead_HTTP_CB01 extends TransferRead_HTTP {
038
039        private String remoteHost = null;               // リモート接続先URL
040        private String remoteReadObj = null;    // リモート接続先の読取対象
041
042        /**
043         * ローカルの読取対象を、リモート接続先の読取対象とリモート接続先URLに分解します。
044         *
045         * @param localReadObj ローカルの読取対象
046         */
047        @Override
048        protected void splitReadObj( final String localReadObj ) {
049                String[] obj = StringUtil.csv2Array( localReadObj, ' ' );
050                if( obj.length < 4 ) {
051                        String errMsg = "読取対象は、(データコード) (送り先) (テキスト種別) ([プロトコル]://[ホスト名]:[ポート番号]/[コンテキスト名]/) の形式で指定して下さい。[READOBJ=" + localReadObj + "]";
052                        throw new RuntimeException( errMsg );
053                }
054                String hcdd = obj[0];
055                String hto = obj[1];
056                String hsyu = obj[2];
057                remoteHost = obj[3];
058                if( hcdd == null || hcdd.length() == 0
059                 || hto  == null || hto.length()  == 0
060                 || hsyu == null || hsyu.length() == 0
061                 || remoteHost == null || remoteHost.length() == 0 ) {
062                        String errMsg = "読取対象は、(データコード) (送り先) (テキスト種別) ([プロトコル]://[ホスト名]:[ポート番号]/[コンテキスト名]/) は必須です。[READOBJ=" + localReadObj + "]";
063                        throw new RuntimeException( errMsg );
064                }
065
066                remoteReadObj = hcdd + " " + hto + " " + hsyu;
067        }
068
069        /**
070         * リモート接続先URLを返します。
071         * このメソッドは、{@link #splitReadObj(String)}の後に呼び出しする必要があります。
072         *
073         * @return リモート接続先URL
074         */
075        @Override
076        public String getRemoteHost() {
077                if( remoteHost == null || remoteHost.length() == 0 ) {
078                        String errMsg = "先に#splitReadObj(String)を実行して下さい";
079                        throw new RuntimeException( errMsg );
080                }
081                return remoteHost;
082        }
083
084        /**
085         * リモート接続先の読取対象を返します。
086         * このメソッドは、{@link #splitReadObj(String)}の後に呼び出しする必要があります。
087         *
088         * @return 接続URL
089         */
090        @Override
091        public String getRemoteReadObj() {
092                if( remoteHost == null || remoteHost.length() == 0 ) {
093                        String errMsg = "先に#splitReadObj(String)を実行して下さい";
094                        throw new RuntimeException( errMsg );
095                }
096                return remoteReadObj;
097        }
098}