浏览代码

feat:通过Coremail接口获取邮箱邮件

mozuwen 2 周之前
父节点
当前提交
b285c3c6e8

+ 4 - 1
service-daq/src/main/java/com/simuwang/daq/service/EmailParseService.java

@@ -92,6 +92,8 @@ public class EmailParseService {
     private ReportParserFactory reportParserFactory;
     @Autowired
     private ReportWriterFactory reportWriterFactory;
+    @Autowired
+    ReadEmailService readEmailService;
 
     public EmailParseService(EmailTypeRuleMapper emailTypeRuleMapper, EmailRuleConfig emailRuleConfig,
                              EmailFieldMappingMapper emailFieldMapper, EmailParserFactory emailParserFactory,
@@ -136,7 +138,8 @@ public class EmailParseService {
         Map<String, List<String>> emailFieldMap = getEmailFieldMapping();
         Map<String, List<EmailContentInfoDTO>> emailContentMap;
         try {
-            emailContentMap = realEmail(mailboxInfoDTO, emailTypeMap, startDate, endDate);
+            // 通过接口获取邮件
+            emailContentMap = readEmailService.realEmail(mailboxInfoDTO, emailTypeMap, startDate, endDate);
         } catch (Exception e) {
             log.info("采集邮件失败 -> 邮箱配置信息:{},堆栈信息:{}", mailboxInfoDTO, ExceptionUtil.stacktraceToString(e));
             return;

+ 29 - 0
service-daq/src/main/java/com/simuwang/daq/service/ReadEmailService.java

@@ -0,0 +1,29 @@
+package com.simuwang.daq.service;
+
+import cn.hutool.core.map.MapUtil;
+import com.simuwang.base.pojo.dto.EmailContentInfoDTO;
+import com.simuwang.base.pojo.dto.MailboxInfoDTO;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class ReadEmailService {
+
+    /**
+     * 通过接口获取邮件
+     *
+     * @param mailboxInfoDTO 邮箱账号密码
+     * @param emailTypeMap   邮箱类型映射表
+     * @param startDate      开始日期
+     * @param endDate        结束日期
+     * @return 邮件信息
+     */
+    public Map<String, List<EmailContentInfoDTO>> realEmail(MailboxInfoDTO mailboxInfoDTO, Map<Integer, List<String>> emailTypeMap, Date startDate, Date endDate) {
+
+        return MapUtil.newHashMap();
+    }
+
+}