package com.xxx.mall.order.service.component;?
import java.lang.annotation.*;
?
/**
?* 庫存不足等信息監(jiān)控
?* Created by xdc on 2019/4/16 15:43
?*/
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public @interface StockWarnCollect {
?
? ? /** 客戶id */
? ? String customerId();
?
? ? /** 來源 */
? ? String source();
?
? ? /** 請求類型 1:詳情頁 2:購物車去結算 3:提交訂單 */
? ? String pageType();
}

@Override
@StockWarnCollect(customerId = "#customerId", source = "#source", pageType = "2")
public Map<String, Object> validateCarts(Long customerId, Set<Long> userSelectedIds, Short source, JSONArray couponInfo){
? ? // 省略
}

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.exception.ExceptionUtils;
import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.core.LocalVariableTableParameterNameDiscoverer;
import org.springframework.expression.EvaluationContext;
import org.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.stereotype.Component; 
import java.lang.reflect.Method;
 
/**
 * 下單失敗、庫存監(jiān)控
 * Created by xdc on 2019/4/16 15:45
 */
@Aspect
@Component
@Slf4j
public class StockWarnCollectAop { 
    @Pointcut(value = "@annotation(com.xxx.mall.order.service.component.StockWarnCollect)")
    public void collectStockWarn(){}
 
    @Around(value = "collectStockWarn()")
    public Object around(ProceedingJoinPoint pjp) throws Throwable {
 
        Method targetMethod = this.getTargetMethod(pjp);
        StockWarnCollect stockWarnCollect = targetMethod.getAnnotation(StockWarnCollect.class);
 
        // spel信息
        String customerIdSpel = stockWarnCollect.customerId();
        String sourceSpel = stockWarnCollect.source();
        Integer pageType = null;  // 操作類型，純字符串
        if (StringUtils.isNotBlank(stockWarnCollect.pageType())) {
            pageType = Integer.valueOf(stockWarnCollect.pageType());
        }
 
        // 客戶id、來源解析
        ExpressionParser parser = new SpelExpressionParser();
        LocalVariableTableParameterNameDiscoverer discoverer = new LocalVariableTableParameterNameDiscoverer();
        String[] params = discoverer.getParameterNames(targetMethod); 
        Object[] args = pjp.getArgs();
 
        EvaluationContext context = new StandardEvaluationContext();
        for (int len = 0; len < params.length; len++) {
            context.setVariable(params[len], args[len]);
        }
        Expression expression = parser.parseExpression(customerIdSpel);
        Long customerId = expression.getValue(context, Long.class);
 
        expression = parser.parseExpression(sourceSpel);
        Short source = expression.getValue(context, Short.class);
        log.info("collectStockWarn customerId:{}, source:{}", customerId, source);
 
        // 業(yè)務邏輯處理
        Object result = null;
        try {
            result = pjp.proceed();
        } catch (Throwable e) {
            log.info("collectStockWarn watchs creating order errorMsg:{}", ExceptionUtils.getStackTrace(e));
            if (e instanceof MallException) {
 
            } else {    // 未知錯誤
            
            } 
            throw e;
        } 
        try {
            if (result != null) {            
            }
        } catch (Exception e) {
            log.error("collectStockWarn process error, errorMsg:{}", ExceptionUtils.getStackTrace(e));
        } 
        return result; 
    } 
    /**
     * 獲取目標方法
     */
    private Method getTargetMethod(ProceedingJoinPoint pjp) throws NoSuchMethodException {
        Signature signature = pjp.getSignature();
        MethodSignature methodSignature = (MethodSignature)signature;
        Method agentMethod = methodSignature.getMethod();
        return pjp.getTarget().getClass().getMethod(agentMethod.getName(),agentMethod.getParameterTypes());
    }
}

? ? //@Value能修飾成員變量和方法形參
? ? //#{}內(nèi)就是表達式的內(nèi)容
? ? @Value("#{表達式}")
? ? public String arg;

<bean id="xxx" class="com.java.XXXXX.xx">
? ? <!-- 同@Value,#{}內(nèi)是表達式的值，可放在property或constructor-arg內(nèi) -->
? ? <property name="arg" value="#{表達式}">
</bean>

public class SpELTest {?
? ? public static void main(String[] args) {
?
? ? ? ? //創(chuàng)建ExpressionParser解析表達式
? ? ? ? ExpressionParser parser = new SpelExpressionParser();
? ? ? ? //表達式放置
? ? ? ? Expression exp = parser.parseExpression("表達式");
? ? ? ? //執(zhí)行表達式，默認容器是spring本身的容器：ApplicationContext
? ? ? ? Object value = exp.getValue();
? ? ? ??
? ? ? ? /**如果使用其他的容器，則用下面的方法*/
? ? ? ? //創(chuàng)建一個虛擬的容器EvaluationContext
? ? ? ? StandardEvaluationContext ctx = new StandardEvaluationContext();
? ? ? ? //向容器內(nèi)添加bean
? ? ? ? BeanA beanA = new BeanA();
? ? ? ? ctx.setVariable("bean_id", beanA);
? ? ? ??
? ? ? ? //setRootObject并非必須；一個EvaluationContext只能有一個RootObject，引用它的屬性時，可以不加前綴
? ? ? ? ctx.setRootObject(XXX);
? ? ? ??
? ? ? ? //getValue有參數(shù)ctx，從新的容器中根據(jù)SpEL表達式獲取所需的值
? ? ? ? Object value = exp.getValue(ctx);
? ? }
}

// 如果屬性文件沒有spelDefault.value，則會報錯
? ? // ?@Value("${spelDefault.value}")
? ? // ?private String spelDefault2;
?
? ? // 使用default.value設置值，如果不存在則使用默認值
? ? @Value("${spelDefault.value:127.0.0.1}")
? ? private String spelDefault;

? ? // SpEL：調(diào)用字符串Hello World的concat方法
? ? @Value("#{'Hello World'.concat('!')}")
? ? private String helloWorld;
?
? ? // SpEL: 調(diào)用字符串的getBytes方法，然后調(diào)用length屬性
? ? @Value("#{'Hello World'.bytes.length}")
? ? private String helloWorldbytes;

// SpEL: 傳入一個字符串，根據(jù)","切分后插入列表中， #{}和${}配置使用(注意單引號，注意不能反過來${}在外面，#{}在里面)
? ? @Value("#{'${server.name}'.split(',')}")
? ? private List<String> servers;

// SpEL: 注意不能反過來${}在外面，#{}在里面，這個會執(zhí)行失敗
? ? @Value("${#{'HelloWorld'.concat('_')}}")
? ? private List<String> servers2;