更改间隔时间

AppStart/Helper/ProfitService.cs

@@ -225,7 +225,7 @@ namespace MySystem
                 }
                 else
                 {
-                    Thread.Sleep(10000);
+                    Thread.Sleep(1000);
                 }
             }
         }
@@ -236,7 +236,7 @@ namespace MySystem
             try
             {
                 int startId = int.Parse(function.ReadInstance("/TradeRecord/TradeDaySummaryId.txt"));
-                List<PxcModels.TradeDaySummary> list = maindb.TradeDaySummary.Where(m => m.Id > startId).OrderBy(m => m.Id).Take(100).ToList();
+                List<PxcModels.TradeDaySummary> list = maindb.TradeDaySummary.Where(m => m.Id > startId && m.Id <= 13509689).OrderBy(m => m.Id).Take(100).ToList();
                 foreach(PxcModels.TradeDaySummary sub in list)
                 {
                     db.TradeDaySummary.Add(Newtonsoft.Json.JsonConvert.DeserializeObject<TradeDaySummary>(Newtonsoft.Json.JsonConvert.SerializeObject(sub)));
@@ -272,7 +272,7 @@ namespace MySystem
                 }
                 else
                 {
-                    Thread.Sleep(10000);
+                    Thread.Sleep(1000);
                 }
             }
         }
@@ -319,7 +319,7 @@ namespace MySystem
                 }
                 else
                 {
-                    Thread.Sleep(10000);
+                    Thread.Sleep(1000);
                 }
             }
         }
@@ -366,7 +366,7 @@ namespace MySystem
                 }
                 else
                 {
-                    Thread.Sleep(10000);
+                    Thread.Sleep(1000);
                 }
             }
         }

AppStart/Helper/StatService.cs

@@ -312,6 +312,7 @@ namespace MySystem
                                 statData.Add("TradeAmount", TradeAmount);
                                 statData.Add("TradeCount", TradeCount);
                                 RedisDbconn.Instance.AddList("StatTradeAmountQueue", Newtonsoft.Json.JsonConvert.SerializeObject(statData));
+                                RedisDbconn.Instance.AddList("ProfitTradeAmountQueue", Newtonsoft.Json.JsonConvert.SerializeObject(statData));
                             }
                             OtherMySqlConn.op("update TradeRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                             if(Id == 0)

Config/Base.cs

@@ -8,6 +8,7 @@ namespace AppConfig
         public static string SqlConn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
         public static string SpSqlConn = Library.ConfigurationManager.AppSettings["SpSqlConnStr"].ToString();
         public static string StatSqlConn = Library.ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
+        public static string ProfitSqlConn = Library.ConfigurationManager.AppSettings["ProfitSqlConnStr"].ToString();
 
         //交易统计表
         public static string CreateTradeDaySummary = "SET NAMES utf8mb4;" +

Controllers/HomeController.cs

@@ -131,6 +131,8 @@ namespace MySystem.Controllers
             //         }
             //     }
             // }
+            DataTable dt = CustomerSqlConn.dtable("select * from ProfitSubsidyExport", AppConfig.Base.ProfitSqlConn);
+            result = dt.Rows.Count.ToString();
             return result;
         }
     }

Startup.cs

@@ -139,7 +139,8 @@ namespace MySystem
             // AddRecordService.Instance.StartSpTradeRecord(); //RDSSP交易记录队列
 
             StatNewService.Instance.CreateTable(); //创建RDS分表
-
+            
+            ProfitService.Instance.StartStat();
             ProfitService.Instance.AddTradeDaySummary(); //补TradeDaySummary数据
             ProfitService.Instance.AddUserAccountRecord(); //补UserAccountRecord数据
             ProfitService.Instance.AddProfitRecord(); //补ProfitRecord数据