开启手动触发模式

AppStart/GetHaoDaFTPInfoService.cs

@@ -52,7 +52,7 @@ namespace MySystem
                     if (string.IsNullOrEmpty(check))
                     {
                         function.WritePage("/GetFTPDepositYesterday/", "check" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString());
-                        GetDepositData();
+                        GetDepositData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
                         Thread.Sleep(60000);
                         GetTradeData();
                         Thread.Sleep(600000);
@@ -64,10 +64,36 @@ namespace MySystem
                 }
             }
         }
-        public void GetDepositData()
+        public void StartListen()
+        {
+            //每天凌晨执行获取好哒FTP昨日交易数据
+            Thread th2 = new Thread(ListenDepositDataReady);
+            th2.IsBackground = true;
+            th2.Start();
+        }
+        /// <summary>
+        /// 获取好哒FTP昨日交易数据
+        /// </summary>
+        public void ListenDepositDataReady()
+        {
+            while (true)
+            {
+                string content = RedisDbconn.Instance.RPop<string>("ListenDepositDataQueue");
+                if (!string.IsNullOrEmpty(content))
+                {
+                    GetDepositData(content);
+                    Thread.Sleep(2000);
+                }
+                else
+                {
+                    Thread.Sleep(1800000);
+                }
+            }
+        }
+        public void GetDepositData(string Date)
         {
             // 要下载的文件路径
-            string filePath = "/haoda-deposit/deposit_" + DateTime.Now.AddDays(-2).ToString("yyyyMMdd") + ".csv";
+            string filePath = "/haoda-deposit/deposit_" + Date + ".csv";
             
             try
             {

Startup.cs

@@ -153,6 +153,7 @@ namespace MySystem
 
             //必须打开的
             GetHaoDaFTPInfoService.Instance.Start();
+            GetHaoDaFTPInfoService.Instance.StartListen();
             // GetHaoDaFTPInfoService.Instance.StartTrade();
         }