尽可能确保景区人脸数据库存在

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();
+            taskFaceService.createFaceDB(scenicId.toString());
-            CreateFaceDbRequest request = new CreateFaceDbRequest();
+            taskFaceService.assureFaceDB(scenicId.toString());
-            request.setName(scenicId.toString());
-            try {
-                client.getAcsResponse(request);
-            } catch (ClientException e) {
-                log.error("阿里云添加人脸数据库失败！", e);
-            }
             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("景区配置修改失败");