重置银联创客交易队列改造

AppStart/Helper/TestService.cs

@@ -29,15 +29,18 @@ namespace MySystem
         }
         public void StartDo()
         {
-            StatTradeAmount("2023-01-01");
-            StatTradeAmount("2023-01-02");
-            StatTradeAmount("2023-01-03");
-            StatTradeAmount("2023-01-04");
-            StatTradeAmount("2023-01-05");
-            StatTradeAmount("2023-01-06");
-            StatTradeAmount("2023-01-07");
-            StatTradeAmount("2023-01-08");
-            StatTradeAmount("2023-01-09");
+            while(true)
+            {
+                string content = RedisDbconn.Instance.RPop<string>("ResetUserTradeQueue");
+                if(!string.IsNullOrEmpty(content))
+                {
+                    StatTradeAmount(content);
+                }
+                else
+                {
+                    Thread.Sleep(60000);
+                }
+            }
         }
         public void StatTradeAmount(string date)
         {

AppStart/Helper/TestService2.cs

@@ -29,15 +29,18 @@ namespace MySystem
         }
         public void StartDo()
         {
-            StatTradeAmount("2024-01-01");
-            StatTradeAmount("2024-01-02");
-            StatTradeAmount("2024-01-03");
-            StatTradeAmount("2024-01-04");
-            StatTradeAmount("2024-01-05");
-            StatTradeAmount("2024-01-06");
-            StatTradeAmount("2024-01-07");
-            StatTradeAmount("2024-01-08");
-            StatTradeAmount("2024-01-09");
+            while(true)
+            {
+                string content = RedisDbconn.Instance.RPop<string>("ResetUserTrade2Queue");
+                if(!string.IsNullOrEmpty(content))
+                {
+                    StatTradeAmount(content);
+                }
+                else
+                {
+                    Thread.Sleep(60000);
+                }
+            }
         }
         public void StatTradeAmount(string date)
         {

Startup.cs

@@ -126,7 +126,7 @@ namespace MySystem
             StatNewService2.Instance.StartMer(); //实时统计商户交易额
             StatNewService2.Instance.CreateTable(); //生成新的分表
 
-            // TestService.Instance.Start();
+            TestService.Instance.Start();
             TestService2.Instance.Start();
 
             #endregion