phoenix-example/src/main/java/com/winhc/phoenix/example/scheduled/ElasticsearchTask.java

//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 !");
//    }
//}