huxin
/
dakeliu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: huxin:6a7b2e5be037e410c2549fc488077a3b69039123
Branches Tags
huxin:main
huxin:origin/main
..
compare: huxin:1ce183b8b050487a93cadb1d2a010514283d1df7
Branches Tags
huxin:main
huxin:origin/main

No commits in common. "6a7b2e5be037e410c2549fc488077a3b69039123" and "1ce183b8b050487a93cadb1d2a010514283d1df7" have entirely different histories.
6a7b2e5be0 ... 1ce183b8b0

2 changed files with 0 additions and 316 deletions
Show Stats Expand all files Collapse all files

130
Dkl-Vue-master/dkl-admin/src/main/java/com/dkl/web/controller/system/LoginSsoController.java
View File

@ -1,130 +0,0 @@
package com.dkl.web.controller.system;
import com.alibaba.fastjson2.JSON;
import com.dkl.common.constant.Constants;
import com.dkl.common.core.domain.AjaxResult;
import com.dkl.common.core.domain.entity.SysDept;
import com.dkl.common.core.domain.entity.SysUser;
import com.dkl.common.core.domain.model.LoginUser;
import com.dkl.common.core.redis.RedisCache;
import com.dkl.common.utils.SecurityUtils;
import com.dkl.common.utils.StringUtils;
import com.dkl.framework.web.service.SysLoginService;
import com.dkl.framework.web.service.SysPermissionService;
import com.dkl.system.service.ISysDeptService;
import com.dkl.system.service.ISysRoleService;
import com.dkl.system.service.ISysUserService;
import com.smartlx.sso.client.model.AccessToken;
import com.smartlx.sso.client.model.RemoteUserInfo;
import com.smartlx.sso.client.result.Result;
import com.smartlx.sso.client.service.SsoClientService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Date;
import static com.dkl.common.core.domain.AjaxResult.error;
import static net.sf.jsqlparser.util.validation.metadata.NamedObject.user;
/**
* 单点登录Controller
* @author sgc
*/
@Slf4j
@RestController
public class LoginSsoController {
@Value("${outData.clientId}")
String clientIds;
@Value("${outData.clientSecret}")
String clientSecret;
@Value("${outData.url}")
String outUrl;
@Autowired
private ISysRoleService roleService;
@Autowired
private ISysDeptService deptService;
@Autowired
private ISysUserService userService;
@Autowired
private SysPermissionService permissionService;
@Autowired
private SsoClientService ssoClientService;
@Autowired
private SysLoginService loginService;
@Autowired
private RedisCache redisCache;
@PostMapping("/loginSso")
public AjaxResult loginSso(String code) {
AjaxResult ajax = AjaxResult.success();
RemoteUserInfo remoteUserInfo = null;
try{
Result result =ssoClientService.getAccessToken(code);
if (result.isSuccess()) {
AccessToken accessToken = (AccessToken) result.getData();
remoteUserInfo =ssoClientService.getRemoteUserInfo(accessToken);
//获取手机号
String phone = remoteUserInfo.getYddh();
//通过手机号查询用户
SysUser sysUser = userService.selectUserByphone(phone);
if(sysUser!=null){
sysUser.setUserName(remoteUserInfo.getXm());
sysUser.setNickName(remoteUserInfo.getYhm());
SysUser user = new SysUser();
user.setUserId(sysUser.getUserId());
user.setUserName(remoteUserInfo.getXm());
user.setNickName(remoteUserInfo.getYhm());
userService.updateUserProfile(user);
redisCache.deleteObject(sysUser.getPhonenumber());
redisCache.setCacheObject(sysUser.getPhonenumber(), accessToken.getAccess_token());
System.out.println(remoteUserInfo.getYddh());
String token = loginService.logingcy(sysUser); // 调用服务层生成Token
return AjaxResult.success().put(Constants.TOKEN, token);
}else{
log.info("进入没查询到用户");
SysUser user = new SysUser();
log.info(remoteUserInfo.getYhm());
user.setUserName(remoteUserInfo.getXm());
user.setNickName(remoteUserInfo.getYhm());
log.info(remoteUserInfo.getYddh());
user.setPhonenumber(remoteUserInfo.getYddh());
user.setStatus("0");
SysDept sysDept = deptService.selectDeptBysjgajgjgdm(remoteUserInfo.getGajgjgdm());
// if (sysDept!=null){
// user.setDeptId(sysDept.getDeptId());
// }else {
// user.setDeptId(10106L);
// }
user.setDeptId(10106L);
user.setRoleIds(new Long[]{2L});
user.setCreateBy("三方");
user.setCreateTime(new Date());
user.setPassword(SecurityUtils.encryptPassword("Syj!123456"));
log.info(user.toString());
userService.insertUser(user);
redisCache.deleteObject(sysUser.getPhonenumber());
redisCache.setCacheObject(user.getPhonenumber(), accessToken.getAccess_token());
System.out.println(remoteUserInfo.getYddh());
String token = loginService.logingcy(user); // 调用服务层生成Token
return AjaxResult.success().put(Constants.TOKEN, token);
}
}
} catch (Exception e) {
return error();
}
return ajax;
}
}

186
Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/utli/zzjgxxUtil.java
View File

@ -1,186 +0,0 @@
package com.dkl.large.utli;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.dkl.common.core.domain.entity.SysDept;
import com.dkl.common.utils.StringUtils;
import com.dkl.system.service.ISysDeptService;
import okhttp3.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.Date;
@Component("zzjgxxUtil")
public class zzjgxxUtil {
@Autowired
private ISysDeptService deptService;
public void getDeptAll() throws IOException {
OkHttpClient client = new OkHttpClient();
// 构建请求体
MediaType mediaType = MediaType.parse("application/json");
RequestBody body = RequestBody.create(mediaType, "{\n" +
" \"jsonObject\": {\n" +
" \"key\": \"value\"\n" +
" },\n" +
" \"method\": \"GET\",\n" +
" \"pageNum\": 1,\n" +
" \"pageSize\": 1000000,\n" +
" \"path\": \"/edataservice/api/zzjgxx\",\n" +
" \"secret\": \"7231958b69385ff66a1900584a72c0b85dbc0b602d54ec7a23f9ccdeeb17018c\",\n" +
" \"sortParam\": \"zzjgdm\",\n" +
" \"sortType\": \"ASC\"\n" +
"}");
// 构建请求
Request request = new Request.Builder()
.url("http://10.22.245.216:29999/jeecg-data-service/edataservice/api/")
.post(body)
.addHeader("Content-Type", "application/json")
.build();
// 执行请求并处理响应
try (Response response = client.newCall(request).execute()) {
// System.out.println("Response Code: " + response.code());
// System.out.println("Response Body: " + response.body().string());
String jsonString = response.body().string();
// 创建ObjectMapper实例
ObjectMapper objectMapper = new ObjectMapper();
try {
// 解析JSON字符串为JsonNode对象
JsonNode rootNode = objectMapper.readTree(jsonString);
// 获取code字段的值
String code = rootNode.get("code").asText();
System.out.println("Code: " + code);
// 获取success字段的值
boolean success = rootNode.get("success").asBoolean();
System.out.println("Success: " + success);
// 获取data字段的值（是一个数组）
JsonNode dataNode = rootNode.get("result");
JsonNode dataList= dataNode.get("records");
// 遍历data数组中的每个元素
for (JsonNode deptNode : dataList) {
//获取所有部门
SysDept sysDept =new SysDept();
//如果组织机构机构代码不为空
if(StringUtils.isNotEmpty( deptNode.get("zzjgdm").asText())){
SysDept gainfo = deptService.selectDeptBygajgjgdm(deptNode.get("zzjgdm").asText());
//部门是空
if (gainfo == null) {
//创建
//上级组织机构不能不空
if(StringUtils.isNotEmpty( deptNode.get("sjzzjg").asText())){
SysDept info = deptService.selectDeptBysjgajgjgdm(deptNode.get("sjzzjg").asText());
//如果上级机构存在
if (info != null) {
//部门名称 = 对接组织机构名称 zzjgmc
if(StringUtils.isNotEmpty( deptNode.get("zzjgmc").asText())){
sysDept.setDeptName(deptNode.get("zzjgmc").asText());
}
sysDept.setParentId(info.getDeptId());
//显示顺序 = 对接显示顺序 xssx
if(StringUtils.isNotEmpty( deptNode.get("xssx").asText())){
sysDept.setOrderNum(Integer.valueOf(deptNode.get("xssx").asText()));
}
//单位类别
if(StringUtils.isNotEmpty( deptNode.get("dwlb").asText())){
sysDept.setDwlb(deptNode.get("dwlb").asText());
}
//组织机构单位性质类别 zzjgdwxzlbdm
if(StringUtils.isNotEmpty( deptNode.get("zzjgdwxzlbdm").asText())){
sysDept.setGajgbmlbdm(deptNode.get("zzjgdwxzlbdm").asText());
}
//单位级别
if(StringUtils.isNotEmpty( deptNode.get("dwjb").asText())){
sysDept.setGajgbmlbdm(deptNode.get("dwjb").asText());
}
//组织机构代码
if(StringUtils.isNotEmpty( deptNode.get("zzjgdm").asText())){
sysDept.setGajgjgdm(deptNode.get("zzjgdm").asText());
}
//上级组织机构不能不空
if(StringUtils.isNotEmpty( deptNode.get("sjzzjg").asText())){
sysDept.setSjgajgjgdm(deptNode.get("sjzzjg").asText());
}
//组织机构简称不能不空
if(StringUtils.isNotEmpty( deptNode.get("zzjgjc").asText())){
sysDept.setZzjgjc(deptNode.get("zzjgjc").asText());
}
//行政区划代码不能不空
if(StringUtils.isNotEmpty( deptNode.get("xzqhdm").asText())){
sysDept.setXzqhdm(deptNode.get("xzqhdm").asText());
}
//单位类型不能不空
if(StringUtils.isNotEmpty( deptNode.get("dwlx").asText())){
sysDept.setDwlx(deptNode.get("dwlx").asText());
}
//派出所类型代码不能不空
if(StringUtils.isNotEmpty( deptNode.get("pcslxdm").asText())){
sysDept.setDwlb(deptNode.get("pcslxdm").asText());
}
//联系人不能不空
if(StringUtils.isNotEmpty( deptNode.get("lxr").asText())){
sysDept.setLeader(deptNode.get("lxr").asText());
}
//联系电话不能不空
if(StringUtils.isNotEmpty( deptNode.get("lxdh").asText())){
sysDept.setPhone(deptNode.get("lxdh").asText());
}
//值班电话不能不空
if(StringUtils.isNotEmpty( deptNode.get("zbdh").asText())){
sysDept.setZbdh(deptNode.get("zbdh").asText());
}
//帐号状态（0正常 1停用）
sysDept.setStatus("0");
//删除状态
sysDept.setDelFlag("0");
//创建时间
sysDept.setCreateTime(new Date());
//创建人
sysDept.setCreateBy("admin");
//修改时间
sysDept.setUpdateTime(new Date());
//修改人
sysDept.setUpdateBy("admin");
deptService.insertDept(sysDept);
}
}
}
}
}
System.out.println(dataList);
} catch (IOException e) {
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}