package com.thhy.general.config;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.thhy.general.common.enums.LogTypeEnums;
|
import com.thhy.general.entity.SysLogVo;
|
import com.thhy.general.utils.UserInfoUtils;
|
import lombok.Data;
|
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
import org.aspectj.lang.ProceedingJoinPoint;
|
import org.aspectj.lang.annotation.Around;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.annotation.Pointcut;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.messaging.Message;
|
import org.springframework.messaging.support.MessageBuilder;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.Map;
|
|
@Component
|
@Aspect
|
@ConditionalOnProperty(prefix = "rocketmq",value = "enable",havingValue = "true")
|
public class SysLogExec {
|
|
@Pointcut("execution(public * com.thhy.*.modules.*.*.service.impl.*.*(..))")
|
public void pointcut(){
|
|
}
|
|
@Autowired
|
private RocketMQTemplate rocketMQTemplate;
|
|
@Value("${spring.application.name}")
|
private String moduleName;
|
|
private String topic = "syslog";
|
|
@Around("pointcut()")
|
public Object invoke(ProceedingJoinPoint invocation) throws Throwable {
|
|
String methodName = invocation.getSignature().getName();
|
Map<String,Object> map = UserInfoUtils.getInstance().currentPath();
|
String ip = map.get("ip").toString();
|
String path = map.get("path").toString();
|
System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"___"+ip+"---"+path);
|
if(methodName.contains("add")||methodName.contains("Add")||methodName.contains("update")||methodName.contains("Update")
|
||methodName.contains("delete")||methodName.contains("insert")
|
||methodName.contains("Insert")){
|
System.out.println("拦截到需要日志"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
|
SysLogVo sysLogVo = new SysLogVo();
|
sysLogVo.setLogIp(ip);
|
sysLogVo.setLoginUser(userInfo.getUserId());
|
sysLogVo.setLogUrl(path);
|
sysLogVo.setOpTime(new Date());
|
sysLogVo.setOpType(getOpType(methodName));
|
sysLogVo.setModuleName(moduleName);
|
Object obj = invocation.proceed();
|
|
Message<String> message = MessageBuilder.withPayload(JSONObject.toJSONString(sysLogVo)).build();
|
rocketMQTemplate.send(topic,message);
|
return obj;
|
}
|
return invocation.proceed();
|
}
|
|
public String getOpType(String methodName){
|
if(methodName.contains("add")||methodName.contains("Add")||methodName.contains("insert")||methodName.contains("Insert")){
|
return LogTypeEnums.add.getValue();
|
}else if(methodName.contains("update")||methodName.contains("Update")){
|
return LogTypeEnums.update.getValue();
|
}else if(methodName.contains("delete")){
|
return LogTypeEnums.delete.getValue();
|
}
|
return "";
|
}
|
}
|
