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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using MySystem.Models;
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()
        {
            while (true)
            {
                string content = RedisDbconn.Instance.RPop<string>("DoProfitQueue");
                if(!string.IsNullOrEmpty(content) && DateTime.Now.Day < 15)
                {
                    StatProfiting();
                }
                else
                {
                    Thread.Sleep(60000);
                }
            }
        }
        public void StatProfiting()
        {
            string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            string check = function.ReadInstance("/ProfitStat/" + Month + "-1.txt");
            if (!string.IsNullOrEmpty(check))
            {
                return;
            }
            function.WritePage("/ProfitStat/", Month + "-1.txt", DateTime.Now.ToString());
            try
            {
                WebCMSEntities db = new WebCMSEntities();
                for (int i = 1; i <= 9; i++) //品牌
                {
                    for (int j = 0; j <= 1; j++) //卡类型
                    {
                        int PageNum = 1;
                        bool op = true;
                        while(op)
                        {
                            LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + "BrandId:" + i + ",BankCardType:" + j + ",Month:" + Month + ",PageNum:" + PageNum, "分润监控日志");
                            List<ProfitResult> result = StartProftForPosByDate(i, j, Month, PageNum);
                            LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + "result:" + result.Count, "分润监控日志");
                            LogHelper.Instance.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)
                                    {
                                    }
                                    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;
                                        decimal ProfitCreditTradeProfit = 0;
                                        decimal ProfitCreditProfitRate = 0;
                                        decimal ProfitCreditTradeAmt = 0;
                                        decimal ProfitDebitNonCapTradeAmt = 0;
                                        decimal ProfitDebitNonTradeCapProfit = 0;
                                        decimal ProfitDebitProfitRate = 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 if(sub.HelpFlag == 2)
                                                {
                                                    ProfitCreditTradeProfit = ProfitAmt; //(扶持期)(非云闪付)贷记卡分润总金额
                                                    ProfitCreditProfitRate = ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                                    ProfitCreditTradeAmt = 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.HelpFlag == 2)
                                                {
                                                    if (sub.Money < 1)
                                                    {
                                                        ProfitDebitNonCapTradeAmt = TradeAmt; //(盈利期)(非云闪付)借记卡非封顶交易总金额
                                                        ProfitDebitNonTradeCapProfit = ProfitAmt; //(盈利期)(非云闪付)借记卡非封顶交易分润总金额
                                                    }
                                                    ProfitDebitProfitRate = 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, //交易月
                                            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, //(云闪付)借记卡非封顶交易分润比例或增或减
                                            ProfitCreditTradeProfit = ProfitCreditTradeProfit,  //(盈利期)(非云闪付)贷记卡分润总金额
                                            ProfitCreditProfitRate = ProfitCreditProfitRate, //(盈利期)(非云闪付)贷记卡商户交易对应分润比例
                                            ProfitCreditTradeAmt = ProfitCreditTradeAmt, //(盈利期)(非云闪付)贷记卡交易总金额
                                            ProfitDebitNonCapTradeAmt = ProfitDebitNonCapTradeAmt, //(盈利期)(非云闪付)借记卡非封顶交易总金额
                                            ProfitDebitNonTradeCapProfit = ProfitDebitNonTradeCapProfit, //(盈利期)(非云闪付)借记卡非封顶交易分润总金额
                                            ProfitDebitProfitRate = ProfitDebitProfitRate, //(盈利期)(非云闪付)借记卡商户交易对应分润比例
                                        });
                                        // db.SaveChanges();
                                    }
                                }
                                db.SaveChanges();
                                PageNum += 1;
                            }
                            else
                            {
                                op = false;
                            }
                        }
                    }
                }
                db.Dispose();
            }
            catch(Exception ex)
            {
                LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "分润监控异常");
            }

            ProfitHelper.Instance.StatProfit();
        }
        public List<ProfitResult> StartProftForPosByDate(int BrandId, int BankCardType, string Month, 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,(case when ProfitType=1 then '直营' else '团队' end) as DirectFlag,
                    k.Name,CreditTradeAmt,CreditTradeProfit,QrCreditTradeAmt,QrCreditTradeProfit,NonQrCreditTradeAmt,NonQrCreditTradeProfit,HelpCreditTradeAmt,HelpCreditTradeProfit,NotHelpCreditTradeAmt,NotHelpCreditTradeProfit,DebitTradeAmt,DebitTradeProfit from (
                    select UserId,ProfitType,BrandId,
                    sum(CreditTradeAmt) as CreditTradeAmt,
                    sum(CreditTradeProfit) as CreditTradeProfit,
                    sum(QrCreditTradeAmt) as QrCreditTradeAmt,
                    sum(QrCreditTradeProfit) as QrCreditTradeProfit,
                    sum(NonQrCreditTradeAmt) as NonQrCreditTradeAmt,
                    sum(NonQrCreditTradeProfit) as NonQrCreditTradeProfit,
                    sum(HelpCreditTradeAmt) as HelpCreditTradeAmt,
                    sum(HelpCreditTradeProfit) as HelpCreditTradeProfit,
                    sum(NotHelpCreditTradeAmt) as NotHelpCreditTradeAmt,
                    sum(NotHelpCreditTradeProfit) as NotHelpCreditTradeProfit,
                    sum(DebitNonCapTradeAmt+DebitCapTradeAmt) as DebitTradeAmt,
                    sum(DebitNonTradeCapProfit+DebitTradeCapProfit) as DebitTradeProfit 
                    from ProfitRewardRecord where TradeMonth='202208' 
                    GROUP BY UserId,ProfitType,BrandId
                    ) tb 
                    left join Users u on tb.UserId=u.Id 
                    LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
                    left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00' 
                    ORDER BY u.MakerCode

                    //查补贴
                    select u.MakerCode,u.RealName,u.UserLevel,r.Rank,(case when SubsidyType=1 then '直营' else '团队' end) as DirectFlag,
                    k.Name,CreditTradeAmt,SubsidyProfit from (
                    select SubsidyUserId,BrandId,SubsidyType,
                    sum(CreditTradeAmt) as CreditTradeAmt,
                    sum(SubsidyProfitRate) as SubsidyProfit
                    from ProfitSubsidyDetail where TradeMonth='202206' 
                    GROUP BY SubsidyUserId,BrandId,SubsidyType
                    ) tb 
                    left join Users u on tb.SubsidyUserId=u.Id 
                    LEFT JOIN KqProducts k ON k.Id=tb.BrandId 
                    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 = 200;
            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,QrPayFlag,HelpDirectTradeAmt,NotHelpDirectTradeAmt,ProfitDirectTradeAmt from CreditTradeDaySummary" + Month + " where BrandId=" + BrandId + LimitString;
                }
                if (BankCardType == 0)
                {
                    sqlstr = "select UserId,QrPayFlag,HelpDirectDebitTradeAmt,NotHelpDirectDebitTradeAmt,HelpDirectDebitCapTradeAmt,NotHelpDirectDebitCapTradeAmt,HelpDirectDebitCapNum,NotHelpDirectDebitCapNum,ProfitDirectDebitTradeAmt,ProfitDirectDebitCapTradeAmt,ProfitDirectDebitCapNum from DebitTradeDaySummary" + Month + " where BrandId=" + BrandId + LimitString;
                }
                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + sqlstr, "分润监控日志");
                DataTable dt = GetDataTable(sqlstr);
                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + 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["QrPayFlag"].ToString());
                            List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
                            SubUser selfUser = GetUser(UserId, Month) ?? new SubUser();
                            int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
                            if (BankCardType == 0)
                            {
                                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":借记卡", "分润监控日志");
                                decimal HelpDirectDebitTradeAmt = decimal.Parse(dr[2].ToString()); //借记卡扶持期交易额
                                decimal NotHelpDirectDebitTradeAmt = decimal.Parse(dr[3].ToString()); //借记卡稳定期交易额
                                decimal ProfitDirectDebitTradeAmt = decimal.Parse(dr[8].ToString()); //借记卡扶持期交易额
                                decimal HelpDirectDebitCapTradeAmt = decimal.Parse(dr[4].ToString()); //借记卡扶持期封顶交易额
                                decimal NotHelpDirectDebitCapTradeAmt = decimal.Parse(dr[5].ToString()); //借记卡稳定期封顶交易额
                                decimal ProfitDirectDebitCapTradeAmt = decimal.Parse(dr[9].ToString()); //借记卡扶持期封顶交易额
                                int HelpDirectDebitCapNum = int.Parse(dr[6].ToString().Split('.')[0]); //借记卡扶持期封顶交易笔数
                                int NotHelpDirectDebitCapNum = int.Parse(dr[7].ToString().Split('.')[0]); //借记卡稳定期封顶交易笔数
                                int ProfitDirectDebitCapNum = int.Parse(dr[10].ToString().Split('.')[0]); //借记卡扶持期封顶交易笔数
                                int UserLevel = selfUser.UserLevel; //当前会员等级
                                decimal getLevelProfit = (HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt - HelpDirectDebitCapTradeAmt - NotHelpDirectDebitCapTradeAmt - ProfitDirectDebitCapTradeAmt) * 0.0006M + HelpDirectDebitCapNum + NotHelpDirectDebitCapNum + ProfitDirectDebitCapNum;
                                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 + ProfitDirectDebitTradeAmt,
                                });
                            }
                            else
                            {
                                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":贷记卡", "分润监控日志");
                                decimal HelpDirectTradeAmt = decimal.Parse(dr[2].ToString()); //贷记卡扶持期交易额
                                decimal NotHelpDirectTradeAmt = decimal.Parse(dr[3].ToString()); //贷记卡稳定期交易额
                                decimal ProfitDirectTradeAmt = decimal.Parse(dr[4].ToString()); //贷记卡盈利期期交易额
                                int maxLevel = obj.MaxLevel; //最大等级
                                decimal diffLevelProfit = 0;  //等级级差
                                int curLevel = 0; //当前层级的会员等级
                                string ParentNav = selfUser.ParentNav;
                                if (string.IsNullOrEmpty(ParentNav))
                                {
                                    ParentNav = ",0,";
                                }
                                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + ParentNav, "分润监控日志");
                                if (!string.IsNullOrEmpty(ParentNav))
                                {
                                    ParentNav += "," + UserId + ",";
                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    Array.Reverse(ParentNavList); //反转顺序
                                    int level = 0;
                                    DateTime now = DateTime.Now;
                                    DateTime ThisMonth = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
                                    LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":扶持期:" + HelpDirectTradeAmt, "分润监控日志");
                                    if (HelpDirectTradeAmt > 0)
                                    {
                                        level = 0;
                                        curLevel = 0;
                                        diffLevelProfit = 0;  //等级级差
                                        decimal checkProfit = HelpDirectTradeAmt * 0.0012M;
                                        decimal curProfit = 0;
                                        foreach (string UserIdString in ParentNavList)
                                        {
                                            level += 1;
                                            int uid = int.Parse(UserIdString);
                                            SubUser user = GetUser(uid, Month) ?? new SubUser();
                                            int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
                                            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)
                                                    {
                                                        int DirectFlag = selfUser.Id == user.Id ? 1 : 0;
                                                        result.Add(new ProfitResult()
                                                        {
                                                            UserId = user.Id,
                                                            UserNav = user.ParentNav,
                                                            Money = PublicFunction.NumberFormat(getLevelProfit),
                                                            ProfitRate = objlevel.Percents,
                                                            Message = "交易分润",
                                                            BankCardType = BankCardType,
                                                            QrPayFlag = QrPayFlag,
                                                            DirectFlag = DirectFlag,
                                                            BrandId = BrandId,
                                                            IsSubsidy = 0,
                                                            TradeAmount = HelpDirectTradeAmt,
                                                            HelpFlag = 1,
                                                        });
                                                        curProfit += getLevelProfit;
                                                        LogHelper.Instance.WriteLog(user.Id + "-" + UserLevel + "-" + HelpDirectTradeAmt + "-" + DirectFlag + "-扶持期分润:" + getLevelProfit, "分润监控日志");
                                                    }
                                                }
                                            }
                                            if(curLevel < UserLevel)
                                            {
                                                curLevel = UserLevel;
                                            }
                                        }
                                        if(curProfit > checkProfit)
                                        {
                                            decimal more = curProfit - checkProfit;
                                            LogHelper.Instance.WriteLog("超标了:" + more, "分润监控日志");
                                        }
                                    }
                                    LogHelper.Instance.WriteLog("------------------------", "分润监控日志");
                                    LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":稳定期:" + NotHelpDirectTradeAmt, "分润监控日志");
                                    if (NotHelpDirectTradeAmt > 0)
                                    {
                                        level = 0;
                                        curLevel = 0;
                                        diffLevelProfit = 0;  //等级级差
                                        foreach (string UserIdString in ParentNavList)
                                        {
                                            level += 1;
                                            int uid = int.Parse(UserIdString);
                                            SubUser user = GetUser(uid, Month) ?? new SubUser();
                                            int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
                                            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,
                                                        });
                                                    }
                                                }
                                            }
                                            if(curLevel < UserLevel)
                                            {
                                                curLevel = UserLevel;
                                            }
                                        }
                                    }
                                    LogHelper.Instance.WriteLog("------------------------", "分润监控日志");
                                    LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":盈利期:" + ProfitDirectTradeAmt, "分润监控日志");
                                    if (ProfitDirectTradeAmt > 0)
                                    {
                                        level = 0;
                                        curLevel = 0;
                                        diffLevelProfit = 0;  //等级级差
                                        foreach (string UserIdString in ParentNavList)
                                        {
                                            level += 1;
                                            int uid = int.Parse(UserIdString);
                                            SubUser user = GetUser(uid, Month) ?? new SubUser();
                                            int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
                                            if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                            {
                                                break;
                                            }
                                            if (UserLevel <= maxLevel && UserLevel > curLevel)
                                            {
                                                int LevelKindId = GetLevelKindId(BrandId, 2, 1);
                                                ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                                if (objlevel != null)
                                                {
                                                    decimal getLevelProfit = 0;  //等级分润
                                                    if (objlevel.Percents > 0)
                                                    {
                                                        getLevelProfit += ProfitDirectTradeAmt * 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 = ProfitDirectTradeAmt,
                                                            HelpFlag = 2,
                                                        });
                                                    }
                                                }
                                            }
                                            if(curLevel < UserLevel)
                                            {
                                                curLevel = UserLevel;
                                            }
                                        }
                                    }
                                }
                            }
                            LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":over", "分润监控日志");
                        }
                        catch (Exception ex)
                        {
                            LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
                        }
                        dbnew.Dispose();
                    }
                }
            }
            return result;
        }
        #endregion

        public SubUser GetUser(int UserId, string Month)
        {
            SubUser user = new SubUser();
            DataTable dt = GetDataTable("select * from Users" + Month + " where Id=" + UserId);
            if(dt.Rows.Count > 0)
            {
                user.Id = int.Parse(dt.Rows[0]["Id"].ToString());
                user.ParentUserId = int.Parse(dt.Rows[0]["ParentUserId"].ToString());
                user.ParentNav = dt.Rows[0]["ParentNav"].ToString();
                user.UserLevel = int.Parse(dt.Rows[0]["UserLevel"].ToString());
                user.PreUserLevel = int.Parse(dt.Rows[0]["PreUserLevel"].ToString());
            }
            return user;
        }

        public DataTable GetDataTable(string sqlstr)
        {
            DataTable dt = CustomerSqlConn.dtable(sqlstr, Library.ConfigurationManager.AppSettings["MainSqlConnStr"].ToString());
            return dt;
        }
    }
}