修改奖励MQ推送逻辑

AppStart/RabbitMQPrize.cs

@@ -31,7 +31,7 @@ namespace MySystem
 
         #region 单对单接收
         public static IModel _channel_send;
-        public void CreateConn(string QueueName)
+        public void CreateConn()
         { 
             var factory = new ConnectionFactory()
             {
@@ -50,9 +50,13 @@ namespace MySystem
             }
             var conn = factory.CreateConnection(p);
             _channel_send = conn.CreateModel();
-            _channel_send.ExchangeDeclare("kxs_direct_ranch", "direct", true);
-            _channel_send.QueueDeclare(QueueName, true, false, false);
-            _channel_send.QueueBind(QueueName, "kxs_direct_ranch", QueueName);
+            _channel_send.ExchangeDeclare("PRIZE_SEND_QUEUE", "topic", true);
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_1", "PRIZE_SEND_QUEUE", "/");
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_3", "PRIZE_SEND_QUEUE", "/");
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_4", "PRIZE_SEND_QUEUE", "/");
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_5", "PRIZE_SEND_QUEUE", "/");
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_6", "PRIZE_SEND_QUEUE", "/");
+            _channel_send.QueueBind("PRIZE_SEND_QUEUE_7", "PRIZE_SEND_QUEUE", "/");
         }
         #endregion
     }

AppStart/Service/PrizeSendService.cs

@@ -31,7 +31,7 @@ namespace MySystem
                     try
                     {
                         JsonData jsonObj = JsonMapper.ToObject(content);
-                        RabbitMQPrize.Instance.SendMsg(jsonObj["content"].ToString(), "PRIZE_SEND_QUEUE" + jsonObj["prize_tag"].ToString());
+                        RabbitMQPrize.Instance.SendMsg(jsonObj["content"].ToString(), "PRIZE_SEND_QUEUE_" + jsonObj["prize_tag"].ToString());
                     }
                     catch (Exception ex)
                     {                        

Startup.cs

@@ -137,7 +137,7 @@ namespace MySystem
             RabbitMQClient.Instance.StartReceive("QUEUE_GD_ACT_DIVISION");
             RabbitMQClient.Instance.CreateConn2("QUEUE_LKB_TRADE_DIVISION");
             RabbitMQClient.Instance.CreateConn3("QUEUE_KXS_ACT_DIVISION");
-            RabbitMQPrize.Instance.CreateConn("PRIZE_SEND_QUEUE");
+            RabbitMQPrize.Instance.CreateConn();
             // RabbitMQClient.Instance.CreatePushConn("");
             MpOrderService.Instance.Start();
             MpMerchantActService.Instance.Start();