前端发送消息，成功

@@ -140,7 +140,7 @@ public class MessageNoteController {
      * @return {@link ResultJson}
      * @return {@link ResultJson}
      */
      */
     @PostMapping("/insert")
     @PostMapping("/insert")
-    public ResultJson insertMessageNote(@RequestBody @NotNull MessageNote messageNote)
+    public ResultJson insertMessageNote(@RequestBody @NotNull MessageNote messageNote) throws Exception
     {
     {
         return messageNoteService.insertSelective(messageNote) > 0
         return messageNoteService.insertSelective(messageNote) > 0
                 ? new ResultJson<>("200", "编辑-消息收发记录，成功")
                 ? new ResultJson<>("200", "编辑-消息收发记录，成功")

@@ -29,11 +29,11 @@ public interface MessageNoteService {
 
 
     /**
     /**
      * 新增，选择性
      * 新增，选择性
-     *
      * @param record the record
      * @param record the record
      * @return insert count
      * @return insert count
+     * @throws Exception 异常
      */
      */
-    int insertSelective(MessageNote record);
+    int insertSelective(MessageNote record) throws Exception;
 
 
     /**
     /**
      * 查询，根据主键
      * 查询，根据主键

@@ -107,4 +107,6 @@ public class AsyncTaskService {
         // 删除相关配置关系
         // 删除相关配置关系
         userMessageBindingService.deleteByQueueId(busQueue.getId());
         userMessageBindingService.deleteByQueueId(busQueue.getId());
     }
     }
+
+
 }
 }

@@ -5,6 +5,7 @@ import com.github.pagehelper.PageInfo;
 import com.sunyo.wlpt.message.bus.service.domain.*;
 import com.sunyo.wlpt.message.bus.service.domain.*;
 import com.sunyo.wlpt.message.bus.service.mapper.MessageNoteMapper;
 import com.sunyo.wlpt.message.bus.service.mapper.MessageNoteMapper;
 import com.sunyo.wlpt.message.bus.service.mapper.UserMessageBindingMapper;
 import com.sunyo.wlpt.message.bus.service.mapper.UserMessageBindingMapper;
+import com.sunyo.wlpt.message.bus.service.rabbit.utils.DirectUtils;
 import com.sunyo.wlpt.message.bus.service.service.*;
 import com.sunyo.wlpt.message.bus.service.service.*;
 import com.sunyo.wlpt.message.bus.service.utils.IdUtils;
 import com.sunyo.wlpt.message.bus.service.utils.IdUtils;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
@@ -47,6 +48,9 @@ public class MessageNoteServiceImpl implements MessageNoteService {
     @Resource
     @Resource
     private MessageNoteMapper messageNoteMapper;
     private MessageNoteMapper messageNoteMapper;
 
 
+    @Resource
+    private DirectUtils directUtils;
+
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
     @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
     public int deleteByPrimaryKey(String id)
     public int deleteByPrimaryKey(String id)
@@ -80,7 +84,7 @@ public class MessageNoteServiceImpl implements MessageNoteService {
     }
     }
 
 
     @Override
     @Override
-    public int insertSelective(MessageNote record)
+    public int insertSelective(MessageNote record) throws Exception
     {
     {
         return validateNoteAndFill(record);
         return validateNoteAndFill(record);
     }
     }
@@ -164,15 +168,15 @@ public class MessageNoteServiceImpl implements MessageNoteService {
         messageNote.setId(IdUtils.generateId());
         messageNote.setId(IdUtils.generateId());
 
 
         // 填充，用户名称
         // 填充，用户名称
-        UserInfo userInfo = userInfoService.selectByPrimaryKey(messageNote.getUserId());
-        messageNote.setUsername(userInfo.getUsername());
+//        UserInfo userInfo = userInfoService.selectByPrimaryKey(messageNote.getUserId());
+//        messageNote.setUsername(userInfo.getUsername());
 
 
         // 填充，发送内容（编辑 or 新增）
         // 填充，发送内容（编辑 or 新增）
         messageNote.setSendContent(messageNote.getAlias_sendContent().getBytes());
         messageNote.setSendContent(messageNote.getAlias_sendContent().getBytes());
 
 
         // 填充，服务器名称
         // 填充，服务器名称
-        BusServer busServer = busServerService.selectByPrimaryKey(messageNote.getServerId());
-        messageNote.setServerName(busServer.getServerName());
+//        BusServer busServer = busServerService.selectByPrimaryKey(messageNote.getServerId());
+//        messageNote.setServerName(busServer.getServerName());
 
 
         // 填充，虚拟主机名称
         // 填充，虚拟主机名称
         VirtualHost virtualHost = virtualHostService.selectByPrimaryKey(messageNote.getVirtualHostId());
         VirtualHost virtualHost = virtualHostService.selectByPrimaryKey(messageNote.getVirtualHostId());
@@ -205,9 +209,35 @@ public class MessageNoteServiceImpl implements MessageNoteService {
      * @param messageNote {@link MessageNote}
      * @param messageNote {@link MessageNote}
      * @return 发送信息记录的条数
      * @return 发送信息记录的条数
      */
      */
-    public int validateNoteAndFill(MessageNote messageNote)
+    public int validateNoteAndFill(MessageNote messageNote) throws Exception
     {
     {
-        return validateNote(messageNote) ? messageNoteMapper.insertSelective(note_fillName(messageNote)) : 0;
+        if (validateNote(messageNote)) {
+            // 填充，用户名称
+            UserInfo userInfo = userInfoService.selectByPrimaryKey(messageNote.getUserId());
+            messageNote.setUsername(userInfo.getUsername());
+            // 填充，服务器名称
+            BusServer busServer = busServerService.selectByPrimaryKey(messageNote.getServerId());
+            messageNote.setServerName(busServer.getServerName());
+
+            MessageNote note = note_fillName(messageNote);
+            // 发送到MQ服务器
+            XmlData xmlData = XmlData.builder()
+                    .sender(note.getUsername())
+                    .password(userInfo.getPassword())
+                    .sendContent(note.getAlias_sendContent())
+                    .sendDateTime(note.getSendTime())
+                    .exchangeName(note.getExchangeName())
+                    .routingKeyName(note.getRoutingKeyName())
+                    .virtualHostName(note.getVirtualHostName())
+                    .serverName(note.getServerName())
+                    .serverIp(busServer.getServerIp())
+                    .serverPort(busServer.getServerPort())
+                    .build();
+            directUtils.sendMessage(xmlData);
+            return messageNoteMapper.insertSelective(note);
+        } else {
+            return 0;
+        }
     }
     }
 }
 }