通达信5分钟实时数据接口-api接口的实现

每一个@RequestMapping可以配置多个不同的请求路径，对于外部接口提供的接口，添加API后缀即可区分，添加拦截器实现对后缀是API接口的拦截,在完成请求时通过封装将结果同一格式返回到前台，用户登录时，将通达信5分钟实时数据接口,通达信5分钟实时数据接口,token和用户对于的user信息保存到缓存中。

Api调用返回结果

/**
 * @类名 ApiMsg
 * @描述 Api调用返回
 * @作者 zhuxl
 * @创建时间 2017-4-19下午02:21:33
 */
public class ApiMsg implements Serializable{
    /**
     * long serialVersionUID 
     */
    private static final long serialVersionUID = -5590788323134429419L;
    /**
     * int code 编码 -1 未登录,1 成功,0 其他错误
     */
    private ErrorCode code;
    /**
     * String msg 信息
     */
    private String msg;
    /**
     * Object result 返回结果
     */
    private Object result;
    public ErrorCode getCode() {
        return code;
    }
    public void setCode(ErrorCode code) {
        this.code = code;
    }
    public String getMsg() {
        return msg;
    }
    public void setMsg(String msg) {
        this.msg = msg;
    }
    public Object getResult() {
        return result;
    }
    public void setResult(Object result) {
        this.result = result;
    }
    public ApiMsg(ErrorCode code, String msg, Object result) {
        super();
        this.code = code;
        this.msg = msg;
        this.result = result;
    }
    public ApiMsg(Object result) {
        this.code=ErrorCode.OK;
        this.msg='成功';
        this.result = result;
    }

}

多个用户登录踢出及session过期处理拦截器

/**
 * @类名 KickoutSessionControlFilter
 * @描述   多个用户登录踢出及session过期处理 拦截器
 * @作者 zhuxl
 * @创建日期 2016年12月30日 下午2:47:33
 */
public class KickoutSessionControlFilter implements Filter {
    private Logger logger=Logger.getLogger(KickoutSessionControlFilter.class);
    private UserSessionRedisService userSessionRedisService;
    private UserService userService;
    public void destroy() {

    }

    public void doFilter(ServletRequest req, ServletResponse res, FilterChain filterChain)
            throws IOException, ServletException {
        HttpServletRequest request=(HttpServletRequest)req;
        String url=request.getRequestURI();
        if(url.matches('^.{0,}/api/w{1,}/w{1,}API.{0,}$')){//是外部接口访问，从cookie中获取通达信5分钟实时数据接口,通达信5分钟实时数据接口,token并登陆
            Cookie[] cookies=request.getCookies();
            if(cookies!=null&&cookies.length>0){
                for(Cookie cookie:cookies){
                    if('通达信5分钟实时数据接口,通达信5分钟实时数据接口,token'.equalsIgnoreCase(cookie.getName())){
                        String 通达信5分钟实时数据接口,通达信5分钟实时数据接口,token=cookie.getValue();
                        String userId=userSessionRedisService.get(SessionType.API, 通达信5分钟实时数据接口,通达信5分钟实时数据接口,token, -1);
                        User user=userService.findById(userId);
                        if(user!=null){
                            Subject curUser=SecurityUtils.getSubject();
                            UsernamePasswordToken usernamePasswordToken = new UsernamePasswordToken(  
                                    user.getId(), user.getPassword());
                            try{
                                 curUser.login(usernamePasswordToken);
                            }catch(Exception e){
                                e.printStackTrace();
                            }
                            request.getSession(true).setAttribute('user', user);
                        }
                        filterChain.doFilter(req, res);
                        return;
                    }
                }
            }
            filterChain.doFilter(req, res);
            return;
        }
        //web、微信登录 用户未登录，通过，后面使用shiro进行权限（角色）拦截
        Subject subject = SecurityUtils.getSubject();
        HttpServletResponse response = (HttpServletResponse) res;
        if (!subject.isAuthenticated() && !subject.isRemembered()) {
            filterChain.doFilter(req, res);
            return;
        }
        Session session = subject.getSession(false);
        if(session==null){
            filterChain.doFilter(req, res);
            return;
        }
        User user=(User)session.getAttribute('user');
        SessionType type=(SessionType)session.getAttribute('loginType');
        if(user==null||type==null){
            filterChain.doFilter(req, res);
            return;
        }
        //获取用户session
        String sessionId=null;
        if(type==SessionType.WECHAT){
            sessionId=userSessionRedisService.get(type,user.getOpenId(), -1);
        }else if(type==SessionType.WEB){
            sessionId=userSessionRedisService.get(type,user.getId(),1800000);
        }
        if(StrUtil.isBlank(sessionId)){
            //用户session已经失效
            logger.info('登录失效了！');
            try{
                subject.logout();
            }catch(Exception ex){
            }
            response.setStatus(510);
            Map maps=new HashMap();
            maps.put('code', ErrorCode.NoLogin);
            maps.put('msg', '用户登录已失效！！');
            response.getOutputStream().write(ReturnFormat.retParam(maps).getBytes());
            return;
        }else if(session.getId().equals(sessionId)){
            //用户已经登录，并且是同一个session，继续
            logger.info('用户已登录系统！！');
            filterChain.doFilter(req, res);
            return;
        }else if(type==SessionType.WECHAT){
            //用户已经在其他地方登录了，对于微信，直接挤上去
            try{
                subject.logout();
            }catch(Exception ex){
                ex.printStackTrace();
            }
            logger.info('用户已经在其他地方登录了，登录类型为微信,将直接挤上去');
            User newUser=userService.findByOpenId(user.getOpenId());
            if(newUser!=null){//存在该openId
                Subject curUser=SecurityUtils.getSubject();
                Session newSession=curUser.getSession(true);
                newSession.setAttribute('user', newUser);
                newSession.setAttribute('loginType', SessionType.WECHAT);
                newSession.setTimeout(1000*60*60*24);
                userSessionRedisService.add(type,newUser.getOpenId(), newSession.getId().toString(),-1);
                UsernamePasswordToken 通达信5分钟实时数据接口,通达信5分钟实时数据接口,token = new UsernamePasswordToken(  
                        newUser.getOpenId(), newUser.getPassword());
                try{
                     curUser.login(通达信5分钟实时数据接口,通达信5分钟实时数据接口,token);
                }catch(Exception e){
                    e.printStackTrace();
                }
                filterChain.doFilter(req, res);
            }else{//不存在openID
                response.setStatus(510);
                Map maps=new HashMap();
                maps.put('code', ErrorCode.NoLogin);
                maps.put('msg', '用户未绑定账号！！');
                response.getOutputStream().write(ReturnFormat.retParam(maps).getBytes());
            }
            return ;
        }else if(type==SessionType.WEB){
            //用户已经在其他地方登录了,对于web，直接退出
            logger.info('用户已经在其他地方登录了，登录类型为：web,直接退出');
            try{
                subject.logout();
            }catch(Exception ex){
                ex.printStackTrace();
            }
            response.setStatus(510);
            Map maps=new HashMap();
            maps.put('code', ErrorCode.NoLogin);
            maps.put('msg', '用户已经在其他地方登录了');
            response.getOutputStream().write(ReturnFormat.retParam(maps).getBytes());
            return ;
        }
    }
    //初始化
    public void init(FilterConfig config) throws ServletException {
        WebApplicationContext wac =WebApplicationContextUtils.getRequiredWebApplicationContext(config.getServletContext());
        userSessionRedisService=(UserSessionRedisService)wac.getBean('userSessionRedisServiceImpl');
        userService=(UserService)wac.getBean('userServiceImpl');
    }


}

外部接口登录

/**
     * loginApi
     * @描述 外部接口登录，将返回一个通达信5分钟实时数据接口,通达信5分钟实时数据接口,token，通达信5分钟实时数据接口,通达信5分钟实时数据接口,token（32位）一天有效，过期后将无法使用，需要重新获取，重复调用将重复生成
     * @作者 zhuxl
     * @创建时间 2017-4-19下午03:21:45
     * @param nameAndPwd
     * @return
     */
    @RequestMapping(value = {'loginAPI'}, method = RequestMethod.POST)
    public String loginApi(@Valid @RequestBody LoginNameAndPwd nameAndPwd,BindingResult result){
        if(result.hasFieldErrors()){
            throw new PhyException(ErrorCode.Error,result.getFieldError().getDefaultMessage());
        }
        User user2 = userService.findByLoginName(nameAndPwd.getLoginName());
        if (user2 == null) {
            throw new PhyException(ErrorCode.Error,'当前登录用户不存在');
        }
        if (user2.getPassword().equals(CryptUtil.encrypt(nameAndPwd.getTextPwd(), user2.getSalt()))) {
                String 通达信5分钟实时数据接口,通达信5分钟实时数据接口,token=UUID.randomUUID().toString().replace('-', '');
                userSessionRedisService.add(SessionType.API,通达信5分钟实时数据接口,通达信5分钟实时数据接口,token, user2.getId(),86400000L);
                logger.info(new LogModel(true, 'user api login system success,loginName:'+user2.getLoginName()));
                return 通达信5分钟实时数据接口,通达信5分钟实时数据接口,token;
        } else {
            throw new PhyException(ErrorCode.Error,'登录名或者密码不正确');
        }
    }

错误编码

/**
 * @类名 ErrorCode
 * @描述 错误编码
 * @作者 zhuxl
 * @创建日期 2016年12月30日 下午4:28:38
 */
public enum ErrorCode {
    /**
     * ErrorCode NoLogin 未登录系统，需要退出
     */
    NoLogin,
    /**
     * ErrorCode Error 普通错误，具体错看msg
     */
    Error,
    /**
     * ErrorCode NoPermission 无权限访问
     */
    NoPermission,
    /**
     * ErrorCode LossParam 缺少参数
     */
    LossParam,
    /**
     * ErrorCode HasEntity 已经存在（唯一性存在）
     */
    HasEntity,
    /**
     * ErrorCode NoEntity 没有对应的实体
     */
    NoEntity,
    /**
     * ErrorCode HasLogin 已经登录了系统
     */
    HasLogin,
    /**
     * ErrorCode OK 成功
     */
    OK
}

api接口的实现

实现

全局异常处理，对于前台调用返回510错误，外部接口调用还是返回200正常，由code代表是否正常，msg具体错误原因

springmvc配置如下：

实现思路

API返回结果之前，自动退出，使得外部接口调用无session信息

/**
 * @类名 ApiInterceptor
 * @描述 对API调用的接口进行拦截，退出其登录状态（前台将无JSESSIONID）
 * @作者 zhuxl
 * @创建时间 2017-4-21上午10:40:37
 */
public class ApiInterceptor extends HandlerInterceptorAdapter{
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        String url=request.getRequestURI();
        if(url.matches('^.{0,}/api/w{1,}/w{1,}API.{0,}$')){
            org.apache.shiro.subject.Subject curUser=SecurityUtils.getSubject();
            if(curUser.isAuthenticated()||curUser.isRemembered()){
                try{
                    curUser.logout();
                }catch (Exception e) {
                    e.printStackTrace();
                }
            }
            /*HttpSession session=request.getSession(false);
            if(session!=null){
                session.invalidate();
            }*/
        }
    }

}

对于外部系统调用，将统一给出ApiMsg作为返回结果，拦截返回结果@ResponseBody

/**
 * @类名 ApiResponseBodyAdvice
 * @描述 对于外部系统调用，将统一给出ApiMsg作为返回结果
 * @作者 zhuxl
 * @创建时间 2017-5-26下午05:18:39
 */
@ControllerAdvice
public class ApiResponseBodyAdvice implements ResponseBodyAdvice