将数据库数据导入到Elasticsearch

通过分页的思想，将数据，一步步导入到ES
下面就是具体业务逻辑代码， 其他代码，就不一一列出了。

 /**
     * 循环导入数据库的数据
     * @param status sku 的状态， 是否上架
     */
    @Override
    public void importSku(String status) {

        // 查询出总记录数
        Integer count = skuFeign.findCountByStatus(status).getData();

        Integer pageSize = 20000; // 每页的数

        Integer pageCount = (int)Math.ceil((double) count / pageSize); // 总页数

        for (int i = 1; i <= pageCount; i++) {
            // 1. 调用skuFeign 查询所有上架的商品
            Result<List<Sku>> skus = skuFeign.findByStatus(status,i, pageSize);
            // 2. 把商品集合。转换为Skuinfo
            List<SkuInfo> skuInfos = JSON.parseArray(JSON.toJSONString(skus.getData()), SkuInfo.class);
            for (SkuInfo skuInfo : skuInfos) {
                Map<String,Object> map = JSON.parseObject(skuInfo.getSpec(), Map.class);// 把规格转换为Map， 在es中，会把map 的key作为域，把value作为值
                skuInfo.setSpecMap(map);
            }
            // 3.保存数据
            skuEsMapper.saveAll(skuInfos);
        }
    }