推送实时订单数据

AppStart/GetHaoDaFTPInfoService.cs

@@ -452,9 +452,29 @@ namespace MySystem
 
 
 
+        public void StartTradeListenBridge()
+        {
+            Thread th2 = new Thread(ListenTradeDataBridgeReady);
+            th2.IsBackground = true;
+            th2.Start();
+        }
+        public void ListenTradeDataBridgeReady()
+        {
+            while (true)
+            {
+                string content = RedisDbconn.Instance.RPop<string>("cache:ListenTradeDataByOneQueue");
+                if (!string.IsNullOrEmpty(content))
+                {
+                    RedisDbconn.Instance.AddList("ListenTradeDataByOneQueue", content);
+                }
+                else
+                {
+                    Thread.Sleep(10000);
+                }
+            }
+        }
         public void StartTradeListenByOne()
         {
-            //每天凌晨执行获取好哒FTP昨日交易数据
             Thread th2 = new Thread(ListenTradeDataByOneReady);
             th2.IsBackground = true;
             th2.Start();

Startup.cs

@@ -160,6 +160,7 @@ namespace MySystem
             GetHaoDaFTPInfoService.Instance.StartGetTradeData();
             GetHaoDaFTPInfoService.Instance.StartDepositListenByOne();
             GetHaoDaFTPInfoService.Instance.StartTradeListenByOne();
+            GetHaoDaFTPInfoService.Instance.StartTradeListenBridge();
 
             // GetHaoDaFTPInfoService.Instance.StartTrade();
             // GetHaoDaFTPInfoService.Instance.GetTradeData();