RoomServiceImpl.java 81 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647
  1. package com.ym.service.Impl;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.alibaba.fastjson.serializer.SerializerFeature;
  5. import com.ym.common.ApiException;
  6. import com.ym.common.BaseResponse;
  7. import com.ym.common.DisplayEnum;
  8. import com.ym.common.ErrorEnum;
  9. import com.ym.config.IMProperties;
  10. import com.ym.config.RoomProperties;
  11. import com.ym.dao.*;
  12. import com.ym.job.ScheduleManager;
  13. import com.ym.mec.auth.api.client.SysUserFeignService;
  14. import com.ym.mec.auth.api.entity.SysUser;
  15. import com.ym.mec.biz.dal.dao.*;
  16. import com.ym.mec.biz.dal.dao.CourseScheduleStudentMusicScoreDao;
  17. import com.ym.mec.biz.dal.dto.BasicUserDto;
  18. import com.ym.mec.biz.dal.dto.RongyunBasicUserDto;
  19. import com.ym.mec.biz.dal.entity.*;
  20. import com.ym.mec.biz.dal.enums.GroupType;
  21. import com.ym.mec.biz.dal.enums.TeachModeEnum;
  22. import com.ym.mec.biz.service.StudentAttendanceService;
  23. import com.ym.mec.biz.service.SysConfigService;
  24. import com.ym.mec.biz.service.TeacherAttendanceService;
  25. import com.ym.mec.common.exception.BizException;
  26. import com.ym.mec.im.IMHelper;
  27. import com.ym.mec.im.message.*;
  28. import com.ym.mec.util.collection.MapUtil;
  29. import com.ym.mec.util.date.DateUtil;
  30. import com.ym.pojo.*;
  31. import com.ym.service.RoomService;
  32. import com.ym.utils.CheckUtils;
  33. import com.ym.utils.CodeUtil;
  34. import com.ym.utils.DateTimeUtils;
  35. import com.ym.utils.IdentifierUtils;
  36. import com.ym.whiteboard.WhiteBoardHelper;
  37. import lombok.extern.slf4j.Slf4j;
  38. import org.apache.commons.lang3.StringUtils;
  39. import org.springframework.beans.factory.annotation.Autowired;
  40. import org.springframework.data.redis.core.RedisTemplate;
  41. import org.springframework.stereotype.Service;
  42. import org.springframework.transaction.annotation.Isolation;
  43. import org.springframework.transaction.annotation.Propagation;
  44. import org.springframework.transaction.annotation.Transactional;
  45. import java.util.*;
  46. import java.util.concurrent.TimeUnit;
  47. import java.util.stream.Collectors;
  48. import static com.ym.pojo.RoleEnum.RoleStudent;
  49. import static com.ym.pojo.RoleEnum.RoleTeacher;
  50. /**
  51. * Created by super_zou on 2019/11/28.
  52. */
  53. @Slf4j
  54. @Service
  55. public class RoomServiceImpl implements RoomService {
  56. @Autowired
  57. private IMHelper imHelper;
  58. @Autowired
  59. private RoomProperties roomProperties;
  60. @Autowired
  61. private RoomDao roomDao;
  62. @Autowired
  63. private RoomMemberDao roomMemberDao;
  64. @Autowired
  65. private CourseScheduleStudentPaymentDao courseScheduleStudentPaymentDao;
  66. @Autowired
  67. private WhiteBoardHelper whiteBoardHelper;
  68. @Autowired
  69. private WhiteboardDao whiteboardDao;
  70. @Autowired
  71. private ScheduleManager scheduleManager;
  72. @Autowired
  73. private UserDao userDao;
  74. @Autowired
  75. private TeacherDao teacherDao;
  76. @Autowired
  77. private CourseScheduleDao courseScheduleDao;
  78. @Autowired
  79. private TeacherAttendanceService teacherAttendanceService;
  80. @Autowired
  81. private StudentAttendanceService studentAttendanceService;
  82. @Autowired
  83. private IMProperties imProperties;
  84. @Autowired
  85. private SysUserFeignService sysUserFeignService;
  86. @Autowired
  87. private SysExamSongDao sysExamSongDao;
  88. @Autowired
  89. private SysConfigDao sysConfigDao;
  90. @Autowired
  91. private CourseScheduleStudentMusicScoreDao courseScheduleStudentMusicScoreDao;
  92. @Autowired
  93. private SysMusicScoreAccompanimentDao sysMusicScoreAccompanimentDao;
  94. @Autowired
  95. private RedisTemplate<String,String> redisTemplate;
  96. @Override
  97. public Integer getCurrentCourseId(String roomId){
  98. String continueCourseTime = sysConfigDao.findConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME);
  99. if(StringUtils.isEmpty(continueCourseTime)){
  100. continueCourseTime = "5";
  101. }
  102. CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
  103. CourseSchedule schedule = courseSchedule;
  104. //如果当前课程是连堂课,那么获取第一节课的课程编号
  105. while (true){
  106. String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  107. String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  108. schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
  109. if(schedule != null){
  110. roomId = schedule.getId().toString();
  111. }else {
  112. break;
  113. }
  114. }
  115. return Integer.parseInt(roomId);
  116. }
  117. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  118. @Override
  119. public RoomResult joinRoom(String roomId) throws Exception {
  120. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  121. SysUser sysUser = sysUserFeignService.queryUserInfo();
  122. String userId = sysUser.getId().toString();
  123. log.info("joinRoom: roomId={}, userId={}", roomId, userId);
  124. Teacher teacher = teacherDao.get(Integer.parseInt(userId));
  125. CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
  126. if(courseSchedule.getTeachMode() == TeachModeEnum.OFFLINE){
  127. throw new ApiException(ErrorEnum.JOIN_ROOM_ERROR);
  128. }
  129. String continueCourseTime = sysConfigDao.findConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME);
  130. if(StringUtils.isEmpty(continueCourseTime)){
  131. continueCourseTime = "5";
  132. }
  133. String autoCloseNetworkRoomTime = sysConfigDao.findConfigValue(SysConfigService.AUTO_CLOSE_NETWORK_ROOM);
  134. if(StringUtils.isEmpty(autoCloseNetworkRoomTime)){
  135. continueCourseTime = "15";
  136. }
  137. RoomResult roomResult = new RoomResult();
  138. roomResult.setAutoCloseNetworkRoomTime(autoCloseNetworkRoomTime);
  139. CourseSchedule schedule = courseSchedule;
  140. //如果当前课程是连堂课,那么获取第一节课的课程编号
  141. while (true){
  142. String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  143. String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  144. schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
  145. if(schedule != null){
  146. roomId = schedule.getId().toString();
  147. roomResult.setAutoCloseFlag(false);
  148. }else {
  149. break;
  150. }
  151. }
  152. Long courseId = Long.parseLong(roomId);
  153. //记录用户实际选择的房间
  154. if(courseSchedule.getGroupType() == GroupType.COMM){
  155. roomId = "I" + roomId;
  156. }else {
  157. roomId = "S" + roomId;
  158. }
  159. redisTemplate.opsForValue().setIfAbsent(roomId + userId,courseSchedule.getId().toString());
  160. log.info("joinRoom current: roomId={}, userId={}", roomId, userId);
  161. Date curTime = DateTimeUtils.currentUTC();
  162. RoleEnum roleEnum;
  163. RoomResult.MemberResult userResult = new RoomResult.MemberResult();
  164. RoomMember member = roomMemberDao.findByRidAndUid(roomId, userId);
  165. String userName;
  166. if (member == null) {
  167. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  168. if (count == roomProperties.getMaxCount()) {
  169. log.info("join error Over max count: roomId = {}, userId = {}", roomId,userId);
  170. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  171. }
  172. if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
  173. roleEnum = RoleTeacher;
  174. userName = sysUser.getRealName();
  175. }else {
  176. roleEnum = RoleStudent;
  177. userName = sysUser.getUsername();
  178. }
  179. userResult.setMicrophone(true);
  180. userResult.setCamera(true);
  181. userResult.setHandUpOn(false);
  182. userResult.setJoinTime(curTime);
  183. saveRoomMember(userId,sysUser.getAvatar(), userName, roomId, roleEnum.getValue(), curTime);
  184. } else {
  185. roleEnum = RoleEnum.getEnumByValue(member.getRole());
  186. if(roleEnum == RoleTeacher){
  187. courseScheduleStudentPaymentDao.adjustPlayMidi(courseId,null,null);
  188. }
  189. userName = member.getName();
  190. userResult.setCamera(member.isCamera());
  191. userResult.setHandUpOn(member.isHand());
  192. userResult.setJoinTime(member.getJoinDt());
  193. }
  194. imHelper.joinGroup(new String[]{userId}, roomId, roomId);
  195. List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(null, courseId,null, null, null);
  196. String display = "";
  197. if (roleEnum == RoleTeacher) {
  198. display = "display://type=1?userId=" + userId + "?uri=";
  199. } else if (roleEnum == RoleEnum.RoleAssistant && display.isEmpty()) {
  200. display = "display://type=0?userId=" + userId + "?uri=";
  201. }else {
  202. ExamSongDownloadData examSongDownloadData;
  203. String json = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(courseId, sysUser.getId());
  204. if(StringUtils.isEmpty(json)){
  205. examSongDownloadData = new ExamSongDownloadData();
  206. }else {
  207. examSongDownloadData = JSON.parseObject(json,ExamSongDownloadData.class);
  208. }
  209. //获取学员曲目下载状态
  210. userResult.setExamSongDownloadJson(examSongDownloadData);
  211. Room room = roomDao.findByRid(roomId);
  212. if (room != null) {
  213. display = room.getDisplay();
  214. }
  215. }
  216. //已下载的伴奏列表
  217. if(scheduleStudentMusicScores != null && scheduleStudentMusicScores.size() > 0){
  218. List<CourseScheduleStudentMusicScore> musicScores = scheduleStudentMusicScores.stream().filter(e -> e.getUserId().equals(sysUser.getId())).collect(Collectors.toList());
  219. String toJSONString = JSON.toJSONString(musicScores, SerializerFeature.DisableCircularReferenceDetect);
  220. List<CourseScheduleStudentMusicScore> lists = JSON.parseArray(toJSONString, CourseScheduleStudentMusicScore.class);
  221. userResult.setScheduleStudentMusicScores(lists);
  222. }
  223. userResult.setUserName(userName);
  224. userResult.setUserId(userId);
  225. userResult.setRole(roleEnum.getValue());
  226. //获取节拍器信息
  227. String midi = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(courseId.toString(),userId);
  228. userResult.setPlayMidiJson(JSONObject.parseObject(midi,CustomMessage.class));
  229. //获取当前课程剩余时长
  230. String classDate = DateUtil.format(courseSchedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  231. String endClassTime = DateUtil.format(courseSchedule.getEndClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  232. roomResult.setSurplusTime(DateUtil.secondsBetween(new Date(),DateUtil.stringToDate(classDate + " " + endClassTime,DateUtil.EXPANDED_DATE_TIME_FORMAT)));
  233. roomResult.setUserInfo(userResult);
  234. roomResult.setDisplay(display);
  235. roomResult.setRoomId(roomId);
  236. List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
  237. if(roomMemberList != null && roomMemberList.size() > 0){
  238. Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
  239. Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,courseId.toString()));
  240. Map<Integer,String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds,courseId.toString()));
  241. roomResult.setMembers(roomMemberList,midiMap,examSongMap,scheduleStudentMusicScores);
  242. }
  243. roomResult.setWhiteboards(whiteboardDao.findByRid(roomId));
  244. log.info("join room: roomId = {}, userId = {}, userName={}, role = {}", roomId, userId, userName, roleEnum);
  245. return roomResult;
  246. }
  247. public RoomMember saveRoomMember(String roomId,String userId){
  248. SysUser sysUser = sysUserFeignService.queryUserById(Integer.parseInt(userId));
  249. Teacher teacher = teacherDao.get(Integer.parseInt(userId));
  250. CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId.substring(1)));
  251. Date curTime = DateTimeUtils.currentUTC();
  252. RoleEnum roleEnum;
  253. RoomMember member = roomMemberDao.findByRidAndUid(roomId, userId);
  254. String userName;
  255. if (member == null) {
  256. if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
  257. roleEnum = RoleTeacher;
  258. userName = sysUser.getRealName();
  259. }else {
  260. roleEnum = RoleStudent;
  261. userName = sysUser.getUsername();
  262. }
  263. member = saveRoomMember(userId, sysUser.getAvatar(), userName, roomId, roleEnum.getValue(), curTime);
  264. }
  265. return member;
  266. }
  267. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  268. @Override
  269. public void joinRoomFailure(String roomId, String userId) {
  270. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  271. if(roomMember == null){
  272. return ;
  273. }
  274. log.info("joinRoomFailure : roomId={}, userId={}", roomId, userId);
  275. //如果加入失败,删除该用户数据
  276. roomMemberDao.deleteUserByRidAndUid(roomId,userId);
  277. }
  278. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  279. @Override
  280. public void joinRoomSuccess(String roomId,String userId,String deviceNum) throws Exception {
  281. log.info("joinRoomSuccess: roomId={}, userId={}, deviceNum={}", roomId,userId,deviceNum);
  282. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  283. if(roomMember == null){
  284. roomMember = saveRoomMember(roomId,userId);
  285. }
  286. String joinSuccessKey = "joinRoomSuccess"+ roomId + userId;
  287. Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent(joinSuccessKey, roomId, 2l, TimeUnit.SECONDS);
  288. if(!aBoolean){
  289. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  290. if(roleEnum == RoleTeacher && StringUtils.isNotEmpty(deviceNum)){
  291. signInSuccess(roomMember,deviceNum);
  292. }
  293. return;
  294. }
  295. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  296. CourseSchedule schedule = courseScheduleDao.getLock(Long.parseLong(roomId.substring(1)));
  297. String display = "";
  298. if(roleEnum == RoleTeacher){
  299. //如果是老师加入房间,调整节拍器状态
  300. courseScheduleStudentPaymentDao.adjustPlayMidi(schedule.getId(),null,null);
  301. display = "display://type=1?userId=" + userId + "?uri=";
  302. }else if (roleEnum == RoleEnum.RoleAssistant){
  303. display = "display://type=0?userId=" + userId + "?uri=";
  304. }
  305. Date curTime = DateTimeUtils.currentUTC();
  306. Room room = roomDao.findByRid(roomId);
  307. if (room == null) {
  308. saveRoom(roomId, roomId, curTime, display);
  309. IMApiResultInfo resultInfo = imHelper.createGroup(new String[]{userId}, roomId, roomId);
  310. if (!resultInfo.isSuccess()) {
  311. log.error("joinRoomSuccess createGroup error: roomId={}, {}", roomId, resultInfo.getErrorMessage());
  312. throw new ApiException(ErrorEnum.ERR_CREATE_ROOM_ERROR, resultInfo.getErrorMessage());
  313. }
  314. }else{
  315. if(roleEnum == RoleTeacher || roleEnum == RoleEnum.RoleAssistant){
  316. updateDisplay(roomId, userId, display, 0);
  317. }
  318. }
  319. UserInfo userInfo = userDao.findByUid(userId);
  320. if (userInfo == null) {
  321. userInfo = new UserInfo();
  322. userInfo.setUid(userId);
  323. userInfo.setName(roomMember.getName());
  324. userInfo.setCreateDt(curTime);
  325. userInfo.setUpdateDt(curTime);
  326. userDao.save(userInfo);
  327. }
  328. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Join, userId, roleEnum.getValue());
  329. msg.setTimestamp(curTime);
  330. msg.setUserName(roomMember.getName());
  331. msg.setCamera(true);
  332. Boolean playMidi = false;
  333. Boolean examSong = false;
  334. if(roleEnum == RoleStudent){
  335. String midiByCourseIdAndUserId = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(schedule.getId().toString(), userId);
  336. //获取节拍器信息
  337. if(StringUtils.isNotEmpty(midiByCourseIdAndUserId)){
  338. JSONObject jsonObject = JSONObject.parseObject(midiByCourseIdAndUserId);
  339. if(jsonObject.get("enable") != null){
  340. playMidi = Boolean.parseBoolean(jsonObject.get("enable").toString());
  341. }
  342. }
  343. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(schedule.getId(), Integer.parseInt(userId));
  344. if(StringUtils.isNotEmpty(examJson)){
  345. ExamSongDownloadData examSongDownloadData = JSON.parseObject(examJson, ExamSongDownloadData.class);
  346. examSong = examSongDownloadData.getEnable();
  347. }
  348. }
  349. msg.setHandUpOn(roomMember.isHand());
  350. msg.setMetronomeSwitch(playMidi);
  351. msg.setExamSongSwitch(examSong);
  352. imHelper.publishMessage(userId, roomId, msg);
  353. log.info("join room success: roomId = {}, userId = {}, role = {}", roomId, userId, roleEnum);
  354. signInSuccess(roomMember,deviceNum);
  355. }
  356. public void signInSuccess(RoomMember roomMember,String deviceNum) {
  357. String roomId = roomMember.getRid();
  358. String userId = roomMember.getUid();
  359. String currentRoomIdKey = roomId + userId;
  360. Long firstCourseId = Long.parseLong(roomId.substring(1));
  361. Long currentRoomId;
  362. if(redisTemplate.hasKey(currentRoomIdKey)){
  363. currentRoomId = Long.parseLong(redisTemplate.opsForValue().get(currentRoomIdKey));
  364. }else {
  365. log.error("signInFailure: roomId={}, userId={}", roomId, userId);
  366. currentRoomId = firstCourseId;
  367. }
  368. log.info("signInSuccess: roomId={}, userId={},currentRoomId={}", roomId, userId,currentRoomId);
  369. Integer userIdInt = Integer.parseInt(userId);
  370. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  371. if(roleEnum == RoleTeacher){
  372. teacherAttendanceService.addTeacherAttendanceSignIn(firstCourseId,userIdInt,currentRoomId,deviceNum);
  373. }else {
  374. studentAttendanceService.addStudentAttendanceSignIn(firstCourseId,userIdInt,currentRoomId);
  375. }
  376. redisTemplate.delete(roomId + userId);
  377. }
  378. public void saveRoom(String roomId, String roomName, Date createTime, String display) {
  379. Room room = new Room();
  380. room.setRid(roomId);
  381. room.setName(roomName);
  382. room.setCreateDt(createTime);
  383. room.setDisplay(display);
  384. room.setWhiteboardNameIndex(0);
  385. roomDao.save(room);
  386. }
  387. public RoomMember saveRoomMember(String userId, String headUrl, String userName, String roomId, int role, Date joinTime) {
  388. RoomMember roomMember = new RoomMember();
  389. roomMember.setUid(userId);
  390. roomMember.setName(userName);
  391. roomMember.setRid(roomId);
  392. roomMember.setRole(role);
  393. roomMember.setCamera(true);
  394. roomMember.setJoinDt(joinTime);
  395. roomMember.setMusicMode(false);
  396. roomMember.setHeadUrl(headUrl);
  397. roomMemberDao.save(roomMember);
  398. return roomMember;
  399. }
  400. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.SERIALIZABLE)
  401. @Override
  402. public void leaveRoomSuccess(String roomId,String userId,String deviceNum) throws Exception {
  403. log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={}", roomId,userId,deviceNum);
  404. Integer firstCourseId = Integer.parseInt(roomId.substring(1));
  405. RoleEnum roleEnum;
  406. int parseInt = Integer.parseInt(userId);
  407. Teacher teacher = teacherDao.get(parseInt);
  408. CourseSchedule courseSchedule = courseScheduleDao.get(firstCourseId.longValue());
  409. if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
  410. roleEnum = RoleTeacher;
  411. courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(),null,null);
  412. }else {
  413. roleEnum = RoleStudent;
  414. }
  415. String leaveSuccessKey = "leaveRoomSuccess"+ roomId + userId;
  416. Boolean aBoolean = redisTemplate.opsForValue().setIfAbsent(leaveSuccessKey, roomId, 2, TimeUnit.SECONDS);
  417. log.info("leaveRoomSuccess: roomId={}, userId={},deviceNum={},aBoolean={}", roomId,userId,deviceNum,aBoolean);
  418. if(!aBoolean){
  419. if (StringUtils.isNotEmpty(deviceNum)){
  420. //如果设备号不为空,更新设备号
  421. if(roleEnum == RoleTeacher){
  422. teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(),parseInt,deviceNum);
  423. }
  424. }
  425. return;
  426. }
  427. String username;
  428. SysUser sysUser = sysUserFeignService.queryUserById(parseInt);
  429. if(roleEnum == RoleTeacher){
  430. username = sysUser.getRealName();
  431. courseScheduleStudentPaymentDao.adjustPlayMidi(firstCourseId,null,null);
  432. courseScheduleStudentPaymentDao.adjustExamSong(firstCourseId.longValue(),null,null);
  433. teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(),parseInt,deviceNum);
  434. }else {
  435. username = sysUser.getUsername();
  436. studentAttendanceService.addStudentAttendanceSignOut(firstCourseId.longValue(),parseInt);
  437. }
  438. Room room = roomDao.findByRid(roomId);
  439. if (room == null) {
  440. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  441. userDao.deleteByUid(userId);
  442. return;
  443. }
  444. if (roleEnum != RoleStudent && isUserDisplay(room, userId)) {
  445. updateDisplay(roomId, userId, "", 0);
  446. }
  447. if (roomMemberDao.countByRid(roomId) <= 1) {
  448. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  449. roomDao.deleteByRid(roomId);
  450. deleteWhiteboardByUser(roomId, userId);
  451. imHelper.dismiss(userId, roomId);
  452. courseScheduleStudentMusicScoreDao.closePlayStatus(courseSchedule.getId(),null,null);
  453. log.info("leaveRoomSuccess dismiss the room: {},userId: {}", roomId,userId);
  454. } else {
  455. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  456. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Leave, userId, roleEnum.getValue());
  457. msg.setUserName(username);
  458. imHelper.publishMessage(userId, roomId, msg);
  459. imHelper.quit(new String[]{userId}, roomId);
  460. log.info("leaveRoomSuccess quit group: roomId={},userId: {}", roomId,userId);
  461. }
  462. userDao.deleteByUid(userId);
  463. }
  464. public void deleteWhiteboardByUser(String roomId, String userId) throws Exception {
  465. List<Whiteboard> whiteboardList = whiteboardDao.findByRidAndCreator(roomId, userId);
  466. if (!whiteboardList.isEmpty()) {
  467. whiteboardDao.deleteByRidAndCreator(roomId, userId);
  468. for (Whiteboard wb : whiteboardList) {
  469. whiteBoardHelper.destroy(wb.getWbRoom());
  470. }
  471. }
  472. }
  473. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  474. @Override
  475. public void destroyRoom(String roomId) {
  476. whiteboardDao.deleteByRid(roomId);
  477. Room room = roomDao.findByRid(roomId);
  478. if (room == null) {
  479. List<RoomMember> list = roomMemberDao.findByRid(roomId);
  480. if (!list.isEmpty()) {
  481. try {
  482. imHelper.dismiss(list.get(0).getUid(), roomId);
  483. } catch (Exception e) {
  484. log.error("destroyRoom: {}", e.getMessage());
  485. e.printStackTrace();
  486. }
  487. }
  488. roomMemberDao.deleteByRid(roomId);
  489. log.info("destroyRoom: {}", roomId);
  490. }
  491. }
  492. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  493. @Override
  494. public Boolean downgrade(String roomId, List<ReqChangeUserRoleData.ChangedUser> users) throws Exception {
  495. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  496. CheckUtils.checkArgument(users.size() > 0, "the changed user list must't be null");
  497. SysUser authUser = sysUserFeignService.queryUserInfo();
  498. String userId = authUser.getId().toString();
  499. Room room = roomDao.findByRid(roomId);
  500. if (room == null) {
  501. throw new ApiException(ErrorEnum.ERR_ROOM_NOT_EXIST);
  502. }
  503. boolean result = false;
  504. List<RoleChangedMessage.ChangedUser> changedUsers = new ArrayList<>();
  505. for (ReqChangeUserRoleData.ChangedUser user : users) {
  506. String changedUserId = user.getUserId();
  507. RoleEnum changedRole = RoleEnum.getEnumByValue(user.getRole());
  508. if (changedUserId.equals(userId)) {
  509. log.error("can not change self role: {}, {}, {}", roomId, userId, changedRole);
  510. throw new ApiException(ErrorEnum.ERR_CHANGE_SELF_ROLE);
  511. } else {
  512. RoomMember oldUser = roomMemberDao.findByRidAndUid(roomId, changedUserId);
  513. if (oldUser != null) {
  514. if (changedRole.equals(RoleEnum.RoleAudience)) {
  515. int r = roomMemberDao.updateRoleByRidAndUid(roomId, changedUserId, changedRole.getValue());
  516. RoleChangedMessage.ChangedUser u = new RoleChangedMessage.ChangedUser(changedUserId, changedRole.getValue());
  517. UserInfo userInfo = userDao.findByUid(changedUserId);
  518. if (userInfo != null) {
  519. u.setUserName(userInfo.getName());
  520. }
  521. changedUsers.add(u);
  522. log.info("change the role: {}, {}, {}, result: {}", roomId, userId, changedRole, r);
  523. result = true;
  524. }
  525. if (oldUser.getRole() == RoleTeacher.getValue() && isUserDisplay(room, oldUser.getUid())) {
  526. updateDisplay(roomId, userId, "", 1);
  527. } else {
  528. log.info("don't update display: room={}, userRole={}", room, RoleEnum.getEnumByValue(oldUser.getRole()));
  529. }
  530. } else {
  531. log.info("role changed fail, not exist: {} - {} - {}", roomId, userId, changedRole);
  532. }
  533. }
  534. }
  535. if (result) {
  536. RoleChangedMessage msg = new RoleChangedMessage(userId);
  537. msg.setUsers(changedUsers);
  538. imHelper.publishMessage(userId, roomId, msg, 1);
  539. }
  540. return result;
  541. }
  542. @Override
  543. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  544. public Boolean kickMember(String roomId) throws Exception {
  545. SysUser authUser = sysUserFeignService.queryUserInfo();
  546. String userId = authUser.getId().toString();
  547. CheckUtils.checkArgument(userId != null, "userId must't be null");
  548. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  549. log.info("kickMember: roomId={}, userId={}", roomId, userId);
  550. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  551. if(roomMember == null){
  552. return true;
  553. }
  554. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Kick, userId, roomMember.getRole());
  555. msg.setUserName(roomMember.getName());
  556. imHelper.publishMessage(userId, roomId, msg, 1);
  557. Room room = roomDao.findByRid(roomId);
  558. if (roomMember.getRole() == RoleTeacher.getValue() && isUserDisplay(room, userId)) {
  559. updateDisplay(roomId, userId, "", 1);
  560. }
  561. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  562. userDao.deleteByUid(userId);
  563. IMApiResultInfo apiResultInfo = imHelper.quit(new String[]{userId}, roomId);
  564. if (!apiResultInfo.isSuccess()) {
  565. throw new ApiException(ErrorEnum.ERR_EXIT_ROOM_ERROR, apiResultInfo.getErrorMessage());
  566. }
  567. return true;
  568. }
  569. @Override
  570. @Transactional(rollbackFor = Exception.class)
  571. public Boolean display(String roomId, int type, String uri, String targetUserId) throws Exception {
  572. SysUser authUser = sysUserFeignService.queryUserInfo();
  573. String userId = authUser.getId().toString();
  574. log.info("display in room: {}, type = {}, uri = {}", roomId, type, uri);
  575. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  576. CheckUtils.checkArgument(type >= 0 && type < DisplayEnum.values().length, "type not exist");
  577. DisplayEnum displayEnum = DisplayEnum.values()[type];
  578. if (displayEnum.equals(DisplayEnum.None)) {
  579. roomDao.updateDisplayByRid(roomId, "");
  580. DisplayMessage displayMessage = new DisplayMessage("");
  581. IMApiResultInfo apiResultInfo = imHelper.publishMessage(userId, roomId, displayMessage);
  582. if (apiResultInfo.isSuccess()) {
  583. return true;
  584. } else {
  585. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, apiResultInfo.getErrorMessage());
  586. }
  587. }
  588. String display = "display://type=" + type;
  589. if (displayEnum.equals(DisplayEnum.Teacher)) {
  590. List<RoomMember> teachers = roomMemberDao.findByRidAndRole(roomId, RoleTeacher.getValue());
  591. if (teachers.isEmpty()) {
  592. throw new ApiException(ErrorEnum.ERR_TEACHER_NOT_EXIST_IN_ROOM);
  593. } else {
  594. display += "?userId=" + teachers.get(0).getUid() + "?uri=";
  595. roomDao.updateDisplayByRid(roomId, display);
  596. DisplayMessage displayMessage = new DisplayMessage(display);
  597. imHelper.publishMessage(userId, roomId, displayMessage);
  598. log.info("change display to teacher: roomId={}, display={}", roomId, display);
  599. }
  600. } else if (displayEnum.equals(DisplayEnum.Assistant)) {
  601. List<RoomMember> assistants = roomMemberDao.findByRidAndRole(roomId, RoleEnum.RoleAssistant.getValue());
  602. if (assistants.isEmpty()) {
  603. throw new ApiException(ErrorEnum.ERR_ASSISTANT_NOT_EXIST_IN_ROOM);
  604. } else {
  605. display += "?userId=" + assistants.get(0).getUid() + "?uri=";
  606. roomDao.updateDisplayByRid(roomId, display);
  607. DisplayMessage displayMessage = new DisplayMessage(display);
  608. imHelper.publishMessage(userId, roomId, displayMessage);
  609. log.info("change display to assistant: roomId={}, display={}", roomId, display);
  610. }
  611. } else if (displayEnum.equals(DisplayEnum.Screen)) {
  612. display += "?userId=" + userId + "?uri=";
  613. roomDao.updateDisplayByRid(roomId, display);
  614. DisplayMessage displayMessage = new DisplayMessage(display);
  615. imHelper.publishMessage(userId, roomId, displayMessage);
  616. log.info("change display to screen: roomId={}, display={}", roomId, display);
  617. } else if (displayEnum.equals(DisplayEnum.STUDENT)) {
  618. display += "?userId=" + targetUserId + "?uri=" + uri;
  619. roomDao.updateDisplayByRid(roomId, display);
  620. DisplayMessage displayMessage = new DisplayMessage(display);
  621. imHelper.publishMessage(userId, roomId, displayMessage);
  622. log.info("change display to screen: roomId={}, display={}", roomId, display);
  623. } else {
  624. display += "?userId=" + userId + "?uri=" + uri;
  625. // CheckUtils.checkArgument(uri != null, "uri must't be null");
  626. // CheckUtils.checkArgument(whiteboardDao.findByRidAndWbid(roomId, uri).size() > 0, "whiteboard not exist");
  627. roomDao.updateDisplayByRid(roomId, display);
  628. DisplayMessage displayMessage = new DisplayMessage(display);
  629. imHelper.publishMessage(userId, roomId, displayMessage);
  630. }
  631. log.info("result display in room: {}, type = {}, uri = {}", roomId, type, uri);
  632. return true;
  633. }
  634. @Override
  635. @Transactional(rollbackFor = Exception.class)
  636. public String createWhiteBoard(String roomId) throws Exception {
  637. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  638. SysUser authUser = sysUserFeignService.queryUserInfo();
  639. String userId = authUser.getId().toString();
  640. log.info("createWhiteBoard: roomId = {}", roomId);
  641. String wbRoom = IdentifierUtils.uuid();
  642. WhiteBoardApiResultInfo resultInfo = whiteBoardHelper.create(wbRoom);
  643. if (resultInfo.isSuccess()) {
  644. String wbId = resultInfo.getData();
  645. Date date = DateTimeUtils.currentUTC();
  646. Room room = roomDao.findByRid(roomId);
  647. int whiteboardNameIndex = room.getWhiteboardNameIndex() + 1;
  648. String name = "白板" + whiteboardNameIndex;
  649. roomDao.updateWhiteboardNameIndexByRid(roomId, whiteboardNameIndex);
  650. Whiteboard wb = new Whiteboard();
  651. wb.setRid(roomId);
  652. wb.setWbRoom(wbRoom);
  653. wb.setWbid(wbId);
  654. wb.setName(name);
  655. wb.setCreator(userId);
  656. wb.setCreateDt(date);
  657. wb.setCurPg(0);
  658. whiteboardDao.save(wb);
  659. WhiteboardMessage wbmsg = new WhiteboardMessage(WhiteboardMessage.Create);
  660. wbmsg.setWhiteboardId(wbId);
  661. wbmsg.setWhiteboardName(name);
  662. imHelper.publishMessage(userId, roomId, wbmsg);
  663. String display = "display://type=2?userId=" + userId + "?uri=" + wbId;
  664. roomDao.updateDisplayByRid(roomId, display);
  665. DisplayMessage displayMessage = new DisplayMessage(display);
  666. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  667. return wbId;
  668. } else {
  669. throw new ApiException(ErrorEnum.ERR_CREATE_WHITE_BOARD, resultInfo.getMsg());
  670. }
  671. }
  672. @Override
  673. @Transactional(rollbackFor = Exception.class)
  674. public Boolean deleteWhiteboard(String roomId, String whiteBoardId) throws Exception {
  675. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  676. CheckUtils.checkArgument(whiteBoardId != null, "whiteBoardId must't be null");
  677. SysUser authUser = sysUserFeignService.queryUserInfo();
  678. String userId = authUser.getId().toString();
  679. List<Whiteboard> whiteboardList = whiteboardDao.findByRidAndWbid(roomId, whiteBoardId);
  680. CheckUtils.checkArgument(whiteboardList.size() > 0, "whiteboard not exist");
  681. Room room = roomDao.findByRid(roomId);
  682. CheckUtils.checkArgument(room != null, "room not exist");
  683. log.info("deleteWhiteboard: room={}, whiteBoardId={}", room, whiteBoardId);
  684. String display = room.getDisplay();
  685. if (display.contains("uri=" + whiteBoardId)) {
  686. int result = roomDao.updateDisplayByRid(roomId, "");
  687. log.info("clear room display, room: {}, result: {}", roomId, result);
  688. DisplayMessage displayMessage = new DisplayMessage("");
  689. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  690. } else {
  691. log.info("no display to clean: room={}", room);
  692. }
  693. String wbRoom = whiteboardList.get(0).getWbRoom();
  694. WhiteBoardApiResultInfo resultInfo = whiteBoardHelper.destroy(wbRoom);
  695. if (resultInfo.isSuccess()) {
  696. int result = whiteboardDao.deleteByWbid(whiteBoardId);
  697. log.info("delete whiteboard: roomId = {}, whiteBoardId = {}, result = {}", roomId, whiteBoardId, result);
  698. WhiteboardMessage wbmsg = new WhiteboardMessage(WhiteboardMessage.Delete);
  699. wbmsg.setWhiteboardId(whiteBoardId);
  700. imHelper.publishMessage(userId, roomId, wbmsg, 1);
  701. return true;
  702. } else {
  703. throw new ApiException(ErrorEnum.ERR_DELETE_WHITE_BOARD, resultInfo.getMsg());
  704. }
  705. }
  706. @Override
  707. @Transactional(rollbackFor = Exception.class)
  708. public List<RoomResult.WhiteboardResult> getWhiteboard(String roomId) throws Exception {
  709. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  710. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  711. List<Whiteboard> whiteboards = whiteboardDao.findByRid(roomId);
  712. List<RoomResult.WhiteboardResult> result = new ArrayList<>();
  713. for (Whiteboard wb : whiteboards) {
  714. RoomResult.WhiteboardResult r = new RoomResult.WhiteboardResult();
  715. r.setName(wb.getName());
  716. r.setCurPg(wb.getCurPg());
  717. r.setWhiteboardId(wb.getWbid());
  718. result.add(r);
  719. }
  720. return result;
  721. }
  722. @Override
  723. @Transactional(rollbackFor = Exception.class)
  724. public Boolean turnWhiteBoardPage(String roomId, String whiteBoardId, int page) throws Exception {
  725. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  726. CheckUtils.checkArgument(whiteBoardId != null, "whiteBoardId must't be null");
  727. SysUser authUser = sysUserFeignService.queryUserInfo();
  728. String userId = authUser.getId().toString();
  729. Room room = roomDao.findByRid(roomId);
  730. CheckUtils.checkArgument(room != null, "room not exist");
  731. int result = whiteboardDao.updatePageByRidAndWbid(roomId, whiteBoardId, page);
  732. log.info("turn page to: {}, room: {}, wb : {}; r: {}", page, roomId, whiteBoardId, result);
  733. TurnPageMessage turnPageMessage = new TurnPageMessage(whiteBoardId, userId, page);
  734. imHelper.publishMessage(userId, roomId, turnPageMessage);
  735. return true;
  736. }
  737. @Override
  738. @Transactional(rollbackFor = Exception.class)
  739. public Boolean controlDevice(ReqDeviceControlData data) throws Exception {
  740. String roomId = data.getRoomId();
  741. String userId = data.getUserId();
  742. DeviceTypeEnum typeEnum;
  743. boolean enable;
  744. if (data.getCameraOn() != null) {
  745. typeEnum = DeviceTypeEnum.Camera;
  746. enable = data.getCameraOn();
  747. } else if (data.getMicrophoneOn() != null) {
  748. typeEnum = DeviceTypeEnum.Microphone;
  749. enable = data.getMicrophoneOn();
  750. } else if (data.getMusicModeOn() != null) {
  751. typeEnum = DeviceTypeEnum.MusicMode;
  752. enable = data.getMusicModeOn();
  753. } else if (data.getHandUpOn() != null) {
  754. typeEnum = DeviceTypeEnum.HandUp;
  755. enable = data.getHandUpOn();
  756. }else if (data.getExamSongOn() != null) {
  757. typeEnum = DeviceTypeEnum.ExamSong;
  758. enable = data.getExamSongOn();
  759. }else if (data.getMusicScoreOn() != null) {
  760. typeEnum = DeviceTypeEnum.MusicScore;
  761. enable = data.getMusicScoreOn();
  762. }else if (data.getAccompanimentOn() != null) {
  763. typeEnum = DeviceTypeEnum.MusicScoreAccompaniment;
  764. enable = data.getAccompanimentOn();
  765. } else {
  766. throw new ApiException(ErrorEnum.ERR_REQUEST_PARA_ERR);
  767. }
  768. SysUser authUser = sysUserFeignService.queryUserInfo();
  769. log.info("controlDevice: userId={}, typeEnum={}, onOff={}", userId, typeEnum, enable);
  770. if (enable) {
  771. if (typeEnum.equals(DeviceTypeEnum.ExamSong)){
  772. long scheduleId = Long.parseLong(roomId.substring(1));
  773. ExamSongDownloadData msg;
  774. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, Integer.parseInt(userId));
  775. if(StringUtils.isEmpty(examJson)){
  776. throw new BizException("学员伴奏信息异常");
  777. }else {
  778. msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
  779. msg.setEnable(enable);
  780. }
  781. courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,Integer.parseInt(userId),JSON.toJSONString(msg));
  782. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
  783. deviceResourceMessage.setUserId(userId);
  784. imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
  785. }else if(typeEnum.equals(DeviceTypeEnum.MusicScore)){
  786. long scheduleId = Long.parseLong(roomId.substring(1));
  787. //关闭所有曲目播放
  788. courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
  789. //原音
  790. courseScheduleStudentMusicScoreDao.openPlayStatus(scheduleId,data.getMusicScoreAccompanimentId());
  791. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
  792. deviceResourceMessage.setMusicScoreAccompanimentId(data.getMusicScoreAccompanimentId());
  793. deviceResourceMessage.setUserId(userId);
  794. imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
  795. }else if(typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)){
  796. long scheduleId = Long.parseLong(roomId.substring(1));
  797. //关闭所有曲目播放
  798. courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
  799. courseScheduleStudentMusicScoreDao.openAccompanimentPlayStatus(scheduleId,data.getMusicScoreAccompanimentId());
  800. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), enable);
  801. deviceResourceMessage.setMusicScoreAccompanimentId(data.getMusicScoreAccompanimentId());
  802. deviceResourceMessage.setUserId(userId);
  803. imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
  804. }else {
  805. String ticket = IdentifierUtils.uuid();
  806. ControlDeviceTaskInfo taskInfo = new ControlDeviceTaskInfo();
  807. taskInfo.setRoomId(roomId);
  808. taskInfo.setTypeEnum(typeEnum);
  809. taskInfo.setOnOff(true);
  810. taskInfo.setApplyUserId(authUser.getId().toString());
  811. taskInfo.setTargetUserId(userId);
  812. taskInfo.setTicket(ticket);
  813. scheduleManager.addTask(taskInfo);
  814. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Invite.ordinal());
  815. msg.setTicket(ticket);
  816. msg.setType(taskInfo.getTypeEnum().ordinal());
  817. msg.setOpUserId(authUser.getId().toString());
  818. msg.setOpUserName(authUser.getUsername());
  819. imHelper.publishMessage(authUser.getId().toString(), userId, roomId, msg);
  820. }
  821. } else {
  822. if (typeEnum.equals(DeviceTypeEnum.Camera)) {
  823. roomMemberDao.updateCameraByRidAndUid(roomId, userId, false);
  824. } else if (typeEnum.equals(DeviceTypeEnum.Microphone)){
  825. roomMemberDao.updateMicByRidAndUid(roomId, userId, false);
  826. } else if (typeEnum.equals(DeviceTypeEnum.HandUp)){
  827. roomMemberDao.updateHandByRidAndUid(roomId, userId, false);
  828. } else if (typeEnum.equals(DeviceTypeEnum.ExamSong)){
  829. long scheduleId = Long.parseLong(roomId.substring(1));
  830. ExamSongDownloadData msg;
  831. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, Integer.parseInt(userId));
  832. if(StringUtils.isEmpty(examJson)){
  833. throw new BizException("学员伴奏信息异常");
  834. }else {
  835. msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
  836. msg.setEnable(enable);
  837. }
  838. courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,Integer.parseInt(userId),JSON.toJSONString(msg));
  839. }else if(typeEnum.equals(DeviceTypeEnum.MusicScore)){
  840. long scheduleId = Long.parseLong(roomId.substring(1));
  841. //关闭所有曲目播放
  842. courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
  843. }else if(typeEnum.equals(DeviceTypeEnum.MusicScoreAccompaniment)){
  844. long scheduleId = Long.parseLong(roomId.substring(1));
  845. //关闭所有曲目播放
  846. courseScheduleStudentMusicScoreDao.closePlayStatus(scheduleId,Integer.parseInt(userId),null);
  847. }else {
  848. roomMemberDao.updateMusicByRidAndUid(roomId, userId, false);
  849. }
  850. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), false);
  851. deviceResourceMessage.setUserId(userId);
  852. UserInfo userInfo = userDao.findByUid(userId);
  853. if (userInfo != null) {
  854. deviceResourceMessage.setUserName(userInfo.getName());
  855. }
  856. imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
  857. }
  858. return true;
  859. }
  860. @Override
  861. @Transactional(rollbackFor = Exception.class)
  862. public Boolean batchControlDevice(ReqDeviceControlData data) throws Exception {
  863. List<RoomMember> roomMembers;
  864. if(StringUtils.isNotEmpty(data.getUserId())){
  865. roomMembers = new ArrayList<>();
  866. String[] split = data.getUserId().split(",");
  867. for (int i = 0; i < split.length; i++) {
  868. roomMembers.add(new RoomMember(split[i]));
  869. }
  870. }else {
  871. roomMembers = roomMemberDao.findByRidAndRole(data.getRoomId(), RoleStudent.getValue());
  872. }
  873. if(roomMembers.size() == 0){
  874. return false;
  875. }
  876. if (data.getExamSongOn() != null || data.getMusicScoreOn() != null || data.getAccompanimentOn() != null) {
  877. if(StringUtils.isNotEmpty(data.getUserId())){
  878. for (RoomMember e:roomMembers) {
  879. data.setUserId(e.getUid());
  880. controlDevice(data);
  881. }
  882. }else {
  883. List<BasicUserDto> students = courseScheduleStudentPaymentDao.findStudents(Long.parseLong(data.getRoomId().substring(1)));
  884. for (BasicUserDto e:students) {
  885. data.setUserId(e.getUserId().toString());
  886. controlDevice(data);
  887. }
  888. }
  889. } else {
  890. for (RoomMember e:roomMembers) {
  891. data.setUserId(e.getUid());
  892. controlDevice(data);
  893. }
  894. }
  895. return true;
  896. }
  897. @Override
  898. @Transactional(rollbackFor = Exception.class)
  899. public Boolean approveControlDevice(ReqDeviceControlData data) throws Exception {
  900. String ticket = data.getTicket();
  901. String roomId = data.getRoomId();
  902. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  903. SysUser authUser = sysUserFeignService.queryUserInfo();
  904. String userId = authUser.getId().toString();
  905. log.info("approveControlDevice: ticket={}", ticket);
  906. ControlDeviceTaskInfo taskInfo = (ControlDeviceTaskInfo) scheduleManager.executeTask(ticket);
  907. if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.Camera)) {
  908. roomMemberDao.updateCameraByRidAndUid(roomId, userId, taskInfo.isOnOff());
  909. }else if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.ExamSong)) {
  910. long scheduleId = Long.parseLong(roomId.substring(1));
  911. ExamSongDownloadData msg;
  912. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
  913. if(StringUtils.isEmpty(examJson)){
  914. throw new BizException("学员伴奏信息异常");
  915. }else {
  916. msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
  917. msg.setEnable(true);
  918. }
  919. courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
  920. }else {
  921. roomMemberDao.updateMicByRidAndUid(roomId, userId, taskInfo.isOnOff());
  922. }
  923. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Approve.ordinal());
  924. msg.setType(taskInfo.getTypeEnum().ordinal());
  925. msg.setOpUserId(userId);
  926. msg.setOpUserName(authUser.getUsername());
  927. imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  928. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(taskInfo.getTypeEnum().ordinal(), taskInfo.isOnOff());
  929. deviceResourceMessage.setUserId(userId);
  930. imHelper.publishMessage(userId, roomId, deviceResourceMessage, 1);
  931. return true;
  932. }
  933. @Override
  934. @Transactional(rollbackFor = Exception.class)
  935. public Boolean rejectControlDevice(String roomId, String ticket) throws Exception {
  936. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  937. SysUser authUser = sysUserFeignService.queryUserInfo();
  938. String userId = authUser.getId().toString();
  939. log.info("rejectControlDevice: ticket={}", ticket);
  940. ControlDeviceTaskInfo taskInfo = (ControlDeviceTaskInfo) scheduleManager.executeTask(ticket);
  941. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Reject.ordinal());
  942. msg.setType(taskInfo.getTypeEnum().ordinal());
  943. msg.setOpUserId(userId);
  944. msg.setOpUserName(authUser.getUsername());
  945. imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  946. return true;
  947. }
  948. @Override
  949. @Transactional(rollbackFor = Exception.class)
  950. public Boolean syncDeviceState(ReqDeviceControlData data) throws Exception {
  951. String roomId = data.getRoomId();
  952. DeviceTypeEnum type;
  953. boolean enable;
  954. if (data.getCameraOn() != null) {
  955. type = DeviceTypeEnum.Camera;
  956. enable = data.getCameraOn();
  957. } else if (data.getMicrophoneOn() != null) {
  958. type = DeviceTypeEnum.Microphone;
  959. enable = data.getMicrophoneOn();
  960. } else if (data.getMusicModeOn() != null) {
  961. type = DeviceTypeEnum.MusicMode;
  962. enable = data.getMusicModeOn();
  963. } else if (data.getHandUpOn() != null) {
  964. type = DeviceTypeEnum.HandUp;
  965. enable = data.getHandUpOn();
  966. } else if (data.getExamSongOn() != null) {
  967. type = DeviceTypeEnum.ExamSong;
  968. enable = data.getExamSongOn();
  969. }else {
  970. throw new ApiException(ErrorEnum.ERR_REQUEST_PARA_ERR);
  971. }
  972. SysUser authUser = sysUserFeignService.queryUserInfo();
  973. String userId = authUser.getId().toString();
  974. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
  975. if (type.equals(DeviceTypeEnum.Camera)) {
  976. roomMemberDao.updateCameraByRidAndUid(roomId, userId, enable);
  977. } else if (type.equals(DeviceTypeEnum.Microphone)){
  978. roomMemberDao.updateMicByRidAndUid(roomId, userId, enable);
  979. } else if (type.equals(DeviceTypeEnum.HandUp)){
  980. roomMemberDao.updateHandByRidAndUid(roomId, userId, enable);
  981. } else if (type.equals(DeviceTypeEnum.ExamSong)){
  982. long scheduleId = Long.parseLong(roomId.substring(1));
  983. ExamSongDownloadData msg;
  984. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
  985. if(StringUtils.isEmpty(examJson)){
  986. throw new BizException("学员伴奏信息异常");
  987. }else {
  988. msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
  989. msg.setEnable(enable);
  990. }
  991. courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
  992. }else {
  993. roomMemberDao.updateMusicByRidAndUid(roomId, userId, enable);
  994. }
  995. deviceResourceMessage.setUserId(userId);
  996. imHelper.publishMessage(userId, roomId, deviceResourceMessage, 1);
  997. log.info("syncDeviceState : {}, {}, result = {}", roomId, enable);
  998. return true;
  999. }
  1000. @Override
  1001. @Transactional(rollbackFor = Exception.class)
  1002. public List<RoomResult.MemberResult> getMembers(String roomId) throws Exception {
  1003. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1004. List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
  1005. if(roomMemberList != null && roomMemberList.size() > 0){
  1006. List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(null, Long.parseLong(roomId.substring(1)), null, null, null);
  1007. RoomResult roomResult = new RoomResult();
  1008. Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
  1009. Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,roomId.substring(1)));
  1010. Map<Integer,String> examSongMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryExamSongByUserIdsAndCourseId(userIds,roomId.substring(1)));
  1011. roomResult.setMembers(roomMemberList,midiMap,examSongMap,scheduleStudentMusicScores);
  1012. return roomResult.getMembers();
  1013. }
  1014. return null;
  1015. }
  1016. @Override
  1017. @Transactional(rollbackFor = Exception.class)
  1018. public Boolean applySpeech(String roomId) throws Exception {
  1019. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1020. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1021. SysUser authUser = sysUserFeignService.queryUserInfo();
  1022. String userId = authUser.getId().toString();
  1023. List<RoomMember> assistants = roomMemberDao.findByRidAndRole(roomId, RoleEnum.RoleAssistant.getValue());
  1024. if (assistants.isEmpty()) {
  1025. throw new ApiException(ErrorEnum.ERR_ASSISTANT_NOT_EXIST_IN_ROOM);
  1026. }
  1027. String ticket = IdentifierUtils.uuid();
  1028. ScheduledTaskInfo scheduledTaskInfo = new ScheduledTaskInfo();
  1029. scheduledTaskInfo.setTicket(ticket);
  1030. scheduledTaskInfo.setRoomId(roomId);
  1031. scheduledTaskInfo.setApplyUserId(userId);
  1032. scheduledTaskInfo.setTargetUserId(assistants.get(0).getUid());
  1033. scheduleManager.addTask(scheduledTaskInfo);
  1034. log.info("applySpeech: task = {}", scheduledTaskInfo);
  1035. ApplyForSpeechMessage msg = new ApplyForSpeechMessage();
  1036. msg.setTicket(ticket);
  1037. msg.setReqUserId(userId);
  1038. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, assistants.get(0).getUid(), roomId, msg);
  1039. log.info("apply for speech: {}, task = {}", roomId, scheduledTaskInfo);
  1040. if (resultInfo.isSuccess()) {
  1041. return true;
  1042. } else {
  1043. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1044. }
  1045. }
  1046. @Override
  1047. @Transactional(rollbackFor = Exception.class)
  1048. public Boolean approveSpeech(String roomId, String ticket) throws Exception {
  1049. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1050. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1051. SysUser authUser = sysUserFeignService.queryUserInfo();
  1052. String userId = authUser.getId().toString();
  1053. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  1054. if (count == roomProperties.getMaxCount()) {
  1055. log.error("approveSpeech error: roomId = {}, ticket={}", roomId, ticket);
  1056. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  1057. }
  1058. ScheduledTaskInfo taskInfo = scheduleManager.executeTask(ticket);
  1059. log.info("approveSpeech: task = {}", taskInfo);
  1060. roomMemberDao.updateRoleByRidAndUid(roomId, taskInfo.getApplyUserId(), RoleStudent.getValue());
  1061. SpeechResultMessage msg = new SpeechResultMessage(SpeechResultMessage.Action_Approve);
  1062. UserInfo userInfo = userDao.findByUid(taskInfo.getApplyUserId());
  1063. msg.setOpUserId(userId);
  1064. msg.setOpUserName(authUser.getUsername());
  1065. msg.setReqUserId(taskInfo.getApplyUserId());
  1066. if (userInfo != null) {
  1067. msg.setReqUserName(userInfo.getName());
  1068. }
  1069. msg.setRole(RoleStudent.getValue());
  1070. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  1071. if (!resultInfo.isSuccess()) {
  1072. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1073. }
  1074. RoleChangedMessage rcMsg = new RoleChangedMessage(userId);
  1075. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  1076. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(taskInfo.getApplyUserId(), RoleStudent.getValue());
  1077. if (userInfo != null) {
  1078. user.setUserName(userInfo.getName());
  1079. }
  1080. changedUserList.add(user);
  1081. rcMsg.setUsers(changedUserList);
  1082. imHelper.publishMessage(userId, roomId, rcMsg, 1);
  1083. return true;
  1084. }
  1085. @Override
  1086. @Transactional(rollbackFor = Exception.class)
  1087. public Boolean rejectSpeech(String roomId, String ticket) throws Exception {
  1088. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1089. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1090. SysUser authUser = sysUserFeignService.queryUserInfo();
  1091. String userId = authUser.getId().toString();
  1092. ScheduledTaskInfo taskInfo = scheduleManager.executeTask(ticket);
  1093. log.info("rejectSpeech: task = {}", taskInfo);
  1094. SpeechResultMessage msg = new SpeechResultMessage(SpeechResultMessage.Action_Reject);
  1095. msg.setOpUserId(userId);
  1096. msg.setOpUserName(authUser.getUsername());
  1097. msg.setRole(RoleStudent.getValue());
  1098. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  1099. if (resultInfo.isSuccess()) {
  1100. return true;
  1101. } else {
  1102. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1103. }
  1104. }
  1105. public void checkOverMax(String roomId, RoomMember targetUser, int targetRole) {
  1106. if (RoleEnum.getEnumByValue(targetUser.getRole()).equals(RoleEnum.RoleAudience)) {
  1107. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  1108. if (count == roomProperties.getMaxCount()) {
  1109. log.error("assign error: roomId = {}, userId = {}, role = {}", roomId, targetUser.getRid(), targetUser.getRole());
  1110. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  1111. }
  1112. } else if (targetRole > targetUser.getRole()) {
  1113. throw new ApiException(ErrorEnum.ERR_DOWNGRADE_ROLE);
  1114. }
  1115. }
  1116. @Override
  1117. @Transactional(rollbackFor = Exception.class)
  1118. public Boolean transfer(String roomId, String userId) throws Exception {
  1119. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1120. CheckUtils.checkArgument(userId != null, "userId must't be null");
  1121. CheckUtils.checkArgument(!userId.equals(userId), "can't set self role");
  1122. log.info("transfer: roomId = {}, userId = {}", roomId, userId);
  1123. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  1124. if (roomMember == null) {
  1125. log.error("assistant transfer error: {} toUser = {}, opUser={}", roomId, userId, userId);
  1126. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  1127. }
  1128. Room room = roomDao.findByRid(roomId);
  1129. if (room == null) {
  1130. log.error("assistant transfer error: {} toUser = {}, opUser={}", roomId, userId, userId);
  1131. throw new ApiException(ErrorEnum.ERR_ROOM_NOT_EXIST);
  1132. }
  1133. if (isUserDisplay(room, userId) || isUserDisplay(room, userId)) {
  1134. updateDisplay(roomId, userId, "", 1);
  1135. } else {
  1136. log.info("don't update display: room={}", room);
  1137. }
  1138. roomMemberDao.updateRoleByRidAndUid(roomId, userId, RoleStudent.getValue());
  1139. roomMemberDao.updateRoleByRidAndUid(roomId, userId, RoleEnum.RoleAssistant.getValue());
  1140. AssistantTransferMessage msg = new AssistantTransferMessage();
  1141. msg.setOpUserId(userId);
  1142. msg.setToUserId(userId);
  1143. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, roomId, msg, 1);
  1144. if (resultInfo.isSuccess()) {
  1145. return true;
  1146. } else {
  1147. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1148. }
  1149. }
  1150. @Override
  1151. @Transactional(rollbackFor = Exception.class)
  1152. public Boolean inviteUpgradeRole(String roomId, String targetUserId, int targetRole) throws Exception {
  1153. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1154. CheckUtils.checkArgument(targetUserId != null, "userId must't be null");
  1155. CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, targetUserId), "room member not exist");
  1156. SysUser authUser = sysUserFeignService.queryUserInfo();
  1157. String userId = authUser.getId().toString();
  1158. log.info("inviteUpgradeRole roomId = {}, targetUserId = {}, targetRole = {}", roomId, targetUserId, targetRole);
  1159. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, targetUserId);
  1160. if (targetUser == null) {
  1161. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  1162. }
  1163. checkOverMax(roomId, targetUser, targetRole);
  1164. String ticket = IdentifierUtils.uuid();
  1165. UpgradeRoleTaskInfo taskInfo = new UpgradeRoleTaskInfo();
  1166. taskInfo.setTicket(ticket);
  1167. taskInfo.setRoomId(roomId);
  1168. taskInfo.setApplyUserId(userId);
  1169. taskInfo.setTargetUserId(targetUserId);
  1170. taskInfo.setRole(RoleEnum.getEnumByValue(targetRole));
  1171. scheduleManager.addTask(taskInfo);
  1172. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Invite.ordinal());
  1173. msg.setTicket(ticket);
  1174. msg.setOpUserId(userId);
  1175. msg.setOpUserName(authUser.getUsername());
  1176. msg.setRole(targetRole);
  1177. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, targetUserId, roomId, msg);
  1178. if (resultInfo.isSuccess()) {
  1179. return true;
  1180. } else {
  1181. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1182. }
  1183. }
  1184. @Override
  1185. @Transactional(rollbackFor = Exception.class)
  1186. public Boolean approveUpgradeRole(String roomId, String ticket) throws Exception {
  1187. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1188. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  1189. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1190. SysUser authUser = sysUserFeignService.queryUserInfo();
  1191. String userId = authUser.getId().toString();
  1192. UpgradeRoleTaskInfo taskInfo = (UpgradeRoleTaskInfo) scheduleManager.executeTask(ticket);
  1193. log.info("approveUpgradeRole roomId = {}, task={}", roomId, taskInfo);
  1194. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, userId);
  1195. if (targetUser == null) {
  1196. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  1197. }
  1198. if (!taskInfo.getTargetUserId().equals(userId)) {
  1199. throw new ApiException(ErrorEnum.ERR_APPLY_TICKET_INVALID);
  1200. }
  1201. checkOverMax(roomId, targetUser, taskInfo.getRole().getValue());
  1202. roomMemberDao.updateRoleByRidAndUid(roomId, userId, taskInfo.getRole().getValue());
  1203. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Approve.ordinal());
  1204. msg.setOpUserName(authUser.getUsername());
  1205. msg.setOpUserId(userId);
  1206. msg.setRole(taskInfo.getRole().getValue());
  1207. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  1208. if (!resultInfo.isSuccess()) {
  1209. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1210. }
  1211. RoleChangedMessage rcMsg = new RoleChangedMessage(userId);
  1212. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  1213. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(userId, taskInfo.getRole().getValue());
  1214. user.setUserName(authUser.getUsername());
  1215. changedUserList.add(user);
  1216. rcMsg.setUsers(changedUserList);
  1217. imHelper.publishMessage(userId, roomId, rcMsg, 1);
  1218. return true;
  1219. }
  1220. @Override
  1221. @Transactional(rollbackFor = Exception.class)
  1222. public Boolean rejectUpgradeRole(String roomId, String ticket) throws Exception {
  1223. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1224. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  1225. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1226. SysUser authUser = sysUserFeignService.queryUserInfo();
  1227. String userId = authUser.getId().toString();
  1228. UpgradeRoleTaskInfo taskInfo = (UpgradeRoleTaskInfo) scheduleManager.executeTask(ticket);
  1229. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Reject.ordinal());
  1230. msg.setOpUserName(authUser.getUsername());
  1231. msg.setOpUserId(userId);
  1232. msg.setRole(taskInfo.getRole().getValue());
  1233. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  1234. if (resultInfo.isSuccess()) {
  1235. return true;
  1236. } else {
  1237. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1238. }
  1239. }
  1240. @Override
  1241. @Transactional(rollbackFor = Exception.class)
  1242. public Boolean changeRole(String roomId, String targetUserId, int targetRole) throws Exception {
  1243. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1244. CheckUtils.checkArgument(targetUserId != null, "userId must't be null");
  1245. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1246. CheckUtils.checkArgument(RoleEnum.getEnumByValue(targetRole).equals(RoleTeacher), "only set to teacher");
  1247. CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, targetUserId), "room member not exist");
  1248. SysUser authUser = sysUserFeignService.queryUserInfo();
  1249. String userId = authUser.getId().toString();
  1250. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, targetUserId);
  1251. if (targetUser == null) {
  1252. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  1253. } else {
  1254. if (!RoleEnum.getEnumByValue(targetUser.getRole()).equals(RoleStudent)) {
  1255. log.error("change role error: targetUserId={}, targetRole = {}", targetUser, RoleEnum.getEnumByValue(targetRole));
  1256. throw new ApiException(ErrorEnum.ERR_CHANGE_ROLE);
  1257. }
  1258. }
  1259. log.info("changeRole: roomId={}, targetUserId={}", roomId, targetUserId);
  1260. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  1261. RoleChangedMessage msg = new RoleChangedMessage(userId);
  1262. List<RoomMember> teachers = roomMemberDao.findByRidAndRole(roomId, RoleTeacher.getValue());
  1263. if (!teachers.isEmpty()) {
  1264. roomMemberDao.updateRoleByRidAndUid(roomId, teachers.get(0).getUid(), RoleStudent.getValue());
  1265. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(teachers.get(0).getUid(), RoleStudent.getValue());
  1266. UserInfo userInfo = userDao.findByUid(teachers.get(0).getUid());
  1267. if (userInfo != null) {
  1268. user.setUserName(userInfo.getName());
  1269. }
  1270. changedUserList.add(user);
  1271. } else {
  1272. log.info("change directly cause no teacher exist in room, roomId={}", roomId);
  1273. }
  1274. roomMemberDao.updateRoleByRidAndUid(roomId, targetUserId, targetRole);
  1275. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(targetUserId, targetRole);
  1276. UserInfo userInfo = userDao.findByUid(targetUserId);
  1277. if (userInfo != null) {
  1278. user.setUserName(userInfo.getName());
  1279. }
  1280. changedUserList.add(user);
  1281. msg.setUsers(changedUserList);
  1282. imHelper.publishMessage(userId, roomId, msg, 1);
  1283. String display = "display://type=1?userId=" + targetUserId + "?uri=";
  1284. DisplayMessage displayMessage = new DisplayMessage(display);
  1285. roomDao.updateDisplayByRid(roomId, display);
  1286. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  1287. log.info("changeRole, display changed: roomId={}, {}, targetUserId={}", roomId, display, targetUserId);
  1288. return true;
  1289. }
  1290. @Override
  1291. @Transactional(rollbackFor = Exception.class)
  1292. public Boolean memberOnlineStatus(List<ReqMemberOnlineStatus> statusList, String nonce, String timestamp, String signature) throws Exception {
  1293. String sign = imProperties.getSecret() + nonce + timestamp;
  1294. String signSHA1 = CodeUtil.hexSHA1(sign);
  1295. if (!signSHA1.equals(signature)) {
  1296. log.info("memberOnlineStatus signature error");
  1297. return true;
  1298. }
  1299. for (ReqMemberOnlineStatus status : statusList) {
  1300. int s = Integer.parseInt(status.getStatus());
  1301. String userId = status.getUserId();
  1302. log.info("memberOnlineStatus, userId={}, status={}", userId, status);
  1303. //1:offline 离线; 0: online 在线
  1304. if (s == 1) {
  1305. List<RoomMember> members = roomMemberDao.findByUid(userId);
  1306. if (!members.isEmpty()) {
  1307. scheduleManager.userIMOffline(userId);
  1308. }
  1309. } else if (s == 0) {
  1310. scheduleManager.userIMOnline(userId);
  1311. }
  1312. }
  1313. return true;
  1314. }
  1315. @Override
  1316. @Transactional(rollbackFor = Exception.class)
  1317. public void userIMOfflineKick(String userId) {
  1318. List<RoomMember> members = roomMemberDao.findByUid(userId);
  1319. for (RoomMember member : members) {
  1320. int userRole = member.getRole();
  1321. log.info("userIMOfflineKick: roomId={}, {}, role={}", member.getRid(), userId, RoleEnum.getEnumByValue(userRole));
  1322. try {
  1323. if (userRole == RoleTeacher.getValue() || userRole == RoleEnum.RoleAssistant.getValue()) {
  1324. Room room = roomDao.findByRid(member.getRid());
  1325. if (room == null) {
  1326. break;
  1327. }
  1328. if (isUserDisplay(room, member.getUid())) {
  1329. updateDisplay(member.getRid(), member.getUid(), "", 0);
  1330. log.info("memberOnlineStatus offline: roomId={}, {}", member.getRid(), member.getUid());
  1331. }
  1332. }
  1333. if (roomMemberDao.countByRid(member.getRid()) == 1) {
  1334. IMApiResultInfo apiResultInfo = null;
  1335. apiResultInfo = imHelper.dismiss(member.getUid(), member.getRid());
  1336. if (apiResultInfo.getCode() == 200) {
  1337. roomMemberDao.deleteUserByRidAndUid(member.getRid(), member.getUid());
  1338. roomDao.deleteByRid(member.getRid());
  1339. deleteWhiteboardByUser(member.getRid(), member.getUid());
  1340. log.info("dismiss the room: {},userId: {}", member.getRid(),userId);
  1341. } else {
  1342. log.error("{} exit {} room error: {}", member.getUid(), member.getRid(), apiResultInfo.getErrorMessage());
  1343. }
  1344. } else {
  1345. IMApiResultInfo apiResultInfo = null;
  1346. apiResultInfo = imHelper.quit(new String[]{member.getUid()}, member.getRid());
  1347. if (apiResultInfo.isSuccess()) {
  1348. roomMemberDao.deleteUserByRidAndUid(member.getRid(), member.getUid());
  1349. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Leave, member.getUid(), userRole);
  1350. msg.setUserName(member.getName());
  1351. imHelper.publishMessage(member.getUid(), member.getRid(), msg);
  1352. imHelper.quit(new String[]{member.getUid()}, member.getRid());
  1353. log.info("quit group: roomId={},userId: {}", member.getRid(), member.getUid());
  1354. } else {
  1355. log.error("{} exit {} room error: {}", member.getUid(), member.getRid(), apiResultInfo.getErrorMessage());
  1356. }
  1357. }
  1358. userDao.deleteByUid(member.getUid());
  1359. } catch (Exception e) {
  1360. log.error("userIMOfflineKick error: userId={}", userId);
  1361. }
  1362. }
  1363. }
  1364. @Override
  1365. @Transactional(rollbackFor = Exception.class)
  1366. public void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData) throws Exception {
  1367. SysUser sysUser = sysUserFeignService.queryUserInfo();
  1368. if(sysUser == null){
  1369. throw new BizException("用户信息获取失败");
  1370. }
  1371. String content = playMidiMessageData.getContent();
  1372. String roomId = playMidiMessageData.getRoomId();
  1373. CustomMessage customMessage = JSONObject.parseObject(content,CustomMessage.class);
  1374. String userId = sysUser.getId().toString();
  1375. MetronomeMessageMessage displayMessage = new MetronomeMessageMessage(customMessage);
  1376. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  1377. //记录节拍器消息
  1378. courseScheduleStudentPaymentDao.adjustPlayMidi(Long.parseLong(roomId.substring(1)),playMidiMessageData.getUserId(),content);
  1379. }
  1380. @Override
  1381. @Transactional(rollbackFor = Exception.class)
  1382. public void pushDownloadMusicScoreMsg(MusicScoreData musicScoreData) throws Exception {
  1383. SysUser authUser = sysUserFeignService.queryUserInfo();
  1384. String roomId = musicScoreData.getRoomId();
  1385. Long courseScheduleId = Long.parseLong(roomId.substring(1));
  1386. List<CourseScheduleStudentMusicScore> scheduleStudentMusicScores =
  1387. courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(musicScoreData.getMusicScoreAccompanimentId(),
  1388. courseScheduleId,null,null,0);
  1389. SysMusicScoreAccompaniment accompaniment = sysMusicScoreAccompanimentDao.get(musicScoreData.getMusicScoreAccompanimentId());
  1390. if(scheduleStudentMusicScores.size() == 0){
  1391. //第一次下载,生成数据
  1392. List<CourseScheduleStudentPayment> courseScheduleStudentPayments = courseScheduleStudentPaymentDao.findByCourseSchedule(courseScheduleId);
  1393. Set<Integer> studentIds = courseScheduleStudentPayments.stream().map(e -> e.getUserId()).collect(Collectors.toSet());
  1394. studentIds.forEach(e->{
  1395. CourseScheduleStudentMusicScore musicScore = new CourseScheduleStudentMusicScore();
  1396. musicScore.setMusicScoreAccompanimentId(accompaniment.getId());
  1397. musicScore.setSpeed(accompaniment.getSpeed());
  1398. musicScore.setCourseScheduleId(courseScheduleId);
  1399. musicScore.setUserId(e);
  1400. scheduleStudentMusicScores.add(musicScore);
  1401. });
  1402. CourseScheduleStudentMusicScore musicScore = new CourseScheduleStudentMusicScore();
  1403. musicScore.setMusicScoreAccompanimentId(accompaniment.getId());
  1404. musicScore.setSpeed(accompaniment.getSpeed());
  1405. musicScore.setCourseScheduleId(courseScheduleId);
  1406. musicScore.setUserId(authUser.getId());
  1407. musicScore.setUserType(1);
  1408. scheduleStudentMusicScores.add(musicScore);
  1409. courseScheduleStudentMusicScoreDao.batchInsert(scheduleStudentMusicScores);
  1410. }
  1411. MusicScoreMessage musicScoreMessage = JSON.parseObject(JSON.toJSONString(accompaniment), MusicScoreMessage.class);
  1412. MusicScoreDownloadMessageMessage msg = new MusicScoreDownloadMessageMessage(musicScoreMessage);
  1413. imHelper.publishMessage(authUser.getId().toString(), roomId, msg, 0);
  1414. }
  1415. @Override
  1416. @Transactional(rollbackFor = Exception.class)
  1417. public void pushDownloadExamSongMsg(String roomId, Integer examSongId) throws Exception {
  1418. SysUser authUser = sysUserFeignService.queryUserInfo();
  1419. SysExamSong sysExamSong = sysExamSongDao.get(examSongId);
  1420. if(sysExamSong == null){
  1421. throw new BizException("曲目信息不存在");
  1422. }
  1423. //学员曲目下载状态改为未下载
  1424. ExamSongDownloadData json = new ExamSongDownloadData();
  1425. json.setExamSongName(sysExamSong.getName());
  1426. json.setUrl(sysExamSong.getUrl());
  1427. json.setStatus(0);
  1428. json.setExamSongId(examSongId);
  1429. courseScheduleStudentPaymentDao.adjustExamSong(Long.parseLong(roomId.substring(1)),null, JSON.toJSONString(json));
  1430. ExamSongMessage examSongMessage = new ExamSongMessage();
  1431. examSongMessage.setExamSongName(sysExamSong.getName());
  1432. examSongMessage.setUrl(sysExamSong.getUrl());
  1433. examSongMessage.setExamSongId(examSongId);
  1434. ExamSongDownloadMessageMessage msg = new ExamSongDownloadMessageMessage(examSongMessage);
  1435. imHelper.publishMessage(authUser.getId().toString(), roomId, msg, 0);
  1436. }
  1437. @Override
  1438. public List<RongyunBasicUserDto> queryNoJoinStu(String roomId) {
  1439. return courseScheduleStudentPaymentDao.queryNoJoinStu(roomId,roomId.substring(1));
  1440. }
  1441. @Override
  1442. @Transactional(rollbackFor = Exception.class)
  1443. public void adjustMusicScore(MusicScoreData musicScoreData) throws Exception {
  1444. SysUser authUser = sysUserFeignService.queryUserInfo();
  1445. Integer studentId = authUser.getId();
  1446. String roomId = musicScoreData.getRoomId();
  1447. Long scheduleId = Long.parseLong(roomId.substring(1));
  1448. Integer accompanimentId = musicScoreData.getMusicScoreAccompanimentId();
  1449. List<CourseScheduleStudentMusicScore> studentMusicScores = courseScheduleStudentMusicScoreDao.queryByScoreIdAndCourseId(accompanimentId,scheduleId,studentId,null,null);
  1450. if(accompanimentId != null){
  1451. SysMusicScoreAccompaniment accompaniment = sysMusicScoreAccompanimentDao.get(accompanimentId);
  1452. if(accompaniment == null){
  1453. throw new BizException("曲目信息不存在");
  1454. }
  1455. //修改下载状态
  1456. if(studentMusicScores == null || studentMusicScores.size() == 0){
  1457. throw new BizException("学员不存在此下载曲目");
  1458. }
  1459. CourseScheduleStudentMusicScore studentMusicScore = studentMusicScores.get(0);
  1460. studentMusicScore.setDownStatus(musicScoreData.getStatus());
  1461. courseScheduleStudentMusicScoreDao.update(studentMusicScore);
  1462. }
  1463. //给老师发送学员曲目下载状态
  1464. CourseSchedule courseSchedule = courseScheduleDao.get(scheduleId);
  1465. MusicScoreDownloadStatusMessage statusMessage = new MusicScoreDownloadStatusMessage(studentId,studentMusicScores);
  1466. imHelper.publishMessage(studentId.toString(),courseSchedule.getActualTeacherId().toString(), roomId,statusMessage);
  1467. }
  1468. @Override
  1469. @Transactional(rollbackFor = Exception.class)
  1470. public void adjustExamSong(String roomId, Integer status,Integer examSongId) throws Exception {
  1471. if(roomId == null || status == null || examSongId == null){
  1472. throw new BizException("参数校验失败");
  1473. }
  1474. SysUser authUser = sysUserFeignService.queryUserInfo();
  1475. long scheduleId = Long.parseLong(roomId.substring(1));
  1476. SysExamSong sysExamSong = sysExamSongDao.get(examSongId);
  1477. if(sysExamSong == null){
  1478. throw new BizException("曲目信息不存在");
  1479. }
  1480. ExamSongDownloadData msg;
  1481. String examJson = courseScheduleStudentPaymentDao.getExamJsonByCourseIdAndUserId(scheduleId, authUser.getId());
  1482. if(StringUtils.isEmpty(examJson)){
  1483. msg = new ExamSongDownloadData();
  1484. msg.setExamSongName(sysExamSong.getName());
  1485. msg.setUrl(sysExamSong.getUrl());
  1486. msg.setStatus(status);
  1487. msg.setExamSongId(examSongId);
  1488. }else {
  1489. msg = JSON.parseObject(examJson, ExamSongDownloadData.class);
  1490. msg.setStatus(status);
  1491. }
  1492. courseScheduleStudentPaymentDao.adjustExamSong(scheduleId,authUser.getId(),JSON.toJSONString(msg));
  1493. //给老师发送学员曲目下载状态
  1494. CourseSchedule courseSchedule = courseScheduleDao.get(scheduleId);
  1495. ExamSongDownloadStatusMessage deviceResourceMessage = new ExamSongDownloadStatusMessage(status,authUser.getId(),examSongId);
  1496. imHelper.publishMessage(authUser.getId().toString(),courseSchedule.getActualTeacherId().toString(), roomId, deviceResourceMessage);
  1497. }
  1498. public void updateDisplay(String roomId, String senderId, String display, Integer isIncludeSender) throws Exception {
  1499. roomDao.updateDisplayByRid(roomId, display);
  1500. DisplayMessage displayMessage = new DisplayMessage(display);
  1501. imHelper.publishMessage(senderId, roomId, displayMessage, isIncludeSender);
  1502. }
  1503. public boolean isUserDisplay(Room room, String userId) {
  1504. boolean result = false;
  1505. if (!room.getDisplay().isEmpty() && room.getDisplay().contains("userId=" + userId)) {
  1506. if (room.getDisplay().contains("type=0") || room.getDisplay().contains("type=1") || room.getDisplay().contains("type=3")) {
  1507. result = true;
  1508. }
  1509. }
  1510. return result;
  1511. }
  1512. }