package com.ruoyi.framework.interceptor;

import java.lang.reflect.Method;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.springframework.stereotype.Component;

import org.springframework.web.method.HandlerMethod;

import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;

import com.ruoyi.common.annotation.RepeatSubmit;

import com.ruoyi.common.core.domain.AjaxResult;

import com.ruoyi.common.json.JSON;

import com.ruoyi.common.utils.ServletUtils;

/**

 * 防止重复提交拦截器

 *

 * @author ruoyi

 */

@Component

public abstract class RepeatSubmitInterceptor extends HandlerInterceptorAdapter

{

    @Override

    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception

    {

        if (handler instanceof HandlerMethod)

        {

            HandlerMethod handlerMethod = (HandlerMethod) handler;

            Method method = handlerMethod.getMethod();

            RepeatSubmit annotation = method.getAnnotation(RepeatSubmit.class);

            if (annotation != null)

            {

                if (this.isRepeatSubmit(request))

                {

                    AjaxResult ajaxResult = AjaxResult.error("不允许重复提交，请稍后再试");

                    ServletUtils.renderString(response, JSON.marshal(ajaxResult));

                    return false;

                }

            }

            return true;

        }

        else

        {

            return super.preHandle(request, response, handler);

        }

    }

    /**

     * 验证是否重复提交由子类实现具体的防重复提交的规则

     *

     * @param httpServletRequest

     * @return

     * @throws Exception

     */

    public abstract boolean isRepeatSubmit(HttpServletRequest request) throws Exception;

}
package com.ruoyi.framework.interceptor.impl;

import java.util.HashMap;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;

import org.springframework.stereotype.Component;

import com.ruoyi.common.json.JSON;

import com.ruoyi.framework.interceptor.RepeatSubmitInterceptor;

/**

 * 判断请求url和数据是否和上一次相同，

 * 如果和上次相同，则是重复提交表单。 有效时间为10秒内。

 *

 * @author ruoyi

 */

@Component

public class SameUrlDataInterceptor extends RepeatSubmitInterceptor

{

    public final String REPEAT_PARAMS = "repeatParams";

    public final String REPEAT_TIME = "repeatTime";

    public final String SESSION_REPEAT_KEY = "repeatData";

    /**

     * 间隔时间，单位:秒 默认10秒

     *

     * 两次相同参数的请求，如果间隔时间大于该参数，系统不会认定为重复提交的数据

     */

    private int intervalTime = 10;

    public void setIntervalTime(int intervalTime)

    {

        this.intervalTime = intervalTime;

    }

    @SuppressWarnings("unchecked")

    @Override

    public boolean isRepeatSubmit(HttpServletRequest request) throws Exception

    {

        // 本次参数及系统时间

        String nowParams = JSON.marshal(request.getParameterMap());

        Map<String, Object> nowDataMap = new HashMap<String, Object>();

        nowDataMap.put(REPEAT_PARAMS, nowParams);

        nowDataMap.put(REPEAT_TIME, System.currentTimeMillis());

        // 请求地址（作为存放session的key值）

        String url = request.getRequestURI();

        HttpSession session = request.getSession();

        Object sessionObj = session.getAttribute(SESSION_REPEAT_KEY);

        if (sessionObj != null)

        {

            Map<String, Object> sessionMap = (Map<String, Object>) sessionObj;

            if (sessionMap.containsKey(url))

            {

                Map<String, Object> preDataMap = (Map<String, Object>) sessionMap.get(url);

                if (compareParams(nowDataMap, preDataMap) && compareTime(nowDataMap, preDataMap))

                {

                    return true;

                }

            }

        }

        Map<String, Object> sessionMap = new HashMap<String, Object>();

        sessionMap.put(url, nowDataMap);

        session.setAttribute(SESSION_REPEAT_KEY, sessionMap);

        return false;

    }

    /**

     * 判断参数是否相同

     */

    private boolean compareParams(Map<String, Object> nowMap, Map<String, Object> preMap)

    {

        String nowParams = (String) nowMap.get(REPEAT_PARAMS);

        String preParams = (String) preMap.get(REPEAT_PARAMS);

        return nowParams.equals(preParams);

    }

    /**

     * 判断两次间隔时间

     */

    private boolean compareTime(Map<String, Object> nowMap, Map<String, Object> preMap)

    {

        long time1 = (Long) nowMap.get(REPEAT_TIME);

        long time2 = (Long) preMap.get(REPEAT_TIME);

        if ((time1 - time2) < (this.intervalTime * 1000))

        {

            return true;

        }

        return false;

    }

}
package com.ruoyi.common.annotation;

import java.lang.annotation.Documented;

import java.lang.annotation.ElementType;

import java.lang.annotation.Inherited;

import java.lang.annotation.Retention;

import java.lang.annotation.RetentionPolicy;

import java.lang.annotation.Target;

/**

 * 自定义注解防止表单重复提交

 *

 * @author ruoyi

 *

 */

@Inherited

@Target(ElementType.METHOD)

@Retention(RetentionPolicy.RUNTIME)

@Documented

public @interface RepeatSubmit

{

}
package com.ruoyi.common.core.domain;

import java.util.HashMap;

import com.ruoyi.common.utils.StringUtils;

/**

 * 操作消息提醒

 *

 * @author ruoyi

 */

public class AjaxResult extends HashMap<String, Object>

{

    private static final long serialVersionUID = 1L;

    /** 状态码 */

    public static final String CODE_TAG = "code";

    /** 返回内容 */

    public static final String MSG_TAG = "msg";

    /** 数据对象 */

    public static final String DATA_TAG = "data";

    /**

     * 状态类型

     */

    public enum Type

    {

        /** 成功 */

        SUCCESS(0),

        /** 警告 */

        WARN(301),

        /** 错误 */

        ERROR(500);

        private final int value;

        Type(int value)

        {

            this.value = value;

        }

        public int value()

        {

            return this.value;

        }

    }

    /**

     * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。

     */

    public AjaxResult()

    {

    }

    /**

     * 初始化一个新创建的 AjaxResult 对象

     *

     * @param type 状态类型

     * @param msg 返回内容

     */

    public AjaxResult(Type type, String msg)

    {

        super.put(CODE_TAG, type.value);

        super.put(MSG_TAG, msg);

    }

    /**

     * 初始化一个新创建的 AjaxResult 对象

     *

     * @param type 状态类型

     * @param msg 返回内容

     * @param data 数据对象

     */

    public AjaxResult(Type type, String msg, Object data)

    {

        super.put(CODE_TAG, type.value);

        super.put(MSG_TAG, msg);

        if (StringUtils.isNotNull(data))

        {

            super.put(DATA_TAG, data);

        }

    }

    /**

     * 返回成功消息

     *

     * @return 成功消息

     */

    public static AjaxResult success()

    {

        return AjaxResult.success("操作成功");

    }

    /**

     * 返回成功数据

     *

     * @return 成功消息

     */

    public static AjaxResult success(Object data)

    {

        return AjaxResult.success("操作成功", data);

    }

    /**

     * 返回成功消息

     *

     * @param msg 返回内容

     * @return 成功消息

     */

    public static AjaxResult success(String msg)

    {

        return AjaxResult.success(msg, null);

    }

    /**

     * 返回成功消息

     *

     * @param msg 返回内容

     * @param data 数据对象

     * @return 成功消息

     */

    public static AjaxResult success(String msg, Object data)

    {

        return new AjaxResult(Type.SUCCESS, msg, data);

    }

    /**

     * 返回警告消息

     *

     * @param msg 返回内容

     * @return 警告消息

     */

    public static AjaxResult warn(String msg)

    {

        return AjaxResult.warn(msg, null);

    }

    /**

     * 返回警告消息

     *

     * @param msg 返回内容

     * @param data 数据对象

     * @return 警告消息

     */

    public static AjaxResult warn(String msg, Object data)

    {

        return new AjaxResult(Type.WARN, msg, data);

    }

    /**

     * 返回错误消息

     *

     * @return

     */

    public static AjaxResult error()

    {

        return AjaxResult.error("操作失败");

    }

    /**

     * 返回错误消息

     *

     * @param msg 返回内容

     * @return 警告消息

     */

    public static AjaxResult error(String msg)

    {

        return AjaxResult.error(msg, null);

    }

    /**

     * 返回错误消息

     *

     * @param msg 返回内容

     * @param data 数据对象

     * @return 警告消息

     */

    public static AjaxResult error(String msg, Object data)

    {

        return new AjaxResult(Type.ERROR, msg, data);

    }

}
package com.ruoyi.framework.config;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Configuration;

import org.springframework.web.servlet.config.annotation.InterceptorRegistry;

import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;

import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;

import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

import com.ruoyi.common.config.Global;

import com.ruoyi.common.constant.Constants;

import com.ruoyi.framework.interceptor.RepeatSubmitInterceptor;

/**

 * 通用配置

 *

 * @author ruoyi

 */

@Configuration

public class ResourcesConfig implements WebMvcConfigurer

{

    /**

     * 首页地址

     */

    @Value("${shiro.user.indexUrl}")

    private String indexUrl;

    @Autowired

    private RepeatSubmitInterceptor repeatSubmitInterceptor;

    /**

     * 默认首页的设置，当输入域名是可以自动跳转到默认指定的网页

     */

    @Override

    public void addViewControllers(ViewControllerRegistry registry)

    {

        registry.addViewController("/").setViewName("forward:" + indexUrl);

    }

    @Override

    public void addResourceHandlers(ResourceHandlerRegistry registry)

    {

        /** 本地文件上传路径 */

        registry.addResourceHandler(Constants.RESOURCE_PREFIX + "/**").addResourceLocations("file:" + Global.getProfile() + "/");

        /** swagger配置 */

        registry.addResourceHandler("swagger-ui.html").addResourceLocations("classpath:/META-INF/resources/");

        registry.addResourceHandler("/webjars/**").addResourceLocations("classpath:/META-INF/resources/webjars/");

    }

    /**

     * 自定义拦截规则

     */

    @Override

    public void addInterceptors(InterceptorRegistry registry)

    {

        registry.addInterceptor(repeatSubmitInterceptor).addPathPatterns("/**");

    }

}

最新文章

  1. TCP服务和首部知识点小结
  2. （转载）centos yum源的配置和使用
  3. Ehcache Demo
  4. jQuery中的事件与动画 (你的明天Via Via)
  5. Hash链表
  6. Java for LeetCode 078 Subsets
  7. 数独Sudoku
  8. XSS技巧综合
  9. jQuery：show()方法
  10. quartz 时间配置规则
  11. Eclipse+Axis自动生成Web Service WSDL文件
  12. 1px
  13. 用 CALayer 定制下载进度条控件
  14. html中的表格 bootstrap-table
  15. WPF中将16进制颜色码转换成SolidColorBrush
  16. python爬虫——写出最简单的网页爬虫
  17. bzoj1233[Usaco2009Open]干草堆tower 单调队列优化dp
  18. 深入理解C#中的IDisposable接口
  19. 二.Rsync备份服务
  20. springboot启动插件

热门文章

  1. 088-PHP数组运用 - 通过循环函数过滤部分数组
  2. 量化交易回测系统---RQalpha、qstrade学习笔记
  3. redis性能测试方法
  4. Arduino - -- 串口双向通信
  5. php-fpm启动 关闭 重启
  6. /Array.CreateInstance创建类型为int，长度为5的数组
  7. idea自定义模版
  8. 读书笔记 - js高级程序设计 - 第六章 面向对象的程序设计
  9. [前端] VUE基础 (9) (element-ui、axios、Vuex)
  10. MyBatis 关联查询的实现：多对多