替换链接

src/main/resources/application-dev.properties

@@ -122,7 +122,9 @@ spring.elasticsearch.bboss.es5.name = es5
 spring.elasticsearch.bboss.es5.elasticUser=elastic
 spring.elasticsearch.bboss.es5.elasticPassword=elastic_168
 
-spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.public.elasticsearch.aliyuncs.com:9200
+#5.x版本es
+#spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.public.elasticsearch.aliyuncs.com:9200
+spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-zxu362ii6000oj8y3.public.elasticsearch.aliyuncs.com:9200
 #spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.elasticsearch.aliyuncs.com:9200
 
 #spring.elasticsearch.bboss.default.elasticsearch.rest.hostNames=10.180.211.27:9280,10.180.211.27:9281,10.180.211.27:9282

src/main/resources/application-prd.properties

@@ -115,7 +115,9 @@ spring.elasticsearch.bboss.es5.elasticUser=elastic
 spring.elasticsearch.bboss.es5.elasticPassword=elastic_168
 
 #spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.public.elasticsearch.aliyuncs.com:9200
-spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.elasticsearch.aliyuncs.com:9200
+#5.x版本链接
+#spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-0pp0r32zf000ipovd.elasticsearch.aliyuncs.com:9200
+spring.elasticsearch.bboss.es5.elasticsearch.rest.hostNames=es-cn-zxu362ii6000oj8y3.elasticsearch.aliyuncs.com:9200
 
 #spring.elasticsearch.bboss.default.elasticsearch.rest.hostNames=10.180.211.27:9280,10.180.211.27:9281,10.180.211.27:9282
 spring.elasticsearch.bboss.es5.elasticsearch.dateFormat=yyyy.MM.dd

src/main/resources/logback-spring.xml

@@ -28,8 +28,8 @@
         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
             <!-- 日志文件名格式 -->
             <fileNamePattern>logs/info.%d{yyyy-MM-dd}.log</fileNamePattern>
-            <!-- 最大保存时间：30天-->
-            <maxHistory>30</maxHistory>
+            <!-- 最大保存时间：7天-->
+            <maxHistory>7</maxHistory>
         </rollingPolicy>
     </appender>
 

src/test/java/com/winhc/test/TestEsApi.java

@@ -0,0 +1,47 @@
+package com.winhc.test;
+
+import com.alibaba.fastjson.JSON;
+import com.winhc.kafka.KafkaProduce;
+import com.winhc.service.EsQueryService;
+import com.winhc.service.impl.CaseRelationIncrImpl;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.neo4j.driver.Driver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.HashMap;
+
+/**
+ * @author π
+ * @Description:案件关联测试
+ * @date 2021/05/17 16:24
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class TestEsApi {
+    Log log = LogFactory.getLog(TestEsApi.class);
+    @Autowired
+    CaseRelationIncrImpl caseRelationImpl;
+
+    @Autowired
+    Driver driver;
+    @Autowired
+    KafkaProduce kafkaProduce;
+
+    @Autowired
+    EsQueryService esQueryService;
+
+
+    @Test
+    public void testEs() {
+        String human_pid = "p1fced228c8a568e7184372831f8e74b8";
+        Integer count = esQueryService.queryByDsl(human_pid);
+        System.out.println(count);
+    }
+
+
+}

src/test/java/com/winhc/test/TestPersonUpdate.java

@@ -95,7 +95,7 @@ public class TestPersonUpdate {
         //String relation_index = "winhc-company-human-relation";
         String relation_index = "winhc-company-human-relation-v9";
 
-        Arrays.stream(loadResourceAsString("data/update_pid.txt")
+        Arrays.stream(loadResourceAsString("data/update_pid2.txt")
                 .split("\n"))
                 .filter(StringUtils::isNotBlank)
                 .distinct()