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