|
|
|
@@ -231,13 +231,17 @@ public class BaseServiceImpl<Q extends BaseEntity, D extends BaseEntity, IDG ext |
|
|
|
@Override |
|
|
|
public void createEsIndex(D dto) { |
|
|
|
boolean exists = false; |
|
|
|
String indexName = activeProfile+"_"+dto.getClass().getSimpleName(); |
|
|
|
indexName = indexName.toLowerCase(); |
|
|
|
try { |
|
|
|
exists = client.indices().exists(query -> query.index(activeProfile+"_"+dto.getClass().getSimpleName())).value(); |
|
|
|
String finalIndexName = indexName; |
|
|
|
exists = client.indices().exists(query -> query.index(finalIndexName)).value(); |
|
|
|
System.out.println(exists); |
|
|
|
if (exists) { |
|
|
|
log.info("索引已存在"); |
|
|
|
} else { |
|
|
|
final CreateIndexResponse products = client.indices().create(builder -> builder.index(activeProfile+"_"+dto.getClass().getSimpleName())); |
|
|
|
String finalIndexName1 = indexName; |
|
|
|
final CreateIndexResponse products = client.indices().create(builder -> builder.index(finalIndexName1)); |
|
|
|
log.info(products.acknowledged()?"索引创建成功" : "索引创建失败"); |
|
|
|
} |
|
|
|
} catch (IOException e) { |
|
|
|
@@ -249,9 +253,12 @@ public class BaseServiceImpl<Q extends BaseEntity, D extends BaseEntity, IDG ext |
|
|
|
@Override |
|
|
|
public void saveToEs(BaseEntity dto) { |
|
|
|
try { |
|
|
|
String indexName = activeProfile+"_"+dto.getClass().getSimpleName(); |
|
|
|
indexName = indexName.toLowerCase(); |
|
|
|
createEsIndex((D)dto); |
|
|
|
String finalIndexName = indexName; |
|
|
|
client.index(i -> i |
|
|
|
.index(activeProfile+"_"+dto.getClass().getSimpleName()) |
|
|
|
.index(finalIndexName) |
|
|
|
.id(dto.getId().toString()) |
|
|
|
.document(dto)); |
|
|
|
} catch (IOException e) { |
|
|
|
|