音视频通话系统通知消息添加

core/src/main/java/com/wecloud/im/ws/model/request/PushVO.java

 package com.wecloud.im.ws.model.request;
 
+import lombok.AllArgsConstructor;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import java.io.Serializable;
 import java.util.HashMap;
@@ -11,6 +13,8 @@ import java.util.HashMap;
  * @Date 2019-12-05
  */
 @Data
+@AllArgsConstructor
+@NoArgsConstructor
 public class PushVO implements Serializable {
 
     /**

core/src/main/java/com/wecloud/rtc/service/impl/RtcServiceImpl.java

@@ -7,6 +7,7 @@ import com.google.common.collect.Lists;
 import com.wecloud.im.entity.ImApplication;
 import com.wecloud.im.entity.ImClient;
 import com.wecloud.im.entity.ImRtcRecord;
+import com.wecloud.im.mq.MqSender;
 import com.wecloud.im.param.rtc.CandidateForwardParam;
 import com.wecloud.im.param.rtc.CreateRtcChannelParam;
 import com.wecloud.im.param.rtc.CreateRtcChannelResult;
@@ -16,12 +17,16 @@ import com.wecloud.im.param.rtc.RejectRtcChannelParam;
 import com.wecloud.im.param.rtc.SdpForwardParam;
 import com.wecloud.im.sdk.enums.RtcStateEnum;
 import com.wecloud.im.sdk.enums.SingleRtcOperateTypeEnum;
+import com.wecloud.im.service.ContextService;
 import com.wecloud.im.service.ImApplicationService;
 import com.wecloud.im.service.ImClientBlacklistService;
 import com.wecloud.im.service.ImClientService;
 import com.wecloud.im.service.ImRtcRecordService;
 import com.wecloud.im.ws.cache.UserStateCacheManager;
 import com.wecloud.im.ws.cache.UserStateListener;
+import com.wecloud.im.ws.model.request.PushVO;
+import com.wecloud.pushserver.client.model.constant.MqConstant;
+import com.wecloud.pushserver.client.model.dto.PushDTO;
 import com.wecloud.rtc.entity.response.RtcCallResponse;
 import com.wecloud.rtc.entity.response.RtcCandidateForwardResponse;
 import com.wecloud.rtc.entity.response.RtcClientJoinResponse;
@@ -72,6 +77,12 @@ public class RtcServiceImpl extends UserStateListener implements RtcService {
     @Autowired
     private ImRtcRecordService imRtcRecordService;
 
+    @Autowired
+    private MqSender mqSender;
+
+    @Autowired
+    private ContextService contextService;
+
     @Override
     public void onLineEvent(Long client, Integer platform, String longChannelId) {
         // nothing need to do
@@ -133,11 +144,13 @@ public class RtcServiceImpl extends UserStateListener implements RtcService {
         // 创建通话记录
         imRtcRecordService.createRtcRecord(createRtcChannelParam, createRtcChannelResult.getChannelId(), currentClient);
 
-        // TODO 待开发 下发安卓和ios系统推送
-
+        // 异步推送系统通知消息
+        ImApplication imApplication = contextService.getImApplicationIfNotNullOrThrow(currentClient.getFkAppid());
+        PushDTO pushDTO = mqSender.buildPushDto(new PushVO("音视频通话", "点击查看", null), toClient, imApplication);
+        if (pushDTO != null) {
+            mqSender.orderSend(MqConstant.Topic.IM_ORDER_MSG_TOPIC, MqConstant.Tag.IM_ORDER_MSG_TAG, pushDTO);
+        }
         return createRtcChannelResult;
-
-
     }
 
     @Override