From ad87d4396bb3ac5542901d6656444aa1fce1169e Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Thu, 26 Dec 2024 14:07:11 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B0=BD=E5=8F=AF=E8=83=BD=E7=A1=AE=E4=BF=9D?=
 =?UTF-8?q?=E6=99=AF=E5=8C=BA=E4=BA=BA=E8=84=B8=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E5=AD=98=E5=9C=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/pc/ScenicServiceImpl.java    | 21 +++++++++++--------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/service/impl/pc/ScenicServiceImpl.java b/src/main/java/com/ycwl/basic/service/impl/pc/ScenicServiceImpl.java
index a659f65..e7711f3 100644
--- a/src/main/java/com/ycwl/basic/service/impl/pc/ScenicServiceImpl.java
+++ b/src/main/java/com/ycwl/basic/service/impl/pc/ScenicServiceImpl.java
@@ -16,6 +16,7 @@ import com.ycwl.basic.model.pc.scenic.req.ScenicAddOrUpdateReq;
 import com.ycwl.basic.model.pc.scenic.req.ScenicReqQuery;
 import com.ycwl.basic.model.pc.scenic.resp.ScenicRespVO;
 import com.ycwl.basic.service.pc.ScenicService;
+import com.ycwl.basic.service.task.TaskFaceService;
 import com.ycwl.basic.utils.ApiResponse;
 import com.ycwl.basic.utils.SnowFlakeUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -39,6 +40,8 @@ public class ScenicServiceImpl implements ScenicService {
     private ScenicAccountMapper scenicAccountMapper;
     @Autowired
     private FaceDetectConfig faceDetectConfig;
+    @Autowired
+    private TaskFaceService taskFaceService;
 
     @Override
     public ApiResponse<PageInfo<ScenicRespVO>> pageQuery(ScenicReqQuery scenicReqQuery) {
@@ -77,16 +80,10 @@ public class ScenicServiceImpl implements ScenicService {
         account.setIsSuper(1);
         scenicAccountMapper.add(account);
         if (add > 0) {
-            IAcsClient client = getClient();
-            CreateFaceDbRequest request = new CreateFaceDbRequest();
-            request.setName(scenicId.toString());
-            try {
-                client.getAcsResponse(request);
-            } catch (ClientException e) {
-                log.error("阿里云添加人脸数据库失败！", e);
-            }
+            taskFaceService.createFaceDB(scenicId.toString());
+            taskFaceService.assureFaceDB(scenicId.toString());
             return ApiResponse.success(true);
-        }else {
+        } else {
             return ApiResponse.fail("景区添加失败");
         }
     }
@@ -98,6 +95,7 @@ public class ScenicServiceImpl implements ScenicService {
         if (i > 0) {
             scenicMapper.deleteConfigByScenicId(id);
             scenicAccountMapper.deleteByScenicId(id);
+            taskFaceService.deleteFaceDB(id.toString());
             return ApiResponse.success(true);
         }else {
             return ApiResponse.fail("景区删除失败");
@@ -131,16 +129,19 @@ public class ScenicServiceImpl implements ScenicService {
         }
         int i = scenicMapper.update(scenicUpdateReq);
         if (i > 0) {
+            taskFaceService.assureFaceDB(scenicUpdateReq.getId().toString());
             return ApiResponse.success(true);
         }else {
             return ApiResponse.fail("景区修改失败");
         }
+
     }
 
     @Override
     public ApiResponse<Boolean> updateStatus(Long id) {
         int i = scenicMapper.updateStatus(id);
         if (i > 0) {
+            taskFaceService.assureFaceDB(id.toString());
             return ApiResponse.success(true);
         }else {
             return ApiResponse.fail("景区状态修改失败");
@@ -151,6 +152,7 @@ public class ScenicServiceImpl implements ScenicService {
     public ApiResponse<Boolean> addConfig(ScenicConfigEntity scenicConfig) {
         int i = scenicMapper.addConfig(scenicConfig);
         if (i > 0) {
+            taskFaceService.assureFaceDB(scenicConfig.getScenicId().toString());
             return ApiResponse.success(true);
         }else {
             return ApiResponse.fail("景区配置添加失败");
@@ -161,6 +163,7 @@ public class ScenicServiceImpl implements ScenicService {
     public ApiResponse<Boolean> updateConfigById(ScenicConfigEntity scenicConfig) {
         int i = scenicMapper.updateConfigById(scenicConfig);
         if (i > 0) {
+            taskFaceService.assureFaceDB(scenicConfig.getScenicId().toString());
             return ApiResponse.success(true);
         }else {
             return ApiResponse.fail("景区配置修改失败");