LinkerManager.cs 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160
  1. ////----------------------------------------------------------------
  2. ////Module Name: LinkerManager
  3. ////Purpose:
  4. ////CopyRight: Muchinfo
  5. ////History:
  6. ////----------------------------------------------------------------
  7. ////DateTime Author Description
  8. ////----------------------------------------------------------------
  9. ////2014-03-21 deng.yinping Create
  10. ////----------------------------------------------------------------
  11. //using Muchinfo.MTPClient.Data;
  12. //using Muchinfo.MTPClient.Data.Enums;
  13. //using Muchinfo.MTPClient.Data.Interfaces;
  14. //using Muchinfo.MTPClient.Data.Model.Account;
  15. //using Muchinfo.MTPClient.Resources;
  16. //using System;
  17. //using System.Collections.Generic;
  18. //using System.Linq;
  19. //using System.Threading;
  20. //namespace Muchinfo.MTPClient.Infrastructure.Utilities
  21. //{
  22. // /// <summary>
  23. // /// LinkerManager类
  24. // /// </summary>
  25. // public class LinkerManager
  26. // {
  27. // static LinkerManager()
  28. // {
  29. // }
  30. // /// <summary>
  31. // /// 创建链路
  32. // /// </summary>
  33. // /// <param name="exchangeId">The exchange identifier.</param>
  34. // public static void CreateLinks()
  35. // {
  36. // //创建实时行情链路
  37. // CreateRealTimeQuoteLinks();
  38. // //创建历史行情链路
  39. // //CreateHistoryQuoteLinks(exchangeId);
  40. // }
  41. // /// <summary>
  42. // /// 根据交易所Id创建链路
  43. // /// </summary>
  44. // public static void CreateRealTimeQuoteLinks()
  45. // {
  46. // }
  47. // /// <summary>
  48. // /// 获取交易帐号的业务代理
  49. // /// </summary>
  50. // /// <returns>BizServiceProxy.</returns>
  51. // public static IServiceProxy GetBizServiceProxyByAccount(string loginCode, bool needCreate)
  52. // {
  53. // if (String.IsNullOrWhiteSpace(loginCode)) return null;
  54. // var tradeAccount = UserManager.TradeAccounts.FirstOrDefault(z => z.LoginCode == loginCode);
  55. // if (tradeAccount == null) return null;
  56. // return null;
  57. // }
  58. // /// <summary>
  59. // /// 删除交易帐号的业务代理
  60. // /// </summary>
  61. // /// <param name="tradeCode">The trade code.</param>
  62. // /// <param name="exchangeId">The login code.</param>
  63. // public static void RemoveBizServiceProxy(string tradeCode)
  64. // {
  65. // }
  66. // /// <summary>
  67. // /// 测试连接速度
  68. // /// </summary>
  69. // /// <param name="ip"></param>
  70. // /// <param name="port"></param>
  71. // /// <returns></returns>
  72. // public static TimeSpan TestSpeed(string ip, int port)
  73. // {
  74. // try
  75. // {
  76. // DateTime oldDt = DateTime.Now;
  77. // System.Net.Sockets.TcpClient client = new System.Net.Sockets.TcpClient(ip, port);
  78. // client.Close();
  79. // return DateTime.Now - oldDt;
  80. // }
  81. // catch (Exception ex)
  82. // {
  83. // return new TimeSpan(0, 0, 6);
  84. // }
  85. // }
  86. // /// <summary>
  87. // /// 测试地址是否连通
  88. // /// </summary>
  89. // /// <param name="ip"></param>
  90. // /// <param name="port"></param>
  91. // /// <param name="sec">超时时间</param>
  92. // /// <returns></returns>
  93. // public static bool IsOnLine(string ip, int port, int sec)
  94. // {
  95. // System.Net.Sockets.TcpClient client = null;
  96. // try
  97. // {
  98. // bool isFinish = false;
  99. // bool isEnable = false;
  100. // ThreadStart ts = new ThreadStart(() =>
  101. // {
  102. // try
  103. // {
  104. // client = new System.Net.Sockets.TcpClient(ip, port);
  105. // isEnable = true;
  106. // }
  107. // catch
  108. // {
  109. // isEnable = false;
  110. // }
  111. // isFinish = true;
  112. // }
  113. // );
  114. // Thread th = new Thread(ts);
  115. // th.Start();
  116. // for (int i = 0; i < sec; i++)
  117. // {
  118. // Thread.Sleep(1000);
  119. // if (isFinish)
  120. // if (isEnable) return true;
  121. // else return false;
  122. // }
  123. // th.Abort();
  124. // return false;
  125. // }
  126. // catch
  127. // {
  128. // return false;
  129. // }
  130. // finally
  131. // {
  132. // if (client != null)
  133. // client.Close();
  134. // }
  135. // }
  136. // }
  137. //}