|
@@ -15,7 +15,6 @@ import com.alibaba.fastjson.JSON;
|
|
|
|
|
|
import cn.com.qmth.examcloud.commons.util.ThreadLocalUtil;
|
|
|
import cn.com.qmth.examcloud.reports.commons.bean.BaseReport;
|
|
|
-import cn.com.qmth.examcloud.reports.commons.bean.LoginStudentReport;
|
|
|
import cn.com.qmth.examcloud.reports.commons.bean.OnlineExamStudentReport;
|
|
|
import cn.com.qmth.examcloud.reports.commons.bean.OnlineStudentReport;
|
|
|
import cn.com.qmth.examcloud.reports.commons.bean.OnlineUserReport;
|
|
@@ -58,15 +57,9 @@ public class ReportsUtil {
|
|
|
if (b instanceof OnlineExamStudentReport) {
|
|
|
OnlineExamStudentReport ob = (OnlineExamStudentReport) b;
|
|
|
kafkaTemplate.send(ob.getTopic(), JSON.toJSONString(b));
|
|
|
- LoginStudentReport lp = new LoginStudentReport(ob.getRootOrgId(), ob.getStudentId());
|
|
|
- setReportCommonData(lp);
|
|
|
- kafkaTemplate.send(lp.getTopic(), JSON.toJSONString(lp));
|
|
|
} else if (b instanceof OnlineStudentReport) {
|
|
|
OnlineStudentReport ob = (OnlineStudentReport) b;
|
|
|
kafkaTemplate.send(ob.getTopic(), JSON.toJSONString(b));
|
|
|
- LoginStudentReport lp = new LoginStudentReport(ob.getRootOrgId(), ob.getStudentId());
|
|
|
- setReportCommonData(lp);
|
|
|
- kafkaTemplate.send(lp.getTopic(), JSON.toJSONString(lp));
|
|
|
} else if (b instanceof OnlineUserReport) {
|
|
|
OnlineUserReport ob = (OnlineUserReport) b;
|
|
|
kafkaTemplate.send(ob.getTopic(), JSON.toJSONString(b));
|