Jpa 如何使用@EntityListeners 实现实体对象的自动赋值

-- 用户表

create table `acc_user` (

   `id` bigint(20) not null auto_increment,

   `username` varchar(40) not null default '' comment '用户名' ,

   `password` varchar(40) not null default '' comment '密码' ,

   `create_by` varchar(80) default null,

   `create_time` datetime default current_timestamp,

   `update_by` varchar(80) default null,

   `update_time` datetime default current_timestamp on update current_timestamp,

   primary key (`id`)

) engine=innodb default charset=utf8mb4;

-- 日志表

create table `modify_log` (

   `id` bigint(20) not null auto_increment,

   `action` varchar(20) not null default '' comment '操作' ,

   `entity_name` varchar(40) not null default '' comment '实体类名' ,

   `entity_key` varchar(20) default null comment '主键值' ,

   `entity_value` varchar(400) default null comment '实体值' ,

   `create_by` varchar(80) default null,

   `create_time` datetime default current_timestamp,

   primary key (`id`)

) engine=innodb default charset=utf8mb4;

@mappedsuperclass

@getter @setter

@mappedsuperclass

// 指定对应监听类

@entitylisteners(createlistener. class )

public abstract class idmapped {

     @id

     @generatedvalue(strategy = generationtype.identity)

     private long id;

     private string createby;

     private date createtime;

}

@getter @setter

@mappedsuperclass

// 指定对应监听类

@entitylisteners(editlistener. class )

public abstract class editmapped extends idmapped{

     private string updateby;

     private date updatetime;

}

@entity

@table(name = "acc_user" )

@getter @setter

public class userentity extends editmapped {

     private string username;

     private string password;

}

@entity

@table(name = "modify_log" )

@getter @setter

public class modifylogentity extends idmapped{

     private string  action;

     private string  entityname;

     private string  entitykey;

     private string  entityvalue;

}

public class createlistener extends basiclistener {

     // 保存之前，为创建时间和创建人赋值

     @prepersist

     public void prepersist(idmapped idmapped) {

         if (objects.isnull(idmapped.getcreatetime())) {

             idmapped.setcreatetime( new date());

         }

         if (stringutils.isblank(idmapped.getcreateby())) {

             // 根据鉴权系统实现获取当前操作用户，此处只做模拟

             idmapped.setcreateby( "test_create" );

         }

     }

     // 保存之后，记录变更日志

     @postpersist

     public void postpersist(idmapped idmapped) throws jsonprocessingexception {

         recordlog(action_insert, idmapped);

     }

}

public class editlistener extends basiclistener {

     // 修改之前，为修改人和修改时间赋值

     @preupdate

     public void preupdate(editmapped editmapped) {

         if (objects.isnull(editmapped.getupdatetime())) {

             editmapped.setcreatetime( new date());

         }

         if (stringutils.isblank(editmapped.getupdateby())) {

             // 根据鉴权系统实现获取当前操作用户，此处只做模拟

             editmapped.setupdateby( "test_update" );

         }

     }

     // 修改之后，记录变更日志

     @postupdate

     public void postupdate(editmapped editmapped) throws jsonprocessingexception {

         recordlog(action_update, editmapped);

     }

     // 删除之前，记录变更日志

     @preremove

     public void preremove(editmapped editmapped) throws jsonprocessingexception {

         recordlog(action_delete, editmapped);

     }

}

public class basiclistener implements applicationcontextaware {

     private applicationcontext applicationcontext;

     protected static final string action_insert = "insert" ;

     protected static final string action_update = "update" ;

     protected static final string action_delete = "delete" ;

     // 记录变更日志

     protected void recordlog(string action, idmapped object) throws jsonprocessingexception {

         // 日志对象不需要再记录变更日志

         if (object instanceof modifylogentity) {

             return ;

         }

         modifylogentity modifylogentity = new modifylogentity();

         modifylogentity.setaction(action);

         modifylogentity.setentitykey(string.valueof(object.getid()));

         modifylogentity.setentityname(object.getclass().getsimplename());

         // 对象转json字符串存储

         modifylogentity.setentityvalue( new objectmapper().writevalueasstring(object));

         optional.ofnullable(applicationcontext.getbean(modifylogdao. class ))

                 .ifpresent(modifylogdao -> modifylogdao.save(modifylogentity));

     }

     @override

     public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception {

         this .applicationcontext = applicationcontext;

     }

}

@repository

public interface userdao extends jparepository<userentity, long > {

}

@repository

public interface modifylogdao extends jparepository<modifylogentity, long > {

}

@service

public class userserviceimpl implements userservice {

     @autowired

     private userdao userdao;

     @override

     @transactional

     public void add(string username, string password) {

         userentity userentity = new userentity();

         userentity.setusername(username);

         userentity.setpassword(password);

         userdao.save(userentity);

     }

     @override

     @transactional

     public void update( long id, string password) {

         userentity userentity = userdao.findbyid(id).orelsethrow(() -> new runtimeexception( "用户不存在" ));

         userentity.setpassword(password);

         userdao.save(userentity);

     }

     @override

     @transactional

     public void delete ( long id) {

         userentity userentity = userdao.findbyid(id).orelsethrow(() -> new runtimeexception( "用户不存在" ));

         userdao. delete (userentity);

     }

}

@springboottest

public class schoolapplicationtests {

     @autowired

     private userservice userservice;

     @test

     public void testadd() {

         userservice.add( "test1" , "123456" );

     }   

}

@test

public void testupdate() {

     userservice.update(1l, "654321" );

}

@test

public void testremove() {

     userservice. delete (1l);

}