代码提交

src/main/java/com/zzsn/leaderbase/config/MyApplicationRunner.java

+package com.zzsn.leaderbase.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.context.annotation.Bean;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+
+@Service
+@Slf4j
+public class MyApplicationRunner {
+
+    @PostConstruct
+    public  void pot(){
+        log.info("----------- PostConstruct is running ---------------");
+    }
+    @Bean
+    public ApplicationRunner applicationRunner(){
+       return (ApplicationArguments args)->{
+           log.info("-----------------------ApplicationRunner is running-------------------------");
+//           detailChongFu.group();
+       };
+    }
+    @Bean
+    public ApplicationRunner applicationRunner2(){
+        return  new ApplicationRunner() {
+            @Override
+            public void run(ApplicationArguments args) throws Exception {
+                log.info("-----------------------ApplicationRunner2 is running-------------------------");
+            }
+        };
+    }
+
+    /**所有的ApplicationRunner运行完毕之后才会开始运行CommandLineRunner*/
+    @Bean
+    public CommandLineRunner commandLineRunner(){
+        return  (String... args)->{
+
+            log.info("-----------------------CommandLineRunner is end-------------------------");
+
+        };
+    }
+
+    @Bean
+    public ApplicationRunner applicationRunner3(){
+        return (ApplicationArguments args)->{
+            log.info("-----------------------ApplicationRunner3 is running-------------------------");
+        };
+    }
+}

src/main/java/com/zzsn/leaderbase/service/DealLeaderDataService.java

@@ -52,6 +52,7 @@ public class DealLeaderDataService {
         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
         BoolQueryBuilder boolQueryBuilder1 = QueryBuilders.boolQuery()
                 .must(QueryBuilders.termsQuery("subjectId", Arrays.asList("1750716233967157250", "1750716067187048450")))
+                //.must(QueryBuilders.termsQuery("id", "1750716067187048450300259889635377190"))
                 ;
 
         boolQueryBuilder1.filter(QueryBuilders.rangeQuery("createDate").gte(EsDateUtil.esFieldDateFormat(startTime)));
@@ -101,6 +102,7 @@ public class DealLeaderDataService {
                                     boolean b = characterInfoService.deduplication(temp.get("curStation") != null ? temp.get("curStation").toString() : "",
                                             temp.get("curWorkPlace") != null ? temp.get("curWorkPlace").toString() : "",
                                             temp.get("person") != null ? temp.get("person").toString() : "");
+                                    //b = false;
                                     if(b){
                                         log.info("数据重复：{}",data.toString());
                                     } else {