001/*
002 * Copyright (c) 2017 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.fileexec;
017
018import java.util.concurrent.ConcurrentMap;
019import java.util.concurrent.ConcurrentHashMap;
020import java.util.StringJoiner;
021import java.util.Arrays;
022import java.util.List;
023import java.nio.file.Path;
024
025import org.opengion.fukurou.util.StringUtil;
026
027/**
028 * AppliExec は、アプリケーションの実行を行う共通の処理クラスです。
029 *
030 *<pre>
031 *
032 * ここでは、GE72の処理IDに応じた方法で実行します。
033 *
034 *</pre>
035 *
036 * @og.rev 7.0.0.0 (2017/07/07) 新規作成
037 *
038 * @version  7.0
039 * @author   Kazuhiko Hasegawa
040 * @since    JDK1.8,
041 */
042public final class AppliExec {
043        private static final XLogger LOGGER= XLogger.getLogger( AppliExec.class.getName() );            // ログ出力
044
045        /** GE72 テーブルのカラム定義の enum */
046        public static enum GE72 {
047                /** GE72 テーブルから検索するカラム名 */
048//              RUNTYPE,RUNPG,CLMS,PARAMS,DBID,TABLE_NAME,SHT_NOS,FILE_ENC,SKIP_CNT ;
049                EXECID,RUNTYPE,RUNPG,CLMS,PARAMS,DBID,TABLE_NAME,SHT_NOS,FILE_ENC,SKIP_CNT ;                    // 7.2.1.0 (2020/03/13) EXECID 追加
050
051                /** order by で、開始日時(ST_TIME)順に処理されるようにしておきます。 */
052                private static final String FROM_WHERE = " from GE72 where SYSTEM_ID=? and EXECID=? and FGJ='1'" ;              // 1件のみのはず
053
054                /** 列挙子のCSV形式文字列 のキャッシュ  */
055                public static final String SELECT ;
056                static {
057                        final StringJoiner sj = new StringJoiner( "," , "select " , FROM_WHERE );
058                        Arrays.stream( values() ).forEachOrdered( v -> sj.add( v.name() ) );
059                        SELECT = sj.toString();
060                }
061
062                /** 列挙子の序数(カラムの並び順) */
063                public final int NO ;
064
065                /** private コンストラクター */
066                private GE72() { NO = ordinal(); }
067        };
068
069        // GE72()のユニークキーは、systemId + execId だが、GE70()のユニークキーは、systemId + rsrv_no
070        private static final ConcurrentMap<String,AppliExec> APP_EXEC_MAP = new ConcurrentHashMap<>();
071
072        private final String[] ge72Data ;
073
074        private final RunExec runexec ;                 // これもキャッシュできますが、とりあえず動くまでは毎回作成します。
075
076        /**
077         * private コンストラクタ
078         *
079         * @og.rev 6.8.1.5 (2017/09/08) LOGGER.debug 情報の追加
080         *
081         * @param       systemId        システムID
082         * @param       execId          処理ID
083         */
084        private AppliExec( final String systemId , final String execId ) {
085                LOGGER.debug( () -> "⑥ systemId=" + systemId + " , execId=" + execId );
086
087                final List<String[]> cmdRow = DBUtil.dbQuery( GE72.SELECT , systemId , execId );
088
089                if( cmdRow.isEmpty() ) {
090                        // MSG2001 = コマンドリストに、予約番号,取込ID,処理IDは必須です。[{0}]
091                        throw MsgUtil.throwException( "MSG2001" , "SYSTEM_ID=" + systemId + " , EXECID=" + execId );
092                }
093
094                ge72Data = cmdRow.get(0);               // 1件のみのはず
095                final String type = ge72Data[GE72.RUNTYPE.NO];
096
097                final String key ;
098                switch( type ) {
099                        case "0" : key = "NONE";        break;                  // なにもしない
100                        case "1" : key = "DBIN";        break;                  // DB入力
101        //              case "2" : key = "PLSQL";       break;                  // PL/SQLコール
102                        case "3" : key = "BAT";         break;                  // BATファイルコール
103        //              case "4" : key = "JSP";         break;                  // JSPファイルコール(URLコネクション)
104                        default  : key = null;          break;                  // なにもしない(runTypeなしエラー)
105                }
106
107                if( key == null ) {
108                        // MSG2002 = RUNTYPEに対応するRunExec実装クラスがありません。[{0}]
109                        throw MsgUtil.throwException( "MSG2002" , "RUNTYPE=" + type + " , systemId=" + systemId + " , execId=" + execId );
110                }
111
112                runexec = (RunExec)StringUtil.newInstance( "org.opengion.fukurou.fileexec.RunExec_" + key );
113        }
114
115        /**
116         * システムIDと処理IDから、対応するAppliExecオブジェクトを返します。
117         *
118         * AppliExecオブジェクトを、動的に作成し、システムID + 予約番号 をキーにキャッシュします。
119         *
120         * 何らかの Exception が、throw された場合は、null を返します。
121         *
122         * @og.rev 7.2.1.0 (2020/03/13) APP_EXEC_MAPのキーを、systemId + rsrv_no に変更します。
123         *
124         * @param       systemId        システムID
125         * @param       rsrvNo          予約番号(文字列のまま扱います)
126         * @param       execId          処理ID
127         * @return      AppliDataオブジェクト(作成できなければ、null)
128         */
129//      public static AppliExec newInstance( final String systemId , final String execId ) {
130        public static AppliExec newInstance( final String systemId , final String rsrvNo , final String execId ) {
131//              final String mapKey = systemId + "_" + execId ;
132                final String mapKey = systemId + "_" + rsrvNo ;
133
134                return APP_EXEC_MAP.computeIfAbsent( mapKey , key -> new AppliExec( systemId,execId ) );
135        }
136
137        /**
138         * システムID + 予約番号 をキーにキャッシュからAppliExecオブジェクトを削除します。
139         *
140         * 新しい AppliExecオブジェクトを作成する際に、GE72 を再読み込みします。
141         * 何か定義変更を行った後、読み取りスレッドを停止すると同時に、キャッシュを削除すれば、
142         * 次回起動時には、DBの設定を再読み込みします。
143         *
144         * @og.rev 7.2.1.0 (2020/03/13) APP_EXEC_MAPのキーを、systemId + rsrv_no に変更します。
145         *
146         * @param       systemId        システムID
147         * @param       rsrvNo          予約番号(文字列のまま扱います)
148         */
149        public static void removeInstance( final String systemId , final String rsrvNo ) {
150                final String mapKey = systemId + "_" + rsrvNo ;
151
152                APP_EXEC_MAP.remove( mapKey );
153        }
154
155        /**
156         * GE72.RUNTYPE に基づいて、各種処理を実行します。
157         *
158         * @og.rev 6.8.1.5 (2017/09/08) LOGGER.debug 情報の追加
159         * 
160         * @param       path 処理するファイルパス
161         * @return      処理件数(正は成功、マイナスは異常時の行番号)
162         */
163        public int exec( final Path path ) {
164                return runexec.exec( path,ge72Data ) ;
165        }
166
167        /**
168         * GE72.RUNTYPE に基づいて、各種処理を実行します。
169         *
170         * @og.rev 7.2.1.0 (2020/03/13) 新規追加
171         * 
172         * @param       path 処理するファイルパス
173         * @param       fgtkan 取込完了フラグ(0:取込なし , 1:処理中 , 2:済 , 7:デーモンエラー , 8:アプリエラー)
174         * @param       errMsg エラーメッセージ
175         */
176        public void endExec( final Path path , final String fgtkan , final String errMsg ) {
177                runexec.endExec( path,ge72Data,fgtkan,errMsg ) ;
178        }
179}