From 78e81a9f56a2e2f7962be11343c533eaaf3f2201 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Mon, 17 Oct 2022 15:36:43 +0800
Subject: [PATCH] message

---
 .../listener/CheckAndExportOperationLogListener.java        | 6 +++---
 .../com/epmet/commons/rocketmq/messages/CheckMQMsg.java     | 3 +++
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java b/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
index 1d86c65b8d..b11751f3eb 100644
--- a/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
+++ b/epmet-admin/epmet-admin-server/src/main/java/com/epmet/mq/listener/listener/CheckAndExportOperationLogListener.java
@@ -63,9 +63,9 @@ public class CheckAndExportOperationLogListener implements MessageListenerConcur
         //获取操作人信息
         OperatorInfo operatorInfo = LogOperationHelper.getInstance().getOperatorInfo(msgObj.getUserId());
         LogOperationEntity logEntity = new LogOperationEntity();
-        logEntity.setCategory(messageExt.getTopic());
-        logEntity.setType(tags);
-        logEntity.setTypeDisplay(AuthOperationEnum.getDisplay(tags));
+        logEntity.setCategory("data_tm");
+        logEntity.setType(msgObj.getType());
+        logEntity.setTypeDisplay(msgObj.getTypeDisplay());
         logEntity.setIp(msgObj.getIp());
         logEntity.setFromApp(msgObj.getFromApp());
         logEntity.setFromClient(msgObj.getFromClient());
diff --git a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
index 0a9f02b692..462133adfe 100644
--- a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
+++ b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/CheckMQMsg.java
@@ -14,6 +14,9 @@ public class CheckMQMsg {
 
     private String content;
 
+    private String typeDisplay;
+    private String type;
+
     /**
      * 操作时间
      */