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.hayabusa.report;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.fukurou.util.StringUtil;
020    import org.opengion.fukurou.util.Shell;
021    import org.opengion.fukurou.util.ApplicationInfo;
022    import org.opengion.fukurou.db.DBUtil;
023    
024    /**
025     * 縲舌Ξ繝昴?繝亥?蜉帙?DBTableModel繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ繝ｬ繝昴?繝亥ｽ｢蠑上↓霑秘ｄ縺吶ｋ繧ｿ繧ｰ繝ｪ繝悶け繝ｩ繧ｹ縺ｧ縺吶?
026     * 縺薙?繧ｪ繝悶ず繧ｧ繧ｯ繝医↓縲?繝??繧ｿ(DBTableModel)縺ｨ縲√さ繝ｳ繝医Ο繝ｼ繝ｩ(DBTableReport 繧ｯ繝ｩ繧ｹ)繧剃ｸ弱∴縺ｦ縲?
027     * 螟夜Κ縺九ｉ繧ｳ繝ｳ繝医Ο繝ｼ繝ｫ縺吶ｋ縺薙→縺ｧ縲∝推遞ｮ蠖｢蠑上〒 繝??繧ｿ(DBTableModel)繧定｡ｨ遉ｺ縺輔○繧九％縺ｨ縺?
028     * 蜿ｯ閭ｽ縺ｧ縺吶?
029     *
030     * 蜷?ｱ樊?縺ｯ縲＋&#064;XXXX} 螟画焚縺御ｽｿ逕ｨ縺ｧ縺阪∪縺吶?
031     * 縺薙ｌ縺ｯ縲ヾervletRequest 縺九ｉ縲』xxx 繧偵く繝ｼ縺ｫ蛟､繧貞叙繧雁?縺?縺薙?螟画焚縺ｫ
032     * 蜑ｲ繧雁ｽ薙※縺ｾ縺吶?縺､縺ｾ繧翫?縺薙?xxxx繧偵く繝ｼ縺ｫ繝ｪ繧ｯ繧ｨ繧ｹ繝医☆繧後?縲?
033     * 縺薙?螟画焚縺ｫ蛟､繧偵そ繝?ヨ縺吶ｋ縺薙→縺後〒縺阪∪縺吶?
034     *
035     * http://localhost/query.jsp?KEY1=VLA1&amp;KEY2=VAL2
036     *
037     * 縺ｮ繧医≧縺ｪ繝ｪ繧ｯ繧ｨ繧ｹ繝医〒縲＋&#064;KEY1} 縺ｨ縺吶ｌ縺ｰ縲?VAL1 縺後そ繝?ヨ縺輔ｌ縺ｾ縺吶?
038     *
039     * @og.group 蟶ｳ逾ｨ繧ｷ繧ｹ繝?Β
040     *
041     * @version  4.0
042     * @author   Kazuhiko Hasegawa
043     * @since    JDK5.0,
044     */
045    public class ReportPrint {
046            // 3.6.1.0 (2005/01/05) Shell 縺ｮ 繧ｿ繧､繝?い繧ｦ繝医ｒ險ｭ螳?
047            private final int TIMEOUT = HybsSystem.sysInt( "REPORT_DAEMON_TIMEOUT" );
048    
049            private static final String CR     = HybsSystem.CR ;
050            private final StringBuilder errMsg = new StringBuilder();
051    
052            private final String    SYSTEM_ID       ;
053            private final String    YKNO            ;
054            private final String    PRTID           ;
055            private       String    PRTNM           ;
056            private final String    programFile     ;
057            private final String    htmlDir         ;
058            private final String    modelFile       ;
059            private final String    pdfFile         ;
060            private final String    DMN_GRP         ;               // 3.8.0.5 (2005/08/26)
061            private final boolean   DEBUG           ;       // 3.8.5.0 (2006/03/06) 繝?ヰ繝?げ逕ｨ縺ｮ繝輔Λ繧ｰ繧定ｿｽ蜉?
062    
063            private String          shellCmd        = null;
064    
065            // GE55 縺ｮ繝励Μ繝ｳ繧ｿ蜷阪ｒ蜿門ｾ励☆繧鬼QL譁?〒縺吶?
066            // 4.0.0 (2005/01/31) 蜈ｱ譛?system_id 繧偵?閠??
067            private static final String GE55_SELECT =
068                    "SELECT PRTNM,SYSTEM_ID" +
069                    " FROM GE55" +
070                    " WHERE FGJ = '1'" +
071                    " AND  SYSTEM_ID IN (?,'**')" +
072                    " AND  PRTID = ?" ;
073    
074            private static final int GE55_PRTNM             = 0;
075            private static final int GE55_SYSTEM_ID = 1;
076    
077            /** 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｫ繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ諠??繧定ｿｽ險倥☆繧九°縺ｩ縺?°謖?ｮ?*/
078            public static final boolean USE_DB_APPLICATION_INFO  = HybsSystem.sysBool( "USE_DB_APPLICATION_INFO" ) ;
079    
080            // 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
081            private final ApplicationInfo appInfo;
082            private final String DBID = HybsSystem.sys( "RESOURCE_DBID" );          // 5.5.5.1 (2012/08/07) 繝ｪ繧ｽ繝ｼ繧ｹ邉ｻDBID 莉倥￠蠢倥ｌ蟇ｾ蠢?
083    
084            /**
085             * 繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ
086             *
087             * @og.rev 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
088             *
089             * @param system_id 繧ｷ繧ｹ繝?ΒID
090             * @param ykno 隕∵ｱら分蜿ｷ
091             * @param prtId 繝励Μ繝ｳ繧ｿ繝ｼID
092             * @param prgFile 螳溯｡後?繝ｭ繧ｰ繝ｩ繝?D
093             * @param inDir 繝ｬ繝昴?繝亥?蜉帙ョ繧｣繝ｬ繧ｯ繝医Μ
094             * @param mdlFile 繝?Φ繝昴Λ繝ｪ繝ｼ繝輔ぃ繧､繝ｫ
095             * @param outFile 蜃ｺ蜉帙ヵ繧｡繧､繝ｫ蜷?
096             * @param dmnGrp  繝??繝｢繝ｳ繧ｰ繝ｫ繝ｼ繝?
097             * @param debug 繝?ヰ繝?げ繝輔Λ繧ｰ
098             */
099            public ReportPrint( final String system_id, final String ykno, final String prtId,
100                                                    final String prgFile,final String inDir,String mdlFile,
101                                                    final String outFile,final String dmnGrp,final boolean debug ) {
102                    SYSTEM_ID       = system_id;
103                    YKNO            = ykno;
104                    PRTID           = prtId;
105                    programFile     = prgFile ;
106                    htmlDir         = inDir ;
107                    modelFile       = mdlFile ; // 4.0.1.0 (2007/12/18)
108                    pdfFile         = outFile ;
109                    DMN_GRP         = dmnGrp;                               // 3.8.0.5 (2005/08/26)
110                    DEBUG           = debug;
111    
112                    // 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
113                    if( USE_DB_APPLICATION_INFO ) {
114                            appInfo = new ApplicationInfo();
115                            // 繝ｦ繝ｼ繧ｶ繝ｼID,IP繧｢繝峨Ξ繧ｹ,繝帙せ繝亥錐
116                            appInfo.setClientInfo( SYSTEM_ID,HybsSystem.HOST_ADRS,HybsSystem.HOST_NAME );
117                            // 逕ｻ髱｢ID,謫堺ｽ?繝励Ο繧ｰ繝ｩ繝?D
118                            appInfo.setModuleInfo( "ReportPrint",YKNO,PRTID );
119                    }
120                    else {
121                            appInfo = null;
122                    }
123            }
124    
125            /**
126             * 繝ｬ繝昴?繝亥?蜉帛?逅?ｒ螳溯｡後＠縺ｾ縺吶?
127             *
128             * @return 邨先棡 [true:豁｣蟶ｸ/false:逡ｰ蟶ｸ]
129             */
130            public boolean execute() {
131                    System.out.print( "ReportPrint Started ... " );
132                    boolean flag ;
133    
134                    try {
135                            flag = initialDataSet();
136                            if( flag ) { System.out.print( "INIT," ); }
137    
138                            if( flag ) {
139                                    flag = makeShellCommand();
140                                    if( flag ) { System.out.print( "SHELL," ); }
141                            }
142    
143                            if( flag ) {
144                                    flag = programRun();
145                                    if( flag ) { System.out.print( "RUN," ); }
146                                    // 3.8.5.3 (2006/06/30) 蟶ｳ逾ｨ蜃ｦ逅?ｮ溯｡梧凾繧ｨ繝ｩ繝ｼ縺ｮ蜀榊ｮ溯｡?
147            //                      else {
148            //                              System.out.println();
149            //                              System.out.println( "蟶ｳ逾ｨ蜊ｰ蛻ｷ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲ゅΜ繝医Λ繧､縺励∪縺吶?" );
150            //                              System.out.println( "YKNO=[" + YKNO + "],PRTID=[" + PRTID + "],DMN_GRP=[" + DMN_GRP + "]" );
151            //                              System.out.println();
152            //                              flag = programRun();
153            //                              if( flag ) { System.out.print( "RUN 2," ); }
154            //                              else {
155            //                                      System.out.println( "蟶ｳ逾ｨ蜊ｰ蛻ｷ繝ｪ繝医Λ繧､縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲?KNO=[" + YKNO + "]" );
156            //                              }
157            //                      }
158                            }
159                    }
160                    catch ( RuntimeException ex ) {
161                            errMsg.append( "ReportPrint Execute Error! " ).append( CR ) ;
162                            errMsg.append( "==============================" ).append( CR );
163                            errMsg.append( StringUtil.stringStackTrace( ex ) ) ;
164                            errMsg.append( CR ) ;
165                            flag = false;
166                    }
167    
168                    System.out.println( "End." );
169                    return flag ;
170            }
171    
172            /**
173             * 蛻晄悄繝??繧ｿ繧ｻ繝?ヨ繧定｡後＞縺ｾ縺吶?
174             * 縺薙％縺ｧ縺ｯ縲；E55 繝??繝悶Ν繧医ｊ蠢?ｦ√↑諠??繧貞叙蠕励＠縺ｾ縺吶?
175             *
176             * @og.rev 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
177             * @og.rev 5.5.5.1 (2012/08/07) 繝ｪ繧ｽ繝ｼ繧ｹ邉ｻDBID 莉倥￠蠢倥ｌ蟇ｾ遲?
178             *
179             * @return 邨先棡 [true:豁｣蟶ｸ/false:逡ｰ蟶ｸ]
180             */
181            private boolean initialDataSet() {
182                    if( PRTID == null ) {
183                            errMsg.append( "PRTID columns does not exist in GE55 table." ).append( CR );
184                            errMsg.append( "==============================" ).append( CR );
185                            errMsg.append( "SYSTEM_ID=[" ).append( SYSTEM_ID ).append( "] , " );
186                            errMsg.append( "PRTID=["     ).append( PRTID     ).append( "]" );
187                            errMsg.append( CR );
188                            return false;
189                    }
190    
191                    String[] args = new String[] { SYSTEM_ID,PRTID };
192                    // prtnm,system_id
193    //              String[][] vals = DBUtil.dbExecute( GE55_SELECT,args,appInfo );                 // 3.8.7.0 (2006/12/15)
194                    String[][] vals = DBUtil.dbExecute( GE55_SELECT,args,appInfo, DBID );   // 5.5.5.1 (2012/08/07)
195                    if( vals == null || vals.length == 0 ) {
196                            errMsg.append( "Data does not exist in GE55 table." ).append( CR );
197                            errMsg.append( "==============================" ).append( CR );
198                            errMsg.append( "SYSTEM_ID=[" ).append( SYSTEM_ID ).append( "] , " );
199                            errMsg.append( "PRTID=["     ).append( PRTID     ).append( "]" );
200                            errMsg.append( CR );
201                            return false;
202                    }
203    
204                    int row = 0;
205                    // 讀懃ｴ｢邨先棡縺瑚､?焚蟶ｰ縺｣縺溘→縺阪?SYSTEM_ID 縺?謖?ｮ壹＆繧後※縺?ｋ譁ｹ縺ｮ繝??繧ｿ(陦?繧呈治逕ｨ縺吶ｋ縲?
206                    for( int i=0; i<vals.length; i++ ) {
207                            if( SYSTEM_ID.equalsIgnoreCase( vals[i][GE55_SYSTEM_ID] ) ) { row = i; break; }
208                    }
209    
210                    PRTNM = StringUtil.nval( vals[row][GE55_PRTNM],PRTNM );
211    
212                    if( DEBUG ) {
213                            System.out.println( "SYSTEM_ID   =" + SYSTEM_ID   );
214                            System.out.println( "YKNO        =" + YKNO        );
215                            System.out.println( "PRTID       =" + PRTID       );
216                            System.out.println( "PRTNM       =" + PRTNM       );
217                            System.out.println( "programFile =" + programFile );
218                            System.out.println( "htmlDir     =" + htmlDir     );
219                            System.out.println( "pdfFile     =" + pdfFile     );
220                            System.out.println( "DMN_GRP     =" + DMN_GRP     );
221                            System.out.println( "GE55_SELECT =" + GE55_SELECT );
222                    }
223    
224                    return true;
225            }
226    
227            /**
228             * 繧ｷ繧ｧ繝ｫ繧ｳ繝槭Φ繝峨?譁?ｭ怜?繧剃ｽ懈?縺励∪縺吶?
229             *
230             * @og.rev 3.8.0.5 (2005/08/26) 蠑墓焚縺ｫ繝??繝｢繝ｳ繧ｰ繝ｫ繝ｼ繝励ｒ霑ｽ蜉?
231             * @og.rev 3.8.0.8 (2005/10/03) 繝??繝｢繝ｳ繧ｰ繝ｫ繝ｼ繝励?繝?ヵ繧ｩ繝ｫ繝亥?險ｭ螳?
232             * @og.rev 4.0.1.0 (2007/12/18) 蟶ｳ逾ｨ縺ｮ繝?Φ繝昴Λ繝ｪ繝ｼ繝輔ぃ繧､繝ｫ繧定ｿｽ蜉?
233             *
234             * @return 邨先棡 [true:豁｣蟶ｸ/false:逡ｰ蟶ｸ]
235             */
236            private boolean makeShellCommand() {
237                    StringBuilder buf = new StringBuilder( HybsSystem.BUFFER_SMALL );
238    
239                    buf.append( programFile ).append( " " );                // 螳溯｡後☆繧九さ繝槭Φ繝?
240                    buf.append( "\"" ).append( htmlDir ).append( HybsSystem.FS );           // 蜈･蜉姨TML繝輔ぃ繧､繝ｫ
241                    buf.append( YKNO ).append( "_*.html\" " );              // 蜈･蜉姨TML繝輔ぃ繧､繝ｫ
242                    buf.append( "\"" ).append( PRTNM ).append( "\" " );     // 繝励Μ繝ｳ繧ｿ蜷?
243                    if( pdfFile != null ) {
244                            buf.append( "\"" ).append( pdfFile ).append( "\" " );           // PDF繝輔ぃ繧､繝ｫ蜷?
245                    }
246                    else {
247                            // 繝?Α繝ｼ繝輔ぃ繧､繝ｫ繧呈欠螳壹☆繧句ｿ?ｦ√′縺ゅｋ縲?
248                            buf.append( "\"" ).append( htmlDir ).append( HybsSystem.FS );
249                            buf.append( YKNO ).append( ".xls\" " );         // 繝?Α繝ｼ蜃ｺ蜉帙ヵ繧｡繧､繝ｫ
250                    }
251    
252                    // 3.8.5.0 (2006/03/06) EXCEL繧偵が繝ｼ繝励Φ縺吶ｋ繝輔ぃ繧､繝ｫ蜷阪↓隕∵ｱら分蜿ｷ繧剃ｽｿ縺?
253    //              buf.append( YKNO ).append( " " );
254                    if( modelFile != null ) { // 4.0.1.0 (2007/12/18)
255                            buf.append( modelFile ).append( " " );          // 繝｢繝?Ν繝輔ぃ繧､繝ｫ蜷?4)
256                    }
257                    else {
258                            buf.append( "DMY_MDL" ).append( " " );          // 繝?Α繝ｼ繝｢繝?Ν繝輔ぃ繧､繝ｫ蜷?4)
259                    }
260    
261                    // 3.8.5.0 (2006/03/06) DMN_GRP縺ｯ蠢??
262                    buf.append( DMN_GRP ).append( " " );            // 繝??繝｢繝ｳ繧ｰ繝ｫ繝ｼ繝?
263    
264                    buf.append( PRTID );            // 繝励Μ繝ｳ繧ｿID(縺薙?蜷榊燕.pdf 縺ｧPDF繝輔ぃ繧､繝ｫ縺御ｽ懈?縺輔ｌ繧九?)
265    
266                    shellCmd = buf.toString();
267                    System.out.println( CR + shellCmd + CR );
268    
269                    return true;
270            }
271    
272            /**
273             * 螳滄圀縺ｮ繝ｬ繝昴?繝亥?蜉帛?逅?ｒ陦後＞縺ｾ縺吶?
274             *
275             * @og.rev 3.1.9.0 (2003/05/16) Shell 縺ｸ縺ｮ stdout 縺ｨ stderr 縺ｮ蜿門ｾ苓ｨｭ螳壹?蟒?ｭ｢縲４hellTag 縺ｧ縺ｯ縲∵怏蜉ｹ縲?
276             * @og.rev 3.6.1.0 (2005/01/05) Shell 縺ｮ 繧ｿ繧､繝?い繧ｦ繝医ｒ險ｭ螳?
277             *
278             * @return 邨先棡 [true:豁｣蟶ｸ/false:逡ｰ蟶ｸ]
279             */
280            private boolean programRun() {
281                    Shell shell = new Shell();
282                    shell.setCommand( shellCmd,true );              // BATCH繝励Ο繧ｻ繧ｹ縺ｧ螳溯｡後☆繧?
283                    shell.setWait( true );                                  // 繝励Ο繧ｻ繧ｹ縺ｮ邨ゆｺ?ｒ蠕?▽
284                    shell.setTimeout( TIMEOUT );                    // 3.6.1.0 (2005/01/05) Shell 縺ｮ 繧ｿ繧､繝?い繧ｦ繝医ｒ險ｭ螳?
285    
286                    int rtnCode = shell.exec();                             // 0 縺ｯ豁｣蟶ｸ邨ゆｺ?ｒ遉ｺ縺?
287    
288                    if( rtnCode != 0 ) {
289                            errMsg.append( "Shell Command exequte Error." ).append( CR );
290                            errMsg.append( "==============================" ).append( CR );
291                            errMsg.append( shellCmd ).append( CR );
292                            errMsg.append( shell.getStdoutData() ).append( CR );
293                            errMsg.append( shell.getStderrData() ).append( CR );
294                            errMsg.append( CR );
295                            return false;
296                    }
297    
298                    return true;
299            }
300    
301            /**
302             * 繧ｨ繝ｩ繝ｼ縺悟ｭ伜惠縺励◆蝣ｴ蜷医↓縲√お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ繧定ｿ斐＠縺ｾ縺吶?
303             *
304             * @return 繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ String
305             */
306            public String getErrMsg() {
307                    return errMsg.toString();
308            }
309    }