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;