notificationmanagerejb.java

CRM源码This file describes some issues that should be implemented in future and how it should be imple

/*
 * Copyright 2006-2007 Queplix Corp.
 *
 * Licensed under the Queplix Public License, Version 1.1.1 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.queplix.com/solutions/commercial-open-source/queplix-public-license/
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

package com.queplix.qwoss.notification;

import com.queplix.core.modules.eqlext.error.FileManagerException;
import com.queplix.core.modules.eqlext.utils.FileManager;
import com.queplix.core.modules.eqlext.utils.images.FileUploadManager;
import com.queplix.core.modules.mail.Attachment;
import com.queplix.core.utils.StringHelper;
import java.util.List;
import javax.mail.MessagingException;
import com.queplix.core.error.ErrorHelper;
import com.queplix.core.error.GenericSystemException;
import com.queplix.core.jxb.entity.Entity;
import com.queplix.core.modules.eql.CompoundKey;
import com.queplix.core.modules.eqlext.error.FormTransformException;
import com.queplix.core.modules.eqlext.utils.FormsManager;
import com.queplix.core.modules.inbox.InboxHelper;
import com.queplix.core.modules.inbox.InboxMessage;
import com.queplix.qwoss.inbox.ejb.InboxManagerLocal;
import com.queplix.qwoss.inbox.ejb.InboxManagerLocalHome;
import com.queplix.core.modules.jeo.gen.UserObject;
import com.queplix.core.modules.mail.MailAddress;
import com.queplix.core.integrator.security.AccessRightsManager;
import com.queplix.core.integrator.security.LogonSession;
import com.queplix.core.integrator.security.SecurityHelper;
import com.queplix.core.integrator.security.User;
import com.queplix.core.integrator.security.WorkGroup;
import com.queplix.qwoss.utils.CustomJNDINames;
import com.queplix.core.utils.ejb.AbstractSessionEJB;
import com.queplix.qwoss.utils.TicketNotificationHelper;
import org.apache.regexp.RE;
import org.apache.regexp.RESyntaxException;

/**
 * <p>
 * Notification manager stateful session EJB
 * </p>
 *
 * @author [ALB] Baranov Andrey
 * @version $Revision: 1.7.2.4 $ $Date: 2006/01/24 20:33:36 $
 */

public class NotificationManagerEJB
    extends AbstractSessionEJB {

    // ----------------------------------------------------- variables

    // base attributes
    private LogonSession ls;
    private Entity entity;
    private CompoundKey key;

    // notification attributes
    private Integer alertSeverityId;
    private String subject;
    private String message;
    //private Form form;

    // specials...
    private String translatedSubject;
    private String translatedMessage;
    private boolean isTranslated = false;

    // ----------------------------------------------------- create method

    /**
     * Initialize bean
     *
     * @param ls LogonSession object
     * @param entity changed entity
     * @param key changed record compound primary key
     */
    public void ejbCreate( LogonSession ls, Entity entity, CompoundKey key ) {

        INFO( "NotificationManagerEJB create - " + hashCode() );
        if( getLogger().isDebugEnabled() ) {
            DEBUG( "Notification parameters:" );
            DEBUG( "   entity: " + entity.getName() );
            DEBUG( "   key: " + key );
        }

        if( ls == null ) {
            throw new IllegalStateException( "Logon session is NULL" );
        }
        if( entity == null ) {
            throw new IllegalStateException( "Entity is NULL" );
        }
        if( key == null ) {
            throw new IllegalStateException( "Key is NULL" );
        }

        this.ls = ls;
        this.entity = entity;
        this.key = key;
    }

    // ----------------------------------------------------- setters

    public void setAlertSeverityId( Integer alertSeverityId ) {
        this.alertSeverityId = alertSeverityId;
    }

    public void setSubject( String subject ) {
        this.subject = subject;
        isTranslated = false;
    }

    public void setMessage( String message ) {
        this.message = message;
        isTranslated = false;
    }

    // ----------------------------------------------------- busines methods

    /**
     * Default notification
     *
     * @param user User object
     */
    public void notify( User user ) {
        notify( user, TicketNotificationHelper.ALERT_METHOD );
    }

    /**
     * Notify via alert
     *
     * @param user
     *            User object
     */
    public void notifyByAlert( User user ) {

        long time = System.currentTimeMillis();

        if( getLogger().isInfoEnabled() ) {
            INFO( "Try to send alert notification to user '" + user + "'" );
        }
        InboxManagerLocal inboxLocal = getInboxManagerLocal();
        InboxMessage mailMessage = buildAlertInboxMessage( AccessRightsManager.getSystemLogonSession().getUser().getUserID() , user.getUserID() );
        inboxLocal.sendAlertMessage(ls, mailMessage);

        if( getLogger().isInfoEnabled() ) {
            INFO( "Send notification to user via alert - ok. Time(ms)="
                   + ( System.currentTimeMillis() - time ) );
        }
    }

    /**
     * Notify via E-mail
     *
     * @param user
     *            User object
     */
    public void notifyByMail( User user ) {

        long time = System.currentTimeMillis();
        if( getLogger().isDebugEnabled() ) {
            DEBUG( "Try to send mail notification to user '" + user + "'" );
        }

        try {
            InboxManagerLocal inboxLocal = getInboxManagerLocal();
            MailAddress[] to = new MailAddress[] {new MailAddress( user )};
            InboxMessage mailMessage = buildInboxMessage( to );

            // Send message!
            inboxLocal.sendEmailMessage( ls, mailMessage, null );

            if( getLogger().isDebugEnabled() ) {
                DEBUG( "Send notification to user via e-mail - ok. Time(ms)="
                       + ( System.currentTimeMillis() - time ) );
                DEBUG( "Send notification to address " + mailMessage.getTo()
                       + " from address " + mailMessage.getFrom() );
            }

        } catch( MessagingException mex ) {
            WARN( "Send notification to user via e-mail - fail. Problem:\n"
                  + mex.getMessage() + "\nTime(ms)="
                  + ( System.currentTimeMillis() - time ) );

        } catch( Throwable t ) {
            ErrorHelper.throwSystemException( t, this );
        }
    }

    /**
     * Notify via E-mail
     *
     * @param email
     *            String
     */
    public void notifyByMail( String email ) {
        long time = System.currentTimeMillis();

        if( getLogger().isDebugEnabled() ) {
            DEBUG( "Try to send mail notification to addressee '" + email + "'" );
        }

        try {
            InboxManagerLocal inboxLocal = getInboxManagerLocal();
            MailAddress[] to = MailAddress.parse( email );
            InboxMessage mailMessage = buildInboxMessage( to );

            // Send message!
            inboxLocal.sendEmailMessage( ls, mailMessage, null );

            if( getLogger().isDebugEnabled() ) {
                DEBUG( "Send notification to addressee via e-mail - ok. Time(ms)="
                       + ( System.currentTimeMillis() - time ) );
                DEBUG( "Send notification to address " + mailMessage.getTo()
                       + " from address " + mailMessage.getFrom() );
            }

        } catch( MessagingException mex ) {
            WARN( "Send notification to addressee via e-mail. Problem:\n"
                  + mex.getMessage() + "\nTime(ms)="
                  + ( System.currentTimeMillis() - time ) );
        
        } catch( Throwable t ) {
            ErrorHelper.throwSystemException( t, this );
        }
    }

    /**
     * Default notification
     *
     * @param group
     *            Group object
     * @param tier
     *            group tier
     * @param userList
     *            List of User objects (optional)
     */
    public void notify( WorkGroup group, Integer tier, List userList ) {
        // send notification to memebers of this group
        
        int notifyMethod = group.getNotifyMethod();
        if( notifyMethod == WorkGroup.NOTIFY_METHOD_OWNER ) {
            
            // Notify workgroup members
            if( userList == null ) {
                userList = SecurityHelper.loadUsers(ls, group, tier);
            }
            int size = ( userList == null ) ? 0 : userList.size();
            for( int i = 0; i < size; i++ ) {
                
                UserObject userObj = ( UserObject ) userList.get( i );
                User user = new User();
                user.setUserID(userObj.getPkey().longValue());
                user.setUserType(userObj.getUser_type().intValue());
                user.setLoginName(userObj.getLoginname());
                user.setFullName(userObj.getFullname());