(rocketmq-dashboard) branch rocketmq-studio updated: fix(audit): persist resource type, cluster id and error message (#1152)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimins pushed a commit to branch rocketmq-studio
in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git


The following commit(s) were added to refs/heads/rocketmq-studio by this push:
     new adb13fc4 fix(audit): persist resource type, cluster id and error 
message (#1152)
adb13fc4 is described below

commit adb13fc4ca8ee86c8dce94596dfa32b3f23473da
Author: 0 <1939455...@qq.com>
AuthorDate: Fri Aug 7 16:11:47 2026 +0800

    fix(audit): persist resource type, cluster id and error message (#1152)
---
 .../apache/rocketmq/studio/ops/audit/MybatisPlusAuditRepository.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/rocketmq/studio/ops/audit/MybatisPlusAuditRepository.java
 
b/server/src/main/java/org/apache/rocketmq/studio/ops/audit/MybatisPlusAuditRepository.java
index acdb9015..e6f2dc35 100644
--- 
a/server/src/main/java/org/apache/rocketmq/studio/ops/audit/MybatisPlusAuditRepository.java
+++ 
b/server/src/main/java/org/apache/rocketmq/studio/ops/audit/MybatisPlusAuditRepository.java
@@ -62,10 +62,12 @@ public class MybatisPlusAuditRepository implements 
AuditRepository {
     public void save(AuditRecordVO record) {
         RmqOperationAudit entity = new RmqOperationAudit();
         entity.setOperation(record.getOperationType());
-        entity.setResourceType("GENERAL");
+        entity.setResourceType(record.getResourceType() == null ? "GENERAL" : 
record.getResourceType());
         entity.setResourceName(record.getTarget());
+        entity.setClusterId(record.getClusterId());
         entity.setDetail(record.getDetail());
         entity.setResult(record.getResult());
+        entity.setErrorMessage(record.getErrorMessage());
         entity.setOperator(record.getOperator());
         entity.setOperatedAt(record.getTimestamp() == null ? 
LocalDateTime.now() : record.getTimestamp());
         auditMapper.insert(entity);