322 lines
8.7 KiB
C#
322 lines
8.7 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Diagnostics;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Windows.Forms;
|
|
|
|
namespace upper_limit_crawler
|
|
{
|
|
public static class ULUtil
|
|
{
|
|
//static string m_strLogServer = "http://mjjo53.us.to:8000";
|
|
|
|
static CPUTILLib.CpCybos m_CPUtil = null;
|
|
static CPUTILLib.CpCodeMgr m_CPCodeMgr = null;
|
|
static TextBox m_tbLog = null;
|
|
static string m_strLogDir;
|
|
static string m_strLogFileName;
|
|
static string m_strCSVFileName;
|
|
static TimeSpan m_TimeDiff = TimeSpan.Zero;
|
|
|
|
static int m_iTradingStartTime;
|
|
static int m_iTradingEndTime;
|
|
|
|
public static void Init(TextBox tbLog)
|
|
{
|
|
m_CPUtil = new CPUTILLib.CpCybos();
|
|
m_CPCodeMgr = new CPUTILLib.CpCodeMgr();
|
|
|
|
m_tbLog = tbLog;
|
|
|
|
if (Debugger.IsAttached == true)
|
|
m_strLogDir = Directory.GetParent(Environment.CurrentDirectory).Parent.FullName + "\\";
|
|
m_strLogDir += "log\\";
|
|
if (Directory.Exists(m_strLogDir) == false)
|
|
Directory.CreateDirectory(m_strLogDir);
|
|
|
|
m_strLogFileName = m_strLogDir + "log-" + GetCurTime().ToString("yyyy-MM-dd") + ".txt";
|
|
m_strCSVFileName = m_strLogDir + "log-" + GetCurTime().ToString("yyyy-MM-dd") + ".csv";
|
|
|
|
m_iTradingStartTime = (int)m_CPCodeMgr.GetMarketStartTime();
|
|
m_iTradingStartTime *= 100;
|
|
m_iTradingEndTime = (int)m_CPCodeMgr.GetMarketEndTime();
|
|
m_iTradingEndTime *= 100;
|
|
}
|
|
|
|
public static void SyncServerTime()
|
|
{
|
|
DateTime time = GetFastestNISTDate();
|
|
m_TimeDiff = time - DateTime.Now;
|
|
}
|
|
|
|
public static DateTime GetCurTime()
|
|
{
|
|
return DateTime.Now + m_TimeDiff;
|
|
}
|
|
|
|
public static void GetServerTime()
|
|
{
|
|
try
|
|
{
|
|
string strURL = string.Format("http://www.timeapi.org/utc/now?format={0}", (@"\Y-\m-\d \H:\M:\S"));
|
|
Uri uri = new Uri(strURL);
|
|
WebRequest wReq = (HttpWebRequest)WebRequest.Create(uri); // WebRequest 객체 형성 및 HttpWebRequest 로 형변환
|
|
wReq.Method = "GET"; // 전송 방법 "GET" or "POST"
|
|
|
|
using (HttpWebResponse wRes = (HttpWebResponse)wReq.GetResponse())
|
|
{
|
|
Stream respPostStream = wRes.GetResponseStream();
|
|
StreamReader readerPost = new StreamReader(respPostStream, Encoding.GetEncoding("EUC-KR"), true);
|
|
|
|
string resResult = readerPost.ReadToEnd();
|
|
}
|
|
}
|
|
catch (WebException ex)
|
|
{
|
|
if (ex.Status == WebExceptionStatus.ProtocolError && ex.Response != null)
|
|
{
|
|
var resp = (HttpWebResponse)ex.Response;
|
|
Trace("인터넷 시간 동기화 실패 ({0})", resp.StatusCode);
|
|
}
|
|
}
|
|
}
|
|
|
|
public static DateTime GetFastestNISTDate()
|
|
{
|
|
var result = DateTime.MinValue;
|
|
// Initialize the list of NIST time servers
|
|
// http://tf.nist.gov/tf-cgi/servers.cgi
|
|
string[] servers = new string[] {
|
|
"time-c.nist.gov",
|
|
"nist1-macon.macon.ga.us",
|
|
"time.nist.gov",
|
|
"time-nw.nist.gov",
|
|
"nist-time-server.eoni.com"
|
|
};
|
|
|
|
// Try 5 servers in random order to spread the load
|
|
Random rnd = new Random();
|
|
foreach (string server in servers.OrderBy(s => rnd.NextDouble()).Take(5))
|
|
{
|
|
try
|
|
{
|
|
ULUtil.Trace("TimeSync trying [server:{0}]", server);
|
|
|
|
// Connect to the server (at port 13) and get the response
|
|
string serverResponse = string.Empty;
|
|
using (var reader = new StreamReader(new System.Net.Sockets.TcpClient(server, 13).GetStream()))
|
|
{
|
|
serverResponse = reader.ReadToEnd();
|
|
}
|
|
|
|
// If a response was received
|
|
if (!string.IsNullOrEmpty(serverResponse))
|
|
{
|
|
// Split the response string ("55596 11-02-14 13:54:11 00 0 0 478.1 UTC(NIST) *")
|
|
string[] tokens = serverResponse.Split(' ');
|
|
|
|
// Check the number of tokens
|
|
if (tokens.Length >= 6)
|
|
{
|
|
// Check the health status
|
|
string health = tokens[5];
|
|
if (health == "0")
|
|
{
|
|
// Get date and time parts from the server response
|
|
string[] dateParts = tokens[1].Split('-');
|
|
string[] timeParts = tokens[2].Split(':');
|
|
|
|
// Create a DateTime instance
|
|
DateTime utcDateTime = new DateTime(
|
|
Convert.ToInt32(dateParts[0]) + 2000,
|
|
Convert.ToInt32(dateParts[1]), Convert.ToInt32(dateParts[2]),
|
|
Convert.ToInt32(timeParts[0]), Convert.ToInt32(timeParts[1]),
|
|
Convert.ToInt32(timeParts[2]));
|
|
|
|
// Convert received (UTC) DateTime value to the local timezone
|
|
result = utcDateTime.ToLocalTime();
|
|
|
|
return result;
|
|
// Response successfully received; exit the loop
|
|
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
catch
|
|
{
|
|
// Ignore exception and try the next server
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
public static string GetCurTimeString()
|
|
{
|
|
return GetCurTime().ToString("yyyy-MM-dd HH:mm:ss");
|
|
}
|
|
|
|
public static int GetCurTimeInt()
|
|
{
|
|
return int.Parse(GetCurTime().ToString("HHmmss"));
|
|
}
|
|
|
|
public static int GetTimeDiff(int iTime1, int iTime2)
|
|
{
|
|
TimeSpan Diff = DateTime.Parse(iTime2.ToString()) - DateTime.Parse(iTime1.ToString());
|
|
return int.Parse(Diff.ToString("HHmmss"));
|
|
}
|
|
|
|
public static void WebLog(string strURL, string strMsg)
|
|
{
|
|
try
|
|
{
|
|
// 요청 String -> 요청 Byte 변환
|
|
byte[] byteDataParams = UTF8Encoding.UTF8.GetBytes(strMsg);
|
|
|
|
// HttpWebRequest 객체 생성, 설정
|
|
Uri reqURI = new Uri(strURL);
|
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(reqURI);
|
|
request.Method = "POST"; // 기본값 "GET"
|
|
request.ContentType = "application/x-www-form-urlencoded";
|
|
request.ContentLength = byteDataParams.Length;
|
|
|
|
// 요청 Byte -> 요청 Stream 변환
|
|
Stream stDataParams = request.GetRequestStream();
|
|
stDataParams.Write(byteDataParams, 0, byteDataParams.Length);
|
|
stDataParams.Close();
|
|
|
|
// 요청, 응답 받기
|
|
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
|
|
|
|
// 응답 Stream 읽기
|
|
Stream stReadData = response.GetResponseStream();
|
|
StreamReader srReadData = new StreamReader(stReadData, Encoding.Default);
|
|
|
|
// 응답 Stream -> 응답 String 변환
|
|
string strResult = srReadData.ReadToEnd();
|
|
|
|
Console.WriteLine(strResult);
|
|
}
|
|
catch(Exception ex)
|
|
{
|
|
ex.ToString();
|
|
}
|
|
}
|
|
|
|
public static string GetLogDir()
|
|
{
|
|
return m_strLogDir;
|
|
}
|
|
|
|
public static void Trace(string strMsg)
|
|
{
|
|
string strLog = "["+GetCurTimeString()+"] "+strMsg;
|
|
|
|
System.IO.File.AppendAllText(m_strLogFileName, strLog + Environment.NewLine);
|
|
Console.WriteLine(strLog);
|
|
|
|
bool bScrollToEnd = (m_tbLog.SelectionStart == m_tbLog.Text.Length);
|
|
m_tbLog.Text += strLog + Environment.NewLine;
|
|
if(bScrollToEnd == true)
|
|
{
|
|
m_tbLog.SelectionStart = m_tbLog.Text.Length;
|
|
m_tbLog.ScrollToCaret();
|
|
}
|
|
|
|
//WebLog(m_strLogServer, strLog);
|
|
}
|
|
|
|
public static void Trace(string strFormat, params object[] args)
|
|
{
|
|
Trace(string.Format(strFormat, args));
|
|
}
|
|
|
|
public static void TraceCSV(params object[] args)
|
|
{
|
|
string strLog = GetCurTimeString();
|
|
foreach (object arg in args)
|
|
strLog += ", " + arg;
|
|
|
|
System.IO.File.AppendAllText(m_strCSVFileName, strLog + Environment.NewLine, Encoding.UTF8);
|
|
}
|
|
|
|
public static int GetLimitRemainCountTrace()
|
|
{
|
|
return m_CPUtil.GetLimitRemainCount(CPUTILLib.LIMIT_TYPE.LT_TRADE_REQUEST);
|
|
}
|
|
|
|
public static int GetLimitRemainCountRQ()
|
|
{
|
|
return m_CPUtil.GetLimitRemainCount(CPUTILLib.LIMIT_TYPE.LT_NONTRADE_REQUEST);
|
|
}
|
|
|
|
public static int GetLimitRemainCountSB()
|
|
{
|
|
return m_CPUtil.GetLimitRemainCount(CPUTILLib.LIMIT_TYPE.LT_SUBSCRIBE);
|
|
}
|
|
|
|
public static bool IsConnected()
|
|
{
|
|
return (m_CPUtil.IsConnect==1);
|
|
}
|
|
|
|
public static string GetCodeName(string strCode)
|
|
{
|
|
return m_CPCodeMgr.CodeToName(strCode);
|
|
}
|
|
|
|
public static void Reset()
|
|
{
|
|
m_CPUtil = null;
|
|
System.GC.Collect(0, GCCollectionMode.Forced);
|
|
System.GC.WaitForFullGCComplete();
|
|
|
|
m_CPUtil = new CPUTILLib.CpCybos();
|
|
}
|
|
|
|
public static bool IsInTime(int iTime1, int iTime2, int iMinDiff)
|
|
{
|
|
int iHour1 = iTime1 / 10000;
|
|
int iMin1 = (iTime1 / 100) % 100;
|
|
int iSec1 = iTime1 % 100;
|
|
|
|
int iHour2 = iTime2 / 10000;
|
|
int iMin2 = (iTime2 / 100) % 100;
|
|
int iSec2 = iTime2 % 100;
|
|
|
|
int iTotalSec1 = iHour1 * 60 * 60 + iMin1 * 60 + iSec1;
|
|
int iTotalSec2 = iHour2 * 60 * 60 + iMin2 * 60 + iSec2;
|
|
|
|
return (iTotalSec2 >= iTotalSec1 && iTotalSec2 - iTotalSec1 <= iMinDiff * 60);
|
|
}
|
|
|
|
public static short BlockRequest(CPTRADELib.ICpTdDib obj)
|
|
{
|
|
while(GetLimitRemainCountRQ() < 1)
|
|
Thread.Sleep(500);
|
|
return obj.BlockRequest2(1);
|
|
}
|
|
|
|
public static short BlockRequest(CPSYSDIBLib.ISysDib obj)
|
|
{
|
|
while(GetLimitRemainCountRQ() < 1)
|
|
Thread.Sleep(500);
|
|
return obj.BlockRequest2(1);
|
|
}
|
|
|
|
public static bool IsTradingTime()
|
|
{
|
|
int iCurTime = GetCurTimeInt();
|
|
return (iCurTime >= m_iTradingStartTime && iCurTime <= m_iTradingEndTime);
|
|
}
|
|
}
|
|
}
|