Merge remote-tracking branch 'origin/yonge' into yonge

mec-biz/src/main/java/com/ym/mec/biz/service/OnlineMusicGroupService.java

@@ -0,0 +1,15 @@
+package com.ym.mec.biz.service;
+
+import com.ym.mec.biz.dal.entity.MusicGroup;
+import com.ym.mec.common.page.QueryInfo;
+
+import java.util.List;
+
+public interface OnlineMusicGroupService {
+
+    /**
+     * 创建线上乐团班级
+     */
+    void createOnlineMusicClassGroup();
+
+}

mec-biz/src/main/java/com/ym/mec/biz/service/SysMessageService.java

@@ -42,7 +42,7 @@ public interface SysMessageService extends BaseService<Long, SysMessage> {
 	 * @param roomId
 	 * @param content
 	 */
-	void batchSendImPlayMidiMessage(String senderId,String roomId, String content);
+//	void batchSendImPlayMidiMessage(String senderId,String roomId, String content);
 
 	/**
 	 * 批量发送消息

mec-biz/src/main/java/com/ym/mec/biz/service/impl/OnlineMusicGroupServiceImpl.java

@@ -0,0 +1,14 @@
+package com.ym.mec.biz.service.impl;
+
+import com.ym.mec.biz.dal.entity.MusicGroup;
+import com.ym.mec.biz.service.OnlineMusicGroupService;
+
+import java.util.List;
+
+public class OnlineMusicGroupServiceImpl implements OnlineMusicGroupService {
+
+    @Override
+    public void createOnlineMusicClassGroup() {
+
+    }
+}

mec-biz/src/main/java/com/ym/mec/biz/service/impl/SysMessageServiceImpl.java

@@ -192,16 +192,16 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		imFeignService.privateSend(privateMessage);
 	}
 
-	@Override
+	/*@Override
 	public void batchSendImPlayMidiMessage(String senderId,String roomId, String content) {
 		ImGroupMessage groupMessage = new ImGroupMessage();
-//		privateMessage.setObjectName("DY:PlayMidiMessage");
+		privateMessage.setObjectName("DY:PlayMidiMessage");
 		groupMessage.setTargetId(roomId.split(","));
 		groupMessage.setSenderId(senderId);
 		groupMessage.setContent(new ImPlayMidiMessage(content,null));
 		groupMessage.setType("DY:PlayMidiMessage");
 		imFeignService.privateSendCustom(groupMessage);
-	}
+	}*/
 
 	@Override
 	public void sendPrivateMessage(String studentId, String content) {

mec-client-api/src/main/java/com/ym/mec/im/ImFeignService.java

@@ -102,9 +102,9 @@ public interface ImFeignService {
 	 * @param groupMessage
 	 * @return
 	 */
-	@PostMapping(value = "private/sendCustom")
+//	@PostMapping(value = "private/sendCustom")
 	//body模板
 	//{"senderId":"325","targetId":[1094986],"objectName":"RC:TxtMsg",
 	// "content":{"content":"www.baidu.com"}}
-	Object privateSendCustom(@RequestBody ImGroupMessage groupMessage);
+//	Object privateSendCustom(@RequestBody ImGroupMessage groupMessage);
 }

mec-client-api/src/main/java/com/ym/mec/im/fallback/ImFeignServiceFallback.java

@@ -59,9 +59,9 @@ public class ImFeignServiceFallback implements ImFeignService {
     public Object privateSend(ImPrivateMessage privateMessage) {
         return null;
     }
-
+/*
     @Override
     public Object privateSendCustom(ImGroupMessage groupMessage) {
         return null;
-    }
+    }*/
 }

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

@@ -39,7 +39,7 @@ public class PrivateController {
         return messageService.privateSend(privateMessage);
     }
 
-    @RequestMapping(value = "/sendCustom", method = RequestMethod.POST)
+    /*@RequestMapping(value = "/sendCustom", method = RequestMethod.POST)
     public Object sendCustom(@RequestBody ImGroupMessage imGroupMessage) throws Exception {
         GroupMessage groupMessage = new GroupMessage();
         ImTxtMessage content = (ImTxtMessage)imGroupMessage.getContent();
@@ -50,7 +50,7 @@ public class PrivateController {
         groupMessage.setSenderId(imGroupMessage.getSenderId());
         groupMessage.setObjectName(imGroupMessage.getType());
         return messageService.groupSend(groupMessage);
-    }
+    }*/
 
     @RequestMapping(value = "/recall", method = RequestMethod.POST)
     public Object recall(@RequestBody RecallMessage recallMessage) throws Exception {

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

@@ -1,6 +1,5 @@
 package com.ym.controller;
 
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.ym.common.ApiException;
 import com.ym.common.BaseResponse;
@@ -59,14 +58,12 @@ public class RoomController{
             throw new BizException("用户信息获取失败");
         }
 //        roomService.sendImPlayMidiMessage(playMidiMessageData);
-        CustomGroupMessage groupMessage = new CustomGroupMessage();
-        CustomMessage customMessage = new CustomMessage(playMidiMessageData.getContent(),null);
-        customMessage.setTYPE("DY:PlayMidiMessage");
+        GroupMessage groupMessage = new GroupMessage();
+        CustomMessage customMessage = JSONObject.parseObject(playMidiMessageData.getContent(),CustomMessage.class);
         groupMessage.setContent(customMessage);
         groupMessage.setTargetId(playMidiMessageData.getRoomId().split(","));
         groupMessage.setSenderId(sysUser.getId().toString());
         groupMessage.setObjectName("DY:PlayMidiMessage");
-        groupMessage.setCustomContent(JSON.parseObject(playMidiMessageData.getContent()));
         messageService.groupSend(groupMessage);
         return new BaseResponse<>();
     }

mec-im/src/main/java/com/ym/pojo/CustomMessage.java

@@ -1,43 +1,56 @@
 package com.ym.pojo;
 
-import com.alibaba.fastjson.JSONObject;
 import io.rong.messages.BaseMessage;
 
 public class CustomMessage extends BaseMessage {
-    private String content = "";
-    private String extra = "";
-    private String TYPE = "";
+    private Boolean enable;
+    private int customType;
+    private int rate;
+    private int userId;
 
-    public CustomMessage(String content, String extra) {
-        this.content = content;
-        this.extra = extra;
+    public Boolean getEnable() {
+        return enable;
     }
 
-    public void setTYPE(String TYPE) {
-        this.TYPE = TYPE;
+    public void setEnable(Boolean enable) {
+        this.enable = enable;
     }
 
-    public String getType() {
-        return TYPE;
+    public int getCustomType() {
+        return customType;
+    }
+
+    public void setCustomType(int customType) {
+        this.customType = customType;
     }
 
-    public String getContent() {
-        return this.content;
+    public int getRate() {
+        return rate;
     }
 
-    public void setContent(String content) {
-        this.content = content;
+    public void setRate(int rate) {
+        this.rate = rate;
     }
 
-    public String getExtra() {
-        return this.extra;
+    public int getUserId() {
+        return userId;
     }
 
-    public void setExtra(String extra) {
-        this.extra = extra;
+    public void setUserId(int userId) {
+        this.userId = userId;
+    }
+
+    @Override
+    public String getType() {
+        return "DY:PlayMidiMessage";
     }
 
+    @Override
     public String toString() {
-        return JSONObject.toJSONString(this);
+        return "{enable=" + enable +
+                ", customType=" + customType +
+                ", rate=" + rate +
+                ", userId=" + userId +
+                '}';
     }
 }

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

@@ -1369,14 +1369,14 @@ public class RoomServiceImpl implements RoomService {
         return true;
     }
 
-    @Override
+    /*@Override
     public void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData) {
         SysUser sysUser = sysUserFeignService.queryUserInfo();
         if(sysUser == null){
             throw new BizException("用户信息获取失败");
         }
         sysMessageService.batchSendImPlayMidiMessage(sysUser.getId().toString(),playMidiMessageData.getRoomId(),playMidiMessageData.getContent());
-    }
+    }*/
 
     private void updateDisplay(String roomId, String senderId, String display, Integer isIncludeSender) throws ApiException, Exception {
         roomDao.updateDisplayByRid(roomId, display);

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

@@ -70,5 +70,5 @@ public interface RoomService {
     /**
      * 发送节拍器自定义消息
      */
-    void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData);
+//    void sendImPlayMidiMessage(PlayMidiMessageData playMidiMessageData);
 }

mec-web/src/main/java/com/ym/mec/web/controller/education/EduOnlineMusicGroupController.java

@@ -0,0 +1,58 @@
+package com.ym.mec.web.controller.education;
+
+import com.ym.mec.auth.api.client.SysUserFeignService;
+import com.ym.mec.auth.api.entity.SysUser;
+import com.ym.mec.biz.dal.dao.EmployeeDao;
+import com.ym.mec.biz.dal.entity.Employee;
+import com.ym.mec.biz.dal.page.MusicGroupQueryInfo;
+import com.ym.mec.biz.service.MusicGroupService;
+import com.ym.mec.common.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Arrays;
+import java.util.List;
+
+@RequestMapping("eduCourseReview")
+@Api(tags = "教务端课程评价")
+@RestController
+public class EduOnlineMusicGroupController extends BaseController {
+
+    @Autowired
+    private MusicGroupService musicGroupService;
+    @Autowired
+    private SysUserFeignService sysUserFeignService;
+    @Autowired
+    private EmployeeDao employeeDao;
+
+    @ApiOperation(value = "分页查询乐团列表")
+    @GetMapping("/queryPage")
+    @PreAuthorize("@pcs.hasPermissions('musicGroup/queryPage')")
+    public Object queryPage(MusicGroupQueryInfo queryInfo) {
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        if (sysUser == null) {
+            return failed("用户信息获取失败");
+        }
+        if(!sysUser.getIsSuperAdmin()){
+            Employee employee = employeeDao.get(sysUser.getId());
+            if (StringUtils.isEmpty(queryInfo.getOrganId())) {
+                queryInfo.setOrganId(employee.getOrganIdList());
+            }else if(StringUtils.isEmpty(employee.getOrganIdList())){
+                return failed("用户所在分部异常");
+            }else {
+                List<String> list = Arrays.asList(employee.getOrganIdList().split(","));
+                if(!list.containsAll(Arrays.asList(queryInfo.getOrganId().split(",")))){
+                    return failed("非法请求");
+                }
+            }
+        }
+        return succeed(musicGroupService.queryMusicGroupPage(queryInfo));
+    }
+
+}