RoomServiceImpl.java 62 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293
  1. package com.ym.service.Impl;
  2. import com.alibaba.fastjson.JSONObject;
  3. import com.ym.common.ApiException;
  4. import com.ym.common.DisplayEnum;
  5. import com.ym.common.ErrorEnum;
  6. import com.ym.config.IMProperties;
  7. import com.ym.config.RoomProperties;
  8. import com.ym.dao.RoomDao;
  9. import com.ym.dao.RoomMemberDao;
  10. import com.ym.dao.UserDao;
  11. import com.ym.dao.WhiteboardDao;
  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.CourseScheduleDao;
  16. import com.ym.mec.biz.dal.dao.CourseScheduleStudentPaymentDao;
  17. import com.ym.mec.biz.dal.dao.SysConfigDao;
  18. import com.ym.mec.biz.dal.dao.TeacherDao;
  19. import com.ym.mec.biz.dal.dto.RongyunBasicUserDto;
  20. import com.ym.mec.biz.dal.entity.CourseSchedule;
  21. import com.ym.mec.biz.dal.entity.Teacher;
  22. import com.ym.mec.biz.dal.enums.GroupType;
  23. import com.ym.mec.biz.dal.enums.TeachModeEnum;
  24. import com.ym.mec.biz.service.StudentAttendanceService;
  25. import com.ym.mec.biz.service.SysConfigService;
  26. import com.ym.mec.biz.service.TeacherAttendanceService;
  27. import com.ym.mec.common.exception.BizException;
  28. import com.ym.mec.im.IMHelper;
  29. import com.ym.mec.im.message.*;
  30. import com.ym.mec.util.collection.MapUtil;
  31. import com.ym.mec.util.date.DateUtil;
  32. import com.ym.pojo.*;
  33. import com.ym.service.RoomService;
  34. import com.ym.utils.CheckUtils;
  35. import com.ym.utils.CodeUtil;
  36. import com.ym.utils.DateTimeUtils;
  37. import com.ym.utils.IdentifierUtils;
  38. import com.ym.whiteboard.WhiteBoardHelper;
  39. import lombok.extern.slf4j.Slf4j;
  40. import org.apache.commons.lang3.StringUtils;
  41. import org.springframework.beans.factory.annotation.Autowired;
  42. import org.springframework.data.redis.core.RedisTemplate;
  43. import org.springframework.stereotype.Service;
  44. import org.springframework.transaction.annotation.Isolation;
  45. import org.springframework.transaction.annotation.Propagation;
  46. import org.springframework.transaction.annotation.Transactional;
  47. import java.util.*;
  48. import java.util.stream.Collectors;
  49. import static com.ym.pojo.RoleEnum.RoleStudent;
  50. import static com.ym.pojo.RoleEnum.RoleTeacher;
  51. /**
  52. * Created by super_zou on 2019/11/28.
  53. */
  54. @Slf4j
  55. @Service
  56. public class RoomServiceImpl implements RoomService {
  57. @Autowired
  58. private IMHelper imHelper;
  59. @Autowired
  60. private RoomProperties roomProperties;
  61. @Autowired
  62. private RoomDao roomDao;
  63. @Autowired
  64. private RoomMemberDao roomMemberDao;
  65. @Autowired
  66. private CourseScheduleStudentPaymentDao courseScheduleStudentPaymentDao;
  67. @Autowired
  68. private WhiteBoardHelper whiteBoardHelper;
  69. @Autowired
  70. private WhiteboardDao whiteboardDao;
  71. @Autowired
  72. private ScheduleManager scheduleManager;
  73. @Autowired
  74. private UserDao userDao;
  75. @Autowired
  76. private TeacherDao teacherDao;
  77. @Autowired
  78. private CourseScheduleDao courseScheduleDao;
  79. @Autowired
  80. private TeacherAttendanceService teacherAttendanceService;
  81. @Autowired
  82. private StudentAttendanceService studentAttendanceService;
  83. @Autowired
  84. private IMProperties imProperties;
  85. @Autowired
  86. private SysUserFeignService sysUserFeignService;
  87. @Autowired
  88. private SysConfigDao sysConfigDao;
  89. @Autowired
  90. private RedisTemplate<String,String> redisTemplate;
  91. @Override
  92. public Integer getCurrentCourseId(String roomId){
  93. String continueCourseTime = sysConfigDao.findConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME);
  94. if(StringUtils.isEmpty(continueCourseTime)){
  95. continueCourseTime = "5";
  96. }
  97. CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
  98. CourseSchedule schedule = courseSchedule;
  99. //如果当前课程是连堂课,那么获取第一节课的课程编号
  100. while (true){
  101. String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  102. String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  103. schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
  104. if(schedule != null){
  105. roomId = schedule.getId().toString();
  106. }else {
  107. break;
  108. }
  109. }
  110. return Integer.parseInt(roomId);
  111. }
  112. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
  113. @Override
  114. public RoomResult joinRoom(String roomId) throws Exception {
  115. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  116. SysUser sysUser = sysUserFeignService.queryUserInfo();
  117. String userId = sysUser.getId().toString();
  118. log.info("joinRoom: roomId={}, userId={}", roomId, userId);
  119. Teacher teacher = teacherDao.get(Integer.parseInt(userId));
  120. CourseSchedule courseSchedule = courseScheduleDao.get(Long.parseLong(roomId));
  121. if(courseSchedule.getTeachMode() == TeachModeEnum.OFFLINE){
  122. throw new ApiException(ErrorEnum.JOIN_ROOM_ERROR);
  123. }
  124. String continueCourseTime = sysConfigDao.findConfigValue(SysConfigService.ONLINE_CONTINUE_COURSE_TIME);
  125. if(StringUtils.isEmpty(continueCourseTime)){
  126. continueCourseTime = "5";
  127. }
  128. CourseSchedule schedule = courseSchedule;
  129. //如果当前课程是连堂课,那么获取第一节课的课程编号
  130. while (true){
  131. String classDate = DateUtil.format(schedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  132. String startClassTime = DateUtil.format(schedule.getStartClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  133. schedule = courseScheduleDao.getLastCourse(schedule.getClassGroupId(),classDate + " " + startClassTime,schedule.getActualTeacherId(),continueCourseTime);
  134. if(schedule != null){
  135. roomId = schedule.getId().toString();
  136. }else {
  137. break;
  138. }
  139. }
  140. Long courseId = Long.parseLong(roomId);
  141. //记录用户实际选择的房间
  142. if(courseSchedule.getGroupType() == GroupType.COMM){
  143. roomId = "I" + roomId;
  144. }else {
  145. roomId = "S" + roomId;
  146. }
  147. redisTemplate.opsForValue().set(roomId + userId,courseSchedule.getId().toString());
  148. log.info("joinRoom current: roomId={}, userId={}", roomId, userId);
  149. Date curTime = DateTimeUtils.currentUTC();
  150. RoleEnum roleEnum;
  151. RoomResult roomResult = new RoomResult();
  152. RoomResult.MemberResult userResult = new RoomResult.MemberResult();
  153. RoomMember member = roomMemberDao.findByRidAndUid(roomId, userId);
  154. String userName;
  155. if (member == null) {
  156. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  157. if (count == roomProperties.getMaxCount()) {
  158. log.info("join error Over max count: roomId = {}, userId = {}", roomId,userId);
  159. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  160. }
  161. if(teacher != null && teacher.getId().equals(courseSchedule.getActualTeacherId())){
  162. roleEnum = RoleTeacher;
  163. userName = sysUser.getRealName();
  164. }else {
  165. roleEnum = RoleStudent;
  166. userName = sysUser.getUsername();
  167. }
  168. userResult.setMicrophone(true);
  169. userResult.setCamera(true);
  170. userResult.setHandUpOn(false);
  171. userResult.setJoinTime(curTime);
  172. saveRoomMember(userId,sysUser.getAvatar(), userName, roomId, roleEnum.getValue(), curTime);
  173. imHelper.joinGroup(new String[]{userId}, roomId, roomId);
  174. } else {
  175. roleEnum = RoleEnum.getEnumByValue(member.getRole());
  176. if(roleEnum == RoleTeacher){
  177. courseScheduleStudentPaymentDao.adjustPlayMidi(courseId,null,null);
  178. }
  179. userName = member.getName();
  180. userResult.setCamera(member.isCamera());
  181. userResult.setHandUpOn(member.isHand());
  182. userResult.setJoinTime(member.getJoinDt());
  183. }
  184. String display = "";
  185. if (roleEnum == RoleTeacher) {
  186. display = "display://type=1?userId=" + userId + "?uri=";
  187. } else if (roleEnum == RoleEnum.RoleAssistant && display.isEmpty()) {
  188. display = "display://type=0?userId=" + userId + "?uri=";
  189. }else {
  190. Room room = roomDao.findByRid(roomId);
  191. if (room != null) {
  192. display = room.getDisplay();
  193. }
  194. }
  195. userResult.setUserName(userName);
  196. userResult.setUserId(userId);
  197. userResult.setRole(roleEnum.getValue());
  198. //获取节拍器信息
  199. String midi = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(courseId.toString(),userId);
  200. userResult.setPlayMidiJson(JSONObject.parseObject(midi,CustomMessage.class));
  201. //获取当前课程剩余时长
  202. String classDate = DateUtil.format(courseSchedule.getClassDate(), DateUtil.DEFAULT_PATTERN);
  203. String endClassTime = DateUtil.format(courseSchedule.getEndClassTime(), DateUtil.EXPANDED_TIME_FORMAT);
  204. roomResult.setSurplusTime(DateUtil.secondsBetween(new Date(),DateUtil.stringToDate(classDate + " " + endClassTime,DateUtil.EXPANDED_DATE_TIME_FORMAT)));
  205. roomResult.setUserInfo(userResult);
  206. roomResult.setDisplay(display);
  207. roomResult.setRoomId(roomId);
  208. List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
  209. if(roomMemberList != null && roomMemberList.size() > 0){
  210. Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
  211. Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,courseId.toString()));
  212. roomResult.setMembers(roomMemberList,midiMap);
  213. }
  214. roomResult.setWhiteboards(whiteboardDao.findByRid(roomId));
  215. log.info("join room: roomId = {}, userId = {}, userName={}, role = {}", roomId, userId, userName, roleEnum);
  216. return roomResult;
  217. }
  218. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
  219. @Override
  220. public void joinRoomSuccess(String roomId,String userId) throws Exception {
  221. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  222. if(roomMember == null){
  223. return ;
  224. }
  225. log.info("joinRoomSuccess : roomId={}, userId={}", roomId, userId);
  226. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  227. CourseSchedule schedule = courseScheduleDao.getLock(Long.parseLong(roomId.substring(1)));
  228. String display = "";
  229. if(roleEnum == RoleTeacher){
  230. //如果是老师加入房间,调整节拍器状态
  231. courseScheduleStudentPaymentDao.adjustPlayMidi(schedule.getId(),null,null);
  232. display = "display://type=1?userId=" + userId + "?uri=";
  233. }else if (roleEnum == RoleEnum.RoleAssistant){
  234. display = "display://type=0?userId=" + userId + "?uri=";
  235. }
  236. Date curTime = DateTimeUtils.currentUTC();
  237. Room room = roomDao.findByRid(roomId);
  238. if (room == null) {
  239. //如果房间不存在,删除除了自己之外的其他用户
  240. // roomMemberDao.deleteRoomMember(roomId,userId);
  241. saveRoom(roomId, roomId, curTime, display);
  242. IMApiResultInfo resultInfo = imHelper.createGroup(new String[]{userId}, roomId, roomId);
  243. if (!resultInfo.isSuccess()) {
  244. log.error("joinRoomSuccess createGroup error: roomId={}, {}", roomId, resultInfo.getErrorMessage());
  245. throw new ApiException(ErrorEnum.ERR_CREATE_ROOM_ERROR, resultInfo.getErrorMessage());
  246. }
  247. }
  248. if(roleEnum == RoleTeacher || roleEnum == RoleEnum.RoleAssistant){
  249. updateDisplay(roomId, userId, display, 0);
  250. }
  251. UserInfo userInfo = userDao.findByUid(userId);
  252. if (userInfo == null) {
  253. userInfo = new UserInfo();
  254. userInfo.setUid(userId);
  255. userInfo.setName(roomMember.getName());
  256. userInfo.setCreateDt(curTime);
  257. userInfo.setUpdateDt(curTime);
  258. userDao.save(userInfo);
  259. }
  260. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Join, userId, roleEnum.getValue());
  261. msg.setTimestamp(curTime);
  262. msg.setUserName(roomMember.getName());
  263. msg.setCamera(true);
  264. Boolean playMidi = false;
  265. if(roleEnum == RoleStudent){
  266. String midiByCourseIdAndUserId = courseScheduleStudentPaymentDao.getMidiByCourseIdAndUserId(schedule.getId().toString(), userId);
  267. //获取节拍器信息
  268. if(StringUtils.isNotEmpty(midiByCourseIdAndUserId)){
  269. JSONObject jsonObject = JSONObject.parseObject(midiByCourseIdAndUserId);
  270. if(jsonObject.get("enable") != null){
  271. playMidi = Boolean.parseBoolean(jsonObject.get("enable").toString());
  272. }
  273. }
  274. }
  275. msg.setHandUpOn(roomMember.isHand());
  276. msg.setMetronomeSwitch(playMidi);
  277. imHelper.publishMessage(userId, roomId, msg);
  278. log.info("join room success: roomId = {}, userId = {}, role = {}", roomId, userId, roleEnum);
  279. signInSuccess(roomMember);
  280. }
  281. public void signInSuccess(RoomMember roomMember) {
  282. String roomId = roomMember.getRid();
  283. String userId = roomMember.getUid();
  284. log.info("signInSuccess: roomId={}, userId={}", roomId, userId);
  285. Integer userIdInt = Integer.parseInt(userId);
  286. Long firstCourseId = Long.parseLong(roomId.substring(1));
  287. Long currentRoomId = Long.parseLong(redisTemplate.opsForValue().get(roomId + userId));
  288. log.info("signInSuccess: currentRoomId={}", currentRoomId);
  289. redisTemplate.delete(roomId + userId);
  290. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  291. if(roleEnum == RoleTeacher){
  292. teacherAttendanceService.addTeacherAttendanceSignIn(firstCourseId,userIdInt,currentRoomId);
  293. }else {
  294. studentAttendanceService.addStudentAttendanceSignIn(firstCourseId,userIdInt,currentRoomId);
  295. }
  296. }
  297. public void saveRoom(String roomId, String roomName, Date createTime, String display) {
  298. Room room = new Room();
  299. room.setRid(roomId);
  300. room.setName(roomName);
  301. room.setCreateDt(createTime);
  302. room.setDisplay(display);
  303. room.setWhiteboardNameIndex(0);
  304. roomDao.save(room);
  305. }
  306. public RoomMember saveRoomMember(String userId, String headUrl, String userName, String roomId, int role, Date joinTime) {
  307. RoomMember roomMember = new RoomMember();
  308. roomMember.setUid(userId);
  309. roomMember.setName(userName);
  310. roomMember.setRid(roomId);
  311. roomMember.setRole(role);
  312. roomMember.setCamera(true);
  313. roomMember.setJoinDt(joinTime);
  314. roomMember.setMusicMode(false);
  315. roomMember.setHeadUrl(headUrl);
  316. roomMemberDao.save(roomMember);
  317. return roomMember;
  318. }
  319. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
  320. @Override
  321. public void leaveRoomSuccess(String roomId,String userId) throws Exception {
  322. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  323. if(roomMember == null){
  324. return ;
  325. }
  326. log.info("leaveRoomSuccess: roomId={}, userId={}", roomId,userId);
  327. RoleEnum roleEnum = RoleEnum.getEnumByValue(roomMember.getRole());
  328. Integer firstCourseId = Integer.parseInt(roomId.substring(1));
  329. if(roleEnum == RoleTeacher){
  330. courseScheduleStudentPaymentDao.adjustPlayMidi(firstCourseId,null,null);
  331. teacherAttendanceService.addTeacherAttendanceSignOut(firstCourseId.longValue(),Integer.parseInt(userId));
  332. }else {
  333. studentAttendanceService.addStudentAttendanceSignOut(firstCourseId.longValue(),Integer.parseInt(userId));
  334. }
  335. Room room = roomDao.findByRid(roomId);
  336. if (room == null) {
  337. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  338. userDao.deleteByUid(userId);
  339. return;
  340. }
  341. if (roleEnum != RoleStudent && isUserDisplay(room, userId)) {
  342. updateDisplay(roomId, userId, "", 0);
  343. }
  344. if (roomMemberDao.countByRid(roomId) == 1) {
  345. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  346. roomDao.deleteByRid(roomId);
  347. deleteWhiteboardByUser(roomId, userId);
  348. imHelper.dismiss(userId, roomId);
  349. log.info("leaveRoomSuccess dismiss the room: {},userId: {}", roomId,userId);
  350. } else {
  351. // imHelper.quit(new String[]{userId}, roomId);
  352. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  353. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Leave, userId, roleEnum.getValue());
  354. msg.setUserName(roomMember.getName());
  355. imHelper.publishMessage(userId, roomId, msg);
  356. imHelper.quit(new String[]{userId}, roomId);
  357. log.info("leaveRoomSuccess quit group: roomId={},userId: {}", roomId,userId);
  358. }
  359. userDao.deleteByUid(userId);
  360. }
  361. public void deleteWhiteboardByUser(String roomId, String userId) throws Exception {
  362. List<Whiteboard> whiteboardList = whiteboardDao.findByRidAndCreator(roomId, userId);
  363. if (!whiteboardList.isEmpty()) {
  364. whiteboardDao.deleteByRidAndCreator(roomId, userId);
  365. for (Whiteboard wb : whiteboardList) {
  366. whiteBoardHelper.destroy(wb.getWbRoom());
  367. }
  368. }
  369. }
  370. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
  371. @Override
  372. public void destroyRoom(String roomId) {
  373. whiteboardDao.deleteByRid(roomId);
  374. Room room = roomDao.findByRid(roomId);
  375. if (room == null) {
  376. List<RoomMember> list = roomMemberDao.findByRid(roomId);
  377. if (!list.isEmpty()) {
  378. try {
  379. imHelper.dismiss(list.get(0).getUid(), roomId);
  380. } catch (Exception e) {
  381. log.error("destroyRoom: {}", e.getMessage());
  382. e.printStackTrace();
  383. }
  384. }
  385. roomMemberDao.deleteByRid(roomId);
  386. log.info("destroyRoom: {}", roomId);
  387. }
  388. }
  389. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
  390. @Override
  391. public Boolean downgrade(String roomId, List<ReqChangeUserRoleData.ChangedUser> users) throws Exception {
  392. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  393. CheckUtils.checkArgument(users.size() > 0, "the changed user list must't be null");
  394. SysUser authUser = sysUserFeignService.queryUserInfo();
  395. String userId = authUser.getId().toString();
  396. Room room = roomDao.findByRid(roomId);
  397. if (room == null) {
  398. throw new ApiException(ErrorEnum.ERR_ROOM_NOT_EXIST);
  399. }
  400. boolean result = false;
  401. List<RoleChangedMessage.ChangedUser> changedUsers = new ArrayList<>();
  402. for (ReqChangeUserRoleData.ChangedUser user : users) {
  403. String changedUserId = user.getUserId();
  404. RoleEnum changedRole = RoleEnum.getEnumByValue(user.getRole());
  405. if (changedUserId.equals(userId)) {
  406. log.error("can not change self role: {}, {}, {}", roomId, userId, changedRole);
  407. throw new ApiException(ErrorEnum.ERR_CHANGE_SELF_ROLE);
  408. } else {
  409. RoomMember oldUser = roomMemberDao.findByRidAndUid(roomId, changedUserId);
  410. if (oldUser != null) {
  411. if (changedRole.equals(RoleEnum.RoleAudience)) {
  412. int r = roomMemberDao.updateRoleByRidAndUid(roomId, changedUserId, changedRole.getValue());
  413. RoleChangedMessage.ChangedUser u = new RoleChangedMessage.ChangedUser(changedUserId, changedRole.getValue());
  414. UserInfo userInfo = userDao.findByUid(changedUserId);
  415. if (userInfo != null) {
  416. u.setUserName(userInfo.getName());
  417. }
  418. changedUsers.add(u);
  419. log.info("change the role: {}, {}, {}, result: {}", roomId, userId, changedRole, r);
  420. result = true;
  421. }
  422. if (oldUser.getRole() == RoleTeacher.getValue() && isUserDisplay(room, oldUser.getUid())) {
  423. updateDisplay(roomId, userId, "", 1);
  424. } else {
  425. log.info("don't update display: room={}, userRole={}", room, RoleEnum.getEnumByValue(oldUser.getRole()));
  426. }
  427. } else {
  428. log.info("role changed fail, not exist: {} - {} - {}", roomId, userId, changedRole);
  429. }
  430. }
  431. }
  432. if (result) {
  433. RoleChangedMessage msg = new RoleChangedMessage(userId);
  434. msg.setUsers(changedUsers);
  435. imHelper.publishMessage(userId, roomId, msg, 1);
  436. }
  437. return result;
  438. }
  439. @Override
  440. @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
  441. public Boolean kickMember(String roomId) throws Exception {
  442. SysUser authUser = sysUserFeignService.queryUserInfo();
  443. String userId = authUser.getId().toString();
  444. CheckUtils.checkArgument(userId != null, "userId must't be null");
  445. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  446. log.info("kickMember: roomId={}, userId={}", roomId, userId);
  447. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  448. if(roomMember == null){
  449. return true;
  450. }
  451. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Kick, userId, roomMember.getRole());
  452. msg.setUserName(roomMember.getName());
  453. imHelper.publishMessage(userId, roomId, msg, 1);
  454. Room room = roomDao.findByRid(roomId);
  455. if (roomMember.getRole() == RoleTeacher.getValue() && isUserDisplay(room, userId)) {
  456. updateDisplay(roomId, userId, "", 1);
  457. }
  458. roomMemberDao.deleteUserByRidAndUid(roomId, userId);
  459. userDao.deleteByUid(userId);
  460. IMApiResultInfo apiResultInfo = imHelper.quit(new String[]{userId}, roomId);
  461. if (!apiResultInfo.isSuccess()) {
  462. throw new ApiException(ErrorEnum.ERR_EXIT_ROOM_ERROR, apiResultInfo.getErrorMessage());
  463. }
  464. return true;
  465. }
  466. @Override
  467. @Transactional(rollbackFor = Exception.class)
  468. public Boolean display(String roomId, int type, String uri, String targetUserId) throws Exception {
  469. SysUser authUser = sysUserFeignService.queryUserInfo();
  470. String userId = authUser.getId().toString();
  471. log.info("display in room: {}, type = {}, uri = {}", roomId, type, uri);
  472. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  473. CheckUtils.checkArgument(type >= 0 && type < DisplayEnum.values().length, "type not exist");
  474. DisplayEnum displayEnum = DisplayEnum.values()[type];
  475. if (displayEnum.equals(DisplayEnum.None)) {
  476. roomDao.updateDisplayByRid(roomId, "");
  477. DisplayMessage displayMessage = new DisplayMessage("");
  478. IMApiResultInfo apiResultInfo = imHelper.publishMessage(userId, roomId, displayMessage);
  479. if (apiResultInfo.isSuccess()) {
  480. return true;
  481. } else {
  482. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, apiResultInfo.getErrorMessage());
  483. }
  484. }
  485. String display = "display://type=" + type;
  486. if (displayEnum.equals(DisplayEnum.Teacher)) {
  487. List<RoomMember> teachers = roomMemberDao.findByRidAndRole(roomId, RoleTeacher.getValue());
  488. if (teachers.isEmpty()) {
  489. throw new ApiException(ErrorEnum.ERR_TEACHER_NOT_EXIST_IN_ROOM);
  490. } else {
  491. display += "?userId=" + teachers.get(0).getUid() + "?uri=";
  492. roomDao.updateDisplayByRid(roomId, display);
  493. DisplayMessage displayMessage = new DisplayMessage(display);
  494. imHelper.publishMessage(userId, roomId, displayMessage);
  495. log.info("change display to teacher: roomId={}, display={}", roomId, display);
  496. }
  497. } else if (displayEnum.equals(DisplayEnum.Assistant)) {
  498. List<RoomMember> assistants = roomMemberDao.findByRidAndRole(roomId, RoleEnum.RoleAssistant.getValue());
  499. if (assistants.isEmpty()) {
  500. throw new ApiException(ErrorEnum.ERR_ASSISTANT_NOT_EXIST_IN_ROOM);
  501. } else {
  502. display += "?userId=" + assistants.get(0).getUid() + "?uri=";
  503. roomDao.updateDisplayByRid(roomId, display);
  504. DisplayMessage displayMessage = new DisplayMessage(display);
  505. imHelper.publishMessage(userId, roomId, displayMessage);
  506. log.info("change display to assistant: roomId={}, display={}", roomId, display);
  507. }
  508. } else if (displayEnum.equals(DisplayEnum.Screen)) {
  509. display += "?userId=" + userId + "?uri=";
  510. roomDao.updateDisplayByRid(roomId, display);
  511. DisplayMessage displayMessage = new DisplayMessage(display);
  512. imHelper.publishMessage(userId, roomId, displayMessage);
  513. log.info("change display to screen: roomId={}, display={}", roomId, display);
  514. } else if (displayEnum.equals(DisplayEnum.STUDENT)) {
  515. display += "?userId=" + targetUserId + "?uri=" + uri;
  516. roomDao.updateDisplayByRid(roomId, display);
  517. DisplayMessage displayMessage = new DisplayMessage(display);
  518. imHelper.publishMessage(userId, roomId, displayMessage);
  519. log.info("change display to screen: roomId={}, display={}", roomId, display);
  520. } else {
  521. display += "?userId=" + userId + "?uri=" + uri;
  522. // CheckUtils.checkArgument(uri != null, "uri must't be null");
  523. // CheckUtils.checkArgument(whiteboardDao.findByRidAndWbid(roomId, uri).size() > 0, "whiteboard not exist");
  524. roomDao.updateDisplayByRid(roomId, display);
  525. DisplayMessage displayMessage = new DisplayMessage(display);
  526. imHelper.publishMessage(userId, roomId, displayMessage);
  527. }
  528. log.info("result display in room: {}, type = {}, uri = {}", roomId, type, uri);
  529. return true;
  530. }
  531. @Override
  532. @Transactional(rollbackFor = Exception.class)
  533. public String createWhiteBoard(String roomId) throws Exception {
  534. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  535. // CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  536. SysUser authUser = sysUserFeignService.queryUserInfo();
  537. String userId = authUser.getId().toString();
  538. // CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, userId), "room member not exist");
  539. log.info("createWhiteBoard: roomId = {}", roomId);
  540. String wbRoom = IdentifierUtils.uuid();
  541. WhiteBoardApiResultInfo resultInfo = whiteBoardHelper.create(wbRoom);
  542. if (resultInfo.isSuccess()) {
  543. String wbId = resultInfo.getData();
  544. Date date = DateTimeUtils.currentUTC();
  545. Room room = roomDao.findByRid(roomId);
  546. int whiteboardNameIndex = room.getWhiteboardNameIndex() + 1;
  547. String name = "白板" + whiteboardNameIndex;
  548. roomDao.updateWhiteboardNameIndexByRid(roomId, whiteboardNameIndex);
  549. Whiteboard wb = new Whiteboard();
  550. wb.setRid(roomId);
  551. wb.setWbRoom(wbRoom);
  552. wb.setWbid(wbId);
  553. wb.setName(name);
  554. wb.setCreator(userId);
  555. wb.setCreateDt(date);
  556. wb.setCurPg(0);
  557. whiteboardDao.save(wb);
  558. WhiteboardMessage wbmsg = new WhiteboardMessage(WhiteboardMessage.Create);
  559. wbmsg.setWhiteboardId(wbId);
  560. wbmsg.setWhiteboardName(name);
  561. imHelper.publishMessage(userId, roomId, wbmsg);
  562. String display = "display://type=2?userId=" + userId + "?uri=" + wbId;
  563. roomDao.updateDisplayByRid(roomId, display);
  564. DisplayMessage displayMessage = new DisplayMessage(display);
  565. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  566. return wbId;
  567. } else {
  568. throw new ApiException(ErrorEnum.ERR_CREATE_WHITE_BOARD, resultInfo.getMsg());
  569. }
  570. }
  571. @Override
  572. @Transactional(rollbackFor = Exception.class)
  573. public Boolean deleteWhiteboard(String roomId, String whiteBoardId) throws Exception {
  574. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  575. CheckUtils.checkArgument(whiteBoardId != null, "whiteBoardId must't be null");
  576. SysUser authUser = sysUserFeignService.queryUserInfo();
  577. String userId = authUser.getId().toString();
  578. List<Whiteboard> whiteboardList = whiteboardDao.findByRidAndWbid(roomId, whiteBoardId);
  579. CheckUtils.checkArgument(whiteboardList.size() > 0, "whiteboard not exist");
  580. Room room = roomDao.findByRid(roomId);
  581. CheckUtils.checkArgument(room != null, "room not exist");
  582. log.info("deleteWhiteboard: room={}, whiteBoardId={}", room, whiteBoardId);
  583. String display = room.getDisplay();
  584. if (display.contains("uri=" + whiteBoardId)) {
  585. int result = roomDao.updateDisplayByRid(roomId, "");
  586. log.info("clear room display, room: {}, result: {}", roomId, result);
  587. DisplayMessage displayMessage = new DisplayMessage("");
  588. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  589. } else {
  590. log.info("no display to clean: room={}", room);
  591. }
  592. String wbRoom = whiteboardList.get(0).getWbRoom();
  593. WhiteBoardApiResultInfo resultInfo = whiteBoardHelper.destroy(wbRoom);
  594. if (resultInfo.isSuccess()) {
  595. int result = whiteboardDao.deleteByWbid(whiteBoardId);
  596. log.info("delete whiteboard: roomId = {}, whiteBoardId = {}, result = {}", roomId, whiteBoardId, result);
  597. WhiteboardMessage wbmsg = new WhiteboardMessage(WhiteboardMessage.Delete);
  598. wbmsg.setWhiteboardId(whiteBoardId);
  599. imHelper.publishMessage(userId, roomId, wbmsg, 1);
  600. return true;
  601. } else {
  602. throw new ApiException(ErrorEnum.ERR_DELETE_WHITE_BOARD, resultInfo.getMsg());
  603. }
  604. }
  605. @Override
  606. @Transactional(rollbackFor = Exception.class)
  607. public List<RoomResult.WhiteboardResult> getWhiteboard(String roomId) throws Exception {
  608. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  609. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  610. List<Whiteboard> whiteboards = whiteboardDao.findByRid(roomId);
  611. List<RoomResult.WhiteboardResult> result = new ArrayList<>();
  612. for (Whiteboard wb : whiteboards) {
  613. RoomResult.WhiteboardResult r = new RoomResult.WhiteboardResult();
  614. r.setName(wb.getName());
  615. r.setCurPg(wb.getCurPg());
  616. r.setWhiteboardId(wb.getWbid());
  617. result.add(r);
  618. }
  619. return result;
  620. }
  621. @Override
  622. @Transactional(rollbackFor = Exception.class)
  623. public Boolean turnWhiteBoardPage(String roomId, String whiteBoardId, int page) throws Exception {
  624. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  625. CheckUtils.checkArgument(whiteBoardId != null, "whiteBoardId must't be null");
  626. SysUser authUser = sysUserFeignService.queryUserInfo();
  627. String userId = authUser.getId().toString();
  628. Room room = roomDao.findByRid(roomId);
  629. CheckUtils.checkArgument(room != null, "room not exist");
  630. int result = whiteboardDao.updatePageByRidAndWbid(roomId, whiteBoardId, page);
  631. log.info("turn page to: {}, room: {}, wb : {}; r: {}", page, roomId, whiteBoardId, result);
  632. TurnPageMessage turnPageMessage = new TurnPageMessage(whiteBoardId, userId, page);
  633. imHelper.publishMessage(userId, roomId, turnPageMessage);
  634. return true;
  635. }
  636. @Override
  637. @Transactional(rollbackFor = Exception.class)
  638. public Boolean controlDevice(String roomId, String userId, DeviceTypeEnum typeEnum, boolean enable) throws Exception {
  639. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  640. CheckUtils.checkArgument(userId != null, "userId must't be null");
  641. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  642. CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, userId), "room member not exist");
  643. SysUser authUser = sysUserFeignService.queryUserInfo();
  644. log.info("controlDevice: userId={}, typeEnum={}, onOff={}", userId, typeEnum, enable);
  645. if (enable) {
  646. String ticket = IdentifierUtils.uuid();
  647. ControlDeviceTaskInfo taskInfo = new ControlDeviceTaskInfo();
  648. taskInfo.setRoomId(roomId);
  649. taskInfo.setTypeEnum(typeEnum);
  650. taskInfo.setOnOff(true);
  651. taskInfo.setApplyUserId(authUser.getId().toString());
  652. taskInfo.setTargetUserId(userId);
  653. taskInfo.setTicket(ticket);
  654. scheduleManager.addTask(taskInfo);
  655. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Invite.ordinal());
  656. msg.setTicket(ticket);
  657. msg.setType(taskInfo.getTypeEnum().ordinal());
  658. msg.setOpUserId(authUser.getId().toString());
  659. msg.setOpUserName(authUser.getUsername());
  660. imHelper.publishMessage(authUser.getId().toString(), userId, roomId, msg);
  661. } else {
  662. if (typeEnum.equals(DeviceTypeEnum.Camera)) {
  663. roomMemberDao.updateCameraByRidAndUid(roomId, userId, false);
  664. } else if (typeEnum.equals(DeviceTypeEnum.Microphone)){
  665. roomMemberDao.updateMicByRidAndUid(roomId, userId, false);
  666. } else if (typeEnum.equals(DeviceTypeEnum.HandUp)){
  667. roomMemberDao.updateHandByRidAndUid(roomId, userId, false);
  668. }else {
  669. roomMemberDao.updateMusicByRidAndUid(roomId, userId, false);
  670. }
  671. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(typeEnum.ordinal(), false);
  672. deviceResourceMessage.setUserId(userId);
  673. UserInfo userInfo = userDao.findByUid(userId);
  674. if (userInfo != null) {
  675. deviceResourceMessage.setUserName(userInfo.getName());
  676. }
  677. imHelper.publishMessage(authUser.getId().toString(), roomId, deviceResourceMessage, 1);
  678. }
  679. return true;
  680. }
  681. @Override
  682. @Transactional(rollbackFor = Exception.class)
  683. public Boolean batchControlDevice(ReqDeviceControlData data) throws Exception {
  684. List<RoomMember> roomMembers;
  685. if(StringUtils.isNotEmpty(data.getUserId())){
  686. roomMembers = new ArrayList<>();
  687. String[] split = data.getUserId().split(",");
  688. for (int i = 0; i < split.length; i++) {
  689. roomMembers.add(new RoomMember(split[i]));
  690. }
  691. }else {
  692. roomMembers = roomMemberDao.findByRidAndRole(data.getRoomId(), RoleStudent.getValue());
  693. }
  694. if(roomMembers.size() == 0){
  695. return false;
  696. }
  697. boolean result = true;
  698. if (data.getCameraOn() != null) {
  699. for (RoomMember e:roomMembers) {
  700. controlDevice(data.getRoomId(), e.getUid(), DeviceTypeEnum.Camera, data.getCameraOn());
  701. }
  702. } else if (data.getMicrophoneOn() != null) {
  703. for (RoomMember e:roomMembers) {
  704. controlDevice(data.getRoomId(), e.getUid(), DeviceTypeEnum.Microphone, data.getMicrophoneOn());
  705. }
  706. } else if (data.getMusicModeOn() != null) {
  707. for (RoomMember e:roomMembers) {
  708. controlDevice(data.getRoomId(), e.getUid(), DeviceTypeEnum.MusicMode, data.getMusicModeOn());
  709. }
  710. } else {
  711. throw new ApiException(ErrorEnum.ERR_REQUEST_PARA_ERR);
  712. }
  713. return result;
  714. }
  715. @Override
  716. @Transactional(rollbackFor = Exception.class)
  717. public Boolean approveControlDevice(String roomId, String ticket) throws Exception {
  718. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  719. SysUser authUser = sysUserFeignService.queryUserInfo();
  720. String userId = authUser.getId().toString();
  721. log.info("approveControlDevice: ticket={}", ticket);
  722. ControlDeviceTaskInfo taskInfo = (ControlDeviceTaskInfo) scheduleManager.executeTask(ticket);
  723. if (taskInfo.getTypeEnum().equals(DeviceTypeEnum.Camera)) {
  724. roomMemberDao.updateCameraByRidAndUid(roomId, userId, taskInfo.isOnOff());
  725. } else {
  726. roomMemberDao.updateMicByRidAndUid(roomId, userId, taskInfo.isOnOff());
  727. }
  728. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Approve.ordinal());
  729. msg.setType(taskInfo.getTypeEnum().ordinal());
  730. msg.setOpUserId(userId);
  731. msg.setOpUserName(authUser.getUsername());
  732. imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  733. DeviceStateChangedMessage deviceResourceMessage = new DeviceStateChangedMessage(taskInfo.getTypeEnum().ordinal(), taskInfo.isOnOff());
  734. deviceResourceMessage.setUserId(userId);
  735. imHelper.publishMessage(userId, roomId, deviceResourceMessage, 1);
  736. return true;
  737. }
  738. @Override
  739. @Transactional(rollbackFor = Exception.class)
  740. public Boolean rejectControlDevice(String roomId, String ticket) throws Exception {
  741. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  742. SysUser authUser = sysUserFeignService.queryUserInfo();
  743. String userId = authUser.getId().toString();
  744. log.info("rejectControlDevice: ticket={}", ticket);
  745. ControlDeviceTaskInfo taskInfo = (ControlDeviceTaskInfo) scheduleManager.executeTask(ticket);
  746. ControlDeviceNotifyMessage msg = new ControlDeviceNotifyMessage(ActionEnum.Reject.ordinal());
  747. msg.setType(taskInfo.getTypeEnum().ordinal());
  748. msg.setOpUserId(userId);
  749. msg.setOpUserName(authUser.getUsername());
  750. imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  751. return true;
  752. }
  753. @Override
  754. @Transactional(rollbackFor = Exception.class)
  755. public Boolean syncDeviceState(String roomId, DeviceTypeEnum type, boolean enable) throws Exception {
  756. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  757. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  758. SysUser authUser = sysUserFeignService.queryUserInfo();
  759. String userId = authUser.getId().toString();
  760. int result;
  761. DeviceStateChangedMessage deviceResourceMessage;
  762. if (type.equals(DeviceTypeEnum.Camera)) {
  763. result = roomMemberDao.updateCameraByRidAndUid(roomId, userId, enable);
  764. deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
  765. } else if (type.equals(DeviceTypeEnum.Microphone)){
  766. result = roomMemberDao.updateMicByRidAndUid(roomId, userId, enable);
  767. deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
  768. } else if (type.equals(DeviceTypeEnum.HandUp)){
  769. result = roomMemberDao.updateHandByRidAndUid(roomId, userId, enable);
  770. deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
  771. }else {
  772. result = roomMemberDao.updateMusicByRidAndUid(roomId, userId, enable);
  773. deviceResourceMessage = new DeviceStateChangedMessage(type.ordinal(), enable);
  774. }
  775. deviceResourceMessage.setUserId(userId);
  776. imHelper.publishMessage(userId, roomId, deviceResourceMessage, 1);
  777. log.info("syncDeviceState : {}, {}, result = {}", roomId, enable, result);
  778. return true;
  779. }
  780. @Override
  781. @Transactional(rollbackFor = Exception.class)
  782. public List<RoomResult.MemberResult> getMembers(String roomId) throws Exception {
  783. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  784. List<RoomMember> roomMemberList = roomMemberDao.findByRid(roomId);
  785. if(roomMemberList != null && roomMemberList.size() > 0){
  786. RoomResult roomResult = new RoomResult();
  787. Set<String> userIds = roomMemberList.stream().map(e -> e.getUid()).collect(Collectors.toSet());
  788. Map<Integer,String> midiMap = MapUtil.convertMybatisMap(courseScheduleStudentPaymentDao.queryMidiByUserIdsAndCourseId(userIds,roomId.substring(1)));
  789. roomResult.setMembers(roomMemberList,midiMap);
  790. return roomResult.getMembers();
  791. }
  792. return null;
  793. }
  794. @Override
  795. @Transactional(rollbackFor = Exception.class)
  796. public Boolean applySpeech(String roomId) throws Exception {
  797. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  798. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  799. SysUser authUser = sysUserFeignService.queryUserInfo();
  800. String userId = authUser.getId().toString();
  801. List<RoomMember> assistants = roomMemberDao.findByRidAndRole(roomId, RoleEnum.RoleAssistant.getValue());
  802. if (assistants.isEmpty()) {
  803. throw new ApiException(ErrorEnum.ERR_ASSISTANT_NOT_EXIST_IN_ROOM);
  804. }
  805. String ticket = IdentifierUtils.uuid();
  806. ScheduledTaskInfo scheduledTaskInfo = new ScheduledTaskInfo();
  807. scheduledTaskInfo.setTicket(ticket);
  808. scheduledTaskInfo.setRoomId(roomId);
  809. scheduledTaskInfo.setApplyUserId(userId);
  810. scheduledTaskInfo.setTargetUserId(assistants.get(0).getUid());
  811. scheduleManager.addTask(scheduledTaskInfo);
  812. log.info("applySpeech: task = {}", scheduledTaskInfo);
  813. ApplyForSpeechMessage msg = new ApplyForSpeechMessage();
  814. msg.setTicket(ticket);
  815. msg.setReqUserId(userId);
  816. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, assistants.get(0).getUid(), roomId, msg);
  817. log.info("apply for speech: {}, task = {}", roomId, scheduledTaskInfo);
  818. if (resultInfo.isSuccess()) {
  819. return true;
  820. } else {
  821. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  822. }
  823. }
  824. @Override
  825. @Transactional(rollbackFor = Exception.class)
  826. public Boolean approveSpeech(String roomId, String ticket) throws Exception {
  827. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  828. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  829. SysUser authUser = sysUserFeignService.queryUserInfo();
  830. String userId = authUser.getId().toString();
  831. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  832. if (count == roomProperties.getMaxCount()) {
  833. log.error("approveSpeech error: roomId = {}, ticket={}", roomId, ticket);
  834. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  835. }
  836. ScheduledTaskInfo taskInfo = scheduleManager.executeTask(ticket);
  837. log.info("approveSpeech: task = {}", taskInfo);
  838. roomMemberDao.updateRoleByRidAndUid(roomId, taskInfo.getApplyUserId(), RoleStudent.getValue());
  839. SpeechResultMessage msg = new SpeechResultMessage(SpeechResultMessage.Action_Approve);
  840. UserInfo userInfo = userDao.findByUid(taskInfo.getApplyUserId());
  841. msg.setOpUserId(userId);
  842. msg.setOpUserName(authUser.getUsername());
  843. msg.setReqUserId(taskInfo.getApplyUserId());
  844. if (userInfo != null) {
  845. msg.setReqUserName(userInfo.getName());
  846. }
  847. msg.setRole(RoleStudent.getValue());
  848. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  849. if (!resultInfo.isSuccess()) {
  850. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  851. }
  852. RoleChangedMessage rcMsg = new RoleChangedMessage(userId);
  853. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  854. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(taskInfo.getApplyUserId(), RoleStudent.getValue());
  855. if (userInfo != null) {
  856. user.setUserName(userInfo.getName());
  857. }
  858. changedUserList.add(user);
  859. rcMsg.setUsers(changedUserList);
  860. imHelper.publishMessage(userId, roomId, rcMsg, 1);
  861. return true;
  862. }
  863. @Override
  864. @Transactional(rollbackFor = Exception.class)
  865. public Boolean rejectSpeech(String roomId, String ticket) throws Exception {
  866. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  867. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  868. SysUser authUser = sysUserFeignService.queryUserInfo();
  869. String userId = authUser.getId().toString();
  870. ScheduledTaskInfo taskInfo = scheduleManager.executeTask(ticket);
  871. log.info("rejectSpeech: task = {}", taskInfo);
  872. SpeechResultMessage msg = new SpeechResultMessage(SpeechResultMessage.Action_Reject);
  873. msg.setOpUserId(userId);
  874. msg.setOpUserName(authUser.getUsername());
  875. msg.setRole(RoleStudent.getValue());
  876. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  877. if (resultInfo.isSuccess()) {
  878. return true;
  879. } else {
  880. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  881. }
  882. }
  883. public void checkOverMax(String roomId, RoomMember targetUser, int targetRole) {
  884. if (RoleEnum.getEnumByValue(targetUser.getRole()).equals(RoleEnum.RoleAudience)) {
  885. int count = roomMemberDao.countByRidAndExcludeRole(roomId, RoleEnum.RoleAudience.getValue());
  886. if (count == roomProperties.getMaxCount()) {
  887. log.error("assign error: roomId = {}, userId = {}, role = {}", roomId, targetUser.getRid(), targetUser.getRole());
  888. throw new ApiException(ErrorEnum.ERR_OVER_MAX_COUNT);
  889. }
  890. } else if (targetRole > targetUser.getRole()) {
  891. throw new ApiException(ErrorEnum.ERR_DOWNGRADE_ROLE);
  892. }
  893. }
  894. @Override
  895. @Transactional(rollbackFor = Exception.class)
  896. public Boolean transfer(String roomId, String userId) throws Exception {
  897. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  898. CheckUtils.checkArgument(userId != null, "userId must't be null");
  899. CheckUtils.checkArgument(!userId.equals(userId), "can't set self role");
  900. log.info("transfer: roomId = {}, userId = {}", roomId, userId);
  901. RoomMember roomMember = roomMemberDao.findByRidAndUid(roomId, userId);
  902. if (roomMember == null) {
  903. log.error("assistant transfer error: {} toUser = {}, opUser={}", roomId, userId, userId);
  904. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  905. }
  906. Room room = roomDao.findByRid(roomId);
  907. if (room == null) {
  908. log.error("assistant transfer error: {} toUser = {}, opUser={}", roomId, userId, userId);
  909. throw new ApiException(ErrorEnum.ERR_ROOM_NOT_EXIST);
  910. }
  911. if (isUserDisplay(room, userId) || isUserDisplay(room, userId)) {
  912. updateDisplay(roomId, userId, "", 1);
  913. } else {
  914. log.info("don't update display: room={}", room);
  915. }
  916. roomMemberDao.updateRoleByRidAndUid(roomId, userId, RoleStudent.getValue());
  917. roomMemberDao.updateRoleByRidAndUid(roomId, userId, RoleEnum.RoleAssistant.getValue());
  918. AssistantTransferMessage msg = new AssistantTransferMessage();
  919. msg.setOpUserId(userId);
  920. msg.setToUserId(userId);
  921. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, roomId, msg, 1);
  922. if (resultInfo.isSuccess()) {
  923. return true;
  924. } else {
  925. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  926. }
  927. }
  928. @Override
  929. @Transactional(rollbackFor = Exception.class)
  930. public Boolean inviteUpgradeRole(String roomId, String targetUserId, int targetRole) throws Exception {
  931. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  932. CheckUtils.checkArgument(targetUserId != null, "userId must't be null");
  933. CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, targetUserId), "room member not exist");
  934. SysUser authUser = sysUserFeignService.queryUserInfo();
  935. String userId = authUser.getId().toString();
  936. log.info("inviteUpgradeRole roomId = {}, targetUserId = {}, targetRole = {}", roomId, targetUserId, targetRole);
  937. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, targetUserId);
  938. if (targetUser == null) {
  939. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  940. }
  941. checkOverMax(roomId, targetUser, targetRole);
  942. String ticket = IdentifierUtils.uuid();
  943. UpgradeRoleTaskInfo taskInfo = new UpgradeRoleTaskInfo();
  944. taskInfo.setTicket(ticket);
  945. taskInfo.setRoomId(roomId);
  946. taskInfo.setApplyUserId(userId);
  947. taskInfo.setTargetUserId(targetUserId);
  948. taskInfo.setRole(RoleEnum.getEnumByValue(targetRole));
  949. scheduleManager.addTask(taskInfo);
  950. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Invite.ordinal());
  951. msg.setTicket(ticket);
  952. msg.setOpUserId(userId);
  953. msg.setOpUserName(authUser.getUsername());
  954. msg.setRole(targetRole);
  955. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, targetUserId, roomId, msg);
  956. if (resultInfo.isSuccess()) {
  957. return true;
  958. } else {
  959. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  960. }
  961. }
  962. @Override
  963. @Transactional(rollbackFor = Exception.class)
  964. public Boolean approveUpgradeRole(String roomId, String ticket) throws Exception {
  965. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  966. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  967. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  968. SysUser authUser = sysUserFeignService.queryUserInfo();
  969. String userId = authUser.getId().toString();
  970. UpgradeRoleTaskInfo taskInfo = (UpgradeRoleTaskInfo) scheduleManager.executeTask(ticket);
  971. log.info("approveUpgradeRole roomId = {}, task={}", roomId, taskInfo);
  972. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, userId);
  973. if (targetUser == null) {
  974. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  975. }
  976. if (!taskInfo.getTargetUserId().equals(userId)) {
  977. throw new ApiException(ErrorEnum.ERR_APPLY_TICKET_INVALID);
  978. }
  979. checkOverMax(roomId, targetUser, taskInfo.getRole().getValue());
  980. roomMemberDao.updateRoleByRidAndUid(roomId, userId, taskInfo.getRole().getValue());
  981. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Approve.ordinal());
  982. msg.setOpUserName(authUser.getUsername());
  983. msg.setOpUserId(userId);
  984. msg.setRole(taskInfo.getRole().getValue());
  985. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  986. if (!resultInfo.isSuccess()) {
  987. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  988. }
  989. RoleChangedMessage rcMsg = new RoleChangedMessage(userId);
  990. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  991. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(userId, taskInfo.getRole().getValue());
  992. user.setUserName(authUser.getUsername());
  993. changedUserList.add(user);
  994. rcMsg.setUsers(changedUserList);
  995. imHelper.publishMessage(userId, roomId, rcMsg, 1);
  996. return true;
  997. }
  998. @Override
  999. @Transactional(rollbackFor = Exception.class)
  1000. public Boolean rejectUpgradeRole(String roomId, String ticket) throws Exception {
  1001. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1002. CheckUtils.checkArgument(ticket != null, "ticket must't be null");
  1003. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1004. SysUser authUser = sysUserFeignService.queryUserInfo();
  1005. String userId = authUser.getId().toString();
  1006. UpgradeRoleTaskInfo taskInfo = (UpgradeRoleTaskInfo) scheduleManager.executeTask(ticket);
  1007. UpgradeRoleMessage msg = new UpgradeRoleMessage(ActionEnum.Reject.ordinal());
  1008. msg.setOpUserName(authUser.getUsername());
  1009. msg.setOpUserId(userId);
  1010. msg.setRole(taskInfo.getRole().getValue());
  1011. IMApiResultInfo resultInfo = imHelper.publishMessage(userId, taskInfo.getApplyUserId(), roomId, msg);
  1012. if (resultInfo.isSuccess()) {
  1013. return true;
  1014. } else {
  1015. throw new ApiException(ErrorEnum.ERR_MESSAGE_ERROR, resultInfo.getErrorMessage());
  1016. }
  1017. }
  1018. @Override
  1019. @Transactional(rollbackFor = Exception.class)
  1020. public Boolean changeRole(String roomId, String targetUserId, int targetRole) throws Exception {
  1021. CheckUtils.checkArgument(roomId != null, "roomId must't be null");
  1022. CheckUtils.checkArgument(targetUserId != null, "userId must't be null");
  1023. CheckUtils.checkArgument(roomDao.existsByRid(roomId), "room not exist");
  1024. CheckUtils.checkArgument(RoleEnum.getEnumByValue(targetRole).equals(RoleTeacher), "only set to teacher");
  1025. CheckUtils.checkArgument(roomMemberDao.existsByRidAndUid(roomId, targetUserId), "room member not exist");
  1026. SysUser authUser = sysUserFeignService.queryUserInfo();
  1027. String userId = authUser.getId().toString();
  1028. RoomMember targetUser = roomMemberDao.findByRidAndUid(roomId, targetUserId);
  1029. if (targetUser == null) {
  1030. throw new ApiException(ErrorEnum.ERR_USER_NOT_EXIST_IN_ROOM);
  1031. } else {
  1032. if (!RoleEnum.getEnumByValue(targetUser.getRole()).equals(RoleStudent)) {
  1033. log.error("change role error: targetUserId={}, targetRole = {}", targetUser, RoleEnum.getEnumByValue(targetRole));
  1034. throw new ApiException(ErrorEnum.ERR_CHANGE_ROLE);
  1035. }
  1036. }
  1037. log.info("changeRole: roomId={}, targetUserId={}", roomId, targetUserId);
  1038. List<RoleChangedMessage.ChangedUser> changedUserList = new ArrayList<>();
  1039. RoleChangedMessage msg = new RoleChangedMessage(userId);
  1040. List<RoomMember> teachers = roomMemberDao.findByRidAndRole(roomId, RoleTeacher.getValue());
  1041. if (!teachers.isEmpty()) {
  1042. roomMemberDao.updateRoleByRidAndUid(roomId, teachers.get(0).getUid(), RoleStudent.getValue());
  1043. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(teachers.get(0).getUid(), RoleStudent.getValue());
  1044. UserInfo userInfo = userDao.findByUid(teachers.get(0).getUid());
  1045. if (userInfo != null) {
  1046. user.setUserName(userInfo.getName());
  1047. }
  1048. changedUserList.add(user);
  1049. } else {
  1050. log.info("change directly cause no teacher exist in room, roomId={}", roomId);
  1051. }
  1052. roomMemberDao.updateRoleByRidAndUid(roomId, targetUserId, targetRole);
  1053. RoleChangedMessage.ChangedUser user = new RoleChangedMessage.ChangedUser(targetUserId, targetRole);
  1054. UserInfo userInfo = userDao.findByUid(targetUserId);
  1055. if (userInfo != null) {
  1056. user.setUserName(userInfo.getName());
  1057. }
  1058. changedUserList.add(user);
  1059. msg.setUsers(changedUserList);
  1060. imHelper.publishMessage(userId, roomId, msg, 1);
  1061. String display = "display://type=1?userId=" + targetUserId + "?uri=";
  1062. DisplayMessage displayMessage = new DisplayMessage(display);
  1063. roomDao.updateDisplayByRid(roomId, display);
  1064. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  1065. log.info("changeRole, display changed: roomId={}, {}, targetUserId={}", roomId, display, targetUserId);
  1066. return true;
  1067. }
  1068. @Override
  1069. @Transactional(rollbackFor = Exception.class)
  1070. public Boolean memberOnlineStatus(List<ReqMemberOnlineStatus> statusList, String nonce, String timestamp, String signature) throws Exception {
  1071. String sign = imProperties.getSecret() + nonce + timestamp;
  1072. String signSHA1 = CodeUtil.hexSHA1(sign);
  1073. if (!signSHA1.equals(signature)) {
  1074. log.info("memberOnlineStatus signature error");
  1075. return true;
  1076. }
  1077. for (ReqMemberOnlineStatus status : statusList) {
  1078. int s = Integer.parseInt(status.getStatus());
  1079. String userId = status.getUserId();
  1080. log.info("memberOnlineStatus, userId={}, status={}", userId, status);
  1081. //1:offline 离线; 0: online 在线
  1082. if (s == 1) {
  1083. List<RoomMember> members = roomMemberDao.findByUid(userId);
  1084. if (!members.isEmpty()) {
  1085. scheduleManager.userIMOffline(userId);
  1086. }
  1087. } else if (s == 0) {
  1088. scheduleManager.userIMOnline(userId);
  1089. }
  1090. }
  1091. return true;
  1092. }
  1093. @Override
  1094. @Transactional(rollbackFor = Exception.class)
  1095. public void userIMOfflineKick(String userId) {
  1096. List<RoomMember> members = roomMemberDao.findByUid(userId);
  1097. for (RoomMember member : members) {
  1098. int userRole = member.getRole();
  1099. log.info("userIMOfflineKick: roomId={}, {}, role={}", member.getRid(), userId, RoleEnum.getEnumByValue(userRole));
  1100. try {
  1101. if (userRole == RoleTeacher.getValue() || userRole == RoleEnum.RoleAssistant.getValue()) {
  1102. Room room = roomDao.findByRid(member.getRid());
  1103. if (room == null) {
  1104. break;
  1105. }
  1106. if (isUserDisplay(room, member.getUid())) {
  1107. updateDisplay(member.getRid(), member.getUid(), "", 0);
  1108. log.info("memberOnlineStatus offline: roomId={}, {}", member.getRid(), member.getUid());
  1109. }
  1110. }
  1111. if (roomMemberDao.countByRid(member.getRid()) == 1) {
  1112. IMApiResultInfo apiResultInfo = null;
  1113. apiResultInfo = imHelper.dismiss(member.getUid(), member.getRid());
  1114. if (apiResultInfo.getCode() == 200) {
  1115. roomMemberDao.deleteUserByRidAndUid(member.getRid(), member.getUid());
  1116. roomDao.deleteByRid(member.getRid());
  1117. deleteWhiteboardByUser(member.getRid(), member.getUid());
  1118. log.info("dismiss the room: {},userId: {}", member.getRid(),userId);
  1119. } else {
  1120. log.error("{} exit {} room error: {}", member.getUid(), member.getRid(), apiResultInfo.getErrorMessage());
  1121. }
  1122. } else {
  1123. IMApiResultInfo apiResultInfo = null;
  1124. apiResultInfo = imHelper.quit(new String[]{member.getUid()}, member.getRid());
  1125. if (apiResultInfo.isSuccess()) {
  1126. roomMemberDao.deleteUserByRidAndUid(member.getRid(), member.getUid());
  1127. MemberChangedMessage msg = new MemberChangedMessage(MemberChangedMessage.Action_Leave, member.getUid(), userRole);
  1128. msg.setUserName(member.getName());
  1129. imHelper.publishMessage(member.getUid(), member.getRid(), msg);
  1130. imHelper.quit(new String[]{member.getUid()}, member.getRid());
  1131. log.info("quit group: roomId={},userId: {}", member.getRid(), member.getUid());
  1132. } else {
  1133. log.error("{} exit {} room error: {}", member.getUid(), member.getRid(), apiResultInfo.getErrorMessage());
  1134. }
  1135. }
  1136. userDao.deleteByUid(member.getUid());
  1137. } catch (Exception e) {
  1138. log.error("userIMOfflineKick error: userId={}", userId);
  1139. }
  1140. }
  1141. }
  1142. @Override
  1143. @Transactional(rollbackFor = Exception.class)
  1144. public void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData) throws Exception {
  1145. SysUser sysUser = sysUserFeignService.queryUserInfo();
  1146. if(sysUser == null){
  1147. throw new BizException("用户信息获取失败");
  1148. }
  1149. String content = playMidiMessageData.getContent();
  1150. String roomId = playMidiMessageData.getRoomId();
  1151. CustomMessage customMessage = JSONObject.parseObject(content,CustomMessage.class);
  1152. String userId = sysUser.getId().toString();
  1153. MetronomeMessageMessage displayMessage = new MetronomeMessageMessage(customMessage);
  1154. imHelper.publishMessage(userId, roomId, displayMessage, 1);
  1155. //记录节拍器消息
  1156. courseScheduleStudentPaymentDao.adjustPlayMidi(Long.parseLong(roomId.substring(1)),playMidiMessageData.getUserId(),content);
  1157. }
  1158. @Override
  1159. public List<RongyunBasicUserDto> queryNoJoinStu(String roomId) {
  1160. return courseScheduleStudentPaymentDao.queryNoJoinStu(roomId,roomId.substring(1));
  1161. }
  1162. public void updateDisplay(String roomId, String senderId, String display, Integer isIncludeSender) throws Exception {
  1163. roomDao.updateDisplayByRid(roomId, display);
  1164. DisplayMessage displayMessage = new DisplayMessage(display);
  1165. imHelper.publishMessage(senderId, roomId, displayMessage, isIncludeSender);
  1166. }
  1167. public boolean isUserDisplay(Room room, String userId) {
  1168. boolean result = false;
  1169. if (!room.getDisplay().isEmpty() && room.getDisplay().contains("userId=" + userId)) {
  1170. if (room.getDisplay().contains("type=0") || room.getDisplay().contains("type=1") || room.getDisplay().contains("type=3")) {
  1171. result = true;
  1172. }
  1173. }
  1174. return result;
  1175. }
  1176. }