cq_anquan
/
safety-eval-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

delete ok

dev-deployment
luotaiqian 2026-06-30 15:00:24 +08:00
parent a8d2486ec1
commit 139c23c640
2 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/adapter/gbs/GbsUserFacadeClient.java
View File

@ -28,13 +28,16 @@ public class GbsUserFacadeClient {
list.add(roleDeptAddCmd); list.add(roleDeptAddCmd);
cmd.setRoleDepts(list); cmd.setRoleDepts(list);
SingleResponse<Long> singleResponse = userFacade.add(cmd); SingleResponse<Long> singleResponse = userFacade.add(cmd);
if (singleResponse.isSuccess()) { if (!singleResponse.isSuccess()) {
throw new BizException(singleResponse.getErrCode(), singleResponse.getErrMessage()); throw new BizException(singleResponse.getErrCode(), singleResponse.getErrMessage());
} }
} }
public void delete(Long userId) { public void delete(Long userId) {
userFacade.delete(userId); Response response = userFacade.delete(userId);
if (!response.isSuccess()) {
throw new BizException(response.getErrCode(), response.getErrMessage());
}
} }
public void updatePassword(UserUpdatePasswordCmd cmd) { public void updatePassword(UserUpdatePasswordCmd cmd) {

18
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java
View File

@ -11,6 +11,8 @@ import com.zcloud.gbscommon.utils.MD5;
import com.zcloud.gbscommon.utils.Sm2Util; import com.zcloud.gbscommon.utils.Sm2Util;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.qinan.safetyeval.domain.entity.OrgInfoEntity; import org.qinan.safetyeval.domain.entity.OrgInfoEntity;
import org.qinan.safetyeval.domain.exception.BizException;
import org.qinan.safetyeval.domain.exception.ErrorCode;
import org.qinan.safetyeval.domain.gateway.OrgInfoGateway; import org.qinan.safetyeval.domain.gateway.OrgInfoGateway;
import org.qinan.safetyeval.domain.query.OrgInfoQuery; import org.qinan.safetyeval.domain.query.OrgInfoQuery;
import org.qinan.safetyeval.domain.query.PageResult; import org.qinan.safetyeval.domain.query.PageResult;
@ -103,17 +105,19 @@ public class OrgInfoGatewayImpl implements OrgInfoGateway {
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void delete(Long id) { public void delete(Long id) {
// 同步删除gbs用户(gbs物理) // 同步删除gbs用户(gbs物理)
List<Long> departUserId = orgInfoMapper.selectList(new LambdaQueryWrapper<OrgInfoDO>()
.select(OrgInfoDO::getCreateId)
.eq(OrgInfoDO::getId, id)).stream()
.map(OrgInfoDO::getCreateId).collect(Collectors.toList());
if(CollectionUtils.isEmpty(departUserId)){
throw new BizException(ErrorCode.ORG_DEPARTMENT_NOT_FOUND);
}
gbsUserFacadeClient.delete(departUserId.get(0));
List<Long> orgPersonnelDOIdS = orgPersonnelMapper.selectList(new LambdaQueryWrapper<OrgPersonnelDO>() List<Long> orgPersonnelDOIdS = orgPersonnelMapper.selectList(new LambdaQueryWrapper<OrgPersonnelDO>()
.eq(OrgPersonnelDO::getOrgId, id)).stream().map(OrgPersonnelDO::getId).collect(Collectors.toList()); .eq(OrgPersonnelDO::getOrgId, id)).stream().map(OrgPersonnelDO::getId).collect(Collectors.toList());
if (!CollectionUtils.isEmpty(orgPersonnelDOIdS)) { if (!CollectionUtils.isEmpty(orgPersonnelDOIdS)) {
for (Long orgPersonnelDOId : orgPersonnelDOIdS) { for (Long orgPersonnelDOId : orgPersonnelDOIdS) {
final Long userId = orgPersonnelDOId; gbsUserFacadeClient.delete(orgPersonnelDOId);
syncGbsUser("delete user", new Runnable() {
@Override
public void run() {
gbsUserFacadeClient.delete(userId);
}
});
} }
} }
orgInfoCascadeDeleter.deleteRelatedData(id); orgInfoCascadeDeleter.deleteRelatedData(id);