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.plugin.daemon;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.hayabusa.report.GE50Access;
020    import org.opengion.fukurou.util.LogWriter;
021    import org.opengion.fukurou.util.StringUtil;
022    import org.opengion.fukurou.util.HybsTimerTask;
023    
024    import org.opengion.fukurou.mail.MailReceiveListener ;
025    import org.opengion.fukurou.mail.MailRX ;
026    
027    import java.util.Date;
028    
029    /**
030     * 縲舌Γ繝ｼ繝ｫ繝??繝｢繝ｳ縲代Γ繝ｼ繝ｫ繧ｵ繝ｼ繝舌?繧堤屮隕悶＠縺ｦ縲・XCEL繝輔ぃ繧､繝ｫ縺ｮDB逋ｻ骭ｲ蜃ｦ逅??繝??繝｢繝ｳ縺ｧ縺吶?
031     * 謖?ｮ壹?譚｡莉ｶ縺ｧ繝｡繝ｼ繝ｫ繧ｵ繝ｼ繝舌?繧堤屮隕悶＠縲∵ｷｻ莉倥?EXCEL繝輔ぃ繧､繝ｫ繧貞叙繧雁?縺励∪縺吶?
032     * 豺ｻ莉倥ヵ繧｡繧､繝ｫ縺ｯ縲・XCEL蜿悶ｊ霎ｼ縺ｿ繧､繝ｳ繧ｿ繝ｼ繝輔ぉ繝ｼ繧ｹ縺ｫ蜑?ｊ縲∬ｦ∵ｱら分蜿ｷ.xls 縺ｫ繝ｪ繝阪?繝?＠縺ｦ
033     * 謇?ｮ壹?繝?ぅ繝ｬ繧ｯ繝医Μ(EXCEL_IN_FILE_URL縺ｧ螳夂ｾｩ)縺ｫ繧ｻ繝ｼ繝悶＠縲∝ｸｳ逾ｨ隕∵ｱゅユ繝ｼ繝悶Ν縺ｫ逋ｻ骭ｲ縺励∪縺吶?(GE50)
034     * 縺昴ｌ莉･髯阪?蜃ｦ逅??縲・XCEL蟶ｳ逾ｨ繝??繝｢繝ｳ莉･荳九?蜈ｱ騾壼?逅?〒蜃ｦ逅?＆繧後∪縺吶?
035     * EXCEL蜿悶ｊ霎ｼ縺ｿ蜃ｦ逅??縲√％縺ｮ繝｡繝ｼ繝ｫ閾ｪ蜍募叙繧願ｾｼ縺ｿ縺ｨ縲√ヵ繧｡繧､繝ｫ繧｢繝??繝ｭ繝ｼ繝峨?譁ｹ蠑上ｒ
036     * 繧ｵ繝昴?繝医＠縺ｦ縺?∪縺吶?
037     *
038     * @og.rev 3.8.0.0 (2005/06/07) 譁ｰ隕剰ｿｽ蜉?
039     * @og.rev 4.3.4.4 (2009/01/01) 繝励Λ繧ｰ繧､繝ｳ蛹?
040     * @og.group 繝??繝｢繝ｳ
041     *
042     * @version  4.0
043     * @author   Kazuhiko Hasegawa
044     * @since    JDK5.0,
045     */
046    public class Daemon_MailReceive extends HybsTimerTask {
047            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
048            private static final String VERSION = "5.3.0.0 (2010/12/01)" ;
049    
050            private int                     loopCnt         = 0;
051            private static final int LOOP_COUNTER = 24;             // 繧ｫ繧ｦ繝ｳ繧ｿ繧?4蝗槭↓險ｭ螳?
052    
053            private MailRX  mailRX          = null;
054    
055            /**
056             * 縺薙?繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｫ繧医▲縺ｦ蛻晄悄蛹悶＆繧後ｋ繧｢繧ｯ繧ｷ繝ｧ繝ｳ縺ｧ縺吶?
057             * 繝代Λ繝｡繝ｼ繧ｿ繧剃ｽｿ逕ｨ縺励◆蛻晄悄蛹悶ｒ陦後＞縺ｾ縺吶?
058             *
059             */
060            @Override
061            public void initDaemon() {
062    
063                    String  host     = StringUtil.nval( getValue( "HOST"   ) , HybsSystem.sys( "COMMON_MAIL_SERVER" ) );
064                    String  user     = StringUtil.nval( getValue( "USER"   ) , HybsSystem.sys( "MAIL_DAEMON_DEFAULT_USER" ) );
065                    String  passwd   = StringUtil.nval( getValue( "PASSWD" ) , HybsSystem.sys( "MAIL_DAEMON_DEFAULT_PASS" ) );
066    
067                    mailRX = new MailRX();
068                    mailRX.setHost( host );
069                    mailRX.setUser( user );
070                    mailRX.setPasswd( passwd );
071                    mailRX.setDelete( true );
072    
073            // 迴ｾ谿ｵ髫弱〒縺ｯ縲ヾubject縺ｫ繧医ｋ繝｡繝ｼ繝ｫ蜿門ｾ玲険蛻??陦後＞縺ｾ縺帙ｓ縲?
074            // 譚｡莉ｶ縺ｫ蜷医ｏ縺ｪ縺?お繝ｩ繝ｼ繝｡繝ｼ繝ｫ繧貞叙繧雁?縺呎ｩ滉ｼ壹′縺ｪ縺上↑繧九◆繧√〒縺吶?
075            //      String  subject  = getValue( "SUBJECT" );
076            //      if( subject != null && subject.length() > 0 ) {
077            //              HybsEntry entry = new HybsEntry( "Subject",subject );
078            //              mailRX.addMatchTerm( entry );
079            //      }
080    
081                    String  receiveListener  = getValue( "RECEIVE_LISTENER" );
082                    MailReceiveListener listener = (MailReceiveListener)HybsSystem.newInstance( receiveListener );
083                    mailRX.setMailReceiveListener( listener );
084            }
085    
086            /**
087             * 繧ｿ繧､繝槭?繧ｿ繧ｹ繧ｯ縺ｮ繝??繝｢繝ｳ蜃ｦ逅??髢句ｧ九?繧､繝ｳ繝医〒縺吶?
088             *
089             * @og.rev 5.3.0.0 (2010/12/01) 繧ｨ繝ｩ繝ｼ繝上Φ繝峨Μ繝ｳ繧ｰ繧剃ｿｮ豁｣
090             *
091             */
092            @Override
093            protected void startDaemon() {
094                    if( loopCnt % LOOP_COUNTER == 0 ) {
095                            loopCnt = 1;
096                            System.out.println();
097                            System.out.print( toString() + " " + new Date()  + " " );
098                    }
099                    else {
100                            System.out.print( "." );
101                            loopCnt++ ;
102                    }
103    
104                    try {
105                            mailRX.start();
106                    }
107    //              catch( Throwable ex ) {
108    //                      GE50Access GE50 = new GE50Access( "CYYYYY","M_Daemon","MailReceive" );
109    //
110    //                      GE50.setSystemId( "ERR" );
111    //                      GE50.makeYkno();
112    //
113    //                      GE50.insertGE50( GE50Access.FG_ERR1 );
114    //
115    //                      String errMsg = StringUtil.stringStackTrace( ex );
116    //                      GE50.insertErrorGE56( errMsg );
117    //
118    //                      LogWriter.log( errMsg );
119    //              }
120                    // 5.3.0.0 (2010/12/01) 繧ｨ繝ｩ繝ｼ繝上Φ繝峨Μ繝ｳ繧ｰ繧剃ｿｮ豁｣
121                    catch( Throwable ex ) {
122                            String errMsg = StringUtil.stringStackTrace( ex ) ;
123                            System.out.println( errMsg );
124                            LogWriter.log( errMsg );
125    
126                            GE50Access ge50 = new GE50Access( "CYYYYY","M_Daemon","MailReceive" );
127    
128                            ge50.setSystemId( "ERR" );
129                            ge50.makeYkno();
130    
131                            ge50.insertErrorGE56( errMsg );
132                            ge50.insertGE50( GE50Access.FG_ERR1 );
133    
134                    }
135            }
136    }