连接池改大

AutoTurnOver.Models/dc_base_warehouse.cs

@@ -112,4 +112,10 @@ namespace AutoTurnOver.Models
 
         public string name { get; set; }
     }
+
+    public class dc_base_warehouse_country_dto
+    {
+        public string warehouse_code { get; set; }
+        public string country_code { get; set; }
+    }
 }

AutoTurnOver.Services/PurchaseAdviseServices.cs

@@ -310,6 +310,7 @@ namespace AutoTurnOver.Services
                     // 查询未推送成功的采购建议的明细
                     var detailList = purchase_advise.BuyDetailList(datas.Select(s => s.id).ToList(), false);
                     var _connection = MyMySqlConnection._connection;
+                    var base_warehouse_list = _connection.Query<dc_base_warehouse_country_dto>(" select t1.warehouse_code,t2.`code` as 'country_code' from dc_base_warehouse as t1 left join dc_base_country as t2 on t1.area_name = t2.`name`  ").ToList();
                     foreach (var item in detailList.GroupBy(s => new { s.warehouse_code,s.area_name, s.warehouse_type,s.task_transport_type }))
                     {
                        
@@ -380,7 +381,7 @@ namespace AutoTurnOver.Services
                         //海运则自动选择一个最快的渠道
                         if (data.bp_sendtype == 2 || data.bp_sendtype == 1)
                         {
-                            var base_wa = _connection.QueryFirstOrDefault<string>(" select t2.`code` from dc_base_warehouse as t1 left join dc_base_country as t2 on t1.area_name = t2.`name` where warehouse_code=@warehouse_code ", new { warehouse_code = item.Key.warehouse_code });
+                            var base_wa = base_warehouse_list.FirstOrDefault(s=>s.warehouse_code== item.Key.warehouse_code).country_code;
                             // 查询物流方案
                             var logisticsData = ApiUtility.RealTimeShipLogisticsList(new Models.ApiDto.LmsShipLogisticsRequstDto
                             {
@@ -399,7 +400,7 @@ namespace AutoTurnOver.Services
                         //空运则自动选择一个最便宜的渠道
                         if (data.bp_sendtype == 3)
                         {
-                            var base_wa = _connection.QueryFirstOrDefault<string>(" select t2.`code` from dc_base_warehouse as t1 left join dc_base_country as t2 on t1.area_name = t2.`name` where warehouse_code=@warehouse_code ", new { warehouse_code = item.Key.warehouse_code });
+                            var base_wa = base_warehouse_list.FirstOrDefault(s => s.warehouse_code == item.Key.warehouse_code).country_code;
                             // 查询物流方案
                             var logisticsData = ApiUtility.RealTimeShipLogisticsList(new Models.ApiDto.LmsShipLogisticsRequstDto
                             {
@@ -416,7 +417,6 @@ namespace AutoTurnOver.Services
                             }
                         }
 
-
                         data.bi_buyplandetail = item.GroupBy(s=>s.bailun_sku).Select(s => new bi_buyplandetail
                         {
                             bd_count = s.Sum(g=> g.quantity_actual > 0 ? g.quantity_actual : g.quantity_final_advise),
@@ -440,7 +440,7 @@ namespace AutoTurnOver.Services
                                 sql += " and bailun_sku not in @bailunSku ";
                                 parameters.Add("bailunSku", result.fail_skus.ToList());
                             }
-                            connectionHelper._connection.Execute(sql, parameters);
+                            _connection.Execute(sql, parameters);
 
                             // 把相关的采购明细都标记成已推送
                             var sql2 = " update  dc_auto_purchase_advise_detailed set ispush=1,push_date=now(),plan_nos=@plan_nos,push_user_name=@push_user_name where id in @ids ";
@@ -453,7 +453,7 @@ namespace AutoTurnOver.Services
                                 sql2 += " and bailun_sku not in @bailunSku ";
                                 parameters2.Add("bailunSku", result.fail_skus.ToList());
                             }
-                            connectionHelper._connection.Execute(sql2, parameters2);
+                            _connection.Execute(sql2, parameters2);
                         }
                         planNos.Add(result.planNo);
 

AutoTurnOver/appsettings.Development.json

 {
   "ConnectionStrings": {
-    "Default": "server=gz-cdb-kp7s5i79.sql.tencentcdb.com;port=61691;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
-    "ReadOnly": "server=gz-cdbrg-qdyec2j3.sql.tencentcdb.com;port=59667;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
+    "Default": "server=gz-cdb-kp7s5i79.sql.tencentcdb.com;port=61691;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
+    "ReadOnly": "server=gz-cdbrg-qdyec2j3.sql.tencentcdb.com;port=59667;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
     "RedisConnectionString": "127.0.0.1,password=SpaceHorse1,DefaultDatabase=0"
   },
   "Logging": {

AutoTurnOver/appsettings.Production.json

 {
   "ConnectionStrings": {
-    "Default": "server=10.0.8.15;port=3306;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
-    "ReadOnly": "server=10.0.8.21;port=3306;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
+    "Default": "server=10.0.8.15;port=3306;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
+    "ReadOnly": "server=10.0.8.21;port=3306;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
     "RedisConnectionString": "10.0.11.105,password=SpaceHorse1,DefaultDatabase=0"
   },
   "Logging": {

AutoTurnOver/appsettings.json

 {
   "ConnectionStrings": {
-    "Default": "server=gz-cdb-kp7s5i79.sql.tencentcdb.com;port=61691;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
-    "ReadOnly": "server=gz-cdbrg-qdyec2j3.sql.tencentcdb.com;port=59667;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;",
+    "Default": "server=gz-cdb-kp7s5i79.sql.tencentcdb.com;port=61691;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
+    "ReadOnly": "server=gz-cdbrg-qdyec2j3.sql.tencentcdb.com;port=59667;database=bailun_datacenter;uid=root;password=#7kfnymAM$Y9-Ntf;Max Pool Size=300;",
     "RedisConnectionString": "127.0.0.1,password=SpaceHorse1,DefaultDatabase=0"
   },
   "Logging": {