押金和交易的队列分开

AppStart/GetHaoDaFTPInfoService.cs

@@ -55,10 +55,28 @@ namespace MySystem
                         GetDepositData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
                         Thread.Sleep(60000);
                         GetTradeData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
-                        Thread.Sleep(600000);
                     }
                 }
-                if (DateTime.Now.Hour > 10)
+                Thread.Sleep(7200000);
+            }
+        }
+
+        public void Start2()
+        {
+            //每天凌晨执行获取好哒FTP昨日交易数据
+            Thread th2 = new Thread(GetDepositDataReady2);
+            th2.IsBackground = true;
+            th2.Start();
+        }
+
+        /// <summary>
+        /// 获取好哒FTP昨日交易数据
+        /// </summary>
+        public void GetDepositDataReady2()
+        {
+            while (true)
+            {
+                if (DateTime.Now > DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 10:05:00"))
                 {
                     GetDepositData("d_" + DateTime.Now.ToString("yyyyMMdd"));
                 }
@@ -66,6 +84,7 @@ namespace MySystem
                 Thread.Sleep(1800000);
             }
         }
+
         public void StartListen()
         {
             //每天凌晨执行获取好哒FTP昨日交易数据
@@ -154,7 +173,7 @@ namespace MySystem
                                 string PrizeDateString = "";
                                 if(PrizeDate == "None")
                                 {
-                                    PrizeDate = Date;
+                                    PrizeDate = Date.Replace("d_", "");
                                 }
                                 else
                                 {

Startup.cs

@@ -154,11 +154,13 @@ namespace MySystem
 
             //必须打开的
             GetHaoDaFTPInfoService.Instance.Start();
+            GetHaoDaFTPInfoService.Instance.Start2();
             GetHaoDaFTPInfoService.Instance.StartListen();
             GetHaoDaFTPInfoService.Instance.StartTradeListen();
 
             // GetHaoDaFTPInfoService.Instance.StartTrade();
             // GetHaoDaFTPInfoService.Instance.GetTradeData();
+            // GetHaoDaFTPInfoService.Instance.GetDepositData("d_20241127");
         }
 
         private void InitMain()