package com.vci.web.other;
|
|
import com.vci.model.BdSelectInputCharDO;
|
import com.vci.starter.web.annotation.BdSelectInput;
|
import com.vci.web.dao.BdSelectInputCharDaoI;
|
import com.vci.web.util.WebUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.aspectj.lang.JoinPoint;
|
import org.aspectj.lang.annotation.AfterReturning;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.annotation.Pointcut;
|
import org.aspectj.lang.reflect.MethodSignature;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.core.DefaultParameterNameDiscoverer;
|
import org.springframework.core.ParameterNameDiscoverer;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.lang.reflect.Method;
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
/**
|
* 可以输入也可以选择的切面程序
|
* @author weidy
|
* @date 2022-3-16
|
*/
|
@Aspect
|
@Component
|
public class BdSelectInputCharAspect {
|
|
/**
|
* 当前类的日志输出
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 数据操作类
|
*/
|
@Resource
|
private BdSelectInputCharDaoI selectInputCharDao;
|
|
/**
|
* 所有的BdSelectInput注解的
|
*/
|
@Pointcut("execution(public * com.vci..*.*(..)) && @target(com.vci.starter.web.annotation.BdSelectInput) ")
|
public void selectInputChar(){
|
|
}
|
|
/**
|
* 执行完成后记录
|
* @param joinPoint 切入点
|
*/
|
@AfterReturning(pointcut = "selectInputChar()",returning = "returnVal")
|
public void saveChar(JoinPoint joinPoint,Object returnVal){
|
try {
|
Method method = getMethod(joinPoint);
|
//获取方法上的参数
|
BdSelectInput selectInput = method.getAnnotation(BdSelectInput.class);
|
if (selectInput == null) {
|
method.getDeclaredAnnotation(BdSelectInput.class);
|
}
|
if (selectInput != null) {
|
String fieldString = selectInput.value();
|
ParameterNameDiscoverer pnd = new DefaultParameterNameDiscoverer();
|
String[] parameterNames = pnd.getParameterNames(method);
|
Object[] args = joinPoint.getArgs();
|
//从参数里面找到对应的值
|
String value = getValueFromParam(fieldString, parameterNames, args);
|
String flag = selectInput.flag();
|
String namespace = selectInput.namespace();
|
if (flag == null) {
|
flag = "default";
|
}
|
if (namespace == null) {
|
namespace = "default";
|
}
|
if (StringUtils.isNotBlank(value)) {
|
BdSelectInputCharDO sic = new BdSelectInputCharDO();
|
sic.setSourceNameSpace(namespace);
|
sic.setSourceInputFlag(flag);
|
sic.setId(value);
|
if (logger.isInfoEnabled()) {
|
logger.info("本次保存的字符内容,{0}", sic.toString());
|
}
|
selectInputCharDao.insert(sic);
|
}
|
}
|
}catch (Throwable e){
|
logger.error("切面记录可选字符的时候出错",e);
|
}
|
}
|
|
/**
|
* 多个分隔符
|
*/
|
public static final String SEP = "${SEP}";
|
|
/**
|
* 从参数里获取值
|
* @param fieldString 字段的表达式
|
* @param parameterNames 参数的名字
|
* @param args 参数的对象
|
* @return 记录的值
|
*/
|
private String getValueFromParam(String fieldString, String[] parameterNames, Object[] args) {
|
String value = "";
|
String[] split = fieldString.split(".");
|
if(split.length>0) {
|
String paramName = split[0];
|
for (int i = 0; i < parameterNames.length; i++) {
|
if (paramName.equalsIgnoreCase(parameterNames[i])) {
|
Object param = args[i];
|
//在看看里面的内容
|
if (split.length == 1) {
|
//只有一个，那就是这个参数了
|
if(param!=null){
|
value = param.toString();
|
}
|
}else{
|
//第二层
|
Object fieldValue = WebUtil.getValueFromField(split[1],param);
|
if(fieldValue instanceof Collection){
|
List<String> values = new ArrayList<>();
|
((Collection)fieldValue).stream().forEach(fv ->{
|
if (split.length > 2) {
|
//说明还要往下找
|
Object fromField = WebUtil.getValueFromField(split[2], fv);
|
values.add(WebUtil.getStringValueFromObject(fromField));
|
} else {
|
values.add(WebUtil.getStringValueFromObject(fv));
|
}
|
});
|
value = values.stream().collect(Collectors.joining(SEP));
|
}else if(fieldValue instanceof Map){
|
List<String> values = new ArrayList<>();
|
((Map)fieldValue).values().stream().forEach(fv ->{
|
if (split.length > 2) {
|
//说明还要往下找
|
Object fromField = WebUtil.getValueFromField(split[2], fv);
|
values.add(WebUtil.getStringValueFromObject(fromField));
|
} else {
|
values.add(WebUtil.getStringValueFromObject(fv));
|
}
|
});
|
value = values.stream().collect(Collectors.joining(SEP));
|
}else {
|
if (split.length > 2) {
|
//说明还要往下找
|
fieldValue = WebUtil.getValueFromField(split[2], fieldValue);
|
value = WebUtil.getStringValueFromObject(fieldValue);
|
} else {
|
value = WebUtil.getStringValueFromObject(fieldValue);
|
}
|
}
|
}
|
break;
|
}
|
}
|
}
|
return value;
|
}
|
|
|
/**
|
* 获取被调用的方法
|
* @param joinPoint 切入点
|
* @return 调用的方法
|
*/
|
public Method getMethod(JoinPoint joinPoint){
|
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
|
Method method = signature.getMethod();
|
return method;
|
}
|
}
|
