update mq topic

examcloud-core-basic-service/src/main/java/cn/com/qmth/examcloud/core/basic/service/report/ExamProcessRecordReport.java

@@ -1,68 +0,0 @@
-package cn.com.qmth.examcloud.core.basic.service.report;
-
-import java.util.Date;
-
-import cn.com.qmth.examcloud.reports.commons.bean.BaseReport;
-import cn.com.qmth.examcloud.reports.commons.enums.Tag;
-import cn.com.qmth.examcloud.reports.commons.util.ReportsUtil;
-import cn.com.qmth.examcloud.support.enums.ExamProcess;
-
-/**
- * @Description 考试过程记录
- * @Author lideyin
- * @Date 2020/8/20 14:21
- * @Version 1.0
- */
-public class ExamProcessRecordReport extends BaseReport {
-
-    /**
-     * 考试记录ID
-     */
-    private Long examRecordDataId;
-
-    /**
-     * 考试过程
-     */
-    private ExamProcess examProcess;
-
-    /**
-     * 过程记录时间
-     */
-    private Date recordTime;
-
-    public Long getExamRecordDataId() {
-        return examRecordDataId;
-    }
-
-    public void setExamRecordDataId(Long examRecordDataId) {
-        this.examRecordDataId = examRecordDataId;
-    }
-
-    public ExamProcess getExamProcess() {
-        return examProcess;
-    }
-
-    public void setExamProcess(ExamProcess examProcess) {
-        this.examProcess = examProcess;
-    }
-
-    public Date getRecordTime() {
-        return recordTime;
-    }
-
-    public void setRecordTime(Date recordTime) {
-        this.recordTime = recordTime;
-    }
-
-    public ExamProcessRecordReport() {
-        super();
-    }
-
-    public ExamProcessRecordReport(Long examRecordDataId, ExamProcess examProcess, Date recordTime) {
-        this.examRecordDataId = examRecordDataId;
-        this.examProcess = examProcess;
-        this.recordTime = recordTime;
-        this.topic = ReportsUtil.getReportTopic();
-        this.tag = Tag.EXAM_PROCESS_RECORD.getCode();
-    }
-}

examcloud-core-basic-service/src/main/java/cn/com/qmth/examcloud/core/basic/service/report/RocketMqConsumerListener.java

@@ -40,9 +40,9 @@ public class RocketMqConsumerListener {
     }
 
     private static void adminOperate() {
-        properties.put(PropertyKeyConst.GROUP_ID, Tag.ADMIN_OPERATE_INFO.getGroup() + "_" + ReportsUtil.getProfile());
+        properties.put(PropertyKeyConst.GROUP_ID, ReportsUtil.curConsumerGroup(Tag.ADMIN_OPERATE_INFO));
         Consumer consumer = ONSFactory.createConsumer(properties);
-        consumer.subscribe(ReportsUtil.getReportTopic(), Tag.ADMIN_OPERATE_INFO.getCode(), new MessageListener() {
+        consumer.subscribe(ReportsUtil.curTopic(Tag.ADMIN_OPERATE_INFO), Tag.ADMIN_OPERATE_INFO.name(), new MessageListener() {
 
             @Override
             public Action consume(Message message, ConsumeContext context) {