Browse Source

update rocketmq consumer

deason 1 month ago
parent
commit
bc2cdd4ad3

+ 24 - 8
examcloud-support/src/main/java/cn/com/qmth/examcloud/reports/commons/enums/Tag.java

@@ -5,46 +5,58 @@ public enum Tag {
     /**
      * 学生
      */
-    ONLINE_STUDENT("ONLINE_STUDENT", "学生"),
+    ONLINE_STUDENT("ONLINE_STUDENT", "examcloud_consumer_online_student", "学生"),
 
     /**
      * 考生
      */
-    ONLINE_EXAM_STUDENT("ONLINE_EXAM_STUDENT", "考生"),
+    ONLINE_EXAM_STUDENT("ONLINE_EXAM_STUDENT", "examcloud_consumer_online_exam_student", "考生"),
 
     /**
      * 后台用户
      */
-    ONLINE_USER("ONLINE_USER", "后台用户"),
+    ONLINE_USER("ONLINE_USER", "examcloud_consumer_online_user", "后台用户"),
 
     /**
      * 操作日志
      */
-    OPERATE_INFO("OPERATE_INFO", "操作日志"),
+    OPERATE_INFO("OPERATE_INFO", "examcloud_consumer_operate_info", "操作日志"),
 
     /**
      * 考试过程记录
      */
-    EXAM_PROCESS_RECORD("EXAM_PROCESS_RECORD", "考试过程记录"),
+    EXAM_PROCESS_RECORD("EXAM_PROCESS_RECORD", "examcloud_consumer_exam_process_record", "考试过程记录"),
 
     /**
      * 后台用户操作日志
      */
-    ADMIN_OPERATE_INFO("ADMIN_OPERATE_INFO", "后台用户操作日志");
+    ADMIN_OPERATE_INFO("ADMIN_OPERATE_INFO", "examcloud_consumer_admin_operate_info", "后台用户操作日志");
+
+    // ===========================================================================
 
     /**
      * 码
      */
     private String code;
 
+    /**
+     * 描述
+     */
+    private String group;
+
     /**
      * 描述
      */
     private String desc;
 
-    Tag(String code, String desc) {
+    /**
+     * 构造函数
+     *
+     * @param desc
+     */
+    private Tag(String code, String group, String desc) {
         this.code = code;
-
+        this.group = group;
         this.desc = desc;
     }
 
@@ -56,4 +68,8 @@ public enum Tag {
         return code;
     }
 
+    public String getGroup() {
+        return group;
+    }
+
 }

+ 5 - 0
examcloud-support/src/main/java/cn/com/qmth/examcloud/reports/commons/util/ReportsUtil.java

@@ -113,6 +113,7 @@ public class ReportsUtil {
         } catch (Exception e) {
             LOG.debug("获取本机IP出错", e);
         }
+
         report.setReportHost(ip);
         report.setRemoteHost(IpUtil.getRemoteIp(ServletUtil.getRequest()));
         report.setReportTime(new Date());
@@ -126,4 +127,8 @@ public class ReportsUtil {
         return topic;
     }
 
+    public static String getProfile() {
+        return PropertyHolder.getString("spring.profiles.active", "");
+    }
+
 }