| | |
| | | * @param uuid 唯一标识 |
| | | * @return 结果 |
| | | */ |
| | | public String login(String username, String password, String code, String uuid, String orgid, String campusid) { |
| | | public String login(String username, String password, String code, String uuid, String orgid, String campusid, String userType) { |
| | | boolean captchaEnabled = configService.selectCaptchaEnabled(); |
| | | // 验证码开关 |
| | | if (captchaEnabled) { |
| | |
| | | Authentication authentication = null; |
| | | try { |
| | | if (StringUtils.isEmpty(campusid)) campusid = "1"; |
| | | UsernamePasswordAuthenticationToken authenticationToken = new UsernamePasswordAuthenticationToken(username + "&" + orgid + "&" + campusid, password); |
| | | UsernamePasswordAuthenticationToken authenticationToken = new UsernamePasswordAuthenticationToken(username + "&" + orgid + "&" + campusid + "&" + userType, password); |
| | | AuthenticationContextHolder.setContext(authenticationToken); |
| | | // 该方法会去调用UserDetailsServiceImpl.loadUserByUsername |
| | | authentication = authenticationManager.authenticate(authenticationToken); |
| | |
| | | return tokenService.createToken(loginUser); |
| | | } |
| | | |
| | | public String getTokenWN(String userName) { |
| | | SysUser sysUser = userService.selectUserByUserName(userName); |
| | | System.out.println("sysUser的结果为:" + sysUser); |
| | | |
| | | LoginUser loginUser = new LoginUser(); |
| | | loginUser.setUserId(sysUser.getUserId()); |
| | | loginUser.setDeptId(sysUser.getDeptId()); |
| | | loginUser.setUser(sysUser); |
| | | return tokenService.createToken(loginUser); |
| | | } |
| | | |
| | | /** |
| | | * SSO 单点登录业务处理 |
| | |
| | | */ |
| | | public String ssoLogin(String userName, String orgid, String deptId, String campusid, String token) { |
| | | // sltd 环境:通过 SSO token 获取员工账号 |
| | | if ("sltd".equals(active)) { |
| | | if ("sltd".equals(active) || "nhfy".equals(active)) { |
| | | userName = resolveUserNameBySltdToken(token); |
| | | if (userName == null) { |
| | | return null; |
| | |
| | | headers.put("app-key", APP_KEY); |
| | | Map<String, String> requestParams = new HashMap<>(); |
| | | requestParams.put("token", token); |
| | | String reqData = HttpUtil.postFormRequest(sltdPubPath + "/checkSsoTokenId", requestParams, headers, null); |
| | | String url = active != null && active.contains("nhfy") |
| | | ? sltdPubPath + "/hbos-thirdparty-integration/standard/ih/getHisLoginUserInfo" |
| | | : sltdPubPath + "/checkSsoTokenId"; |
| | | log.info("【SLTD token 验证】请求地址:{},token长度:{},token结尾:{}", url, token.length(), |
| | | token.length() > 4 ? token.substring(token.length() - 4) : token); |
| | | String reqData = HttpUtil.postFormRequest(url, requestParams, headers, null); |
| | | log.info("【SLTD token 验证】响应结果:{}", reqData); |
| | | |
| | | if (StringUtils.isEmpty(reqData)) { |
| | |
| | | } |
| | | |
| | | Map<String, Object> map = JSONObject.parseObject(reqData, Map.class); |
| | | if (ObjectUtils.isEmpty(map) || (Integer) map.get("code") != 200) { |
| | | log.error("【SLTD token 验证】响应码异常,验证失败"); |
| | | if (ObjectUtils.isEmpty(map)) { |
| | | log.error("【SLTD token 验证】响应解析为空,验证失败,响应内容:{}", reqData); |
| | | return null; |
| | | } |
| | | |
| | | Map<String, Object> data = (Map<String, Object>) map.get("data"); |
| | | return (String) data.get("accountNo"); |
| | | Object codeObj = map.get("code"); |
| | | int code = codeObj instanceof Number ? ((Number) codeObj).intValue() : -1; |
| | | if (code != 200) { |
| | | log.error("【SLTD token 验证】响应码异常,验证失败,code={}, message={}, 响应内容:{}", |
| | | code, map.get("message"), reqData); |
| | | return null; |
| | | } |
| | | |
| | | Object dataObj = map.get("data"); |
| | | if (!(dataObj instanceof Map)) { |
| | | log.error("【SLTD token 验证】响应缺少data节点,验证失败,data={}", dataObj); |
| | | return null; |
| | | } |
| | | |
| | | Object accountNo = ((Map<?, ?>) dataObj).get("accountNo"); |
| | | if (accountNo == null || StringUtils.isEmpty(String.valueOf(accountNo))) { |
| | | log.error("【SLTD token 验证】响应data中没有accountNo,验证失败,data={}", dataObj); |
| | | return null; |
| | | } |
| | | return String.valueOf(accountNo); |
| | | } |
| | | |
| | | public String loginByUserName(String userName) { |
| | |
| | | } |
| | | |
| | | /** |
| | | * 记录登录信息 |
| | | * 记录登录信息(异步执行,不阻塞登录主流程) |
| | | * |
| | | * @param userId 用户ID |
| | | */ |
| | | public void recordLoginInfo(Long userId) { |
| | | SysUser sysUser = new SysUser(); |
| | | sysUser.setUserId(userId); |
| | | sysUser.setLoginIp(IpUtils.getIpAddr(ServletUtils.getRequest())); |
| | | sysUser.setLoginDate(DateUtils.getNowDate()); |
| | | userService.updateUserProfile(sysUser); |
| | | // 在异步前捕获IP,避免异步线程中Request上下文失效 |
| | | String loginIp = IpUtils.getIpAddr(ServletUtils.getRequest()); |
| | | AsyncManager.me().execute(new java.util.TimerTask() { |
| | | @Override |
| | | public void run() { |
| | | SysUser sysUser = new SysUser(); |
| | | sysUser.setUserId(userId); |
| | | sysUser.setLoginIp(loginIp); |
| | | sysUser.setLoginDate(DateUtils.getNowDate()); |
| | | userService.updateUserProfile(sysUser); |
| | | } |
| | | }); |
| | | } |
| | | } |