Binance.TradeRobot.API/Binance.TradeRobot.Business/Business/TradeBusiness/D21TradeBusiness.cs

using Binance.TradeRobot.Business.Extensions;
using Binance.TradeRobot.Common.DI;
using Binance.TradeRobot.Model.Base;
using Binance.TradeRobot.Model.Db;
using Binance.TradeRobot.Model.Dto;
using Binance.TradeRobot.Model.RuningInfo;
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.DependencyInjection;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using Yitter.IdGenerator;

namespace Binance.TradeRobot.Business
{
    [BatchRegistration(ServiceLifetime.Singleton, RegistrationType.Interface)]
    public class D21TradeBusiness : BaseBusiness, ITradeBusiness
    {
        private DingBusiness dingBusiness;
        private GlobalContext globalContext;
        private IList<Enums.SpotOrderState> validStateList;
        public Enums.TradePolicy TradePolicy => Enums.TradePolicy.D21;

        public D21TradeBusiness(IFreeSql fsql,
                                NLogManager logManager,
                                IIdGenerator idGenerator,
                                IMemoryCache memoryCache,
                                DingBusiness dingBusiness,
                                GlobalContext globalContext) : base(fsql, logManager, idGenerator, memoryCache)
        {
            this.dingBusiness = dingBusiness;
            this.globalContext = globalContext;
            validStateList = new List<Enums.SpotOrderState>()
            {
                Enums.SpotOrderState.Filled,
                Enums.SpotOrderState.PartiallyFilled,
                Enums.SpotOrderState.Expired
            };
        }

        public void TrendChanged<T, T1>(T singalRequest, T1 robot) where T : BaseSingalRequest where T1 : RobotResponse
        {
            try
            {
                var executionLog = new ExecutionLog()
                {
                    Id = idGenerator.NewLong(),
                    RobotId = robot.Id,
                    CreateTime = DateTime.Now,
                    SourceSingal = singalRequest.SingalType,
                    Content = $"收到信号{singalRequest.SingalType}"
                };
                fsql.Insert(executionLog).ExecuteAffrows();
                var d21RuningInfo = RedisHelper.Get<D21RuningInfo>(robot.Id.ToString()) ?? new D21RuningInfo() { RobotId = robot.Id };
                d21RuningInfo.RecentSmallTrendSingal = singalRequest.SingalType;
                RedisHelper.Set(robot.Id.ToString(), d21RuningInfo);
            }
            catch (Exception ex)
            {
                var stringBuilder = new StringBuilder("TrendChanged");
                stringBuilder.AppendLine($"SingalRequest {JsonConvert.SerializeObject(singalRequest)}");
                stringBuilder.AppendLine($"Robot {JsonConvert.SerializeObject(robot)}");
                logManager.GetLogger(robot.ExecuteLogKey).Error(ex, stringBuilder.ToString());
            }
        }

        public void LongCross<T, T1>(T singalRequest, T1 robot, bool isRemedy) where T : BaseSingalRequest where T1 : RobotResponse
        {
            string step = string.Empty;
            var logList = new List<ExecutionLog>();
            logList.Add(new ExecutionLog()
            {
                Id = idGenerator.NewLong(),
                SourceSingal = Enums.SingalType.多交叉,
                RobotId = robot.Id,
                CreateTime = DateTime.Now,
                Content = $"收到信号{singalRequest.SingalType}{(isRemedy ? "(补救)" : string.Empty)}"
            });
            try
            {
                var d21RuningInfo = RedisHelper.Get<D21RuningInfo>(robot.Id.ToString()) ?? new D21RuningInfo() { RobotId = robot.Id };

                #region 验证信号
                step = "验证信号";
                if (!isRemedy)
                {
                    if (d21RuningInfo.ErrorCrossSingal != null)
                    {
                        d21RuningInfo.ErrorCrossSingal = null;
                        d21RuningInfo.ErrorCrossSingalTime = 0;
                        RedisHelper.Set(robot.Id.ToString(), d21RuningInfo);
                        throw new BusinessException("前一个信号错误,终止多交叉信号执行");
                    }

                    if (d21RuningInfo.RecentSmallTrendSingal == null)
                        throw new BusinessException("缺少小趋势,终止多交叉信号执行");

                    if (d21RuningInfo.RecentSmallTrendSingal == Enums.SingalType.小趋势看空)
                    {
                        var errorTimeStamp = DateTime.Now.GetKID(singalRequest.KLinePeriodic, false);
                        Thread.Sleep(5000); //防止多交叉和小趋势看多同时接收造成误判
                        d21RuningInfo = RedisHelper.Get<D21RuningInfo>(robot.Id.ToString()) ?? new D21RuningInfo() { RobotId = robot.Id };
                        if (d21RuningInfo.RecentSmallTrendSingal == Enums.SingalType.小趋势看空)
                        {
                            d21RuningInfo.ErrorCrossSingal = singalRequest.SingalType;
                            d21RuningInfo.ErrorCrossSingalTime = errorTimeStamp;
                            RedisHelper.Set(robot.Id.ToString(), d21RuningInfo);
                            throw new BusinessException("小趋势看空,终止多交叉信号执行");
                        }
                    }
                }
                #endregion

                #region 限制追高
                var d21Robot = robot as D21PolicyRobotResponse;
                var newestPrice = globalContext.GetSpotNewestPrice(robot.KLineKey) ?? singalRequest.ClosePrice;

                step = "限制追高";
                if (d21RuningInfo.RecentShortCrossSignalTradePrice != null && newestPrice > d21RuningInfo.RecentShortCrossSignalTradePrice)
                {
                    var diffRatio = Math.Round((newestPrice / d21RuningInfo.RecentShortCrossSignalTradePrice.Value - 1) * 100, 2);
                    if (diffRatio > d21Robot.D21Policy.MaxFollowPurchaseRatio)
                    {
                        throw new BusinessException($"触发追高限制,最近空交叉成交价{d21RuningInfo.RecentShortCrossSignalTradePrice},当前价格{newestPrice},最大追高比例{d21Robot.D21Policy.MaxFollowPurchaseRatio}%,当前追高比例{diffRatio}%,终止多交叉信号执行");
                    }
                }
                #endregion

                #region 获取账户余额
                step = "获取账户余额";
                var apiClient = GetBaseAPIClient(robot.ExchangeId, robot.ExchangeAPIKey.AccountId, robot.ExchangeAPIKey.APIKey, robot.ExchangeAPIKey.SecretKey);
                //逐仓杠杆账户余额
                var balance = apiClient.GetIsolatedMarginAccountAssets().FirstOrDefault(m => m.Symbol == robot.Symbol)?.QuoteFree ?? 0M;
                if (balance == 0M)
                    throw new BusinessException("可用资产为0");
                #endregion

                #region 计算下单数量
                step = "计算下单数量";
                var diffAmount = 0M;  //下单缺口金额
                var previewTradeAmount = d21Robot.D21Policy.Position; //预估交易额
                if (balance < previewTradeAmount)
                {
                    #region 借币
                    step = "借币";
                    diffAmount = previewTradeAmount - balance;
                    var diffRatio = diffAmount / balance * 100;     //借币比例

                    #region 验证策略中的最大借币比例
                    if (diffRatio > d21Robot.D21Policy.MaxExchangeLoanRatio)
                    {
                        logList.Add(new ExecutionLog()
                        {
                            Id = idGenerator.NewLong(),
                            SourceSingal = Enums.SingalType.多交叉,
                            RobotId = robot.Id,
                            CreateTime = DateTime.Now,
                            Content = $"触发策略中交易所最大借币比例限制,交易所最大借币比例{d21Robot.D21Policy.MaxExchangeLoanRatio}%,当前借币比例{diffRatio}%,按交易所最大借币比例借币"
                        });
                        diffAmount = previewTradeAmount * (d21Robot.D21Policy.MaxExchangeLoanRatio / 100M);
                        //previewTradeAmount = balance + diffAmount; //在策略允许的借币比例范围内的最大下单金额
                    }
                    #endregion

                    #region 验证交易所的最大可借额度
                    try
                    {
                        var exchangeMaxLoanAmount = apiClient.QueryMaxLoanAmount(robot.Symbol);
                        if (exchangeMaxLoanAmount < diffAmount)
                        {
                            if (exchangeMaxLoanAmount == 0M)
                                throw new Exception("可借额度为0");
                            diffAmount = exchangeMaxLoanAmount;
                        }
                        previewTradeAmount = balance + diffAmount;
                    }
                    catch (Exception borrowex)
                    {
                        logList.Add(new ExecutionLog()
                        {
                            Id = idGenerator.NewLong(),
                            SourceSingal = Enums.SingalType.多交叉,
                            RobotId = robot.Id,
                            CreateTime = DateTime.Now,
                            Content = $"验证交易所的最大可借额度失败 {borrowex.Message}"
                        });
                        previewTradeAmount = balance;  //无法借币,使用余额下单
                        diffAmount = 0M;
                    }
                    #endregion

                    #endregion
                }
                #endregion

                #region 借币
                if (diffAmount > 0M)
                {

                }
                #endregion

                #region 下单

                #endregion

            }
            catch (Exception ex)
            {
                logList.Add(new ExecutionLog()
                {
                    Id = idGenerator.NewLong(),
                    SourceSingal = Enums.SingalType.多交叉,
                    RobotId = robot.Id,
                    CreateTime = DateTime.Now,
                    Content = ex.Message
                });
                try { fsql.Insert(logList).ExecuteAffrows(); } catch { }
                var errorMsg = $"交易警报 {robot.ExecuteLogKey} {robot.Id} {step}";
                logManager.GetLogger(robot.ExecuteLogKey).Error(ex, errorMsg);
                dingBusiness.Send($"{errorMsg} {ex.Message}");
            }
        }

        public void ShortCross<T, T1>(T singalRequest, T1 robot, bool isRemedy) where T : BaseSingalRequest where T1 : RobotResponse
        {

        }
    }
}