读取数据库方式切换

AppStart/Helper/StatGdService.cs

@@ -35,21 +35,21 @@ namespace MySystem
                 {
                     StatTradeAmount();
                 }
-                Thread.Sleep(10000);
+                Thread.Sleep(1000);
             }
         }
         public void StatTradeAmount()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志");
+            string connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计创客归档交易日志");
             WebCMSEntities db = new WebCMSEntities();
             KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
             using (var tran = db.Database.BeginTransaction())
             {
                 try
                 {
-                    string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
-                    DataTable idsDt = OtherMySqlConn.dtable("select Id from ConsumerOrders where CreateDate>='" + start + "' and Status>0 and Version=1 order by Id limit 20");
+                    string start = "2024-10-01 00:00:00";
+                    DataTable idsDt = CustomerSqlConn.dtable("select Id from ConsumerOrders where Id>=318109 and CreateDate>='" + start + "' and Status>0 and Version=1 order by Id limit 50", connstr);
                     if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
@@ -57,10 +57,10 @@ namespace MySystem
                         {
                             ids += idsDr["Id"].ToString() + ",";
                         }
-                        DataTable selfDt = OtherMySqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')");
+                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", connstr);
                         if (selfDt.Rows.Count > 0)
                         {
-                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "统计商户和创客交易额日志");
+                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "统计创客归档交易日志");
                             foreach (DataRow selfDr in selfDt.Rows)
                             {
                                 int UserId = int.Parse(selfDr["UserId"].ToString());
@@ -81,7 +81,7 @@ namespace MySystem
                                     StatAfter(db, selfDr, UserId, ParentNav);
                                 }
                             }
-                            OtherMySqlConn.op("update ConsumerOrders set Version=2 where Id in (" + ids.TrimEnd(',') + ")");
+                            CustomerSqlConn.op("update ConsumerOrders set Version=2 where Id in (" + ids.TrimEnd(',') + ")", connstr);
                         }
                     }
                     tran.Commit();
@@ -89,12 +89,12 @@ namespace MySystem
                 catch (Exception ex)
                 {
                     tran.Rollback();
-                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户和创客交易额异常");
+                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计创客归档交易日志异常");
                 }
             }
             db.Dispose();
             maindb.Dispose();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志");
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计创客归档交易日志");
         }
 
         

AppStart/Helper/StatGdService2.cs

@@ -35,21 +35,21 @@ namespace MySystem
                 {
                     StatTradeAmount();
                 }
-                Thread.Sleep(10000);
+                Thread.Sleep(1000);
             }
         }
         public void StatTradeAmount()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr2"].ToString();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志");
+            string connstr = Library.ConfigurationManager.AppSettings["SqlConnStr2"].ToString();
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计创客归档交易日志2");
             WebCMSEntities db = new WebCMSEntities();
             KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
             using (var tran = db.Database.BeginTransaction())
             {
                 try
                 {
-                    string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
-                    DataTable idsDt = OtherMySqlConn.dtable("select Id from ConsumerOrders where CreateDate>='" + start + "' and Status>0 and Version=1 order by Id limit 20");
+                    string start = "2024-10-01 00:00:00";
+                    DataTable idsDt = CustomerSqlConn.dtable("select Id from ConsumerOrders where Id>=501376 and CreateDate>='" + start + "' and Status>0 and Version=1 order by Id limit 50", connstr);
                     if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
@@ -57,10 +57,10 @@ namespace MySystem
                         {
                             ids += idsDr["Id"].ToString() + ",";
                         }
-                        DataTable selfDt = OtherMySqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')");
+                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", connstr);
                         if (selfDt.Rows.Count > 0)
                         {
-                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "统计商户和创客交易额日志");
+                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "统计创客归档交易日志2");
                             foreach (DataRow selfDr in selfDt.Rows)
                             {
                                 int UserId = int.Parse(selfDr["UserId"].ToString());
@@ -81,7 +81,7 @@ namespace MySystem
                                     StatAfter(db, selfDr, UserId, ParentNav);
                                 }
                             }
-                            OtherMySqlConn.op("update ConsumerOrders set Version=2 where Id in (" + ids.TrimEnd(',') + ")");
+                            CustomerSqlConn.op("update ConsumerOrders set Version=2 where Id in (" + ids.TrimEnd(',') + ")", connstr);
                         }
                     }
                     tran.Commit();
@@ -89,12 +89,12 @@ namespace MySystem
                 catch (Exception ex)
                 {
                     tran.Rollback();
-                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户和创客交易额异常");
+                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计创客归档交易日志2异常");
                 }
             }
             db.Dispose();
             maindb.Dispose();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志");
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计创客归档交易日志2");
         }
 
         

AppStart/Helper/StatService.cs

@@ -65,7 +65,7 @@ namespace MySystem
         }
         public void StatTradeAmount()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
+            string connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志");
             WebCMSEntities db = new WebCMSEntities();
             KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
@@ -74,7 +74,7 @@ namespace MySystem
                 try
                 {
                     string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
-                    DataTable idsDt = OtherMySqlConn.dtable("select Id from ConsumerOrders where CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 20");
+                    DataTable idsDt = CustomerSqlConn.dtable("select Id from ConsumerOrders where CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 20", connstr);
                     if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
@@ -82,7 +82,7 @@ namespace MySystem
                         {
                             ids += idsDr["Id"].ToString() + ",";
                         }
-                        DataTable selfDt = OtherMySqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')");
+                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", connstr);
                         if (selfDt.Rows.Count > 0)
                         {
                             function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "统计商户和创客交易额日志");
@@ -207,7 +207,7 @@ namespace MySystem
                                 string jsonString = "{\"TradeDate\":\"" + TradeDate + "\",\"PayMoney\":\"" + TradeAmount + "\",\"TradeCount\":\"" + TradeCount + "\",\"MerchantActualAmount\":\"" + ActualAmount + "\",\"MerchantId\":\"" + MerchantId + "\",\"PayMode\":\"" + PayMode + "\",\"IsAct\":\"" + IsAct + "\"}";
                                 RedisDbconn.Instance.AddList("StatMerchantTradeSummaryQueue", jsonString);
                             }
-                            OtherMySqlConn.op("update ConsumerOrders set Version=1 where Id in (" + ids.TrimEnd(',') + ")");
+                            CustomerSqlConn.op("update ConsumerOrders set Version=1 where Id in (" + ids.TrimEnd(',') + ")", connstr);
                         }
                     }
                     tran.Commit();