|
@@ -20,6 +20,7 @@ import org.apache.commons.lang3.StringUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -67,6 +68,9 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
@Resource
|
|
|
private RedisTemplate<String,Object> redisTemplate;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ImGroupService imGroupService;
|
|
|
+
|
|
|
private String QUIT_ROOM_SUCCESS = "quitRoomSuccess:";
|
|
|
|
|
|
@Override
|
|
@@ -113,10 +117,10 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
for (ImNetworkRoomMember item : roomMemberList) {
|
|
|
if (EStatus.ENABLE.match(item.getRole())) {
|
|
|
// 老师
|
|
|
- item.setImUserId(String.valueOf(item.getUserId()));
|
|
|
+ item.setImUserId(imGroupService.getImUserId(String.valueOf(item.getUserId()),ClientEnum.TEACHER.name()));
|
|
|
} else {
|
|
|
// 学生
|
|
|
- item.setImUserId(MessageFormat.format("{0}:{1}", String.valueOf(item.getUserId()), ClientEnum.STUDENT.name()));
|
|
|
+ item.setImUserId(imGroupService.getImUserId(String.valueOf(item.getUserId()),ClientEnum.STUDENT.name()));
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -136,7 +140,7 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
// IM用户ID
|
|
|
String imUserId = sysUser.getUserId().toString();
|
|
|
if (UserRoleEnum.STUDENT == userRole) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId,ClientEnum.STUDENT.name());
|
|
|
}
|
|
|
roomMember.setImUserId(imUserId);
|
|
|
|
|
@@ -321,7 +325,9 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
|
|
|
String imUserId = String.valueOf(userId);
|
|
|
if (ClientEnum.STUDENT == customMessage.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.STUDENT.name());
|
|
|
+ }else if(ClientEnum.TEACHER == customMessage.getClientType()){
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
// 用户ID
|
|
|
imHelper.publishMessage(imUserId, roomId.toString(), displayMessage, 1);
|
|
@@ -371,7 +377,9 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
// IM用户ID
|
|
|
String imUserId = String.valueOf(userId);
|
|
|
if (ClientEnum.STUDENT == musicSheetDto.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId= imGroupService.getImUserId(imUserId,ClientEnum.STUDENT.name());
|
|
|
+ }else if (ClientEnum.TEACHER == musicSheetDto.getClientType()) {
|
|
|
+ imUserId= imGroupService.getImUserId(imUserId,ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
|
|
|
imHelper.publishMessage(imUserId, courseScheduleId.toString(), msg, 0);
|
|
@@ -410,7 +418,9 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
|
|
|
String imUserId = String.valueOf(userId);
|
|
|
if (ClientEnum.STUDENT == displayData.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.STUDENT.name());
|
|
|
+ } else if (ClientEnum.TEACHER == displayData.getClientType()) {
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
|
|
|
this.updateDisplay(imUserId,room);
|
|
@@ -562,9 +572,10 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
String imUserId = String.valueOf(sysUser.getId());
|
|
|
UserRoleEnum userRole = UserRoleEnum.TEACHER;
|
|
|
if (ClientEnum.STUDENT == deviceControl.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
-
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.STUDENT.name());
|
|
|
userRole = UserRoleEnum.STUDENT;
|
|
|
+ }else {
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
|
|
|
ImNetworkRoomMember roomMember = Optional.ofNullable(imNetworkRoomMemberService.getDao().findByRidAndUid(deviceControl.getRoomId(), sysUser.getId(),
|
|
@@ -611,9 +622,11 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
UserRoleEnum userRole = UserRoleEnum.TEACHER;
|
|
|
String imUserId = String.valueOf(userId);
|
|
|
if (ClientEnum.STUDENT == deviceStatusSync.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId,ClientEnum.STUDENT.name());
|
|
|
|
|
|
userRole = UserRoleEnum.STUDENT;
|
|
|
+ }else {
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
|
|
|
ImNetworkDeviceTypeEnum deviceType = deviceStatusSync.getDeviceType();
|
|
@@ -656,9 +669,7 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
List<BasicUserInfo> userInfos = courseScheduleStudentPaymentService.getDao().queryNoJoinStu(roomId);
|
|
|
|
|
|
for (BasicUserInfo item : userInfos) {
|
|
|
-
|
|
|
- item.setImUserId(MessageFormat.format("{0}:{1}", String.valueOf(item.getUserId()),
|
|
|
- ClientEnum.STUDENT.name()));
|
|
|
+ item.setImUserId(imGroupService.getImUserId(String.valueOf(item.getUserId()),ClientEnum.STUDENT.name()));
|
|
|
}
|
|
|
|
|
|
return userInfos;
|
|
@@ -714,7 +725,9 @@ public class ImNetworkRoomServiceImpl extends ServiceImpl<ImNetworkRoomDao, ImNe
|
|
|
// IM用户ID
|
|
|
String imUserId = String.valueOf(userId);
|
|
|
if (ClientEnum.STUDENT == musicSheetDto.getClientType()) {
|
|
|
- imUserId = MessageFormat.format("{0}:{1}", imUserId, ClientEnum.STUDENT.name());
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.STUDENT.name());
|
|
|
+ }else {
|
|
|
+ imUserId = imGroupService.getImUserId(imUserId, ClientEnum.TEACHER.name());
|
|
|
}
|
|
|
|
|
|
imHelper.publishMessage(imUserId, courseSchedule.getTeacherId().toString(), roomId.toString(), statusMessage);
|