B2C物料搜索 - 实时更新问题处理

mall-search/src/main/java/com/uas/search/constant/SearchConstants.java

@@ -64,7 +64,7 @@ public class SearchConstants {
 	public static final String PURCHASE_INVOICE_TABLE_NAME = "trade$invoice_fmpu";
 
 	/**
-	 * 物料表（标准）
+	 * 物料表
 	 */
 	public static final String PRODUCTS_PRIVATE_TABLE_NAME = "v$product$private";
 

mall-search/src/main/java/com/uas/search/service/impl/IndexServiceImpl.java

@@ -839,7 +839,7 @@ public class IndexServiceImpl implements IndexService {
                         indexWriter.updateDocument(new Term(SearchConstants.PURCHASE_INVOICE_ID_FIELD,
                                 String.valueOf(((PurchaseInvoice) obj).getId())), document);
                     } else if (obj instanceof  V_Products) {
-                        indexWriter.updateDocument(new Term(SearchConstants.PRODUCTS_PRIVATE_TABLE_NAME,
+                        indexWriter.updateDocument(new Term(SearchConstants.PRODUCT_PRIVATE_ID_FIELD,
                                 String.valueOf(((V_Products) obj).getId())), document);
                     } else {
                         throw new IllegalStateException("Message parsing failed!");
@@ -942,7 +942,7 @@ public class IndexServiceImpl implements IndexService {
                     indexWriter.deleteDocuments(new Term(SearchConstants.PURCHASE_INVOICE_ID_FIELD,
                             String.valueOf(((PurchaseInvoice) obj).getId())));
                 } else if (obj instanceof V_Products) {
-                    indexWriter.deleteDocuments(new Term(SearchConstants.PRODUCTS_PRIVATE_TABLE_NAME,
+                    indexWriter.deleteDocuments(new Term(SearchConstants.PRODUCT_PRIVATE_ID_FIELD,
                             String.valueOf(((V_Products) obj).getId())));
                 } else {
                     throw new IllegalStateException("Message parsing failed!");

mall-search/src/main/resources/application.yml

@@ -24,4 +24,6 @@ security:
  ignored: false
   
 schedule:
- auto-start: false
+ auto-start: false
+server:
+  port: 8888