//package com.winhc.phoenix.example.scheduled; // //import com.winhc.phoenix.example.service.SearchService; //import com.winhc.phoenix.example.service.impl.SearchV8SimpServiceImpl; //import lombok.extern.slf4j.Slf4j; //import org.springframework.beans.factory.annotation.Qualifier; // //import java.util.HashSet; // ///** // * @author: XuJiakai // * 2020/12/2 10:11 // */ ////@Component //@Slf4j //public class ElasticsearchTask { // public ElasticsearchTask(@Qualifier(SearchV8SimpServiceImpl.index) SearchService searchService) { // this.searchService = searchService; // } // // private final SearchService searchService; // private static final String[] keywords = new String[]{"所", "厂", "集团", "店", "公司", "县", "市", "省", "区", "场", "会"}; // private static int i = 0; // //// @Scheduled(cron = "0 0/1 * * * ? ") // public void preheat() { // i = ++i % keywords.length; // int size = (int) (Math.random() * 9 + 1); //// String k = keywords[(int) (Math.random() * keywords.length)]; // String k = keywords[i]; // log.info("preheat index {} {}...", k, size); // Object query = searchService.query(k, size, size,new HashSet<>()); //// log.info("{}", query); // log.info("preheat successfully !"); // } //}