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 */ 016 package org.opengion.plugin.daemon; 017 018 import java.util.ArrayList; 019 import java.util.Date; 020 import java.util.HashMap; 021 import java.util.LinkedHashMap; 022 import java.util.LinkedHashSet; 023 import java.util.List; 024 import java.util.Map; 025 import java.util.Set; 026 027 import org.opengion.fukurou.db.DBUtil; 028 import org.opengion.fukurou.db.Transaction; 029 import org.opengion.fukurou.db.TransactionReal; 030 import org.opengion.fukurou.transfer.TransferConfig; 031 import org.opengion.fukurou.transfer.TransferExec; 032 import org.opengion.fukurou.util.ApplicationInfo; 033 import org.opengion.fukurou.util.LogWriter; 034 import org.opengion.fukurou.util.StringUtil; 035 import org.opengion.hayabusa.common.HybsSystem; 036 import org.opengion.hayabusa.common.HybsSystemException; 037 038 /** 039 * ã€ä¼é?シスãƒ?ƒ 】旧ä¼é?DB(CB01)を監視ã—ã¦ã€å®Ÿè¡Œæ–¹æ³•ã«å¿œã˜ãŸå?ç??ãƒã‚°ãƒ©ãƒ?‚’呼ã³å‡ºã—ã¾ã™ã? 040 * 041 * ã“ã?ãƒ??モンã¯ã€ä¼é?定義マスタã®èªå–方法ãŒã€æ—§ä¼é?DBèªå?CB01)ã®å®šç¾©ã‚’対象ã¨ã—ã¦å®Ÿè¡Œã•れã¾ã™ã? 042 * èªå–対象ã¯ã€æ—§ä¼é?DB(CB01)ã§ã€ãƒ‡ãƒ¼ã‚¿ã‚³ãƒ¼ãƒ‰ã?é€ã‚Šå…ˆã?ãƒ?‚スト種別ã€çжæ³?'1'ã‚’æ¡ä»¶ã«èªã¿è¾¼ã¾ã‚Œã¾ã™ã? 043 * ä¼é?定義マスタ上ã§ã¯ã€èªå–対象ã«ã¦ã€ä»¥ä¸‹ã?å½¢å¼ã§å®šç¾©ã™ã‚‹å¿?¦ãŒã‚りã¾ã™ã? 044 * (ãƒ??タコーãƒ? (é€ã‚Šå…? (ãƒ?‚スト種別) ä¾?:"3 D9 B119" 045 * 処ç?®Ÿè¡Œå¾Œã?ã€èªã¿å–ã£ãŸã?ãƒ?ƒ€ãƒ¼ãƒ??ã‚¿ã®çжæ³ã‚’'2'ã«æ›´æ–°ã—ã¾ã™ã? 046 * ä½?—ã€èªå–パラメーターã«"NOUPDATE"を指定ã—ãŸå?åˆã?処ç?¾Œã?æ›´æ–°ã¯è¡Œã‚れã¾ã›ã‚“ã€? 047 * ã¾ãŸã?エラーãŒç™ºç”Ÿã—ãŸå?åˆã?ヘッãƒ??ãƒ??ã‚¿ã®çжæ³ã‚’'9'ã«æ›´æ–°ã—ã¾ã™ã? 048 * 049 * トランザクションã¯ã€èªå–対象ã®å˜ä½ã«ãªã‚Šã¾ã™ã? 050 * åŒã˜èªå–対象ã§ã€ç•°ãªã‚‹å®Ÿè¡Œæ–¹æ³•ã?実行対象を定義ã—ãŸå ´åˆã?åŒã˜ãƒ??ã‚¿ã«å¯¾ã—ã¦è¤?•°å›žå?ç?Œè¡Œã‚れã¾ã™ã? 051 * ã—ã‹ã—ã?ã“ã?å ´åˆã«ãŠã„ã¦ã‚‚ã?トランザクションã¯èªå–対象ã®å˜ä½ã§ç”Ÿæ?ã•れるãŸã‚ã?è¤?•°å›žã?処ç??å†?? 052 * 1回ã§ã‚‚エラーãŒç™ºç”Ÿã—ãŸå?åˆã?ã€åŒã˜èªå–対象ã§ãれã¾ã§ã«å‡¦ç?—ãŸå?ã«ã¤ã?¦ã‚‚rollbackã•れã¾ã™ã? 053 * 054 * ã¾ãŸã?ã“ã?ä¼é?ãƒ??モン(èªå–æ–¹æ³?ã¯ã€æ—§ä¼é?DB(CB01)ã«å¯¾ã™ã‚‹ã‚¯ã‚¨ãƒªå›žæ•°ã‚’減らã™ãŸã‚ã?æ—§ä¼é?DB(CB01)㨠055 * ä¼é?定義マスタ(GE62)ã‚’JOINã—ã¦ä¸?‹¬ã§ãƒ??ã‚¿ã‚’å–å¾—ã—ã¦ã?¾ã™ã? 056 * ã“ã?ãŸã‚ã€ä»–ã?ä¼é?ãƒ??モン(èªå–æ–¹æ³?ã¨ã¯èªå–部åˆ??実è£?–¹æ³•ãŒç•°ãªã£ã¦ã?¾ã™ã? 057 * 具体的ã«ã¯ã€{@link org.opengion.fukurou.transfer.TransferRead}インターフェースを利用ã›ãšã«ã€? 058 * ã“ã?ãƒ??モン自体ã«èªå–åŠã³ã‚¹ãƒ??タス更新ã®å‡¦ç?‚’実è£?—ã¦ã?¾ã™ã? 059 * 060 * ※処ç?¸ã«ä½•らã‹ã?エラーã?度ã§ã‚‚発生ã—ãŸå?åˆã?ã“ã?ãƒ??モンã¯åœæ¢ã—ã¾ã™ã? 061 * 062 * ã“ã?クラスã¯ã€HybsTimerTask を継承ã—㟠タイマã?タスククラスã§ã™ã? 063 * startDaemon() ãŒã‚¿ã‚¤ãƒžã?タスクã«ã‚ˆã£ã¦ã€å‘¼ã³å‡ºã•れã¾ã™ã? 064 * 065 * @og.rev 5.4.1.0 (2011/11/01) ä¼é?シスãƒ?ƒ 対å¿? 066 * @og.group ãƒ??モン 067 * 068 * @version 5.0 069 * @author Hiroki Nakamura 070 * @since JDK6.0, 071 */ 072 public class Daemon_Transfer_CB01 extends Daemon_Transfer { 073 //* ã“ã?プãƒã‚°ãƒ©ãƒ??VERSIONæ–?—å?ã‚’è¨å®šã—ã¾ã™ã? {@value} */ 074 private static final String VERSION = "5.4.1.0 (2011/11/01)" ; 075 076 // 実行方法ã«å¯¾å¿œã™ã‚‹å®Ÿè£?‚¯ãƒ©ã‚¹ã®åŸºæº–å 077 private static final String EXEC_CLS_BASE = "org.opengion.fukurou.transfer.TransferExec_" ; 078 079 // ä¼é?ãƒ??ã‚¿å–得用SQL(クエリ回数を減らã™ãŸã‚æ—§ä¼é?DBã¨ä¼é?定義マスタをJOINã—ã¦æ¤œç´¢) 080 private static final String GE62CB01_SELECT = 081 "SELECT B.KBREAD,B.READOBJ,B.READPRM,B.KBEXEC,B.EXECDBID,B.EXECOBJ,B.EXECPRM,B.ERROR_SENDTO,A.HTCNO" + 082 " FROM CB01 A,GE62 B" + 083 " WHERE A.HCDD = SUBSTR(B.READOBJ,1,INSTR(B.READOBJ,' ',1,1)-1)" + // "3 D9 B119"ã®"3" 084 " AND A.HTO = RPAD(SUBSTR(B.READOBJ,INSTR(B.READOBJ,' ',1,1)+1,INSTR(B.READOBJ,' ',1,2)-INSTR(B.READOBJ,' ',1,1)-1),8)" + // "3 D9 B119"ã®"D9" 085 " AND A.HSYU = RPAD(SUBSTR(B.READOBJ,INSTR(B.READOBJ,' ',1,2)+1),4)" + // "3 D9 B119"ã®"B119" 086 " AND A.HCDJ = '1'" + 087 " AND B.FGJ = '1'"; 088 089 // コãƒã‚¯ã‚·ãƒ§ãƒ³ã«ã‚¢ãƒ—リケーションæƒ??を追記ã™ã‚‹ã‹ã©ã?‹æŒ?®? 090 private static final boolean USE_DB_APPLICATION_INFO = HybsSystem.sysBool( "USE_DB_APPLICATION_INFO" ) ; 091 092 // HTTP接続時ã®ãƒ—ãƒã‚シホスãƒ? 093 private static final String HTTP_PROXY_HOST = HybsSystem.sys( "HTTP_PROXY_HOST" ); 094 095 // HTTP接続時ã®ãƒ—ãƒã‚ã‚·ãƒã?ãƒ? 096 private static final int HTTP_PROXY_PORT = HybsSystem.sysInt( "HTTP_PROXY_PORT" ); 097 098 // 呼ã³å‡ºã—å?ホストコーãƒ? 099 private static final String HFROM = HybsSystem.sys( "TRANSFER_HOST_CODE" ); 100 101 // ループカウンタã‚?4回ã«è¨å®? 102 private static final int LOOP_COUNTER = 24; 103 104 private boolean running = true; 105 private int loopCnt = 0; 106 107 private String ge62Cb01Select = null; 108 private String dmnName = null; 109 110 private ApplicationInfo appInfo = null; 111 private boolean debug = false; 112 113 /** 114 * ã“ã?タイマã?タスクã«ã‚ˆã£ã¦åˆæœŸåŒ–ã•れるアクションã§ã™ã? 115 * パラメータを使用ã—ãŸåˆæœŸåŒ–を行ã„ã¾ã™ã? 116 * 117 */ 118 @Override 119 public void initDaemon() { 120 debug = StringUtil.nval( getValue( "DEBUG" ),debug ); 121 122 dmnName = getName(); 123 124 StringBuilder buf = new StringBuilder(); 125 buf.append( GE62CB01_SELECT ); 126 127 // シスãƒ?ƒ IDã¯å¿??æŒ?®? 128 String systemId = getValue( "SYSTEM_ID" ); 129 if( StringUtil.isNull( systemId ) ) { 130 String errMsg = "シスãƒ?ƒ ID方法ã?å¿??æŒ?®šã§ã™ã?" ; 131 throw new HybsSystemException( errMsg ); 132 } 133 else { 134 buf.append( " AND B.SYSTEM_ID='" ).append( systemId ).append( "'" ); 135 } 136 137 // èªå–方法ã?å¿??æŒ?®? 138 String kbRead = getValue( "KBREAD" ); 139 if( StringUtil.isNull( kbRead ) ) { 140 String errMsg = "èªå–方法ã?å¿??æŒ?®šã§ã™ã?" ; 141 throw new HybsSystemException( errMsg ); 142 } 143 else { 144 buf.append( " AND B.KBREAD='" ).append( kbRead ).append( "'" ); 145 } 146 147 // ãƒ??モングループã?å¿??æŒ?®? 148 String dmnGroup = getValue( "DMN_GRP" ); 149 if( StringUtil.isNull( dmnGroup ) ) { 150 String errMsg = "ãƒ??モングループã?å¿??æŒ?®šã§ã™ã?" ; 151 throw new HybsSystemException( errMsg ); 152 } 153 else { 154 buf.append( " AND B.DMN_GRP='" ).append( dmnGroup ).append( "'" ); 155 } 156 157 buf.append( " ORDER BY A.HTC" ); 158 159 ge62Cb01Select = buf.toString() ; 160 161 if( debug ) { 162 System.out.println( "DMN_NAME=[" + dmnName + "]" ); 163 System.out.println( "QUERY=[" + ge62Cb01Select + "]" ); 164 } 165 166 if( USE_DB_APPLICATION_INFO ) { 167 appInfo = new ApplicationInfo(); 168 // ユーザーID,IPアドレス,ホストå 169 appInfo.setClientInfo( systemId,HybsSystem.HOST_ADRS,HybsSystem.HOST_NAME ); 170 // ç”»é¢ID,æ“ä½?プãƒã‚°ãƒ©ãƒ?D 171 appInfo.setModuleInfo( "TransferDaemon",dmnName,dmnName ); 172 } 173 else { 174 appInfo = null; 175 } 176 } 177 178 /** 179 * タイマã?タスクã®ãƒ??モン処ç??é–‹å§‹ã?イントã§ã™ã? 180 * 181 */ 182 @Override 183 protected void startDaemon() { 184 if( loopCnt % LOOP_COUNTER == 0 ) { 185 loopCnt = 1; 186 System.out.println(); 187 System.out.print( toString() + " " + new Date() + " " ); 188 } 189 else { 190 System.out.print( "." ); 191 loopCnt++ ; 192 } 193 194 // ä¼é?DBèªå? 195 String[][] vals = null; 196 GE62CB01Data ge62Cb01Data = new GE62CB01Data(); 197 try { 198 vals = DBUtil.dbExecute( ge62Cb01Select,null,appInfo ); 199 if( vals != null && vals.length > 0 ) { 200 for( int row=0; running && row<vals.length; row++ ) { 201 ge62Cb01Data.addData( vals[row] ); 202 } 203 } 204 } 205 catch( Throwable ex ) { 206 String header = "ä¼é?èªå–エラー?šDMN_NAME=[" + dmnName + "] , DMN_HOST=[" + HybsSystem.HOST_NAME + "] , QUERY=[" + ge62Cb01Select + "]"; 207 String errMsg = header + HybsSystem.CR + StringUtil.stringStackTrace( ex ) ; 208 System.out.println( errMsg ); 209 LogWriter.log( errMsg ); 210 String errorSendto = HybsSystem.sys( "ERROR_MAIL_TO_USERS" ); 211 sendMail( header, errMsg, errorSendto ); 212 } 213 214 // 処ç?®Ÿè¡? 215 // èªå–対象ã®å˜ä½ã§ãƒˆãƒ©ãƒ³ã‚¶ã‚¯ã‚·ãƒ§ãƒ³ã‚’生æˆã—ã¾ã™ã? 216 for( String tranKey : ge62Cb01Data.getTranSet() ) { 217 Transaction tran = null; 218 TransferConfig conf = null; 219 String[] htcnoArr = null; 220 boolean isUpdate = true; 221 try { 222 tran = new TransactionReal( appInfo ); 223 224 // èªå–対象+実行方æ³?実行対象ã®å˜ä½ã§å‡¦ç?‚’行ã„ã¾ã™ã? 225 for( String confKey : ge62Cb01Data.getExecKeySet( tranKey ) ) { 226 conf = ge62Cb01Data.getConfig( confKey ); 227 htcnoArr = ge62Cb01Data.getHtcno( confKey ); 228 229 // ãƒ?ƒãƒ?‚°æƒ??ã‚’å?力ã—ã¾ã™ã? 230 if( debug ) { 231 System.out.println(); 232 System.out.print( " START = " + new Date() ); 233 System.out.print( "[" + dmnName + "]:[" + StringUtil.array2csv( htcnoArr ) + "]:[" + conf.toString() + "]" ); 234 } 235 236 // ä¼é?ãƒ??ã‚¿ã‚’èªã¿å‡ºã—ã¾ã™ã? 237 String[] val = read( htcnoArr, tran ); 238 // 実行方法ã?オブジェクトを生æ?ã—ã¾ã™ã? 239 TransferExec exec = (TransferExec)StringUtil.newInstance( EXEC_CLS_BASE + conf.getKbExec() ); 240 // 処ç?‚’実行ã—ã¾ã™ã? 241 exec.execute( val, conf, tran ); 242 243 // ãƒ?ƒãƒ?‚°æƒ??ã‚’å?力ã—ã¾ã™ã? 244 if( debug ) { 245 System.out.println(); 246 System.out.print( " END = " + new Date() ); 247 System.out.print( "[" + dmnName + "]:[" + StringUtil.array2csv( htcnoArr ) + "]:[" + conf.toString() + "]" ); 248 } 249 250 // 対象ã¨ãªã‚‹ã?スタã®å†??èªå–パラメーターã«?‘ã¤ã§ã‚?NOUPDATE"ãŒæŒ‡å®šã•れã¦ã?‚‹å ´åˆã?ã€CB01ã®çжæ³ã‚’æ›´æ–°ã—ãªã? 251 if( "NOUPDATE".equalsIgnoreCase( conf.getReadPrm() ) ) { 252 isUpdate = false; 253 } 254 } 255 256 // 対象ã¨ãªã‚‹ã?スタã®å†??èªå–パラメーターã«?‘ã¤ã§ã‚?NOUPDATE"ãŒæŒ‡å®šã•れã¦ã?‚‹å ´åˆã?ã€CB01ã®çжæ³ã‚’æ›´æ–°ã—ãªã? 257 if( isUpdate ) { 258 complete( htcnoArr, tran ); 259 } 260 } 261 catch( Throwable ex ) { 262 // エラーãŒç™ºç”Ÿã—ãŸå?åˆã?ãƒ??ãƒ¢ãƒ³ã‚’åœæ¢ã—ã¾ã™ã? 263 cancel(); 264 265 if( tran != null ) { 266 tran.rollback(); 267 tran.close(); 268 tran = null; // エラー発生時ã¯ã€æŽ¥ç¶šã‚’終äº?—ã¾ã™ã?(次ã®çŠ¶æ³æ›´æ–°ã§ãƒ?ƒƒãƒ‰ãƒãƒ?‚¯ã«ãªã‚‹ãŸã‚? 269 } 270 271 if( htcnoArr != null && htcnoArr.length > 0 ) { 272 error( htcnoArr ); // エラー発生時ã¯CB01>状態を9:ã‚¨ãƒ©ãƒ¼ã«æ›´æ–° 273 } 274 275 String header = "ä¼é?エラー?šDMN_NAME=[" + dmnName + "] , DMN_HOST=[" + HybsSystem.HOST_NAME + "]"; 276 String errorSendto = null; 277 if( htcnoArr != null && htcnoArr.length > 0 ) { 278 header += " , HTCNO=[" + StringUtil.array2csv( htcnoArr ) + "]"; 279 } 280 if( conf != null ) { 281 header += " , CONFIG=[" + conf.toString() + "]"; 282 errorSendto = conf.getErrorSendto(); 283 } 284 285 String errMsg = header + HybsSystem.CR + StringUtil.stringStackTrace( ex ) ; 286 System.out.println( errMsg ); 287 LogWriter.log( errMsg ); 288 sendMail( header, errMsg, errorSendto ); 289 } 290 finally { 291 if( tran != null ) { tran.close(); } 292 } 293 } 294 } 295 296 /** 297 * ã“ã?タイマã?タスクã®cancel() メソãƒ?ƒ‰ã‚’オーãƒã?ライドã—ã¾ã™ã? 298 * HybsTimerTaskManager#cancelTask( int ) を実行ã—ã¾ã™ã? 299 * 300 * @return スケジュールã•れã¦ã?‚‹ 1 回以上実行ã•れãªã??åˆã« true 301 * @see java.util.TimerTask#cancel() 302 */ 303 @Override 304 public boolean cancel() { 305 running = false; 306 return super.cancel(); 307 } 308 309 /** 310 * CB01ã‚’èªã¿è¾¼ã¿ãƒ??ã‚¿ã‚’é?列ã§è¿”ã—ã¾ã™ã? 311 * 312 * @param htcnoArr èªå–対象ã®é€šç•ªNO(é…å?) 313 * @param tran トランザクション 314 * 315 * @return ãƒ??ã‚¿(é…å?) 316 */ 317 private String[] read( final String[] htcnoArr, final Transaction tran ) { 318 if( htcnoArr == null || htcnoArr.length == 0 ) { return new String[0]; } 319 320 String htcnos = StringUtil.array2csv( htcnoArr ); 321 StringBuilder buf = new StringBuilder(); 322 buf.append( "SELECT A.HTEXT" ); 323 buf.append( " FROM CB01 A" ); 324 buf.append( " WHERE A.HCDJ = '5'" ); 325 buf.append( " AND A.HTCNO IN (" ); 326 buf.append( htcnos ); 327 buf.append( ") ORDER BY A.HTC, A.HTCNO" ); 328 329 String[][] vals = DBUtil.dbExecute( buf.toString(),null,tran ); 330 String[] rtn = new String[vals.length]; 331 for( int i=0; i<vals.length; i++ ) { 332 rtn[i] = vals[i][0]; 333 } 334 return rtn; 335 } 336 337 /** 338 * CB01ã®ãƒ˜ãƒƒãƒ??ãƒ??ã‚¿ã®çжæ³ã‚’2:抜å?済ã¿ã«æ›´æ–°ã—ã¾ã™ã? 339 * 340 * @param htcnoArr 更新対象ã®é€šç•ªNO(é…å?) 341 * @param tran トランザクション 342 */ 343 private void complete( final String[] htcnoArr, final Transaction tran ) { 344 if( htcnoArr == null || htcnoArr.length == 0 ) { return; } 345 346 String htcnos = StringUtil.array2csv( htcnoArr ); 347 StringBuilder buf = new StringBuilder(); 348 buf.append( "UPDATE CB01 A" ); 349 buf.append( " SET A.HCDJ = '2'" ); 350 buf.append( " WHERE A.HCDJ = '1'" ); 351 buf.append( " AND A.HTCNO IN (" ); 352 buf.append( htcnos ); 353 buf.append( ")" ); 354 355 DBUtil.dbExecute( buf.toString(),null,tran ); 356 } 357 358 /** 359 * CB01ã®ãƒ˜ãƒƒãƒ??ãƒ??ã‚¿ã®çжæ³ã‚’9:ã‚¨ãƒ©ãƒ¼ã«æ›´æ–°ã—ã¾ã™ã? 360 * 361 * @param htcnoArr 更新対象ã®é€šç•ªNO(é…å?) 362 */ 363 private void error( final String[] htcnoArr ) { 364 if( htcnoArr == null || htcnoArr.length == 0 ) { return; } 365 366 String htcnos = StringUtil.array2csv( htcnoArr ); 367 StringBuilder buf = new StringBuilder(); 368 buf.append( "UPDATE CB01 A" ); 369 buf.append( " SET A.HCDJ = '9'" ); 370 buf.append( " WHERE A.HCDJ in ('1','2')" ); // æ—¢ã«å®Ÿè¡ŒPGã§æŠœå?済ã¿ã«æ›´æ–°ã•れã¦ã?‚‹å¯èƒ½æ€§ãŒã‚ã‚? 371 buf.append( " AND A.HTCNO IN (" ); 372 buf.append( htcnos ); 373 buf.append( ")" ); 374 375 DBUtil.dbExecute( buf.toString(),null,appInfo ); // エラー更新ã¯ãƒˆãƒ©ãƒ³ã‚¶ã‚¯ã‚·ãƒ§ãƒ³ã‚’å?ã‘ã¦å‡¦ç?™ã‚? 376 } 377 378 /** 379 * ä¼é?定義マスタåŠã?æ—§ä¼é?DBã‹ã‚‰èªã¿å‡ºã—ãŸãƒ??タを管ç?—ã¾ã™ã? 380 */ 381 private static class GE62CB01Data { 382 383 // トランザクションを生æˆã™ã‚‹ã‚ーã®ã‚»ãƒ?ƒˆ(èªå–対象å˜ä½? 384 private final Set<String> tranSet = new LinkedHashSet<String>(); 385 // トランザクションã‚ー(èªå–対象)ã«å¯¾ã™ã‚‹ã€å?ç?‚ー(èªå–対象+実行方æ³?実行対象)ã®ã‚»ãƒ?ƒˆ 386 private final Map<String,Set<String>> tran2ExecKeySet = new LinkedHashMap<String,Set<String>>(); 387 // 処ç?‚ー(èªå–対象+実行方æ³?実行対象)ã«å¯¾ã™ã‚‹è¨å®šã‚ªãƒ–ジェクトã?マッピング 388 private final Map<String,TransferConfig> execKey2Conf = new HashMap<String,TransferConfig>(); 389 // 処ç?‚ー(èªå–対象+実行方æ³?実行対象)ã«å¯¾ã™ã‚‹é€šç•ªNO(é…å?)ã®ãƒžãƒƒãƒ”ング 390 private final Map<String,List<String>> execKey2HtcnoArr = new LinkedHashMap<String,List<String>>(); 391 392 /** 393 * GE62åŠã?CB01èªå–データを追åŠ?—ã¾ã™ã? 394 * 395 * @param data GE62åŠã?CB01èªå–データ 396 */ 397 private void addData( final String[] data ) { 398 String kbRead = data[0]; 399 String readObj = data[1]; 400 String readPrm = data[2]; 401 String kbExec = data[3]; 402 String execDbid = data[4]; 403 String execObj = data[5]; 404 String execPrm = data[6]; 405 String errorSendto = data[7]; 406 String htcno = data[8]; 407 408 String tranKey = readObj; 409 tranSet.add( tranKey ); 410 411 // èªå–対象 + 実行方æ³?+ 実行対象 å˜ä½ã«å‡¦ç?¯¾è±¡é€šç•ªNOを集ç´?™ã‚? 412 String execKey = readObj + kbExec + execObj; 413 Set<String> execKeySet = tran2ExecKeySet.get( tranKey ); 414 if( execKeySet == null ) { 415 execKeySet = new LinkedHashSet<String>(); 416 } 417 execKeySet.add( execKey ); 418 tran2ExecKeySet.put( tranKey, execKeySet ); 419 420 // ä¼é?è¨å®šã‚ªãƒ–ジェクトã?マッãƒ? 421 TransferConfig conf = execKey2Conf.get( execKey ); 422 if( conf == null ) { 423 conf = new TransferConfig( 424 kbRead, readObj, readPrm 425 , kbExec, execDbid, execObj, execPrm 426 , errorSendto, HFROM, HTTP_PROXY_HOST, HTTP_PROXY_PORT ); 427 execKey2Conf.put( execKey, conf ); 428 } 429 430 // 通番NOã®ãƒžãƒƒãƒ? 431 List<String> htcnoArr = execKey2HtcnoArr.get( execKey ); 432 if( htcnoArr == null ) { 433 htcnoArr = new ArrayList<String>(); 434 } 435 htcnoArr.add( htcno ); 436 execKey2HtcnoArr.put( execKey, htcnoArr ); 437 } 438 439 /** 440 * トランザクション生æ?ã‚ー(èªå–対象)ã®ã‚»ãƒ?ƒˆã‚’è¿”ã—ã¾ã™ã? 441 * 442 * @return トランザクション生æ?ã‚ー(èªå–対象)ã®ã‚»ãƒ?ƒˆ 443 */ 444 private Set<String> getTranSet() { 445 return tranSet; 446 } 447 448 /** 449 * トランザクション生æ?ã‚ー(èªå–対象)ã«å¯¾ã™ã‚‹å‡¦ç?‚ー(èªå–対象+実行方æ³?実行対象)ã®ã‚»ãƒ?ƒˆã‚’è¿”ã—ã¾ã™ã? 450 * 451 * @param tranKey トランザクション生æ?ã‚ー(èªå–対象) 452 * @return トランザクション生æ?ã‚ー(èªå–対象)ã«å¯¾ã™ã‚‹å‡¦ç?‚ー(èªå–対象+実行方æ³?実行対象)ã®ã‚»ãƒ?ƒˆ 453 */ 454 private Set<String> getExecKeySet( final String tranKey ) { 455 return tran2ExecKeySet.get( tranKey ); 456 } 457 458 /** 459 * 処ç?‚ー(èªå–対象+実行方æ³?実行対象)ã«å¯¾ã™ã‚‹è¨å®šã‚ªãƒ–ジェクトを返ã—ã¾ã™ã? 460 * 461 * @param execKey 処ç?‚ー(èªå–対象+実行方æ³?実行対象) 462 * @return è¨å®šã‚ªãƒ–ジェクãƒ? 463 */ 464 private TransferConfig getConfig( final String execKey ) { 465 return execKey2Conf.get( execKey ); 466 } 467 468 /** 469 * 処ç?‚ー(èªå–対象+実行方æ³?実行対象)ã«å¯¾ã™ã‚‹é€šç•ªNO(é…å?)ã‚’è¿”ã—ã¾ã™ã? 470 * 471 * @param execKey 処ç?‚ー(èªå–対象+実行方æ³?実行対象) 472 * @return 通番NO(é…å?) 473 */ 474 private String[] getHtcno( final String execKey ) { 475 List<String> lst = execKey2HtcnoArr.get( execKey ); 476 if( lst == null ) { return new String[0]; } 477 // else { return lst.toArray( new String[0] ); } 478 else { return lst.toArray( new String[lst.size()] ); } 479 } 480 } 481 }