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.util.ArrayList;
019    import java.util.List;
020    
021    import org.opengion.fukurou.db.DBUtil;
022    import org.opengion.fukurou.db.Transaction;
023    import org.opengion.fukurou.util.ApplicationInfo;
024    import org.opengion.fukurou.util.StringUtil;
025    
026    /**
027     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縲∵立莨晞?DB縺ｮ繝??繧ｿ繧定ｪｭ蜿悶＠縺ｾ縺吶?
028     *
029     * 莨晞?螳夂ｾｩ繝槭せ繧ｿ縺ｮ隱ｭ蜿門ｯｾ雎｡縺ｯ縲∽ｻ･荳九?蠖｢蠑上〒螳夂ｾｩ縺吶ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
030     *   (繝??繧ｿ繧ｳ繝ｼ繝? (騾√ｊ蜈? (繝?く繧ｹ繝育ｨｮ蛻･)   萓?:"3 D9 B119"
031     * 蜃ｦ逅?ｮ溯｡悟ｾ後?縲∬ｪｭ縺ｿ蜿悶▲縺溘?繝?ム繝ｼ繝??繧ｿ縺ｮ迥ｶ豕√ｒ'2'縺ｫ譖ｴ譁ｰ縺励∪縺吶?
032     * 菴?＠縲∬ｪｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ"NOUPDATE"繧呈欠螳壹＠縺溷?蜷医?蜃ｦ逅?ｾ後?譖ｴ譁ｰ縺ｯ陦後ｏ繧後∪縺帙ｓ縲?
033     * 縺ｾ縺溘?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?繝倥ャ繝??繝??繧ｿ縺ｮ迥ｶ豕√ｒ'9'縺ｫ譖ｴ譁ｰ縺励∪縺吶?
034     *
035     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
036     *
037     * @version  5.0
038     * @author   Hiroki.Nakamura
039     * @since    JDK1.6
040     */
041    public class TransferRead_CB01 implements TransferRead {
042    
043            // 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO(驟榊?)
044            private String[] htcnoArr = null;
045    
046            /**
047             * 莨晞?繝??繧ｿ繧定ｪｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
048             *
049             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
050             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
051             *
052             * @return 隱ｭ縺ｿ蜿悶ｊ縺励◆繝??繧ｿ(驟榊?)
053             * @see #getKeys()
054             */
055            @Override
056            public String[] read( final TransferConfig config, final Transaction tran ) {
057                    htcnoArr = getHtcno( config, tran );
058                    return getData( htcnoArr, tran );
059            }
060    
061            /**
062             * 譌ｧ莨晞?DB繧呈､懃ｴ｢縺励?蟇ｾ雎｡縺ｮ騾夂分NO(驟榊?)繧定ｿ斐＠縺ｾ縺吶?
063             *
064             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
065             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
066             *
067             * @return 騾夂分NO(驟榊?)
068             */
069            private String[] getHtcno( final TransferConfig config, final Transaction tran ) {
070                    String readObj = config.getReadObj();
071                    String[] obj = StringUtil.csv2Array( readObj, ' ' );
072                    if( obj.length < 3 ) {
073                            String errMsg = "隱ｭ蜿門ｯｾ雎｡縺ｯ縲?繝??繧ｿ繧ｳ繝ｼ繝? (騾√ｊ蜈? (繝?く繧ｹ繝育ｨｮ蛻･) 縺ｮ蠖｢蠑上〒謖?ｮ壹＠縺ｦ荳九＆縺??[READOBJ=" + readObj + "]";
074                            throw new RuntimeException( errMsg );
075                    }
076                    String hcdd = obj[0];
077                    String hto = obj[1];
078                    String hsyu = obj[2];
079                    if( hcdd == null || hcdd.length() == 0
080                     || hto  == null || hto.length()  == 0
081                     || hsyu == null || hsyu.length() == 0 ) {
082                            String errMsg = "隱ｭ蜿門ｯｾ雎｡縺ｯ縲?繝??繧ｿ繧ｳ繝ｼ繝? (騾√ｊ蜈? (繝?く繧ｹ繝育ｨｮ蛻･) 縺ｯ蠢??縺ｧ縺吶?[READOBJ=" + readObj + "]";
083                            throw new RuntimeException( errMsg );
084                    }
085    
086                    StringBuilder buf = new StringBuilder();
087                    buf.append( "SELECT A.HTCNO" );
088                    buf.append( " FROM CB01 A" );
089                    buf.append( " WHERE A.HCDD = '" + hcdd + "'" );
090                    buf.append( " AND A.HTO = '" + hto + "'" );
091                    buf.append( " AND A.HSYU = '" + hsyu + "'" );
092                    buf.append( " AND A.HCDJ = '1'" );
093                    buf.append( " ORDER BY A.HTC" );
094    
095                    String[][] vals = DBUtil.dbExecute( buf.toString(),null,tran );
096                    List<String> hnoList = new ArrayList<String>();
097                    if( vals != null && vals.length > 0 ) {
098                            for( int row=0; row<vals.length; row++ ) {
099                                    hnoList.add( vals[row][0] );
100                            }
101                    }
102    
103    //              return hnoList.toArray( new String[0] );
104                    return hnoList.toArray( new String[hnoList.size()] );
105            }
106    
107            /**
108             * 蟇ｾ雎｡縺ｮ騾夂分NO縺ｫ蟇ｾ縺励※CB01繧定ｪｭ縺ｿ霎ｼ縺ｿ繝??繧ｿ繧帝?蛻励〒霑斐＠縺ｾ縺吶?
109             *
110             * @param htcnoArr 隱ｭ蜿門ｯｾ雎｡縺ｮ騾夂分NO(驟榊?)
111             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ
112             *
113             * @return 繝??繧ｿ(驟榊?)
114             */
115            private String[] getData( final String[] htcnoArr, final Transaction tran ) {
116                    if( htcnoArr == null || htcnoArr.length == 0 ) { return new String[0]; }
117    
118                    String htcnos = StringUtil.array2csv( htcnoArr );
119                    StringBuilder buf = new StringBuilder();
120                    buf.append( "SELECT A.HTEXT" );
121                    buf.append( " FROM CB01 A" );
122                    buf.append( " WHERE A.HCDJ = '5'" );
123                    buf.append( " AND A.HTCNO IN (" );
124                    buf.append( htcnos );
125                    buf.append( ") ORDER BY A.HTC, A.HTCNO" );
126    
127                    String[][] vals = DBUtil.dbExecute( buf.toString(),null,tran );
128                    String[] rtn = new String[vals.length];
129                    for( int i=0; i<vals.length; i++ ) {
130                            rtn[i] = vals[i][0];
131                    }
132                    return rtn;
133            }
134    
135            /**
136             * 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO(驟榊?)繧定ｿ斐＠縺ｾ縺吶?
137             *
138             * @og.rev 5.5.2.4 (2012/05/16) 驟榊?繧定ｿ斐☆蝣ｴ蜷医?縲∝?驛ｨ陦ｨ迴ｾ繧呈垓髴ｲ縺励↑縺?ｈ縺?↓縲…lone 繧定ｿ斐＠縺ｾ縺吶?
139             *
140             * @return 騾夂分NO(驟榊?)
141             */
142            @Override
143            public String[] getKeys() {
144    //              return htcnoArr;
145                    String[] rtn = null ;
146                    if( htcnoArr != null ) { rtn = htcnoArr.clone(); }
147                    return rtn ;
148            }
149    
150            /**
151             * 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO(驟榊?)繧偵そ繝?ヨ縺励∪縺吶?
152             *
153             * @og.rev 5.5.2.4 (2012/05/16) 蜿ら?縺ｮ譬ｼ邏阪↓縺ｯ縲ヾystem.arraycopy 繧剃ｽｿ縺?∪縺吶?
154             *
155             * @param keys 騾夂分NO(驟榊?)
156             */
157            @Override
158            public void setKeys( final String[] keys ) {
159    //              htcnoArr = keys;
160                    if( keys != null ) {
161                            int size = keys.length ;
162                            htcnoArr = new String[size];
163                            System.arraycopy( keys,0,htcnoArr,0,size );
164                    }
165                    else {
166                            htcnoArr = null;
167                    }
168            }
169    
170            /**
171             * 隱ｭ蜿悶＠縺滉ｼ晞?繝??繧ｿ縺ｮ繝倥ャ繝??繝??繧ｿ縺ｮ迥ｶ豕√ｒ'2'(謚懷?貂医∩)縺ｫ譖ｴ譁ｰ縺励∪縺吶?
172             * 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO縺ｫ縺､縺?※縺ｯ縲＋@link #setKeys(String[])}縺ｧ螟夜Κ縺九ｉ繧ｻ繝?ヨ縺吶ｋ縺薙→繧ゅ〒縺阪∪縺吶?
173             *
174             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
175             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
176             * @see #setKeys(String[])
177             */
178            @Override
179            public void complete( final TransferConfig config, final Transaction tran ) {
180                    if( htcnoArr == null || htcnoArr.length == 0 ) { return; }
181                    // 隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ"NOUPDATE"縺梧欠螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲，B01縺ｮ迥ｶ豕√ｒ譖ｴ譁ｰ縺励↑縺?
182                    if( "NOUPDATE".equalsIgnoreCase( config.getReadPrm() ) ) { return; }
183    
184                    String htcnos = StringUtil.array2csv( htcnoArr );
185                    StringBuilder buf = new StringBuilder();
186                    buf.append( "UPDATE CB01 A" );
187                    buf.append( " SET A.HCDJ = '2'" );
188                    buf.append( " WHERE A.HCDJ = '1'" );
189                    buf.append( " AND A.HTCNO IN (" );
190                    buf.append( htcnos );
191                    buf.append( ")" );
192    
193                    DBUtil.dbExecute( buf.toString(),null,tran );
194            }
195    
196            /**
197             * 隱ｭ蜿悶＠縺滉ｼ晞?繝??繧ｿ縺ｮ繝倥ャ繝??繝??繧ｿ縺ｮ迥ｶ豕√ｒ'9'(繧ｨ繝ｩ繝ｼ)縺ｫ譖ｴ譁ｰ縺励∪縺吶?
198             * 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO縺ｫ縺､縺?※縺ｯ縲＋@link #setKeys(String[])}縺ｧ螟夜Κ縺九ｉ繧ｻ繝?ヨ縺吶ｋ縺薙→繧ゅ〒縺阪∪縺吶?
199             *
200             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
201             * @param appInfo DB謗･邯壽ュ蝣ｱ
202             * @see #setKeys(String[])
203             */
204            @Override
205            public void error( final TransferConfig config, final ApplicationInfo appInfo ) {
206                    if( htcnoArr == null || htcnoArr.length == 0 ) { return; }
207    
208                    String htcnos = StringUtil.array2csv( htcnoArr );
209                    StringBuilder buf = new StringBuilder();
210                    buf.append( "UPDATE CB01 A" );
211                    buf.append( " SET A.HCDJ = '9'" );
212                    buf.append( " WHERE A.HCDJ in ('1','2')" ); // 譌｢縺ｫ螳溯｡訓G縺ｧ謚懷?貂医∩縺ｫ譖ｴ譁ｰ縺輔ｌ縺ｦ縺?ｋ蜿ｯ閭ｽ諤ｧ縺後≠繧?
213                    buf.append( " AND A.HTCNO IN (" );
214                    buf.append( htcnos );
215                    buf.append( ")" );
216    
217                    DBUtil.dbExecute( buf.toString(),null,appInfo ); // 繧ｨ繝ｩ繝ｼ譖ｴ譁ｰ縺ｯ繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧貞?縺代※蜃ｦ逅?☆繧?
218            }
219    
220    }