feat: es集成

tfis-admin/src/main/java/com/tfis/system/controller/FaultCaseController.java

@@ -99,6 +99,11 @@ public class FaultCaseController extends BaseController {
         return toAjax(faultCaseService.updateFaultCase(faultCase));
     }
 
+    @GetMapping("/syncEsData")
+    public AjaxResult syncEsData() {
+        return toAjax(faultCaseService.syncEsData());
+    }
+
     /**
      * 删除故障案例管理
      */

tfis-admin/src/main/java/com/tfis/system/service/IFaultCaseService.java

@@ -61,4 +61,6 @@ public interface IFaultCaseService {
     public int deleteFaultCaseById(Long id);
 
     int countPlus(Long id);
+
+    boolean syncEsData();
 }

tfis-admin/src/main/java/com/tfis/system/service/impl/FaultCaseServiceImpl.java

@@ -115,4 +115,19 @@ public class FaultCaseServiceImpl implements IFaultCaseService {
     public int countPlus(Long id) {
         return faultCaseMapper.countPlus(id);
     }
+
+    /**
+     * 数据同步到es
+     *
+     * @return 插入的数据总数
+     */
+    @Override
+    public boolean syncEsData() {
+        esFaultCaseMapper.deleteIndex("fault_case_index");
+        if (!esFaultCaseMapper.existsIndex("fault_case_index")) {
+            esFaultCaseMapper.createIndex();
+        }
+        Integer count = esFaultCaseMapper.insertBatch(faultCaseMapper.selectFaultCaseList(new FaultCase()));
+        return count > 0;
+    }
 }