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 4530fd4b..0c509512 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 @@ -99,6 +99,7 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit .map(this::convert) .filter(e -> StringUtils.isNotBlank(e.getTemplateCode())) .collect(Collectors.toList()); + log.info("[cold_blade] transform rows:[{}]", pendingMessageRecords.size()); //批量插入数据库 pendingMessageRecordDao.saveOrUpdateBatch(pendingMessageRecords); } @@ -138,8 +139,7 @@ public class PendingMessageDataInitServiceImpl implements PendingMessageDataInit // 需要通过映射表获取 https://alidocs.dingtalk.com/i/nodes/YndMj49yWj7q1dB9h793q5dKV3pmz5aA?iframeQuery=utm_source%3Dportal%26utm_medium%3Dportal_recent String profile = environment.getProperty("spring.profiles.active"); if ("test".equals(profile) || "master".equals(profile)) { - String templateCode = msgTemplateMap.get(Integer.parseInt(String.valueOf(relationId))); - return templateCode; + return msgTemplateMap.get(Integer.parseInt(String.valueOf(relationId))); } throw new ServiceException("系统环境[" + profile + "],不支持该接口操作"); }