|
|
|
@@ -256,15 +256,16 @@ public class BaseServiceImpl<Q extends BaseEntity, D extends BaseEntity, IDG ext |
|
|
|
@Override |
|
|
|
public void saveToEs(BaseEntity dto) { |
|
|
|
try { |
|
|
|
// CharsetUtil |
|
|
|
String indexName = activeProfile+"_"+StrUtil.camelCaseToUnderscore(dto.getClass().getSimpleName()); |
|
|
|
log.info("indexName:{}", indexName); |
|
|
|
createEsIndex((D)dto); |
|
|
|
String finalIndexName = indexName; |
|
|
|
client.index(i -> i |
|
|
|
.index(finalIndexName) |
|
|
|
.id(dto.getId().toString()) |
|
|
|
.document(dto)); |
|
|
|
if (null != dto.getId()) { |
|
|
|
String indexName = activeProfile+"_"+StrUtil.camelCaseToUnderscore(dto.getClass().getSimpleName()); |
|
|
|
log.info("indexName:{}", indexName); |
|
|
|
createEsIndex((D)dto); |
|
|
|
String finalIndexName = indexName; |
|
|
|
client.index(i -> i |
|
|
|
.index(finalIndexName) |
|
|
|
.id(dto.getId().toString()) |
|
|
|
.document(dto)); |
|
|
|
} |
|
|
|
} catch (IOException e) { |
|
|
|
e.printStackTrace(); |
|
|
|
throw new RuntimeException(e); |
|
|
|
|