es工具类AbstractElasticSearch

 
import com.alibaba.fastjson.JSON;
 
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.get.MultiGetItemResponse;
import org.elasticsearch.action.get.MultiGetRequestBuilder;
import org.elasticsearch.action.get.MultiGetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.cluster.metadata.MappingMetaData;
import org.elasticsearch.common.collect.ImmutableOpenMap;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.sort.SortBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.concurrent.ExecutionException;

/**
 * ES搜索服务的抽象类
 *
 
 *
 * @param
 */
public abstract class AbstractElasticSearch {
    /** 日志记录 */
    public static final Logger logger = LoggerFactory.getLogger(AbstractElasticSearch.class);

    // 创建访问ES服务器的客户端

    protected Client client = ElasticSearchClientHelper.getInstance().getClient();

    /**
     * 索引名称 相当于数据库的数据名称
     *
     * @return
     */
    protected abstract String getIndex();

    /**
     * 类型名称 相当于数据库的表名
     *
     * @return
     */
    protected abstract String getType();

    /**
     * 获取集成类的类对象
     *
     * @return
     */
    protected abstract Class getBeanClass();

//    /**
//     * 自定义的查询条件 HashMap
//     *
//     * @param map
//     * @return
//     */
//    public abstract List query(HashMap map);

//    /**
//     * 将数据重新加载到ES到服务器中
//     */
//    public abstract void reLoad();

    /**
     * 将list集合转换为key为id和value为对象的map
     *
     * @param list
     * @return
     */
    protected  HashMap listToMap(List list){
        if (list == null || list.size()