【操作日志】如何在一个SpringBoot+Mybatis的项目中设计一个自定义ChangeLo ...

　　设计一个业务改动信息时的自定义记录，例如新增、修改、删除数据等。并且记录的规则可以通过配置的方式控制。大家需要根据各自业务场景参考，欢迎讨论。伪代码如下：
实体类：

1. @TableName("tbl_user")
2. User{
3.     String id
4.     String name
5.     Integer age
6.     String addr
7. }

复制代码

 


DAO层：

1. UserDao{
2.     getById(Long id);
3.     list(Wrapper wrapper);
4. }

复制代码

 
 
自定义注解：

1. MybatisPropAnno{
3. 　　String value
5. 　　Class<?> daoClazz
7. }

复制代码

 


Http接口请求参数：

1. SaveReq{
2.     @MybatisPropAnno(value="name", daoClazz = UserDao.class)
3.     String userName;
4.     @MybatisPropAnno(value="age", daoClazz = UserDao.class)
5.     Integer userAge;
6. }
8. UpdateReq{
9.     @MybatisPropAnno(value="id", daoClazz = UserDao.class)
10.     String userNo;
11.     @MybatisPropAnno(value="name", daoClazz = UserDao.class)
12.     String userName;
13.     @MybatisPropAnno(value="age", daoClazz = UserDao.class)
14.     Integer userAge;
16.     @MybatisPropAnno(value="id", daoClazz = DepartDao.class)
17.     String departId;
18.     String departAddress;
19. }

复制代码

 


Http接口：

1. TestController{
2.     public void save(SaveReq saveReq){
3.         operTypeInheritedThreadLocal.set(Enum."添加数据");
4.         sthInheritedThreadLocal.set(saveReq);
5.     };
7.     public void update(UpdateReq updateReq){
8.         operTypeInheritedThreadLocal.set(Enum."更新数据");
9.         sthInheritedThreadLocal.set(updateReq);
10.     };
12.     @MybatisLogAnno("删除数据")
13.     public void delete(){};
15.     @MybatisLogAnno("查询数据")
16.     public void query(){};
18.     public void other(){};
19. }

复制代码

 


SQL拦截器：

1. SqlInterceptor{
2.     public Object intercept(Mybatis param){   
3.         OperType operType = operTypeInheritedThreadLocal.get
4.         if(operType == null）{
5.             return ;
6.         }
7.         
8.         // insert/update/delete/select
9.         String type = param.getSqlType();
10.         if(operType == select）{
11.             return ;
12.         }
13.         
14.         String sql = param.getSql();
15.         
16.         String tableName = sql.getTableName();
18.         List<Field> fields = Reflect.getFields(sthInheritedThreadLocal.get());
20.         for(Field field : fields){
21.             MybatisPropAnno propAnno = field.getAnnotation(MybatisPropAnno);
22.             if(propAnno  == null){
23.                 continue;
24.             }
25.             if(propAnno.getDaoClazz.getEntity.getTableName.equals(tableName )){
26.                 User oldUser = new JSONObject();
27.                 User newUser = new JSONObject();
28.                 if(type == insert){
29.                     oldUser = new JSONObject();
30.                     newUser = getInsertInfo(sql);
31.                 }
33.                 if(type == update){
34.                     oldUser = SpringContext.get(daoClazz).getById(field.value());
35.                     newUser = getUpdateInfo(sql);
36.                     insertChangeLog(new JSONObject(), JSON.toJson(newUser));
37.                 }
38.                 if(type == delete){
39.                     oldUser = SpringContext.get(daoClazz).getById(field.value());
40.                     newUser = new JSONObject();
41.                 }
43.                 insertChangeLog(operType, traceId, oldUser, newUser);
44.                 break;
45.             }
46.         }
47.     }
48. }

复制代码

 


Spring切面：

1. SpringAop {
2.     public Object doAround(){
3.         operTypeInheritedThreadLocal.remove
4.     }
5. }

复制代码

 


数据库设计：
Table：dc_change_log
id    changeTime    changeType    traceId    oldInfo        newInfo        httpMethod        table        operator    changeDesc
1    2020-01-01    添加用户        123    {}        {"name":"lil"}    com.xx.TestCtrl.saveUser    tbl_user        admin    descxxxxxxxxxxxx
2    2020-01-01    修改用户        124    {"name":"lil"}    {"name":"a"}    com.xx.TestCtrl.updateUser    tbl_user        admin    descxxxxxxxxxxxx
3    2020-01-01    修改用户        124    {"addr":"南山"}    {"addr":"福田"}    com.xx.TestCtrl.updateUser    tbl_department    admin    descxxxxxxxxxxxx

Table：dc_change_rule
id    httpMethod        table        showRule
1    com.xx.TestCtrl.saveUser    tbl_user        [{"propKey":"name", "propDesc":"name detail info"}]
1    com.xx.TestCtrl.updateUser    tbl_user        [{"propKey":"name", "propDesc":"name detail info"}]
1    com.xx.TestCtrl.updateUser    tbl_department    [{"propKey":"addr", "propDesc":"addr detail info"}]

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！