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 org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * @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);
        log.info("{}", query);
        log.info("preheat successfully !");
    }
}