提交 651e5b5a 编写于 作者: sq3536's avatar sq3536

login

上级 1fe53228
...@@ -109,6 +109,8 @@ public class UserDingtalkRegisterService { ...@@ -109,6 +109,8 @@ public class UserDingtalkRegisterService {
if((sysOpenAccess==null|| (sysOpenAccess.getDisabled()!=null && sysOpenAccess.getDisabled()==1))&&throwEx) if((sysOpenAccess==null|| (sysOpenAccess.getDisabled()!=null && sysOpenAccess.getDisabled()==1))&&throwEx)
throw new BadRequestAlertException("获取接入配置失败","UserDingtalkRegisterService",""); throw new BadRequestAlertException("获取接入配置失败","UserDingtalkRegisterService","");
try {
// 可能抛出异常,但暂时不进行处理
String accessToken = getAccessToken(sysOpenAccess.getAccessKey(),sysOpenAccess.getSecretKey()); String accessToken = getAccessToken(sysOpenAccess.getAccessKey(),sysOpenAccess.getSecretKey());
if(!accessToken.equals(sysOpenAccess.getAccessToken())) if(!accessToken.equals(sysOpenAccess.getAccessToken()))
{ {
...@@ -116,6 +118,9 @@ public class UserDingtalkRegisterService { ...@@ -116,6 +118,9 @@ public class UserDingtalkRegisterService {
sysOpenAccess.setExpiresTime(new Timestamp(lastRefreshTime)); sysOpenAccess.setExpiresTime(new Timestamp(lastRefreshTime));
sysOpenAccessService.update(sysOpenAccess); sysOpenAccessService.update(sysOpenAccess);
} }
}catch (Exception e) {
}
return sysOpenAccess; return sysOpenAccess;
} }
...@@ -171,7 +176,7 @@ public class UserDingtalkRegisterService { ...@@ -171,7 +176,7 @@ public class UserDingtalkRegisterService {
* @return * @return
*/ */
public JSONObject getUserBySnsToken(String id,String requestAuthCode) { public JSONObject getUserBySnsToken(String id,String requestAuthCode) {
JSONObject returnObj = null; JSONObject returnObj = new JSONObject();
SysOpenAccess openAccess = getOpenAccess(id); SysOpenAccess openAccess = getOpenAccess(id);
if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1)) if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1))
......
...@@ -59,7 +59,7 @@ public class UserQQRegisterService { ...@@ -59,7 +59,7 @@ public class UserQQRegisterService {
* @return * @return
*/ */
public JSONObject getUserBySnsToken(String id,String requestAuthCode) { public JSONObject getUserBySnsToken(String id,String requestAuthCode) {
JSONObject returnObj = null; JSONObject returnObj = new JSONObject();
SysOpenAccess openAccess = getOpenAccess(id); SysOpenAccess openAccess = getOpenAccess(id);
if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1)) if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1))
......
...@@ -86,7 +86,7 @@ public class UserWechatRegisterService { ...@@ -86,7 +86,7 @@ public class UserWechatRegisterService {
String unionid = returnObj.getString("unionid"); String unionid = returnObj.getString("unionid");
SysUserAuth userAuth = sysUserAuthService.getOne(Wrappers.<SysUserAuth>lambdaQuery().eq(SysUserAuth::getIdentityType,"webchat") SysUserAuth userAuth = sysUserAuthService.getOne(Wrappers.<SysUserAuth>lambdaQuery().eq(SysUserAuth::getIdentityType,"wechat")
.and(wrapper -> wrapper.eq(SysUserAuth::getIdentifier, openid).or().eq(SysUserAuth::getIdentifier, unionid) .and(wrapper -> wrapper.eq(SysUserAuth::getIdentifier, openid).or().eq(SysUserAuth::getIdentifier, unionid)
),false); ),false);
......
...@@ -44,8 +44,11 @@ public class UserDingtalkRegisterResource { ...@@ -44,8 +44,11 @@ public class UserDingtalkRegisterResource {
@Autowired @Autowired
private ISysOpenAccessService openAccessService; private ISysOpenAccessService openAccessService;
/** /**
* 获取钉钉开放平台创建的网站应用appid * 获取钉钉开放平台创建的网站应用appid
* @param id
* @return
*/ */
@GetMapping(value = {"/uaa/getDingtalkAppId","/uaa/open/dingtalk/access_token","/uaa/open/dingtalk/appid"}) @GetMapping(value = {"/uaa/getDingtalkAppId","/uaa/open/dingtalk/access_token","/uaa/open/dingtalk/appid"})
public ResponseEntity<JSONObject> getDingtalkAppId(@RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getDingtalkAppId(@RequestParam(value = "id",required = false) String id) {
...@@ -64,26 +67,14 @@ public class UserDingtalkRegisterResource { ...@@ -64,26 +67,14 @@ public class UserDingtalkRegisterResource {
return ResponseEntity.ok(obj); return ResponseEntity.ok(obj);
} }
/** /**
* 根据code查钉钉用户 * 扫码后查询钉钉用户
* * 已注册:返回注册用户并登录
* @param param * 未注册:进行注册
* @param code
* @param id
* @return * @return
*/ */
@PostMapping(value = "/uaa/queryDingtalkUserByCode")
public ResponseEntity<JSONObject> queryDingtalkUserByCode(@RequestParam(value = "id",required = false) String id,@RequestParam(value = "code",required = false) String tmpcode,@RequestBody JSONObject param) {
// 空校验
String code = param.getString("code");
if (StringUtils.isEmpty(code))
code = tmpcode;
if (StringUtils.isEmpty(code))
throw new BadRequestAlertException("code为空", "UserDingtalkRegisterResource", "");
return ResponseEntity.ok().body(getUserBySnsCode(id,code));
}
@GetMapping(value = "/uaa/open/dingtalk/sns/{code}") @GetMapping(value = "/uaa/open/dingtalk/sns/{code}")
public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) {
if (StringUtils.isEmpty(code)) if (StringUtils.isEmpty(code))
...@@ -114,13 +105,11 @@ public class UserDingtalkRegisterResource { ...@@ -114,13 +105,11 @@ public class UserDingtalkRegisterResource {
/** /**
* 绑定钉钉并注册 * 绑定钉钉并注册
*
* @param param * @param param
* @return * @return
*/ */
@PostMapping(value = {"/uaa/bindDingtalkToRegister","/uaa/open/dingtalk/bind"}) @PostMapping(value = {"/uaa/bindDingtalkToRegister","/uaa/open/dingtalk/bind"})
public ResponseEntity<AuthenticationInfo> bindDingtalkToRegister(@RequestBody JSONObject param) { public ResponseEntity<AuthenticationInfo> bindDingtalkToRegister(@RequestBody JSONObject param) {
// 空校验 // 空校验
String loginname = param.getString("loginname"); String loginname = param.getString("loginname");
String password = param.getString("password"); String password = param.getString("password");
...@@ -136,8 +125,6 @@ public class UserDingtalkRegisterResource { ...@@ -136,8 +125,6 @@ public class UserDingtalkRegisterResource {
throw new BadRequestAlertException("密码为空", "UserDingtalkRegisterResource", ""); throw new BadRequestAlertException("密码为空", "UserDingtalkRegisterResource", "");
if (StringUtils.isEmpty(openid)) if (StringUtils.isEmpty(openid))
throw new BadRequestAlertException("钉钉信息openid为空", "UserDingtalkRegisterResource", ""); throw new BadRequestAlertException("钉钉信息openid为空", "UserDingtalkRegisterResource", "");
if (StringUtils.isEmpty(nickname))
throw new BadRequestAlertException("钉钉信息nickname为空", "UserDingtalkRegisterResource", "");
// 钉钉用户注册 // 钉钉用户注册
IBZUSER ibzuser = new IBZUSER(); IBZUSER ibzuser = new IBZUSER();
...@@ -155,8 +142,6 @@ public class UserDingtalkRegisterResource { ...@@ -155,8 +142,6 @@ public class UserDingtalkRegisterResource {
userRegisterService.toRegister(ibzuser,userAuth); userRegisterService.toRegister(ibzuser,userAuth);
// 生成登录token信息 // 生成登录token信息
userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
......
...@@ -18,6 +18,7 @@ import com.alibaba.fastjson.JSONObject; ...@@ -18,6 +18,7 @@ import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Primary;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -34,10 +35,6 @@ public class UserQQRegisterResource { ...@@ -34,10 +35,6 @@ public class UserQQRegisterResource {
@Autowired @Autowired
private UserRegisterService userRegisterService; private UserRegisterService userRegisterService;
@Autowired @Autowired
private IBZUSERService ibzuserService;
@Autowired
private ISysUserAuthService sysUserAuthService;
@Autowired
private AuthTokenUtil jwtTokenUtil; private AuthTokenUtil jwtTokenUtil;
@Autowired @Autowired
@Qualifier("UAAUserService") @Qualifier("UAAUserService")
...@@ -45,8 +42,11 @@ public class UserQQRegisterResource { ...@@ -45,8 +42,11 @@ public class UserQQRegisterResource {
@Autowired @Autowired
private ISysOpenAccessService openAccessService; private ISysOpenAccessService openAccessService;
/** /**
* 获取QQ互联平台创建的网站应用appid * 获取qq互联平台创建的网站应用appid
* @param id
* @return
*/ */
@GetMapping(value = {"/uaa/getQQAppId","/uaa/open/qq/access_token","/uaa/open/qq/appid"}) @GetMapping(value = {"/uaa/getQQAppId","/uaa/open/qq/access_token","/uaa/open/qq/appid"})
public ResponseEntity<JSONObject> getQQAppId(@RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getQQAppId(@RequestParam(value = "id",required = false) String id) {
...@@ -67,24 +67,13 @@ public class UserQQRegisterResource { ...@@ -67,24 +67,13 @@ public class UserQQRegisterResource {
/** /**
* 根据code查qq用户 * 扫码后查询qq用户
* * 已注册:返回注册用户并登录
* @param param * 未注册:进行注册
* @param code
* @param id
* @return * @return
*/ */
@PostMapping(value = "/uaa/queryQQUserByCode")
public ResponseEntity<JSONObject> queryQQUserByCode(@RequestParam(value = "id",required = false) String id,@RequestParam(value = "code",required = false) String tmpcode,@RequestBody JSONObject param) {
// 空校验
String code = param.getString("code");
if (StringUtils.isEmpty(code))
code = tmpcode;
if (StringUtils.isEmpty(code))
throw new BadRequestAlertException("code为空", "UserQQRegisterResource", "");
return ResponseEntity.ok().body(getUserBySnsCode(id,code));
}
@GetMapping(value = "/uaa/open/qq/sns/{code}") @GetMapping(value = "/uaa/open/qq/sns/{code}")
public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) {
if (StringUtils.isEmpty(code)) if (StringUtils.isEmpty(code))
...@@ -114,14 +103,12 @@ public class UserQQRegisterResource { ...@@ -114,14 +103,12 @@ public class UserQQRegisterResource {
/** /**
* 绑定QQ并注册 * 绑定qq并注册
*
* @param param * @param param
* @return * @return
*/ */
@PostMapping(value = {"/uaa/bindQQtoRegister","/uaa/open/qq/bind"}) @PostMapping(value = {"/uaa/bindQQtoRegister","/uaa/open/qq/bind"})
public ResponseEntity<AuthenticationInfo> bindQQToRegister(@RequestBody JSONObject param) { public ResponseEntity<AuthenticationInfo> bindQQToRegister(@RequestBody JSONObject param) {
// 空校验 // 空校验
String loginname = param.getString("loginname"); String loginname = param.getString("loginname");
String password = param.getString("password"); String password = param.getString("password");
...@@ -138,8 +125,7 @@ public class UserQQRegisterResource { ...@@ -138,8 +125,7 @@ public class UserQQRegisterResource {
if (StringUtils.isEmpty(openid)) if (StringUtils.isEmpty(openid))
throw new BadRequestAlertException("QQ信息openid为空", "UserQQRegisterResource", ""); throw new BadRequestAlertException("QQ信息openid为空", "UserQQRegisterResource", "");
// qq用户注册
// 微信用户注册
IBZUSER ibzuser = new IBZUSER(); IBZUSER ibzuser = new IBZUSER();
ibzuser.setPassword(password); ibzuser.setPassword(password);
ibzuser.setLoginname(loginname); ibzuser.setLoginname(loginname);
...@@ -155,8 +141,6 @@ public class UserQQRegisterResource { ...@@ -155,8 +141,6 @@ public class UserQQRegisterResource {
userRegisterService.toRegister(ibzuser,userAuth); userRegisterService.toRegister(ibzuser,userAuth);
// 生成登录token信息 // 生成登录token信息
userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
......
...@@ -45,8 +45,11 @@ public class UserWechatRegisterResource { ...@@ -45,8 +45,11 @@ public class UserWechatRegisterResource {
@Autowired @Autowired
private ISysOpenAccessService openAccessService; private ISysOpenAccessService openAccessService;
/** /**
* 获取微信开放平台创建的网站应用appid * 获取微信开放平台创建的网站应用appid
* @param id
* @return
*/ */
@GetMapping(value = {"/uaa/getWechatAppId","/uaa/open/wechat/access_token","/uaa/open/wechat/appid"}) @GetMapping(value = {"/uaa/getWechatAppId","/uaa/open/wechat/access_token","/uaa/open/wechat/appid"})
public ResponseEntity<JSONObject> getWechatAppId(@RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getWechatAppId(@RequestParam(value = "id",required = false) String id) {
...@@ -54,7 +57,7 @@ public class UserWechatRegisterResource { ...@@ -54,7 +57,7 @@ public class UserWechatRegisterResource {
SysOpenAccess openAccess = userWechatRegisterService.getOpenAccess(id,false); SysOpenAccess openAccess = userWechatRegisterService.getOpenAccess(id,false);
if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1)) if (openAccess==null || (openAccess.getDisabled()!=null && openAccess.getDisabled()==1))
return ResponseEntity.ok(obj); return ResponseEntity.ok(obj);
String appId = openAccess.getAccessKey();// qq互联appid String appId = openAccess.getAccessKey();// 微信开放平台appid
if (!StringUtils.isEmpty(appId)) { if (!StringUtils.isEmpty(appId)) {
obj.put("appid", appId); obj.put("appid", appId);
obj.put("corp_id",openAccess.getRegionId()); obj.put("corp_id",openAccess.getRegionId());
...@@ -65,27 +68,14 @@ public class UserWechatRegisterResource { ...@@ -65,27 +68,14 @@ public class UserWechatRegisterResource {
} }
/** /**
* 根据code查微信用户 * 扫码后查询微信用户
* * 已注册:返回注册用户并登录
* @param param * 未注册:进行注册
* @param code
* @param id
* @return * @return
*/ */
@PostMapping(value = "/uaa/queryWechatUserByCode")
public ResponseEntity<JSONObject> queryWechatUserByCode(@RequestParam(value = "id",required = false) String id,@RequestParam(value = "code",required = false) String tmpcode,@RequestBody JSONObject param) {
// 空校验
String code = param.getString("code");
if (StringUtils.isEmpty(code))
code = tmpcode;
if (StringUtils.isEmpty(code))
throw new BadRequestAlertException("code为空", "UserWechatRegisterResource", "");
return ResponseEntity.ok().body(getUserBySnsCode(id,code));
}
@GetMapping(value = "/uaa/open/wechat/sns/{code}") @GetMapping(value = "/uaa/open/wechat/sns/{code}")
public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) { public ResponseEntity<JSONObject> getUserBySnsToken(@PathVariable(value = "code") String code, @RequestParam(value = "id",required = false) String id) {
if (StringUtils.isEmpty(code)) if (StringUtils.isEmpty(code))
...@@ -116,13 +106,11 @@ public class UserWechatRegisterResource { ...@@ -116,13 +106,11 @@ public class UserWechatRegisterResource {
/** /**
* 绑定微信并注册 * 绑定微信并注册
*
* @param param * @param param
* @return * @return
*/ */
@PostMapping(value = {"/uaa/bindWechatToRegister","/uaa/open/wechat/bind"}) @PostMapping(value = {"/uaa/bindWechatToRegister","/uaa/open/wechat/bind"})
public ResponseEntity<AuthenticationInfo> bindWechatToRegister(@RequestBody JSONObject param) { public ResponseEntity<AuthenticationInfo> bindWechatToRegister(@RequestBody JSONObject param) {
// 空校验 // 空校验
String loginname = param.getString("loginname"); String loginname = param.getString("loginname");
String password = param.getString("password"); String password = param.getString("password");
...@@ -139,7 +127,6 @@ public class UserWechatRegisterResource { ...@@ -139,7 +127,6 @@ public class UserWechatRegisterResource {
if (StringUtils.isEmpty(openid)) if (StringUtils.isEmpty(openid))
throw new BadRequestAlertException("微信信息openid为空", "UserWechatRegisterResource", ""); throw new BadRequestAlertException("微信信息openid为空", "UserWechatRegisterResource", "");
// 微信用户注册 // 微信用户注册
IBZUSER ibzuser = new IBZUSER(); IBZUSER ibzuser = new IBZUSER();
ibzuser.setPassword(password); ibzuser.setPassword(password);
...@@ -156,8 +143,6 @@ public class UserWechatRegisterResource { ...@@ -156,8 +143,6 @@ public class UserWechatRegisterResource {
userRegisterService.toRegister(ibzuser,userAuth); userRegisterService.toRegister(ibzuser,userAuth);
// 生成登录token信息 // 生成登录token信息
userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); userDetailsService.resetByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains()))); AuthenticationUser user = userDetailsService.loadUserByUsername(ibzuser.getLoginname()+(StringUtils.isEmpty(ibzuser.getDomains())?"":("|"+ibzuser.getDomains())));
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册