From c8bd0f408d5a5f0eca41a0cce29e673ff578e5d3 Mon Sep 17 00:00:00 2001
From: xsx <825657193@qq.com>
Date: Tue, 12 Sep 2023 09:31:28 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/bx/implatform/listener/GroupMessageListener.java     | 2 +-
 .../com/bx/implatform/listener/PrivateMessageListener.java   | 4 ++--
 .../src/main/java/com/bx/implatform/util/MinioUtil.java      | 5 ++---
 3 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/im-platform/src/main/java/com/bx/implatform/listener/GroupMessageListener.java b/im-platform/src/main/java/com/bx/implatform/listener/GroupMessageListener.java
index 1258781..f9f5be2 100644
--- a/im-platform/src/main/java/com/bx/implatform/listener/GroupMessageListener.java
+++ b/im-platform/src/main/java/com/bx/implatform/listener/GroupMessageListener.java
@@ -23,8 +23,8 @@ public class GroupMessageListener implements MessageListener {
     @Override
     public void process(SendResult result){
         GroupMessageInfo messageInfo = (GroupMessageInfo) result.getMessageInfo();
+        // 提示类数据不记录
         if(messageInfo.getType().equals(MessageType.TIP)){
-            // 提示类数据不记录
             return;
         }
 
diff --git a/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java b/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
index b7fad41..06fa83d 100644
--- a/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
+++ b/im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java
@@ -33,13 +33,12 @@ public class PrivateMessageListener implements MessageListener {
         PrivateMessageInfo messageInfo = (PrivateMessageInfo) result.getMessageInfo();
         // 提示类数据不记录
         if(messageInfo.getType().equals(MessageType.TIP.code())){
-
             return;
         }
         // 视频通话信令不记录
         if(messageInfo.getType() >= MessageType.RTC_CALL.code() && messageInfo.getType()< MessageType.RTC_CANDIDATE.code()){
             // 通知用户呼叫失败了
-            if(messageInfo.getType() == MessageType.RTC_CALL.code()
+            if(messageInfo.getType().equals(MessageType.RTC_CALL.code())
                     && !result.getCode().equals(IMSendCode.SUCCESS)){
                 PrivateMessageInfo sendMessage = new PrivateMessageInfo();
                 sendMessage.setRecvId(messageInfo.getSendId());
@@ -49,6 +48,7 @@ public class PrivateMessageListener implements MessageListener {
                 sendMessage.setSendTime(new Date());
                 imClient.sendPrivateMessage(sendMessage.getRecvId(),sendMessage);
             }
+            return;
         }
         // 更新消息状态
         if(result.getCode().equals(IMSendCode.SUCCESS)){
diff --git a/im-platform/src/main/java/com/bx/implatform/util/MinioUtil.java b/im-platform/src/main/java/com/bx/implatform/util/MinioUtil.java
index 203bae6..f10cfee 100644
--- a/im-platform/src/main/java/com/bx/implatform/util/MinioUtil.java
+++ b/im-platform/src/main/java/com/bx/implatform/util/MinioUtil.java
@@ -25,14 +25,12 @@ public class MinioUtil {
      * @return boolean
      */
     public Boolean bucketExists(String bucketName) {
-        Boolean found;
         try {
-            found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
+            return  minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
         } catch (Exception e) {
             log.error("查询bucket失败",e);
             return false;
         }
-        return found;
     }
 
     /**
@@ -141,6 +139,7 @@ public class MinioUtil {
                     .stream(stream, fileByte.length, -1).contentType(contentType).build();
             //文件名称相同会覆盖
             minioClient.putObject(objectArgs);
+
         } catch (Exception e) {
             log.error("上传图片失败,",e);
             return null;