message

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());

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;
+
     /**
      * 操作时间
      */