Commit aa7ab76f authored by 唐峰's avatar 唐峰

Merge branch 'feature-migration-20230628' of...

Merge branch 'feature-migration-20230628' of git.quantgroup.cn:head_group/xyqb-user2 into feature-migration-20230628
parents 30dc036c 7e3436b1
...@@ -24,7 +24,7 @@ import java.util.List; ...@@ -24,7 +24,7 @@ import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@RestController @RestController
@RequestMapping("/api/v2/user") @RequestMapping("/api/v2/users")
public class UserApiV2Controller { public class UserApiV2Controller {
private final IUserRepository userRepository; private final IUserRepository userRepository;
......
...@@ -9,16 +9,12 @@ import cn.quantgroup.xyqb.remote.StmsRemoteService; ...@@ -9,16 +9,12 @@ import cn.quantgroup.xyqb.remote.StmsRemoteService;
import cn.quantgroup.xyqb.service.session.ISessionService; import cn.quantgroup.xyqb.service.session.ISessionService;
import cn.quantgroup.xyqb.session.XyqbSessionContextHolder; import cn.quantgroup.xyqb.session.XyqbSessionContextHolder;
import cn.quantgroup.xyqb.util.StringUtils; import cn.quantgroup.xyqb.util.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.springframework.web.servlet.HandlerInterceptor; import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
/** /**
* stms权限认证拦截器 * stms权限认证拦截器
...@@ -41,19 +37,17 @@ public class InnerInterceptor implements HandlerInterceptor { ...@@ -41,19 +37,17 @@ public class InnerInterceptor implements HandlerInterceptor {
if (StringUtils.isEmpty(tenantId)) { if (StringUtils.isEmpty(tenantId)) {
throw new BizException(BizExceptionEnum.UN_EXIT_TENANT_ID); throw new BizException(BizExceptionEnum.UN_EXIT_TENANT_ID);
} }
if (StringUtils.isEmpty(registeredFrom)) {
throw new BizException(BizExceptionEnum.UN_EXIT_REGISTERED_FROM);
}
if (StringUtils.isEmpty(stmsToken)) { if (StringUtils.isEmpty(stmsToken)) {
throw new BizException(BizExceptionEnum.UN_EXIT_STMS_TOKEN); throw new BizException(BizExceptionEnum.UN_EXIT_STMS_TOKEN);
} }
SessionStruct sessionStruct = XyqbSessionContextHolder.getXSessionFromRedis(stmsToken,Integer.valueOf(tenantId)); SessionStruct sessionStruct = XyqbSessionContextHolder.getXSessionFromRedis(stmsToken, Integer.valueOf(tenantId));
if (sessionStruct == null) { if (sessionStruct == null) {
OauthResult oauthResult = stmsRemoteService.checkToken(stmsToken); OauthResult oauthResult = stmsRemoteService.checkToken(stmsToken);
if (oauthResult != null && 2000 == oauthResult.getCode()) { if (oauthResult != null && 2000 == oauthResult.getCode()) {
LinkedHashMap<String,Object> linkedHashMap = (LinkedHashMap<String, Object>) oauthResult.getData(); LinkedHashMap<String, Object> linkedHashMap = (LinkedHashMap<String, Object>) oauthResult.getData();
String userId = String.valueOf(linkedHashMap.get("id")); String userId = String.valueOf(linkedHashMap.get("id"));
String userName = String.valueOf(linkedHashMap.get("name")); String userName = String.valueOf(linkedHashMap.get("name"));
sessionStruct = XyqbSessionContextHolder.initSTMSSession(stmsToken, userId, userName); sessionStruct = XyqbSessionContextHolder.initSTMSSession(stmsToken, userId, userName);
......
...@@ -95,6 +95,11 @@ public class XyqbSessionContextHolder { ...@@ -95,6 +95,11 @@ public class XyqbSessionContextHolder {
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String tenantId = request.getHeader(Constants.X_AUTH_TENANT); String tenantId = request.getHeader(Constants.X_AUTH_TENANT);
String registered_from = request.getHeader(Constants.X_AUTH_FROM); String registered_from = request.getHeader(Constants.X_AUTH_FROM);
if (cn.quantgroup.xyqb.util.StringUtils.isEmpty(registered_from)) {
//TODO:唐峰,先默认给0
registered_from = "0";
}
String ip = IpUtil.getRemoteIP(request); String ip = IpUtil.getRemoteIP(request);
sessionStruct.setTenantId(Integer.valueOf(tenantId)); sessionStruct.setTenantId(Integer.valueOf(tenantId));
sessionStruct.setRegisteredFrom(Long.valueOf(registered_from)); sessionStruct.setRegisteredFrom(Long.valueOf(registered_from));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment