|
@@ -13,6 +13,9 @@ import com.ym.dao.RoomDao;
|
|
|
import com.ym.dao.RoomMemberDao;
|
|
|
import com.ym.dao.UserDao;
|
|
|
import com.ym.dao.WhiteboardDao;
|
|
|
+import com.ym.enums.ActionEnum;
|
|
|
+import com.ym.enums.DeviceTypeEnum;
|
|
|
+import com.ym.enums.RoleEnum;
|
|
|
import com.ym.job.ScheduleManager;
|
|
|
import com.ym.mec.auth.api.client.SysUserFeignService;
|
|
|
import com.ym.mec.auth.api.entity.SysUser;
|
|
@@ -49,8 +52,8 @@ import java.util.*;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
-import static com.ym.pojo.RoleEnum.RoleStudent;
|
|
|
-import static com.ym.pojo.RoleEnum.RoleTeacher;
|
|
|
+import static com.ym.enums.RoleEnum.RoleStudent;
|
|
|
+import static com.ym.enums.RoleEnum.RoleTeacher;
|
|
|
|
|
|
/**
|
|
|
* Created by super_zou on 2019/11/28.
|
|
@@ -99,25 +102,25 @@ public class RoomServiceImpl implements RoomService {
|
|
|
@Autowired
|
|
|
private TenantAssetsInfoService tenantAssetsInfoService;
|
|
|
@Autowired
|
|
|
- private RedisTemplate<String,String> redisTemplate;
|
|
|
+ private RedisTemplate<String, String> redisTemplate;
|
|
|
|
|
|
@Override
|
|
|
- public Integer getCurrentCourseId(String roomId){
|
|
|
+ public Integer getCurrentCourseId(String roomId) {
|
|
|
CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
|
|
|
//是否是连堂课
|
|
|
- String continueCourseTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME,courseSchedule.getTenantId());
|
|
|
+ String continueCourseTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME, courseSchedule.getTenantId());
|
|
|
if (StringUtils.isEmpty(continueCourseTime)) {
|
|
|
continueCourseTime = "5";
|
|
|
}
|
|
|
CourseSchedule schedule = courseSchedule;
|
|
|
//如果当前课程是连堂课,那么获取第一节课的课程编号
|
|
|
- while (true){
|
|
|
+ while (true) {
|
|
|
String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
|
|
|
String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
|
|
|
- schedule = courseScheduleDao.getFirstCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
|
|
|
- if(schedule != null){
|
|
|
+ schedule = courseScheduleDao.getFirstCourse(schedule.getClassGroupId(), classDate + " " + startClassTime, schedule.getActualTeacherId(), continueCourseTime);
|
|
|
+ if (schedule != null) {
|
|
|
roomId = schedule.getId().toString();
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
@@ -125,20 +128,20 @@ public class RoomServiceImpl implements RoomService {
|
|
|
}
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public String getCloseNetworkRoomTime(CourseSchedule courseSchedule,String continueCourseTime){
|
|
|
- String autoCloseNetworkRoomTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.COURSE_AFTER_BUFFER_TIME,courseSchedule.getTenantId());
|
|
|
- if(StringUtils.isEmpty(autoCloseNetworkRoomTime)){
|
|
|
+ public String getCloseNetworkRoomTime(CourseSchedule courseSchedule, String continueCourseTime) {
|
|
|
+ String autoCloseNetworkRoomTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.COURSE_AFTER_BUFFER_TIME, courseSchedule.getTenantId());
|
|
|
+ if (StringUtils.isEmpty(autoCloseNetworkRoomTime)) {
|
|
|
autoCloseNetworkRoomTime = "15";
|
|
|
}
|
|
|
CourseSchedule schedule = courseSchedule;
|
|
|
//如果当前课程是连堂课,那么获取第一节课的课程编号
|
|
|
- while (true){
|
|
|
+ while (true) {
|
|
|
String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
|
|
|
String endClassTime = DateUtil.format(schedule.getEndClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
|
|
|
- schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(),classDate + " " + endClassTime,schedule.getActualTeacherId(),continueCourseTime);
|
|
|
- if(schedule != null){
|
|
|
- autoCloseNetworkRoomTime = DateUtil.minutesBetween(new Date(),schedule.getEndClassTime()) + "";
|
|
|
- }else {
|
|
|
+ schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(), classDate + " " + endClassTime, schedule.getActualTeacherId(), continueCourseTime);
|
|
|
+ if (schedule != null) {
|
|
|
+ autoCloseNetworkRoomTime = DateUtil.minutesBetween(new Date(), schedule.getEndClassTime()) + "";
|
|
|
+ } else {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
@@ -155,57 +158,57 @@ public class RoomServiceImpl implements RoomService {
|
|
|
|
|
|
Teacher teacher = teacherDao.get(Integer.parseInt(userId));
|
|
|
CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
|
|
|
- if(courseSchedule.getTeachMode() == TeachModeEnum.OFFLINE){
|
|
|
- return new BaseResponse(ErrorEnum.JOIN_ROOM_ERROR,ErrorEnum.JOIN_ROOM_ERROR.getErrMsg(),null);
|
|
|
+ if (courseSchedule.getTeachMode() == TeachModeEnum.OFFLINE) {
|
|
|
+ return new BaseResponse(ErrorEnum.JOIN_ROOM_ERROR, ErrorEnum.JOIN_ROOM_ERROR.getErrMsg(), null);
|
|
|
}
|
|
|
Date curTime = DateTimeUtils.currentUTC();
|
|
|
//是否提前进入教室
|
|
|
- String courseBeforeBufferTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.COURSE_BEFORE_BUFFER_TIME,courseSchedule.getTenantId());
|
|
|
+ String courseBeforeBufferTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.COURSE_BEFORE_BUFFER_TIME, courseSchedule.getTenantId());
|
|
|
if (StringUtils.isEmpty(courseBeforeBufferTime)) {
|
|
|
courseBeforeBufferTime = "5";
|
|
|
}
|
|
|
Date addMinutes = DateUtil.addMinutes(curTime, Integer.parseInt(courseBeforeBufferTime));
|
|
|
- if(courseSchedule.getStartClassTime().compareTo(addMinutes) > 0 ){
|
|
|
- return new BaseResponse(ErrorEnum.ROOM_NOT_START,ErrorEnum.ROOM_NOT_START.getErrMsg(),null);
|
|
|
+ if (courseSchedule.getStartClassTime().compareTo(addMinutes) > 0) {
|
|
|
+ return new BaseResponse(ErrorEnum.ROOM_NOT_START, ErrorEnum.ROOM_NOT_START.getErrMsg(), null);
|
|
|
// throw new BizException("网络教室暂未开启,请在{}分钟后进入教室",DateUtil.minutesBetween(addMinutes,courseSchedule.getStartClassTime()));
|
|
|
}
|
|
|
final TenantAssetsInfo one = tenantAssetsInfoService.getOne(new WrapperUtil<TenantAssetsInfo>()
|
|
|
.hasEq("tenant_id_", courseSchedule.getTenantId())
|
|
|
.queryWrapper()
|
|
|
.gt("balance_", 0));
|
|
|
- if(one == null){
|
|
|
- return new BaseResponse(ErrorEnum.CLOUD_BALANCE_NOT_FEE,ErrorEnum.CLOUD_BALANCE_NOT_FEE.getErrMsg(),null);
|
|
|
+ if (one == null) {
|
|
|
+ return new BaseResponse(ErrorEnum.CLOUD_BALANCE_NOT_FEE, ErrorEnum.CLOUD_BALANCE_NOT_FEE.getErrMsg(), null);
|
|
|
}
|
|
|
|
|
|
//是否是连堂课
|
|
|
- String continueCourseTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME,courseSchedule.getTenantId());
|
|
|
+ String continueCourseTime = sysTenantConfigService.getTenantConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME, courseSchedule.getTenantId());
|
|
|
if (StringUtils.isEmpty(continueCourseTime)) {
|
|
|
continueCourseTime = "5";
|
|
|
}
|
|
|
|
|
|
RoomResult roomResult = new RoomResult();
|
|
|
- roomResult.setAutoCloseNetworkRoomTime(this.getCloseNetworkRoomTime(courseSchedule,continueCourseTime));
|
|
|
+ roomResult.setAutoCloseNetworkRoomTime(this.getCloseNetworkRoomTime(courseSchedule, continueCourseTime));
|
|
|
CourseSchedule schedule = courseSchedule;
|
|
|
//如果当前课程是连堂课,那么获取第一节课的课程编号
|
|
|
- while (true){
|
|
|
+ while (true) {
|
|
|
String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
|
|
|
String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
|
|
|
- schedule = courseScheduleDao.getFirstCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
|
|
|
- if(schedule != null){
|
|
|
+ schedule = courseScheduleDao.getFirstCourse(schedule.getClassGroupId(), classDate + " " + startClassTime, schedule.getActualTeacherId(), continueCourseTime);
|
|
|
+ if (schedule != null) {
|
|
|
roomId = schedule.getId().toString();
|
|
|
// roomResult.setAutoCloseFlag(false);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
Long courseId = Long.parseLong(roomId);
|
|
|
//记录用户实际选择的房间
|
|
|
- if(courseSchedule.getGroupType() == GroupType.COMM){
|
|
|
+ if (courseSchedule.getGroupType() == GroupType.COMM) {
|
|
|
roomId = "I" + roomId;
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
roomId = "S" + roomId;
|
|
|
}
|
|
|
- redisTemplate.opsForValue().setIfAbsent(roomId + userId,courseSchedule.getId().toString());
|
|
|
+ redisTemplate.opsForValue().setIfAbsent(roomId + userId, courseSchedule.getId().toString());
|
|
|
log.info("joinRoom current: roomId={}, userId={}", roomId, userId);
|
|
|
RoleEnum roleEnum;
|
|
|
|
|
@@ -216,13 +219,13 @@ public class RoomServiceImpl implements RoomService {
|
|
|
if (member == null) {
|
|
|
int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
|
|
|
if (count == roomProperties.getMaxCount()) {
|
|
|
- log.info("join error Over max count: roomId = {}, userId = {}", roomId,userId);
|
|
|
- return new BaseResponse(ErrorEnum.ERR_OVER_MAX_COUNT,ErrorEnum.ERR_OVER_MAX_COUNT.getErrMsg(),null);
|
|
|
+ log.info("join error Over max count: roomId = {}, userId = {}", roomId, userId);
|
|
|
+ return new BaseResponse(ErrorEnum.ERR_OVER_MAX_COUNT, ErrorEnum.ERR_OVER_MAX_COUNT.getErrMsg(), null);
|
|
|
}
|
|
|
- if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
|
|
|
+ if (teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())) {
|
|
|
roleEnum = RoleTeacher;
|
|
|
userName = sysUser.getRealName();
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
roleEnum = RoleStudent;
|
|
|
userName = sysUser.getUsername();
|
|
|
}
|
|
@@ -230,11 +233,11 @@ public class RoomServiceImpl implements RoomService {
|
|
|
userResult.setCamera(true);
|
|
|
userResult.setHandUpOn(false);
|
|
|
userResult.setJoinTime(curTime);
|
|
|
- saveRoomMember(userId,sysUser.getAvatar(), userName, roomId, roleEnum.getValue(), curTime);
|
|
|
+ saveRoomMember(userId, sysUser.getAvatar(), userName, roomId, roleEnum.getValue(), curTime);
|
|
|
} else {
|
|
|
roleEnum = RoleEnum.getEnumByValue(member.getRole());
|
|
|
- if(roleEnum == RoleTeacher){
|
|
|
- courseScheduleStudentPaymentDao.adjustPlayMidi(courseId,null,null);
|
|
|
+ if (roleEnum == RoleTeacher) {
|
|
|
+ courseScheduleStudentPaymentDao.adjustPlayMidi(courseId, null, null);
|
|
|
}
|
|
|
userName = member.getName();
|
|
|
userResult.setCamera(member.isCamera());
|
|
@@ -243,7 +246,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
}
|
|
|
imHelper.joinGroup(new String[]{userId}, roomId, roomId);
|
|
|
|
|
|
- List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(null, courseId,null, null, null);
|
|
|
+ List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(null, courseId, null, null, null);
|
|
|
|
|
|
Room room = roomDao.findByRid(roomId);
|
|
|
String display = "";
|
|
@@ -251,13 +254,13 @@ public class RoomServiceImpl implements RoomService {
|
|
|
display = "display://type=1?userId=" + userId + "?uri=";
|
|
|
} else if (roleEnum == RoleEnum.RoleAssistant && display.isEmpty()) {
|
|
|
display = "display://type=0?userId=" + userId + "?uri=";
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
ExamSongDownloadData examSongDownloadData;
|
|
|
String json = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(courseId, sysUser.getId());
|
|
|
- if(StringUtils.isEmpty(json)){
|
|
|
+ if (StringUtils.isEmpty(json)) {
|
|
|
examSongDownloadData = new ExamSongDownloadData();
|
|
|
- }else {
|
|
|
- examSongDownloadData = JSON.parseObject(json,ExamSongDownloadData.class);
|
|
|
+ } else {
|
|
|
+ examSongDownloadData = JSON.parseObject(json, ExamSongDownloadData.class);
|
|
|
}
|
|
|
//获取学员曲目下载状态
|
|
|
userResult.setExamSongDownloadJson(examSongDownloadData);
|
|
@@ -266,7 +269,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
}
|
|
|
}
|
|
|
//已下载的伴奏列表
|
|
|
- if(scheduleStudentMusicScores != null && scheduleStudentMusicScores.size() > 0){
|
|
|
+ if (scheduleStudentMusicScores != null && scheduleStudentMusicScores.size() > 0) {
|
|
|
List<CourseScheduleStudentMusicScore> musicScores = scheduleStudentMusicScores.stream().filter(e -> e.getUserId().equals(sysUser.getId())).collect(Collectors.toList());
|
|
|
String toJSONString = JSON.toJSONString(musicScores, SerializerFeature.DisableCircularReferenceDetect);
|
|
|
List<CourseScheduleStudentMusicScore> lists = JSON.parseArray(toJSONString, CourseScheduleStudentMusicScore.class);
|
|
@@ -277,24 +280,24 @@ public class RoomServiceImpl implements RoomService {
|
|
|
userResult.setUserId(userId);
|
|
|
userResult.setRole(roleEnum.getValue());
|
|
|
//获取节拍器信息
|
|
|
- String midi = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(courseId.toString(),userId);
|
|
|
- userResult.setPlayMidiJson(JSONObject.parseObject(midi,CustomMessage.class));
|
|
|
+ String midi = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(courseId.toString(), userId);
|
|
|
+ userResult.setPlayMidiJson(JSONObject.parseObject(midi, CustomMessage.class));
|
|
|
|
|
|
//获取当前课程剩余时长
|
|
|
// String classDate = DateUtil.format(courseSchedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
|
|
|
// String endClassTime = DateUtil.format(courseSchedule.getEndClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
|
|
|
- roomResult.setSurplusTime(DateUtil.secondsBetween(new Date(),courseSchedule.getEndClassTime()));
|
|
|
+ roomResult.setSurplusTime(DateUtil.secondsBetween(new Date(), courseSchedule.getEndClassTime()));
|
|
|
|
|
|
roomResult.setUserInfo(userResult);
|
|
|
roomResult.setDisplay(display);
|
|
|
roomResult.setRoomId(roomId);
|
|
|
|
|
|
List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
|
|
|
- if(roomMemberList != null && roomMemberList.size() > 0){
|
|
|
+ if (roomMemberList != null && roomMemberList.size() > 0) {
|
|
|
Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
|
|
|
- Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,courseId.toString()));
|
|
|
- Map<Integer,String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds,courseId.toString()));
|
|
|
- roomResult.setMembers(roomMemberList,midiMap,examSongMap,scheduleStudentMusicScores);
|
|
|
+ Map<Integer, String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds, courseId.toString()));
|
|
|
+ Map<Integer, String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds, courseId.toString()));
|
|
|
+ roomResult.setMembers(roomMemberList, midiMap, examSongMap, scheduleStudentMusicScores);
|
|
|
}
|
|
|
roomResult.setWhiteboards(whiteboardDao.findByRid(roomId));
|
|
|
if (room != null) {
|
|
@@ -304,7 +307,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
return new BaseResponse(roomResult);
|
|
|
}
|
|
|
|
|
|
- public RoomMember saveRoomMember(String roomId,String userId){
|
|
|
+ public RoomMember saveRoomMember(String roomId, String userId) {
|
|
|
SysUser sysUser = sysUserFeignService.queryUserById(Integer.parseInt(userId));
|
|
|
|
|
|
Teacher teacher = teacherDao.get(Integer.parseInt(userId));
|
|
@@ -316,10 +319,10 @@ public class RoomServiceImpl implements RoomService {
|
|
|
RoomMember member = roomMemberDao.findByRidAndUid(roomId, userId);
|
|
|
String userName;
|
|
|
if (member == null) {
|
|
|
- if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
|
|
|
+ if (teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())) {
|
|
|
roleEnum = RoleTeacher;
|
|
|
userName = sysUser.getRealName();
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
roleEnum = RoleStudent;
|
|
|
userName = sysUser.getUsername();
|
|
|
}
|
|
@@ -333,28 +336,28 @@ public class RoomServiceImpl implements RoomService {
|
|
|
@Override
|
|
|
public void joinRoomFailure(String roomId, String userId) {
|
|
|
RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
|
|
|
- if(roomMember == null){
|
|
|
- return ;
|
|
|
+ if (roomMember == null) {
|
|
|
+ return;
|
|
|
}
|
|
|
log.info("joinRoomFailure : roomId={}, userId={}", roomId, userId);
|
|
|
//如果加入失败,删除该用户数据
|
|
|
- roomMemberDao.deleteUserByRidAndUid(roomId,userId);
|
|
|
+ roomMemberDao.deleteUserByRidAndUid(roomId, userId);
|
|
|
}
|
|
|
|
|
|
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
|
|
|
@Override
|
|
|
- public void joinRoomSuccess(String roomId,String userId,String deviceNum) throws Exception {
|
|
|
- log.info("joinRoomSuccess: roomId={}, userId={}, deviceNum={}", roomId,userId,deviceNum);
|
|
|
+ public void joinRoomSuccess(String roomId, String userId, String deviceNum) throws Exception {
|
|
|
+ log.info("joinRoomSuccess: roomId={}, userId={}, deviceNum={}", roomId, userId, deviceNum);
|
|
|
RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
|
|
|
- if(roomMember == null){
|
|
|
- roomMember = saveRoomMember(roomId,userId);
|
|
|
+ if (roomMember == null) {
|
|
|
+ roomMember = saveRoomMember(roomId, userId);
|
|
|
}
|
|
|
- String joinSuccessKey = "joinRoomSuccess"+ roomId + userId;
|
|
|
+ String joinSuccessKey = "joinRoomSuccess" + roomId + userId;
|
|
|
Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent(joinSuccessKey, roomId, 1l, TimeUnit.SECONDS);
|
|
|
- if(!aBoolean){
|
|
|
+ if (!aBoolean) {
|
|
|
RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
|
|
|
- if(roleEnum == RoleTeacher && StringUtils.isNotEmpty(deviceNum)){
|
|
|
- teacherAttendanceService.updateDeviceNum(Integer.parseInt(roomId.substring(1)),userId,deviceNum,null);
|
|
|
+ if (roleEnum == RoleTeacher && StringUtils.isNotEmpty(deviceNum)) {
|
|
|
+ teacherAttendanceService.updateDeviceNum(Integer.parseInt(roomId.substring(1)), userId, deviceNum, null);
|
|
|
// signInSuccess(roomMember,deviceNum);
|
|
|
}
|
|
|
return;
|
|
@@ -364,11 +367,11 @@ public class RoomServiceImpl implements RoomService {
|
|
|
CourseSchedule schedule = courseScheduleDao.getLock(Long.parseLong(roomId.substring(1)));
|
|
|
|
|
|
String display = "";
|
|
|
- if(roleEnum == RoleTeacher){
|
|
|
+ if (roleEnum == RoleTeacher) {
|
|
|
//如果是老师加入房间,调整节拍器状态
|
|
|
- courseScheduleStudentPaymentDao.adjustPlayMidi(schedule.getId(),null,null);
|
|
|
+ courseScheduleStudentPaymentDao.adjustPlayMidi(schedule.getId(), null, null);
|
|
|
display = "display://type=1?userId=" + userId + "?uri=";
|
|
|
- }else if (roleEnum == RoleEnum.RoleAssistant){
|
|
|
+ } else if (roleEnum == RoleEnum.RoleAssistant) {
|
|
|
display = "display://type=0?userId=" + userId + "?uri=";
|
|
|
}
|
|
|
Date curTime = DateTimeUtils.currentUTC();
|
|
@@ -380,8 +383,8 @@ public class RoomServiceImpl implements RoomService {
|
|
|
log.error("joinRoomSuccess createGroup error: roomId={}, {}", roomId, resultInfo.getErrorMessage());
|
|
|
throw new ApiException(ErrorEnum.ERR_CREATE_ROOM_ERROR, resultInfo.getErrorMessage());
|
|
|
}
|
|
|
- }else{
|
|
|
- if(roleEnum == RoleTeacher || roleEnum == RoleEnum.RoleAssistant){
|
|
|
+ } else {
|
|
|
+ if (roleEnum == RoleTeacher || roleEnum == RoleEnum.RoleAssistant) {
|
|
|
updateDisplay(roomId, userId, display, 0);
|
|
|
}
|
|
|
}
|
|
@@ -401,17 +404,17 @@ public class RoomServiceImpl implements RoomService {
|
|
|
msg.setCamera(true);
|
|
|
Boolean playMidi = false;
|
|
|
Boolean examSong = false;
|
|
|
- if(roleEnum == RoleStudent){
|
|
|
+ if (roleEnum == RoleStudent) {
|
|
|
String midiByCourseIdAndUserId = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(schedule.getId().toString(), userId);
|
|
|
//获取节拍器信息
|
|
|
- if(StringUtils.isNotEmpty(midiByCourseIdAndUserId)){
|
|
|
+ if (StringUtils.isNotEmpty(midiByCourseIdAndUserId)) {
|
|
|
JSONObject jsonObject = JSONObject.parseObject(midiByCourseIdAndUserId);
|
|
|
- if(jsonObject.get("enable") != null){
|
|
|
+ if (jsonObject.get("enable") != null) {
|
|
|
playMidi = Boolean.parseBoolean(jsonObject.get("enable").toString());
|
|
|
}
|
|
|
}
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(schedule.getId(), Integer.parseInt(userId));
|
|
|
- if(StringUtils.isNotEmpty(examJson)){
|
|
|
+ if (StringUtils.isNotEmpty(examJson)) {
|
|
|
ExamSongDownloadData examSongDownloadData = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
examSong = examSongDownloadData.getEnable();
|
|
|
}
|
|
@@ -421,30 +424,30 @@ public class RoomServiceImpl implements RoomService {
|
|
|
msg.setExamSongSwitch(examSong);
|
|
|
imHelper.publishMessage(userId, roomId, msg);
|
|
|
log.info("join room success: roomId = {}, userId = {}, role = {}", roomId, userId, roleEnum);
|
|
|
- signInSuccess(roomMember,deviceNum);
|
|
|
+ signInSuccess(roomMember, deviceNum);
|
|
|
}
|
|
|
|
|
|
- public void signInSuccess(RoomMember roomMember,String deviceNum) {
|
|
|
+ public void signInSuccess(RoomMember roomMember, String deviceNum) {
|
|
|
String roomId = roomMember.getRid();
|
|
|
String userId = roomMember.getUid();
|
|
|
String currentRoomIdKey = roomId + userId;
|
|
|
|
|
|
Long firstCourseId = Long.parseLong(roomId.substring(1));
|
|
|
Long currentRoomId;
|
|
|
- if(redisTemplate.hasKey(currentRoomIdKey)){
|
|
|
+ if (redisTemplate.hasKey(currentRoomIdKey)) {
|
|
|
currentRoomId = Long.parseLong(redisTemplate.opsForValue().get(currentRoomIdKey));
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
log.error("signInFailure: roomId={}, userId={}", roomId, userId);
|
|
|
currentRoomId = firstCourseId;
|
|
|
}
|
|
|
- log.info("signInSuccess: roomId={}, userId={},currentRoomId={}", roomId, userId,currentRoomId);
|
|
|
+ log.info("signInSuccess: roomId={}, userId={},currentRoomId={}", roomId, userId, currentRoomId);
|
|
|
Integer userIdInt = Integer.parseInt(userId);
|
|
|
|
|
|
RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
|
|
|
- if(roleEnum == RoleTeacher){
|
|
|
- teacherAttendanceService.addTeacherAttendanceSignIn(firstCourseId,userIdInt,currentRoomId,deviceNum);
|
|
|
- }else {
|
|
|
- studentAttendanceService.addStudentAttendanceSignIn(firstCourseId,userIdInt,currentRoomId);
|
|
|
+ if (roleEnum == RoleTeacher) {
|
|
|
+ teacherAttendanceService.addTeacherAttendanceSignIn(firstCourseId, userIdInt, currentRoomId, deviceNum);
|
|
|
+ } else {
|
|
|
+ studentAttendanceService.addStudentAttendanceSignIn(firstCourseId, userIdInt, currentRoomId);
|
|
|
}
|
|
|
redisTemplate.delete(roomId + userId);
|
|
|
}
|
|
@@ -473,30 +476,30 @@ public class RoomServiceImpl implements RoomService {
|
|
|
return roomMember;
|
|
|
}
|
|
|
|
|
|
- @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
|
|
|
+ @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
|
|
|
@Override
|
|
|
- public void leaveRoomSuccess(String roomId,String userId,String deviceNum) throws Exception {
|
|
|
- log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={}", roomId,userId,deviceNum);
|
|
|
+ public void leaveRoomSuccess(String roomId, String userId, String deviceNum) throws Exception {
|
|
|
+ log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={}", roomId, userId, deviceNum);
|
|
|
Integer firstCourseId = Integer.parseInt(roomId.substring(1));
|
|
|
RoleEnum roleEnum;
|
|
|
int parseInt = Integer.parseInt(userId);
|
|
|
Teacher teacher = teacherDao.get(parseInt);
|
|
|
CourseSchedule courseSchedule = courseScheduleDao.get(firstCourseId.longValue());
|
|
|
- if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
|
|
|
+ if (teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())) {
|
|
|
roleEnum = RoleTeacher;
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(),null,null);
|
|
|
- }else {
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(), null, null);
|
|
|
+ } else {
|
|
|
roleEnum = RoleStudent;
|
|
|
}
|
|
|
|
|
|
- String leaveSuccessKey = "leaveRoomSuccess"+ roomId + userId;
|
|
|
+ String leaveSuccessKey = "leaveRoomSuccess" + roomId + userId;
|
|
|
Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent(leaveSuccessKey, roomId, 1l, TimeUnit.SECONDS);
|
|
|
- log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={},aBoolean={}", roomId,userId,deviceNum,aBoolean);
|
|
|
- if(!aBoolean){
|
|
|
- if (StringUtils.isNotEmpty(deviceNum)){
|
|
|
+ log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={},aBoolean={}", roomId, userId, deviceNum, aBoolean);
|
|
|
+ if (!aBoolean) {
|
|
|
+ if (StringUtils.isNotEmpty(deviceNum)) {
|
|
|
//如果设备号不为空,更新设备号
|
|
|
- if(roleEnum == RoleTeacher){
|
|
|
- teacherAttendanceService.updateDeviceNum(firstCourseId,userId,null,deviceNum);
|
|
|
+ if (roleEnum == RoleTeacher) {
|
|
|
+ teacherAttendanceService.updateDeviceNum(firstCourseId, userId, null, deviceNum);
|
|
|
// teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(),parseInt,deviceNum);
|
|
|
}
|
|
|
}
|
|
@@ -505,14 +508,14 @@ public class RoomServiceImpl implements RoomService {
|
|
|
|
|
|
String username;
|
|
|
SysUser sysUser = sysUserFeignService.queryUserById(parseInt);
|
|
|
- if(roleEnum == RoleTeacher){
|
|
|
+ if (roleEnum == RoleTeacher) {
|
|
|
username = sysUser.getRealName();
|
|
|
- courseScheduleStudentPaymentDao.adjustPlayMidi(firstCourseId,null,null);
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(firstCourseId.longValue(),null,null);
|
|
|
- teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(),parseInt,deviceNum);
|
|
|
- }else {
|
|
|
+ courseScheduleStudentPaymentDao.adjustPlayMidi(firstCourseId, null, null);
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(firstCourseId.longValue(), null, null);
|
|
|
+ teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(), parseInt, deviceNum);
|
|
|
+ } else {
|
|
|
username = sysUser.getUsername();
|
|
|
- studentAttendanceService.addStudentAttendanceSignOut(firstCourseId.longValue(),parseInt);
|
|
|
+ studentAttendanceService.addStudentAttendanceSignOut(firstCourseId.longValue(), parseInt);
|
|
|
}
|
|
|
Room room = roomDao.findByRid(roomId);
|
|
|
if (room == null) {
|
|
@@ -528,15 +531,15 @@ public class RoomServiceImpl implements RoomService {
|
|
|
roomDao.deleteByRid(roomId);
|
|
|
deleteWhiteboardByUser(roomId, userId);
|
|
|
imHelper.dismiss(userId, roomId);
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(),null,null);
|
|
|
- log.info("leaveRoomSuccess dismiss the room: {},userId: {}", roomId,userId);
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(), null, null);
|
|
|
+ log.info("leaveRoomSuccess dismiss the room: {},userId: {}", roomId, userId);
|
|
|
} else {
|
|
|
roomMemberDao.deleteUserByRidAndUid(roomId, userId);
|
|
|
MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Leave, userId, roleEnum.getValue());
|
|
|
msg.setUserName(username);
|
|
|
imHelper.publishMessage(userId, roomId, msg);
|
|
|
imHelper.quit(new String[]{userId}, roomId);
|
|
|
- log.info("leaveRoomSuccess quit group: roomId={},userId: {}", roomId,userId);
|
|
|
+ log.info("leaveRoomSuccess quit group: roomId={},userId: {}", roomId, userId);
|
|
|
}
|
|
|
userDao.deleteByUid(userId);
|
|
|
}
|
|
@@ -632,7 +635,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
CheckUtils.checkArgument(roomId != null, "roomId must't be null");
|
|
|
log.info("kickMember: roomId={}, userId={}", roomId, userId);
|
|
|
RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
|
|
|
- if(roomMember == null){
|
|
|
+ if (roomMember == null) {
|
|
|
return true;
|
|
|
}
|
|
|
|
|
@@ -861,22 +864,22 @@ public class RoomServiceImpl implements RoomService {
|
|
|
} else if (data.getHandUpOn() != null) {
|
|
|
typeEnum = DeviceTypeEnum.HandUp;
|
|
|
enable = data.getHandUpOn();
|
|
|
- }else if (data.getExamSongOn() != null) {
|
|
|
+ } else if (data.getExamSongOn() != null) {
|
|
|
typeEnum = DeviceTypeEnum.ExamSong;
|
|
|
enable = data.getExamSongOn();
|
|
|
- }else if (data.getMusicScoreOn() != null) {
|
|
|
+ } else if (data.getMusicScoreOn() != null) {
|
|
|
typeEnum = DeviceTypeEnum.MusicScore;
|
|
|
enable = data.getMusicScoreOn();
|
|
|
- if(enable){
|
|
|
+ if (enable) {
|
|
|
//保存伴奏音量
|
|
|
- roomDao.updateSoundVolumeById(roomId,data.getSoundVolume()==null?0:data.getSoundVolume());
|
|
|
+ roomDao.updateSoundVolumeById(roomId, data.getSoundVolume() == null ? 0 : data.getSoundVolume());
|
|
|
}
|
|
|
- }else if (data.getAccompanimentOn() != null) {
|
|
|
+ } else if (data.getAccompanimentOn() != null) {
|
|
|
typeEnum = DeviceTypeEnum.MusicScoreAccompaniment;
|
|
|
enable = data.getAccompanimentOn();
|
|
|
- if(enable){
|
|
|
+ if (enable) {
|
|
|
//保存伴奏音量
|
|
|
- roomDao.updateSoundVolumeById(roomId,data.getSoundVolume()==null?0:data.getSoundVolume());
|
|
|
+ roomDao.updateSoundVolumeById(roomId, data.getSoundVolume() == null ? 0 : data.getSoundVolume());
|
|
|
}
|
|
|
} else {
|
|
|
throw new ApiException(ErrorEnum.ERR_REQUEST_PARA_ERR);
|
|
@@ -885,24 +888,24 @@ public class RoomServiceImpl implements RoomService {
|
|
|
log.info("controlDevice: userId = {}, typeEnum = {}, enable = {} ,roomId = {}", userId, typeEnum, enable, roomId);
|
|
|
|
|
|
if (enable) {
|
|
|
- if (typeEnum.equals(DeviceTypeEnum.ExamSong)){
|
|
|
+ if (typeEnum.equals(DeviceTypeEnum.ExamSong)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
ExamSongDownloadData msg;
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, Integer.parseInt(userId));
|
|
|
- if(StringUtils.isEmpty(examJson)){
|
|
|
+ if (StringUtils.isEmpty(examJson)) {
|
|
|
throw new BizException("学员伴奏信息异常");
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
msg.setEnable(enable);
|
|
|
}
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,Integer.parseInt(userId),JSON.toJSONString(msg));
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(scheduleId, Integer.parseInt(userId), JSON.toJSONString(msg));
|
|
|
DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
|
|
|
deviceResourceMessage.setUserId(userId);
|
|
|
imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
|
|
|
- }else if(typeEnum.equals(DeviceTypeEnum.MusicScore)){
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.MusicScore)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
//关闭所有曲目播放
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId, Integer.parseInt(userId), null);
|
|
|
DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
|
|
|
deviceResourceMessage.setMusicScoreAccompanimentId(data.getMusicScoreAccompanimentId());
|
|
|
deviceResourceMessage.setUserId(userId);
|
|
@@ -910,17 +913,17 @@ public class RoomServiceImpl implements RoomService {
|
|
|
//原音
|
|
|
courseScheduleStudentMusicScoreDao.openPlayStatus(scheduleId, data.getMusicScoreAccompanimentId(), Integer.parseInt(userId));
|
|
|
imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
|
|
|
- }else if(typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)){
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
//关闭所有曲目播放
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
|
|
|
- courseScheduleStudentMusicScoreDao.openAccompanimentPlayStatus(scheduleId,data.getMusicScoreAccompanimentId(),Integer.parseInt(userId));
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId, Integer.parseInt(userId), null);
|
|
|
+ courseScheduleStudentMusicScoreDao.openAccompanimentPlayStatus(scheduleId, data.getMusicScoreAccompanimentId(), Integer.parseInt(userId));
|
|
|
DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
|
|
|
deviceResourceMessage.setMusicScoreAccompanimentId(data.getMusicScoreAccompanimentId());
|
|
|
deviceResourceMessage.setUserId(userId);
|
|
|
deviceResourceMessage.setSoundVolume(data.getSoundVolume());
|
|
|
imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
String ticket = IdentifierUtils.uuid();
|
|
|
ControlDeviceTaskInfo taskInfo = new ControlDeviceTaskInfo();
|
|
|
taskInfo.setRoomId(roomId);
|
|
@@ -940,30 +943,30 @@ public class RoomServiceImpl implements RoomService {
|
|
|
} else {
|
|
|
if (typeEnum.equals(DeviceTypeEnum.Camera)) {
|
|
|
roomMemberDao.updateCameraByRidAndUid(roomId, userId, false);
|
|
|
- } else if (typeEnum.equals(DeviceTypeEnum.Microphone)){
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.Microphone)) {
|
|
|
roomMemberDao.updateMicByRidAndUid(roomId, userId, false);
|
|
|
- } else if (typeEnum.equals(DeviceTypeEnum.HandUp)){
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.HandUp)) {
|
|
|
roomMemberDao.updateHandByRidAndUid(roomId, userId, false);
|
|
|
- } else if (typeEnum.equals(DeviceTypeEnum.ExamSong)){
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.ExamSong)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
ExamSongDownloadData msg;
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, Integer.parseInt(userId));
|
|
|
- if(StringUtils.isEmpty(examJson)){
|
|
|
+ if (StringUtils.isEmpty(examJson)) {
|
|
|
throw new BizException("学员伴奏信息异常");
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
msg.setEnable(enable);
|
|
|
}
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,Integer.parseInt(userId),JSON.toJSONString(msg));
|
|
|
- }else if(typeEnum.equals(DeviceTypeEnum.MusicScore)){
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(scheduleId, Integer.parseInt(userId), JSON.toJSONString(msg));
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.MusicScore)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
//关闭所有曲目播放
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
|
|
|
- }else if(typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)){
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId, Integer.parseInt(userId), null);
|
|
|
+ } else if (typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
//关闭所有曲目播放
|
|
|
- courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
|
|
|
- }else {
|
|
|
+ courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId, Integer.parseInt(userId), null);
|
|
|
+ } else {
|
|
|
roomMemberDao.updateMusicByRidAndUid(roomId, userId, false);
|
|
|
}
|
|
|
DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), false);
|
|
@@ -980,28 +983,28 @@ public class RoomServiceImpl implements RoomService {
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Boolean batchControlDevice(ReqDeviceControlData data) throws Exception {
|
|
|
- if(data.getExamSongOn() != null || data.getMusicScoreOn() != null || data.getAccompanimentOn() != null){
|
|
|
+ if (data.getExamSongOn() != null || data.getMusicScoreOn() != null || data.getAccompanimentOn() != null) {
|
|
|
List<BasicUserDto> students = courseScheduleStudentPaymentDao.findStudents(Long.parseLong(data.getRoomId().substring(1)));
|
|
|
- for (BasicUserDto e:students) {
|
|
|
+ for (BasicUserDto e : students) {
|
|
|
data.setUserId(e.getUserId().toString());
|
|
|
controlDevice(data);
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
List<RoomMember> roomMembers;
|
|
|
- if(StringUtils.isNotEmpty(data.getUserId())){
|
|
|
+ if (StringUtils.isNotEmpty(data.getUserId())) {
|
|
|
roomMembers = new ArrayList<>();
|
|
|
String[] split = data.getUserId().split(",");
|
|
|
for (int i = 0; i < split.length; i++) {
|
|
|
roomMembers.add(new RoomMember(split[i]));
|
|
|
}
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
roomMembers = roomMemberDao.findByRidAndRole(data.getRoomId(), RoleStudent.getValue());
|
|
|
}
|
|
|
- if(roomMembers.size() == 0){
|
|
|
+ if (roomMembers.size() == 0) {
|
|
|
return false;
|
|
|
}
|
|
|
- for (RoomMember e:roomMembers) {
|
|
|
+ for (RoomMember e : roomMembers) {
|
|
|
data.setUserId(e.getUid());
|
|
|
controlDevice(data);
|
|
|
}
|
|
@@ -1020,18 +1023,18 @@ public class RoomServiceImpl implements RoomService {
|
|
|
ControlDeviceTaskInfo taskInfo = (ControlDeviceTaskInfo) scheduleManager.executeTask(ticket);
|
|
|
if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.Camera)) {
|
|
|
roomMemberDao.updateCameraByRidAndUid(roomId, userId, taskInfo.isOnOff());
|
|
|
- }else if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.ExamSong)) {
|
|
|
+ } else if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.ExamSong)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
ExamSongDownloadData msg;
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
|
|
|
- if(StringUtils.isEmpty(examJson)){
|
|
|
+ if (StringUtils.isEmpty(examJson)) {
|
|
|
throw new BizException("学员伴奏信息异常");
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
msg.setEnable(true);
|
|
|
}
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
|
|
|
- }else {
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(scheduleId, authUser.getId(), JSON.toJSONString(msg));
|
|
|
+ } else {
|
|
|
roomMemberDao.updateMicByRidAndUid(roomId, userId, taskInfo.isOnOff());
|
|
|
}
|
|
|
ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Approve.ordinal());
|
|
@@ -1078,13 +1081,13 @@ public class RoomServiceImpl implements RoomService {
|
|
|
} else if (data.getMusicModeOn() != null) {
|
|
|
type = DeviceTypeEnum.MusicMode;
|
|
|
enable = data.getMusicModeOn();
|
|
|
- } else if (data.getHandUpOn() != null) {
|
|
|
+ } else if (data.getHandUpOn() != null) {
|
|
|
type = DeviceTypeEnum.HandUp;
|
|
|
enable = data.getHandUpOn();
|
|
|
- } else if (data.getExamSongOn() != null) {
|
|
|
+ } else if (data.getExamSongOn() != null) {
|
|
|
type = DeviceTypeEnum.ExamSong;
|
|
|
enable = data.getExamSongOn();
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
throw new ApiException(ErrorEnum.ERR_REQUEST_PARA_ERR);
|
|
|
}
|
|
|
SysUser authUser = sysUserFeignService.queryUserInfo();
|
|
@@ -1093,22 +1096,22 @@ public class RoomServiceImpl implements RoomService {
|
|
|
DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
|
|
|
if (type.equals(DeviceTypeEnum.Camera)) {
|
|
|
roomMemberDao.updateCameraByRidAndUid(roomId, userId, enable);
|
|
|
- } else if (type.equals(DeviceTypeEnum.Microphone)){
|
|
|
+ } else if (type.equals(DeviceTypeEnum.Microphone)) {
|
|
|
roomMemberDao.updateMicByRidAndUid(roomId, userId, enable);
|
|
|
- } else if (type.equals(DeviceTypeEnum.HandUp)){
|
|
|
+ } else if (type.equals(DeviceTypeEnum.HandUp)) {
|
|
|
roomMemberDao.updateHandByRidAndUid(roomId, userId, enable);
|
|
|
- } else if (type.equals(DeviceTypeEnum.ExamSong)){
|
|
|
+ } else if (type.equals(DeviceTypeEnum.ExamSong)) {
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
ExamSongDownloadData msg;
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
|
|
|
- if(StringUtils.isEmpty(examJson)){
|
|
|
+ if (StringUtils.isEmpty(examJson)) {
|
|
|
throw new BizException("学员伴奏信息异常");
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
msg.setEnable(enable);
|
|
|
}
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
|
|
|
- }else {
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(scheduleId, authUser.getId(), JSON.toJSONString(msg));
|
|
|
+ } else {
|
|
|
roomMemberDao.updateMusicByRidAndUid(roomId, userId, enable);
|
|
|
}
|
|
|
Room room = roomDao.findByRid(roomId);
|
|
@@ -1124,13 +1127,13 @@ public class RoomServiceImpl implements RoomService {
|
|
|
public List<RoomResult.MemberResult> getMembers(String roomId) throws Exception {
|
|
|
CheckUtils.checkArgument(roomId != null, "roomId must't be null");
|
|
|
List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
|
|
|
- if(roomMemberList != null && roomMemberList.size() > 0){
|
|
|
+ if (roomMemberList != null && roomMemberList.size() > 0) {
|
|
|
List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(null, Long.parseLong(roomId.substring(1)), null, null, null);
|
|
|
RoomResult roomResult = new RoomResult();
|
|
|
Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
|
|
|
- Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,roomId.substring(1)));
|
|
|
- Map<Integer,String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds,roomId.substring(1)));
|
|
|
- roomResult.setMembers(roomMemberList,midiMap,examSongMap,scheduleStudentMusicScores);
|
|
|
+ Map<Integer, String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds, roomId.substring(1)));
|
|
|
+ Map<Integer, String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds, roomId.substring(1)));
|
|
|
+ roomResult.setMembers(roomMemberList, midiMap, examSongMap, scheduleStudentMusicScores);
|
|
|
return roomResult.getMembers();
|
|
|
}
|
|
|
return null;
|
|
@@ -1506,7 +1509,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
roomMemberDao.deleteUserByRidAndUid(member.getRid(), member.getUid());
|
|
|
roomDao.deleteByRid(member.getRid());
|
|
|
deleteWhiteboardByUser(member.getRid(), member.getUid());
|
|
|
- log.info("dismiss the room: {},userId: {}", member.getRid(),userId);
|
|
|
+ log.info("dismiss the room: {},userId: {}", member.getRid(), userId);
|
|
|
} else {
|
|
|
log.error("{} exit {} room error: {}", member.getUid(), member.getRid(), apiResultInfo.getErrorMessage());
|
|
|
}
|
|
@@ -1535,17 +1538,17 @@ public class RoomServiceImpl implements RoomService {
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData) throws Exception {
|
|
|
SysUser sysUser = sysUserFeignService.queryUserInfo();
|
|
|
- if(sysUser == null){
|
|
|
+ if (sysUser == null) {
|
|
|
throw new BizException("用户信息获取失败");
|
|
|
}
|
|
|
String content = playMidiMessageData.getContent();
|
|
|
String roomId = playMidiMessageData.getRoomId();
|
|
|
- CustomMessage customMessage = JSONObject.parseObject(content,CustomMessage.class);
|
|
|
+ CustomMessage customMessage = JSONObject.parseObject(content, CustomMessage.class);
|
|
|
String userId = sysUser.getId().toString();
|
|
|
MetronomeMessageMessage displayMessage = new MetronomeMessageMessage(customMessage);
|
|
|
imHelper.publishMessage(userId, roomId, displayMessage, 1);
|
|
|
//记录节拍器消息
|
|
|
- courseScheduleStudentPaymentDao.adjustPlayMidi(Long.parseLong(roomId.substring(1)),playMidiMessageData.getUserId(),content);
|
|
|
+ courseScheduleStudentPaymentDao.adjustPlayMidi(Long.parseLong(roomId.substring(1)), playMidiMessageData.getUserId(), content);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -1556,13 +1559,13 @@ public class RoomServiceImpl implements RoomService {
|
|
|
Long courseScheduleId = Long.parseLong(roomId.substring(1));
|
|
|
List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores =
|
|
|
courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(musicScoreData.getMusicScoreAccompanimentId(),
|
|
|
- courseScheduleId,null,null,0);
|
|
|
+ courseScheduleId, null, null, 0);
|
|
|
SysMusicScoreAccompaniment accompaniment = sysMusicScoreAccompanimentDao.get(musicScoreData.getMusicScoreAccompanimentId());
|
|
|
- if(scheduleStudentMusicScores.size() == 0){
|
|
|
+ if (scheduleStudentMusicScores.size() == 0) {
|
|
|
//第一次下载,生成数据
|
|
|
List<CourseScheduleStudentPayment> courseScheduleStudentPayments = courseScheduleStudentPaymentDao.findByCourseSchedule(courseScheduleId);
|
|
|
Set<Integer> studentIds = courseScheduleStudentPayments.stream().map(e -> e.getUserId()).collect(Collectors.toSet());
|
|
|
- studentIds.forEach(e->{
|
|
|
+ studentIds.forEach(e -> {
|
|
|
CourseScheduleStudentMusicScore musicScore = new CourseScheduleStudentMusicScore();
|
|
|
musicScore.setMusicScoreAccompanimentId(accompaniment.getId());
|
|
|
musicScore.setSpeed(accompaniment.getSpeed());
|
|
@@ -1590,7 +1593,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
SysUser authUser = sysUserFeignService.queryUserInfo();
|
|
|
|
|
|
SysExamSong sysExamSong = sysExamSongDao.get(examSongId);
|
|
|
- if(sysExamSong == null){
|
|
|
+ if (sysExamSong == null) {
|
|
|
throw new BizException("曲目信息不存在");
|
|
|
}
|
|
|
//学员曲目下载状态改为未下载
|
|
@@ -1599,7 +1602,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
json.setUrl(sysExamSong.getUrl());
|
|
|
json.setStatus(0);
|
|
|
json.setExamSongId(examSongId);
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(Long.parseLong(roomId.substring(1)),null, JSON.toJSONString(json));
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(Long.parseLong(roomId.substring(1)), null, JSON.toJSONString(json));
|
|
|
|
|
|
ExamSongMessage examSongMessage = new ExamSongMessage();
|
|
|
examSongMessage.setExamSongName(sysExamSong.getName());
|
|
@@ -1611,7 +1614,7 @@ public class RoomServiceImpl implements RoomService {
|
|
|
|
|
|
@Override
|
|
|
public List<RongyunBasicUserDto> queryNoJoinStu(String roomId) {
|
|
|
- return courseScheduleStudentPaymentDao.queryNoJoinStu(roomId,roomId.substring(1));
|
|
|
+ return courseScheduleStudentPaymentDao.queryNoJoinStu(roomId, roomId.substring(1));
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -1622,14 +1625,14 @@ public class RoomServiceImpl implements RoomService {
|
|
|
String roomId = musicScoreData.getRoomId();
|
|
|
Long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
Integer accompanimentId = musicScoreData.getMusicScoreAccompanimentId();
|
|
|
- List<CourseScheduleStudentMusicScore> studentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(accompanimentId,scheduleId,studentId,null,null);
|
|
|
- if(accompanimentId != null){
|
|
|
+ List<CourseScheduleStudentMusicScore> studentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(accompanimentId, scheduleId, studentId, null, null);
|
|
|
+ if (accompanimentId != null) {
|
|
|
SysMusicScoreAccompaniment accompaniment = sysMusicScoreAccompanimentDao.get(accompanimentId);
|
|
|
- if(accompaniment == null){
|
|
|
+ if (accompaniment == null) {
|
|
|
throw new BizException("曲目信息不存在");
|
|
|
}
|
|
|
//修改下载状态
|
|
|
- if(studentMusicScores == null || studentMusicScores.size() == 0){
|
|
|
+ if (studentMusicScores == null || studentMusicScores.size() == 0) {
|
|
|
throw new BizException("学员不存在此下载曲目");
|
|
|
}
|
|
|
CourseScheduleStudentMusicScore studentMusicScore = studentMusicScores.get(0);
|
|
@@ -1638,41 +1641,41 @@ public class RoomServiceImpl implements RoomService {
|
|
|
}
|
|
|
//给老师发送学员曲目下载状态
|
|
|
CourseSchedule courseSchedule = courseScheduleDao.get(scheduleId);
|
|
|
- MusicScoreDownloadStatusMessage statusMessage = new MusicScoreDownloadStatusMessage(studentId,studentMusicScores);
|
|
|
- imHelper.publishMessage(studentId.toString(),courseSchedule.getActualTeacherId().toString(), roomId,statusMessage);
|
|
|
+ MusicScoreDownloadStatusMessage statusMessage = new MusicScoreDownloadStatusMessage(studentId, studentMusicScores);
|
|
|
+ imHelper.publishMessage(studentId.toString(), courseSchedule.getActualTeacherId().toString(), roomId, statusMessage);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public void adjustExamSong(String roomId, Integer status,Integer examSongId) throws Exception {
|
|
|
- if(roomId == null || status == null || examSongId == null){
|
|
|
+ public void adjustExamSong(String roomId, Integer status, Integer examSongId) throws Exception {
|
|
|
+ if (roomId == null || status == null || examSongId == null) {
|
|
|
throw new BizException("参数校验失败");
|
|
|
}
|
|
|
SysUser authUser = sysUserFeignService.queryUserInfo();
|
|
|
long scheduleId = Long.parseLong(roomId.substring(1));
|
|
|
|
|
|
SysExamSong sysExamSong = sysExamSongDao.get(examSongId);
|
|
|
- if(sysExamSong == null){
|
|
|
+ if (sysExamSong == null) {
|
|
|
throw new BizException("曲目信息不存在");
|
|
|
}
|
|
|
ExamSongDownloadData msg;
|
|
|
String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
|
|
|
- if(StringUtils.isEmpty(examJson)){
|
|
|
+ if (StringUtils.isEmpty(examJson)) {
|
|
|
msg = new ExamSongDownloadData();
|
|
|
msg.setExamSongName(sysExamSong.getName());
|
|
|
msg.setUrl(sysExamSong.getUrl());
|
|
|
msg.setStatus(status);
|
|
|
msg.setExamSongId(examSongId);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
|
|
|
msg.setStatus(status);
|
|
|
}
|
|
|
- courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
|
|
|
+ courseScheduleStudentPaymentDao.adjustExamSong(scheduleId, authUser.getId(), JSON.toJSONString(msg));
|
|
|
|
|
|
//给老师发送学员曲目下载状态
|
|
|
CourseSchedule courseSchedule = courseScheduleDao.get(scheduleId);
|
|
|
- ExamSongDownloadStatusMessage deviceResourceMessage = new ExamSongDownloadStatusMessage(status,authUser.getId(),examSongId);
|
|
|
- imHelper.publishMessage(authUser.getId().toString(),courseSchedule.getActualTeacherId().toString(), roomId, deviceResourceMessage);
|
|
|
+ ExamSongDownloadStatusMessage deviceResourceMessage = new ExamSongDownloadStatusMessage(status, authUser.getId(), examSongId);
|
|
|
+ imHelper.publishMessage(authUser.getId().toString(), courseSchedule.getActualTeacherId().toString(), roomId, deviceResourceMessage);
|
|
|
}
|
|
|
|
|
|
public void updateDisplay(String roomId, String senderId, String display, Integer isIncludeSender) throws Exception {
|