修复方法

src/main/java/com/futu/course/es/Service/impl/ESCourseService.java

@@ -26,6 +26,7 @@ import org.elasticsearch.index.query.BoolQueryBuilder;
 import org.elasticsearch.index.query.MatchAllQueryBuilder;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.index.reindex.DeleteByQueryRequest;
+import org.elasticsearch.rest.BaseRestHandler;
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.xcontent.XContentBuilder;
@@ -38,6 +39,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.io.IOException;
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * @author "杨旭朋"
@@ -378,4 +380,19 @@ public class ESCourseService {
         return true;
     }
 
+    public List<MongoDBCourse> searchLogs(){
+        List<MongoDBCourse> all = esService.findAll();
+        List<MongoDBCourse> mongoDBCourses = new ArrayList<>();
+        for (MongoDBCourse mongoDBCourse : all) {
+            if (mongoDBCourse.getUid().equals(1L)){
+                mongoDBCourses.add(mongoDBCourse);
+            }
+        }
+        // 按 createTime 降序排序并取最多 10 条数据
+        List<MongoDBCourse> sortedCourses = mongoDBCourses.stream()
+                .sorted(Comparator.comparing(MongoDBCourse::getCreateTime).reversed())
+                .limit(10)
+                .collect(Collectors.toList());
+        return sortedCourses;
+    }
 }

src/main/java/com/futu/course/es/controller/ESCourseController.java

@@ -2,12 +2,14 @@ package com.futu.course.es.controller;
 
 import com.futu.course.es.Service.impl.ESCourseService;
 import com.futu.course.es.domain.ESCourse;
+import com.futu.course.es.domain.MongoDBCourse;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashSet;
+import java.util.List;
 
 /**
  * @author "杨旭朋"
@@ -39,4 +41,9 @@ public class ESCourseController {
     public boolean checkAndCreateIndex() throws IOException {
         return esCourseService.checkAndCreateIndex();
     }
+
+    @GetMapping("/searchLogs")
+    public List<MongoDBCourse> searchLogs(){
+        return esCourseService.searchLogs();
+    }
 }

接口文档.txt

@@ -0,0 +1,6 @@
+      方法               参数              返回                 作用           请求         请求路径
+   search             String name    ArrayList<String>       搜索指引         post     /EsCourse/search
+   MysqlInterES          无                无              同步mysql中的数据   get      /EsCourse/MysqlInterES
+   CourseList         int categoryId  HashSet<ESCourse>    课程分类查询所有    Post     /EsCourse/CourseList
+   SelCourse          String name     HashSet<ESCourse>     课程的搜索        Post     /EsCourse/SelCourse
+   checkAndCreateIndex  无              boolean           ES索引结构初始化     Get      /EsCourse/checkAndCreateIndex