diff --git a/im-platform/src/main/java/com/bx/implatform/controller/GroupMessageController.java b/im-platform/src/main/java/com/bx/implatform/controller/GroupMessageController.java index 3f803e5..007a3de 100644 --- a/im-platform/src/main/java/com/bx/implatform/controller/GroupMessageController.java +++ b/im-platform/src/main/java/com/bx/implatform/controller/GroupMessageController.java @@ -24,7 +24,7 @@ public class GroupMessageController { @PostMapping("/send") @Operation(summary = "发送群聊消息", description = "发送群聊消息") - public Result sendMessage(@Valid @RequestBody GroupMessageDTO vo) { + public Result sendMessage(@Valid @RequestBody GroupMessageDTO vo) { return ResultUtils.success(groupMessageService.sendMessage(vo)); } diff --git a/im-platform/src/main/java/com/bx/implatform/controller/PrivateMessageController.java b/im-platform/src/main/java/com/bx/implatform/controller/PrivateMessageController.java index f18c68d..622c5dc 100644 --- a/im-platform/src/main/java/com/bx/implatform/controller/PrivateMessageController.java +++ b/im-platform/src/main/java/com/bx/implatform/controller/PrivateMessageController.java @@ -24,7 +24,7 @@ public class PrivateMessageController { @PostMapping("/send") @Operation(summary = "发送消息", description = "发送私聊消息") - public Result sendMessage(@Valid @RequestBody PrivateMessageDTO vo) { + public Result sendMessage(@Valid @RequestBody PrivateMessageDTO vo) { return ResultUtils.success(privateMessageService.sendMessage(vo)); } diff --git a/im-platform/src/main/java/com/bx/implatform/dto/GroupMessageDTO.java b/im-platform/src/main/java/com/bx/implatform/dto/GroupMessageDTO.java index 4fbf715..9f8e2c8 100644 --- a/im-platform/src/main/java/com/bx/implatform/dto/GroupMessageDTO.java +++ b/im-platform/src/main/java/com/bx/implatform/dto/GroupMessageDTO.java @@ -23,7 +23,7 @@ public class GroupMessageDTO { private String content; @NotNull(message = "消息类型不可为空") - @Schema(description = "消息类型") + @Schema(description = "消息类型 0:文字 1:图片 2:文件 3:语音 4:视频") private Integer type; @Schema(description = "是否回执消息") diff --git a/im-platform/src/main/java/com/bx/implatform/dto/PrivateMessageDTO.java b/im-platform/src/main/java/com/bx/implatform/dto/PrivateMessageDTO.java index 4fb49e0..f954f93 100644 --- a/im-platform/src/main/java/com/bx/implatform/dto/PrivateMessageDTO.java +++ b/im-platform/src/main/java/com/bx/implatform/dto/PrivateMessageDTO.java @@ -21,7 +21,7 @@ public class PrivateMessageDTO { private String content; @NotNull(message = "消息类型不可为空") - @Schema(description = "消息类型") + @Schema(description = "消息类型 0:文字 1:图片 2:文件 3:语音 4:视频") private Integer type; } diff --git a/im-platform/src/main/java/com/bx/implatform/service/GroupMessageService.java b/im-platform/src/main/java/com/bx/implatform/service/GroupMessageService.java index a7e67c6..dc4efda 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/GroupMessageService.java +++ b/im-platform/src/main/java/com/bx/implatform/service/GroupMessageService.java @@ -15,7 +15,7 @@ public interface GroupMessageService extends IService { * @param dto 群聊消息 * @return 群聊id */ - Long sendMessage(GroupMessageDTO dto); + GroupMessageVO sendMessage(GroupMessageDTO dto); /** * 撤回消息 diff --git a/im-platform/src/main/java/com/bx/implatform/service/PrivateMessageService.java b/im-platform/src/main/java/com/bx/implatform/service/PrivateMessageService.java index ed40c30..261a5e0 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/PrivateMessageService.java +++ b/im-platform/src/main/java/com/bx/implatform/service/PrivateMessageService.java @@ -15,7 +15,7 @@ public interface PrivateMessageService extends IService { * @param dto 私聊消息 * @return 消息id */ - Long sendMessage(PrivateMessageDTO dto); + PrivateMessageVO sendMessage(PrivateMessageDTO dto); /** diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java index c44fc32..b29ec6b 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java +++ b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java @@ -55,7 +55,7 @@ public class GroupMessageServiceImpl extends ServiceImpl sendMessage = new IMPrivateMessage<>(); @@ -70,7 +71,7 @@ public class PrivateMessageServiceImpl extends ServiceImpl { + }).then((m) => { msgInfo.loadStatus = 'ok'; - msgInfo.id = id; + msgInfo.id = m.id; this.isReceipt = false; this.$store.commit("insertMessage", msgInfo); }) @@ -371,9 +371,9 @@ url: this.messageAction, method: 'post', data: msgInfo - }).then((id) => { + }).then((m) => { msgInfo.loadStatus = 'ok'; - msgInfo.id = id; + msgInfo.id = m.id; this.isReceipt = false; this.$store.commit("insertMessage", msgInfo); }) @@ -528,14 +528,9 @@ url: this.messageAction, method: 'post', data: msgInfo - }).then((id) => { - msgInfo.id = id; - msgInfo.sendTime = new Date().getTime(); - msgInfo.sendId = this.$store.state.userStore.userInfo.id; - msgInfo.selfSend = true; - msgInfo.status = this.$enums.MESSAGE_STATUS.UNSEND; - msgInfo.readedCount = 0; - this.$store.commit("insertMessage", msgInfo); + }).then((m) => { + m.selfSend = true; + this.$store.commit("insertMessage", m); // 会话置顶 this.moveChatToTop(); // 保持输入框焦点 @@ -605,14 +600,9 @@ url: this.messageAction, method: 'post', data: msgInfo - }).then((id) => { - msgInfo.id = id; - msgInfo.sendTime = new Date().getTime(); - msgInfo.sendId = this.$store.state.userStore.userInfo.id; - msgInfo.selfSend = true; - msgInfo.readedCount = 0; - msgInfo.status = this.$enums.MESSAGE_STATUS.UNSEND; - this.$store.commit("insertMessage", msgInfo); + }).then((m) => { + m.selfSend = true; + this.$store.commit("insertMessage", m); // 会话置顶 this.moveChatToTop(); }).finally(() => { diff --git a/im-uniapp/pages/chat/chat-box.vue b/im-uniapp/pages/chat/chat-box.vue index 1988662..1cb97f1 100644 --- a/im-uniapp/pages/chat/chat-box.vue +++ b/im-uniapp/pages/chat/chat-box.vue @@ -157,14 +157,9 @@ url: this.messageAction, method: 'POST', data: msgInfo - }).then((id) => { - msgInfo.id = id; - msgInfo.sendTime = new Date().getTime(); - msgInfo.sendId = this.$store.state.userStore.userInfo.id; - msgInfo.selfSend = true; - msgInfo.status = this.$enums.MESSAGE_STATUS.UNSEND; - msgInfo.readedCount = 0; - this.$store.commit("insertMessage", msgInfo); + }).then((m) => { + m.selfSend = true; + this.$store.commit("insertMessage", m); // 会话置顶 this.moveChatToTop(); // 滚动到底部 @@ -289,14 +284,9 @@ url: this.messageAction, method: 'POST', data: msgInfo - }).then((id) => { - msgInfo.id = id; - msgInfo.sendTime = new Date().getTime(); - msgInfo.sendId = this.$store.state.userStore.userInfo.id; - msgInfo.selfSend = true; - msgInfo.readedCount = 0, - msgInfo.status = this.$enums.MESSAGE_STATUS.UNSEND; - this.$store.commit("insertMessage", msgInfo); + }).then((m) => { + m.selfSend = true; + this.$store.commit("insertMessage", m); // 会话置顶 this.moveChatToTop(); this.sendText = ""; @@ -421,9 +411,9 @@ url: this.messageAction, method: 'POST', data: msgInfo - }).then((id) => { + }).then((m) => { msgInfo.loadStatus = 'ok'; - msgInfo.id = id; + msgInfo.id = m.id; this.isReceipt = false; this.$store.commit("insertMessage", msgInfo); }) @@ -476,9 +466,9 @@ url: this.messageAction, method: 'POST', data: msgInfo - }).then((id) => { + }).then((m) => { msgInfo.loadStatus = 'ok'; - msgInfo.id = id; + msgInfo.id = m.id; this.isReceipt = false; this.$store.commit("insertMessage", msgInfo); })