添加好哒交易手动处理队列

AppStart/GetHaoDaFTPInfoService.cs

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

Startup.cs

@@ -154,7 +154,10 @@ namespace MySystem
             //必须打开的
             GetHaoDaFTPInfoService.Instance.Start();
             GetHaoDaFTPInfoService.Instance.StartListen();
+            GetHaoDaFTPInfoService.Instance.StartTradeListen();
+
             // GetHaoDaFTPInfoService.Instance.StartTrade();
+            // GetHaoDaFTPInfoService.Instance.GetTradeData();
         }
 
         private void InitMain()