【操作日志】如何在一个SpringBoot+Mybatis的项目中设计一个自定义ChangeLog记录？

@TableName("tbl_user")
User{
    String id
    String name
    Integer age
    String addr
}

UserDao{
    getById(Long id);
    list(Wrapper wrapper);
}

MybatisPropAnno{

　　String value

　　Class<?> daoClazz

}

SaveReq{
    @MybatisPropAnno(value="name", daoClazz = UserDao.class)
    String userName;
    @MybatisPropAnno(value="age", daoClazz = UserDao.class)
    Integer userAge;
}

UpdateReq{
    @MybatisPropAnno(value="id", daoClazz = UserDao.class)
    String userNo;
    @MybatisPropAnno(value="name", daoClazz = UserDao.class)
    String userName;
    @MybatisPropAnno(value="age", daoClazz = UserDao.class)
    Integer userAge;

    @MybatisPropAnno(value="id", daoClazz = DepartDao.class)
    String departId;
    String departAddress;
}

TestController{
    public void save(SaveReq saveReq){
        operTypeInheritedThreadLocal.set(Enum."添加数据");
        sthInheritedThreadLocal.set(saveReq);
    };

    public void update(UpdateReq updateReq){
        operTypeInheritedThreadLocal.set(Enum."更新数据");
        sthInheritedThreadLocal.set(updateReq);
    };

    @MybatisLogAnno("删除数据")
    public void delete(){};

    @MybatisLogAnno("查询数据")
    public void query(){};

    public void other(){};
}

SqlInterceptor{
    public Object intercept(Mybatis param){    
        OperType operType = operTypeInheritedThreadLocal.get
        if(operType == null）{
            return ;
        }
        
        // insert/update/delete/select
        String type = param.getSqlType();
        if(operType == select）{
            return ;
        }
        
        String sql = param.getSql();
        
        String tableName = sql.getTableName();

        List<Field> fields = Reflect.getFields(sthInheritedThreadLocal.get());

        for(Field field : fields){
            MybatisPropAnno propAnno = field.getAnnotation(MybatisPropAnno);
            if(propAnno  == null){
                continue;
            }
            if(propAnno.getDaoClazz.getEntity.getTableName.equals(tableName )){
                User oldUser = new JSONObject();
                User newUser = new JSONObject();
                if(type == insert){
                    oldUser = new JSONObject();
                    newUser = getInsertInfo(sql);
                }

                if(type == update){
                    oldUser = SpringContext.get(daoClazz).getById(field.value());
                    newUser = getUpdateInfo(sql);
                    insertChangeLog(new JSONObject(), JSON.toJson(newUser));
                }
                if(type == delete){
                    oldUser = SpringContext.get(daoClazz).getById(field.value());
                    newUser = new JSONObject();
                }

                insertChangeLog(operType, traceId, oldUser, newUser);
                break;
            }
        }
    }
}

SpringAop {
    public Object doAround(){
        operTypeInheritedThreadLocal.remove
    }
}