如何在Spring crud存储库方法上实现方面

Question

我正在做一个项目，我们有很多实体，我们将在这些实体上进行CRUD操作。我创建了一个基本实体类，在所有其他实体中，我扩展了基本实体类，该类具有诸如created\u date、created\u by、last\u updated\u date、last\u updated\u by等公共字段。现在，我想在Spring CrudRepository方法上实现aspect，并在保存时设置上述字段。

我尝试过实现类似的东西，但没有成功。

package com.cerium.aop;

import java.util.Date;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import com.cerium.datamodel.AccountDataModel;
import com.cerium.domain.Account;
import com.cerium.domain.BaseEntity;
import com.cerium.util.Constants;

/**
 * @author Manikanta B Cerium
 *
 */
@Component
@Aspect
public class SampleAspect {

    private static final Logger LOG = LoggerFactory.getLogger(SampleAspect.class);

    @Around("execution(* com.cerium.repository.*.save (com.cerium.domain.BaseEntity)) && args(saveData)")
    public Object beforeSave(ProceedingJoinPoint proceedingJoinPoint, Object saveData) throws Throwable {

        LOG.debug("Into aspect before save: {}", saveData);

        BaseEntity baseEntity = (BaseEntity) proceedingJoinPoint.proceed(new Object[] { saveData });

        // set the fields here......
        baseEntity.setCreatedDate(new Date());

        System.out.println(saveData);

        return baseEntity;

    }
}

Answer 1

要使用方面，我们应该首先使用过滤器表达式定义一个切入点方法（在您的情况下是“保存”方法），然后创建一个方法来处理此切入点：

@Component
@Aspect
public class CommonSaveAspect {

    @Pointcut("execution(* com.cerium.repository.*.save(..))")
    public void commonSave() {
    }

    @Around("commonSave()")
    public Object addCommonData(final ProceedingJoinPoint pjp) throws Throwable {

        Object[] args = pjp.getArgs();

        if (Iterable.class.isAssignableFrom(args[0].getClass())) {
            //noinspection unchecked
            Iterable<BaseEntity> entities = (Iterable<BaseEntity>) args[0];
            entities.forEach(entity -> {
                // set the fields here...
            });
        }

        if (args[0] instanceof BaseEntity) {
            BaseEntity entity = (BaseEntity) args[0];
            // set the fields here...
        }

        return pjp.proceed(args); 
    }
}

更多信息