商业网站推广,骆驼网站建设,汕尾海丰建设规划局网站,做网站有哪些场景#xff1a;当处理一些请求时#xff0c;会重复的对数据库的某些字段进行赋值#xff08;如#xff1a;在插入和更新某个物品时#xff0c;需要更新该物品的更新时间和更新者的信息#xff09;#xff0c;这样会导致代码冗余。 如#xff1a; 思路#xff1a;
自…场景当处理一些请求时会重复的对数据库的某些字段进行赋值如在插入和更新某个物品时需要更新该物品的更新时间和更新者的信息这样会导致代码冗余。 如 思路
自定义注解 AutoFill用于标识需要进行公共字段自动填充的方法自定义切面类 AutoFillAspect统一拦截加入了 AutoFill 注解的方法通过反射为公共字段赋值在 Mapper 的方法上加入 AutoFill 注解
实现 定义AutoFill注解
package com.sky.annotation;import com.sky.enumeration.OperationType;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** ClassName: AufoFill* PackageName: com.sky.Annotation* Description: 用于表示某个方法需要进行功能字段自动填充处理** Author Xiyan Zhong* Create 2023/12/18 下午2:55* Version 1.0*/
Target({ElementType.METHOD})
Retention(RetentionPolicy.RUNTIME)
public interface AutoFill {// 数据库操作类型UPDATE INSERTOperationType value();
}
实现切面类
package com.sky.aspect;import com.sky.annotation.AutoFill;
import com.sky.constant.AutoFillConstant;
import com.sky.context.BaseContext;
import com.sky.enumeration.OperationType;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;import java.lang.reflect.Method;
import java.time.LocalDateTime;/*** ClassName: AutoFillAspect* PackageName: com.sky.Aspect* Description:自定义切面实现公共字段自动填充逻辑** Author Xiyan Zhong* Create 2023/12/18 下午3:00* Version 1.0*/Aspect
Component
Slf4j
public class AutoFillAspect {/*** 切入点*/Pointcut(execution(* com.sky.mapper.*.*(..)) annotation(com.sky.annotation.AutoFill))public void autoFillPointCut() {}/*** 前置通知在通知中进行公共字段的赋值*/Before(autoFillPointCut())public void autoFill(JoinPoint joinPoint) {log.info(开始进行公共字段自动填充……);// 获取被拦截的方法上的数据库操作类型MethodSignature signature (MethodSignature) joinPoint.getSignature(); // 方法签名对象AutoFill annotation signature.getMethod().getAnnotation(AutoFill.class);// 获取方法上的注解对象OperationType operationType annotation.value(); // 获取数据库操作类型// 获取到当前被拦截方法的参数——实体对象Object[] args joinPoint.getArgs();if (args null || args.length 0) {return;}Object entity args[0];// 准备赋值的数据LocalDateTime now LocalDateTime.now();Long currentId BaseContext.getCurrentId();// 根据当前不同的操作类型为对应的属性通过反射来赋值if (operationType OperationType.INSERT) {//try {Method setCreateTime entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_TIME, LocalDateTime.class);Method setCreateUser entity.getClass().getDeclaredMethod(AutoFillConstant.SET_CREATE_USER, Long.class);Method setUpdateTime entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME ,LocalDateTime.class);Method setUpdateUser entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);// 通过反射为对象属性赋值setCreateTime.invoke(entity,now);setCreateUser.invoke(entity,currentId);setUpdateTime.invoke(entity,now);setUpdateUser.invoke(entity,currentId);} catch (Exception e) {e.printStackTrace();}} else if (operationType OperationType.UPDATE) {try {// 为2个公共字段赋值Method setUpdateTime entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_TIME ,LocalDateTime.class);Method setUpdateUser entity.getClass().getDeclaredMethod(AutoFillConstant.SET_UPDATE_USER, Long.class);// 通过反射为对象属性赋值setUpdateTime.invoke(entity,now);setUpdateUser.invoke(entity,currentId);}catch (Exception e){e.printStackTrace();}}}
}
需要注意的是在反射中获取方法名时和判断拦截方法的类型时分别采用的是常量和枚举而不是直接使用方法的字符串名称这样可以降低编码时的错误率也更加规范对应的代码
package com.sky.constant;/*** 公共字段自动填充相关常量*/
public class AutoFillConstant {/*** 实体类中的方法名称*/public static final String SET_CREATE_TIME setCreateTime;public static final String SET_UPDATE_TIME setUpdateTime;public static final String SET_CREATE_USER setCreateUser;public static final String SET_UPDATE_USER setUpdateUser;
}
/*** 数据库操作类型*/
package com.sky.enumeration;/*** 数据库操作类型*/
public enum OperationType {/*** 更新操作*/UPDATE,/*** 插入操作*/INSERT}
在Mapper对应的方法中添加注解AutoFill /*** 插入数据* param category*/Insert(insert into category(type, name, sort, status, create_time, update_time, create_user, update_user) values (#{type}, #{name},#{sort},#{status},#{createTime},#{updateTime},#{createUser},#{updateUser}))AutoFill(OperationType.INSERT)void insert(Category category);/*** 根据id修改分类* param category*/AutoFill(OperationType.UPDATE)void update(Category category);
删除对应的服务实现类的赋值操作。
