feat: 增加发送消息的方法

src/main/java/com/uas/platform/b2b/support/mq/RabbitSendService.java

@@ -1,6 +1,7 @@
 package com.uas.platform.b2b.support.mq;
 
 import com.alibaba.fastjson.JSON;
+import com.uas.platform.b2b.support.mq.config.RabbitMqConfig;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -36,6 +37,8 @@ public class RabbitSendService implements RabbitTemplate.ConfirmCallback, Rabbit
 	}
 
 	/**
+	 * 发送消息
+	 *
 	 * @param queueName 队列名
 	 * @param userId    用户ID
 	 * @param appId     应用号
@@ -52,6 +55,18 @@ public class RabbitSendService implements RabbitTemplate.ConfirmCallback, Rabbit
 		return sendMessage(queueName, messageInfo);
 	}
 
+	/**
+	 * 发送消息，用默认的userId和appId
+	 *
+	 * @param queueName	队列名
+	 * @param bizType	业务类型
+	 * @param bizId		业务id
+	 * @return
+	 */
+	public String sendMessage(String queueName, String bizType, String bizId) {
+		return sendMessage(queueName, RabbitMqConfig.RABBIT_USER_ID, RabbitMqConfig.RABBIT_APP_ID, bizType, bizId);
+	}
+
 
 	/**
 	 * 发送消息

src/main/java/com/uas/platform/b2b/support/mq/config/RabbitMqConfig.java

@@ -12,12 +12,20 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class RabbitMqConfig {
 
-    public static final String QUEUE_B2B_PURCHASE_APCHECK_NAME = "b2b_purchase_apcheck";
+    public static final String RABBIT_USER_ID = "platform-b2b";
+    public static final String RABBIT_APP_ID = "B2B";
 
+    public static final String QUEUE_SAAS_SALE_DOWN_NAME = "saas_sale_order";
+    public static final String QUEUE_SAAS_PURCHASE_APCHECK_NAME = "saas_purchase_apcheck";
 
-    @Bean(name = QUEUE_B2B_PURCHASE_APCHECK_NAME)
+    @Bean(name = QUEUE_SAAS_SALE_DOWN_NAME)
+    public Queue getSassSaleDown() {
+        return new Queue(QUEUE_SAAS_SALE_DOWN_NAME, true);
+    }
+
+    @Bean(name = QUEUE_SAAS_PURCHASE_APCHECK_NAME)
     public Queue getSassPurchaseApcheck() {
-        return new Queue(QUEUE_B2B_PURCHASE_APCHECK_NAME, true);
+        return new Queue(QUEUE_SAAS_PURCHASE_APCHECK_NAME, true);
     }
 
 }

src/main/java/com/uas/platform/b2b/support/mq/service/impl/RabbitApCheckServiceImpl.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Service;
  * @date 2019-01-15 16:31
  */
 @Service
-@RabbitListener(queues = RabbitMqConfig.QUEUE_B2B_PURCHASE_APCHECK_NAME)
+@RabbitListener(queues = RabbitMqConfig.QUEUE_SAAS_PURCHASE_APCHECK_NAME)
 public class RabbitApCheckServiceImpl extends BaseRabbitReceiveService implements RabbitApCheckService {
 
     /**