优化:组件功能

Bailun.DC.Common/GlobalConfig.cs

@@ -49,5 +49,10 @@ namespace Bailun.DC.Common
         /// </summary>
         public static string ConnectionString_DW = "server=gz-cdb-ncg4yhjb.sql.tencentcdb.com;port=58537;database=datawarehouse;uid=root;password=#7kfnymAM$Y9-Ntf;SslMode=none;";
          
+        /// <summary>
+        /// 产品库
+        /// </summary>
+        public static string ConnectionString_Pro = "Server=gz-cdb-oxt89knc.sql.tencentcdb.com;port=62967;database=bailun_bltpro;uid=root;password=#7kfnymAM$Y9-Ntf;Convert Zero Datetime=True;Allow User Variables=True;pooling=true";
+
     }
 }

Bailun.DC.Models/Component/Enum/ComponentEnum.cs

@@ -3,7 +3,7 @@
 namespace Bailun.DC.Models.Component.Enum
 {
     /// <summary>
-    /// 数据库：1: 数据中心， 2: 交易流水
+    /// 数据库：1: 数据中心， 2: 交易流水， 3: 产品库
     /// </summary>
     public enum DBEnum
     {
@@ -17,6 +17,12 @@ namespace Bailun.DC.Models.Component.Enum
         /// 交易流水
         /// </summary>
         [Description("交易流水")]
-        DataWareHouse = 2
+        DataWareHouse = 2,
+
+        /// <summary>
+        /// 产品库
+        /// </summary>
+        [Description("产品库")]
+        Pro = 3
     }
 }

Bailun.DC.Services/Component/BaseService.cs

@@ -53,6 +53,24 @@ namespace Bailun.DC.Services.Component
             }
         }
 
+        private MySqlConnection _PRO_DB;
+
+        public MySqlConnection PRO_DB
+        {
+            get
+            {
+                if (_PRO_DB == null)
+                {
+                    _PRO_DB = new MySqlConnection(GlobalConfig.ConnectionString_Pro);
+                }
+                if (_PRO_DB.State == ConnectionState.Closed)
+                {
+                    _PRO_DB.Open();
+                }
+                return _PRO_DB;
+            }
+        }
+
         public IEnumerable<T> DeserializeCollection<T>(string jsonStr)
         {
             IEnumerable<T> list = default(IEnumerable<T>);

Bailun.DC.Services/Component/DictionaryService.cs

@@ -35,8 +35,21 @@ namespace Bailun.DC.Services.Component
                     switch (entity.type)
                     {
                         case DictionaryTypeEnum.SQL:
+                            MySqlConnection db = default(MySqlConnection);
+                            switch (entity.data_db)
+                            {
+                                case DBEnum.DataWareHouse:
+                                    db = DW_DB;
+                                    break;
+                                case DBEnum.Pro:
+                                    db = PRO_DB;
+                                    break;
+                                default:
+                                    db = DB;
+                                    break;
+                            }
                             //查询
-                            using (var db = (entity.data_db == DBEnum.DataWareHouse ? DW_DB : DB))
+                            using (db)
                             {
                                 list = db.Query(entity.value, sqlparam);
                             }