直播分享

mec-biz/src/main/java/com/ym/mec/biz/dal/enums/MessageTypeEnum.java

@@ -217,6 +217,7 @@ public enum MessageTypeEnum implements BaseEnum<String, MessageTypeEnum> {
 
     STUDENT_SMS_CLOUD_PAYMENT("STUDENT_SMS_CLOUD_PAYMENT",  "待缴费订单"),
     STUDENT_PUSH_CLOUD_PAYMENT("STUDENT_PUSH_CLOUD_PAYMENT",  "待缴费订单"),
+    IM_SHARE_LIVE_URL("IM_SHARE_LIVE_URL",  "直播链接分享")
     ;
 
     MessageTypeEnum(String code, String msg) {

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

@@ -30,5 +30,13 @@ public interface ImLiveBroadcastRoomService extends IService<ImLiveBroadcastRoom
 
     void test();
 
+    /**
+    * @description: 分享直播链接
+     * @param roomUid
+    * @return void
+    * @author zx
+    * @date 2022/2/23 16:17
+    */
+    void shareGroup(String roomUid,String groupIds);
 }
 

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

@@ -9,14 +9,19 @@ import com.ym.mec.auth.api.entity.SysUser;
 import com.ym.mec.biz.dal.dao.ImLiveBroadcastRoomDao;
 import com.ym.mec.biz.dal.dto.ImLiveBroadcastRoomDto;
 import com.ym.mec.biz.dal.entity.ImLiveBroadcastRoom;
+import com.ym.mec.biz.dal.enums.ImSendTypeEnum;
+import com.ym.mec.biz.dal.enums.MessageTypeEnum;
 import com.ym.mec.biz.dal.vo.ImLiveBroadcastRoomVo;
 import com.ym.mec.biz.service.ImLiveBroadcastRoomService;
+import com.ym.mec.biz.service.SysConfigService;
+import com.ym.mec.biz.service.SysMessageService;
 import com.ym.mec.common.exception.BizException;
 import com.ym.mec.common.page.PageInfo;
 import com.ym.mec.common.page.PageUtil;
 import com.ym.mec.common.tenant.TenantContextHolder;
 import com.ym.mec.im.ImFeignService;
 import com.ym.mec.util.date.DateUtil;
+import com.ym.mec.util.http.HttpUtil;
 import org.redisson.api.RedissonClient;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,6 +49,8 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
     private ImFeignService imFeignService;
     @Autowired
     private RedissonClient redissonClient;
+    @Autowired
+    private SysMessageService sysMessageService;
 
     /**
      * 进入直播间检查数据
@@ -189,5 +196,17 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
 
     }
 
+    @Override
+    public void shareGroup(String roomUid,String groupIds) {
+        ImLiveBroadcastRoomVo imLiveBroadcastRoomVo = queryRoomInfo(roomUid);
+        if (imLiveBroadcastRoomVo == null) {
+            throw new BizException("直播间信息异常！");
+        }
+        SysUser sysUser = sysUserFeignService.queryUserInfo();
+        sysMessageService.batchSendImMessage(MessageTypeEnum.IM_SHARE_LIVE_URL,sysUser.getId().toString(),null,groupIds.split(","),null,
+                imLiveBroadcastRoomVo.getTenantName(),imLiveBroadcastRoomVo.getRoomTitle(),imLiveBroadcastRoomVo.getSpeakerName(),
+                DateUtil.format(imLiveBroadcastRoomVo.getLiveStartTime(),DateUtil.CHINESE_DATA_FORMAT_1),
+                imLiveBroadcastRoomVo.getLiveRemark(), HttpUtil.getSortUrl("https://test.dayaedu.com/"));
+    }
 }
 

mec-util/src/main/java/com/ym/mec/util/date/DateUtil.java

@@ -21,6 +21,8 @@ public class DateUtil {
 
 	public static final String CHINESE_DATA_FORMAT = "yyyy年MM月dd日 HH:mm:ss";
 
+	public static final String CHINESE_DATA_FORMAT_1 = "yyyy/MM/dd HH:mm";
+
 	public static final String YEAR_MONTH_DAY_HOUR = "yyyyMMddHH";
 
 	public static final String DEFAULT_PATTERN = "yyyy-MM-dd";

mec-web/src/main/java/com/ym/mec/web/controller/ImLiveBroadcastRoomController.java

@@ -94,5 +94,12 @@ public class ImLiveBroadcastRoomController extends BaseController {
         return succeed();
     }
 
+    @GetMapping("/shareGroup")
+    public HttpResponseResult shareGroup(@ApiParam(value = "房间uid", required = true) String roomUid,
+                                         @ApiParam(value = "群编号", required = true) String groupIds) {
+        imLiveBroadcastRoomService.shareGroup(roomUid,groupIds);
+        return succeed();
+    }
+
 }