hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-11 11:56:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

es数据同步

Browse Source
This commit is contained in:
yang
2024-12-18 13:39:21 +08:00
parent be18f7477b
commit 9866618110
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
servers/boe-server-all/src/main/java/com/xboe/school/study/api/PhpOnlineStudyRecordScheduledTasks.java
View File

@@ -133,7 +133,7 @@ public class PhpOnlineStudyRecordScheduledTasks {
}
// 调用批量更新方法
// toBeUpdatedEs(toBeUpdatedEs, indexName);
toBeUpdatedEs(toBeUpdatedEs);
}
return tempResultList;
}
@@ -181,7 +181,7 @@ public class PhpOnlineStudyRecordScheduledTasks {
return courseStudyDtoList;
}
private void toBeUpdatedEs(List<CourseStudyDto> toBeUpdatedEsData, String indexName) {
private void toBeUpdatedEs(List<CourseStudyDto> toBeUpdatedEsData) {
if (CollUtil.isEmpty(toBeUpdatedEsData)) {
return;
}
@@ -192,7 +192,7 @@ public class PhpOnlineStudyRecordScheduledTasks {
docMap.put("progress", courseStudyDto.getProgress());
// 创建更新请求，并传入单一的docMap
UpdateRequest updateRequest = new UpdateRequest(indexName, courseStudyDto.getId())
UpdateRequest updateRequest = new UpdateRequest("new_study_resource", courseStudyDto.getId())
.doc(docMap, XContentType.JSON);
// 将请求添加到批量请求中