栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

基于AOP 封装数据库通用字段

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

基于AOP 封装数据库通用字段

基于AOP 封装数据库通用字段 数据库通用字段表

如图所示 通用字段
  `create_user` bigint(64) DEFAULT NULL COMMENT '创建人',
  `create_dept` bigint(64) DEFAULT NULL COMMENT '创建部门',
  `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  `update_user` bigint(64) DEFAULT NULL COMMENT '修改人',
  `update_time` datetime DEFAULT NULL COMMENT '修改时间',
  `status` int(2) DEFAULT NULL COMMENT '状态',
  `is_deleted` int(2) DEFAULT '0' COMMENT '是否已删除',
对应java 实体


import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

@Data
public class basePojo  implements Serializable {
	private static final long serialVersionUID = 1L;
	
	private Long createDept;
	
	private Date createTime;
	
	private Long updateUser;
	
	private Date updateTime;

	private Long createUser;
}

业务实体集成通用实体

开始AOP配置

自定义注解

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface UserSaveOrUpdate {

	public static  final String INSERT = "insert";
	public static  final String UPDATE = "update";

	String value();
}

切面设置
import com.ch.event.bo.basePojo;
import org.aspectj.lang.ProceedingJoinPoint;
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.springblade.core.secure.utils.AuthUtil;
import org.springframework.stereotype.Component;

import java.lang.reflect.Method;
import java.util.Date;

@Aspect
@Component
public class UserSaveOrUpdateAspet {
	@Pointcut("@annotation(com.ch.event.aop.UserSaveOrUpdate)")
	public void methodPointcut() {
	}
	@Around(value= "methodPointcut()")
	public Object around(ProceedingJoinPoint point) throws Throwable{
		MethodSignature signature = (MethodSignature) point.getSignature();
		Method method = signature.getMethod(); //获取被拦截的方法
		UserSaveOrUpdate annotation = method.getAnnotation(UserSaveOrUpdate.class);//获取注解
		String value = annotation.value();//获取注解的值
		String deptId = AuthUtil.getDeptId();//token工具类 取出对应的 数据
		Long userId = AuthUtil.getUserId();
		Date date = new Date();
		if (value.equals(UserSaveOrUpdate.INSERT)){//判断注解的值 如果是新增那就 插多一点
			Object[] args = point.getArgs();//获取请求的参数
			for (Object arg : args) {
				if(arg instanceof basePojo){
					basePojo cmEvent = (basePojo)arg;
					cmEvent.setCreateUser(userId);
					cmEvent.setUpdateUser(userId);
					cmEvent.setCreateTime(date);
					cmEvent.setUpdateTime(date);
					cmEvent.setCreateDept(Long.valueOf(deptId));
				}
			}
		}
		return point.proceed();//放行
	}

}

controller使用

    @PostMapping("/save")
	@ApiOperationSupport(order = 4)
	@ApiOperation(value = "新增", notes = "传入cmEvent")
	@UserSaveOrUpdate(UserSaveOrUpdate.INSERT)
	public R save(@Valid @RequestBody CmEvent cmEvent) {
		System.out.println("cmEvent:"+ cmEvent.getCreateUser()+cmEvent.getCreateTime());
		return R.status(cmEventService.save(cmEvent));
	}
结果打印

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/271118.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号