读取数据单独链接

AppStart/Helper/Profit/HelpProfitHelper.cs

@@ -170,8 +170,9 @@ namespace MySystem
             }
             function.WritePage("/HelpProfitStat/", Month + ".txt", DateTime.Now.ToString());
             WebCMSEntities db = new WebCMSEntities();
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            var orders = db.Orders.Select(m => new { m.UserId, m.Status, m.ProductId }).Where(m => m.Status > 0 && m.ProductId == 34).ToList();
+            ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["ReadSqlConnStr"].ToString();
+            var orders = rdb.Orders.Select(m => new { m.UserId, m.Status, m.ProductId }).Where(m => m.Status > 0 && m.ProductId == 34).ToList();
             DataTable list = OtherMySqlConn.dtable("select UserId,sum(TradeAmount) from HelpProfitMerchantForUser u,HelpProfitMerTradeSummay s where u.MerchantId=s.MerchantId and TradeMonth='" + Month + "' group by UserId");
             function.WriteLog("开始：" + DateTime.Now.ToString(), "助利宝分润日志");
             function.WriteLog("总数：" + list.Rows.Count, "助利宝分润日志");
@@ -215,6 +216,7 @@ namespace MySystem
                 function.WriteLog(index + "--UserId:" + UserId + "；TradeAmount:" + TradeAmount + "；" + DateTime.Now.ToString(), "助利宝分润日志");
             }
             db.Dispose();
+            rdb.Dispose();
             function.WriteLog("结束：" + DateTime.Now.ToString(), "助利宝分润日志");
         }
 

AppStart/Helper/Profit/ProfitHelper.cs

@@ -1740,7 +1740,8 @@ namespace MySystem
             }
             function.WritePage("/ProfitStat/", Month + ".txt", DateTime.Now.ToString());
             WebCMSEntities db = new WebCMSEntities();
-            List<int> BrandIds = db.KqProducts.OrderBy(m => m.Id).ToList().Select(m => m.Id).ToList();
+            ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
+            List<int> BrandIds = rdb.KqProducts.OrderBy(m => m.Id).ToList().Select(m => m.Id).ToList();
             foreach (int i in BrandIds) //品牌
             {
                 for (int j = 0; j <= 1; j++) //卡类型
@@ -1788,9 +1789,9 @@ namespace MySystem
                                         CreditProfitRate = ProfitRate; //(非云闪付)贷记卡交易分润比例
                                         SubsidyProfit = ProfitAmt; //商户(非云闪付)贷记卡交易分润补贴金额
                                     }
-                                    MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == sub.PosSn) ?? new MachineForSnNo();
-                                    PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo(); 
-                                    PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.MerchantId) ?? new PosMerchantInfo();
+                                    ReadModels.MachineForSnNo forSnNo = rdb.MachineForSnNo.FirstOrDefault(m => m.SnNo == sub.PosSn) ?? new ReadModels.MachineForSnNo();
+                                    ReadModels.PosMachinesTwo pos = rdb.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new ReadModels.PosMachinesTwo(); 
+                                    ReadModels.PosMerchantInfo merchant = rdb.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.MerchantId) ?? new ReadModels.PosMerchantInfo();
                                     db.ProfitSubsidyDetail.Add(new ProfitSubsidyDetail()
                                     {
                                         CreateDate = DateTime.Now,
@@ -1828,9 +1829,10 @@ namespace MySystem
                 }
             }
             db.Dispose();
+            rdb.Dispose();
 
             HelpProfitHelper.Instance.StatProfitEveryDay(DateTime.Now.AddMonths(-1).ToString("yyyyMM")); //助利宝分润
-            ProfitCheckHelper.Instance.Start();
+            // ProfitCheckHelper.Instance.Start();
         }
         public List<ProfitResult> StartProftForPosByMonth(int BrandId, int BankCardType, string Month, int PageNum = 1)
         {

AppStart/Helper/Profit/ProfitHelperV2.cs

@@ -60,7 +60,8 @@ namespace MySystem
             try
             {
                 WebCMSEntities db = new WebCMSEntities();
-                List<int> BrandIds = db.KqProducts.OrderBy(m => m.Id).ToList().Select(m => m.Id).ToList();
+                ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
+                List<int> BrandIds = rdb.KqProducts.OrderBy(m => m.Id).ToList().Select(m => m.Id).ToList();
                 foreach (int i in BrandIds) //品牌
                 {
                     for (int j = 0; j <= 1; j++) //卡类型
@@ -333,6 +334,7 @@ namespace MySystem
                     }
                 }
                 db.Dispose();
+                rdb.Dispose();
             }
             catch(Exception ex)
             {