mirror of
https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git
synced 2025-12-07 01:46:47 +08:00
Merge branch 'refs/heads/zxwy-esSync' into dev1107
This commit is contained in:
@@ -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);
|
||||
|
||||
// 将请求添加到批量请求中
|
||||
|
||||
Reference in New Issue
Block a user