package com.zhitan.singlelogin.service.impl;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.google.common.collect.Lists;
|
import com.zhitan.common.core.domain.entity.SysRole;
|
import com.zhitan.common.core.domain.entity.SysUser;
|
import com.zhitan.common.utils.SecurityUtils;
|
import com.zhitan.singlelogin.service.ISingleLoginService;
|
import com.zhitan.system.domain.SysUserRole;
|
import com.zhitan.system.mapper.SysUserRoleMapper;
|
import com.zhitan.system.service.ISysRoleService;
|
import com.zhitan.system.service.ISysUserService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
|
/**
|
* description todu
|
*
|
* @author hmj
|
* @date 2024-11-15 17:10
|
*/
|
@Component
|
public class SingleLoginServiceImpl implements ISingleLoginService {
|
|
private static final Logger log = LoggerFactory.getLogger(SingleLoginServiceImpl.class);
|
|
@Value("${singleLoginUrl}")
|
private String singleLoginUrl;
|
|
@Resource
|
private ISysUserService userService;
|
|
@Resource
|
private ISysRoleService roleService;
|
|
@Resource
|
private SysUserRoleMapper userRoleMapper;
|
|
@Override
|
public SysUser singleLogin(String token) {
|
JSONObject jsonObject = checkToken(token);
|
log.info("请求综合治理" + jsonObject.toString());
|
if(jsonObject.containsKey("code") && jsonObject.getInt("code") == 200) {
|
|
final SysUser user = JSONUtil.toBean(jsonObject.getJSONObject("user"), SysUser.class);
|
|
user.setSingleUser(String.valueOf(user.getUserId()));
|
user.setUserId(null);
|
//检测一下用户存在不存在
|
Long count = userService.checkThirdUserExist(user);
|
if (count > 0 ) {
|
return user;
|
} else {
|
//用户不存在时，将用户添加到数据库中
|
//密码统一都是hrd123456
|
user.setPassword(SecurityUtils.encryptPassword("hrd123456"));
|
//创建者，标识J平台过来的用户
|
user.setCreateBy("thirdPartGetAuth");
|
//创建日期
|
user.setCreateTime(new Date());
|
|
int rows = userService.insertUser(user);
|
if (rows > 0) {
|
SysRole queryRole = new SysRole();
|
queryRole.setRoleKey("zonghezhili");
|
SysRole sysRoles = roleService.getRoleByKey(queryRole);
|
if(null != sysRoles){
|
SysUserRole sysUserRole = new SysUserRole();
|
sysUserRole.setUserId(user.getUserId());
|
sysUserRole.setRoleId(sysRoles.getRoleId());
|
userRoleMapper.batchUserRole(Lists.newArrayList(sysUserRole));
|
}
|
}
|
return user;
|
}
|
}else {
|
return null;
|
}
|
}
|
|
/**
|
* 通过第三方平台接口，鉴定token合法性，并返回userName等登录信息
|
* 这个方法需要根据实际需要进行修改
|
* @param token
|
* @return
|
*/
|
public JSONObject checkToken(String token) {
|
|
String result = HttpRequest.get(singleLoginUrl)
|
.header("Authorization","Bearer " + token)
|
.execute()
|
.body();
|
JSONObject parseObj = JSONUtil.parseObj(result);
|
return parseObj;
|
}
|
}
|
