消息队列处理

Mall.Common/Models/RabbitKey.cs

@@ -17,6 +17,10 @@ namespace Mall.Common.Models
         /// 初始化教育消息队列
         /// </summary>
         public const string QUEEN_GENERATE_EDUCARION = "generate_educarion";
+        /// <summary>
+        /// 初始化教育消息队列（本地）
+        /// </summary>
+        public const string QUEEN_GENERATE_EDUCARION_LOCAL = "generate_educarion_local";
 
     }
 }

Mall.Education/Model/RabbitKey.cs

@@ -18,5 +18,10 @@ namespace Mall.Education.Models
         /// </summary>
         public const string QUEEN_GENERATE_EDUCARION = "generate_educarion";
 
+        /// <summary>
+        /// 初始化教育消息队列（测试）
+        /// </summary>
+        public const string QUEEN_GENERATE_EDUCARION_LOCAL = "generate_educarion_local";
+
     }
 }

Mall.Module.Education/EducationModule.cs

-using Mall.Common.API;
+using Mall.Common;
+using Mall.Common.API;
 using Mall.Common.Models;
 using Mall.Common.Plugin;
 using Mall.Model.Entity.Education;
@@ -843,7 +844,7 @@ namespace Mall.Module.Education
                                     Port = 5672,
                                     UserName = "guest",
                                     Password = "viitto2019",
-                                    QueenName = RabbitKey.QUEEN_GENERATE_EDUCARION
+                                    QueenName = Config.IsNormalServer == "1" ? RabbitKey.QUEEN_GENERATE_EDUCARION : RabbitKey.QUEEN_GENERATE_EDUCARION_LOCAL
                                 }, JsonConvert.SerializeObject(new
                                 {
                                     GoodsId = demodel.Id,
@@ -899,7 +900,7 @@ namespace Mall.Module.Education
                                     Port = 5672,
                                     UserName = "guest",
                                     Password = "viitto2019",
-                                    QueenName = RabbitKey.QUEEN_GENERATE_EDUCARION
+                                    QueenName = Config.IsNormalServer == "1" ? RabbitKey.QUEEN_GENERATE_EDUCARION : RabbitKey.QUEEN_GENERATE_EDUCARION_LOCAL
                                 }, JsonConvert.SerializeObject(new
                                 {
                                     GoodsId = demodel.Id,
@@ -1043,7 +1044,7 @@ namespace Mall.Module.Education
                                     Port = 5672,
                                     UserName = "guest",
                                     Password = "viitto2019",
-                                    QueenName = RabbitKey.QUEEN_GENERATE_EDUCARION
+                                    QueenName = Config.IsNormalServer == "1" ? RabbitKey.QUEEN_GENERATE_EDUCARION : RabbitKey.QUEEN_GENERATE_EDUCARION_LOCAL
                                 }, JsonConvert.SerializeObject(new
                                 {
                                     GoodsId = Id,