From 25d3298b71253900d46491c05547e9d36d5fb762 Mon Sep 17 00:00:00 2001 From: "dengchao@xgtl" <2325690622@qq.com> Date: Wed, 15 Apr 2020 17:32:00 +0800 Subject: [PATCH] Fix BasicErrorController's package path --- .../interceptor/UserInterceptorHandler.java | 387 +++++++++--------- 1 file changed, 193 insertions(+), 194 deletions(-) diff --git a/contact-center/app/src/main/java/com/chatopera/cc/interceptor/UserInterceptorHandler.java b/contact-center/app/src/main/java/com/chatopera/cc/interceptor/UserInterceptorHandler.java index 22fe9670..fe5e638a 100644 --- a/contact-center/app/src/main/java/com/chatopera/cc/interceptor/UserInterceptorHandler.java +++ b/contact-center/app/src/main/java/com/chatopera/cc/interceptor/UserInterceptorHandler.java @@ -1,194 +1,193 @@ -/* - * Copyright (C) 2017 优客服-多渠道客服系统 - * Modifications copyright (C) 2018-2019 Chatopera Inc, - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.chatopera.cc.interceptor; - -import com.chatopera.cc.acd.ACDServiceRouter; -import com.chatopera.cc.basic.Constants; -import com.chatopera.cc.basic.MainContext; -import com.chatopera.cc.basic.MainUtils; -import com.chatopera.cc.config.MessagingServerConfigure; -import com.chatopera.cc.model.Dict; -import com.chatopera.cc.model.SystemConfig; -import com.chatopera.cc.model.User; -import com.chatopera.cc.proxy.AgentSessionProxy; -import com.chatopera.cc.proxy.UserProxy; -import com.chatopera.cc.util.Menu; -import org.apache.commons.lang.StringUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.boot.autoconfigure.web.BasicErrorController; -import org.springframework.web.method.HandlerMethod; -import org.springframework.web.servlet.ModelAndView; -import org.springframework.web.servlet.handler.HandlerInterceptorAdapter; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; - -public class UserInterceptorHandler extends HandlerInterceptorAdapter { - private final static Logger logger = LoggerFactory.getLogger(UserInterceptorHandler.class); - private static UserProxy userProxy; - private static AgentSessionProxy agentSessionProxy; - private static Integer webimport; - - @Override - public boolean preHandle(final HttpServletRequest request, final HttpServletResponse response, Object handler) - throws Exception { - boolean filter = false; - User user = (User) request.getSession(true).getAttribute(Constants.USER_SESSION_NAME); - - if (handler instanceof HandlerMethod) { - HandlerMethod handlerMethod = (HandlerMethod) handler; - Menu menu = handlerMethod.getMethod().getAnnotation(Menu.class); - if (user != null || (menu != null && menu.access()) || handlerMethod.getBean() instanceof BasicErrorController) { - filter = true; - if (user != null && StringUtils.isNotBlank(user.getId())) { - - /** - * 每次刷新用户的组织机构、角色和权限 - * TODO 此处代码执行频率高，但是并不是每次都要执行，存在很多冗余 - * 待用更好的方法实现 - */ - getUserProxy().attachOrgansPropertiesForUser(user); - getUserProxy().attachRolesMap(user); - - request.getSession(true).setAttribute(Constants.USER_SESSION_NAME, user); - } - } - - if (!filter) { - if (StringUtils.isNotBlank(request.getParameter("msg"))) { - response.sendRedirect("/login.html?msg=" + request.getParameter("msg")); - } else { - response.sendRedirect("/login.html"); - } - } - } else { - filter = true; - } - return filter; - } - - @Override - public void postHandle( - HttpServletRequest request, HttpServletResponse response, Object arg2, - ModelAndView view) { - final User user = (User) request.getSession().getAttribute(Constants.USER_SESSION_NAME); - final String infoace = (String) request.getSession().getAttribute( - Constants.CSKEFU_SYSTEM_INFOACQ); //进入信息采集模式 - final SystemConfig systemConfig = MainUtils.getSystemConfig(); - if (view != null) { - if (user != null) { - view.addObject("user", user); - - if (systemConfig != null && systemConfig.isEnablessl()) { - view.addObject("schema", "https"); - if (request.getServerPort() == 80) { - view.addObject("port", 443); - } else { - view.addObject("port", request.getServerPort()); - } - } else { - view.addObject("schema", request.getScheme()); - view.addObject("port", request.getServerPort()); - } - view.addObject("hostname", request.getServerName()); - - HandlerMethod handlerMethod = (HandlerMethod) arg2; - Menu menu = handlerMethod.getMethod().getAnnotation(Menu.class); - if (menu != null) { - view.addObject("subtype", menu.subtype()); - view.addObject("maintype", menu.type()); - view.addObject("typename", menu.name()); - } - view.addObject("orgi", user.getOrgi()); - } - if (StringUtils.isNotBlank(infoace)) { - view.addObject("infoace", infoace); //进入信息采集模式 - } - view.addObject("webimport", getWebimport()); - view.addObject("sessionid", MainUtils.getContextID(request.getSession().getId())); - - view.addObject("models", MainContext.getModules()); - - if (user != null) { - view.addObject( - "agentStatusReport", - ACDServiceRouter.getAcdWorkMonitor().getAgentReport(user.getOrgi())); - } - /** - * WebIM共享用户 - */ - User imUser = (User) request.getSession().getAttribute(Constants.IM_USER_SESSION_NAME); - if (imUser == null && view != null) { - imUser = new User(); - imUser.setUsername(Constants.GUEST_USER); - imUser.setId(MainUtils.getContextID(request.getSession(true).getId())); - imUser.setSessionid(imUser.getId()); - view.addObject("imuser", imUser); - } - - if (request.getParameter("msg") != null) { - view.addObject("msg", request.getParameter("msg")); - } - - view.addObject("uKeFuDic", Dict.getInstance()); //处理系统 字典数据 ， 通过 字典code 获取 - - view.addObject( - "uKeFuSecField", MainContext.getCache().findOneSystemByIdAndOrgi( - Constants.CSKEFU_SYSTEM_SECFIELD, - MainContext.SYSTEM_ORGI)); //处理系统 需要隐藏号码的字段， 启动的时候加载 - - if (systemConfig != null) { - view.addObject("systemConfig", systemConfig); - } else { - view.addObject("systemConfig", new SystemConfig()); - } - view.addObject("tagTypeList", Dict.getInstance().getDic("com.dic.tag.type")); - - view.addObject("advTypeList", Dict.getInstance().getDic("com.dic.adv.type")); - view.addObject("ip", request.getRemoteAddr()); - } - } - - @Override - public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - } - - - private static Integer getWebimport() { - if (webimport == null) { - webimport = MainContext.getContext().getBean(MessagingServerConfigure.class).getWebIMPort(); - } - return webimport; - } - - - private static UserProxy getUserProxy() { - if (userProxy == null) { - userProxy = MainContext.getContext().getBean(UserProxy.class); - } - return userProxy; - } - - private static AgentSessionProxy getAgentSessionProxy() { - if (agentSessionProxy == null) { - agentSessionProxy = MainContext.getContext().getBean(AgentSessionProxy.class); - } - return agentSessionProxy; - } - -} +/* + * Copyright (C) 2017 优客服-多渠道客服系统 + * Modifications copyright (C) 2018-2019 Chatopera Inc, + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.chatopera.cc.interceptor; + +import com.chatopera.cc.acd.ACDServiceRouter; +import com.chatopera.cc.basic.Constants; +import com.chatopera.cc.basic.MainContext; +import com.chatopera.cc.basic.MainUtils; +import com.chatopera.cc.config.MessagingServerConfigure; +import com.chatopera.cc.model.Dict; +import com.chatopera.cc.model.SystemConfig; +import com.chatopera.cc.model.User; +import com.chatopera.cc.proxy.AgentSessionProxy; +import com.chatopera.cc.proxy.UserProxy; +import com.chatopera.cc.util.Menu; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController; +import org.springframework.lang.NonNull; +import org.springframework.lang.Nullable; +import org.springframework.web.method.HandlerMethod; +import org.springframework.web.servlet.ModelAndView; +import org.springframework.web.servlet.handler.HandlerInterceptorAdapter; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; + +@Slf4j +public class UserInterceptorHandler extends HandlerInterceptorAdapter { + + private static UserProxy userProxy; + private static AgentSessionProxy agentSessionProxy; + private static Integer webIMPort; + + private static Integer getWebIMPort() { + if (webIMPort == null) { + webIMPort = MainContext.getContext().getBean(MessagingServerConfigure.class).getWebIMPort(); + } + return webIMPort; + } + + private static UserProxy getUserProxy() { + if (userProxy == null) { + userProxy = MainContext.getContext().getBean(UserProxy.class); + } + return userProxy; + } + + private static AgentSessionProxy getAgentSessionProxy() { + if (agentSessionProxy == null) { + agentSessionProxy = MainContext.getContext().getBean(AgentSessionProxy.class); + } + return agentSessionProxy; + } + + @Override + public boolean preHandle(@NonNull final HttpServletRequest request, @NonNull final HttpServletResponse response, + @NonNull Object handler) throws Exception { + boolean filter = false; + User user = (User) request.getSession(true).getAttribute(Constants.USER_SESSION_NAME); + + if (handler instanceof HandlerMethod) { + HandlerMethod handlerMethod = (HandlerMethod) handler; + Menu menu = handlerMethod.getMethod().getAnnotation(Menu.class); + if (user != null || (menu != null && menu.access()) || handlerMethod.getBean() instanceof BasicErrorController) { + filter = true; + if (user != null && StringUtils.isNotBlank(user.getId())) { + + /* + * 每次刷新用户的组织机构、角色和权限 + * TODO 此处代码执行频率高，但是并不是每次都要执行，存在很多冗余 + * 待用更好的方法实现 + */ + getUserProxy().attachOrgansPropertiesForUser(user); + getUserProxy().attachRolesMap(user); + + request.getSession(true).setAttribute(Constants.USER_SESSION_NAME, user); + } + } + + if (!filter) { + if (StringUtils.isNotBlank(request.getParameter("msg"))) { + response.sendRedirect("/login.html?msg=" + request.getParameter("msg")); + } else { + response.sendRedirect("/login.html"); + } + } + } else { + filter = true; + } + return filter; + } + + @Override + public void postHandle(@NonNull HttpServletRequest request, @NonNull HttpServletResponse response, @NonNull Object handler, + @Nullable ModelAndView view) { + final User user = (User) request.getSession().getAttribute(Constants.USER_SESSION_NAME); + final String infoace = (String) request.getSession().getAttribute( + Constants.CSKEFU_SYSTEM_INFOACQ); //进入信息采集模式 + final SystemConfig systemConfig = MainUtils.getSystemConfig(); + if (view != null) { + if (user != null) { + view.addObject("user", user); + + if (systemConfig != null && systemConfig.isEnablessl()) { + view.addObject("schema", "https"); + if (request.getServerPort() == 80) { + view.addObject("port", 443); + } else { + view.addObject("port", request.getServerPort()); + } + } else { + view.addObject("schema", request.getScheme()); + view.addObject("port", request.getServerPort()); + } + view.addObject("hostname", request.getServerName()); + + HandlerMethod handlerMethod = (HandlerMethod) handler; + Menu menu = handlerMethod.getMethod().getAnnotation(Menu.class); + if (menu != null) { + view.addObject("subtype", menu.subtype()); + view.addObject("maintype", menu.type()); + view.addObject("typename", menu.name()); + } + view.addObject("orgi", user.getOrgi()); + } + if (StringUtils.isNotBlank(infoace)) { + view.addObject("infoace", infoace); //进入信息采集模式 + } + view.addObject("webimport", getWebIMPort()); + view.addObject("sessionid", MainUtils.getContextID(request.getSession().getId())); + + view.addObject("models", MainContext.getModules()); + + if (user != null) { + view.addObject( + "agentStatusReport", + ACDServiceRouter.getAcdWorkMonitor().getAgentReport(user.getOrgi())); + } + /* + * WebIM共享用户 + */ + User imUser = (User) request.getSession().getAttribute(Constants.IM_USER_SESSION_NAME); + if (imUser == null) { + imUser = new User(); + imUser.setUsername(Constants.GUEST_USER); + imUser.setId(MainUtils.getContextID(request.getSession(true).getId())); + imUser.setSessionid(imUser.getId()); + view.addObject("imuser", imUser); + } + + if (request.getParameter("msg") != null) { + view.addObject("msg", request.getParameter("msg")); + } + + view.addObject("uKeFuDic", Dict.getInstance()); //处理系统 字典数据 ， 通过 字典code 获取 + + view.addObject( + "uKeFuSecField", MainContext.getCache().findOneSystemByIdAndOrgi( + Constants.CSKEFU_SYSTEM_SECFIELD, + MainContext.SYSTEM_ORGI)); //处理系统 需要隐藏号码的字段， 启动的时候加载 + + if (systemConfig != null) { + view.addObject("systemConfig", systemConfig); + } else { + view.addObject("systemConfig", new SystemConfig()); + } + view.addObject("tagTypeList", Dict.getInstance().getDic("com.dic.tag.type")); + + view.addObject("advTypeList", Dict.getInstance().getDic("com.dic.adv.type")); + view.addObject("ip", request.getRemoteAddr()); + } + } + + @Override + public void afterCompletion(@NonNull HttpServletRequest request, @NonNull HttpServletResponse response, @NonNull Object handler, @Nullable Exception ex) { + } + +}