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蝗槭〒繧ゅお繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?縲∝酔縺倩ｪｭ蜿門ｯｾ雎｡縺ｧ縺昴ｌ縺ｾ縺ｧ縺ｫ蜃ｦ逅?＠縺溷?縺ｫ縺､縺?※繧Ｓollback縺輔ｌ縺ｾ縺吶?
053     *
054     * 縺ｾ縺溘?縺薙?莨晞?繝??繝｢繝ｳ(隱ｭ蜿匁婿豕?縺ｯ縲∵立莨晞?DB(CB01)縺ｫ蟇ｾ縺吶ｋ繧ｯ繧ｨ繝ｪ蝗樊焚繧呈ｸ帙ｉ縺吶◆繧√?譌ｧ莨晞?DB(CB01)縺ｨ
055     * 莨晞?螳夂ｾｩ繝槭せ繧ｿ(GE62)繧谷OIN縺励※荳?峡縺ｧ繝??繧ｿ繧貞叙蠕励＠縺ｦ縺?∪縺吶?
056     * 縺薙?縺溘ａ縲∽ｻ悶?莨晞?繝??繝｢繝ｳ(隱ｭ蜿匁婿豕?縺ｨ縺ｯ隱ｭ蜿夜Κ蛻??螳溯｣?婿豕輔′逡ｰ縺ｪ縺｣縺ｦ縺?∪縺吶?
057     * 蜈ｷ菴鍋噪縺ｫ縺ｯ縲＋@link org.opengion.fukurou.transfer.TransferRead}繧､繝ｳ繧ｿ繝ｼ繝輔ぉ繝ｼ繧ｹ繧貞茜逕ｨ縺帙★縺ｫ縲?
058     * 縺薙?繝??繝｢繝ｳ閾ｪ菴薙↓隱ｭ蜿門所縺ｳ繧ｹ繝??繧ｿ繧ｹ譖ｴ譁ｰ縺ｮ蜃ｦ逅?ｒ螳溯｣?＠縺ｦ縺?∪縺吶?
059     *
060     * 窶ｻ蜃ｦ逅?ｸｭ縺ｫ菴輔ｉ縺九?繧ｨ繝ｩ繝ｼ縺?蠎ｦ縺ｧ繧ら匱逕溘＠縺溷?蜷医?縺薙?繝??繝｢繝ｳ縺ｯ蛛懈ｭ｢縺励∪縺吶?
061     *
062     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｯ縲？ybsTimerTask 繧堤ｶ呎価縺励◆ 繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
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縺ｨ莨晞?螳夂ｾｩ繝槭せ繧ｿ繧谷OIN縺励※讀懃ｴ｢)
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 = "莨晞?隱ｭ蜿悶お繝ｩ繝ｼ?咼MN_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"縺梧欠螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲，B01縺ｮ迥ｶ豕√ｒ譖ｴ譁ｰ縺励↑縺?
251                                            if( "NOUPDATE".equalsIgnoreCase( conf.getReadPrm() ) ) {
252                                                    isUpdate = false;
253                                            }
254                                    }
255    
256                                    // 蟇ｾ雎｡縺ｨ縺ｪ繧九?繧ｹ繧ｿ縺ｮ蜀??隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ?代▽縺ｧ繧?NOUPDATE"縺梧欠螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲，B01縺ｮ迥ｶ豕√ｒ譖ｴ譁ｰ縺励↑縺?
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 = "莨晞?繧ｨ繝ｩ繝ｼ?咼MN_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')" ); // 譌｢縺ｫ螳溯｡訓G縺ｧ謚懷?貂医∩縺ｫ譖ｴ譁ｰ縺輔ｌ縺ｦ縺?ｋ蜿ｯ閭ｽ諤ｧ縺後≠繧?
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    }