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.fukurou.util;
017    
018    import java.io.File;
019    import java.io.IOException;
020    
021    /**
022     * AbstractConnect.java 縺ｯ縲∝?騾夂噪縺ｫ菴ｿ逕ｨ縺輔ｌ繧?繝輔ぃ繧､繝ｫ莨晞?髢｢騾｣縺ｮ蝓ｺ譛ｬ讖溯?繧貞ｮ溯｣?＠縺溘?Abstract繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
023     *
024     * -host=繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?繧貞ｿ??險ｭ螳壹＠縺ｾ縺吶?
025     * -localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｿ??縺ｧ縺ｯ縺ゅｊ縺ｾ縺帙ｓ縺後?-command=DEL 縺ｮ蝣ｴ蜷医↓縺ｮ縺ｿ荳崎ｦ√〒縺ゅｊ縲?
026     * 縺昴ｌ莉･螟悶? command 縺ｮ蝣ｴ蜷医?縲∝ｿ?ｦ√〒縺吶?
027     *
028     * -command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] 縺ｯ縲√し繝ｼ繝舌?縺ｫ蟇ｾ縺励※縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
029     *   GET:繧ｵ繝ｼ繝舌?縺九ｉ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝輔ぃ繧､繝ｫ霆｢騾√＠縺ｾ縺?蛻晄悄蛟､)
030     *   PUT:繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧偵し繝ｼ繝舌?縺ｫ PUT(STORE縲ヾAVE縲ゞPLOAD縲√↑縺ｩ縺ｨ蜷梧э隱?縺励∪縺吶?
031     *   DEL:繧ｵ繝ｼ繝舌?縺ｮ謖?ｮ壹?繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?縺薙?蝣ｴ蜷医?縺ｿ縲?localFile 螻樊?縺ｮ謖?ｮ壹?荳崎ｦ√〒縺吶?
032     *   GETDIR,PUTDIR,DELDIR:謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
033     *
034     * -mkdirs=[true/false] 縺ｯ縲∝女縺大?縺ｮ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ蜿悶ｊ霎ｼ繧?ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺?
035     * 蟄伜惠縺励↑縺??蜷医↓縲∽ｽ懈?縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
036     * 騾壼ｸｸ縲√し繝ｼ繝舌?縺ｫ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｽ懈?縺励※PUT縺吶ｋ蝣ｴ蜷医?蜍慕噪縺ｫ繝輔か繝ｫ繝?嚴螻､繧剃ｽ懈?縺励◆縺?こ繝ｼ繧ｹ縺ｧ萓ｿ蛻ｩ縺ｧ縺吶?
037     * 騾?↓縲√ヵ繧ｩ繝ｫ繝??遒ｺ螳壹＠縺ｦ縺翫ｊ縲∵欠螳壹ヵ繧ｩ繝ｫ繝?ｻ･螟悶↓ PUT 縺吶ｋ縺ｮ縺ｯ繝舌げ縺｣縺ｦ縺?ｋ縺ｨ莠九′蛻?°縺｣縺ｦ縺?ｋ蝣ｴ蜷医↓縺ｯ
038     * false 縺ｫ險ｭ螳壹＠縺ｦ縲∝ｭ伜惠縺励↑縺?ヵ繧ｩ繝ｫ繝?↓PUT 縺励ｈ縺?→縺吶ｋ縺ｨ縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧九ｈ縺?↓縺励∪縺吶?
039     *
040     * 蠑墓焚譁?ｭ怜?荳ｭ縺ｫ遨ｺ逋ｽ繧貞性繧??蜷医?縲√ム繝悶Ν繧ｳ繝ｼ繝??繧ｷ繝ｧ繝ｳ("") 縺ｧ諡ｬ縺｣縺ｦ荳九＆縺??
041     * 蠑墓焚譁?ｭ怜?縺ｮ 縲?縲上?蜑榊ｾ後↓縺ｯ縲∫ｩｺ逋ｽ縺ｯ謖溘ａ縺ｾ縺帙ｓ縲ょｿ?★縲?key=value 縺ｮ讒倥↓
042     * 郢九￡縺ｦ縺上□縺輔＞縲?
043     *
044     * @og.formSample
045     *  XXXConnect -host=繧ｵ繝ｼ繝舌? -user=繝ｦ繝ｼ繧ｶ繝ｼ -passwd=繝代せ繝ｯ繝ｼ繝?-remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?[-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江
046     *                   [-command=[GET/PUT/DEL/GETDIR/PUTDIR/DELDIR] ] [-display=[true/false] ] 繝ｻ繝ｻ繝ｻ繝ｻ
047     *
048     *    -host=繧ｵ繝ｼ繝舌?                    ?壽磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?縺ｮ繧｢繝峨Ξ繧ｹ縺ｾ縺溘?縲√し繝ｼ繝舌?蜷?
049     *    -user=繝ｦ繝ｼ繧ｶ繝ｼ                    ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ蜷?
050     *    -passwd=繝代せ繝ｯ繝ｼ繝?               ?壽磁邯壹☆繧九Θ繝ｼ繧ｶ繝ｼ縺ｮ繝代せ繝ｯ繝ｼ繝?
051     *    -remoteFile=謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?   ?壽磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺洲TP蛛ｴ縺ｨ縺励※謖?ｮ壹＠縺ｾ縺吶?
052     *   [-localFile=繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷江  ?壹Ο繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷阪?PUT,GET 髢｢菫ゅ↑縺上Ο繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧呈欠螳壹＠縺ｾ縺吶?
053     *   [-port=繝昴?繝?]                    ?壽磁邯壹☆繧九し繝ｼ繝舌?縺ｮ繝昴?繝医ｒ謖?ｮ壹＠縺ｾ縺吶?
054     *   [-command=[GET/PUT/DEL] ]          ?壹し繝ｼ繝舌?蛛ｴ縺ｧ縺ｮ蜃ｦ逅??譁ｹ豕輔ｒ謖?ｮ壹＠縺ｾ縺吶?
055     *             [GETDIR/PUTDIR/DELDIR]]          GET:FTP竍鱈OCAL縲￣UT:LOCAL竍巽TP 縺ｸ縺ｮ霆｢騾√〒縺?蛻晄悄蛟､:GET)
056     *                                              DEL:FTP繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?
057     *                                              GETDIR,PUTDIR,DELDIR 謖?ｮ壹?繝輔か繝ｫ繝?ｻ･荳九?繝輔ぃ繧､繝ｫ繧貞?逅?＠縺ｾ縺吶?
058     *   [-mkdirs=[true/false]  ]           ?壼女縺大?繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true)
059     *                                              (false:繝?ぅ繝ｬ繧ｯ繝医Μ縺檎┌縺代ｌ縺ｰ縲√お繝ｩ繝ｼ縺ｫ縺励∪縺吶?)
060     *   [-encode=繧ｨ繝ｳ繧ｳ繝ｼ繝牙錐 ]            ?壽律譛ｬ隱槭ヵ繧｡繧､繝ｫ蜷阪↑縺ｩ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝牙錐繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:Windows-31J)
061     *   [-timeout=繧ｿ繧､繝?い繧ｦ繝?遘綻 ]       ?咼ata繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
062     *   [-display=[false/true] ]           ?嗾rue縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
063     *   [-debug=[false|true]   ]           ?壹ョ繝舌ャ繧ｰ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?蛻晄悄蛟､:false[陦ｨ遉ｺ縺励↑縺Ь)
064     *
065     * @og.rev 5.1.6.0 (2010/05/01) 譁ｰ隕剰ｿｽ蜉?
066     *
067     * @version  5.0
068     * @author       Kazuhiko Hasegawa
069     * @since    JDK5.0,
070     */
071    public abstract class AbstractConnect implements ConnectIF {
072            public static final String CR = System.getProperty("line.separator");
073            private final StringBuilder errMsg = new StringBuilder( 200 );
074    
075            /** 豁｣蟶ｸ繝輔Λ繧ｰ  {@value} */
076            public static final boolean FLAG_OK = true;
077            /** 逡ｰ蟶ｸ繝輔Λ繧ｰ  {@value} */
078            public static final boolean FLAG_NG = false;
079            /** Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:{@value} [遘綻) */
080            public static final int         TIMEOUT = 600 ;
081    
082            /** 繧ｵ繝ｼ繝舌? */
083            protected String        host            = null;                 // 繧ｵ繝ｼ繝舌?
084            /** 繝ｦ繝ｼ繧ｶ繝ｼ */
085            protected String        user            = null;                 // 繝ｦ繝ｼ繧ｶ繝ｼ
086            /** 繝代せ繝ｯ繝ｼ繝?*/
087            protected String        passwd          = null;                 // 繝代せ繝ｯ繝ｼ繝?
088            /** 繝昴?繝?*/
089            protected String        port            = null;                 // 繝昴?繝?
090    
091            /** 繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?° */
092            protected boolean       isMkdirs        = true;                 // 蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ / false:辟｡縺代ｌ縺ｰ繧ｨ繝ｩ繝ｼ
093            /** Data繧ｿ繧､繝?い繧ｦ繝? */
094            protected int           timeout         = TIMEOUT;              // Data繧ｿ繧､繝?い繧ｦ繝?蛻晄悄蛟､:600 [遘綻)
095            /** 讀懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺吶ｋ縺九←縺?°  */
096            protected boolean       isDisplay       = false;                // true縺ｯ縲∵､懃ｴ｢迥ｶ豕√ｒ陦ｨ遉ｺ縺励∪縺?蛻晄悄蛟､:false)
097            /** 繝?ヰ繝?げ諠??繧定｡ｨ遉ｺ縺吶ｋ縺九←縺?°  */
098            protected boolean       isDebug         = false;                // 繝?ヰ繝?げ諠??繧呈ｨ呎ｺ門?蜉帙↓陦ｨ遉ｺ縺吶ｋ(true)縺九＠縺ｪ縺?false)縺?
099    
100            /**
101             * 繧ｵ繝ｼ繝舌?縺ｸ縺ｮ謗･邯壹?繝ｭ繧ｰ繧､繝ｳ繧定｡後＞縺ｾ縺吶?
102             */
103            @Override
104            public abstract void connect() ;
105    
106            /**
107             * command , localFile , remoteFile 繧貞?縺ｫ縲：TP蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
108             *
109             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲…onnect( String , String , String )繝｡繧ｽ繝?ラ縲√♀繧医?縲?
110             * paramInit() 螳溯｡悟ｾ後↓縲∝他縺ｳ蜃ｺ縺吝ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
111             *
112             * @param       command GET:HOST竍鱈OCAL 縲￣UT:LOCAL竍辿OST 縲．EL:HOST繝輔ぃ繧､繝ｫ繧貞炎髯､
113             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
114             * @param       remoteFile      HOST謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
115             * @throws RuntimeException
116             */
117            @Override
118            public void action( final String command, final String localFile, final String remoteFile ) {
119                    String rmtFile = remoteFile.replace( '\\','/' );
120                    if( isDisplay ) {
121                            System.out.println( "ACTION: command=" + command + ",localFile=" + localFile + ",remoteFile=" + rmtFile );
122                    }
123    
124                    try {
125                            // 螳滄圀縺ｮ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?(GET/PUT/DEL)
126                            if( "GET".equals( command ) ) {
127                                    actionGET( localFile, rmtFile );
128                            }
129                            else if( "PUT".equals( command ) ) {
130                                    actionPUT( localFile, rmtFile );
131                            }
132                            else if( "DEL".equals( command ) ) {
133                                    actionDEL( rmtFile );
134                            }
135                            else if( "GETDIR".equals( command ) ) {
136                                    actionGETdir( localFile, rmtFile );
137                            }
138                            else if( "PUTDIR".equals( command ) ) {
139                                    actionPUTdir( localFile, rmtFile );
140                            }
141                            else if( "DELDIR".equals( command ) ) {
142                                    actionDELdir( rmtFile );
143                            }
144                            else {
145                                    errAppend( "command縺ｯ縲；ET/PUT/DEL/GETDIR/PUTDIR/DELDIR 縺九ｉ謖?ｮ壹￥縺?＆縺??" );
146                                    errAppend( "   command    = [" , command , "]" );
147                                    throw new RuntimeException(  getErrMsg() );
148                            }
149                    }
150                    catch( Exception ex ) {
151                            errAppend( "Server action Error." );
152                            errAppend( "   command    = [" , command        , "]" );
153                            errAppend( "   localFile  = [" , localFile      , "]" );
154                            errAppend( "   remoteFile = [" , remoteFile , "]" );
155                            errAppend( ex.getMessage() );
156                            if( isDebug ) { ex.printStackTrace(); }
157                            throw new RuntimeException( getErrMsg(),ex );
158                    }
159            }
160    
161            /**
162             * 繧ｵ繝ｼ繝舌?縺ｨ縺ｮ謗･邯壹ｒ繧ｯ繝ｭ繝ｼ繧ｺ縺励∪縺吶?
163             *
164             * 繝ｭ繧ｰ繧､繝ｳ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縲√Ο繧ｰ繧｢繧ｦ繝医ｂ陦後＞縺ｾ縺吶?
165             * 繧ｳ繝阪け繝医＆繧後※縺?ｋ蝣ｴ蜷医?縲√ョ繧｣繧ｹ繧ｳ繝阪け繝医＠縺ｾ縺吶?
166             */
167            @Override
168            public abstract void disconnect();
169    
170            /**
171             * command="GET" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
172             *
173             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ繝ｭ繝ｼ繧ｫ繝ｫ縺ｫ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
174             *
175             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
176             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
177             * @throws Exception
178             */
179            protected abstract void actionGET( final String localFile, final String remoteFile ) throws Exception ;
180    
181            /**
182             * command="GETDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
183             *
184             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ莉･荳九ｒ繝ｭ繝ｼ繧ｫ繝ｫ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ髫主ｱ､讒矩?縺ｮ縺ｾ縺ｾ繝?え繝ｳ繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
185             *
186             * @param       localDir        繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
187             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
188             * @throws IOException
189             */
190            protected abstract void actionGETdir( final String localDir, final String remoteDir ) throws Exception ;
191    
192            /**
193             * command="PUT" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
194             *
195             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ繧偵?謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｫ繧｢繝??繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
196             *
197             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
198             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
199             * @throws Exception
200             */
201            protected abstract void actionPUT( final String localFile, final String remoteFile ) throws Exception ;
202    
203            /**
204             * command="PUTDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
205             *
206             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ莉･荳九ｒ縲∵磁邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ髫主ｱ､讒矩?縺ｮ縺ｾ縺ｾ繧｢繝??繝ｭ繝ｼ繝峨＠縺ｾ縺吶?
207             *
208             * @og.rev 5.3.7.0 (2011/07/01) 繝輔か繝ｫ繝?↓繧｢繧ｯ繧ｻ繧ｹ縺ｧ縺阪↑縺??蜷医?縲√お繝ｩ繝ｼ繧定ｿ斐＠縺ｾ縺吶?
209             *
210             * @param       localDir        繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
211             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
212             * @throws Exception
213             */
214            protected void actionPUTdir( final String localDir, final String remoteDir ) throws Exception {
215                    File[] lclFiles = new File( localDir ).listFiles();
216    
217                    // 5.3.7.0 (2011/07/01) 繝輔か繝ｫ繝?↓繧｢繧ｯ繧ｻ繧ｹ縺ｧ縺阪↑縺??蜷医?縲√お繝ｩ繝ｼ繧定ｿ斐＠縺ｾ縺吶?
218                    if( lclFiles == null ) {
219                            errAppend( "謖?ｮ壹?繝?ぅ繝ｬ繧ｯ繝医Μ縺ｯ縲√い繧ｯ繧ｻ繧ｹ縺ｧ縺阪∪縺帙ｓ縲? );
220                            errAppend( "   localDir   = [" , localDir       , "]" );
221                            throw new RuntimeException( getErrMsg() );
222                    }
223    
224                    for( int i=0; i<lclFiles.length; i++ ) {
225                            String lcl = lclFiles[i].getName();
226                            if( lclFiles[i].isDirectory() ) {
227                                    actionPUTdir( addFile( localDir,lcl ),addFile( remoteDir,lcl ) );
228                            }
229                            else {
230                                    actionPUT( addFile( localDir,lcl ),addFile( remoteDir,lcl ) );
231                            }
232                    }
233            }
234    
235            /**
236             * command="DEL" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
237             *
238             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ蜑企勁縺励∪縺吶?
239             *
240             * @param       remoteFile      謗･邯壼?縺ｮ繝輔ぃ繧､繝ｫ蜷?
241             * @throws Exception
242             */
243            protected abstract void actionDEL( final String remoteFile ) throws Exception ;
244    
245            /**
246             * command="DELDIR" 縺梧欠螳壹＆繧後◆縺ｨ縺阪?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
247             *
248             * 謗･邯壼?縺ｮ繧ｵ繝ｼ繝舌?蛛ｴ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷阪ｒ蜑企勁縺励∪縺吶?
249             *
250             * @param       remoteDir       謗･邯壼?縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
251             * @throws Exception
252             */
253            protected abstract void actionDELdir( final String remoteDir ) throws Exception ;
254    
255            /**
256             * 繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺励∪縺吶?
257             *
258             * 蠑墓焚縺ｮ繝輔ぃ繧､繝ｫ蜷阪?縲√ヵ繧｡繧､繝ｫ蜷阪〒縺吶?菴懈?縺吶ｋ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｯ縲√◎縺ｮ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝医?
259             * getParentFile() 縺ｧ蜿門ｾ励＆繧後ｋ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｾ縺ｧ繧剃ｽ懈?縺励∪縺吶?
260             *
261             * @param       localFile       繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?
262             * @throws IOException , RuntimeException
263             */
264            protected void makeLocalDir( final String localFile ) throws IOException {
265                    File fileDir = new File( localFile ).getCanonicalFile().getParentFile();
266                    if( !fileDir.exists() ) {
267                            if( ! fileDir.mkdirs() ) {
268                                    errAppend( "繝ｭ繝ｼ繧ｫ繝ｫ繝輔ぃ繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｮ菴懈?縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲? );
269                                    errAppend( "   localFile   = [" , localFile     , "]" );
270                                    throw new RuntimeException( getErrMsg() );
271                            }
272                    }
273            }
274    
275            /**
276             * 繝?ぅ繝ｬ繧ｯ繝医Μ縺ｨ繝輔ぃ繧､繝ｫ蜷阪ｒ蜷域?縺励∪縺吶?
277             *
278             * 蜊倡ｴ斐↓縲√ョ繧｣繝ｬ繧ｯ繝医Μ縺ｮ譛?ｾ後→縲√ヵ繧｡繧､繝ｫ縺ｮ譛??縺ｮ縲?/" 繧偵メ繧ｧ繝?け縺励?
279             * 蟄伜惠縺吶ｌ縺ｰ縲√◎縺ｮ縺ｾ縺ｾ縲∫ｵ仙粋縺励?蟄伜惠縺励↑縺代ｌ縺ｰ縲?/" 繧定ｿｽ蜉?＠縺ｾ縺吶?
280             * 荳｡譁ｹ縺ｫ蟄伜惠縺吶ｋ蝣ｴ蜷医?縲∫援譁ｹ繧偵?縺壹＠縺ｾ縺吶?
281             *
282             * @param       dir     繝?ぅ繝ｬ繧ｯ繝医Μ蜷?
283             * @param       file    繝輔ぃ繧､繝ｫ蜷?
284             *
285             * @return      蜷域?縺輔ｌ縺溘ヵ繧｡繧､繝ｫ蜷?
286             */
287            protected String addFile( final String dir,final String file ) {
288                    final String filepath ;
289    
290                    char ch1 = dir.charAt( dir.length()-1 ) ;       // 繝?ぅ繝ｬ繧ｯ繝医Μ縺ｮ譛?ｾ後?譁?ｭ?
291                    char ch2 = file.charAt( 0 ) ;                           // 繝輔ぃ繧､繝ｫ縺ｮ譛??縺ｮ譁?ｭ?
292    
293                    if( ch1 == '/' || ch1 == '\\' ) {
294                            if( ch2 == '/' || ch2 == '\\' ) {       // 荳｡譁ｹ縺ｨ繧ょｭ伜惠縺吶ｋ縲?
295                                    filepath = dir + file.substring(1);
296                            }
297                            else {
298                                    filepath = dir + file;
299                            }
300                    }
301                    else {
302                            if( ch2 == '/' || ch2 == '\\' ) {       // 迚?婿縺ｮ縺ｿ蟄伜惠縺吶ｋ縲?
303                                    filepath = dir + file;
304                            }
305                            else {
306                                    filepath = dir + "/" + file;
307                            }
308                    }
309    
310                    return filepath ;
311            }
312    
313            /**
314             * 繧ｵ繝ｼ繝舌?縺ｮ縲√?繧ｹ繝医?繝ｦ繝ｼ繧ｶ繝ｼ縲√ヱ繧ｹ繝ｯ繝ｼ繝峨ｒ險ｭ螳壹＠縺ｾ縺吶?
315             *
316             * @param       host    繧ｵ繝ｼ繝舌?
317             * @param       user    繝ｦ繝ｼ繧ｶ繝ｼ
318             * @param       passwd  繝代せ繝ｯ繝ｼ繝?
319             */
320            @Override
321            public void setHostUserPass( final String host , final String user , final String passwd ) {
322                    this.host = host;
323                    this.user = user;
324                    this.passwd = passwd;
325            }
326    
327            /**
328             * 繧ｵ繝ｼ繝舌?蜷阪ｒ蜿門ｾ励＠縺ｾ縺吶?
329             *
330             * @return      繧ｵ繝ｼ繝舌?
331             */
332    //      protected String getHost() { return host; }
333    
334            /**
335             * 繝ｦ繝ｼ繧ｶ繝ｼ蜷阪ｒ蜿門ｾ励＠縺ｾ縺吶?
336             *
337             * @return      繝ｦ繝ｼ繧ｶ繝ｼ
338             */
339    //      protected String getUser() { return user; }
340    
341            /**
342             * 繝代せ繝ｯ繝ｼ繝峨ｒ蜿門ｾ励＠縺ｾ縺吶?
343             *
344             * @return      繝代せ繝ｯ繝ｼ繝?
345             */
346    //      protected String getPassword() { return passwd; }
347    
348            /**
349             * 謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ繧定ｨｭ螳壹＠縺ｾ縺吶?
350             *
351             * @param       port    謗･邯壹↓蛻ｩ逕ｨ縺吶ｋ繝昴?繝育分蜿ｷ
352             */
353            @Override
354            public void setPort( final String port ) {
355                    if( port != null ) {
356                            this.port = port ;
357                    }
358            }
359    
360            /**
361             * 繝昴?繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
362             * 險ｭ螳壹＆繧後※縺?ｋ逕溘?port螻樊?(null繧ゅ≠繧翫≧繧?繧定ｿ斐＠縺ｾ縺吶?
363             *
364             * @return      繝昴?繝?
365             */
366            protected String getPort() { return port; }
367    
368            /**
369             * 繝昴?繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
370             * 險ｭ螳壹＆繧後※縺?ｋport螻樊?縺後?null縺ｮ蝣ｴ蜷医?縲‥efPort繧定ｿ斐＠縺ｾ縺吶?
371             *
372             * @param       defPort port 縺?null 縺ｮ蝣ｴ蜷医?蛻晄悄蛟､
373             *
374             * @return      繝昴?繝?
375             */
376            protected int getPort( final int defPort) {
377                    return ( port == null ) ? defPort : Integer.parseInt( port );
378            }
379    
380            /**
381             * 縺昴ｌ縺槭ｌ縺ｮ蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°(蛻晄悄蛟､:true:菴懈?縺吶ｋ)縲?
382             *
383             * -mkdirs=[true/false] 縺ｯ縲∝女縺大?縺ｮ繝輔ぃ繧､繝ｫ(GET譎?LOCAL縲￣UT譎?繧ｵ繝ｼ繝舌?)縺ｫ蜿悶ｊ霎ｼ繧?ヵ繧｡繧､繝ｫ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺?
384             * 蟄伜惠縺励↑縺??蜷医↓縲∽ｽ懈?縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
385             * 騾壼ｸｸ縲√し繝ｼ繝舌?縺ｫ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｽ懈?縺励※PUT縺吶ｋ蝣ｴ蜷医?蜍慕噪縺ｫ繝輔か繝ｫ繝?嚴螻､繧剃ｽ懈?縺励◆縺?こ繝ｼ繧ｹ縺ｧ萓ｿ蛻ｩ縺ｧ縺吶?
386             * 騾?↓縲√ヵ繧ｩ繝ｫ繝??遒ｺ螳壹＠縺ｦ縺翫ｊ縲∵欠螳壹ヵ繧ｩ繝ｫ繝?ｻ･螟悶↓ PUT 縺吶ｋ縺ｮ縺ｯ繝舌げ縺｣縺ｦ縺?ｋ縺ｨ莠九′蛻?°縺｣縺ｦ縺?ｋ蝣ｴ蜷医↓縺ｯ
387             * false 縺ｫ險ｭ螳壹＠縺ｦ縲∝ｭ伜惠縺励↑縺?ヵ繧ｩ繝ｫ繝?↓PUT 縺励ｈ縺?→縺吶ｋ縺ｨ縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧九ｈ縺?↓縺励∪縺吶?
388             *
389             * @param       isMkdirs        蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ
390             */
391            @Override
392            public void setMkdirs( final boolean isMkdirs ) {
393                    this.isMkdirs = isMkdirs ;
394            }
395    
396            /**
397             * 蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°繧貞叙蠕励＠縺ｾ縺吶?
398             *
399             * @return      蜿励￠蛛ｴ繝輔ぃ繧､繝ｫ縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧剃ｽ懈?縺吶ｋ縺九←縺?°縲Ｕrue:菴懈?縺吶ｋ
400             */
401    //      protected boolean isMkdirs() { return isMkdirs; }
402    
403            /**
404             * 繧ｿ繧､繝?い繧ｦ繝医ｒ遘偵〒謖?ｮ壹＠縺ｾ縺?蛻晄悄蛟､:600 [遘綻)縲?
405             *
406             * 繧ｪ繝ｪ繧ｸ繝翫Ν縺ｮ FTPClient#setDataTimeout( int ) 縺ｯ縲√Α繝ｪ遘偵〒繧ｻ繝?ヨ
407             * 縺励∪縺吶′縲√％縺薙?繝｡繧ｽ繝?ラ縺ｧ縺ｯ縲∫ｧ偵〒繧ｻ繝?ヨ縺励∪縺吶?
408             *
409             * @param       timeout 繧ｿ繧､繝?い繧ｦ繝?遘綻
410             * @throws RuntimeException 繧ｿ繧､繝?い繧ｦ繝医?謖?ｮ壹′螟ｧ縺阪☆縺弱◆蝣ｴ蜷?
411             */
412            @Override
413            public void setTimeout( final int timeout ) {
414                    if( Integer.MAX_VALUE / 1000 < timeout ) {
415                            errAppend( "繧ｿ繧､繝?い繧ｦ繝医?謖?ｮ壹′螟ｧ縺阪☆縺弱∪縺吶?" );
416                            errAppend( "   timeout   = [" , timeout , "]" );
417                            throw new RuntimeException( getErrMsg() );
418                    }
419    
420                    this.timeout = timeout ;
421            }
422    
423            /**
424             *謖?ｮ壹＆繧後◆繧ｿ繧､繝?い繧ｦ繝医ｒ遘偵〒蜿門ｾ励＠縺ｾ縺?蛻晄悄蛟､:600 [遘綻)縲?
425             *
426             * @return      繧ｿ繧､繝?い繧ｦ繝?遘綻
427             */
428    //      protected int getTimeout() { return timeout; }
429    
430            /**
431             * 螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ 繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false:陦ｨ遉ｺ縺励↑縺?縲?
432             *
433             * @param       isDisplay       螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ
434             */
435            @Override
436            public void setDisplay( final boolean isDisplay ) {
437                    this.isDisplay = isDisplay ;
438            }
439    
440            /**
441             * 螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ繧貞叙蠕励＠縺ｾ縺吶?
442             *
443             * @return      螳溯｡檎憾豕√?陦ｨ遉ｺ蜿ｯ蜷ｦ
444             */
445    //      protected boolean isDisplay() { return isDisplay; }
446    
447            /**
448             * 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ 繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false:陦ｨ遉ｺ縺励↑縺?縲?
449             *
450             * @param       isDebug 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ
451             */
452            @Override
453            public void setDebug( final boolean isDebug ) {
454                    this.isDebug = isDebug ;
455            }
456    
457            /**
458             * 繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ 繧貞叙蠕励＠縺ｾ縺吶?
459             *
460             * @return      繝?ヰ繝?げ諠??縺ｮ陦ｨ遉ｺ蜿ｯ蜷ｦ
461             */
462    //      protected boolean isDebug() { return isDebug; }
463    
464            /**
465             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧偵そ繝?ヨ縺励∪縺吶?
466             *
467             * @param       msg  繝｡繝?そ繝ｼ繧ｸ蛹悶＠縺溘＞繧ｪ繝悶ず繧ｧ繧ｯ繝?
468             */
469            protected void errAppend( final Object msg ) {
470                    errMsg.append( String.valueOf(msg) ).append( CR );
471            }
472    
473            /**
474             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧偵そ繝?ヨ縺励∪縺吶?
475             *
476             * @param       msgs  Object...
477             */
478            protected void errAppend( final Object... msgs ) {
479                    for( int i=0; i<msgs.length; i++ ) {
480                            errMsg.append( String.valueOf(msgs[i]) );
481                    }
482    
483                    errMsg.append( CR );
484            }
485    
486            /**
487             * 蜃ｦ逅?ｸｭ縺ｫ逋ｺ逕溘＠縺溘お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧貞叙繧雁?縺励∪縺吶?
488             *
489             * @return      繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ
490             */
491            @Override
492            public String getErrMsg() {
493                    return errMsg.toString();
494            }
495    }