| | |
|---|
| | | package com.ruoyi.framework.aspectj; |
|---|
| | | |
|---|
| | | import cn.dev33.satoken.SaManager; |
|---|
| | | import cn.hutool.core.util.ObjectUtil; |
|---|
| | | import cn.hutool.crypto.SecureUtil; |
|---|
| | | import com.ruoyi.common.annotation.RepeatSubmit; |
|---|
| | | import com.ruoyi.common.constant.Constants; |
|---|
| | | import com.ruoyi.common.exception.ServiceException; |
|---|
| | | import com.ruoyi.common.utils.JsonUtils; |
|---|
| | | import com.ruoyi.common.utils.RedisUtils; |
|---|
| | | import com.ruoyi.common.utils.ServletUtils; |
|---|
| | | import com.ruoyi.common.utils.StringUtils; |
|---|
| | | import com.ruoyi.common.utils.redis.RedisUtils; |
|---|
| | | import com.ruoyi.framework.config.properties.RepeatSubmitProperties; |
|---|
| | | import lombok.RequiredArgsConstructor; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.aspectj.lang.JoinPoint; |
|---|
| | | import org.aspectj.lang.annotation.Aspect; |
|---|
| | | import org.aspectj.lang.annotation.Before; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.validation.BindingResult; |
|---|
| | | import org.springframework.web.multipart.MultipartFile; |
|---|
| | |
|---|
| | | * @author Lion Li |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @RequiredArgsConstructor(onConstructor_ = @Autowired) |
|---|
| | | @RequiredArgsConstructor |
|---|
| | | @Aspect |
|---|
| | | @Component |
|---|
| | | public class RepeatSubmitAspect { |
|---|
| | |
|---|
| | | String url = request.getRequestURI(); |
|---|
| | | |
|---|
| | | // 唯一值（没有消息头则使用请求地址） |
|---|
| | | String submitKey = request.getHeader(SaManager.getConfig().getTokenName()); |
|---|
| | | if (StringUtils.isEmpty(submitKey)) { |
|---|
| | | submitKey = url; |
|---|
| | | } |
|---|
| | | String submitKey = StringUtils.trimToEmpty(request.getHeader(SaManager.getConfig().getTokenName())); |
|---|
| | | |
|---|
| | | submitKey = SecureUtil.md5(submitKey + ":" + nowParams); |
|---|
| | | // 唯一标识（指定key + 消息头） |
|---|
| | | String cacheRepeatKey = Constants.REPEAT_SUBMIT_KEY + submitKey; |
|---|
| | | // 唯一标识（指定key + url + 消息头） |
|---|
| | | String cacheRepeatKey = Constants.REPEAT_SUBMIT_KEY + url + submitKey; |
|---|
| | | String key = RedisUtils.getCacheObject(cacheRepeatKey); |
|---|
| | | if (key == null) { |
|---|
| | | RedisUtils.setCacheObject(cacheRepeatKey, "", interval, TimeUnit.MILLISECONDS); |
|---|
| | |
|---|
| | | StringBuilder params = new StringBuilder(); |
|---|
| | | if (paramsArray != null && paramsArray.length > 0) { |
|---|
| | | for (Object o : paramsArray) { |
|---|
| | | if (StringUtils.isNotNull(o) && !isFilterObject(o)) { |
|---|
| | | if (ObjectUtil.isNotNull(o) && !isFilterObject(o)) { |
|---|
| | | try { |
|---|
| | | params.append(JsonUtils.toJsonString(o)).append(" "); |
|---|
| | | } catch (Exception e) { |
|---|
