初始化无问题词数据

knowledgeman-service/src/main/java/com/diagbot/client/NeoServiceClient.java

@@ -7,6 +7,8 @@ import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 
+import java.util.List;
+
 
 /**
  * @Description: 图谱服务
@@ -21,6 +23,9 @@ public interface NeoServiceClient {
 
     @PostMapping("/knowledge/deleteDisease")
     RespDTO<Boolean> deleteNeo(@RequestBody NeoParamVO neoParamVO);
+
+    @PostMapping("/knowledge/init")
+    RespDTO<Boolean> initNeo(@RequestBody List<Long> idList);
 }
 
 

knowledgeman-service/src/main/java/com/diagbot/client/hystrix/NeoServiceHystrix.java

@@ -6,6 +6,8 @@ import com.diagbot.vo.NeoParamVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 
 /**
  * @Description: 图谱服务
@@ -28,4 +30,10 @@ public class NeoServiceHystrix implements NeoServiceClient {
         log.error("【hystrix】调用{}异常", "deleteNeo");
         return null;
     }
+
+    @Override
+    public RespDTO<Boolean> initNeo(List<Long> idList) {
+        log.error("【hystrix】调用{}异常", "initNeo");
+        return null;
+    }
 }

knowledgeman-service/src/main/java/com/diagbot/config/ResourceServerConfigurer.java

@@ -36,6 +36,7 @@ public class ResourceServerConfigurer extends ResourceServerConfigurerAdapter {
                 .antMatchers("/commonconcept/getConceptMapByNameAndType").permitAll()
                 .antMatchers("/commonconcept/index").permitAll()
                 .antMatchers("/commonconcept/indexByLexicon").permitAll()
+                .antMatchers("/diagnose/initNeo").permitAll()
                 .antMatchers("/**").authenticated();
 //                .antMatchers("/**").permitAll();
     }

knowledgeman-service/src/main/java/com/diagbot/config/security/UrlAccessDecisionManager.java

@@ -99,6 +99,7 @@ public class UrlAccessDecisionManager implements AccessDecisionManager {
                 || matchers("/commonconcept/getConceptMapByNameAndType", request)
                 || matchers("/commonconcept/index", request)
                 || matchers("/commonconcept/indexByLexicon", request)
+                || matchers("/diagnose/initNeo", request)
                 || matchers("/", request)) {
             return true;
         }

knowledgeman-service/src/main/java/com/diagbot/facade/DiagnoseFacade.java

@@ -149,6 +149,27 @@ public class DiagnoseFacade extends DiagnoseServiceImpl {
     }
 
 
+    /**
+     * 初始化图谱数据
+     *
+     * @return
+     */
+    public void initNeo() {
+        this.update(new Diagnose(), new UpdateWrapper<Diagnose>()
+                .eq("is_deleted", IsDeleteEnum.N.getKey())
+                .eq("has_question", HasQuestionEnum.NO_QUESTION.getKey())
+                .set("neo_update", DateUtil.getDateFromTime(1970, 1, 1, 12, 0, 0))
+        );
+        List<Diagnose> diagnoseList = this.list(new QueryWrapper<Diagnose>()
+                .eq("is_deleted", IsDeleteEnum.N.getKey())
+                .eq("has_question", HasQuestionEnum.NO_QUESTION.getKey())
+        );
+        List<Long> idList = diagnoseList.stream().map(row -> row.getId()).collect(Collectors.toList());
+        RespDTO<Boolean> respDTO = neoServiceClient.initNeo(idList);
+        RespDTOUtil.respNGDeal(respDTO, "初始化图谱数据失败【远程调用】");
+    }
+
+
     public String addTest() {
         StringBuffer sb = new StringBuffer();
         List<Diagnose> diagnoseList = this.list(new QueryWrapper<Diagnose>()

knowledgeman-service/src/main/java/com/diagbot/web/DiagnoseController.java

@@ -132,4 +132,14 @@ public class DiagnoseController {
         String str = diagnoseFacade.addTest();
         return RespDTO.onSuc(str);
     }
+
+
+    @ApiOperation(value = "诊断依据-初始化图谱数据[by:zhoutg]")
+    @PostMapping("/initNeo")
+    @SysLogger("initNeo")
+    @ApiIgnore
+    public RespDTO<Boolean> initNeo() {
+        diagnoseFacade.initNeo();
+        return RespDTO.onSuc(true);
+    }
 }