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    
021    import org.opengion.fukurou.mail.MailReceiveListener ;
022    import org.opengion.fukurou.mail.MailTX ;
023    import org.opengion.fukurou.mail.MailMessage ;
024    import org.opengion.fukurou.mail.MailAttachFiles ;
025    
026    import java.util.Date;
027    
028    /**
029     * MailReceiveListener 縺ｮ螳溯｣?け繝ｩ繧ｹ縺ｧ縺吶?
030     * MailRX 繧ｯ繝ｩ繧ｹ縺ｫ繧ｻ繝?ヨ縺吶ｋ縺薙→縺ｧ縲√Γ繝ｼ繝ｫ?台ｻｶ縺斐→縺ｫ receive( MailMessage ) 繝｡繧ｽ繝?ラ縺?
031     * 蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
032     * 繝｡繝ｼ繝ｫ?台ｻｶ縺ｫ縲∵ｷｻ莉倥ヵ繧｡繧､繝ｫ縺瑚､?焚逋ｻ骭ｲ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?蜃ｦ逅?ｒ陦後▲縺ｦ縺?∪縺吶?
033     * 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺斐→縺ｫ隕∵ｱら分蜿ｷ繧呈治逡ｪ縺励※縲∬ｦ∵ｱら分蜿ｷ.xls 縺ｨ縺励※繧ｻ繝ｼ繝悶＠縲∝ｸｳ逾ｨ隕∵ｱゅユ繝ｼ繝悶Ν縺ｫ
034     * 譖ｸ縺崎ｾｼ縺ｿ縺ｾ縺吶?
035     *
036     * @og.rev 3.8.0.0 (2005/06/07) 譁ｰ隕剰ｿｽ蜉?
037     * @og.group 蟶ｳ逾ｨ繧ｷ繧ｹ繝?Β
038     *
039     * @version  4.0
040     * @author   Kazuhiko Hasegawa
041     * @since    JDK5.0,
042     */
043    public class ExcelInsertReceiveListener implements MailReceiveListener {
044    
045            // EXCEL蜿冶ｾｼ譎ゅ↓菴ｿ逕ｨ縺吶ｋ繝?Φ繝昴Λ繝ｪ繝輔か繝ｫ繝?錐縲ゅヵ繧｡繧､繝ｫ蜷阪?縲∬ｦ∵ｱら分蜿ｷ.xls
046            private final String EXCELIN_URL =
047                    HybsSystem.url2dir( StringUtil.nval(
048                                                                    HybsSystem.sys( "EXCEL_IN_FILE_URL" ) ,
049                                                                    HybsSystem.sys( "FILE_URL"   ) + "EXCELIN/" ) ) ;
050    
051            private GE50Access ge50 = null;
052    
053            /**
054             * 繝｡繝ｼ繝ｫ蜿嶺ｿ｡蜃ｦ逅?〒縲?ｼ代Γ繝ｼ繝ｫ蜿嶺ｿ｡縺斐→縺ｫ蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
055             * 蜃ｦ逅?ｵ先棡繧偵?boolean 縺ｧ霑斐＠縺ｾ縺吶?
056             *
057             * @param message MailMessage繧ｪ繝悶ず繧ｧ繧ｯ繝?
058             *
059             * @return      蜃ｦ逅?ｵ先棡(豁｣蟶ｸ:true / 逡ｰ蟶ｸ:false)
060             */
061            public boolean receive( final MailMessage message ) {
062                    System.out.println();
063                    System.out.println( "Receive " + new Date() );
064    
065                    String errMsg ;
066                    boolean okFlag = false;
067    
068                    // 豈主屓 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ讒狗ｯ峨＠縺ｾ縺吶?逋ｻ骭ｲ譌･莉倥′蛻晄悄蛹悶＆繧後∪縺吶?
069                    ge50 = new GE50Access( "CXXXXX","M_RECEIVE","ExcelInsert" );
070    
071                    try {
072                            String from             = message.getHeader( "From" );
073                            String subject  = message.getSubject();
074                            String content  = message.getContent();
075                            String msgid    = message.getMessageID();
076                            String comments = from + " " + subject + " " + msgid ;
077    
078                            String systemId = getContentParam( content,"SYSTEM_ID" );
079                            if( systemId == null ) {
080                                    errMsg = "繝｡繝ｼ繝ｫ譛ｬ譁?↓ SYSTEM_ID=[xx] 縺ｮ繧ｭ繝ｼ繝ｯ繝ｼ繝峨′蟄伜惠縺励∪縺帙ｓ縲? ;
081                                    errorReport( message,errMsg ) ;
082                                    return okFlag;
083                            }
084    
085                            System.out.println( " From:" + from );
086                            String joken = getContentParam( content,"JOKEN" );
087                            if( joken == null ) { joken = "EXCELIN"; }
088    
089                            ge50.setSystemId( systemId );
090                            ge50.setJoken   ( joken );
091                            ge50.setComments( comments );
092    
093                            MailAttachFiles attFiles = new MailAttachFiles( message.getMessage() );
094                            String[] files = attFiles.getNames();
095                            if( files == null || files.length == 0 ) {
096                                    errMsg = "繝｡繝ｼ繝ｫ縺ｫ EXCEL 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺悟ｭ伜惠縺励∪縺帙ｓ縲? ;
097                                    errorReport( message,errMsg ) ;
098                                    return okFlag;
099                            }
100    
101                            // 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺ｮ謨ｰ縺?￠蜃ｦ逅?＠縺ｾ縺吶?
102                            for( int i=0; i<files.length; i++ ) {
103                                    String ykno    = ge50.makeYkno();               // 譁ｰ縺溘↑隕∵ｱら分蜿ｷ縺悟?驛ｨ縺ｫ繧ゅそ繝?ヨ縺輔ｌ繧九?
104                                    String file    = ykno + ".xls" ;
105                                    String attFile = files[i];
106    
107                                    // LISTID 繧貞叙蠕励＠縺ｾ縺吶? EXCEL繝輔ぃ繧､繝ｫ蜷阪↓(蟶ｳ逾ｨID)繧貞?繧後∪縺吶?
108                                    int st = attFile.indexOf( '(' );
109                                    int ed = attFile.indexOf( ')',st );
110                                    if( st < 0 || ed < 0 ) {
111                                            errMsg = "EXCEL 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺ｫ(蟶ｳ逾ｨID)縺悟ｭ伜惠縺励∪縺帙ｓ縲?" + attFile + "]" ;
112                                            errorReport( message,errMsg ) ;
113                                            return okFlag;
114                                    }
115    
116                                    String listId  = attFile.substring( st+1,ed );
117                                    if( listId.length() == 0 ) {
118                                            errMsg = "EXCEL 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺ｮ(蟶ｳ逾ｨID)繧貞?繧雁?縺帙∪縺帙ｓ縲?" + attFile + "]" ;
119                                            errorReport( message,errMsg ) ;
120                                            return okFlag;
121                                    }
122    
123                                    String fileDir = EXCELIN_URL + systemId + "/" + listId + "/" ;
124    
125                                    attFiles.saveFileName( fileDir,file,i );
126    
127                                    ge50.setListId( listId );
128                                    ge50.setOutDir( fileDir );
129                                    ge50.setOutFile( files[i] );
130    
131                                    ge50.insertGE50( GE50Access.FG_SET );
132    
133                                    System.out.println( attFile + " -> " + file );
134                            }
135                            System.out.println( " End." );
136                            okFlag = true;
137                    }
138                    catch( Throwable ex ) {
139                            errMsg = StringUtil.stringStackTrace( ex );
140                            errorReport( message,errMsg ) ;
141                            okFlag = false;
142                    }
143                    return okFlag;
144            }
145    
146            /**
147             * 繝｡繝ｼ繝ｫ蜃ｦ逅?ｸｭ縺ｫ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
148             * 蜃ｦ逅??縲?ｼ鍋ｨｮ鬘槭≠繧翫∪縺吶?
149             * ?托ｼ弱お繝ｩ繝ｼ繝｡繝ｼ繝ｫ繧偵?EXCELIN_URL/ERROR_MAIL 繝輔か繝ｫ繝?↓縲√Γ繝?そ繝ｼ繧ｸID.txt 縺ｧ菫晏ｭ倥＠縺ｾ縺吶?
150             * ?抵ｼ擦OMMON_MAIL_SERVER 縺ｨ ERROR_MAIL_TO_USERS 縺瑚ｨｭ螳壹＆繧後※縺?ｋ蝣ｴ蜷医↓縲?
151             *     縺昴?縺ゅ※蜈医↓縲∬ｿ比ｿ｡繝｡繝ｼ繝ｫ繧帝?菫｡縺励∪縺吶?
152             * ?難ｼ雑E50(蟶ｳ逾ｨ隕∵ｱゅユ繝ｼ繝悶Ν)縺ｨ縲；E51(蟶ｳ逾ｨ繧ｨ繝ｩ繝ｼ繝??繝悶Ν)縺ｫ繧ｨ繝ｩ繝ｼ迥ｶ豕√ｒ譖ｸ縺崎ｾｼ縺ｿ縺ｾ縺吶?
153             *
154             * @param message MailMessage繧ｪ繝悶ず繧ｧ繧ｯ繝?
155             * @param errorMessage 繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ
156             */
157            private void errorReport( final MailMessage message,final String errorMessage ) {
158                    // 繧ｨ繝ｩ繝ｼ繝｡繝ｼ繝ｫ繧?謇?ｮ壹?繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ蜃ｺ蜉帙＠縺ｾ縺吶?
159                    message.saveSimpleMessage( EXCELIN_URL + "/ERROR_MAIL/" );
160    
161                    String subject          = "EXCEL蜿冶ｾｼ繝｡繝ｼ繝ｫ蜿嶺ｿ｡荳ｭ縺ｫ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?;
162                    String org_from         = message.getHeader( "From" ) ;
163                    String ord_subject      = message.getSubject();
164                    String content          = message.getContent();
165                    String errMsg = subject + HybsSystem.CR
166                                            + " Subject=" + ord_subject + " From=" + org_from + HybsSystem.CR
167                                            + " MessageID=" + message.getMessageID() + HybsSystem.CR
168                                            + " Save ErrorMail=" + EXCELIN_URL + "/ERROR_MAIL/" + HybsSystem.CR
169                                            + errorMessage + HybsSystem.CR
170                                            + "==========================================================="
171                                            + HybsSystem.CR
172                                            + content ;
173    
174                    if( ge50 != null ) {
175                            String systemId = ge50.getSystemId() ;
176                            if( systemId == null ) { ge50.setSystemId( "ERR" ); }
177    
178                            // 繧ｨ繝ｩ繝ｼ譎ゅ?隕∵ｱら分蜿ｷ縺ｯ縲∵眠縺溘↓謗｡逡ｪ縺励↑縺翫＠縺ｾ縺吶?
179                            ge50.makeYkno();
180    
181                            ge50.insertGE50( GE50Access.FG_ERR2 );
182                            ge50.insertErrorGE56( errMsg );
183                    }
184    
185                    // host 縺ｨ user 縺ｮ繝｡繝ｼ繝ｫ騾∽ｿ｡蜈医′險倩ｿｰ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縲√Γ繝ｼ繝ｫ縺ｧ繧りｻ｢騾√☆繧九?
186                    String   host = message.getHost();
187                    String   from = message.getUser();
188    
189                    if( host != null && from != null ) {
190                            String[] to             = new String[] { org_from };
191                            String[] cc = StringUtil.csv2Array( HybsSystem.sys( "ERROR_MAIL_TO_USERS" ) );
192    
193                            MailTX tx = new MailTX( host );
194    //                      tx.setHost( host );
195                            tx.setFrom( from );
196                            tx.setTo( to );
197                            if( cc.length > 0 ) { tx.setCc( cc ); }
198                            tx.setSubject( subject );
199                            tx.setMessage( errMsg );
200                            tx.sendmail();
201                    }
202            }
203    
204            /**
205             * 繝｡繝?そ繝ｼ繧ｸ譛ｬ譁?ｈ繧翫?謖?ｮ壹?繧ｭ繝ｼ縺ｫ髢｢騾｣莉倥￠繧峨ｌ縺ｦ縺?ｋ諠??繧貞?繧雁?縺励∪縺吶?
206             * 縺薙ｌ縺ｯ縲∵欠螳壹?譁?ｭ怜?=[險ｭ螳壼?] 縺ｨ縺?≧繧ｭ繝ｼ繝ｯ繝ｼ繝峨°繧峨?險ｭ螳壼?繧貞叙繧雁?縺励∪縺吶?
207             * 謖?ｮ壹?譁?ｭ怜?縺ｨ=縺ｮ縺ｨ髢薙↓縲√せ繝壹?繧ｹ繧貞?繧後↑縺?〒縺上□縺輔＞縲?
208             * 險ｭ螳壼?縺ｮ蛻?ｊ蜃ｺ縺励?縲?謖?ｮ壹?譁?ｭ怜?=[" 縺ｨ "]" 縺ｮ髢薙?譁?ｭ怜?繧貞?繧雁?縺励∪縺吶?
209             * 蜀?Κ縺ｫ繧ｹ繝壹?繧ｹ縺悟?縺｣縺ｦ縺?※繧ゅ?蝠城｡後≠繧翫∪縺帙ｓ縲ゅ◆縺?＠縲‐ 縺悟?縺｣縺ｦ縺?ｋ蝣ｴ蜷医?縲?
210             * 豁｣蟶ｸ縺ｫ蛻?ｊ蜃ｺ縺吶％縺ｨ縺ｯ蜃ｺ譚･縺ｾ縺帙ｓ縺励?繧ｨ繧ｹ繧ｱ繝ｼ繝玲枚蟄励ｂ逕ｨ諢上＠縺ｦ縺?∪縺帙ｓ縲?
211             *
212             * @param       content 繧ｳ繝ｳ繝?Φ繝??譁?ｭ怜?
213             * @param       key     諠??繧貞?繧雁?縺呎凾縺ｮ繧ｭ繝ｼ
214             *
215             * @return      險ｭ螳壼? (險ｭ螳壼?縺瑚ｦ九▽縺九ｉ縺ｪ縺??蜷?null
216             */
217            private String getContentParam( final String content,final String key ) {
218                    if( content == null || key == null ) { return null; }
219    
220                    String newKey = key + "=[" ;
221    
222                    // 繧ｭ繝ｼ縺ｮ蟄伜惠繝√ぉ繝?け縺ｨ蝣ｴ謇?ｒ豎ゅａ繧九?
223                    int keyAd = content.indexOf( newKey );
224                    if( keyAd >= 0 ) {
225                            // [險ｭ螳壼?] 縺ｮ邨ゆｺ??謇?ｒ豎ゅａ繧九?(隕九▽縺代◆菴咲ｽｮ?区枚蟄怜?謨ｰ)
226                            int st = keyAd + newKey.length() ;
227                            int ed = content.indexOf( ']' , st );
228                            if( ed >= 0 ) {
229                                    return content.substring( st,ed );
230                            }
231                    }
232                    return null;
233            }
234    }