wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-1507): 老的待办数据迁移

Browse Source 
背景：
  https://jira.axzo.cn/browse/REQ-1507?goToView=1

影响：
  无
This commit is contained in:
luofu 2023-11-20 14:29:52 +08:00
parent 72582e108b
commit 2315c3b091
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageDataInitServiceImpl.java
View File

@ -20,6 +20,7 @@ import cn.axzo.msg.center.utils.UUIDUtil;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -96,6 +97,7 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit
} }
List<PendingMessageRecord> pendingMessageRecords = records.stream() List<PendingMessageRecord> pendingMessageRecords = records.stream()
.map(this::convert) .map(this::convert)
.filter(e -> StringUtils.isNotBlank(e.getTemplateCode()))
.collect(Collectors.toList()); .collect(Collectors.toList());
//批量插入数据库 //批量插入数据库
pendingMessageRecordDao.saveOrUpdateBatch(pendingMessageRecords); pendingMessageRecordDao.saveOrUpdateBatch(pendingMessageRecords);