diff --git a/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/CompanyServiceImpl.java b/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/CompanyServiceImpl.java index 9537a568..925f0369 100644 --- a/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/CompanyServiceImpl.java +++ b/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/CompanyServiceImpl.java @@ -26,7 +26,6 @@ public class CompanyServiceImpl implements CompanyService { private final CompanyRepository companyRepository; - @Override @Transactional(rollbackFor = Exception.class) @CacheEvict(cacheNames = "companyCache", key = "#company.id") diff --git a/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/FormSourceServiceImpl.java b/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/FormSourceServiceImpl.java index 5b60bd46..09c388f2 100644 --- a/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/FormSourceServiceImpl.java +++ b/services/ad-platform-source/src/main/java/com/baiye/module/service/impl/FormSourceServiceImpl.java @@ -42,13 +42,10 @@ public class FormSourceServiceImpl implements FormSourceService { private final TaskClient taskClient; - private final TaskImeiClient taskImeiClient; private final ClueRepository clueRepository; - private final ClueMiddleRepository clueMiddleRepository; - private final DeliveryRecordRepository deliveryRecordRepository; @Value("${storage.private-key}") private String privatePath; diff --git a/services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java b/services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java index de172410..0c12010c 100644 --- a/services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java +++ b/services/ad-platform-source/src/main/java/com/baiye/task/MailSourceTask.java @@ -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 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()); } } }