kxs-main/AppStart/Helper/Profit/ProfitHelperV2.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using MySystem.PxcModels;
using Library;
using System.Threading;
using Microsoft.Extensions.Hosting;
using System.Threading.Tasks;

namespace MySystem
{
    public class ProfitHelperV2
    {
        public readonly static ProfitHelperV2 Instance = new ProfitHelperV2();
        private ProfitHelperV2()
        {
        }
        
        #region 获取分润规则Id

        private int GetLevelKindId(int BrandId, int Help, int BankCardType)
        {
            return RedisDbconn.Instance.Get<int>("pobjlv:kid:" + BrandId + ":" + Help + ":" + BankCardType);
        }

        #endregion
        
        #region POS分润算法
        public void StatProfit()
        {
            Thread th = new Thread(StatProfitDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatProfitDo()
        {
            DateTime end = DateTime.Parse("2022-06-25 00:00:00");
            DateTime check = DateTime.Parse("2022-06-01");
            while (check <= end)
            {
                StatProfitEveryDay(check.ToString("yyyyMMdd"));
                check = check.AddDays(1);
            }
        }
        public void StatProfitEveryDay(object sender)
        {
            string Date = sender.ToString();
            string Month = Date.Substring(0, 6);
            string check = function.ReadInstance("/ProfitStat/" + Date + ".txt");
            if (!string.IsNullOrEmpty(check))
            {
                return;
            }
            function.WritePage("/ProfitStat/", Date + ".txt", DateTime.Now.ToString());
            WebCMSEntities db = new WebCMSEntities();
            for (int i = 1; i <= 7; i++) //品牌
            {
                for (int j = 0; j <= 1; j++) //卡类型
                {
                    List<ProfitResult> result = StartProftForPosByDate(i, j, Date);
                    foreach (ProfitResult sub in result)
                    {
                        int TopUserId = 0;
                        if (!string.IsNullOrEmpty(sub.UserNav))
                        {
                            string[] UserNavList = sub.UserNav.Trim(',').Replace(",,", ",").Split(',');
                            if (UserNavList.Length > 1)
                            {
                                TopUserId = int.Parse(UserNavList[1]);
                            }
                            else
                            {
                                TopUserId = int.Parse(UserNavList[0]);
                            }
                        }
                        string RecordNo = "P" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
                        decimal ProfitAmt = sub.Money;
                        decimal TradeAmt = sub.TradeAmount;
                        decimal ProfitRate = sub.ProfitRate;
                        if (sub.IsSubsidy == 1 && j == 1)
                        {
                            decimal CreditTradeAmt = TradeAmt; //商户贷记卡交易总金额
                            decimal QrCreditTradeAmt = 0; //商户(云闪付)贷记卡交易总金额
                            decimal NonQrCreditTradeAmt = 0; //商户(非云闪付)贷记卡交易总金额
                            decimal CreditProfitRate = 0; //(非云闪付)贷记卡交易分润比例
                            decimal SubsidyProfit = 0; //商户(非云闪付)贷记卡交易分润补贴金额
                            if (sub.QrPayFlag == 1)
                            {
                                QrCreditTradeAmt = TradeAmt; //商户(云闪付)贷记卡交易总金额
                            }
                            else
                            { 
                                NonQrCreditTradeAmt = TradeAmt; //商户(非云闪付)贷记卡交易总金额
                                CreditProfitRate = ProfitRate; //(非云闪付)贷记卡交易分润比例
                                SubsidyProfit = ProfitAmt; //商户(非云闪付)贷记卡交易分润补贴金额
                            }
                            MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == sub.PosSn) ?? new MachineForSnNo();
                            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo(); 
                            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.MerchantId) ?? new PosMerchantInfo();
                            db.ProfitSubsidyDetail.Add(new ProfitSubsidyDetail()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                RecordNo = RecordNo, //流水号
                                BrandId = sub.BrandId, //品牌
                                ProductName = RelationClass.GetKqProductBrandInfo(sub.BrandId), //产品名称
                                TradeMonth = Month, //交易月份
                                SeoTitle = Date,
                                MerchantId = sub.MerchantId, //商户
                                MerNo = merchant.KqMerNo, //渠道商户编号
                                SnNo = sub.PosSn, //渠道SN号
                                MerRegTime = pos.BindingTime, //渠道注册时间
                                MerStandardDate = merchant.MerStandardDate, //商户激活时间
                                BelongUserId = merchant.UserId, //商户归属人
                                MerHelpFlag = sub.HelpFlag == 1 ? 1u : 0u, //是否属于扶持周期内商户
                                SubsidyUserId = sub.UserId, //补贴人
                                SubsidyType = sub.DirectFlag, //分润补贴类型
                                SubsidyProfitRate = sub.Money, //创客活动期内直营商户分润万分之十
                                CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
                                QrCreditTradeAmt = QrCreditTradeAmt, //商户(云闪付)贷记卡交易总金额
                                NonQrCreditTradeAmt = NonQrCreditTradeAmt, //商户(非云闪付)贷记卡交易总金额
                                CreditProfitRate = CreditProfitRate, //(非云闪付)贷记卡交易分润比例
                                SubsidyProfit = SubsidyProfit, //商户(非云闪付)贷记卡交易分润补贴金额
                            });
                            db.SaveChanges();
                        }
                        else
                        {
                            decimal CreditTradeAmt = 0;
                            decimal CreditTradeProfit = 0;
                            decimal QrCreditTradeAmt = 0;
                            decimal QrCreditProfitRate = 0;
                            decimal QrCreditProfitStandardRate = 0;
                            decimal QrCreditAddOrSubRate = 0;
                            decimal QrCreditTradeProfit = 0;
                            decimal NonQrCreditTradeAmt = 0;
                            decimal NotHelpCreditTradeAmt = 0;
                            decimal NotHelpCreditTradeProfit = 0;
                            decimal NotHelpCreditProfitRate = 0;
                            decimal NotHelpCreditProfitStandardRate = 0;
                            decimal NotHelpCreditAddOrSubRate = 0;
                            decimal HelpCreditTradeAmt = 0;
                            decimal NonQrCreditTradeProfit = 0;
                            decimal HelpCreditTradeProfit = 0;
                            decimal HelpCreditProfitRate = 0;
                            decimal HelpCreditProfitStandardRate = 0;
                            decimal HelpCreditAddOrSubRate = 0;
                            decimal DebitNonCapTradeAmt = 0;
                            decimal DebitCapTradeAmt = 0;
                            decimal QrDebitNotCapTradeAmt = 0;
                            decimal NonQrDebitNotCapTradeAmt = 0;
                            decimal NotHelpDebitNonCapTradeAmt = 0;
                            decimal HelpDebitNonCapTradeAmt = 0;
                            decimal DebitNonTradeCapProfit = 0;
                            decimal QrDebitNonTradeCapProfit = 0;
                            decimal NonQrDebitNonTradeCapProfit = 0;
                            decimal NotHelpDebitNonTradeCapProfit = 0;
                            decimal HelpDebitNonTradeCapProfit = 0;
                            decimal DebitTradeCapProfit = 0;
                            decimal NotHelpDebitProfitRate = 0;
                            decimal NotHelpDebitProfitStandardRate = 0;
                            decimal NotHelpDebitAddOrSubRate = 0;
                            decimal HelpDebitProfitRate = 0;
                            decimal HelpDebitProfitStandardRate = 0;
                            decimal HelpDebitAddOrSubRate = 0;
                            decimal DebitCapSingleReward = 0;
                            decimal QrDebitProfitRate = 0;
                            decimal QrDebitProfitStandardRate = 0;
                            decimal QrDebitAddOrSubRate = 0;
                            if (j == 1)
                            {
                                CreditTradeAmt = TradeAmt; //贷记卡交易总金额
                                CreditTradeProfit = ProfitAmt; //贷记卡分润总金额
                                if (sub.QrPayFlag == 1)
                                {
                                    QrCreditTradeAmt = TradeAmt; //(云闪付)贷记卡交易总金额
                                    QrCreditProfitRate = ProfitRate; //(云闪付)贷记卡交易分润比例
                                    QrCreditTradeProfit = ProfitAmt; //(云闪付)贷记卡交易分润
                                }
                                else
                                {
                                    NonQrCreditTradeAmt = TradeAmt; //(非云闪付)贷记卡交易总金额
                                    NonQrCreditTradeProfit = ProfitAmt; //(非云闪付)贷记卡交易分润
                                    if(sub.HelpFlag == 1)
                                    {
                                        HelpCreditTradeProfit = ProfitAmt; //(扶持期)(非云闪付)贷记卡分润总金额
                                        HelpCreditProfitRate = ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                        HelpCreditTradeAmt = TradeAmt; //(扶持期)(非云闪付)贷记卡交易总金额
                                    }
                                    else
                                    {
                                        NotHelpCreditTradeAmt = TradeAmt; //(非扶持期)(非云闪付)贷记卡交易总金额
                                        NotHelpCreditTradeProfit = ProfitAmt; //(非扶持期)(非云闪付)贷记卡分润总金额
                                        NotHelpCreditProfitRate = ProfitRate; //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                    }
                                }
                            }
                            if (j == 0)
                            {
                                if (sub.Money < 1)
                                {
                                    DebitNonCapTradeAmt = TradeAmt; //商户非封顶借记卡交易总额
                                    DebitNonTradeCapProfit = ProfitAmt; //借记卡非封顶交易分润总金额
                                }
                                else
                                {
                                    DebitCapTradeAmt = TradeAmt; //商户借记卡封顶交易总额
                                    DebitCapSingleReward = ProfitAmt; //借记卡合伙人直营封顶交易奖励金额
                                    DebitTradeCapProfit = ProfitAmt; //借记卡封顶交易分润总金额
                                }
                                if (sub.QrPayFlag == 1)
                                {
                                    if (sub.Money < 1)
                                    {
                                        QrDebitNotCapTradeAmt = TradeAmt; //(云闪付)商户非封顶借记卡交易总额
                                        QrDebitProfitRate = ProfitRate; //(云闪付)借记卡非封顶交易分润比例
                                        QrDebitNonTradeCapProfit = ProfitAmt; //(云闪付)借记卡非封顶交易分润总金额
                                    }
                                }
                                else
                                {
                                    if (sub.Money < 1)
                                    {
                                        NonQrDebitNonTradeCapProfit = ProfitAmt; //(非云闪付)借记卡非封顶交易分润总金额
                                        NonQrDebitNotCapTradeAmt = TradeAmt; //(非云闪付)商户非封顶借记卡交易总额
                                    }
                                    if (sub.HelpFlag == 1)
                                    {
                                        if (sub.Money < 1)
                                        {
                                            HelpDebitNonCapTradeAmt = TradeAmt; //(扶持期)(非云闪付)借记卡非封顶交易总金额
                                            HelpDebitNonTradeCapProfit = ProfitAmt; //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                        }
                                        HelpDebitProfitRate = ProfitRate; //(扶持期)(非云闪付)借记卡商户交易对应分润比例
                                    }
                                    else
                                    {
                                        if (sub.Money < 1)
                                        {
                                            NotHelpDebitNonCapTradeAmt = TradeAmt; //(非扶持期)(非云闪付)借记卡非封顶交易总金额
                                            NotHelpDebitNonTradeCapProfit = ProfitAmt; //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                        }
                                        NotHelpDebitProfitRate = ProfitRate; //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
                                    }
                                }
                            }
                            db.ProfitRewardRecord.Add(new ProfitRewardRecord()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = sub.UserId, //创客
                                MerchantId = sub.MerchantId, //商户
                                BrandId = sub.BrandId, //品牌
                                ProfitType = sub.DirectFlag, //创客分润类型
                                TradeAmt = sub.TradeAmount, //商户交易总额
                                TradeProfit = sub.Money, //交易分润
                                TradeMonth = Month, //交易月
                                SeoTitle = Date,
                                RecordNo = RecordNo, //记录单号
                                TopUserId = TopUserId, //顶级创客
                                CreditTradeAmt = CreditTradeAmt, //贷记卡交易总金额
                                QrCreditTradeAmt = QrCreditTradeAmt, //(云闪付)贷记卡交易总金额
                                NonQrCreditTradeAmt = NonQrCreditTradeAmt, //(非云闪付)贷记卡交易总金额
                                NotHelpCreditTradeAmt = NotHelpCreditTradeAmt, //(非扶持期)(非云闪付)贷记卡交易总金额
                                HelpCreditTradeAmt = HelpCreditTradeAmt, //(扶持期)(非云闪付)贷记卡交易总金额
                                DebitNonCapTradeAmt = DebitNonCapTradeAmt, //商户非封顶借记卡交易总额
                                QrDebitNotCapTradeAmt = QrDebitNotCapTradeAmt, //(云闪付)商户非封顶借记卡交易总额
                                NonQrDebitNotCapTradeAmt = NonQrDebitNotCapTradeAmt, //(非云闪付)商户非封顶借记卡交易总额
                                NotHelpDebitNonCapTradeAmt = NotHelpDebitNonCapTradeAmt, //(非扶持期)(非云闪付)借记卡非封顶交易总金额
                                HelpDebitNonCapTradeAmt = HelpDebitNonCapTradeAmt, //(扶持期)(非云闪付)借记卡非封顶交易总金额
                                DebitCapTradeAmt = DebitCapTradeAmt, //商户借记卡封顶交易总额
                                CreditTradeProfit = CreditTradeProfit, //贷记卡分润总金额
                                QrCreditTradeProfit = QrCreditTradeProfit, //(云闪付)贷记卡交易分润
                                NonQrCreditTradeProfit = NonQrCreditTradeProfit, //(非云闪付)贷记卡交易分润
                                NotHelpCreditTradeProfit = NotHelpCreditTradeProfit, //(非扶持期)(非云闪付)贷记卡分润总金额
                                HelpCreditTradeProfit = HelpCreditTradeProfit, //(扶持期)(非云闪付)贷记卡分润总金额
                                DebitNonTradeCapProfit = DebitNonTradeCapProfit, //借记卡非封顶交易分润总金额
                                QrDebitNonTradeCapProfit = QrDebitNonTradeCapProfit, //(云闪付)借记卡非封顶交易分润总金额
                                NonQrDebitNonTradeCapProfit = NonQrDebitNonTradeCapProfit, //(非云闪付)借记卡非封顶交易分润总金额
                                NotHelpDebitNonTradeCapProfit = NotHelpDebitNonTradeCapProfit, //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                HelpDebitNonTradeCapProfit = HelpDebitNonTradeCapProfit, //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                DebitTradeCapProfit = DebitTradeCapProfit, //借记卡封顶交易分润总金额
                                NotHelpCreditProfitRate = NotHelpCreditProfitRate, //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                NotHelpCreditProfitStandardRate = NotHelpCreditProfitStandardRate, //(非扶持期)(非云闪付)贷记卡标准分润比例
                                NotHelpCreditAddOrSubRate = NotHelpCreditAddOrSubRate, //(非扶持期)(非云闪付)贷记卡成本或增或减比例
                                HelpCreditProfitRate = HelpCreditProfitRate, //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                HelpCreditProfitStandardRate = HelpCreditProfitStandardRate, //(扶持期)(非云闪付)贷记卡-标准分润比例
                                HelpCreditAddOrSubRate = HelpCreditAddOrSubRate, //(扶持期)(非云闪付)贷记卡成本或增或减比例
                                NotHelpDebitProfitRate = NotHelpDebitProfitRate, //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
                                NotHelpDebitProfitStandardRate = NotHelpDebitProfitStandardRate, //(非扶持期)(非云闪付)借记卡标准分润比例
                                NotHelpDebitAddOrSubRate = NotHelpDebitAddOrSubRate, //(非扶持期)(非云闪付)借记卡成本或增或减比例
                                HelpDebitProfitRate = HelpDebitProfitRate, //(扶持期)(非云闪付)借记卡商户交易对应分润比例
                                HelpDebitProfitStandardRate = HelpDebitProfitStandardRate, //(扶持期)(非云闪付)借记卡-标准分润比例
                                HelpDebitAddOrSubRate = HelpDebitAddOrSubRate, //(扶持期)(非云闪付)借记卡成本或增或减比例
                                DebitCapSingleReward = DebitCapSingleReward, //借记卡合伙人直营封顶交易奖励金额
                                QrCreditProfitRate = QrCreditProfitRate, //(云闪付)贷记卡交易分润比例
                                QrCreditProfitStandardRate = QrCreditProfitStandardRate, //(云闪付)贷记卡分润基准
                                QrCreditAddOrSubRate = QrCreditAddOrSubRate, //(云闪付)贷记卡分润比例或增或减
                                QrDebitProfitRate = QrDebitProfitRate, //(云闪付)借记卡非封顶交易分润比例
                                QrDebitProfitStandardRate = QrDebitProfitStandardRate, //(云闪付)借记卡非封顶交易分润基准
                                QrDebitAddOrSubRate = QrDebitAddOrSubRate, //(云闪付)借记卡非封顶交易分润比例或增或减
                            });
                            db.SaveChanges();
                        }
                    }
                }
            }
            db.Dispose();
        }
        public List<ProfitResult> StartProftForPosByDate(int BrandId, int BankCardType, string Date)
        {
            // 级差
            /*   
                
                K1 - K5：无大小市场要求，无押机分润比例为有押金机的70%，如K1的有押金机分润比例为万6，则无押机的分润比例为万4.2
                                      机具激活大于90天，分润比例为原比例的70%

                        if(is0y){
                            分润比例为原比例的70%
                        }
                        if(ActivityDate > now - 90){
                            分润比例为原比例的70%
                        }
                K6 - K9：
                    K6：至少有1个直推大于3000万，且总交易额减去3000万大于1200万，则获得分红奖（月月红）直接级差
                    K7：总交易额减去最大交易额的直推，大于4000万，则获得分红奖（月月红）直接级差
                    K8：总交易额减去最大交易额的直推，大于12000万，则获得分红奖（月月红）直接级差
                    K9：总交易额减去最大交易额的直推，大于32000万，则获得分红奖（月月红）直接级差

                补贴：
                    0押金无补贴
                    机具激活90天内，机具所属创客获得万10置顶
                    若创客为商户型创客，则机具UserId的创客获得万4分润

                    //查分润
                    select u.MakerCode,u.RealName,u.UserLevel,r.Rank,pos.SeoKeyword,p.KqSnNo,(case when ProfitType=1 then '直营' else '团队' end) as DirectFlag,
                    k.Name,CreditTradeAmt,CreditTradeProfit,DebitTradeAmt,DebitTradeProfit,QrCreditTradeAmt,QrCreditTradeProfit from (
                    select UserId,ProfitType,BrandId,MerchantId,
                    sum(CreditTradeAmt) as CreditTradeAmt,
                    sum(CreditTradeProfit) as CreditTradeProfit,
                    sum(DebitNonCapTradeAmt+DebitCapTradeAmt) as DebitTradeAmt,
                    sum(DebitNonTradeCapProfit+DebitTradeCapProfit) as DebitTradeProfit,
                    sum(QrCreditTradeAmt) as QrCreditTradeAmt,
                    sum(QrCreditTradeProfit) as QrCreditTradeProfit
                    from ProfitRewardRecord where MerchantId>0
                    GROUP BY UserId,ProfitType,BrandId,MerchantId
                    ) tb 
                    left join Users u on tb.UserId=u.Id 
                    LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
                    left join PosMerchantInfo p on tb.MerchantId=p.Id 
                    left join MachineForSnNo fp on fp.SnNo=p.KqSnNo 
                    left join PosMachinesTwo pos on pos.Id=fp.SnId 
                    left join UserRankWhite r on u.Id=r.Id 
                    ORDER BY p.KqSnNo,u.MakerCode

                    //查补贴
                    select u.MakerCode,u.RealName,u.UserLevel,r.Rank,m.KqSnNo,m.MerchantName,(case when SubsidyType=1 then '直营' else '团队' end) as DirectFlag,
                    k.Name,CreditTradeAmt,SubsidyProfit from (
                    select SubsidyUserId,MerchantId,BrandId,SubsidyType,
                    sum(CreditTradeAmt) as CreditTradeAmt,
                    sum(SubsidyProfitRate) as SubsidyProfit
                    from ProfitSubsidyDetail 
                    GROUP BY SubsidyUserId,MerchantId,BrandId,SubsidyType
                    ) tb 
                    left join Users u on tb.SubsidyUserId=u.Id 
                    LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
                    left join PosMerchantInfo m on tb.MerchantId=m.Id 
                    left join UserRankWhite r on u.Id=r.Id 

                    // TODO:做到后台查询，换绑机器遗漏交易额补差
                    select UserId,sum(TradeAmount) from TradeRecord where SnNo in (
                    select PosSn from PosMachinesTwo where UserId=0 and BuyUserId=0 and CreditTrade>0
                    ) and CreateDate>='2022-04-01 00:00:00' and CreateDate<'2022-05-01 00:00:00' and UserId>0 group by UserId

            */


            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                DataTable dt = new DataTable();
                if (BankCardType == 1)
                {
                    dt = dbconn.dtable("select UserId,QueryCount,sum(HelpDirectTradeAmt),sum(NotHelpDirectTradeAmt) from TradeDaySummary where TradeDate='" + Date + "' and BrandId=" + BrandId + " group by UserId,QueryCount having sum(HelpDirectTradeAmt)>0 or sum(NotHelpDirectTradeAmt)>0");
                }
                if (BankCardType == 0)
                {
                    dt = dbconn.dtable("select UserId,QueryCount,sum(HelpDirectDebitTradeAmt),sum(NotHelpDirectDebitTradeAmt),sum(HelpDirectDebitCapTradeAmt),sum(NotHelpDirectDebitCapTradeAmt),sum(HelpDirectDebitCapNum),sum(NotHelpDirectDebitCapNum) from TradeDaySummary where TradeDate='" + Date + "' and BrandId=" + BrandId + " group by UserId,QueryCount having sum(HelpDirectDebitTradeAmt)>0 or sum(NotHelpDirectDebitTradeAmt)>0 or sum(HelpDirectDebitCapTradeAmt)>0 or sum(NotHelpDirectDebitCapTradeAmt)>0;");
                }
                foreach (DataRow dr in dt.Rows)
                {
                    WebCMSEntities dbnew = new WebCMSEntities();
                    try
                    {
                        int UserId = int.Parse(dr["UserId"].ToString());
                        int QrPayFlag = int.Parse(dr["QueryCount"].ToString());
                        List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
                        Users selfUser = dbnew.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                        int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
                        if (BankCardType == 0)
                        {
                            decimal HelpDirectDebitTradeAmt = decimal.Parse(dr[2].ToString()); //借记卡扶持期交易额
                            decimal NotHelpDirectDebitTradeAmt = decimal.Parse(dr[3].ToString()); //借记卡稳定期交易额
                            decimal HelpDirectDebitCapTradeAmt = decimal.Parse(dr[4].ToString()); //借记卡扶持期封顶交易额
                            decimal NotHelpDirectDebitCapTradeAmt = decimal.Parse(dr[5].ToString()); //借记卡稳定期封顶交易额
                            int HelpDirectDebitCapNum = int.Parse(dr[6].ToString().Split('.')[0]); //借记卡扶持期封顶交易笔数
                            int NotHelpDirectDebitCapNum = int.Parse(dr[7].ToString()); //借记卡稳定期封顶交易笔数
                            int UserLevel = selfUser.UserLevel; //当前会员等级
                            // int LevelKindId = GetLevelKindId(BrandId, HelpTime, 0);
                            // ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                            decimal getLevelProfit = (HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt - HelpDirectDebitCapTradeAmt - NotHelpDirectDebitCapTradeAmt) * 0.0006M + HelpDirectDebitCapNum + NotHelpDirectDebitCapNum;
                            result.Add(new ProfitResult()
                            {
                                UserId = selfUser.Id,
                                UserNav = selfUser.ParentNav,
                                Money = PublicFunction.NumberFormat(getLevelProfit),
                                ProfitRate = 0.0006M,
                                Message = "储蓄卡分润",
                                BankCardType = BankCardType,
                                QrPayFlag = QrPayFlag,
                                BrandId = BrandId,
                                DirectFlag = 1,
                                IsSubsidy = 0,
                                TradeAmount = HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt,
                            });
                        }
                        else
                        {
                            decimal HelpDirectTradeAmt = decimal.Parse(dr[2].ToString()); //贷记卡扶持期交易额
                            decimal NotHelpDirectTradeAmt = decimal.Parse(dr[3].ToString()); //贷记卡稳定期交易额
                            int maxLevel = obj.MaxLevel; //最大等级
                            decimal diffLevelProfit = 0;  //等级级差
                            int curLevel = 0; //当前层级的会员等级
                            string ParentNav = selfUser.ParentNav;
                            if (string.IsNullOrEmpty(ParentNav))
                            {
                                ParentNav = ",0,";
                            }
                            if (!string.IsNullOrEmpty(ParentNav))
                            {
                                ParentNav += "," + UserId + ",";
                                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                Array.Reverse(ParentNavList); //反转顺序
                                int level = 0;
                                DateTime now = DateTime.Now;
                                foreach (string UserIdString in ParentNavList)
                                {
                                    level += 1;
                                    int uid = int.Parse(UserIdString);
                                    Users user = dbnew.Users.FirstOrDefault(m => m.Id == uid) ?? new Users();
                                    int UserLevel = user.UserLevel; //当前会员等级
                                    UserRankWhite rank = dbnew.UserRankWhite.FirstOrDefault(m => m.Id == user.Id && m.UpdateDate > now);
                                    if (rank != null)
                                    {
                                        if (rank.Rank > UserLevel)
                                        {
                                            UserLevel = rank.Rank;
                                        }
                                    }
                                    if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                    {
                                        break;
                                    }
                                    if (UserLevel <= maxLevel && UserLevel > curLevel)
                                    {
                                        int LevelKindId = GetLevelKindId(BrandId, 1, 1);
                                        ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                        if (objlevel != null)
                                        {
                                            decimal getLevelProfit = 0;  //等级分润
                                            if (objlevel.Percents > 0)
                                            {
                                                //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                                getLevelProfit += HelpDirectTradeAmt * objlevel.Percents;
                                            }
                                            if (objlevel.AddProfitVal > 0)
                                            {
                                                getLevelProfit += objlevel.AddProfitVal;
                                            }
                                            decimal money = getLevelProfit;
                                            getLevelProfit -= diffLevelProfit;
                                            if (objlevel.LevelDiff == 1)  //判断是否有级差
                                            {
                                                diffLevelProfit = money;
                                            }
                                            if (getLevelProfit >= obj.MinProfitVal)
                                            {
                                                result.Add(new ProfitResult()
                                                {
                                                    UserId = user.Id,
                                                    UserNav = user.ParentNav,
                                                    Money = PublicFunction.NumberFormat(getLevelProfit),
                                                    ProfitRate = objlevel.Percents,
                                                    Message = "交易分润",
                                                    BankCardType = BankCardType,
                                                    QrPayFlag = QrPayFlag,
                                                    DirectFlag = selfUser.Id == user.Id ? 1 : 0,
                                                    IsSubsidy = 0,
                                                    TradeAmount = HelpDirectTradeAmt,
                                                    HelpFlag = 1,
                                                });
                                            }

                                            // 分润补贴
                                            if (level == 1)
                                            {
                                                int SubsidyUserId = selfUser.ParentUserId; // TODO: 确定是否100%是上级
                                                Users subuser = dbnew.Users.FirstOrDefault(m => m.Id == SubsidyUserId) ?? new Users();
                                                int subUserLevel = subuser.UserLevel;
                                                if(subUserLevel < 5)
                                                {
                                                    UserRankWhite subrank = dbnew.UserRankWhite.FirstOrDefault(m => m.Id == subuser.Id && m.UpdateDate > now);
                                                    if (subrank != null)
                                                    {
                                                        if (subrank.Rank > subUserLevel)
                                                        {
                                                            subUserLevel = subrank.Rank;
                                                        }
                                                    }
                                                    if(subUserLevel < 5)
                                                    {
                                                        ProfitObjectLevels sublevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + subUserLevel); //获取当前等级参数
                                                        if (sublevel != null)
                                                        {
                                                            decimal otherPercent = 0.001M - sublevel.Percents;
                                                            decimal otherMoney = HelpDirectTradeAmt * otherPercent;
                                                            if (otherMoney >= obj.MinProfitVal)
                                                            {
                                                                result.Add(new ProfitResult()
                                                                {
                                                                    UserId = subuser.Id,
                                                                    UserNav = subuser.ParentNav,
                                                                    Money = PublicFunction.NumberFormat(otherMoney),
                                                                    ProfitRate = otherPercent,
                                                                    Message = "分润补贴",
                                                                    BankCardType = BankCardType,
                                                                    QrPayFlag = QrPayFlag,
                                                                    DirectFlag = 1,
                                                                    BrandId = BrandId,
                                                                    IsSubsidy = 1,
                                                                    TradeAmount = HelpDirectTradeAmt,
                                                                    HelpFlag = 1,
                                                                });
                                                            }
                                                        }
                                                    }
                                                }
                                            }
                                        }
                                    }
                                    curLevel = UserLevel;
                                }
                                level = 0;
                                foreach (string UserIdString in ParentNavList)
                                {
                                    level += 1;
                                    int uid = int.Parse(UserIdString);
                                    Users user = dbnew.Users.FirstOrDefault(m => m.Id == uid) ?? new Users();
                                    int UserLevel = user.UserLevel; //当前会员等级
                                    UserRankWhite rank = dbnew.UserRankWhite.FirstOrDefault(m => m.Id == user.Id && m.UpdateDate > now);
                                    if (rank != null)
                                    {
                                        if (rank.Rank > UserLevel)
                                        {
                                            UserLevel = rank.Rank;
                                        }
                                    }
                                    if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                    {
                                        break;
                                    }
                                    if (UserLevel <= maxLevel && UserLevel > curLevel)
                                    {
                                        int LevelKindId = GetLevelKindId(BrandId, 0, 1);
                                        ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                        if (objlevel != null)
                                        {
                                            decimal getLevelProfit = 0;  //等级分润
                                            if (objlevel.Percents > 0)
                                            {
                                                //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                                getLevelProfit += NotHelpDirectTradeAmt * objlevel.Percents;
                                            }
                                            if (objlevel.AddProfitVal > 0)
                                            {
                                                getLevelProfit += objlevel.AddProfitVal;
                                            }
                                            decimal money = getLevelProfit;
                                            getLevelProfit -= diffLevelProfit;
                                            if (objlevel.LevelDiff == 1)  //判断是否有级差
                                            {
                                                diffLevelProfit = money;
                                            }
                                            if (getLevelProfit >= obj.MinProfitVal)
                                            {
                                                result.Add(new ProfitResult()
                                                {
                                                    UserId = user.Id,
                                                    UserNav = user.ParentNav,
                                                    Money = PublicFunction.NumberFormat(getLevelProfit),
                                                    ProfitRate = objlevel.Percents,
                                                    Message = "交易分润",
                                                    BankCardType = BankCardType,
                                                    QrPayFlag = QrPayFlag,
                                                    DirectFlag = selfUser.Id == user.Id ? 1 : 0,
                                                    IsSubsidy = 0,
                                                    TradeAmount = NotHelpDirectTradeAmt,
                                                    HelpFlag = 0,
                                                });
                                            }
                                        }
                                    }
                                    curLevel = UserLevel;
                                }
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
                    }
                    dbnew.Dispose();
                }
            }
            return result;
        }
        #endregion

    }
}