rtc记录

core/src/main/java/com/wecloud/im/service/ImRtcRecordService.java

 package com.wecloud.im.service;
 package com.wecloud.im.service;
 
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.wecloud.im.entity.ImClient;
 import com.wecloud.im.entity.ImRtcRecord;
 import com.wecloud.im.entity.ImRtcRecord;
 import com.wecloud.im.param.rtc.CreateRtcChannelParam;
 import com.wecloud.im.param.rtc.CreateRtcChannelParam;
 import com.wecloud.im.param.rtc.RtcRecordParam;
 import com.wecloud.im.param.rtc.RtcRecordParam;
@@ -18,7 +19,7 @@ public interface ImRtcRecordService extends BaseService<ImRtcRecord> {
      * @param param
      * @param param
      * @param channelId
      * @param channelId
      */
      */
-    void createRtcRecord(CreateRtcChannelParam param, Long channelId);
+    void createRtcRecord(CreateRtcChannelParam param, Long channelId, ImClient currentClient);
 
 
     /**
     /**
      * 更新音视频记录
      * 更新音视频记录

core/src/main/java/com/wecloud/im/service/impl/ImRtcRecordServiceImpl.java

@@ -31,15 +31,11 @@ import java.util.Date;
 @Service
 @Service
 public class ImRtcRecordServiceImpl extends BaseServiceImpl<ImRtcRecordMapper, ImRtcRecord> implements ImRtcRecordService {
 public class ImRtcRecordServiceImpl extends BaseServiceImpl<ImRtcRecordMapper, ImRtcRecord> implements ImRtcRecordService {
 
 
-    @Autowired
-    private ImClientService imClientService;
-
 
 
     @Async
     @Async
     @Override
     @Override
-    public void createRtcRecord(CreateRtcChannelParam param, Long channelId) {
+    public void createRtcRecord(CreateRtcChannelParam param, Long channelId, ImClient currentClient) {
         try {
         try {
-            ImClient currentClient = imClientService.getCurrentClient();
             ImRtcRecord rtcRecord = new ImRtcRecord();
             ImRtcRecord rtcRecord = new ImRtcRecord();
             rtcRecord.setId(SnowflakeUtil.getId());
             rtcRecord.setId(SnowflakeUtil.getId());
             rtcRecord.setFkAppid(currentClient.getFkAppid());
             rtcRecord.setFkAppid(currentClient.getFkAppid());

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

@@ -120,7 +120,7 @@ public class RtcServiceImpl extends UserStateListener implements RtcService {
         wsRtcWrite.rtcCall(rtcCallResponse, toClient.getId());
         wsRtcWrite.rtcCall(rtcCallResponse, toClient.getId());
 
 
         // 创建通话记录  todo 优化为mq推送
         // 创建通话记录  todo 优化为mq推送
-        imRtcRecordService.createRtcRecord(createRtcChannelParam, createRtcChannelResult.getChannelId());
+        imRtcRecordService.createRtcRecord(createRtcChannelParam, createRtcChannelResult.getChannelId(), currentClient);
 
 
         // TODO 待开发 下发安卓和ios系统推送
         // TODO 待开发 下发安卓和ios系统推送