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}