504 lines
23 KiB
C#
504 lines
23 KiB
C#
using BitgetApi.Data;
|
|
using BitgetAPI.Data;
|
|
using BitgetAPI.IndicatorConditionSetup;
|
|
using BitgetAPI.WebService;
|
|
using DevExpress.Utils.Extensions;
|
|
using DevExpress.Utils.MVVM;
|
|
using DevExpress.XtraEditors;
|
|
using DevExpress.XtraGrid.Views.BandedGrid.Handler;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Data;
|
|
using System.Drawing;
|
|
using System.Linq;
|
|
using System.Net.WebSockets;
|
|
using System.Reflection;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Windows.Forms;
|
|
using static BitgetAPI.CommonProperty;
|
|
using static DevExpress.Utils.Html.ViewInfo.DxHtmlOrderedListInfoCore;
|
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement.TextBox;
|
|
|
|
namespace BitgetAPI
|
|
{
|
|
public partial class MainForm : Form
|
|
{
|
|
CommonProperty commonProperty = CommonProperty.Instance;
|
|
|
|
#region 폼 내 사용되는 스레드
|
|
// 트리 현황판 업데이트 스레드
|
|
Thread treeListMarketInfoListUpdateTimer = null;
|
|
// 현황판 웹소켓 스레드
|
|
Thread th_MarketStatus = null;
|
|
// WebSocket 내 스레드 관리
|
|
List<Thread> webSocketThreadList = new List<Thread>();
|
|
// 종목별 캔들 데이터 스레드
|
|
Thread th_MarketCandeData = null;
|
|
// 신호검색 스레드 함수
|
|
Thread th_SignalInfo = null;
|
|
|
|
// 신호검색 리스트 작성
|
|
// 신호 Long 상승 (구매)
|
|
List<SignalInfoData> signals_LU = null;
|
|
// 신호 Short 하락 (구매)
|
|
List<SignalInfoData> signals_SD = null;
|
|
// 검색현황 Long 하락 (판매)
|
|
List<SignalInfoData> signals_LD = null;
|
|
// 검색현황 Short 상승 (판매)
|
|
List<SignalInfoData> signals_SU = null;
|
|
|
|
// 종목별 캔들 데이터 : 캔들 개수
|
|
const int candleCount = 200;
|
|
#endregion
|
|
|
|
public MainForm()
|
|
{
|
|
InitializeComponent();
|
|
|
|
init();
|
|
}
|
|
|
|
// 폼 초기화 작업
|
|
public void init()
|
|
{
|
|
commonProperty.mainform = this;
|
|
|
|
// 거래소 항목 추가 및 설정하기
|
|
comboBoxEdit_ExchangePlace.Properties.Items.AddRange(Enum.GetNames(typeof(CommonProperty.ExchangePlace)));
|
|
comboBoxEdit_ExchangePlace.SelectedIndex = (int)CommonProperty.ExchangePlace.Bitget;
|
|
commonProperty.selectedChangePlace = CommonProperty.ExchangePlace.Bitget;
|
|
|
|
// 현황판 정렬
|
|
treeList_MarketInfo.BeginSort();
|
|
treeList_MarketInfo.Columns["quoteVolume"].SortOrder = SortOrder.Descending;
|
|
treeList_MarketInfo.EndSort();
|
|
|
|
// 현황판 웹소켓
|
|
commonProperty.webSocketCandles = new List<WebSocketTickerInfo>();
|
|
treeList_MarketInfo.DataSource = commonProperty.webSocketCandles;
|
|
th_MarketStatus = new Thread(() => ThreadEventAsync(BitgetWebSocketType.현황정보_전체종목, "ticker"));
|
|
th_MarketStatus.Start();
|
|
|
|
// 트리 현황판 업데이트
|
|
treeListMarketInfoListUpdateTimer = new Thread(new ThreadStart(TreeListMarketInfoListUpdate));
|
|
treeListMarketInfoListUpdateTimer.Start();
|
|
|
|
// 신호 Long 상승 (구매)
|
|
signals_LU = new List<SignalInfoData>();
|
|
// 신호 Short 하락 (구매)
|
|
signals_SD = new List<SignalInfoData>();
|
|
// 검색현황 Long 하락 (판매)
|
|
signals_LD = new List<SignalInfoData>();
|
|
// 검색현황 Short 상승 (판매)
|
|
signals_SU = new List<SignalInfoData>();
|
|
|
|
// 신호검색 트리리스트 설정
|
|
treeList_LongUp.DataSource = signals_LU;
|
|
treeList_ShortDown.DataSource = signals_SD;
|
|
|
|
// 신호검색 스레드
|
|
th_SignalInfo = new Thread(new ThreadStart(Signalnfo));
|
|
th_SignalInfo.Start();
|
|
|
|
// API Key 가져오기 및 등록
|
|
|
|
}
|
|
|
|
// 웹소켓 생성 관련 함수 스레드 => Thread
|
|
private async void ThreadEventAsync(BitgetWebSocketType bitgetWebSocketType, string channel)
|
|
{
|
|
// WebSocket 생성
|
|
WebConnection webConnection = new WebConnection();
|
|
|
|
webConnection.BitGetWebSocektStart(bitgetWebSocketType, channel);
|
|
|
|
Invoke(new MethodInvoker(delegate ()
|
|
{
|
|
// WebSocket 내 스레드 관리
|
|
webSocketThreadList.Add(webConnection.th_PingTimer);
|
|
}));
|
|
}
|
|
|
|
// 마켓 현황판 업데이트 (1) => Thread
|
|
// 지표 생성 및 신호 검색 (2)
|
|
private void TreeListMarketInfoListUpdate( )
|
|
{
|
|
// 마켓 현황판 업데이트
|
|
while(true)
|
|
{
|
|
Thread.Sleep(300);
|
|
|
|
Invoke(new MethodInvoker(delegate ()
|
|
{
|
|
var scrollPoint = treeList_MarketInfo.TopVisibleNodeIndex;
|
|
var scrollPoint_LU = treeList_LongUp.TopVisibleNodeIndex;
|
|
var scrollPoint_SD = treeList_ShortDown.TopVisibleNodeIndex;
|
|
|
|
treeList_MarketInfo.RefreshDataSource();
|
|
treeList_LongUp.RefreshDataSource();
|
|
treeList_ShortDown.RefreshDataSource();
|
|
|
|
treeList_MarketInfo.TopVisibleNodeIndex = scrollPoint;
|
|
treeList_LongUp.TopVisibleNodeIndex = scrollPoint_LU;
|
|
treeList_ShortDown.TopVisibleNodeIndex = scrollPoint_SD;
|
|
}));
|
|
}
|
|
}
|
|
|
|
// 신호검색 Thread 함수
|
|
private void Signalnfo()
|
|
{
|
|
IchimokuConditionSetup ichimokuConditionSetup = new IchimokuConditionSetup();
|
|
|
|
/*
|
|
* 전환선 : (과거 n일간의 최고가 + 과거 n일간의 최저가) / 2
|
|
|
|
기준선 : (과거 m일간의 최고가 + 과거 m일간의 최저가) / 2
|
|
|
|
후행스팬 : 금일 종가를 ℓ일 전에 기입
|
|
선행스팬1 : (금일 전환선 + 금일 기준선) / 2한 값을 ℓ일 후에 기입
|
|
|
|
선행스팬2 : (과거 k일간의 최고가 + 과거 k일간의 최저가) /2한 값을 ℓ일 후에 기입
|
|
*/
|
|
|
|
while (true)
|
|
{
|
|
//if (!xtraTabPage_Searcher.PageEnabled) continue;
|
|
|
|
Thread.Sleep(200);
|
|
var nowTime = DateTime.Now;
|
|
|
|
// 특정 시간 이후 삭제
|
|
foreach (var item in signals_LU.ToList())
|
|
{
|
|
// 시간 지나면 삭제
|
|
if (item.SignalStart + timeSpanEdit_SesstionTime.TimeSpan < nowTime)
|
|
{
|
|
signals_LU.Remove(item);
|
|
continue;
|
|
|
|
}
|
|
var findedMarket = commonProperty.candleDataLists.Find(i => i.ConGoodsData.MarketName == item.MarketName);
|
|
var lastCandleData = findedMarket.candleDataList[item.MCandleTimeType].OrderBy(i => i.Argument).ToList().Last();
|
|
|
|
if(lastCandleData.IchimokData != null)
|
|
{
|
|
item.Price = lastCandleData.Close;
|
|
item.Rate = (lastCandleData.Close / lastCandleData.Open) * 100 - 100;
|
|
item.IndicatorPrice = lastCandleData.IchimokData.상한선;
|
|
item.IndicatorRate = (lastCandleData.Close / item.IndicatorPrice) * 100 - 100;
|
|
}
|
|
|
|
}
|
|
foreach (var item in signals_LD.ToList())
|
|
if (item.SignalStart + timeSpanEdit_SesstionTime.TimeSpan < nowTime) { signals_LD.Remove(item); }
|
|
foreach (var item in signals_SU.ToList())
|
|
if (item.SignalStart + timeSpanEdit_SesstionTime.TimeSpan < nowTime) signals_SU.Remove(item);
|
|
foreach (var item in signals_SD.ToList())
|
|
if (item.SignalStart + timeSpanEdit_SesstionTime.TimeSpan < nowTime) signals_SD.Remove(item);
|
|
|
|
var intervalList = checkedComboBoxEdit_TimeInterval.Properties.Items.GetCheckedValues();
|
|
|
|
// 체크된 마켓 정보
|
|
foreach (string market in checkedComboBoxEdit_MarketInfoList.Properties.Items.GetCheckedValues())
|
|
{
|
|
var findedMarket = commonProperty.candleDataLists.Find(i => i.ConGoodsData.MarketName == market);
|
|
|
|
foreach (CommonProperty.MCandleTimeType interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
|
|
{
|
|
// Description
|
|
var description = Utils.Convertor.GetEnumDescription((Enum)interval);
|
|
if (!intervalList.Contains(description)) continue;
|
|
|
|
// 시간별로 정렬하기 (임시 리스트)
|
|
var candleDatas = findedMarket.candleDataList[interval];
|
|
var candleDatas_정렬 = candleDatas.OrderBy(i => i.Argument).ToList();
|
|
|
|
var candleData = candleDatas.Find(i => i.Argument == candleDatas_정렬.Last().Argument);
|
|
|
|
ichimokuConditionSetup.calIchimokuData(candleDatas_정렬, candleData);
|
|
|
|
candleDatas_정렬.RemoveAt(candleDatas_정렬.Count - 1);
|
|
var candleData_전봉 = candleDatas.Find(i => i.Argument == candleDatas_정렬.Last().Argument);
|
|
|
|
ichimokuConditionSetup.calIchimokuData(candleDatas_정렬, candleData_전봉);
|
|
|
|
if (candleData_전봉.Open < candleData_전봉.IchimokData.상한선 && candleData.Open > candleData.IchimokData.상한선)
|
|
{
|
|
var price = candleData.Close;
|
|
var rate = (candleData.Close / candleData.Open) * 100 - 100;
|
|
var indicatorPrice = candleData.IchimokData.상한선;
|
|
var indicatorRate = (candleData.Close / indicatorPrice) * 100 - 100;
|
|
|
|
var signalData = signals_LU.Find(i => i.MarketName.Equals(market));
|
|
|
|
// 없으면 생성
|
|
if (signalData == null)
|
|
{
|
|
SignalInfoData signalInfoData = new SignalInfoData();
|
|
signalInfoData.SignalStart = nowTime;
|
|
signalInfoData.MarketName = market;
|
|
signalInfoData.Description = string.Format("{0} 상승", description);
|
|
signalInfoData.Rate = rate;
|
|
signalInfoData.Price = price;
|
|
signalInfoData.IndicatorPrice = indicatorPrice;
|
|
signalInfoData.IndicatorRate = indicatorRate;
|
|
signalInfoData.MCandleTimeType = interval;
|
|
|
|
signals_LU.Add(signalInfoData);
|
|
}
|
|
}
|
|
else if (candleData_전봉.Open > candleData_전봉.IchimokData.하한선 && candleData.Open < candleData.IchimokData.하한선)
|
|
{
|
|
var price = candleData.Close;
|
|
var rate = (candleData.Close / candleData.Open) * 100 - 100;
|
|
var indicatorPrice = candleData.IchimokData.하한선;
|
|
var indicatorRate = (candleData.Close / indicatorPrice) * 100 - 100;
|
|
|
|
var signalData = signals_SD.Find(i => i.MarketName.Equals(market));
|
|
// 존재하면 업데이트
|
|
if (signalData != null)
|
|
{
|
|
signalData.Price = price;
|
|
signalData.Rate = rate;
|
|
signalData.IndicatorPrice = indicatorPrice;
|
|
signalData.IndicatorRate = indicatorRate;
|
|
}
|
|
// 없으면 생성
|
|
else
|
|
{
|
|
SignalInfoData signalInfoData = new SignalInfoData();
|
|
signalInfoData.SignalStart = nowTime;
|
|
signalInfoData.MarketName = market;
|
|
signalInfoData.Description = string.Format("{0} 하락", description);
|
|
signalInfoData.Rate = rate;
|
|
signalInfoData.Price = price;
|
|
signalInfoData.IndicatorPrice = indicatorPrice;
|
|
signalInfoData.IndicatorRate = indicatorRate;
|
|
|
|
signals_SD.Add(signalInfoData);
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
|
|
// 종목별 캔들데이터 가져오기 (초기 설정) => Thread
|
|
private void getMarketCandleData_WebService(ExchangeWebReqType exchangeWebReqType)
|
|
{
|
|
// 프로그레스 바
|
|
progressBarControl_data.Properties.Minimum = 0;
|
|
progressBarControl_data.Properties.Maximum = commonProperty.candleDataLists.Count;
|
|
progressBarControl_data.Properties.Step = 1;
|
|
progressBarControl_data.EditValue = 0;
|
|
var progressCnt = 0;
|
|
// WebServicee 초기 캔들 데이터 가져오기 : 종목, 개수
|
|
foreach (var marketCandleDataList in commonProperty.candleDataLists)
|
|
{
|
|
var marketName = marketCandleDataList.ConGoodsData.MarketName;
|
|
|
|
// 캔들 데이터 가져오기
|
|
foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
|
|
{
|
|
// Description
|
|
var description = Utils.Convertor.GetEnumDescription((Enum)interval);
|
|
// 1M, 3M Names....
|
|
var intervalName = Enum.GetName(typeof(CommonProperty.MCandleTimeType), interval);
|
|
|
|
var url = "";
|
|
|
|
switch (commonProperty.selectedChangePlace)
|
|
{
|
|
case ExchangePlace.Upbit:
|
|
break;
|
|
case ExchangePlace.Bitget:
|
|
switch (commonProperty.selectedBitgetProductType)
|
|
{
|
|
case BitgetProductType.COIN:
|
|
exchangeWebReqType = ExchangeWebReqType.BitgetCandleStick_Coin;
|
|
var defaultDateTime = DateTime.Now;
|
|
|
|
var startDateTime = DateTime.FromFileTimeUtc(defaultDateTime.Ticks);
|
|
|
|
// count + 50 개 캔들 추가 가져오기
|
|
var endDateTime = DateTime.FromFileTimeUtc(defaultDateTime.AddSeconds((int)interval * -1).Ticks);
|
|
|
|
// 종목, 인터벌시간, 시작시간(UTC), 종료시간(UTC), 제한 개수 (default:100, Max:1000)
|
|
url = string.Format(BitgetURL_MarketCandle_Coin,
|
|
marketName, description, startDateTime.ToString(), endDateTime.ToString(), candleCount.ToString());
|
|
break;
|
|
case BitgetProductType.FUTURE:
|
|
exchangeWebReqType = ExchangeWebReqType.BitgetCandleStick_Future;
|
|
|
|
url = string.Format(CommonProperty.BitgetURL_MarketCandle_Future,
|
|
marketName, description, candleCount.ToString(), "USDT-FUTURES");
|
|
break;
|
|
}
|
|
break;
|
|
}
|
|
|
|
// 초당 20회 제한 !!!!
|
|
// Thread.Sleep(50);
|
|
var candleList = BitgetAPI.WebService.WebConnection.SendWebServer(exchangeWebReqType, url, marketCandleDataList, (CommonProperty.MCandleTimeType) interval);
|
|
}
|
|
|
|
// 프로그레스 바
|
|
progressCnt++;
|
|
Invoke(new MethodInvoker(delegate ()
|
|
{
|
|
progressBarControl_data.EditValue = progressCnt;
|
|
progressBarControl_data.PerformStep();
|
|
progressBarControl_data.Update();
|
|
|
|
//xtraTabPage_Searcher.PageEnabled = true;
|
|
//xtraTabControl_Main.SelectedTabPage = xtraTabPage_Searcher;
|
|
}));
|
|
}
|
|
|
|
Invoke(new MethodInvoker(delegate ()
|
|
{
|
|
xtraTabPage_Searcher.PageEnabled = true;
|
|
xtraTabControl_Main.SelectedTabPage = xtraTabPage_Searcher;
|
|
}));
|
|
}
|
|
|
|
// 거래소 콤보박스 클릭 시 이벤트 처리
|
|
private void comboBox_ExchangePlace_SelectedIndexChanged(object sender, EventArgs e)
|
|
{
|
|
var combobox = (ComboBoxEdit)sender;
|
|
|
|
// 거래소에 따라서 코인 타입 생성하기
|
|
switch (combobox.SelectedIndex)
|
|
{
|
|
case (int)CommonProperty.ExchangePlace.Bitget:
|
|
// 코인 타입 설정하기
|
|
comboBoxEdit_ConinType.Properties.Items.AddRange(Enum.GetNames(typeof(CommonProperty.BitgetProductType)));
|
|
comboBoxEdit_ConinType.SelectedIndex = (int)CommonProperty.BitgetProductType.FUTURE;
|
|
commonProperty.selectedBitgetProductType = CommonProperty.BitgetProductType.FUTURE;
|
|
break;
|
|
}
|
|
|
|
}
|
|
|
|
// 코인 타입 콤보박스 클릭 시 이벤트 처리
|
|
private void comboBox_CoinType_SelectedIndexChanged(object sender, EventArgs e)
|
|
{
|
|
var combobox = (ComboBoxEdit)sender;
|
|
|
|
// 선택된 타입에 따라서 종목 정보 가져오기
|
|
ExchangeWebReqType exchangeWebReqType = ExchangeWebReqType.BitgetMarket_Future;
|
|
switch (combobox.SelectedIndex)
|
|
{
|
|
case (int)CommonProperty.BitgetProductType.COIN:
|
|
commonProperty.selectedBitgetProductType = CommonProperty.BitgetProductType.COIN;
|
|
exchangeWebReqType = ExchangeWebReqType.BitgetMarket_Spot;
|
|
break;
|
|
case (int)CommonProperty.BitgetProductType.FUTURE:
|
|
commonProperty.selectedBitgetProductType = CommonProperty.BitgetProductType.FUTURE;
|
|
exchangeWebReqType = ExchangeWebReqType.BitgetMarket_Future;
|
|
break;
|
|
case (int)CommonProperty.BitgetProductType.MARGIN_보류:
|
|
commonProperty.selectedBitgetProductType = CommonProperty.BitgetProductType.MARGIN_보류;
|
|
break;
|
|
}
|
|
|
|
// 마켓 정보 가져오기
|
|
var marketInfos = (List<MarketInfo>)BitgetAPI.WebService.WebConnection.SendWebServer(exchangeWebReqType);
|
|
|
|
labelControl_MarketCount.Text = marketInfos.Count().ToString();
|
|
treeList_MarketInfo.DataSource = marketInfos;
|
|
treeList_MarketInfo.RefreshDataSource();
|
|
|
|
List<MarketCandleDataList> candleDataLists = new List<MarketCandleDataList>();
|
|
|
|
commonProperty.candleDataLists = candleDataLists;
|
|
|
|
// 캔들 리스트 생성하기
|
|
foreach (var item in marketInfos)
|
|
{
|
|
MarketCandleDataList candleDataList = new MarketCandleDataList();
|
|
candleDataList.ConGoodsData = item;
|
|
foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
|
|
{
|
|
candleDataList.candleDataList.Add((MCandleTimeType)interval, new List<CandleData>());
|
|
}
|
|
candleDataLists.Add(candleDataList);
|
|
}
|
|
|
|
// 조건 설정 : 체크콤보박스 마켓 정보 추가하기
|
|
foreach (var item in commonProperty.candleDataLists)
|
|
checkedComboBoxEdit_MarketInfoList.Properties.Items.Add(item.ConGoodsData.MarketName);
|
|
// 조건 설정 : 체크콤보박스 시간별 정보 추가하기
|
|
// 캔들 데이터 가져오기
|
|
foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
|
|
{
|
|
var description = Utils.Convertor.GetEnumDescription((Enum)interval);
|
|
checkedComboBoxEdit_TimeInterval.Properties.Items.Add(description);
|
|
}
|
|
|
|
#region 캔들 웹소켓 : 종목 50, 캔들 1 개만 해도 뒤지려고 함 !! (일딴 패스)
|
|
/*
|
|
// 시간별 분봉 웹소켓
|
|
foreach (var interval in Enum.GetValues(typeof(CommonProperty.MCandleTimeType)))
|
|
{
|
|
var description = Utils.Convertor.GetEnumDescription((Enum)interval);
|
|
var th_CandleStatus = new Thread(() => ThreadEventAsync(BitgetWebSocketType.캔들정보, "candle" + description));
|
|
th_CandleStatus.Start();
|
|
break;
|
|
}*/
|
|
#endregion
|
|
|
|
// WebServicee 초기 캔들 데이터 가져오기 : 종목, 개수
|
|
// 종목별 캔들 데이터 가져오기 (WebService)
|
|
th_MarketCandeData = new Thread(() => getMarketCandleData_WebService(exchangeWebReqType));
|
|
th_MarketCandeData.Start();
|
|
}
|
|
|
|
// 폼 닫기 시 처리 이벤트
|
|
private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
|
|
{
|
|
if (th_MarketStatus != null)
|
|
{
|
|
th_MarketStatus.Abort();
|
|
th_MarketStatus = null;
|
|
}
|
|
|
|
if (treeListMarketInfoListUpdateTimer != null)
|
|
{
|
|
treeListMarketInfoListUpdateTimer.Abort();
|
|
treeListMarketInfoListUpdateTimer = null;
|
|
}
|
|
|
|
if (th_MarketCandeData != null)
|
|
{
|
|
th_MarketCandeData.Abort();
|
|
th_MarketCandeData = null;
|
|
}
|
|
|
|
if(th_SignalInfo != null)
|
|
{
|
|
th_SignalInfo.Abort();
|
|
th_SignalInfo = null;
|
|
}
|
|
|
|
for(var cnt = 0; cnt < webSocketThreadList.Count; cnt++)
|
|
{
|
|
if(webSocketThreadList[cnt] != null && webSocketThreadList[cnt].ThreadState != ThreadState.Running)
|
|
{
|
|
webSocketThreadList[cnt].Abort();
|
|
webSocketThreadList[cnt] = null;
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|