|
@@ -92,6 +92,7 @@ public class KafkaConsumerListener {
|
|
|
ac.setStudentId(r.getStudentId());
|
|
|
ac.setExamId(r.getExamId());
|
|
|
ActiveDataUtil.updateExamStudentActive(ac);
|
|
|
+ onMessageStudent(r.getReportTime().getTime(), r.getRootOrgId(), r.getStudentId());
|
|
|
onMessageLoginStudent(r.getReportTime().getTime(), r.getRootOrgId(), r.getStudentId());
|
|
|
}
|
|
|
|
|
@@ -113,4 +114,12 @@ public class KafkaConsumerListener {
|
|
|
ActiveDataUtil.updateStudentlogin(sl);
|
|
|
}
|
|
|
|
|
|
+ private static void onMessageStudent(Long reportTime, Long rootOrgId, Long studentId) {
|
|
|
+ StudentActive ac = new StudentActive();
|
|
|
+ ac.setActiveTime(reportTime);
|
|
|
+ ac.setRootOrgId(rootOrgId);
|
|
|
+ ac.setStudentId(studentId);
|
|
|
+ ActiveDataUtil.updateStudentActive(ac);
|
|
|
+ }
|
|
|
+
|
|
|
}
|