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:31:27 +08:00
parent 2315c3b091
commit cb036a4886
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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 + "],不支持该接口操作");
}