Browse Source

add es , 通行记录入es

tags/B.1.2.4.0_20230908_base
yk 2 years ago
parent
commit
383587006a
2 changed files with 4 additions and 2 deletions
  1. +2
    -0
      xueyi-common/xueyi-common-web/src/main/java/com/xueyi/common/web/entity/service/impl/BaseServiceImpl.java
  2. +2
    -2
      xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/pass/controller/api/DmRecognizedRecordsInnerApiController.java

+ 2
- 0
xueyi-common/xueyi-common-web/src/main/java/com/xueyi/common/web/entity/service/impl/BaseServiceImpl.java View File

@@ -235,12 +235,14 @@ public class BaseServiceImpl<Q extends BaseEntity, D extends BaseEntity, IDG ext

try {
String finalIndexName = indexName;
log.info("indexName:{}", indexName);
exists = client.indices().exists(query -> query.index(finalIndexName)).value();
System.out.println(exists);
if (exists) {
log.info("索引已存在");
} else {
String finalIndexName1 = indexName;
log.info("exists:false, indexName:{}", indexName);
final CreateIndexResponse products = client.indices().create(builder -> builder.index(finalIndexName1));
log.info(products.acknowledged()?"索引创建成功" : "索引创建失败");
}


+ 2
- 2
xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/pass/controller/api/DmRecognizedRecordsInnerApiController.java View File

@@ -118,7 +118,7 @@ public class DmRecognizedRecordsInnerApiController extends BaseApiController {
}

dmRecognizedRecordsMapper.insert(cr);
recognizedRecordsService.saveToEs(cr);
recognizedRecordsService.saveToEs(recordsConverter.mapperDto(cr));

recognizedRecordsService.setRedisRecognizedCount(1);

@@ -184,7 +184,7 @@ public class DmRecognizedRecordsInnerApiController extends BaseApiController {
cr.setFaceUrl(url);
cr.setResourceId(dmResourcesDto.getId());
}
recognizedRecordsService.saveToEs(cr);
recognizedRecordsService.saveToEs(recordsConverter.mapperDto(cr));
crs.add(cr);
}



Loading…
Cancel
Save