提现创建表

AppStart/Helper/StatNewService.cs

@@ -17,6 +17,38 @@ namespace MySystem
 
 
 
+        public void CreateTable()
+        {
+            Thread th = new Thread(CreateTableDo);
+            th.IsBackground = true;
+            th.Start();
+        }
+        public void CreateTableDo()
+        {
+            while (true)
+            {
+                string TradeDate = DateTime.Now.AddDays(1).ToString("yyyyMMdd");
+                CreateTableOp(TradeDate, 1);
+                string TradeMonth = DateTime.Now.AddMonths(1).ToString("yyyyMM");
+                CreateTableOp(TradeMonth, 2);
+                int timespan = 1000 * 60 * 60;
+                Thread.Sleep(timespan);
+            }
+        }
+        private void CreateTableOp(string TradeDate, int Kind = 1)
+        {
+            if(string.IsNullOrEmpty(RedisDbconn.Instance.Get<string>("TradeDaySummary" + TradeDate)))
+            {
+                CustomerSqlConn.op(AppConfig.Base.CreateTradeDaySummary.Replace("#DateTime#", TradeDate), AppConfig.Base.StatSqlConn);
+                RedisDbconn.Instance.Set("TradeDaySummary" + TradeDate, "1");
+                int sec = 3600 * 25;
+                if(Kind == 2)
+                {
+                    sec = 3600 * 24 * 35;
+                }
+                RedisDbconn.Instance.SetExpire("TradeDaySummary" + TradeDate, sec);
+            }
+        }
 
 
 
@@ -71,10 +103,10 @@ namespace MySystem
                 {
                     CustomerSqlConn.op(AppConfig.Base.CreateTradeDaySummary.Replace("#DateTime#", TradeDate), AppConfig.Base.StatSqlConn);
                     RedisDbconn.Instance.Set("TradeDaySummary" + TradeDate, "1");
-                    int sec = 3600 * 13;
+                    int sec = 3600 * 25;
                     if(Kind == 2)
                     {
-                        sec = 3600 * 12 * 35;
+                        sec = 3600 * 24 * 35;
                     }
                     RedisDbconn.Instance.SetExpire("TradeDaySummary" + TradeDate, sec);
                     Thread.Sleep(2000);

Startup.cs

@@ -127,6 +127,7 @@ namespace MySystem
             OperateService.Instance.StartPosCouponSaleNum(); //统计运营中心机具券销售量
             
             StatNewService.Instance.StartStat(); //实时统计交易额RDS
+            StatNewService.Instance.CreateTable(); //创建RDS分表
             //必须打开的
 
         }