million/BitGet_API
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
bea301ffd75f8f07254239d438109a6a065568d2
BitGet_API/BitgetApi/WebService/WebConnection.cs

967 lines
56 KiB
C#
Raw Normal View History

수정!!!
2024-05-23 16:32:30 +09:00
using BitgetAPI;
using BitgetAPI.Utils;
첫 등록
2024-05-22 16:56:51 +09:00
using BitgetAPI.Data;
using BitgetAPI.Utils;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
수정!!!
2024-05-23 16:32:30 +09:00
using System.Net.WebSockets;
첫 등록
2024-05-22 16:56:51 +09:00
using System.Text;
수정!!!
2024-05-23 16:32:30 +09:00
using System.Threading;
첫 등록
2024-05-22 16:56:51 +09:00
using System.Threading.Tasks;
수정!!!
2024-05-23 16:32:30 +09:00
using BitgetApi.Data;
using Newtonsoft.Json.Linq;
using DevExpress.Utils.Extensions;
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
using static BitgetAPI.CommonProperty;
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
using DateTime = System.DateTime;
임시 수정
2024-07-10 11:46:59 +09:00
using DevExpress.Xpo.Logger;
첫 등록
2024-05-22 16:56:51 +09:00
namespace BitgetAPI.WebService
{
public class WebConnection
{
임시 수정
2024-07-10 11:46:59 +09:00
public Thread th_PingTimer { get; set; } = null;
1. 영호 조건식 추가 진행중!!!!!
2024-06-14 16:49:57 +09:00
// 웹소켓 스레드 시작/종료 플래그
1. 조건 재시작 및 프로그램 종료 Thread 수정
2024-06-14 14:47:51 +09:00
public bool Is_th_webSocketThread { get; set; } = false;
public ClientWebSocket webSocket { get; set; } = null;
임시 수정
2024-07-10 11:46:59 +09:00
private object obj = new object();
public List<Dictionary<string, object>> webSocketDataList = new List<Dictionary<string, object>>();
위와 내용 같음
2024-05-29 17:37:10 +09:00
임시 수정
2024-07-10 11:46:59 +09:00
CommonProperty commonProperty = CommonProperty.Instance;
public static object SendWebServer(CommonProperty.ExchangeWebReqType exchangeWebReqType, string url = "",
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
MarketCandleDataList marketCandleDataList = null, CommonProperty.MCandleTimeType interval = MCandleTimeType.M1,
string postData = "", string subUri = "")
첫 등록
2024-05-22 16:56:51 +09:00
{
object returnJsonData = null;
CommonProperty commonProperty = CommonProperty.Instance;
try
{
HttpWebRequest wReq = null;
// Post 방식인 경우만 사용
var rgbyData = Encoding.ASCII.GetBytes(postData);
// 웹 전송 타입 지정
var webConType = CommonProperty.WebConnectionType.GET;
// 1. WebRequest 객체 형성 및 HttpWebRequest 로 형변환
// 2. 거래소에 따른 헤더 파일 처리(POST 일 경우만 지정함)
임시 수정
2024-07-10 11:46:59 +09:00
if (string.IsNullOrEmpty(url))
첫 등록
2024-05-22 16:56:51 +09:00
{
switch (exchangeWebReqType)
{
#region Upbit
case CommonProperty.ExchangeWebReqType.UpbitMarket:
wReq = (HttpWebRequest)WebRequest.Create(new Uri(CommonProperty.UpbitURL_MarketInfo));
break;
#endregion
#region Bitget
case CommonProperty.ExchangeWebReqType.BitgetMarket_Spot:
wReq = (HttpWebRequest)WebRequest.Create(new Uri(CommonProperty.BitgetURL_MarketInfo_COIN));
break;
case CommonProperty.ExchangeWebReqType.BitgetMarket_Future:
wReq = (HttpWebRequest)WebRequest.Create(new Uri(CommonProperty.BitgetURL_MarketInfo_FUTURE));
break;
case CommonProperty.ExchangeWebReqType.BitgetCandleStick_Coin:
wReq = (HttpWebRequest)WebRequest.Create(new Uri(CommonProperty.BitgetURL_MarketCandle_Coin));
break;
case CommonProperty.ExchangeWebReqType.BitgetCandleStick_Future:
wReq = (HttpWebRequest)WebRequest.Create(new Uri(CommonProperty.BitgetURL_MarketCandle_Future));
break;
#endregion
}
}
임시 수정
2024-07-10 11:46:59 +09:00
else wReq = (HttpWebRequest)WebRequest.Create(new Uri(url));
첫 등록
2024-05-22 16:56:51 +09:00
// GET, POST 구분
switch (webConType)
{
case CommonProperty.WebConnectionType.GET:
break;
case CommonProperty.WebConnectionType.POST:
wReq.Method = "POST"; // 전송 방법 "GET" or "POST"
using (var stream = wReq.GetRequestStream())
{
stream.Write(rgbyData, 0, rgbyData.Length);
}
wReq.ContentType = "application/x-www-form-urlencoded";
wReq.ContentLength = rgbyData.Length;
break;
}
using (var wRes = (HttpWebResponse)wReq.GetResponse())
{
var respPostStream = wRes.GetResponseStream();
var readerPost = new StreamReader(respPostStream, Encoding.UTF8, true);
var resResult = readerPost.ReadToEnd();
switch (exchangeWebReqType)
{
#region Bitget
case CommonProperty.ExchangeWebReqType.BitgetMarket_Spot:
임시 수정
2024-07-10 11:46:59 +09:00
{
첫 등록
2024-05-22 16:56:51 +09:00
var datalist = JsonConvert.DeserializeObject<Dictionary<string, object>>(resResult);
var marketInfo = JsonConvert.DeserializeObject<List<Dictionary<string, object>>>(datalist["data"]?.ToString());
var data = marketInfo.FindAll(x => x["coin"].ToString().Contains("USDT"));
임시 수정
2024-07-10 11:46:59 +09:00
}
break;
첫 등록
2024-05-22 16:56:51 +09:00
case CommonProperty.ExchangeWebReqType.BitgetMarket_Future:
임시 수정
2024-07-10 11:46:59 +09:00
{
첫 등록
2024-05-22 16:56:51 +09:00
var datalist = JsonConvert.DeserializeObject<Dictionary<string, object>>(resResult);
var marketInfos = JsonConvert.DeserializeObject<List<Dictionary<string, object>>>(datalist["data"]?.ToString());
commonProperty.marketInfoList = new List<MarketInfo>();
foreach (var item in marketInfos)
{
MarketInfo marketInfo = new MarketInfo();
marketInfo.MarketName = item["symbol"].ToString();
marketInfo.ExchangePlace = Enum.GetName(typeof(CommonProperty.ExchangePlace), commonProperty.selectedChangePlace);
Market 데이터 수정
2024-06-07 17:05:34 +09:00
marketInfo.lastPr = Convert.ToDouble(item["lastPr"]);
marketInfo.change24h = Convert.ToDouble(item["change24h"]);
marketInfo.baseVolume = Convert.ToDouble(item["baseVolume"]);
marketInfo.quoteVolume = Convert.ToDouble(item["quoteVolume"]);
marketInfo.high24h = Convert.ToDouble(item["high24h"]);
marketInfo.low24h = Convert.ToDouble(item["low24h"]);
구름떼 검색기 수정 중!!
2024-06-10 18:22:06 +09:00
marketInfo.open24h = Convert.ToDouble(item["open24h"]);
첫 등록
2024-05-22 16:56:51 +09:00
commonProperty.marketInfoList.Add(marketInfo);
}
return commonProperty.marketInfoList;
임시 수정
2024-07-10 11:46:59 +09:00
}
break;
첫 등록
2024-05-22 16:56:51 +09:00
case CommonProperty.ExchangeWebReqType.BitgetCandleStick_Coin:
임시 수정
2024-07-10 11:46:59 +09:00
{
첫 등록
2024-05-22 16:56:51 +09:00
임시 수정
2024-07-10 11:46:59 +09:00
}
break;
첫 등록
2024-05-22 16:56:51 +09:00
case CommonProperty.ExchangeWebReqType.BitgetCandleStick_Future:
{
var datalist = JsonConvert.DeserializeObject<Dictionary<string, object>>(resResult);
var datas = JsonConvert.DeserializeObject<List<List<object>>>(datalist["data"]?.ToString());
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
if (marketCandleDataList == null) return null;
var candleDataList = marketCandleDataList.candleDataList[interval];
첫 등록
2024-05-22 16:56:51 +09:00
임시 수정
2024-07-10 11:46:59 +09:00
foreach (var item in datas)
첫 등록
2024-05-22 16:56:51 +09:00
{
CandleData candleData = new CandleData();
구름떼 검색기 수정 중!!
2024-06-10 18:22:06 +09:00
첫 등록
2024-05-22 16:56:51 +09:00
candleData.Argument = Convertor.GetUnixtimeStampToDateTime(long.Parse(item[0].ToString()));
candleData.Open = Convert.ToDouble(item[1]);
candleData.High = Convert.ToDouble(item[2]);
candleData.Low = Convert.ToDouble(item[3]);
candleData.Close = Convert.ToDouble(item[4]);
candleData.Vol_C = Convert.ToDouble(item[5]);
candleData.Vol_USD = Convert.ToDouble(item[6]);
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
// 같은 시간이 존재하면 업데이트 : 1개밖에 없음
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
// 마지막 시간 데이터는 불완전 > 웹소켓 데이터와 합체
임시 수정
2024-07-10 11:46:59 +09:00
if (item == datas.Last())
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
{
임시 수정
2024-07-10 11:46:59 +09:00
var timespan_add = new System.TimeSpan(0, 0, 0);
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
switch (interval)
{
case CommonProperty.MCandleTimeType.M1:
// 같은 분이면 무조건 업데이트
timespan_add = new System.TimeSpan(0, 1, 0);
break;
case CommonProperty.MCandleTimeType.M3:
// 같은 분이면 무조건 업데이트
timespan_add = new System.TimeSpan(0, 3, 0);
break;
case CommonProperty.MCandleTimeType.M5:
timespan_add = new System.TimeSpan(0, 5, 0);
break;
case CommonProperty.MCandleTimeType.M15:
timespan_add = new System.TimeSpan(0, 15, 0);
break;
case CommonProperty.MCandleTimeType.M30:
timespan_add = new System.TimeSpan(0, 30, 0);
break;
case CommonProperty.MCandleTimeType.H1:
timespan_add = new System.TimeSpan(1, 0, 0);
break;
case CommonProperty.MCandleTimeType.H4:
timespan_add = new System.TimeSpan(4, 0, 0);
break;
case CommonProperty.MCandleTimeType.H6:
timespan_add = new System.TimeSpan(6, 0, 0);
break;
case CommonProperty.MCandleTimeType.H12:
timespan_add = new System.TimeSpan(12, 0, 0);
break;
}
var sameCandleData_WebService = candleDataList.Find(i => candleData.Argument <= i.Argument &&
i.Argument < (candleData.Argument + timespan_add) && i.WebSocketUpdate == true);
임시 수정
2024-07-10 11:46:59 +09:00
if (sameCandleData_WebService != null)
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
{
// 종가 => 웹소켓 데이터 사용 (웹 서비스 호출 데이터 중 마지막 데이터는 캔들이 완성되지 않음)
// 시가 => 웹 서비스 데이터 사용
sameCandleData_WebService.Open = candleData.Open;
// 저가, 고가 => 비교해서 사용
sameCandleData_WebService.Low = Math.Min(sameCandleData_WebService.Low, candleData.Low);
sameCandleData_WebService.High = Math.Max(sameCandleData_WebService.High, candleData.High);
sameCandleData_WebService.WebServiceUpdate = true;
}
else
{
candleDataList.Add(candleData);
candleData.WebServiceUpdate = true;
}
임시 수정
2024-07-10 11:46:59 +09:00
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
}
/*
//var sameCandleData_WebService = candleDataList.Find(i => i.Argument.Minute == candleData.Argument.Minute &&
//i.Argument.Hour == candleData.Argument.Hour && i.WebSocketUpdate == true);
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
위와 내용 같음
2024-05-29 17:37:10 +09:00
// 기존 웹소켓으로 부터 받은 데이터에 수정 등록
if (sameCandleData_WebService != null)
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
{
스레드 재실행 수정중!!
2024-06-10 23:22:01 +09:00
}*/
위와 내용 같음
2024-05-29 17:37:10 +09:00
// 웹 서비스로 받은 데이터를 새로 추가
else
{
candleDataList.Add(candleData);
candleData.WebServiceUpdate = true;
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
}
첫 등록
2024-05-22 16:56:51 +09:00
위와 내용 같음
2024-05-29 17:37:10 +09:00
}
첫 등록
2024-05-22 16:56:51 +09:00
}
break;
임시 수정
2024-07-10 11:46:59 +09:00
#endregion
첫 등록
2024-05-22 16:56:51 +09:00
}
}
}
catch (WebException webEx)
{
using (var Response = (HttpWebResponse)webEx.Response)
{
var nCode = Response.StatusCode;
using (var reader = new StreamReader(Response.GetResponseStream()))
{
var sRespBodyData = reader.ReadToEnd();
//return (JObject.Parse(sRespBodyData));
}
}
}
return returnJsonData;
}
수정!!!
2024-05-23 16:32:30 +09:00
?
2024-06-08 14:45:14 +09:00
public async void BitGetWebSocektStart(CommonProperty.BitgetWebSocketType bitgetWebSocketType, Dictionary<string, object> dic)
수정!!!
2024-05-23 16:32:30 +09:00
{
string apiUrl = "https://api.upbit.com/v1/market/all?isDetails=true";
// IP당 100개 연결
// 시간당 240회 !!!
// 타이머 30초 유지 > 30초 이내의 응답 메시지 수신 필요 > 아니면 오류 발생 !! > 재접속 필요 !!
// 초당 10개 메시지 허용
// 단일 연결로 최대 1000개의 스트림 구독
// 단인 IP 최대의 100개 연결
// *
/* timestamp : Unix Epoch 시간
* passphrase : APIKey 비밀번호
* timestamp : Unix Epoch 시간, 단위는 초(--restAPI의 서명 타임스탬프와 다름--)
* secretKey : 사용자가 APIKey를 신청할 때 생성되는 보안 키입니다. 예: 22582BD0CFF14C41EDBF1AB98506286D
*/
임시 수정
2024-07-10 11:46:59 +09:00
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
1. 조건 재시작 및 프로그램 종료 Thread 수정
2024-06-14 14:47:51 +09:00
webSocket = new ClientWebSocket();
수정!!!
2024-05-23 16:32:30 +09:00
string WebSocketUrl = "wss://ws.bitget.com/v2/ws/public";
string message = "";
var tempStrData = "";
위와 내용 같음
2024-05-29 17:37:10 +09:00
수정!!!
2024-05-23 16:32:30 +09:00
try
{
await webSocket.ConnectAsync(new Uri(WebSocketUrl), CancellationToken.None);
// 연결이 성공적으로 이루어지면 처리할 코드 작성
Console.WriteLine("WebSocket 연결 성공");
//var jsonDataText = "{\"op\":\"subscribe\",\"args\":[{\"instType\":\"SPOT\",\"channel\":\"ticker\",\"instId\":\"ETHUSDT\"}, {\"instType\":\"SPOT\",\"channel\":\"ticker\",\"instId\":\"BTCUSDT\"}]}";
var jsonData = JsonConvert.SerializeObject(dic);
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
// Ping 유지용 (25초)
위와 내용 같음
2024-05-29 17:37:10 +09:00
th_PingTimer = new Thread(() => ContinuePing(webSocket));
th_PingTimer.Start();
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
await SendMessage(webSocket, jsonData);
수정!!!
2024-05-23 16:32:30 +09:00
// 데이터 수신을 위한 반복문 시작
while (webSocket.State == WebSocketState.Open)
{
1. 조건 재시작 및 프로그램 종료 Thread 수정
2024-06-14 14:47:51 +09:00
수정!!!
2024-05-23 16:32:30 +09:00
//Thread.Sleep(100);
byte[] buffer = new byte[1024];
WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
message = "";
// 수신한 데이터 처리
message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
if (!ValidateJSON(message))
{
tempStrData += message;
if (!ValidateJSON(message))
{
continue;
}
else
{
message = tempStrData;
}
}
var datalist = JsonConvert.DeserializeObject<Dictionary<string, object>>(message);
임시 수정
2024-07-10 11:46:59 +09:00
lock (obj)
{
webSocketDataList.Add(datalist);
}
#region 접어 둘거
//if (datalist.ContainsKey("data"))
//{
// switch (bitgetWebSocketType)
// {
// case CommonProperty.BitgetWebSocketType.현황정보_전체종목:
// {
// var candleInfo = JsonConvert.DeserializeObject<List<WebSocketTickerInfo>>(datalist["data"]?.ToString());
// var tickerList = candleInfo[0];
// DateTime dt = new DateTime(1970, 01, 01);
// tickerList.reciveTime = dt.AddMilliseconds(Convert.ToDouble(tickerList.ts)).ToLocalTime();
// // 웹소켓 티커 리스트에 추가 (사용 안함)
// /*
// var searchIndex = commonProperty.webSocketCandles.IndexOf(i => i.instId == tickerList.instId);
// if (searchIndex < 0)
// commonProperty.webSocketCandles.Add(tickerList);
// else
// {
// commonProperty.webSocketCandles[searchIndex] = tickerList;
// }
// */
// // 캔들 리스트에서 해당 데이터 찾기
// var searchIndex_c = commonProperty.candleDataLists.IndexOf(i => i.ConGoodsData.MarketName == tickerList.instId);
// // 캔들 리스트에 업데이트 (전체 시간별)
// foreach (CommonProperty.MCandleTimeType interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
// {
// var candleDataList = commonProperty.candleDataLists[searchIndex_c].candleDataList[interval];
// // 캔들 리스트에 추가
// var candleData = new CandleData();
// candleData.Argument = tickerList.reciveTime;
// candleData.Close = tickerList.lastPr;
// // 캔들 리스트가 없으면 추가
// if (candleDataList.Count == 0)
// candleDataList.Add(candleData);
// else
// {
// var lastCandleData_Edit = candleDataList.ToList();
// // 마지막 시간 데이터 가져오기
// var lastCandleData = lastCandleData_Edit.Find(j => j.Argument == lastCandleData_Edit.Max(i => i.Argument));
// if (lastCandleData == null) return;
// // 업데이트 or 추가
// bool updateFlag = true;
// switch (interval)
// {
// case CommonProperty.MCandleTimeType.M1:
// // 같은 분이면 무조건 업데이트
// if (lastCandleData.Argument.Minute != candleData.Argument.Minute)
// updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.M3:
// // 같은 분이면 무조건 업데이트
// if (lastCandleData.Argument.Minute != candleData.Argument.Minute &&
// candleData.Argument.Minute % 3 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.M5:
// if (lastCandleData.Argument.Minute != candleData.Argument.Minute &&
// candleData.Argument.Minute % 5 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.M15:
// if (lastCandleData.Argument.Minute != candleData.Argument.Minute &&
// candleData.Argument.Minute % 15 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.M30:
// if (lastCandleData.Argument.Minute != candleData.Argument.Minute &&
// candleData.Argument.Minute % 30 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.H1:
// if (lastCandleData.Argument.Hour != candleData.Argument.Hour)
// updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.H4:
// if (lastCandleData.Argument.Hour != candleData.Argument.Hour &&
// candleData.Argument.Hour % 4 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.H6:
// if (lastCandleData.Argument.Hour != candleData.Argument.Hour &&
// candleData.Argument.Hour % 6 == 1) updateFlag = false;
// break;
// case CommonProperty.MCandleTimeType.H12:
// if (lastCandleData.Argument.Hour != candleData.Argument.Hour &&
// candleData.Argument.Hour % 12 == 1) updateFlag = false;
// break;
// }
// // 이미 등록된 시간 캔들이 있는 경우 변경
// if (updateFlag)
// {
// // 시간 업데이트
// lastCandleData.Argument = candleData.Argument;
// // 종가 수정
// lastCandleData.Close = candleData.Close;
// // 저가 등록
// if (lastCandleData.Low == 0 || lastCandleData.Low > candleData.Close) lastCandleData.Low = candleData.Close;
// // 고가 등록
// if (lastCandleData.High == 0 || lastCandleData.High < candleData.Close) lastCandleData.High = candleData.Close;
// lastCandleData.WebSocketUpdate = true;
// }
// // 없는 경우 추가
// else
// {
// if (candleData.Open == 0) { }
// // 1분 이상 Ticker가 없는 겨우는 Open 가만 가격이 등록됨
// candleData.Open = candleData.Close;
// candleData.WebSocketUpdate = true;
// // 새 데이터 등록
// candleDataList.Add(candleData);
// // 기존 데이터 삭제
// if (candleDataList.Count > 250)
// {
// // 가장 오래된 데이터 삭제
// candleDataList.Remove(j => j.Argument == candleDataList.Min(i => i.Argument));
// }
// }
// }
// }
// }
// break;
// case CommonProperty.BitgetWebSocketType.캔들정보:
// #region 캔들 웹소켓 : 종목 50, 캔들 1 개만 해도 뒤지려고 함 !! (일딴 패스)
// {
// var argList = JsonConvert.DeserializeObject<Dictionary<string, object>>(datalist["arg"]?.ToString());
// var candleInfos = JsonConvert.DeserializeObject<List<List<object>>>(datalist["data"]?.ToString());
// var candleInfo = candleInfos[0];
// DateTime dt = new DateTime(1970, 01, 01);
// var candleData = new CandleData(
// dt.AddMilliseconds(Convert.ToDouble(candleInfo[0])).ToLocalTime(),
// Convert.ToDouble(candleInfo[1]),
// Convert.ToDouble(candleInfo[2]),
// Convert.ToDouble(candleInfo[3]),
// Convert.ToDouble(candleInfo[4]),
// Convert.ToDouble(candleInfo[5]),
// Convert.ToDouble(candleInfo[6]),
// Convert.ToDouble(candleInfo[7])
// );
// // Websocket 캔들 정보 구분 하기 (1분, 1시간 등)
// CommonProperty.MCandleTimeType mCandleTimeType = CommonProperty.MCandleTimeType.H1;
// foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
// {
// // Description
// var description = Utils.Convertor.GetEnumDescription((Enum)interval);
// if (argList["channel"].ToString().Contains(description))
// mCandleTimeType = (CommonProperty.MCandleTimeType)interval;
// break;
// }
// // 캔들 리스트에서 해당 데이터 찾기
// var searchIndex = commonProperty.candleDataLists.IndexOf(i => i.ConGoodsData.MarketName == argList["instId"].ToString());
// var candleDataList = commonProperty.candleDataLists[searchIndex].candleDataList[mCandleTimeType];
// // 마지막 데이터 (최신데이터) 가져오기
// CandleData lastCandleData = null;
// if (candleDataList.Count == 0)
// candleDataList.Add(candleData);
// else
// {
// lastCandleData = commonProperty.candleDataLists[searchIndex].candleDataList[mCandleTimeType].Last();
// // 최신데이터와 비교하여 교체/등록하기
// // 업데이트 or 추가
// bool updateFlag = false;
// switch (mCandleTimeType)
// {
// case CommonProperty.MCandleTimeType.M1:
// if (lastCandleData.Argument.Minute == candleData.Argument.Minute)
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.M3:
// if (candleData.Argument.Minute % 3 != 0 || (candleData.Argument.Minute % 3 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.M5:
// if (candleData.Argument.Minute % 5 != 0 || (candleData.Argument.Minute % 5 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.M15:
// if (candleData.Argument.Minute % 15 != 0 || (candleData.Argument.Minute % 15 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.M30:
// if (candleData.Argument.Minute % 30 != 0 || (candleData.Argument.Minute % 30 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.H1:
// if (candleData.Argument.Hour == candleData.Argument.Hour)
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.H4:
// if (candleData.Argument.Hour % 4 != 0 || (candleData.Argument.Hour % 4 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.H6:
// if (candleData.Argument.Hour % 6 != 0 || (candleData.Argument.Hour % 6 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
// updateFlag = true;
// break;
// case CommonProperty.MCandleTimeType.H12:
// if (candleData.Argument.Hour % 12 != 0 || (candleData.Argument.Hour % 12 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
// updateFlag = true;
// break;
// }
// // 이미 등록된 시간 캔들이 있는 경우 변경
// if (updateFlag)
// {
// lastCandleData = candleData;
// }
// // 없는 경우 추가
// else
// {
// lastCandleData.Close = candleData.Open;
// // 새 데이터 등록
// candleDataList.Add(candleData);
// // 기존 데이터 삭제
// if (candleDataList.Count > 250)
// {
// var minData = candleDataList.Min(t => t.Argument);
// var minCandle = candleDataList.FirstOrDefault(t => t.Argument == minData);
// if (minCandle != null)
// {
// candleDataList.Remove(minCandle);
// }
// }
// }
// }
// }
// #endregion
// break;
// }
//}
#endregion
}
}
catch (Exception ex)
{
Console.WriteLine("WebSocket 연결 중 오류 발생: " + ex.Message);
}
finally
{
closeWebSocket();
// 웹소켓 재귀
if (Is_th_webSocketThread)
{
BitGetWebSocektStart(bitgetWebSocketType, dic);
}
}
}
// 웹소켓 종료
public async void closeWebSocket()
{
if (webSocket != null)
{
if (webSocket.State == WebSocketState.Open)
{
if (th_PingTimer != null)
{
th_PingTimer.Abort();
th_PingTimer = null;
}
await webSocket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "WebSocket 연결 종료", CancellationToken.None);
}
webSocket.Dispose();
}
}
// Ping 테스트 (25초), 30초에 한번 응답 확인 필요
public static async void ContinuePing(ClientWebSocket webSocket)
{
while (true)
{
Thread.Sleep(25000);
await SendMessage(webSocket, "ping");
}
}
private static async Task SendMessage(ClientWebSocket webSocket, string message)
{
try
{
byte[] buffer = Encoding.UTF8.GetBytes(message);
await webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);
Console.WriteLine("메시지 전송: " + message);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
public static bool ValidateJSON(string s)
{
try
{
JToken.Parse(s);
return true;
}
catch (JsonReaderException)
{
return false;
}
}
public void CalculateDataList(BitgetWebSocketType bitgetWebSocketType)
{
try
{
var cloneList = new List<Dictionary<string, object>>();
lock (obj)
{
try
{
foreach (var item in webSocketDataList)
{
var dic = new Dictionary<string, object>();
foreach (var key in item.Keys)
{
dic[key] = item[key];
}
수정!!!
2024-05-23 16:32:30 +09:00
임시 수정
2024-07-10 11:46:59 +09:00
cloneList.Add(dic);
}
webSocketDataList.Clear();
}
catch (Exception e)
{
}
}
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
커
2024-07-11 11:27:14 +09:00
var dataList = cloneList.Where(t => t.ContainsKey("data")).Select(t => t["data"]);
var list = JsonConvert.DeserializeObject<List<List<WebSocketTickerInfo>>>(JsonConvert.SerializeObject(dataList));
구름떼 검색기 수정 중!!
2024-06-10 18:22:06 +09:00
커
2024-07-11 11:27:14 +09:00
list = list.OrderBy(t => t[0].ts).ToList();
임시 수정
2024-07-10 11:46:59 +09:00
커
2024-07-11 11:27:14 +09:00
switch (bitgetWebSocketType)
{
case CommonProperty.BitgetWebSocketType.현황정보_전체종목:
{
foreach (var datalist in list)
{
var candleInfo = datalist;
var tickerList = candleInfo[0];
DateTime dt = new DateTime(1970, 01, 01);
tickerList.reciveTime = dt.AddMilliseconds(Convert.ToDouble(tickerList.ts)).ToLocalTime();
// 웹소켓 티커 리스트에 추가 (사용 안함)
/*
var searchIndex = commonProperty.webSocketCandles.IndexOf(i => i.instId == tickerList.instId);
if (searchIndex < 0)
commonProperty.webSocketCandles.Add(tickerList);
else
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
{
커
2024-07-11 11:27:14 +09:00
commonProperty.webSocketCandles[searchIndex] = tickerList;
}
*/
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
커
2024-07-11 11:27:14 +09:00
// 캔들 리스트에서 해당 데이터 찾기
var searchIndex_c = commonProperty.candleDataLists.IndexOf(i => i.ConGoodsData.MarketName == tickerList.instId);
임시 수정
2024-07-10 11:46:59 +09:00
커
2024-07-11 11:27:14 +09:00
// 캔들 리스트에 업데이트 (전체 시간별)
foreach (CommonProperty.MCandleTimeType interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
{
var candleDataList = commonProperty.candleDataLists[searchIndex_c].candleDataList[interval];
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
커
2024-07-11 11:27:14 +09:00
// 캔들 리스트에 추가
var candleData = new CandleData();
candleData.Argument = tickerList.reciveTime;
candleData.Close = tickerList.lastPr;
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
커
2024-07-11 11:27:14 +09:00
// 캔들 리스트가 없으면 추가
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
if (candleDataList.Count == 0)
candleDataList.Add(candleData);
else
{
커
2024-07-11 11:27:14 +09:00
var lastCandleData_Edit = candleDataList.ToList();
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
커
2024-07-11 11:27:14 +09:00
// 마지막 시간 데이터 가져오기
var lastCandleData = lastCandleData_Edit.Find(j => j.Argument == lastCandleData_Edit.Max(i => i.Argument));
if (lastCandleData == null || lastCandleData.Argument > candleData.Argument) return;
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
// 업데이트 or 추가
bool updateFlag = false;
커
2024-07-11 11:27:14 +09:00
switch (interval)
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
{
case CommonProperty.MCandleTimeType.M1:
if (lastCandleData.Argument.Minute == candleData.Argument.Minute)
updateFlag = true;
break;
커
2024-07-11 11:27:14 +09:00
case CommonProperty.MCandleTimeType.M3:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Minute % 3 != 0 || (candleData.Argument.Minute % 3 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M5:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Minute % 5 != 0 || (candleData.Argument.Minute % 5 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M15:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Minute % 15 != 0 || (candleData.Argument.Minute % 15 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M30:
if (candleData.Argument.Minute % 30 != 0 || (candleData.Argument.Minute % 30 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H1:
if (candleData.Argument.Hour == candleData.Argument.Hour)
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H4:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Hour % 4 != 0 || (candleData.Argument.Hour % 4 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H6:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Hour % 6 != 0 || (candleData.Argument.Hour % 6 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H12:
임시 수정
2024-07-10 11:46:59 +09:00
if (candleData.Argument.Hour % 12 != 0 || (candleData.Argument.Hour % 12 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
updateFlag = true;
break;
}
// 이미 등록된 시간 캔들이 있는 경우 변경
if (updateFlag)
{
커
2024-07-11 11:27:14 +09:00
// 시간 업데이트
lastCandleData.Argument = candleData.Argument;
// 종가 수정
lastCandleData.Close = candleData.Close;
// 저가 등록
if (lastCandleData.Low == 0 || lastCandleData.Low > candleData.Close) lastCandleData.Low = candleData.Close;
// 고가 등록
if (lastCandleData.High == 0 || lastCandleData.High < candleData.Close) lastCandleData.High = candleData.Close;
lastCandleData.WebSocketUpdate = true;
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
}
// 없는 경우 추가
else
{
커
2024-07-11 11:27:14 +09:00
if (candleData.Open == 0) { }
// 1분 이상 Ticker가 없는 겨우는 Open 가만 가격이 등록됨
candleData.Open = candleData.Close;
candleData.WebSocketUpdate = true;
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
// 새 데이터 등록
candleDataList.Add(candleData);
커
2024-07-11 11:27:14 +09:00
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
// 기존 데이터 삭제
임시 수정
2024-07-10 11:46:59 +09:00
if (candleDataList.Count > 250)
1. 볼랜저 추가 2. 영호 사는거 파는거 디테일 추가 3. 사고 파는 Result 필드 추가 및 데이터 갖고 있게끔만 처리 (추후 Form에 올릴수 있게 할 예정)
2024-06-19 12:51:35 +09:00
{
커
2024-07-11 11:27:14 +09:00
// 가장 오래된 데이터 삭제
candleDataList.Remove(j => j.Argument == candleDataList.Min(i => i.Argument));
}
}
}
}
}
}
break;
case CommonProperty.BitgetWebSocketType.캔들정보:
#region 캔들 웹소켓 : 종목 50, 캔들 1 개만 해도 뒤지려고 함 !! (일딴 패스)
{
foreach (var datalist in cloneList)
{
var argList = JsonConvert.DeserializeObject<Dictionary<string, object>>(datalist["arg"]?.ToString());
var candleInfos = JsonConvert.DeserializeObject<List<List<object>>>(datalist["data"]?.ToString());
var candleInfo = candleInfos[0];
DateTime dt = new DateTime(1970, 01, 01);
var candleData = new CandleData(
dt.AddMilliseconds(Convert.ToDouble(candleInfo[0])).ToLocalTime(),
Convert.ToDouble(candleInfo[1]),
Convert.ToDouble(candleInfo[2]),
Convert.ToDouble(candleInfo[3]),
Convert.ToDouble(candleInfo[4]),
Convert.ToDouble(candleInfo[5]),
Convert.ToDouble(candleInfo[6]),
Convert.ToDouble(candleInfo[7])
);
// Websocket 캔들 정보 구분 하기 (1분, 1시간 등)
CommonProperty.MCandleTimeType mCandleTimeType = CommonProperty.MCandleTimeType.H1;
foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
{
// Description
var description = Utils.Convertor.GetEnumDescription((Enum)interval);
if (argList["channel"].ToString().Contains(description))
mCandleTimeType = (CommonProperty.MCandleTimeType)interval;
break;
}
// 캔들 리스트에서 해당 데이터 찾기
var searchIndex = commonProperty.candleDataLists.IndexOf(i => i.ConGoodsData.MarketName == argList["instId"].ToString());
var candleDataList = commonProperty.candleDataLists[searchIndex].candleDataList[mCandleTimeType];
// 마지막 데이터 (최신데이터) 가져오기
CandleData lastCandleData = null;
임시 수정
2024-07-10 11:46:59 +09:00
커
2024-07-11 11:27:14 +09:00
if (candleDataList.Count == 0)
candleDataList.Add(candleData);
else
{
lastCandleData = commonProperty.candleDataLists[searchIndex].candleDataList[mCandleTimeType].Last();
// 최신데이터와 비교하여 교체/등록하기
// 업데이트 or 추가
bool updateFlag = false;
switch (mCandleTimeType)
{
case CommonProperty.MCandleTimeType.M1:
if (lastCandleData.Argument.Minute == candleData.Argument.Minute)
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M3:
if (candleData.Argument.Minute % 3 != 0 || (candleData.Argument.Minute % 3 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M5:
if (candleData.Argument.Minute % 5 != 0 || (candleData.Argument.Minute % 5 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M15:
if (candleData.Argument.Minute % 15 != 0 || (candleData.Argument.Minute % 15 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.M30:
if (candleData.Argument.Minute % 30 != 0 || (candleData.Argument.Minute % 30 == 0 && candleData.Argument.Minute == lastCandleData.Argument.Minute))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H1:
if (candleData.Argument.Hour == candleData.Argument.Hour)
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H4:
if (candleData.Argument.Hour % 4 != 0 || (candleData.Argument.Hour % 4 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H6:
if (candleData.Argument.Hour % 6 != 0 || (candleData.Argument.Hour % 6 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
updateFlag = true;
break;
case CommonProperty.MCandleTimeType.H12:
if (candleData.Argument.Hour % 12 != 0 || (candleData.Argument.Hour % 12 == 0 && candleData.Argument.Hour == lastCandleData.Argument.Hour))
updateFlag = true;
break;
}
// 이미 등록된 시간 캔들이 있는 경우 변경
if (updateFlag)
{
lastCandleData = candleData;
}
// 없는 경우 추가
else
{
lastCandleData.Close = candleData.Open;
// 새 데이터 등록
candleDataList.Add(candleData);
// 기존 데이터 삭제
if (candleDataList.Count > 250)
{
var minData = candleDataList.Min(t => t.Argument);
var minCandle = candleDataList.FirstOrDefault(t => t.Argument == minData);
if (minCandle != null)
{
candleDataList.Remove(minCandle);
1. 볼랜저 추가 2. 영호 사는거 파는거 디테일 추가 3. 사고 파는 Result 필드 추가 및 데이터 갖고 있게끔만 처리 (추후 Form에 올릴수 있게 할 예정)
2024-06-19 12:51:35 +09:00
}
웻소켓 캔들 데이터 쌓기 로직 작성 (1개 데이터만 테스트)
2024-05-27 18:51:56 +09:00
}
}
}
커
2024-07-11 11:27:14 +09:00
}
수정!!!
2024-05-23 16:32:30 +09:00
}
커
2024-07-11 11:27:14 +09:00
#endregion
break;
1. 조건 재시작 및 프로그램 종료 Thread 수정
2024-06-14 14:47:51 +09:00
}
커
2024-07-11 11:27:14 +09:00
}
catch (Exception e)
위와 내용 같음
2024-05-29 17:37:10 +09:00
{
수정!!!
2024-05-23 16:32:30 +09:00
}
}
첫 등록
2024-05-22 16:56:51 +09:00
}
}
데이터 세트 구성 및 조합 1. 웹소켓 실시간 캔들 2. WebService 캔들
2024-05-28 16:56:19 +09:00
Reference in New Issue Copy Permalink