Просмотр исходного кода

feat:邮件解析-修改文件id字段名

mozuwen 7 месяцев назад
Родитель
Сommit
0f7d4ef98f

+ 2 - 3
service-base/src/main/java/com/simuwang/base/pojo/dto/EmailContentInfoDTO.java

@@ -4,9 +4,8 @@ import lombok.Data;
 
 import java.io.Serializable;
 
-
 @Data
-public class EmailContentInfoDTO implements Serializable, Cloneable {
+public class EmailContentInfoDTO implements Serializable {
 
     private static final long serialVersionUID = 202104140906313753L;
 
@@ -62,6 +61,6 @@ public class EmailContentInfoDTO implements Serializable, Cloneable {
     /**
      * 文件id(重新解析邮件功能)
      */
-    private Integer fielId;
+    private Integer fileId;
 }
 

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

@@ -116,12 +116,12 @@ public class EmailParseApiServiceImpl implements EmailParseApiService {
                 Map<EmailContentInfoDTO, List<EmailFundNavDTO>> fileNameNavMap = MapUtil.newHashMap();
                 for (EmailContentInfoDTO emailContentInfoDTO : emailContentInfoDTOList) {
                     try {
-                        log.info("开始重新解析文件 -> 文件id:{}", emailContentInfoDTO.getFielId());
+                        log.info("开始重新解析文件 -> 文件id:{}", emailContentInfoDTO.getFileId());
                         List<EmailFundNavDTO> fundNavDTOList = emailParseService.parseEmail(emailContentInfoDTO, MapUtil.newHashMap());
                         fileNameNavMap.put(emailContentInfoDTO, fundNavDTOList);
                         emailFundNavDTOList.addAll(fundNavDTOList);
                     } catch (Exception e) {
-                        log.error("重新解析文件失败,邮件id:{},文件id:{},堆栈信息:{}", emailId, emailContentInfoDTO.getFielId(), ExceptionUtil.stacktraceToString(e));
+                        log.error("重新解析文件失败,邮件id:{},文件id:{},堆栈信息:{}", emailId, emailContentInfoDTO.getFileId(), ExceptionUtil.stacktraceToString(e));
                     }
                 }
                 // 保存相关信息 -> 邮件信息表,邮件文件表,邮件净值表,邮件规模表,基金净值表
@@ -136,7 +136,7 @@ public class EmailParseApiServiceImpl implements EmailParseApiService {
         String parseDate = DateUtil.format(new Date(), DateConst.YYYY_MM_DD_HH_MM_SS);
         EmailContentInfoDTO contentInfoDTO = new EmailContentInfoDTO();
         contentInfoDTO.setEmailId(emailInfoDTO.getId());
-        contentInfoDTO.setFielId(emailInfoDTO.getFileId());
+        contentInfoDTO.setFileId(emailInfoDTO.getFileId());
         contentInfoDTO.setEmailAddress(emailInfoDTO.getEmail());
         contentInfoDTO.setEmailDate(emailDate);
         contentInfoDTO.setEmailTitle(emailInfoDTO.getEmailTitle());
@@ -154,7 +154,7 @@ public class EmailParseApiServiceImpl implements EmailParseApiService {
         for (EmailFileInfoDO fileInfoDO : emailFileInfoDOList) {
             EmailContentInfoDTO contentInfoDTO = new EmailContentInfoDTO();
             contentInfoDTO.setEmailId(emailId);
-            contentInfoDTO.setFielId(fileInfoDO.getId());
+            contentInfoDTO.setFileId(fileInfoDO.getId());
             contentInfoDTO.setEmailAddress(emailParseInfoDO.getEmail());
             contentInfoDTO.setEmailDate(emailDate);
             contentInfoDTO.setEmailTitle(emailParseInfoDO.getEmailTitle());

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

@@ -145,7 +145,7 @@ public class EmailParseService {
         for (Map.Entry<EmailContentInfoDTO, List<EmailFundNavDTO>> fileNameNavEntry : fileNameNavMap.entrySet()) {
             // 保存邮件文件表
             EmailContentInfoDTO emailContentInfoDTO = fileNameNavEntry.getKey();
-            Integer fileId = saveEmailFileInfo(emailId, emailContentInfoDTO.getFielId(), emailContentInfoDTO.getFileName(), emailContentInfoDTO.getFilePath(), parseDate);
+            Integer fileId = saveEmailFileInfo(emailId, emailContentInfoDTO.getFileId(), emailContentInfoDTO.getFileName(), emailContentInfoDTO.getFilePath(), parseDate);
 
             List<EmailFundNavDTO> fundNavDTOList = fileNameNavEntry.getValue();
             if (CollUtil.isEmpty(fundNavDTOList)) {
@@ -184,7 +184,7 @@ public class EmailParseService {
         List<EmailFundAssetDO> emailFundAssetDOList = fundNavDTOList.stream()
                 .map(e -> buildEmailFundAssetDo(fileId, e, parseDate)).filter(CollUtil::isNotEmpty).flatMap(List::stream).collect(Collectors.toList());
         if (CollUtil.isNotEmpty(emailFundAssetDOList)) {
-            // 先删除file_id下的规模数据(考虑到重新解析的需求,如果是首次解析,那么fiel_id下不存在规模数据)
+            // 先删除file_id下的规模数据(考虑到重新解析的需求,如果是首次解析,那么file_id下不存在规模数据)
             emailFundAssetMapper.deleteByFileId(fileId);
             emailFundAssetMapper.batchInsert(emailFundAssetDOList);
             List<AssetDO> assetDOList = emailFundAssetDOList.stream().filter(e -> StrUtil.isNotBlank(e.getFundId()))