|  | @@ -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 {
 |