| | |
| | | import javax.servlet.http.HttpServletRequest;
|
| | | import org.springframework.beans.factory.annotation.Autowired;
|
| | | import org.springframework.beans.factory.annotation.Value;
|
| | | import org.springframework.http.MediaType;
|
| | | import org.springframework.stereotype.Component;
|
| | | import com.alibaba.fastjson.JSONObject;
|
| | | import com.ruoyi.common.constant.Constants;
|
| | |
| | | public boolean isRepeatSubmit(HttpServletRequest request)
|
| | | {
|
| | | String nowParams = "";
|
| | | if (request instanceof HttpServletRequest && StringUtils.equalsAnyIgnoreCase(request.getContentType(),
|
| | | MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_JSON_UTF8_VALUE))
|
| | | if (request instanceof RepeatedlyRequestWrapper)
|
| | | {
|
| | | RepeatedlyRequestWrapper repeatedlyRequest = (RepeatedlyRequestWrapper) request;
|
| | | nowParams = HttpHelper.getBodyString(repeatedlyRequest);
|
| | |
| | |
|
| | | // 请求地址(作为存放cache的key值)
|
| | | String url = request.getRequestURI();
|
| | | |
| | | // 唯一值(没有消息头则使用请求地址)
|
| | | String submitKey = request.getHeader(header);
|
| | | if (StringUtils.isEmpty(submitKey))
|
| | | {
|
| | | submitKey = url;
|
| | | }
|
| | |
|
| | | // 唯一标识(指定key + 消息头)
|
| | | String cache_repeat_key = Constants.REPEAT_SUBMIT_KEY + request.getHeader(header);
|
| | | String cacheRepeatKey = Constants.REPEAT_SUBMIT_KEY + submitKey;
|
| | |
|
| | | Object sessionObj = redisCache.getCacheObject(cache_repeat_key);
|
| | | Object sessionObj = redisCache.getCacheObject(cacheRepeatKey);
|
| | | if (sessionObj != null)
|
| | | {
|
| | | Map<String, Object> sessionMap = (Map<String, Object>) sessionObj;
|
| | |
| | | }
|
| | | Map<String, Object> cacheMap = new HashMap<String, Object>();
|
| | | cacheMap.put(url, nowDataMap);
|
| | | redisCache.setCacheObject(cache_repeat_key, cacheMap, intervalTime, TimeUnit.SECONDS);
|
| | | redisCache.setCacheObject(cacheRepeatKey, cacheMap, intervalTime, TimeUnit.SECONDS);
|
| | | return false;
|
| | | }
|
| | |
|