代码优化

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;
         }
 

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)){

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;