|
@@ -167,7 +167,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
|
|
|
map.put("content", prop.get("content"));
|
|
|
WebsocketDto websocketDto = new WebsocketDto(WebsocketTypeEnum.INVIGILATE_NOTICE.name(), map);
|
|
|
webSocketOeServer.sendMessage(websocketDto);
|
|
|
- TIeExamInvigilateNotice tIeExamInvigilateNotice = new TIeExamInvigilateNotice(examId, examActivityId, recordId, Long.parseLong(mqDto.getObjId()), examStudentId, MessageTypeEnum.valueOf(String.valueOf(prop.get("type"))), String.valueOf(prop.get("content")));
|
|
|
+ TIeExamInvigilateNotice tIeExamInvigilateNotice = new TIeExamInvigilateNotice(examId, examActivityId, recordId, Long.parseLong(mqDto.getObjId()), examStudentId, MessageTypeEnum.valueOf(String.valueOf(prop.get("type")).toUpperCase()), String.valueOf(prop.get("content")));
|
|
|
tIeExamInvigilateNoticeService.saveOrUpdate(tIeExamInvigilateNotice);
|
|
|
}
|
|
|
} else if (Objects.equals(MqTagEnum.OE_IM_BROADCASTING.name(), tag)) {//广播消息
|