消息关键词触发特效

webchat-admin/src/main/java/com/webchat/admin/controller/FileController.java

@@ -18,6 +18,8 @@ import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
 
 @RestController
 @RequestMapping("/admin-service/file")
@@ -37,6 +39,17 @@ public class FileController {
         return APIResponseBeanUtil.success(uploadResultDTO);
     }
 
+    @PostMapping("/upload/editor")
+    public APIResponseBean<UploadResultVO> uploadEditor(@RequestParam("file") MultipartFile file) {
+        String path = request.getHeader("upload-path");
+        Assert.isTrue(StringUtils.isNotBlank(path), "上传路径不能为空");
+        String timePackage = DateUtils.getDate2String(DateUtils.YYYYMMDD, new Date());
+        UploadResultVO uploadResultDTO = minioService.upload(path + "/" + timePackage, file, true);
+        Map<String, String> urlMap = new HashMap<>();
+        urlMap.put("url", uploadResultDTO.getUrl());
+        return APIResponseBeanUtil.success(urlMap);
+    }
+
     @GetMapping("/download")
     public void download(@RequestParam String filename, HttpServletResponse response) {
         minioService.download(filename, response);

webchat-common/src/main/java/com/webchat/common/enums/ChatMessageTypeEnum.java

@@ -17,7 +17,8 @@ public enum ChatMessageTypeEnum {
     WALLET_BALANCE(6, "钱包余额"),
     CHATTING_REFRESH(7, "刷新对话列表"),
     VIDEO_CALL(8, "音视频呼叫"),
-    GROUP_VIDEO_CALL(9, "群聊音视频呼叫");
+    GROUP_VIDEO_CALL(9, "群聊音视频呼叫"),
+    VIDEO_LEAVE(10, "一对一音视频对方挂断");
 
     private Integer type;
     private String desc;

webchat-common/src/main/java/com/webchat/common/enums/messagequeue/MessageBroadChannelEnum.java

@@ -20,6 +20,8 @@ public enum MessageBroadChannelEnum {
 
     QUEUE_GROUP_VIDEO_CALL("queue_group_video_call", "群聊多人音视频呼叫频道"),
 
+    QUEUE_GROUP_VIDEO_LEAVE("queue_group_video_leave", "一对一音视频对方已挂断消息"),
+
     QUEUE_GROUP_VIDEO_USER_CHANGE("queue_group_video_user_change", "群聊多人音视频用户上/下线频道"),
 
     QUEUE_CHAT_ROBOT("queue_chat_robot", "机器人对话消息队列"),

webchat-connect/src/main/java/com/webchat/connect/messagequeue/config/RedisConfig.java

@@ -30,6 +30,7 @@ public class RedisConfig {
     @Resource
     private GroupVideoUserChangeRedisQueueListener groupVideoUserChangeRedisQueueListener;
 
+
     @Bean
     public RedisMessageListenerContainer container(RedisConnectionFactory redisConnectionFactory) {
         RedisMessageListenerContainer container = new RedisMessageListenerContainer();