要把数据库数据导入到elasticsearch中，包括下面几步： - 1）将商品微服务中的分页查询商品接口定义为一个FeignClient，放到feign-api模块中 - 2）搜索服务编写一个业务，实现下面功能： - 调用item-service提供的FeignClient，分页查询商品 `PageDTO<Item>` - 将查询到的商品封装为一个`ItemDoc`对象，放入`ItemDoc`集合 - 将`ItemDoc`集合批量导入elasticsearch中

对于这个问题，需要进行以下几个步骤：

1. 创建一个FeignClient，用于调用商品微服务中的分页查询商品接口。

@FeignClient(name = "item-service")
public interface ItemFeignClient {
    @GetMapping("/item/page")
    PageDTO<Item> getItemPage(@RequestParam("pageNum") Integer pageNum, @RequestParam("pageSize") Integer pageSize);
}

2. 在搜索服务中编写一个业务方法，调用商品微服务提供的FeignClient，将查询到的商品封装为一个ItemDoc对象，放入ItemDoc集合。可以使用MapStruct来实现对象之间的转换。

@Service
public class ItemSearchService {
    @Autowired
    private ItemFeignClient itemFeignClient;

    @Autowired
    private ItemDocRepository itemDocRepository;

    @Autowired
    private ItemMapper itemMapper;

    public void importDataToES() {
        // 分页查询商品
        int pageNum = 1;
        int pageSize = 100;
        PageDTO<Item> itemPage = itemFeignClient.getItemPage(pageNum, pageSize);

        // 将查询到的商品封装为ItemDoc对象，放入ItemDoc集合
        List<Item> itemList = itemPage.getData();
        List<ItemDoc> itemDocList = itemMapper.toItemDocList(itemList);

        // 将ItemDoc集合批量导入elasticsearch中
        itemDocRepository.saveAll(itemDocList);
    }
}

3. 在业务方法中调用Elasticsearch的Repository，将ItemDoc集合批量导入到Elasticsearch中。需要先在Spring Boot中配置Elasticsearch的连接信息。

@Configuration
public class ElasticsearchConfig {
    @Value("${elasticsearch.host}")
    private String host;

    @Value("${elasticsearch.port}")
    private int port;

    @Value("${elasticsearch.scheme}")
    private String scheme;

    @Value("${elasticsearch.index.name}")
    private String indexName;

    @Bean
    public RestHighLevelClient restHighLevelClient() {
        RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, scheme));
        RestHighLevelClient client = new RestHighLevelClient(builder);
        return client;
    }

    @Bean
    public ElasticsearchOperations elasticsearchTemplate() {
        return new ElasticsearchRestTemplate(restHighLevelClient());
    }

    @Bean
    public IndexOperations indexOperations() {
        return elasticsearchTemplate().indexOps(ItemDoc.class);
    }

    @Bean
    public ItemDocRepository itemDocRepository() {
        return new ItemDocRepositoryImpl(elasticsearchTemplate());
    }
}

@Repository
public class ItemDocRepositoryImpl implements ItemDocRepository {
    private ElasticsearchOperations elasticsearchOperations;

    public ItemDocRepositoryImpl(ElasticsearchOperations elasticsearchOperations) {
        this.elasticsearchOperations = elasticsearchOperations;
    }

    @Override
    public void saveAll(List<ItemDoc> items) {
        IndexCoordinates indexCoordinates = elasticsearchOperations.getIndexCoordinatesFor(ItemDoc.class);
        List<IndexQuery> indexQueries = items.stream().map(item -> new IndexQueryBuilder().withObject(item).build()).collect(Collectors.toList());
        elasticsearchOperations.bulkIndex(indexQueries, indexCoordinates);
    }
}

4. 最后，在搜索服务的启动类中调用业务方法，将商品数据导入到Elasticsearch中。

@SpringBootApplication
public class SearchServiceApplication {
    @Autowired
    private ItemSearchService itemSearchService;

    public static void main(String[] args) {
        SpringApplication.run(SearchServiceApplication.class, args);
    }

    @PostConstruct
    public void init() {
        itemSearchService.importDataToES();
    }
}