public interface Interceptor {

 Object intercept(Invocation invocation) throws Throwable;

 default Object plugin(Object target) {
 return Plugin.wrap(target, this);
 }

 default void setProperties(Properties properties) {
 // NOP
 }

}

public class Invocation {

 private final Object target;
 private final Method method;
 private final Object[] args;

 public Invocation(Object target, Method method, Object[] args) {
 this.target = target;
 this.method = method;
 this.args = args;
 }

 public Object getTarget() {
 return target;
 }

 public Method getMethod() {
 return method;
 }

 public Object[] getArgs() {
 return args;
 }

 public Object proceed() throws InvocationTargetException, IllegalAccessException {
 return method.invoke(target, args);
 }

}

@Intercepts(@Signature(type = ResultSetHandler.class,
  method = "handleResultSets",
  args = {Statement.class})

/**
 * 具體策略的函數(shù)
 * @author felord.cn
 * @since 11:24
 **/
public interface Desensitizer extends Function<String,String> {

}

/**
 * 脫敏策略.
 *
 * @author felord.cn
 * @since 11 :25
 */
public enum SensitiveStrategy {
 /**
  * Username sensitive strategy.
  */
 USERNAME(s -> s.replaceAll("(\\S)\\S(\\S*)", "$1*$2")),
 /**
  * Id card sensitive type.
  */
 ID_CARD(s -> s.replaceAll("(\\d{4})\\d{10}(\\w{4})", "$1****$2")),
 /**
  * Phone sensitive type.
  */
 PHONE(s -> s.replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2")),

 /**
  * Address sensitive type.
  */
 ADDRESS(s -> s.replaceAll("(\\S{8})\\S{4}(\\S*)\\S{4}", "$1****$2****"));


 private final Desensitizer desensitizer;

 SensitiveStrategy(Desensitizer desensitizer) {
  this.desensitizer = desensitizer;
 }

 /**
  * Gets desensitizer.
  *
  * @return the desensitizer
  */
 public Desensitizer getDesensitizer() {
  return desensitizer;
 }
}

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
public @interface Sensitive {
 SensitiveStrategy strategy();
}

@Data
public class UserInfo {

 private static final long serialVersionUID = -8938650956516110149L;
 private Long userId;
 @Sensitive(strategy = SensitiveStrategy.USERNAME)
 private String name;
 private Integer age;
}

@Slf4j
@Intercepts(@Signature(type = ResultSetHandler.class,
  method = "handleResultSets",
  args = {Statement.class}))
public class SensitivePlugin implements Interceptor {
 @SuppressWarnings("unchecked")
 @Override
 public Object intercept(Invocation invocation) throws Throwable {
  List<Object> records = (List<Object>) invocation.proceed();
  // 對(duì)結(jié)果集脫敏
  records.forEach(this::sensitive);
  return records;
 }


 private void sensitive(Object source) {
  // 拿到返回值類型
  Class<?> sourceClass = source.getClass();
  // 初始化返回值類型的 MetaObject
  MetaObject metaObject = SystemMetaObject.forObject(source);
  // 捕捉到屬性上的標(biāo)記注解 @Sensitive 并進(jìn)行對(duì)應(yīng)的脫敏處理
  Stream.of(sourceClass.getDeclaredFields())
    .filter(field -> field.isAnnotationPresent(Sensitive.class))
    .forEach(field -> doSensitive(metaObject, field));
 }


 private void doSensitive(MetaObject metaObject, Field field) {
  // 拿到屬性名
  String name = field.getName();
  // 獲取屬性值
  Object value = metaObject.getValue(name);
  // 只有字符串類型才能脫敏 而且不能為null
  if (String.class == metaObject.getGetterType(name) && value != null) {
   Sensitive annotation = field.getAnnotation(Sensitive.class);
   // 獲取對(duì)應(yīng)的脫敏策略 并進(jìn)行脫敏
   SensitiveStrategy type = annotation.strategy();
   Object o = type.getDesensitizer().apply((String) value);
   // 把脫敏后的值塞回去
   metaObject.setValue(name, o);
  }
 }
}

@Bean
public SensitivePlugin sensitivePlugin(){
 return new SensitivePlugin();
}