完善，备份

@@ -4,6 +4,7 @@ import com.sunyo.wlpt.message.bus.service.domain.XmlData;
 import com.sunyo.wlpt.message.bus.service.exception.CustomExceptionType;
 import com.sunyo.wlpt.message.bus.service.exception.CustomExceptionType;
 import com.sunyo.wlpt.message.bus.service.rabbit.utils.DirectUtils;
 import com.sunyo.wlpt.message.bus.service.rabbit.utils.DirectUtils;
 import com.sunyo.wlpt.message.bus.service.response.ResultJson;
 import com.sunyo.wlpt.message.bus.service.response.ResultJson;
+import com.sunyo.wlpt.message.bus.service.service.MessageNoteService;
 import com.sunyo.wlpt.message.bus.service.service.UserMessageBindingService;
 import com.sunyo.wlpt.message.bus.service.service.UserMessageBindingService;
 import com.sunyo.wlpt.message.bus.service.service.impl.AsyncTaskService;
 import com.sunyo.wlpt.message.bus.service.service.impl.AsyncTaskService;
 import com.sunyo.wlpt.message.bus.service.utils.XmlUtils;
 import com.sunyo.wlpt.message.bus.service.utils.XmlUtils;
@@ -33,6 +34,9 @@ import static com.sunyo.wlpt.message.bus.service.common.Constant.RESULT_SUCCESS;
 public class RabbitController {
 public class RabbitController {
 
 
     @Resource
     @Resource
+    private MessageNoteService messageNoteService;
+
+    @Resource
     private UserMessageBindingService userMessageBindingService;
     private UserMessageBindingService userMessageBindingService;
 
 
     @Resource
     @Resource
@@ -117,10 +121,11 @@ public class RabbitController {
         // 4、mq发送消息，数据库中保存消息
         // 4、mq发送消息，数据库中保存消息
         ResultJson result = directUtils.sendMessage(sentData);
         ResultJson result = directUtils.sendMessage(sentData);
 
 
+        messageNoteService.insertMessageSelective(sentData);
         // 异步，保存消息记录
         // 异步，保存消息记录
-        CountDownLatch latch = new CountDownLatch(1);
-        Future<String> future = asyncTaskService.saveMessage(sentData, latch);
-        latch.await();
+//        CountDownLatch latch = new CountDownLatch(1);
+//        Future<String> future = asyncTaskService.saveMessage(sentData, latch);
+//        latch.await();
         return result;
         return result;
     }
     }
 }
 }