    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.hayabusa.taglib;
    017
    018import org.opengion.hayabusa.common.HybsSystemException;
    019
    020import static org.opengion.fukurou.util.StringUtil.nval ;
    021import org.opengion.fukurou.util.StringUtil;
    022import org.opengion.fukurou.process.HybsProcess;
    023import org.opengion.fukurou.process.Process_DBParam;
    024
    025import java.io.ObjectOutputStream;
    026import java.io.ObjectInputStream;
    027import java.io.IOException;
    028
    029/**
    030 * MainProcess で実行される Processクラスを構築します。
    031 *
    032 * 親クラス(Process)は、org.opengion.fukurou.process パッケージの HybsProcess
    033 * インターフェースを実装したクラスの、Process_****.java の **** 部分を指定します。
    034 * 共通的な パラメータは、このTagクラスに実装しますが、それぞれ、個別に必要な
    035 * パラメータは、ParamTag を使用して指定します。
    036 * このタグは、MainProcess タグの内部にのみ、記述可能です。
    037 *
    038 * @og.formSample
    039 * ●形式：&lt;og:process processID="ZZZ" &gt;
    040 *             &lt;og:param key="AAA" value="111" /&gt;
    041 *         &lt;/og:process &gt;
    042 * ●body：あり(EVAL_BODY_BUFFERED:BODYを評価し、{&#064;XXXX} を解析します)
    043 *
    044 * ●Tag定義：
    045 *   &lt;og:process
    046 *       processID        ○【TAG】リクエスト情報 に登録するキーをセットします(必須)。
    047 *       debug              【TAG】デバッグ情報を出力するかどうか[true/false]を指定します(初期値:false)
    048 *   &gt;   ... Body ...
    049 *   &lt;/og:process&gt;
    050 *
    051 * ●使用例
    052 *     一般的な変数の渡し方
    053 *   &lt;og:mainProcess &gt;
    054 *     &lt;og:process processID="DBReader" &gt;
    055 *        &lt;og:param key="dbid" value="FROM" /&gt;
    056 *        &lt;og:param key="sql"  value="select * from GE02" /&gt;
    057 *     &lt;/og:process &gt;
    058 *     &lt;og:process processID="DBWriter" &gt;
    059 *        &lt;og:param key="dbid"  value="TO" /&gt;
    060 *        &lt;og:param key="table" value="GE02" /&gt;
    061 *     &lt;/og:process &gt;
    062 *   &lt;/og:mainProcess &gt;
    063 *
    064 *     BODY 部に記述した変数の渡し方
    065 *     &lt;og:process processID="DBReader" &gt;
    066 *        &lt;og:param key="SQL" &gt;
    067 *              SELECT COUNT(*) FROM GEA03
    068 *              WHERE SYSTEM_ID=[SYSTEM_ID]
    069 *              AND   CLM=[CLM]
    070 *              AND   FGJ = '1'
    071 *        &lt;/og:param&gt;
    072 *     &lt;/og:process &gt;
    073 *
    074 * @og.group リアルバッチ系
    075 *
    076 * @version  4.0
    077 * @author       Kazuhiko Hasegawa
    078 * @since    JDK5.0,
    079 */
    080public class ProcessTag extends CommonTagSupport {
    081        //* このプログラムのVERSION文字列を設定します。   {@value} */
    082        private static final String VERSION = "4.3.1.1 (2008/09/04)" ;
    083
    084        private static final long serialVersionUID = 431120080904L ;
    085
    086        private static final String PRCS = "org.opengion.fukurou.process.Process_" ;
    087
    088        private String          processID       = null;
    089        private transient HybsProcess   process         = null;
    090
    091        /**
    092         * Taglibの開始タグが見つかったときに処理する doStartTag() を オーバーライドします。
    093         *
    094         * @og.rev 4.3.1.1 (2008/09/04) DBParam 使用時は、専用の初期化メソッドを呼ぶ
    095         *
    096         * @return      後続処理の指示( EVAL_BODY_BUFFERED )
    097         */
    098        @Override
    099        public int doStartTag() {
    100//              process = (HybsProcess)StringUtil.newInstance( PRCS + processID );
    101//              if( process == null ) {
    102//                      String errMsg = "<b>指定の processID を持つ HybsProcess が見つかりません。</b>"
    103//                                                              + "processID=" + processID ;
    104//                      throw new HybsSystemException( errMsg );
    105//              }
    106
    107                MainProcessTag mainProcess = (MainProcessTag)findAncestorWithClass( this,MainProcessTag.class );
    108                if( mainProcess == null ) {
    109//                      String errMsg = "<b>このタグは、MainProcessTagの内側(要素)に記述してください。</b>"
    110                        String errMsg = "<b>" + getTagName() + "タグは、MainProcessTagの内側(要素)に記述してください。</b>"
    111                                                                + "processID=" + processID ;
    112                        throw new HybsSystemException( errMsg );
    113                }
    114
    115                // 4.3.1.1 (2008/09/04) DBParam 使用時は、専用の初期化メソッドを呼ぶ
    116                if( "DBParam".equals( processID ) ) {
    117                        process = new Process_DBParam();
    118                        ((Process_DBParam)process).setAppInfo( getApplicationInfo() );
    119                }
    120                else {
    121                        process = (HybsProcess)StringUtil.newInstance( PRCS + processID );
    122                }
    123
    124                mainProcess.addProcess( process );
    125
    126                return ( EVAL_BODY_BUFFERED );          // Body を評価する
    127        }
    128
    129        /**
    130         * タグリブオブジェクトをリリースします。
    131         * キャッシュされて再利用されるので、フィールドの初期設定を行います。
    132         *
    133         */
    134        @Override
    135        protected void release2() {
    136                super.release2();
    137                processID       = null;
    138                process         = null;
    139        }
    140
    141        /**
    142         * 【TAG】リクエスト情報 に登録するキーをセットします。
    143         *
    144         * @og.tag
    145         * processID は、org.opengion.fukurou.process.HybsProcess インターフェースを実装した
    146         * Process_**** クラスの **** を与えます。
    147         * これらは、HybsProcess インターフェースを継承したサブクラスである必要があります。
    148         * 標準で、org.opengion.fukurou.process 以下の Process_**** クラスが、Process_**** 宣言 と
    149         * して、定義されています。
    150         * 属性クラス定義の {@link org.opengion.fukurou.process.HybsProcess HybsProcess} を参照願います。
    151         * {@og.doc03Link process Process_**** クラス}
    152         *
    153         * @param       pid リクエスト情報に登録するキー
    154         * @see         org.opengion.fukurou.process.HybsProcess  HybsProcessのサブクラス
    155         */
    156        public void setProcessID( final String pid ) {
    157                processID = nval( getRequestParameter( pid ),processID ) ;
    158        }
    159
    160        /**
    161         * 親クラスに登録するキーをセットします。
    162         *
    163         * @param       key             登録するキー
    164         * @param       value   登録する値
    165         */
    166        protected void addParam( final String key,final String value ) {
    167                process.putArgument( key,value );
    168        }
    169
    170        /**
    171         * シリアライズ用のカスタムシリアライズ書き込みメソッド
    172         *
    173         * @og.rev 4.0.0.0 (2006/09/31) 新規追加
    174         * @serialData 一部のオブジェクトは、シリアライズされません。
    175         *
    176         * @param       strm    ObjectOutputStreamオブジェクト
    177         * @throws IOException  入出力エラーが発生した場合
    178         */
    179        private void writeObject( final ObjectOutputStream strm ) throws IOException {
    180                strm.defaultWriteObject();
    181        }
    182
    183        /**
    184         * シリアライズ用のカスタムシリアライズ読み込みメソッド
    185         *
    186         * ここでは、transient 宣言された内部変数の内、初期化が必要なフィールドのみ設定します。
    187         *
    188         * @og.rev 4.0.0.0 (2006/09/31) 新規追加
    189         * @serialData 一部のオブジェクトは、シリアライズされません。
    190         *
    191         * @param       strm    ObjectInputStreamオブジェクト
    192         * @see #release2()
    193         * @throws IOException  シリアライズに関する入出力エラーが発生した場合
    194         * @throws ClassNotFoundException       クラスを見つけることができなかった場合
    195         */
    196        private void readObject( final ObjectInputStream strm ) throws IOException , ClassNotFoundException {
    197                strm.defaultReadObject();
    198        }
    199
    200        /**
    201         * このオブジェクトの文字列表現を返します。
    202         * 基本的にデバッグ目的に使用します。
    203         *
    204         * @return このクラスの文字列表現
    205         */
    206        @Override
    207        public String toString() {
    208                return org.opengion.fukurou.util.ToString.title( this.getClass().getName() )
    209                                .println( "VERSION"                             ,VERSION                        )
    210                                .println( "processID"                   ,processID                      )
    211                                .fixForm().toString() ;
    212        }
    213}