update

mec-im/src/main/java/com/ym/controller/RoomController.java

@@ -4,11 +4,17 @@ import com.alibaba.fastjson.JSONObject;
 import com.ym.common.ApiException;
 import com.ym.common.BaseResponse;
 import com.ym.common.ErrorEnum;
+import com.ym.mec.auth.api.client.SysUserFeignService;
+import com.ym.mec.auth.api.entity.SysUser;
+import com.ym.mec.common.exception.BizException;
 import com.ym.pojo.*;
+import com.ym.service.MessageService;
 import com.ym.service.RoomService;
+import io.rong.models.message.GroupMessage;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+
 import java.util.List;
 
 /**
@@ -20,6 +26,10 @@ import java.util.List;
 public class RoomController{
     @Autowired
     RoomService roomService;
+    @Autowired
+    MessageService messageService;
+    @Autowired
+    SysUserFeignService sysUserFeignService;
 
     @RequestMapping(value = "/join", method = RequestMethod.POST)
     public Object joinRoom(@RequestBody ReqUserData data)
@@ -42,8 +52,20 @@ public class RoomController{
     }
 
     @RequestMapping(value = "/sendImPlayMidiMessage", method = RequestMethod.POST)
-    public Object sendImPlayMidiMessage(@RequestBody PlayMidiMessageData playMidiMessageData){
-        roomService.sendImPlayMidiMessage(playMidiMessageData);
+    public Object sendImPlayMidiMessage(@RequestBody PlayMidiMessageData playMidiMessageData) throws Exception {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        if(sysUser == null){
+            throw new BizException("用户信息获取失败");
+        }
+//        roomService.sendImPlayMidiMessage(playMidiMessageData);
+        GroupMessage groupMessage = new GroupMessage();
+        CustomMessage customMessage = new CustomMessage(playMidiMessageData.getContent(),null);
+        customMessage.setTYPE("DY:PlayMidiMessage");
+        groupMessage.setContent(customMessage);
+        groupMessage.setTargetId(playMidiMessageData.getRoomId().split(","));
+        groupMessage.setSenderId(sysUser.getId().toString());
+        groupMessage.setObjectName("DY:PlayMidiMessage");
+        messageService.groupSend(groupMessage);
         return new BaseResponse<>();
     }
 

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

@@ -32,7 +32,10 @@ public class MessageServiceImpl implements MessageService {
         return aPrivate;
     }
     private Group getGroup(){
-        return new Group(appKey,appSecret);
+        RongCloud rongCloud = RongCloud.getInstance(appKey, appSecret);
+        Group group = new Group(appKey, appSecret);
+        group.setRongCloud(rongCloud);
+        return group;
     }
     private Chatroom getChatroom(){
         return new Chatroom(appKey,appSecret);