|
@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
import com.caimei365.commodity.feign.ToolsFeign;
|
|
|
import com.caimei365.commodity.model.dto.MessageDto;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang.StringUtils;
|
|
|
import org.aspectj.lang.ProceedingJoinPoint;
|
|
|
import org.aspectj.lang.annotation.Around;
|
|
|
import org.aspectj.lang.annotation.Aspect;
|
|
@@ -66,13 +67,27 @@ public class IpSaveAspect {
|
|
|
IpSave ipSave = method.getAnnotation(IpSave.class);
|
|
|
// 访问名 注解的值
|
|
|
String s = ipSave.saveName();
|
|
|
- HashMap<String, Object> stringObjectHashMap = new HashMap<>();
|
|
|
- stringObjectHashMap.put("ip",remoteAddr);
|
|
|
- stringObjectHashMap.put("uri",requestURI);
|
|
|
- stringObjectHashMap.put("param",queryString);
|
|
|
- stringObjectHashMap.put("ipSave",s);
|
|
|
+ String mes="";
|
|
|
+ if(StringUtils.isNotBlank(remoteAddr)){
|
|
|
+ mes+=remoteAddr+"¥";
|
|
|
+ }else{
|
|
|
+ mes="¥";
|
|
|
+ }
|
|
|
+ if(StringUtils.isNotBlank(requestURI)){
|
|
|
+ mes+=requestURI+"¥";
|
|
|
+ }else{
|
|
|
+ mes+="¥";
|
|
|
+ }
|
|
|
+ if(StringUtils.isNotBlank(queryString)){
|
|
|
+ mes+=queryString+"¥";
|
|
|
+ }else {
|
|
|
+ mes +="¥";
|
|
|
+ }
|
|
|
+ if(StringUtils.isNotBlank(s)){
|
|
|
+ mes+=s;
|
|
|
+ }
|
|
|
//异步给mq存
|
|
|
- toolsFeign.sendCommonMessage("IpSave",stringObjectHashMap.toString(),null,1,1,null,null);
|
|
|
+ toolsFeign.sendCommonMessage("IpSave",mes,null,1,1,null,null);
|
|
|
|
|
|
return joinPoint.proceed();
|
|
|
}
|