实时更新时若新增数据，则调用update方法更新索引

search-console-b2b/src/main/java/com/uas/search/console/b2b/controller/IndexController.java

@@ -52,6 +52,7 @@ public class IndexController {
 		}
 	}
 
+	@RequestMapping("/listen/start")
 	@ResponseBody
 	public String startListen(Long waitInterval) {
 		return aqListener.start(waitInterval);

search-console-b2b/src/main/java/com/uas/search/console/b2b/jms/AQListener.java

@@ -172,14 +172,8 @@ public class AQListener {
 		if (objects == null) {
 			return;
 		}
-		// 新增索引
-		if (parsedQueueMessage.isInsert()) {
-			for (Object object : objects) {
-				indexService.save(object);
-			}
-		}
-		// 更新索引
-		else if (parsedQueueMessage.isUpdate()) {
+		// 新增、更新索引
+		if (parsedQueueMessage.isInsert() || parsedQueueMessage.isUpdate()) {
 			for (Object object : objects) {
 				indexService.update(object);
 			}

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

@@ -299,7 +299,8 @@ public class IndexServiceImpl implements IndexService {
 					count++;
 				}
 				size += content.size();
-				logger.info(String.format("Downloaded...................%.2f%%", size * 100.0 / totalElements));
+				logger.info(String.format(tableName.value() + "Downloaded...................%.2f%%",
+						size * 100.0 / totalElements));
 
 				pageParams.setPage(pageParams.getPage() + 1);
 				pageInfo = new PageInfo(pageParams);