|
@@ -288,6 +288,7 @@ public class DataFlushService {
|
|
|
Map<String, LongArticlesText> kimiTitleMap = kimiTitleList.stream().collect(
|
|
|
Collectors.toMap(LongArticlesText::getContentId, o -> o, (existing, replacement) -> replacement));
|
|
|
List<LongArticlesText> updateList = longArticleBaseMapper.getNeedUpdateRecords();
|
|
|
+ int updateNum = 0;
|
|
|
for (LongArticlesText update : updateList) {
|
|
|
LongArticlesText kimi = kimiTitleMap.get(update.getContentId());
|
|
|
if (Objects.nonNull(kimi)) {
|
|
@@ -297,7 +298,9 @@ public class DataFlushService {
|
|
|
update.setKimiKeys(kimi.getKimiKeys());
|
|
|
longArticleBaseMapper.updateLongArticlesText(update);
|
|
|
});
|
|
|
+ updateNum++;
|
|
|
}
|
|
|
}
|
|
|
+ log.info("flushLongArticlesText updateNum:{}", updateNum);
|
|
|
}
|
|
|
}
|