395 lines
15 KiB
C#
395 lines
15 KiB
C#
using System;
|
|
using System.IO;
|
|
using System.Collections.Generic;
|
|
using System.Globalization;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Newtonsoft.Json;
|
|
using Core.Main.DataObjects.PTMagicData;
|
|
|
|
namespace Core.Main.DataObjects
|
|
{
|
|
|
|
public class ProfitTrailerData
|
|
{
|
|
private List<SellLogData> _sellLog = new List<SellLogData>();
|
|
private List<DCALogData> _dcaLog = new List<DCALogData>();
|
|
private List<BuyLogData> _buyLog = new List<BuyLogData>();
|
|
private string _ptmBasePath = "";
|
|
private PTMagicConfiguration _systemConfiguration = null;
|
|
private TransactionData _transactionData = null;
|
|
private DateTimeOffset _dateTimeNow = Constants.confMinDate;
|
|
|
|
public ProfitTrailerData(PTMagicConfiguration systemConfiguration)
|
|
{
|
|
_systemConfiguration = systemConfiguration;
|
|
|
|
string html = "";
|
|
string url = systemConfiguration.GeneralSettings.Application.ProfitTrailerMonitorURL + "api/data?token=" + systemConfiguration.GeneralSettings.Application.ProfitTrailerServerAPIToken;
|
|
|
|
try
|
|
{
|
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
|
|
request.AutomaticDecompression = DecompressionMethods.GZip;
|
|
|
|
WebResponse response = request.GetResponse();
|
|
Stream dataStream = response.GetResponseStream();
|
|
StreamReader reader = new StreamReader(dataStream);
|
|
html = reader.ReadToEnd();
|
|
reader.Close();
|
|
response.Close();
|
|
|
|
}
|
|
catch (System.Exception)
|
|
{
|
|
throw;
|
|
}
|
|
|
|
PTData rawPTData = JsonConvert.DeserializeObject<PTData>(html);
|
|
if (rawPTData.SellLogData != null)
|
|
{
|
|
this.BuildSellLogData(rawPTData.SellLogData, _systemConfiguration);
|
|
}
|
|
|
|
if (rawPTData.bbBuyLogData != null)
|
|
{
|
|
this.BuildBuyLogData(rawPTData.bbBuyLogData, _systemConfiguration);
|
|
}
|
|
|
|
if (rawPTData.DCALogData != null)
|
|
{
|
|
this.BuildDCALogData(rawPTData.DCALogData, rawPTData.GainLogData, _systemConfiguration);
|
|
}
|
|
|
|
// Convert local offset time to UTC
|
|
TimeSpan offsetTimeSpan = TimeSpan.Parse(systemConfiguration.GeneralSettings.Application.TimezoneOffset.Replace("+", ""));
|
|
_dateTimeNow = DateTimeOffset.UtcNow.ToOffset(offsetTimeSpan);
|
|
}
|
|
|
|
public List<SellLogData> SellLog
|
|
{
|
|
get
|
|
{
|
|
return _sellLog;
|
|
}
|
|
}
|
|
|
|
public List<SellLogData> SellLogToday
|
|
{
|
|
get
|
|
{
|
|
return _sellLog.FindAll(sl => sl.SoldDate.Date == _dateTimeNow.DateTime.Date);
|
|
}
|
|
}
|
|
|
|
public List<SellLogData> SellLogYesterday
|
|
{
|
|
get
|
|
{
|
|
return _sellLog.FindAll(sl => sl.SoldDate.Date == _dateTimeNow.DateTime.AddDays(-1).Date);
|
|
}
|
|
}
|
|
|
|
public List<SellLogData> SellLogLast7Days
|
|
{
|
|
get
|
|
{
|
|
return _sellLog.FindAll(sl => sl.SoldDate.Date >= _dateTimeNow.DateTime.AddDays(-7).Date);
|
|
}
|
|
}
|
|
|
|
public List<SellLogData> SellLogLast30Days
|
|
{
|
|
get
|
|
{
|
|
return _sellLog.FindAll(sl => sl.SoldDate.Date >= _dateTimeNow.DateTime.AddDays(-30).Date);
|
|
}
|
|
}
|
|
|
|
public List<DCALogData> DCALog
|
|
{
|
|
get
|
|
{
|
|
return _dcaLog;
|
|
}
|
|
}
|
|
|
|
public List<BuyLogData> BuyLog
|
|
{
|
|
get
|
|
{
|
|
return _buyLog;
|
|
}
|
|
}
|
|
|
|
public TransactionData TransactionData
|
|
{
|
|
get
|
|
{
|
|
if (_transactionData == null) _transactionData = new TransactionData(_ptmBasePath);
|
|
return _transactionData;
|
|
}
|
|
}
|
|
|
|
public double GetCurrentBalance()
|
|
{
|
|
return this.GetSnapshotBalance(DateTime.UtcNow);
|
|
}
|
|
|
|
public double GetSnapshotBalance(DateTime snapshotDateTime)
|
|
{
|
|
double result = _systemConfiguration.GeneralSettings.Application.StartBalance;
|
|
|
|
result += this.SellLog.FindAll(sl => sl.SoldDate.Date < snapshotDateTime.Date).Sum(sl => sl.Profit);
|
|
result += this.TransactionData.Transactions.FindAll(t => t.GetLocalDateTime(_systemConfiguration.GeneralSettings.Application.TimezoneOffset) < snapshotDateTime).Sum(t => t.Amount);
|
|
|
|
return result;
|
|
}
|
|
|
|
private void BuildSellLogData(List<sellLogData> rawSellLogData, PTMagicConfiguration systemConfiguration)
|
|
{
|
|
foreach (sellLogData rsld in rawSellLogData)
|
|
{
|
|
SellLogData sellLogData = new SellLogData();
|
|
sellLogData.SoldAmount = rsld.soldAmount;
|
|
sellLogData.BoughtTimes = rsld.boughtTimes;
|
|
sellLogData.Market = rsld.market;
|
|
sellLogData.ProfitPercent = rsld.profit;
|
|
sellLogData.SoldPrice = rsld.currentPrice;
|
|
sellLogData.AverageBuyPrice = rsld.avgPrice;
|
|
sellLogData.TotalCost = sellLogData.SoldAmount * sellLogData.AverageBuyPrice;
|
|
|
|
double soldValueRaw = (sellLogData.SoldAmount * sellLogData.SoldPrice);
|
|
double soldValueAfterFees = soldValueRaw - (soldValueRaw * (rsld.fee / 100));
|
|
sellLogData.SoldValue = soldValueAfterFees;
|
|
sellLogData.Profit = Math.Round(sellLogData.SoldValue - sellLogData.TotalCost, 8);
|
|
|
|
//Convert Unix Timestamp to Datetime
|
|
System.DateTime dtDateTime = new DateTime(1970,1,1,0,0,0,System.DateTimeKind.Utc);
|
|
dtDateTime = dtDateTime.AddSeconds(rsld.soldDate).ToUniversalTime();
|
|
|
|
// Profit Trailer sales are saved in UTC
|
|
DateTimeOffset ptSoldDate = DateTimeOffset.Parse(dtDateTime.Year.ToString() + "-" + dtDateTime.Month.ToString("00") + "-" + dtDateTime.Day.ToString("00") + "T" + dtDateTime.Hour.ToString("00") + ":" + dtDateTime.Minute.ToString("00") + ":" + dtDateTime.Second.ToString("00"), CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
|
|
|
|
// Convert UTC sales time to local offset time
|
|
TimeSpan offsetTimeSpan = TimeSpan.Parse(systemConfiguration.GeneralSettings.Application.TimezoneOffset.Replace("+", ""));
|
|
ptSoldDate = ptSoldDate.ToOffset(offsetTimeSpan);
|
|
|
|
sellLogData.SoldDate = ptSoldDate.DateTime;
|
|
|
|
_sellLog.Add(sellLogData);
|
|
}
|
|
}
|
|
|
|
private void BuildDCALogData(List<dcaLogData> rawDCALogData, List<dcaLogData> rawPairsLogData, PTMagicConfiguration systemConfiguration)
|
|
{
|
|
foreach (dcaLogData rdld in rawDCALogData)
|
|
{
|
|
DCALogData dcaLogData = new DCALogData();
|
|
dcaLogData.Amount = rdld.totalAmount;
|
|
dcaLogData.BoughtTimes = rdld.boughtTimes;
|
|
dcaLogData.Market = rdld.market;
|
|
dcaLogData.ProfitPercent = rdld.profit;
|
|
dcaLogData.AverageBuyPrice = rdld.avgPrice;
|
|
dcaLogData.TotalCost = rdld.totalCost;
|
|
dcaLogData.BuyTriggerPercent = rdld.buyProfit;
|
|
dcaLogData.CurrentLowBBValue = rdld.BBLow;
|
|
dcaLogData.CurrentHighBBValue = rdld.highbb;
|
|
dcaLogData.BBTrigger = rdld.BBTrigger;
|
|
dcaLogData.CurrentPrice = rdld.currentPrice;
|
|
dcaLogData.SellTrigger = rdld.triggerValue;
|
|
dcaLogData.PercChange = rdld.percChange;
|
|
dcaLogData.BuyStrategy = rdld.buyStrategy;
|
|
if (dcaLogData.BuyStrategy == null) dcaLogData.BuyStrategy = "";
|
|
dcaLogData.SellStrategy = rdld.sellStrategy;
|
|
if (dcaLogData.SellStrategy == null) dcaLogData.SellStrategy = "";
|
|
|
|
if (rdld.positive != null)
|
|
{
|
|
dcaLogData.IsTrailing = rdld.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
dcaLogData.IsTrue = rdld.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
}
|
|
else
|
|
{
|
|
if (rdld.buyStrategies != null)
|
|
{
|
|
foreach (PTStrategy bs in rdld.buyStrategies)
|
|
{
|
|
Strategy buyStrategy = new Strategy();
|
|
buyStrategy.Type = bs.type;
|
|
buyStrategy.Name = bs.name;
|
|
buyStrategy.EntryValue = bs.entryValue;
|
|
buyStrategy.EntryValueLimit = bs.entryValueLimit;
|
|
buyStrategy.TriggerValue = bs.triggerValue;
|
|
buyStrategy.CurrentValue = bs.currentValue;
|
|
buyStrategy.CurrentValuePercentage = bs.currentValuePercentage;
|
|
buyStrategy.Decimals = bs.decimals;
|
|
buyStrategy.IsTrailing = bs.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
buyStrategy.IsTrue = bs.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
|
|
dcaLogData.BuyStrategies.Add(buyStrategy);
|
|
}
|
|
}
|
|
|
|
if (rdld.sellStrategies != null)
|
|
{
|
|
foreach (PTStrategy ss in rdld.sellStrategies)
|
|
{
|
|
Strategy sellStrategy = new Strategy();
|
|
sellStrategy.Type = ss.type;
|
|
sellStrategy.Name = ss.name;
|
|
sellStrategy.EntryValue = ss.entryValue;
|
|
sellStrategy.EntryValueLimit = ss.entryValueLimit;
|
|
sellStrategy.TriggerValue = ss.triggerValue;
|
|
sellStrategy.CurrentValue = ss.currentValue;
|
|
sellStrategy.CurrentValuePercentage = ss.currentValuePercentage;
|
|
sellStrategy.Decimals = ss.decimals;
|
|
sellStrategy.IsTrailing = ss.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
sellStrategy.IsTrue = ss.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
|
|
dcaLogData.SellStrategies.Add(sellStrategy);
|
|
}
|
|
}
|
|
}
|
|
|
|
//Convert Unix Timestamp to Datetime
|
|
System.DateTime rdldDateTime = new DateTime(1970,1,1,0,0,0,System.DateTimeKind.Utc);
|
|
rdldDateTime = rdldDateTime.AddSeconds(rdld.firstBoughtDate).ToUniversalTime();
|
|
|
|
// Profit Trailer bought times are saved in UTC
|
|
if (rdld.firstBoughtDate > 0)
|
|
{
|
|
DateTimeOffset ptFirstBoughtDate = DateTimeOffset.Parse(rdldDateTime.Year.ToString() + "-" + rdldDateTime.Month.ToString("00") + "-" + rdldDateTime.Day.ToString("00") + "T" + rdldDateTime.Hour.ToString("00") + ":" + rdldDateTime.Minute.ToString("00") + ":" + rdldDateTime.Second.ToString("00"), CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
|
|
|
|
// Convert UTC bought time to local offset time
|
|
TimeSpan offsetTimeSpan = TimeSpan.Parse(systemConfiguration.GeneralSettings.Application.TimezoneOffset.Replace("+", ""));
|
|
ptFirstBoughtDate = ptFirstBoughtDate.ToOffset(offsetTimeSpan);
|
|
|
|
dcaLogData.FirstBoughtDate = ptFirstBoughtDate.DateTime;
|
|
}
|
|
else
|
|
{
|
|
dcaLogData.FirstBoughtDate = Constants.confMinDate;
|
|
}
|
|
|
|
_dcaLog.Add(dcaLogData);
|
|
}
|
|
|
|
foreach (dcaLogData rpld in rawPairsLogData)
|
|
{
|
|
DCALogData dcaLogData = new DCALogData();
|
|
dcaLogData.Amount = rpld.totalAmount;
|
|
dcaLogData.BoughtTimes = 0;
|
|
dcaLogData.Market = rpld.market;
|
|
dcaLogData.ProfitPercent = rpld.profit;
|
|
dcaLogData.AverageBuyPrice = rpld.avgPrice;
|
|
dcaLogData.TotalCost = rpld.totalCost;
|
|
dcaLogData.BuyTriggerPercent = rpld.buyProfit;
|
|
dcaLogData.CurrentPrice = rpld.currentPrice;
|
|
dcaLogData.SellTrigger = rpld.triggerValue;
|
|
dcaLogData.PercChange = rpld.percChange;
|
|
dcaLogData.BuyStrategy = rpld.buyStrategy;
|
|
if (dcaLogData.BuyStrategy == null) dcaLogData.BuyStrategy = "";
|
|
dcaLogData.SellStrategy = rpld.sellStrategy;
|
|
if (dcaLogData.SellStrategy == null) dcaLogData.SellStrategy = "";
|
|
dcaLogData.IsTrailing = false;
|
|
|
|
if (rpld.sellStrategies != null)
|
|
{
|
|
foreach (PTStrategy ss in rpld.sellStrategies)
|
|
{
|
|
Strategy sellStrategy = new Strategy();
|
|
sellStrategy.Type = ss.type;
|
|
sellStrategy.Name = ss.name;
|
|
sellStrategy.EntryValue = ss.entryValue;
|
|
sellStrategy.EntryValueLimit = ss.entryValueLimit;
|
|
sellStrategy.TriggerValue = ss.triggerValue;
|
|
sellStrategy.CurrentValue = ss.currentValue;
|
|
sellStrategy.CurrentValuePercentage = ss.currentValuePercentage;
|
|
sellStrategy.Decimals = ss.decimals;
|
|
sellStrategy.IsTrailing = ss.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
sellStrategy.IsTrue = ss.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
|
|
dcaLogData.SellStrategies.Add(sellStrategy);
|
|
}
|
|
}
|
|
|
|
//Convert Unix Timestamp to Datetime
|
|
System.DateTime rpldDateTime = new DateTime(1970,1,1,0,0,0,System.DateTimeKind.Utc);
|
|
rpldDateTime = rpldDateTime.AddSeconds(rpld.firstBoughtDate).ToUniversalTime();
|
|
|
|
// Profit Trailer bought times are saved in UTC
|
|
if (rpld.firstBoughtDate > 0)
|
|
{
|
|
DateTimeOffset ptFirstBoughtDate = DateTimeOffset.Parse(rpldDateTime.Year.ToString() + "-" + rpldDateTime.Month.ToString("00") + "-" + rpldDateTime.Day.ToString("00") + "T" + rpldDateTime.Hour.ToString("00") + ":" + rpldDateTime.Minute.ToString("00") + ":" + rpldDateTime.Second.ToString("00"), CultureInfo.InvariantCulture, DateTimeStyles.AssumeUniversal);
|
|
|
|
// Convert UTC bought time to local offset time
|
|
TimeSpan offsetTimeSpan = TimeSpan.Parse(systemConfiguration.GeneralSettings.Application.TimezoneOffset.Replace("+", ""));
|
|
ptFirstBoughtDate = ptFirstBoughtDate.ToOffset(offsetTimeSpan);
|
|
|
|
dcaLogData.FirstBoughtDate = ptFirstBoughtDate.DateTime;
|
|
}
|
|
else
|
|
{
|
|
dcaLogData.FirstBoughtDate = Constants.confMinDate;
|
|
}
|
|
|
|
_dcaLog.Add(dcaLogData);
|
|
}
|
|
}
|
|
|
|
private void BuildBuyLogData(List<buyLogData> rawBuyLogData, PTMagicConfiguration systemConfiguration)
|
|
{
|
|
foreach (buyLogData rbld in rawBuyLogData)
|
|
{
|
|
BuyLogData buyLogData = new BuyLogData();
|
|
buyLogData.Market = rbld.market;
|
|
buyLogData.ProfitPercent = rbld.profit;
|
|
buyLogData.TriggerValue = rbld.triggerValue;
|
|
buyLogData.CurrentValue = rbld.currentValue;
|
|
buyLogData.CurrentPrice = rbld.currentPrice;
|
|
buyLogData.PercChange = rbld.percChange;
|
|
buyLogData.BuyStrategy = rbld.buyStrategy;
|
|
buyLogData.CurrentLowBBValue = rbld.BBLow;
|
|
buyLogData.CurrentHighBBValue = rbld.BBHigh;
|
|
buyLogData.BBTrigger = rbld.BBTrigger;
|
|
|
|
if (buyLogData.BuyStrategy == null) buyLogData.BuyStrategy = "";
|
|
|
|
if (rbld.positive != null)
|
|
{
|
|
buyLogData.IsTrailing = rbld.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
buyLogData.IsTrue = rbld.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
}
|
|
else
|
|
{
|
|
if (rbld.buyStrategies != null)
|
|
{
|
|
foreach (PTStrategy bs in rbld.buyStrategies)
|
|
{
|
|
Strategy buyStrategy = new Strategy();
|
|
buyStrategy.Type = bs.type;
|
|
buyStrategy.Name = bs.name;
|
|
buyStrategy.EntryValue = bs.entryValue;
|
|
buyStrategy.EntryValueLimit = bs.entryValueLimit;
|
|
buyStrategy.TriggerValue = bs.triggerValue;
|
|
buyStrategy.CurrentValue = bs.currentValue;
|
|
buyStrategy.CurrentValuePercentage = bs.currentValuePercentage;
|
|
buyStrategy.Decimals = bs.decimals;
|
|
buyStrategy.IsTrailing = bs.positive.IndexOf("trailing", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
buyStrategy.IsTrue = bs.positive.IndexOf("true", StringComparison.InvariantCultureIgnoreCase) > -1;
|
|
|
|
buyLogData.BuyStrategies.Add(buyStrategy);
|
|
}
|
|
}
|
|
}
|
|
|
|
_buyLog.Add(buyLogData);
|
|
}
|
|
}
|
|
}
|
|
}
|