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

        public 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-30 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++) //卡类型
                {
                    int PageNum = 1;
                    bool op = true;
                    while(op)
                    {
                        function.WriteLog("BrandId:" + i + ",BankCardType:" + j + ",Date:" + Date + ",PageNum:" + PageNum, "分润监控日志");
                        List<ProfitResult> result = StartProftForPosByDate(i, j, Date, PageNum);
                        function.WriteLog("result:" + result.Count, "分润监控日志");
                        function.WriteLog("\r\n", "分润监控日志");
                        if(result.Count > 0)
                        {
                            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();
                                }
                            }
                            PageNum += 1;
                        }
                        else
                        {
                            op = false;
                        }
                    }
                }
            }
            db.Dispose();
        }
        public List<ProfitResult> StartProftForPosByDate(int BrandId, int BankCardType, string Date, int PageNum = 1)
        {
            // 级差
            /*   
                
                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

            */

            int PageSize = 20;
            int SkipNum = (PageNum - 1) * PageSize;
            string LimitString = " limit " + PageSize;
            if(PageNum > 1)
            {
                LimitString = " limit " + SkipNum + "," + PageSize;
            }
            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                string sqlstr = "";
                if (BankCardType == 1)
                {
                    sqlstr = "select UserId,QueryCount,sum(HelpDirectTradeAmt),sum(NotHelpDirectTradeAmt) from TradeDaySummary where TradeDate='" + Date + "' and SeoTitle='self' and BrandId=" + BrandId + " group by UserId,QueryCount having sum(HelpDirectTradeAmt)>0 or sum(NotHelpDirectTradeAmt)>0 order by UserId" + LimitString;
                }
                if (BankCardType == 0)
                {
                    sqlstr = "select UserId,QueryCount,sum(HelpDirectDebitTradeAmt),sum(NotHelpDirectDebitTradeAmt),sum(HelpDirectDebitCapTradeAmt),sum(NotHelpDirectDebitCapTradeAmt),sum(HelpDirectDebitCapNum),sum(NotHelpDirectDebitCapNum) from TradeDaySummary where TradeDate='" + Date + "' and SeoTitle='self' and BrandId=" + BrandId + " group by UserId,QueryCount having sum(HelpDirectDebitTradeAmt)>0 or sum(NotHelpDirectDebitTradeAmt)>0 or sum(HelpDirectDebitCapTradeAmt)>0 or sum(NotHelpDirectDebitCapTradeAmt)>0 order by UserId" + LimitString;
                }
                function.WriteLog(sqlstr, "分润监控日志");
                DataTable dt = dbconn.dtable(sqlstr);
                function.WriteLog(dt.Rows.Count.ToString(), "分润监控日志");
                if(dt.Rows.Count > 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,";
                                }
                                function.WriteLog(ParentNav, "分润监控日志");
                                if (!string.IsNullOrEmpty(ParentNav))
                                {
                                    ParentNav += "," + UserId + ",";
                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    Array.Reverse(ParentNavList); //反转顺序
                                    int level = 0;
                                    DateTime now = DateTime.Now;
                                    if (HelpDirectTradeAmt > 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, 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,
                                                            BrandId = BrandId,
                                                            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;
                                        }
                                    }
                                    if (NotHelpDirectTradeAmt > 0)
                                    {
                                        level = 0;
                                        curLevel = 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,
                                                            BrandId = BrandId,
                                                            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

    }
}