|
|
|
@ -29,6 +29,7 @@ import com.google.common.base.Joiner;
|
|
|
|
|
import com.google.common.collect.Lists;
|
|
|
|
|
import com.google.common.collect.Sets;
|
|
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
|
|
import lombok.SneakyThrows;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
|
|
@ -173,24 +174,20 @@ public class MailSourceTask {
|
|
|
|
|
/**
|
|
|
|
|
* 删除五天前数据
|
|
|
|
|
*/
|
|
|
|
|
@SneakyThrows
|
|
|
|
|
@Scheduled(cron = "0 25 23 * * ? ")
|
|
|
|
|
public void deleteMail() {
|
|
|
|
|
// 获取邮件内容
|
|
|
|
|
List<Message> list = MailUtil.readMailByIMAP
|
|
|
|
|
(deliveryProperties.getEmailAddress(), deliveryProperties.getEmailPassword());
|
|
|
|
|
try {
|
|
|
|
|
for (Message message : list) {
|
|
|
|
|
Date sentDate = message.getSentDate();
|
|
|
|
|
// 时间偏移三十天
|
|
|
|
|
DateTime dateTime = DateUtil.offsetDay(DateUtil.date(), -DefaultNumberConstants.FIVE_NUMBER);
|
|
|
|
|
if (dateTime.after(sentDate)) {
|
|
|
|
|
// 删除邮件
|
|
|
|
|
message.setFlag(Flags.Flag.DELETED, Boolean.TRUE);
|
|
|
|
|
}
|
|
|
|
|
for (Message message : list) {
|
|
|
|
|
Date sentDate = message.getSentDate();
|
|
|
|
|
// 时间偏移三十天
|
|
|
|
|
DateTime dateTime = DateUtil.offsetDay(DateUtil.date(), -DefaultNumberConstants.FIVE_NUMBER);
|
|
|
|
|
if (dateTime.after(sentDate)) {
|
|
|
|
|
// 删除邮件
|
|
|
|
|
message.setFlag(Flags.Flag.DELETED, Boolean.TRUE);
|
|
|
|
|
}
|
|
|
|
|
} catch (MessagingException e) {
|
|
|
|
|
log.error("=================== the delete mail error message as {} ===========", e.getMessage());
|
|
|
|
|
throw new BadRequestException(e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|