将3点开始统计改为手动控制开关统计

AppStart/Helper/OperateService.cs

@@ -27,7 +27,7 @@ namespace MySystem
         {
             while (true)
             {
-                if (DateTime.Now.Hour >= 3)
+                if (RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StatSendEverDay();
                 }
@@ -150,7 +150,7 @@ namespace MySystem
         {
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StartPosActNumEverTime();
                 }
@@ -256,7 +256,7 @@ namespace MySystem
         {
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StartPosCouponSaleNumEverTime();
                 }

AppStart/Helper/ProfitService.cs

@@ -215,9 +215,29 @@ namespace MySystem
             // AddUserAccountRecord(); //补UserAccountRecord数据
             // AddProfitRecord(); //补ProfitRecord数据
             // AddSubsidyRecord(); //补SubsidyRecord数据
+
+            AddRdsData("TradeRecord");
+            AddRdsData("PosMerchantTradeSummay");
             AddRdsData("UserAccountRecord");
             AddRdsData("ProfitRecord");
             AddRdsData("SubsidyRecord");
+            AddRdsData("StoreChangeHistory");
+            AddRdsData("StoreStockChange");
+            AddRdsData("MsgPlacardRead");
+            AddRdsData("UserTradeMonthSummary");
+            AddRdsData("ProfitRewardRecord");
+            AddRdsData("HelpProfitMerTradeSummay");
+            AddRdsData("MsgPersonal");
+            AddRdsData("OpenReward");
+            AddRdsData("OpenRewardDetail");
+            AddRdsData("UserStoreChange");
+            AddRdsData("ProfitRewardExport");
+            AddRdsData("ActiveReward");
+            AddRdsData("RecommendTradeSummary");
+            AddRdsData("StoreHouseAmountRecord");
+            AddRdsData("ProfitSubsidyDetail");
+            AddRdsData("ProfitSubsidyExport");
+            AddRdsData("FluxProfitDetail");
         }
 
         public void AddRdsData(string TableName)
@@ -231,9 +251,10 @@ namespace MySystem
             string TableName = sender.ToString();
             while (true)
             {
-                if(RedisDbconn.Instance.Get<string>(TableName + "ThreadStatus") == "1")
+                if(RedisDbconn.Instance.Get<string>("RdsThreadStatus") == "1")
                 {
                     RdsDataDo(TableName);
+                    Thread.Sleep(500);
                 }
                 else
                 {
@@ -243,13 +264,11 @@ namespace MySystem
         }
         public void RdsDataDo(string TableName)
         {
-            WebCMSEntities db = new WebCMSEntities();
-            PxcModels.WebCMSEntities maindb = new PxcModels.WebCMSEntities();
             try
             {
                 string sql = "";
                 int startId = int.Parse(function.CheckInt(function.ReadInstance("/TradeRecord/" + TableName + "Id.txt")));
-                DataTable dt = CustomerSqlConn.dtable("select * from " + TableName + " where Id>" + startId + " order by Id limit 100", AppConfig.Base.ProfitSqlConn);
+                DataTable dt = CustomerSqlConn.dtable("select * from " + TableName + " where Id>" + startId + " order by Id limit 100", AppConfig.Base.SqlConn);
                 if(dt.Rows.Count > 0)
                 {
                     foreach(DataRow dr in dt.Rows)
@@ -270,30 +289,28 @@ namespace MySystem
                                 {
                                     val = "'" + DateTime.Parse(val).ToString("yyyy-MM-dd HH:mm:ss") + "'";
                                 }
-                                vals = dr[dc.ColumnName].ToString() + ",";
+                                vals += val + ",";
                             }
-                            if(dc.DataType == typeof(int) || dc.DataType == typeof(decimal))
+                            else if(dc.DataType == typeof(int) || dc.DataType == typeof(decimal) || dc.DataType == typeof(ulong))
                             {
-                                vals = dr[dc.ColumnName].ToString() + ",";
+                                vals += dr[dc.ColumnName].ToString() + ",";
                             }
                             else
                             {
-                                vals = dr[dc.ColumnName].ToString() + ",";
+                                vals += "'" + dr[dc.ColumnName].ToString() + "',";
                             }
                         }
-                        sql += "insert into (" + fields.TrimEnd(',') + ") values (" + vals.TrimEnd(',') + ");\n";
+                        sql += "insert into " + TableName + " (" + fields.TrimEnd(',') + ") values (" + vals.TrimEnd(',') + ");\n";
                         startId = int.Parse(function.CheckInt(dr["Id"].ToString()));
                     }
                     CustomerSqlConn.op(sql, AppConfig.Base.ProfitSqlConn);
                     function.WritePage("/TradeRecord/", TableName + "Id.txt", startId.ToString());   
-                }             
+                }
             }
             catch (Exception ex)
             {
                 function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "补" + TableName + "数据异常");
             }
-            maindb.Dispose();
-            db.Dispose();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "补" + TableName + "数据");
         }
 

AppStart/Helper/StatHelpProfitService.cs

@@ -31,7 +31,7 @@ namespace MySystem
         {
             while (true)
             {
-                if (DateTime.Now.Hour >= 3)
+                if (RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StatTradeAmountEverDayV2();
                 }
@@ -193,7 +193,7 @@ namespace MySystem
         {
             while (true)
             {
-                if (DateTime.Now.Hour >= 3)
+                if (RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StartUserTradeGo();
                 }

AppStart/Helper/StatService.cs

@@ -31,7 +31,7 @@ namespace MySystem
         {
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StatTradeAmountEverDayV2();
                     StatBusinessService.Instance.StatTradeAmountEverDayV2();
@@ -597,16 +597,9 @@ namespace MySystem
         }
         public void StartPosActNumFor()
         {
-            // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
-            // DateTime check = DateTime.Parse("2022-06-14");
-            // while (check <= end)
-            // {
-            //     StartPosActNumDo(check.ToString("yyyy-MM-dd"));
-            //     check = check.AddDays(1);
-            // }
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StartPosActNumEverTime();
                     StatBusinessService.Instance.StartPosActNumEverTime();
@@ -816,16 +809,9 @@ namespace MySystem
         }
         public void StartNewUserNumFor()
         {
-            // DateTime end = DateTime.Parse("2022-06-15 00:00:00");
-            // DateTime check = DateTime.Parse("2022-06-14");
-            // while (check <= end)
-            // {
-            //     StartNewUserNumDo(check.ToString("yyyy-MM-dd"));
-            //     check = check.AddDays(1);
-            // }
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StartNewUserNumEverTime();
                 }
@@ -1007,17 +993,9 @@ namespace MySystem
         }
         public void StatProfitDo()
         {
-            // DateTime end = DateTime.Parse("2022-06-16 00:00:00");
-            // DateTime check = DateTime.Parse("2022-06-16");
-            // while (check <= end)
-            // {
-            //     StatProfitEverDay(check.ToString("yyyy-MM-dd"));
-            //     Thread.Sleep(1000);
-            //     check = check.AddDays(1);
-            // }
             while (true)
             {
-                if(DateTime.Now.Hour >= 3)
+                if(RedisDbconn.Instance.Get<string>("StatServerStatus") == "1")
                 {
                     StatProfitEverDayEverTime();
                 }

Startup.cs

@@ -133,10 +133,6 @@ namespace MySystem
 
             AddRecordService.Instance.StartTradeRecord(); //RDS交易记录队列
             AddRecordService.Instance.StartUserAccountRecord(); //RDS收支明细队列
-            // AddRecordService.Instance.StartSpBindRecord(); //RDSSP绑定记录队列
-            // AddRecordService.Instance.StartSpMerchants(); //RDSSP商户信息队列
-            // AddRecordService.Instance.StartSpActivateRecord(); //RDSSP激活押金记录队列
-            // AddRecordService.Instance.StartSpTradeRecord(); //RDSSP交易记录队列
 
             StatNewService.Instance.CreateTable(); //创建RDS分表