Bom dia,
Estou usando o spring com o Scheduled, antes usava o quartz mas como fiz upload da versão do spring resolvi abandonar o quartz ja que a primeira opção era o suficiente para atender minha necessidade.
Resumindo, tenho uma tarefa que envia e-mails, esse abaixo é o evento.
@Configuration
@EnableScheduling
public class NotificacaoScheduler {
Logger logger = LoggerFactory.getLogger(getClass());
@Autowired
private NotificacaoService notificacao;
@Scheduled(fixedRate = 3600000)//1800000
public void scheduleFixedRateTask() {
notificacao.analisar();
logger.debug("Fixed rate task - " + LocalDateTime.now());
notificacao.enviarPendentes();
logger.debug("Send ok - " + LocalDateTime.now());
}
}
Abaixo o service,
@Service
public class NotificacaoService {
Logger logger = LoggerFactory.getLogger(getClass());
@Autowired
private JavaMailSender mailSender;
@Autowired
private Notificacoes notificacao;
@Autowired
private NotificacoesEnvios envios;
@Transactional
public void analisar() {
List<Notificacao> result = notificacao.buscarHoje();
List<NotificacaoEnvio> notEnvios = new ArrayList<>();
for(Notificacao n : result) {
if(!notificacao.verSeExiste(n)) {
NotificacaoEnvio ne = new NotificacaoEnvio();
ne.setNotificacao(n);
ne.setStatus(false);
notEnvios.add(ne);
}
}
if(!notEnvios.isEmpty()) envios.saveAll(notEnvios);
}
@Transactional
public void enviarPendentes() {
List<NotificacaoEnvio> ne = notificacao.notificacoesPendentes();
List<NotificacaoEnvio> nList = new ArrayList<>();
for (NotificacaoEnvio n : ne) {
try {
MimeMessage mail = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(mail);
helper.setTo(n.getNotificacao().getPara().replace(" ", "").split(";"));
if(!n.getNotificacao().getCc().trim().equals(""))
helper.setCc(n.getNotificacao().getCc().replace(" ", "").split(";"));
if(!n.getNotificacao().getCo().trim().equals(""))
helper.setBcc(n.getNotificacao().getCo().replace(" ", "").split(";"));
helper.setSubject(n.getNotificacao().getAssunto());
helper.setText(n.getNotificacao().getModelo().getTexto(),true);
helper.setFrom(n.getNotificacao().getDe(),n.getNotificacao().getAutor());
mailSender.send(mail);
n.setDataEnvio(Calendar.getInstance());
n.setStatus(true);
nList.add(n);
} catch (NullPointerException | MailException | MessagingException | UnsupportedEncodingException e) {
logger.error(e.getMessage());
}
}
if(!nList.isEmpty()) envios.saveAll(nList);
}
}
O que ocorre, que tenho notifição que é gerada em uma tabela de pendencias, que a cada 1 hora é enviado as notificações pendentes, o problema esta justamente ai, o metodo analisar() esta funcionando corretamente, porem o metodo enviarPendentes(), esta enviando a mesma notificação 2 vezes (não existe duas linhas do mesmo registro no meu banco). Durante os testes que fiz no eclipse, apenas uma vez era enviado, mas lá no servidor tomcat estou com esse problema.
Abaixo o metodo de consulta a base
@Override
public List<NotificacaoEnvio> notificacoesPendentes(){
Criteria criteria = manager.unwrap(Session.class).createCriteria(NotificacaoEnvio.class);
criteria.add(Restrictions.eq("data", Calendar.getInstance()));
criteria.add(Restrictions.eq("status", false));
return criteria.list();
}
Abraços e Feliz Ano novo a todos