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.transfer;
017    
018    import java.io.File;
019    import java.io.PrintWriter;
020    
021    import org.opengion.fukurou.db.Transaction;
022    import org.opengion.fukurou.util.FileUtil;
023    import org.opengion.fukurou.util.HybsDateUtil;
024    import org.opengion.fukurou.util.StringUtil;
025    
026    /**
027     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縺ｮ繝??繧ｿ繧偵ヵ繧｡繧､繝ｫ縺ｫ譖ｸ霎ｼ縺ｿ縺励∪縺吶?
028     * 菴?＠縲∵嶌縺崎ｾｼ縺ｾ繧後ｋ繝??繧ｿ縺ｫ縺､縺?※縺ｯ縲∵立莨晞?繧ｷ繧ｹ繝?Β縺ｮ蠖｢蠑上→莠呈鋤諤ｧ繧呈戟縺溘○繧九◆繧√?
029     * 繝??繧ｿ縺ｮ蜑?0Byte縺ｫ遨ｺ逋ｽ縺ｧ蝓九ａ縲√＆繧峨↓蜈ｨ菴薙〒讓呎ｺ悶〒縺ｯ500Byte縺ｫ縺ｪ繧九ｈ縺?↓陦梧忰縺ｫ繧らｩｺ逋ｽ蝓九ａ繧偵＠縺ｾ縺吶?
030     * 500byte莉･螟悶↓縺励◆縺??蜷医?縲∵嶌縺崎ｾｼ縺ｿ繝代Λ繝｡繝ｼ繧ｿ縺ｮ隨ｬ?貞ｼ墓焚縺ｫ謨ｴ謨ｰ縺ｧ謖?ｮ壹＠縺ｦ縺上□縺輔＞縲?
031     * 
032     * 蜈磯?繝??繧ｿ縺ｫ髯舌▲縺ｦ縺ｯ縲√せ繝壹?繧ｹ莉･螟悶〒蝓九ａ繧倶ｺ九ｂ蜿ｯ閭ｽ縺ｧ縺吶?
033     * 縺昴?蝣ｴ蜷医?螳溯｡悟ｯｾ雎｡縺ｮ隨ｬ?貞ｼ墓焚縺九ｉ鬆?分縺ｫ
034     * 迥ｶ豕√さ繝ｼ繝?1byte)縲√ョ繝ｼ繧ｿ繧ｳ繝ｼ繝?1byte)縲??繧雁?(2byte)縲√ユ繧ｭ繧ｹ繝育ｨｮ蛻･(4byte) 騾√ｊ蜈?2byte)
035     * 繧呈欠螳壹＠縺ｦ縺上□縺輔＞縲?
036     * 騾√ｊ蜈?ｒ謖?ｮ壹＠縺溷?蜷医?繝?く繧ｹ繝医?蠕後↓8byte繧ｹ繝壹?繧ｹ+騾√ｊ蜈?26byte繧ｹ繝壹?繧ｹ+騾｣逡ｪ縲?ｒ莉伜刈縺励◆荳翫〒
037     * 陦梧忰縺ｮ遨ｺ逋ｽ蝓九ａ繧定｡後＞縺ｾ縺呻ｼ亥ｾ後ｍ70byte縺ｨ縺?≧謖?ｮ壹〒縺ｯ縺ｪ縺??縺ｧ豕ｨ諢擾ｼ?
038     *
039     * 譖ｸ霎ｼ縺ｿ縺吶ｋ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｮ溯｡悟ｯｾ雎｡縺ｧ謖?ｮ壹＠縺ｾ縺吶?繝輔ぃ繧､繝ｫ蜷阪?邨ｶ蟇ｾ繝代せ縺ｧ謖?ｮ壹＠縺ｦ荳九＆縺??
040     * 縺ｾ縺溘?譖ｸ霎ｼ縺吶ｋ繝?く繧ｹ繝医ヵ繧｡繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝峨?譖ｸ霎ｼ繝代Λ繝｡繝ｼ繧ｿ繝ｼ縺ｧ謖?ｮ壹☆繧九％縺ｨ縺後〒縺阪∪縺吶?
041     * 謖?ｮ壹＠縺ｪ縺??蜷医?UTF-8縺碁←逕ｨ縺輔ｌ縺ｾ縺吶?
042     *
043     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
044     *
045     * @version  5.0
046     * @author   Hiroki.Nakamura
047     * @since    JDK1.6
048     */
049    public class TransferExec_SAMCB implements TransferExec {
050    
051            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝?
052    //      private File fileWrite = null;                  // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
053    
054            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?
055    //      private String fileEncode = null;               // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
056    
057            /**
058             * 繝輔ぃ繧､繝ｫ縺ｫ譖ｸ霎ｼ縺ｿ縺励∪縺吶?
059             *
060             * @param vals 莨晞?繝??繧ｿ(驟榊?)
061             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
062             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
063             *
064             * @og.rev 5.5.3.3 (2012/06/15) close蜃ｦ逅?
065             * @og.rev 5.8.1.1 (2014/11/14) 繝代Λ繝｡繝ｼ繧ｿ縺ｧ譯∵焚謖?ｮ壼庄閭ｽ縺ｫ縺吶ｋ
066             * @og.rev 5.8.1.2 (2014/11/21) 蜑肴婿,蠕梧婿縺ｮ繧ｹ繝壹?繧ｹ蝓九ａ縺ｮ邂?園縺ｮ莠呈鋤諤ｧ繧剃ｸ翫￡繧?
067             */
068            @Override
069            public void execute( final String[] vals, final TransferConfig config, final Transaction tran ) {
070                    String fileEncode = "UTF-8";
071                    
072                    // 5.8.1.2
073                    String[] obj = StringUtil.csv2Array( config.getExecObj(), ' ' );
074    //              File fileWrite = new File( config.getExecObj() );
075                    File fileWrite = new File( obj[0] );
076                    String preText = "";
077                    String suffText = "";
078                    preText +=  ( obj.length > 1 ) ? obj[1] : ""; // 迥ｶ豕√さ繝ｼ繝?
079                    preText +=  ( obj.length > 2 ) ? obj[2] : ""; // 繝??繧ｿ繧ｳ繝ｼ繝?
080                    preText +=  ( obj.length > 3 ) ? StringUtil.stringFill( obj[3], 8, fileEncode ) : ""; // 繝帙せ繝?O
081                    preText +=  ( obj.length > 4 ) ? StringUtil.stringFill( obj[4], 4, fileEncode ) : ""; // 繝?く繧ｹ繝育ｨｮ蛻･
082                    preText = StringUtil.stringFill( preText, 14, fileEncode );
083                    if(obj.length > 1){
084                            preText += HybsDateUtil.getDate( "yyMMddHHmmss" );
085                            preText += HybsDateUtil.getDate( "MMdd" );
086                    }
087                    preText +=  ( obj.length > 4 ) ? StringUtil.stringFill( obj[4], 4, fileEncode ) : ""; // 繝?く繧ｹ繝育ｨｮ蛻･
088                    
089                    suffText +=  ( obj.length > 5 ) ? StringUtil.stringFill( "", 8, fileEncode ) + StringUtil.stringFill( obj[5], 28, fileEncode ) : ""; // 騾√ｊ蜈?
090                    
091                    // 5.8.1.1 (2014/11/14) fillByte霑ｽ蜉?
092                    int fillByte = 500;
093                    String execPrm = config.getExecPrm();
094                    if( execPrm != null && execPrm.length() > 0 ){
095                            String[] prm = StringUtil.csv2Array( execPrm, ' ' );
096                            fileEncode =  prm[0];
097                            if( prm.length > 1 ) {
098                                    fillByte = Integer.parseInt( prm[1] );
099                            }
100                    }
101    
102    //              String fileEncode = config.getExecPrm();
103    //              if( fileEncode == null || fileEncode.length() == 0 ) {
104    //                      fileEncode = "UTF-8";
105    //              }
106    
107                    PrintWriter writer = FileUtil.getPrintWriter( fileWrite,fileEncode );
108                    String line = null;
109                    // 5.8.1.2 (2014/11/21) i縺梧ｬｲ縺励＞縺ｮ縺ｧ譖ｸ縺肴婿繧貞､画峩縺吶ｋ
110    //              for( String s : vals ) {
111                    for (int i = 0; i < vals.length; i++){
112                            // 蜑?0Byte繧堤ｩｺ逋ｽ蝓九ａ 
113                            // 5.8.1.2 (2014/11/21) 蜑肴婿繧偵せ繝壹?繧ｹ莉･螟悶〒蝓九ａ繧峨ｌ繧九ｈ縺?↓縺吶ｋ
114    //                      String preSpace = StringUtil.stringFill( "", 30, fileEncode );
115                            String preSpace = StringUtil.stringFill( preText, 30, fileEncode );
116                            // 蜈ｨ菴薙〒500Byte縺ｫ縺ｪ繧九ｈ縺?↓蠕後ｍ縺ｫ遨ｺ逋ｽ蝓九ａ
117                            // 5.8.1.1 500Byte莉･螟悶ｂ謖?ｮ壼庄閭ｽ縺ｨ縺吶ｋ
118    //                      line = StringUtil.stringFill( preSpace + s, 500, fileEncode );
119    //                      line = StringUtil.stringFill( preSpace + s, fillByte, fileEncode );
120                            // 5.8.1.2 (2014/11/21)
121                            if(obj.length > 5){
122                                    line = StringUtil.stringFill( preSpace + vals[i] + suffText + StringUtil.intFill( Integer.toString( i ), 14 ), fillByte, fileEncode );
123                            }
124                            else{
125                                    line = StringUtil.stringFill( preSpace + vals[i] + suffText, fillByte, fileEncode );
126                            }
127                            
128                            writer.println( line );
129                    }
130                    writer.close(); // 5.5.3.3 (2012/06/15)
131            }
132    }