forked from kidgrow-microservices-platform
blame | history | patch | commit | commitdiff | ignore whitespace
zhaoxiaohao
2020-11-18 4130e1d3fc667fad3349e421e40a0ffa145c563c 
 kidgrow-springcloud/kidgrow-springcloud-zuul/src/main/java/com/kidgrow/zuul/filter/OrganizationFilter.java


@@ -17,10 +17,11 @@


import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;


import org.springframework.security.authentication.AnonymousAuthenticationToken;


import org.springframework.security.core.Authentication;


import org.springframework.security.core.context.SecurityContextHolder;


import org.springframework.security.core.context.SecurityContextImpl;


import org.springframework.security.oauth2.provider.OAuth2Authentication;


import org.springframework.stereotype.Component;




import javax.servlet.http.HttpServletRequest;


import java.util.*;




import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_DECORATION_FILTER_ORDER;


@@ -63,7 +64,14 @@


    @SneakyThrows


    @Override


    public Object run() {


        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();


        //Authentication authentication = SecurityContextHolder.getContext().getAuthentication();


        RequestContext currentContext = RequestContext.getCurrentContext();


        //获取request对象


        HttpServletRequest request = currentContext.getRequest();


        //security会把一个SecurityContextImpl对象存储到session中，此对象中有当前用户的各种资料


        SecurityContextImpl securityContextImpl = (SecurityContextImpl) request


                .getSession().getAttribute("SPRING_SECURITY_CONTEXT");


        Authentication authentication = securityContextImpl.getAuthentication();


        if (authentication != null && !(authentication instanceof AnonymousAuthenticationToken)) {


            Object principal = authentication.getPrincipal();


            RequestContext ctx = RequestContext.getCurrentContext();


@@ -97,7 +105,7 @@


                            map=new HashMap<>();


                            map.put("id",sysUserOrg.getOrgId());


                            List<SysOrganization> sysOrganizations = JSON.parseArray(JSON.toJSONString(sysOrganizationService.getListByMap(map).getData()), SysOrganization.class);


                            if(sysOrganizations.isEmpty()){


                            if(sysOrganizations==null||sysOrganizations.size()<=0){


                                ctx.setSendZuulResponse(false);


                                ctx.addZuulResponseHeader("Content-Type","application/json;charset=UTF-8");


                                ctx.setResponseBody(JSON.toJSONString(ResultBody.fail(1000, "您的组织已经被禁用，请联系管理员")));