提交 f73d4f0d authored 作者: hzh's avatar hzh

用户信息配置

上级 ee587ac2
...@@ -148,4 +148,10 @@ public interface RemoteUserService { ...@@ -148,4 +148,10 @@ public interface RemoteUserService {
* @return 租户id集合 * @return 租户id集合
*/ */
List<String> selectTenantIdsByPhone(String phone); List<String> selectTenantIdsByPhone(String phone);
/**
* 注册用户到云上服务器
* @return
*/
boolean registerUserToYs();
} }
package org.dromara.job.snailjob;
import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
import com.aizuda.snailjob.client.job.core.dto.JobArgs;
import com.aizuda.snailjob.client.model.ExecuteResult;
import lombok.AllArgsConstructor;
import org.apache.dubbo.config.annotation.DubboReference;
import org.dromara.system.api.RemoteUserService;
import org.springframework.stereotype.Component;
/**
* @author hzh
* @date 2024-11-18
*/
@AllArgsConstructor
@Component
@JobExecutor(name = "userJobExecutor")
public class UserJobExecutor {
@DubboReference
private RemoteUserService remoteUserService;
public ExecuteResult jobExecute(JobArgs jobArgs) {
remoteUserService.registerUserToYs();
return ExecuteResult.success("注册成功");
}
}
...@@ -5,6 +5,8 @@ import cn.hutool.core.lang.Opt; ...@@ -5,6 +5,8 @@ import cn.hutool.core.lang.Opt;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.DubboService; import org.apache.dubbo.config.annotation.DubboService;
import org.dromara.common.core.enums.UserStatus; import org.dromara.common.core.enums.UserStatus;
import org.dromara.common.core.enums.UserType; import org.dromara.common.core.enums.UserType;
...@@ -15,6 +17,8 @@ import org.dromara.common.core.utils.MapstructUtils; ...@@ -15,6 +17,8 @@ import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils; import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.helper.DataPermissionHelper; import org.dromara.common.mybatis.helper.DataPermissionHelper;
import org.dromara.common.tenant.helper.TenantHelper; import org.dromara.common.tenant.helper.TenantHelper;
import org.dromara.server.api.RemoteServerService;
import org.dromara.server.api.domain.RemoteUser;
import org.dromara.system.api.RemoteUserService; import org.dromara.system.api.RemoteUserService;
import org.dromara.system.api.domain.bo.RemoteUserBo; import org.dromara.system.api.domain.bo.RemoteUserBo;
import org.dromara.system.api.domain.bo.RemoteWxUserBo; import org.dromara.system.api.domain.bo.RemoteWxUserBo;
...@@ -44,6 +48,7 @@ import java.util.stream.Collectors; ...@@ -44,6 +48,7 @@ import java.util.stream.Collectors;
@RequiredArgsConstructor @RequiredArgsConstructor
@Service @Service
@DubboService @DubboService
@Slf4j
public class RemoteUserServiceImpl implements RemoteUserService { public class RemoteUserServiceImpl implements RemoteUserService {
private final ISysUserService userService; private final ISysUserService userService;
...@@ -53,6 +58,8 @@ public class RemoteUserServiceImpl implements RemoteUserService { ...@@ -53,6 +58,8 @@ public class RemoteUserServiceImpl implements RemoteUserService {
private final ISysDeptService deptService; private final ISysDeptService deptService;
private final IWxUserService wxUserService; private final IWxUserService wxUserService;
private final SysUserMapper userMapper; private final SysUserMapper userMapper;
@DubboReference
private RemoteServerService remoteServerService;
/** /**
* 通过用户名查询用户信息 * 通过用户名查询用户信息
...@@ -346,4 +353,24 @@ public class RemoteUserServiceImpl implements RemoteUserService { ...@@ -346,4 +353,24 @@ public class RemoteUserServiceImpl implements RemoteUserService {
return userMapper.selectList(new LambdaQueryWrapper<SysUser>().eq(SysUser::getPhonenumber, phone)) return userMapper.selectList(new LambdaQueryWrapper<SysUser>().eq(SysUser::getPhonenumber, phone))
.stream().map(SysUser::getTenantId).collect(Collectors.toList()); .stream().map(SysUser::getTenantId).collect(Collectors.toList());
} }
@Override
public boolean registerUserToYs() {
List<SysUser> userList = userMapper.selectList();
for (SysUser user : userList) {
try {
remoteServerService.saveOrUpdateUser(
new RemoteUser()
.setSystemUserId(user.getUserId())
.setUserName(user.getUserName())
.setPhoneNumber(user.getPhonenumber())
.setIdCard(user.getIdCard())
.setTenantId(user.getTenantId())
);
}catch (Exception e){
log.error("用户注册到云服务失败,用户id:{}",user.getUserId());
}
}
return true;
}
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论