Browse Source

下掉老的重置程序

lcl 11 months ago
parent
commit
a9a38b6071
3 changed files with 71 additions and 17 deletions
  1. 14 14
      AppStart/Helper/StatService.cs
  2. 55 1
      AppStart/Helper/StatTradeCheckService.cs
  3. 2 2
      Startup.cs

+ 14 - 14
AppStart/Helper/StatService.cs

@@ -31,21 +31,21 @@ namespace MySystem
         {
         {
             while (true)
             while (true)
             {
             {
-                if(DateTime.Now.Hour < 3)
-                {
-                    string yesterday = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
-                    string check = RedisDbconn.Instance.Get<string>("ResetUserTradeFlag:" + yesterday);
-                    if(string.IsNullOrEmpty(check))
-                    {
-                        RedisDbconn.Instance.Set("ResetUserTradeFlag:" + yesterday, "ok");
-                        RedisDbconn.Instance.SetExpire("ResetUserTradeFlag:" + yesterday, 3600 * 5);
+                // if(DateTime.Now.Hour < 3)
+                // {
+                //     string yesterday = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
+                //     string check = RedisDbconn.Instance.Get<string>("ResetUserTradeFlag:" + yesterday);
+                //     if(string.IsNullOrEmpty(check))
+                //     {
+                //         RedisDbconn.Instance.Set("ResetUserTradeFlag:" + yesterday, "ok");
+                //         RedisDbconn.Instance.SetExpire("ResetUserTradeFlag:" + yesterday, 3600 * 5);
 
 
-                        StatResetService.Instance.ResetMerchantTrade(yesterday);
-                        StatResetService2.Instance.ResetMerchantTrade(yesterday);
-                        RedisDbconn.Instance.AddList("ResetUserTradeQueue", yesterday);
-                        RedisDbconn.Instance.AddList("ResetUserTrade2Queue", yesterday);
-                    }
-                }
+                //         StatResetService.Instance.ResetMerchantTrade(yesterday);
+                //         StatResetService2.Instance.ResetMerchantTrade(yesterday);
+                //         RedisDbconn.Instance.AddList("ResetUserTradeQueue", yesterday);
+                //         RedisDbconn.Instance.AddList("ResetUserTrade2Queue", yesterday);
+                //     }
+                // }
                 if(DateTime.Now.Hour == 0)
                 if(DateTime.Now.Hour == 0)
                 {
                 {
                     string date = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
                     string date = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");

+ 55 - 1
AppStart/Helper/StatTradeCheckService.cs

@@ -52,9 +52,63 @@ namespace MySystem
             try
             try
             {
             {
                 date = date.Replace("-", "");
                 date = date.Replace("-", "");
+                List<int> userids = new List<int>();
+                userids.Add(202711);
+                userids.Add(215646);
+                userids.Add(216006);
+                userids.Add(220410);
+                userids.Add(220975);
+                userids.Add(223954);
+                userids.Add(227153);
+                userids.Add(227345);
+                userids.Add(227347);
+                userids.Add(227772);
+                userids.Add(227889);
+                userids.Add(228112);
+                userids.Add(228236);
+                userids.Add(228934);
+                userids.Add(228979);
+                userids.Add(229634);
+                userids.Add(229878);
+                userids.Add(231672);
+                userids.Add(234055);
+                userids.Add(234274);
+                userids.Add(235130);
+                userids.Add(236059);
+                userids.Add(236570);
+                userids.Add(236577);
+                userids.Add(237366);
+                userids.Add(238700);
+                userids.Add(238701);
+                userids.Add(239360);
+                userids.Add(242247);
+                userids.Add(243375);
+                userids.Add(244562);
+                userids.Add(244704);
+                userids.Add(244727);
+                userids.Add(244790);
+                userids.Add(245127);
+                userids.Add(245273);
+                userids.Add(246228);
+                userids.Add(246458);
+                userids.Add(246500);
+                userids.Add(248077);
+                userids.Add(248535);
+                userids.Add(248899);
+                userids.Add(249313);
+                userids.Add(249520);
+                userids.Add(249574);
+                userids.Add(249753);
+                userids.Add(251083);
+                userids.Add(251900);
+                userids.Add(252596);
+                userids.Add(252798);
+                userids.Add(255414);
+                userids.Add(255516);
+                userids.Add(257895);
                 WebCMSEntities db = new WebCMSEntities();
                 WebCMSEntities db = new WebCMSEntities();
                 KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
                 KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
-                List<UserAmountSummary> list = db.UserAmountSummary.Where(m => m.TradeDate == date).ToList();
+                List<UserAmountSummary> list = db.UserAmountSummary.Where(m => m.TradeDate == date && userids.Contains(m.UserId)).ToList();
                 List<int> uids = list.Select(m => m.UserId).Distinct().ToList();
                 List<int> uids = list.Select(m => m.UserId).Distinct().ToList();
                 var users = kxsdb.Users.Select(m => new { m.Id, m.ParentNav }).Where(m => uids.Contains(m.Id)).ToList();
                 var users = kxsdb.Users.Select(m => new { m.Id, m.ParentNav }).Where(m => uids.Contains(m.Id)).ToList();
                 db.Dispose();
                 db.Dispose();

+ 2 - 2
Startup.cs

@@ -131,9 +131,9 @@ namespace MySystem
             StatNewService2.Instance.CreateTable(); //生成新的分表
             StatNewService2.Instance.CreateTable(); //生成新的分表
 
 
             TestService.Instance.Start();
             TestService.Instance.Start();
-            TestService2.Instance.Start();
+            // TestService2.Instance.Start();
 
 
-            StatTradeCheckService.Instance.StartCheck(); //检查交易额
+            // StatTradeCheckService.Instance.StartCheck(); //检查交易额
 
 
             #endregion
             #endregion