From 33c3a194cad905990dcec693b68f953e3b1abfe5 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Fri, 5 Dec 2025 16:01:46 +0800
Subject: [PATCH] =?UTF-8?q?refactor(kafka):=20=E4=BF=AE=E6=94=B9=E4=BA=BA?=
 =?UTF-8?q?=E8=84=B8=E5=BA=93=E5=88=86=E7=BB=84=E5=91=BD=E5=90=8D=E8=A7=84?=
 =?UTF-8?q?=E5=88=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将人脸库分组名称从 "ai-cam-{deviceId}" 更改为 "AiCam{deviceId}"
- 更新 FaceProcessingKafkaService 中的数据库名称生成逻辑
- 同步修改 FaceDetectLogAiCamServiceImpl 中的数据库名称使用方式
---
 .../integration/kafka/service/FaceProcessingKafkaService.java | 4 ++--
 .../basic/service/pc/impl/FaceDetectLogAiCamServiceImpl.java  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java b/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
index 1eca19c1..bff83f54 100644
--- a/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
+++ b/src/main/java/com/ycwl/basic/integration/kafka/service/FaceProcessingKafkaService.java
@@ -471,8 +471,8 @@ public class FaceProcessingKafkaService {
                 return;
             }
 
-            // 使用 "ai-cam-" + deviceId 作为人脸库分组
-            String dbName = "ai-cam-" + deviceId;
+            // 使用 "AiCam" + deviceId 作为人脸库分组
+            String dbName = "AiCam" + deviceId;
             taskFaceService.assureFaceDb(adapter, dbName);
 
             String faceUniqueId = faceSampleId.toString();
diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/FaceDetectLogAiCamServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/FaceDetectLogAiCamServiceImpl.java
index b234b060..0d22dc29 100644
--- a/src/main/java/com/ycwl/basic/service/pc/impl/FaceDetectLogAiCamServiceImpl.java
+++ b/src/main/java/com/ycwl/basic/service/pc/impl/FaceDetectLogAiCamServiceImpl.java
@@ -21,7 +21,7 @@ public class FaceDetectLogAiCamServiceImpl implements FaceDetectLogAiCamService
 
     @Override
     public SearchFaceResp searchAndLog(Long scenicId, Long deviceId, Long faceSampleId, String faceUrl, IFaceBodyAdapter adapter) {
-        String dbName = "ai-cam-" + deviceId;
+        String dbName = "AiCam" + deviceId;
         
         SearchFaceResp resp = null;
         try {