添加景区时同步添加人脸数据库、角色封禁逻辑

This commit is contained in:
2024-12-06 09:27:29 +08:00
parent ad20769a31
commit cda0599d58
2 changed files with 26 additions and 1 deletions

View File

@ -110,7 +110,7 @@ public class AdminUserServiceImpl implements AdminUserService {
Object roleObject = redisTemplate.opsForValue().get(ROLE_STATUS + roleId);
if (roleObject != null) {
if (roleObject.toString().equals("1")) {
if (roleObject.toString().equals("0")) {
throw new RoleStatusException("该角色下的账号已被封禁,请联系管理员");
}
}

View File

@ -1,7 +1,13 @@
package com.ycwl.basic.service.impl.pc;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.facebody.model.v20191230.CreateFaceDbRequest;
import com.aliyuncs.profile.DefaultProfile;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ycwl.basic.config.FaceDetectConfig;
import com.ycwl.basic.mapper.pc.ScenicAccountMapper;
import com.ycwl.basic.mapper.pc.ScenicMapper;
import com.ycwl.basic.model.pc.scenic.entity.ScenicAccountEntity;
@ -12,6 +18,7 @@ import com.ycwl.basic.model.pc.scenic.resp.ScenicRespVO;
import com.ycwl.basic.service.pc.ScenicService;
import com.ycwl.basic.utils.ApiResponse;
import com.ycwl.basic.utils.SnowFlakeUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -23,12 +30,15 @@ import java.util.List;
* @Authorlongbinbin
* @Date2024/12/3 15:25
*/
@Slf4j
@Service
public class ScenicServiceImpl implements ScenicService {
@Autowired
private ScenicMapper scenicMapper;
@Autowired
private ScenicAccountMapper scenicAccountMapper;
@Autowired
private FaceDetectConfig faceDetectConfig;
@Override
public ApiResponse<PageInfo<ScenicRespVO>> pageQuery(ScenicReqQuery scenicReqQuery) {
@ -67,6 +77,14 @@ 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);
}
return ApiResponse.success(true);
}else {
return ApiResponse.fail("景区添加失败");
@ -148,4 +166,11 @@ public class ScenicServiceImpl implements ScenicService {
return ApiResponse.fail("景区配置修改失败");
}
}
private IAcsClient getClient() {
DefaultProfile profile = DefaultProfile.getProfile(
faceDetectConfig.getRegion(),faceDetectConfig.getAccessKeyId(), faceDetectConfig.getAccessKeySecret());
IAcsClient client = new DefaultAcsClient(profile);
return client;
}
}