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

import

dev
luotaiqian 2026-08-03 16:52:17 +08:00
parent 473d237735
commit 8fe973c736
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/remote/SystemRemote.java
View File

@ -1,9 +1,11 @@
package org.qinan.safetyeval.infrastructure.remote; package org.qinan.safetyeval.infrastructure.remote;
import com.alibaba.cola.dto.PageResponse;
import com.alibaba.cola.dto.Response; import com.alibaba.cola.dto.Response;
import com.alibaba.cola.dto.SingleResponse; import com.alibaba.cola.dto.SingleResponse;
import com.jjb.saas.system.client.user.facade.UserFacade; import com.jjb.saas.system.client.user.facade.UserFacade;
import com.jjb.saas.system.client.user.request.UserAddCmd; import com.jjb.saas.system.client.user.request.UserAddCmd;
import com.jjb.saas.system.client.user.request.UserPageQry;
import com.jjb.saas.system.client.user.request.UserRoleUpdateCmd; import com.jjb.saas.system.client.user.request.UserRoleUpdateCmd;
import com.jjb.saas.system.client.user.response.UserCO; import com.jjb.saas.system.client.user.response.UserCO;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@ -44,14 +46,20 @@ public class SystemRemote {
* @return userId * @return userId
*/ */
public Long addUserIfAbsent(UserAddCmd userAddCmd) { public Long addUserIfAbsent(UserAddCmd userAddCmd) {
SingleResponse<UserCO> userResponse = userFacade UserPageQry qry = new UserPageQry();
.getUserSignUrlByMobileAndTenantId(userAddCmd.getMobile(), userAddCmd.getTenantId()); qry.setAccount(userAddCmd.getAccount());
qry.setTenantId(userAddCmd.getTenantId());
PageResponse<UserCO> userResponse = userFacade.pageUser(qry);
if (!userResponse.isSuccess()) { if (!userResponse.isSuccess()) {
log.error("addUserIfAbsent find fail:{}", userResponse.getErrMessage()); log.error("addUserIfAbsent find fail:{}", userResponse.getErrMessage());
throw new com.alibaba.cola.exception.BizException(userResponse.getErrMessage()); throw new BizException(userResponse.getErrCode(), userResponse.getErrMessage());
} }
if (userResponse.getData() != null && userResponse.getData().getId() != null) { if (userResponse.getTotalCount() >= 1) {
return userResponse.getData().getId(); if (userResponse.getTotalCount() == 1) {
return userResponse.getData().get(0).getId();
}
log.error("addUserIfAbsent find fail count:{}", userResponse.getErrMessage());
throw new com.alibaba.cola.exception.BizException("账号查询到多条记录");
} }
// 新增用户 // 新增用户