孙永军 1 anno fa
parent
commit
7d3fdddb30

+ 6 - 0
src/main/java/com/sxtvs/open/api/news/controller/YoumeiDataController.java

@@ -34,6 +34,12 @@ public class YoumeiDataController {
         return youmeiDataService.search(dataRequestDTO);
     }
 
+    @RequestMapping("info")
+    @LoginRequired
+    public YoumeiEsData search(String offset) throws Exception {
+        return youmeiDataService.getData(offset);
+    }
+
     @RequestMapping("/put/MWEZOWQ2NDYXMJU0NW")
     public void put2es(){
         youmeiDataService.putDataRun();

+ 12 - 0
src/main/java/com/sxtvs/open/api/news/service/impl/YoumeiDataServiceImpl.java

@@ -130,6 +130,18 @@ public class YoumeiDataServiceImpl extends ServiceImpl<YoumeiDataMapper, YoumeiD
         return page;
     }
 
+    public YoumeiEsData getData(String id) {
+        try {
+            ElasticsearchClient elasticsearchClient = esClientPool.getClient();
+            YoumeiEsData news_data = elasticsearchClient.search(x -> x.index("news_data").query(q -> q.ids(i -> i.values(id))), YoumeiEsData.class).hits().hits().get(0).source();
+            return news_data;
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+
+    }
+
     public void putDataRun() {
         (new Thread(this::putData)).start();
     }