update

mec-im/src/main/java/com/ym/service/Impl/HereWhiteServiceImpl.java

@@ -10,6 +10,7 @@ import com.ym.service.RoomService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Isolation;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Date;
@@ -30,7 +31,7 @@ public class HereWhiteServiceImpl implements HereWhiteService {
     private RoomService roomService;
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @Transactional(rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
     public HereWhite create(String name, Integer userNum,Integer courseScheduleId) throws Exception {
         courseScheduleId = roomService.getCurrentCourseId(courseScheduleId.toString());
         JSONObject json = new JSONObject();

mec-im/src/main/java/com/ym/service/Impl/RoomServiceImpl.java

@@ -118,7 +118,7 @@ public class RoomServiceImpl implements RoomService {
         return Integer.parseInt(roomId);
     }
 
-    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public RoomResult joinRoom(String roomId) throws Exception {
         CheckUtils.checkArgument(roomId != null, "roomId must't be null");
@@ -1255,22 +1255,7 @@ public class RoomServiceImpl implements RoomService {
     }
 
     @Override
-    public void statusSync(ChannelStateNotify notify) throws Exception {
-        String roomId = notify.getChannelId();
-        String userId = notify.getUserId();
-        switch (notify.getEvent()){
-            case 11:
-                //成员加入
-                joinRoomSuccess(roomId, userId);
-                break;
-            case 12:
-                //成员退出
-                leaveRoomSuccess(roomId, userId);
-                break;
-        }
-    }
-
-    @Override
+    @Transactional(rollbackFor = Exception.class)
     public void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData) throws Exception {
         SysUser sysUser = sysUserFeignService.queryUserInfo();
         if(sysUser == null){
@@ -1291,6 +1276,7 @@ public class RoomServiceImpl implements RoomService {
         return courseScheduleStudentPaymentDao.queryNoJoinStu(roomId,roomId.substring(1));
     }
 
+    @Transactional(rollbackFor = Exception.class)
     private void updateDisplay(String roomId, String senderId, String display, Integer isIncludeSender) throws Exception {
         roomDao.updateDisplayByRid(roomId, display);
         DisplayMessage displayMessage = new DisplayMessage(display);

mec-im/src/main/java/com/ym/service/RoomService.java

@@ -66,8 +66,6 @@ public interface RoomService {
     Boolean memberOnlineStatus(List<ReqMemberOnlineStatus> statusList, String nonce, String timestamp, String signature) throws Exception;
     void userIMOfflineKick(String userId);
 
-    void statusSync(ChannelStateNotify notify) throws Exception;
-
     /**
      * 发送节拍器消息
      * @param playMidiMessageData