Sfoglia il codice sorgente

fixC2C私聊消息

Eric 1 anno fa
parent
commit
3a6ed76b8b

+ 1 - 1
mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImUserFriendServiceImpl.java

@@ -147,7 +147,7 @@ public class ImUserFriendServiceImpl extends BaseServiceImpl<Long, ImUserFriend>
             item.setImUserId(imGroupCoreService.getImUserId(String.valueOf(item.getUserId()),""));
 
             // 设置用户好友昵称
-            if (Objects.nonNull(item.getFriend())) {
+            if (Objects.nonNull(item.getFriend()) && StringUtils.isNotBlank(item.getFriend().getUserType())) {
                 String username = item.getFriend().getUsername();
 
                 List<String> userTypes = Lists.newArrayList(item.getFriend().getUserType().split(","));

+ 7 - 0
mec-im/src/main/java/com/ym/controller/GroupController.java

@@ -25,6 +25,7 @@ import io.rong.models.message.GroupMessage;
 import io.rong.models.message.MentionMessage;
 import io.rong.models.message.RecallMessage;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -121,6 +122,12 @@ public class GroupController{
                     .msgType(ETencentMessage.TIMTextElem.name())
                     .msgContent(TencentRequest.TextMessageBody.builder().text(imMessageDto.getMessageContent()).build())
                     .build());
+
+                // 普通文本消息,若是超链接地址,则需要转换成腾讯云的消息格式
+                if (imMessageDto.getMessageContent().startsWith("http") && StringUtils.isBlank(imMessageDto.getExtra())) {
+                    // 自动填充为拓展消息内容
+                    build.setCloudCustomData(imMessageDto.getMessageContent());
+                }
             }
         }
 

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

@@ -18,6 +18,7 @@ import io.rong.models.message.PrivateMessage;
 import io.rong.models.message.RecallMessage;
 import io.rong.models.message.TemplateMessage;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -108,6 +109,12 @@ public class PrivateController {
                     .msgType(ETencentMessage.TIMTextElem.name())
                     .msgContent(TencentRequest.TextMessageBody.builder().text(imMessageDto.getMessageContent()).build())
                     .build());
+
+                // 普通文本消息,若是超链接地址,则需要转换成腾讯云的消息格式
+                if (imMessageDto.getMessageContent().startsWith("http") && StringUtils.isBlank(imMessageDto.getExtra())) {
+                    // 自动填充为拓展消息内容
+                    build.setCloudCustomData(imMessageDto.getMessageContent());
+                }
             }
         }
         Boolean ret = imPluginContext.getPluginService().sendPrivateMessage(build);