更新 ES 实战代码

Author: Jackson0714

passjava-common/src/main/java/com/jackson0714/common/exception/BizCodeEnum.java

@@ -16,7 +16,8 @@
  ***/
 public enum BizCodeEnum {
     UNKNOWN_EXCEPTION(10000, "系统未知异常"),
-    VALID_EXCEPTION(10001, "参数格式校验失败");
+    VALID_EXCEPTION(10001, "参数格式校验失败"),
+    QUESTION_SAVE_EXCEPTION(12001, "题目保存异常");
 
     private int code;
     private String msg;

passjava-common/src/main/java/com/jackson0714/common/to/es/QuestionEsModel.java

@@ -29,10 +29,8 @@
 * */
 @Data
 public class QuestionEsModel {
-
     private Long id;
     private String title;
     private String answer;
     private String typeName;
-
 }

passjava-question/src/main/java/com/jackson0714/passjava/question/PassjavaQuestionApplication.java

@@ -4,7 +4,10 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.ComponentScan;
 
+@EnableFeignClients(basePackages = "com.jackson0714.passjava.question.feign")
 @EnableDiscoveryClient
 @MapperScan("com.jackson0714.passjava.question.dao")
 @SpringBootApplication

passjava-question/src/main/java/com/jackson0714/passjava/question/feign/SearchFeignService.java

@@ -0,0 +1,22 @@
+package com.jackson0714.passjava.question.feign;
+
+import com.jackson0714.common.to.es.QuestionEsModel;
+import com.jackson0714.common.utils.R;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+/**
+ * @Author: 公众号 | 悟空聊架构
+ * @Date: 2021/4/6 15:14
+ * @Site: www.passjava.cn
+ * @Github: https://github.com/Jackson0714/PassJava-Platform
+ */
+@Mapper
+@FeignClient("passjava-search")
+public interface SearchFeignService {
+
+    @PostMapping("search/question/save")
+    R saveQuestion(@RequestBody QuestionEsModel questionEsModel);
+}

passjava-question/src/main/java/com/jackson0714/passjava/question/service/IQuestionService.java

@@ -9,7 +9,7 @@
 /**
  * 
  *
- * @author jackson0714
+ * @author 公众号 | 悟空聊架构
  * @email jackson0585@163.com
  * @date 2020-04-25 22:34:04
  */

passjava-question/src/main/java/com/jackson0714/passjava/question/service/impl/QuestionServiceImpl.java

@@ -1,7 +1,9 @@
 package com.jackson0714.passjava.question.service.impl;
 
 import com.jackson0714.common.to.es.QuestionEsModel;
+import com.jackson0714.common.utils.R;
 import com.jackson0714.passjava.question.entity.TypeEntity;
+import com.jackson0714.passjava.question.feign.SearchFeignService;
 import com.jackson0714.passjava.question.service.ITypeService;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -23,7 +25,10 @@
 public class QuestionServiceImpl extends ServiceImpl<QuestionDao, QuestionEntity> implements IQuestionService {
 
     @Autowired
-    ITypeService ITypeService;
+    ITypeService typeService;
+
+    @Autowired
+    SearchFeignService searchFeignService;
 
     @Override
     public PageUtils queryPage(Map<String, Object> params) {
@@ -58,7 +63,7 @@ public boolean saveQuestion(QuestionEntity question) {
     public boolean updateQuestion(QuestionEntity question) {
         updateById(question);
         saveEs(question);
-        return false;
+        return true;
     }
 
     private boolean saveEs(QuestionEntity question) {
@@ -68,14 +73,22 @@ private boolean saveEs(QuestionEntity question) {
         // 2.1 复制属性
         BeanUtils.copyProperties(question, esModel);
         // 2.2 获取“题目类型”的名称
-        TypeEntity typeEntity = ITypeService.getById(question.getType());
+        TypeEntity typeEntity = typeService.getById(question.getType());
         String typeName = typeEntity.getType();
         // 2.3 给 ES model 的“类型”字段赋值
         esModel.setTypeName(typeName);
-        // 3.
         System.out.println("-----------------esModel:" + esModel);
 
-        return false;
+        // 3. 调用 passjava-search 服务，将数据发送到 ES 中保存。
+        R r = searchFeignService.saveQuestion(esModel);
+
+        System.out.println("r:" + r);
+
+        if (r.get("code") != 0) {
+            return false;
+        }
+
+        return true;
     }
 
 }

passjava-search/src/main/java/com/jackson0714/passjava/search/PassjavaSearchApplication.java

@@ -4,6 +4,7 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.context.annotation.ComponentScan;
 
 @EnableDiscoveryClient
 @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)

passjava-search/src/main/java/com/jackson0714/passjava/search/config/PassJavaElasticsearchConfig.java

@@ -10,7 +10,7 @@
 /**
  * @Author: 公众号 | 悟空聊架构
  * @Date: 2020/10/8 17:02
- * @Site: www.passjava.club
+ * @Site: www.passjava.cn
  * @Github: https://github.com/Jackson0714/PassJava-Platform
  */
 @Configuration

passjava-search/src/main/java/com/jackson0714/passjava/search/controller/QuestionController.java

@@ -1,5 +1,6 @@
 package com.jackson0714.passjava.search.controller;
 
+import com.jackson0714.common.exception.BizCodeEnum;
 import com.jackson0714.common.to.es.QuestionEsModel;
 import com.jackson0714.common.utils.R;
 import com.jackson0714.passjava.search.service.IQuestionService;
@@ -21,13 +22,21 @@
 public class QuestionController {
 
     @Autowired
-    IQuestionService IQuestionService;
+    IQuestionService questionService;
 
     // 保存题目到 ES。
     @PostMapping("/question/save")
     public R saveQuestion(@RequestBody QuestionEsModel questionEsModel) {
+        boolean result =false;
+        try {
+            result = questionService.save(questionEsModel);
+        } catch (Exception e) {
+            result =false;
+        }
 
-        IQuestionService.save(questionEsModel);
+        if (!result) {
+            return R.error(BizCodeEnum.QUESTION_SAVE_EXCEPTION.getCode(), BizCodeEnum.QUESTION_SAVE_EXCEPTION.getMsg());
+        }
 
         return R.ok();
     }

passjava-search/src/main/java/com/jackson0714/passjava/search/service/IQuestionService.java

@@ -1,13 +1,19 @@
 package com.jackson0714.passjava.search.service;
 
 import com.jackson0714.common.to.es.QuestionEsModel;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
 
 /**
  * @Author: 公众号 | 悟空聊架构
  * @Date: 2021/3/31 17:56
- * @Site: www.jayh.club
+ * @Site: www.passjava.cn
  * @Github: https://github.com/Jackson0714/PassJava-Platform
  */
+@Mapper
+@Component
 public interface IQuestionService {
-    void save(QuestionEsModel questionEsModel);
+    boolean save(QuestionEsModel questionEsModel) throws IOException;
 }