Subversion Repositories bacoAlunos

Rev

Rev 1426 | Rev 1456 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1426 Rev 1429
Line 1... Line 1...
1 
package pt.estgp.estgweb.services.questionarios;
 1 
package pt.estgp.estgweb.services.questionarios;
2 
 
 2 
 
3 
import org.apache.log4j.Logger;
 3 
import org.apache.log4j.Logger;
- 
 
 4 
import pt.estgp.estgweb.Globals;
4 
import pt.estgp.estgweb.domain.*;
 5 
import pt.estgp.estgweb.domain.*;
5 
import pt.estgp.estgweb.domain.dao.DaoFactory;
 6 
import pt.estgp.estgweb.domain.dao.DaoFactory;
6 
import pt.estgp.estgweb.domain.dao.impl.AnnouncementDaoImpl;
 7 
import pt.estgp.estgweb.domain.dao.impl.AnnouncementDaoImpl;
7 
import pt.estgp.estgweb.domain.views.QuestionarioView;
 8 
import pt.estgp.estgweb.domain.views.QuestionarioView;
8 
import pt.estgp.estgweb.services.email.EMAILJob;
 9 
import pt.estgp.estgweb.services.email.EMAILJob;
- 
 
 10 
import pt.estgp.estgweb.services.email.EMAILJobPersonalizedCertificated;
9 
import pt.estgp.estgweb.services.email.SendEmailService;
 11 
import pt.estgp.estgweb.services.email.SendEmailService;
10 
import pt.estgp.estgweb.services.jobs.JobScheduleService;
 12 
import pt.estgp.estgweb.services.jobs.JobScheduleService;
11 
import pt.estgp.estgweb.utils.Email;
 13 
import pt.estgp.estgweb.utils.Email;
- 
 
 14 
import pt.estgp.estgweb.utils.EmailPersonalizedCertificated;
12 
import pt.estgp.estgweb.web.exceptions.NotAuthorizedException;
 15 
import pt.estgp.estgweb.web.exceptions.NotAuthorizedException;
13 
import pt.utl.ist.berserk.logic.serviceManager.IService;
 16 
import pt.utl.ist.berserk.logic.serviceManager.IService;
14 
 
 17 
 
15 
import java.util.*;
 18 
import java.util.*;
16 
 
 19 
 
Line 200... Line 203...
200 
 
 203 
 
201 
    SendEmailService sendEmailService = new SendEmailService();
 204 
    SendEmailService sendEmailService = new SendEmailService();
202 
    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)
 205 
    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)
203 
    {
 206 
    {
204 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario message";
 207 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario message";
205 
        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmails(id,onlyNotAnswered);
 208 
        AnnouncementDaoImpl.FindUsersIdResult result = DaoFactory.getQuestionarioDaoImpl().findUsersIds(id, onlyNotAnswered);
206 
 
 209 
 
207 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
 210 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
208 
    }
 211 
    }
209 
 
 212 
 
210 
    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)
 213 
    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)
211 
    {
 214 
    {
212 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario curso message";
 215 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario curso message";
213 
        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmailsPedagogico(onlyNotAnswered,id,0);
 216 
        AnnouncementDaoImpl.FindUsersIdResult result = DaoFactory.getQuestionarioDaoImpl().findUsersIdsPedagogico(onlyNotAnswered, id, 0);
214 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
 217 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
215 
    }
 218 
    }
216 
    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)
 219 
    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)
217 
    {
 220 
    {
218 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario unidade message";
 221 
        1.5.0/docs/api/java/lang/String.html">String source = "questionario unidade message";
219 
        AnnouncementDaoImpl.FindUsersResult result = DaoFactory.getQuestionarioDaoImpl().findUsersEmailsPedagogico(onlyNotAnswered,0,id);
 222 
        AnnouncementDaoImpl.FindUsersIdResult result = DaoFactory.getQuestionarioDaoImpl().findUsersIdsPedagogico(onlyNotAnswered, 0, id);
220 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
 223 
        return sendEmails(id, msg, emailFrom, personFrom, subject, userSession, source, result);
221 
    }
 224 
    }
222 
 
 225 
 
223 
 
 226 
 
224 
    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) {
 227 
    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.FindUsersIdResult result) {
225 
        List<String> usersToConsume = result.emails;
 228 
        List<Long> usersToConsume = result.userIds;
226 
 
 229 
 
227 
 
 230 
 
228 
        logger.info("Scheduling mail jobs to " + result.users + " users: " + usersToConsume.size() + " recipients");
 231 
        logger.info("Scheduling mail jobs to " + result.users + " users: " + usersToConsume.size() + " recipients");
229 
        //while(usersToConsume.size() > 0)
 232 
        //while(usersToConsume.size() > 0)
230 
        //{
 233 
        //{
Line 236... Line 239...
236 
        //        usersToJob.add(iter.next());
 239 
        //        usersToJob.add(iter.next());
237 
        //        iter.remove();
 240 
        //        iter.remove();
238 
        //        contador++;
 241 
        //        contador++;
239 
        //    }
 242 
        //    }
240 
 
 243 
 
241 
        Email e =  sendEmailService.getMessageEmailAdulteredFromEmailIpp(emailFrom,
 244 
        EmailPersonalizedCertificated e =  sendEmailService.getMessageEmailAdulteredFromEmailIppCertificated(emailFrom,
242 
                personFrom,
 245 
                personFrom,
243 
                subject,
 246 
                subject,
244 
                msg,
 247 
                msg,
- 
 
 248 
                userSession.getUser(),
245 
                usersToConsume,
 249 
                usersToConsume,
246 
                userSession.getUser());
 250 
                Globals.SITE_URL + "/user/homePae.do");
247 
 
 251 
 
248 
        e.setHtml(true);
 252 
        e.setHtml(true);
249 
        EMAILJob emailJob = new EMAILJob(e);
 253 
        EMAILJobPersonalizedCertificated emailJob = new EMAILJobPersonalizedCertificated(e);
250 
        JobScheduleService.getInstance().scheduleNow(emailJob,"Message Email (" + source + ":id " + id +  ") from " + userSession.getUsername() + " as " + personFrom + " - subject:" + subject  ,userSession);
 254 
        JobScheduleService.getInstance().scheduleNow(emailJob,"Message Email (" + source + ":id " + id +  ") from " + userSession.getUsername() + " as " + personFrom + " - subject:" + subject  ,userSession);
251 
        //}
 255 
        //}
252 
        enviarComprovativoAoRemetente(id, msg, emailFrom, personFrom, subject, userSession, source,usersToConsume.size());
 256 
        enviarComprovativoAoRemetente(id, msg, emailFrom, personFrom, subject, userSession, source,usersToConsume.size());
253 
        return result.users;
 257 
        return result.users;
254 
    }
 258 
    }