Subversion Repositories bacoAlunos

import pt.estgp.estgweb.domain.dao.impl.AnnouncementDaoImpl;

import pt.estgp.estgweb.services.email.EMAILJob;

import pt.estgp.estgweb.services.email.SendEmailService;

import pt.estgp.estgweb.services.jobs.JobScheduleService;

import pt.estgp.estgweb.utils.Email;

import java.util.ArrayList;

import java.util.Iterator;

    SendEmailService sendEmailService = new SendEmailService();

    public int sendMessage(boolean onlyNotAnswered,1.5.0/docs/api/java/lang/Long.html">Long id,1.5.0/docs/api/java/lang/String.html">String msg,1.5.0/docs/api/java/lang/String.html">String emailFrom,1.5.0/docs/api/java/lang/String.html">String personFrom, 1.5.0/docs/api/java/lang/String.html">String subject,UserSession userSession)

    {

        1.5.0/docs/api/java/lang/String.html">String source = "questionario message";

        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmails(id,onlyNotAnswered);

        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);

    }

    private int sendEmails(1.5.0/docs/api/java/lang/Long.html">Long id, 1.5.0/docs/api/java/lang/String.html">String msg, 1.5.0/docs/api/java/lang/String.html">String emailFrom, 1.5.0/docs/api/java/lang/String.html">String personFrom, 1.5.0/docs/api/java/lang/String.html">String subject, UserSession userSession, 1.5.0/docs/api/java/lang/String.html">String source, AnnouncementDaoImpl.FindUsersResult result) {

        List<String> usersToConsume = result.emails;

        logger.info("Scheduling mail jobs to " + result.users + " users: " + usersToConsume.size() + " recipients");

        while(usersToConsume.size() > 0)

        {

            Iterator<String> iter = usersToConsume.iterator();

            List<String> usersToJob = new ArrayList<String>();

            int contador = 0;

            while(iter.hasNext() && contador < 20)

            {

                usersToJob.add(iter.next());

                iter.remove();

                contador++;

            }

            Email e =  sendEmailService.getMessageEmailAdulteredFromEmailIpp(emailFrom,

                    personFrom,

                    subject,

                    msg,

                    usersToJob,

                    userSession.getUser());

            e.setHtml(true);

            EMAILJob emailJob = new EMAILJob(e);

            JobScheduleService.getInstance().scheduleNow(emailJob,"Message Email (" + source + ":id " + id +  ") from " + userSession.getUsername() + " as " + personFrom + " - subject:" + subject  ,userSession);

        }

        return result.users;

    }

    public int sendMessageCursoAfeto(boolean onlyNotAnswered,1.5.0/docs/api/java/lang/Long.html">Long id,1.5.0/docs/api/java/lang/String.html">String msg,1.5.0/docs/api/java/lang/String.html">String emailFrom,1.5.0/docs/api/java/lang/String.html">String personFrom, 1.5.0/docs/api/java/lang/String.html">String subject,UserSession userSession)

    {

        1.5.0/docs/api/java/lang/String.html">String source = "questionario curso message";

        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmailsPedagogico(onlyNotAnswered,id,0);

        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);

    }

    public int sendMessageUnidadeAfeta(boolean onlyNotAnswered,1.5.0/docs/api/java/lang/Long.html">Long id,1.5.0/docs/api/java/lang/String.html">String msg,1.5.0/docs/api/java/lang/String.html">String emailFrom,1.5.0/docs/api/java/lang/String.html">String personFrom, 1.5.0/docs/api/java/lang/String.html">String subject,UserSession userSession)

    {

        1.5.0/docs/api/java/lang/String.html">String source = "questionario unidade message";

        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmailsPedagogico(onlyNotAnswered,0,id);

        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);

    }