LPD-17341 DDLRecordBatchReindexer is an internal interface, it should not be registered as osgi service

Author: shuyangzhou

modules/apps/dynamic-data-lists/dynamic-data-lists-service/src/main/java/com/liferay/dynamic/data/lists/internal/search/DDLRecordBatchReindexer.java

@@ -5,11 +5,46 @@
 
 package com.liferay.dynamic.data.lists.internal.search;
 
+import com.liferay.dynamic.data.lists.model.DDLRecord;
+import com.liferay.portal.kernel.dao.orm.Property;
+import com.liferay.portal.kernel.dao.orm.PropertyFactoryUtil;
+import com.liferay.portal.search.batch.BatchIndexingActionable;
+import com.liferay.portal.search.indexer.IndexerDocumentBuilder;
+import com.liferay.portal.search.indexer.IndexerWriter;
+
 /**
  * @author Marcela Cunha
  */
-public interface DDLRecordBatchReindexer {
+public class DDLRecordBatchReindexer {
+
+	public DDLRecordBatchReindexer(
+		IndexerDocumentBuilder indexerDocumentBuilder,
+		IndexerWriter<DDLRecord> indexerWriter) {
+
+		_indexerDocumentBuilder = indexerDocumentBuilder;
+		_indexerWriter = indexerWriter;
+	}
+
+	public void reindex(long ddlRecordSetId, long companyId) {
+		BatchIndexingActionable batchIndexingActionable =
+			_indexerWriter.getBatchIndexingActionable();
+
+		batchIndexingActionable.setAddCriteriaMethod(
+			dynamicQuery -> {
+				Property recordIdProperty = PropertyFactoryUtil.forName(
+					"recordSetId");
+
+				dynamicQuery.add(recordIdProperty.eq(ddlRecordSetId));
+			});
+		batchIndexingActionable.setCompanyId(companyId);
+		batchIndexingActionable.setPerformActionMethod(
+			(DDLRecord record) -> batchIndexingActionable.addDocuments(
+				_indexerDocumentBuilder.getDocument(record)));
+
+		batchIndexingActionable.performActions();
+	}
 
-	public void reindex(long ddlRecordSetId, long companyId);
+	private final IndexerDocumentBuilder _indexerDocumentBuilder;
+	private final IndexerWriter<DDLRecord> _indexerWriter;
 
 }

modules/apps/dynamic-data-lists/dynamic-data-lists-service/src/main/java/com/liferay/dynamic/data/lists/internal/search/DDLRecordBatchReindexerImpl.java

@@ -6,10 +6,13 @@
 package com.liferay.dynamic.data.lists.internal.search;
 
 import com.liferay.dynamic.data.lists.internal.search.spi.model.index.contributor.DDLRecordSetModelIndexerWriterContributor;
+import com.liferay.dynamic.data.lists.model.DDLRecord;
 import com.liferay.dynamic.data.lists.model.DDLRecordSet;
 import com.liferay.dynamic.data.lists.service.DDLRecordSetLocalService;
 import com.liferay.portal.kernel.search.Field;
 import com.liferay.portal.search.batch.DynamicQueryBatchIndexingActionableFactory;
+import com.liferay.portal.search.indexer.IndexerDocumentBuilder;
+import com.liferay.portal.search.indexer.IndexerWriter;
 import com.liferay.portal.search.spi.model.index.contributor.ModelIndexerWriterContributor;
 import com.liferay.portal.search.spi.model.registrar.ModelSearchConfigurator;
 
@@ -53,20 +56,29 @@ public String[] getDefaultSelectedLocalizedFieldNames() {
 	protected void activate() {
 		_modelIndexWriterContributor =
 			new DDLRecordSetModelIndexerWriterContributor(
-				_ddlRecordBatchReindexer, _ddlRecordSetLocalService,
+				new DDLRecordBatchReindexer(
+					_indexerDocumentBuilder, _indexerWriter),
+				_ddlRecordSetLocalService,
 				_dynamicQueryBatchIndexingActionableFactory);
 	}
 
-	@Reference
-	private DDLRecordBatchReindexer _ddlRecordBatchReindexer;
-
 	@Reference
 	private DDLRecordSetLocalService _ddlRecordSetLocalService;
 
 	@Reference
 	private DynamicQueryBatchIndexingActionableFactory
 		_dynamicQueryBatchIndexingActionableFactory;
 
+	@Reference(
+		target = "(indexer.class.name=com.liferay.dynamic.data.lists.model.DDLRecord)"
+	)
+	private IndexerDocumentBuilder _indexerDocumentBuilder;
+
+	@Reference(
+		target = "(indexer.class.name=com.liferay.dynamic.data.lists.model.DDLRecord)"
+	)
+	private IndexerWriter<DDLRecord> _indexerWriter;
+
 	private ModelIndexerWriterContributor<DDLRecordSet>
 		_modelIndexWriterContributor;