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

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

namespace MySystem
{
    public class ProfitBeforeHelper
    {
        public readonly static ProfitBeforeHelper Instance = new ProfitBeforeHelper();
        private ProfitBeforeHelper()
        {
        }
        
        public void StartListenProfit()
        {
            Thread th = new Thread(StartListenProfitDo);
            th.IsBackground = true;
            th.Start();
        }

        public void StartListenProfitDo()
        {
            while(true)
            {
                if(DateTime.Now.Day < 25 && DateTime.Now.Hour > 2 && DateTime.Now.Hour < 23)
                {
                    try
                    {
                        DoProfit();
                    }
                    catch(Exception ex)
                    {
                        LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "来客吧分润异常");
                    }
                    Thread.Sleep(600000);
                }
                else
                {
                    Thread.Sleep(3600000);
                }
            }
        }

        //分润算法
        public void DoProfit()
        {
            string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            string check = function.ReadInstance("/ProfitFlag/" + TradeMonth + "-before.txt");
            if(!string.IsNullOrEmpty(check))
            {
                return;
            }
            function.WritePage("/ProfitFlag/", TradeMonth + "-before.txt", DateTime.Now.ToString());
            KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
            WebCMSEntities dbnew = new WebCMSEntities();
            KxsUserModels.WebCMSEntities udb = new KxsUserModels.WebCMSEntities();
            DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummaryOldBefore where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", MysqlConn.SqlConnStr);
            foreach(DataRow dr in dt.Rows)
            {
                int UserId = int.Parse(dr["UserId"].ToString());
                bool IsActive = dr["IsAct"].ToString() == "1";
                decimal TotalAmount = decimal.Parse(dr[2].ToString());
                List<ProfitUsers> users = new List<ProfitUsers>();
                int TopUserId = 0; //顶级创客Id
                KxsUserModels.KxsUser us = udb.KxsUser.FirstOrDefault(a => a.Id == UserId);
                if (us != null)
                {
                    string uidstring = us.Id.ToString();
                    if (!string.IsNullOrEmpty(us.PidPath))
                    {
                        uidstring = us.PidPath.Trim(',').Replace(",,", ",") + "," + uidstring;
                        string[] parents = us.PidPath.Trim(',').Replace(",,", ",").Split(',');
                        if(parents.Length > 1)
                        {
                            TopUserId = int.Parse(function.CheckInt(parents[1]));
                        }
                        else
                        {
                            TopUserId = int.Parse(function.CheckInt(parents[0]));
                        }
                    }
                    string[] uidlist = uidstring.Split(',');
                    Array.Reverse(uidlist);
                    foreach (string uidstr in uidlist)
                    {
                        int puid = int.Parse(function.CheckInt(uidstr));
                        KxsUserModels.KxsUser pus = udb.KxsUser.FirstOrDefault(a => a.Id == puid);
                        if (pus != null)
                        {
                            users.Add(new ProfitUsers()
                            {
                                UserId = pus.Id,
                                MakerCode = pus.UserCode,
                                RealName = pus.Username,
                                UserNav = pus.PidPath,
                                UserLevel = pus.UserLevel,
                                CreateDate = pus.CreateTime.Value,
                            });
                        }
                    }
                }
                KxsUserModels.KxsUser topUser = udb.KxsUser.FirstOrDefault(a => a.Id == TopUserId) ?? new KxsUserModels.KxsUser();
                List<ProfitResult> list = new List<ProfitResult>();
                list = StartProft(TotalAmount, 1, users, IsActive);
                try
                {
                    foreach (ProfitResult sub in list)
                    {
                        int ProfitType = sub.UserId == UserId ? 0 : 1;
                        ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.BrandId == 1 && m.Version == 0 && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
                        if (editprofitrecord == null)
                        {
                            editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
                            {
                                CreateDate = DateTime.Now,
                                UserId = sub.UserId, //创客
                                BrandId = 1, //品牌
                                ProfitType = ProfitType, //创客分润类型
                                TradeMonth = TradeMonth, //交易月
                                TopUserId = TopUserId, //顶级创客
                                CreateMan = sub.MakerCode, //创客编号
                                UpdateMan = topUser.UserCode, //顶级编号
                                SeoTitle = sub.RealName, //创客姓名
                                SeoKeyword = topUser.Username, //创客姓名
                            }).Entity;
                            dbnew.SaveChanges();
                            string RecordNo = "KPM";
                            int RecordId = editprofitrecord.Id;
                            string RecordIdString = RecordId.ToString();
                            for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
                            {
                                RecordIdString = "0" + RecordIdString;
                            }
                            RecordNo += RecordIdString;
                            editprofitrecord.RecordNo = RecordNo;
                            dbnew.SaveChanges();
                        }
                        if(IsActive)
                        {
                            editprofitrecord.CreditTradeAmt += TotalAmount;
                            editprofitrecord.CreditTradeProfit += sub.Money;
                        }
                        else
                        {
                            editprofitrecord.TradeAmt += TotalAmount;
                            editprofitrecord.TradeProfit += sub.Money;
                        }
                        dbnew.SaveChanges();
                    }
                    dbnew.SaveChanges();
                }
                catch (Exception ex)
                { 
                    LogHelper.Instance.WriteLog(ex.ToString(), "分润异常");
                }
            }
            dbnew.Dispose();
            kxsdb.Dispose();
            udb.Dispose();
        }


        #region 分润算法
        public List<ProfitResult> StartProft(decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
        {
            LogHelper.Instance.WriteLog("\n\nTotalAmount：" + TotalAmount + "；", "来客吧分润日志");
            string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            WebCMSEntities db = new WebCMSEntities();
            KxsUserModels.WebCMSEntities udb = new KxsUserModels.WebCMSEntities();
            List<UserLevelSet> levels = db.UserLevelSet.ToList();
            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = db.ProfitObjects.FirstOrDefault();
            if (obj.Status == 1) //判断分润是否开启
            {
                int maxLevel = obj.MaxLevel; //最大等级
                int maxFloor = obj.MaxFloor; //最大层级
                decimal diffLevelProfit = 0;  //等级级差
                ProfitObjectLevels maxlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.LevelNumber == 9) ?? new ProfitObjectLevels(); //获取最高等级参数
                decimal maxPercent = IsActive ? maxlevel.DebitPercents : maxlevel.Percents;
                LogHelper.Instance.WriteLog("maxPercent：" + maxPercent + "；", "来客吧分润日志");
                decimal maxLevelProfit = TotalAmount * maxPercent;
                LogHelper.Instance.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
                maxLevelProfit = PublicFunction.NumberFormat(maxLevelProfit);
                LogHelper.Instance.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
                // decimal diffDiviProfit = 0; //分红级差
                int curLevel = 0; //当前层级的会员等级
                for (int curFloor = 1; curFloor <= users.Count; curFloor++)
                {
                    ProfitUsers user = new ProfitUsers();
                    if (curFloor <= users.Count)
                    {
                        user = users[curFloor - 1];
                    }
                    SubUser selfUser = GetUser(udb, user.UserId, int.Parse(Month)) ?? new SubUser();
                    int UserLevel = GetUserLevel(selfUser); //当前会员等级
                    //判断当前创客是否有直推的激活机具，并且在活动时间内
                    if (curLevel == maxLevel)
                    {
                        break;
                    }
                    if (UserLevel <= maxLevel && UserLevel >= curLevel)
                    {
                        ProfitObjectLevels objlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.LevelNumber == UserLevel && m.Version == 0); //获取当前等级参数
                        if (objlevel != null)
                        {
                            decimal getLevelProfit = 0;  //等级分润
                            UserProfitSet profitSet = new UserProfitSet();
                            decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
                            LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + profitPercent + "；", "来客吧分润日志");
                            if (profitPercent > 0)
                            {
                                decimal profitTmp = TotalAmount * profitPercent;
                                getLevelProfit += profitTmp;
                                LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + profitTmp + "；", "来客吧分润日志");
                            }
                            decimal money = getLevelProfit;
                            getLevelProfit -= diffLevelProfit;
                            if (objlevel.LevelDiff == 1)  //判断是否有级差
                            {
                                diffLevelProfit = money;
                            }
                            if (getLevelProfit >= obj.MinProfitVal)
                            {
                                result.Add(new ProfitResult()
                                {
                                    UserId = user.UserId,
                                    MakerCode = user.MakerCode,
                                    RealName = user.RealName,
                                    UserNav = user.UserNav,
                                    Money = PublicFunction.NumberFormat(getLevelProfit),
                                    ProfitRate = profitSet.ProfitRate,
                                    ProfitPercent = profitSet.ProfitPercent,
                                    AddOrSubRate = profitSet.AddOrSubRate,
                                    ProfitRateBase = profitSet.ProfitRateBase,
                                });
                                LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + PublicFunction.NumberFormat(getLevelProfit) + "；", "来客吧分润日志");
                            }
                        }
                    }
                    if(curLevel < UserLevel)
                    {
                        curLevel = UserLevel;
                    }
                }
            }
            db.Dispose();
            udb.Dispose();
            return result;
        }

        public SubUser GetUser(KxsUserModels.WebCMSEntities db, int UserId, int Month)
        {
            SubUser user = new SubUser();
            KxsUserModels.KxsTradeLevelLog log = db.KxsTradeLevelLog.FirstOrDefault(m => m.TradeMonth == Month && m.Version == 1 && m.UserId == UserId);
            if(log != null)
            {
                user.Id = log.UserId;
                user.Level = log.Level;
                user.ParentNav = log.PidPath;
                user.UserLevel = log.UserLevel;
                user.PreUserLevelBefore = log.BeforePreLevel;
            }
            // DataTable dt = GetDataTable("select * from kxs_trade_level_log where trade_month=" + Month + " and version=0 and user_id=" + UserId);
            // if (dt.Rows.Count > 0)
            // {
            //     user.Id = int.Parse(dt.Rows[0]["user_id"].ToString());
            //     // user.ParentUserId = int.Parse(dt.Rows[0]["ParentUserId"].ToString());
            //     user.Level = int.Parse(dt.Rows[0]["level"].ToString());
            //     user.ParentNav = dt.Rows[0]["pid_path"].ToString();
            //     user.UserLevel = int.Parse(dt.Rows[0]["user_level"].ToString());
            //     user.PreUserLevelBefore = int.Parse(dt.Rows[0]["before_pre_level"].ToString());
            // }
            return user;
        }

        public int GetUserLevel(SubUser user)
        {
            int[] levels = new int[] { user.Level, user.UserLevel, user.PreUserLevelBefore };
            return levels.ToList().Max();
        }

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

        #region 活动奖励算法
        public List<ProfitResult> StartActiveProft(WebCMSEntities dbnew, PosMachinesTwo machine, string CheckObject, int ObjectId, Dictionary<string, ProfitUsers> Users, ActiveCheckData StatParam)
        {
            DateTime Start = machine.ActivationTime.Value;
            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + ObjectId);
            if (obj.Status == 1) //判断分润是否开启
            {
                List<ProfitObjectsActives> objactives = RedisDbconn.Instance.GetList<ProfitObjectsActives>("pobjact" + ObjectId);
                foreach (ProfitObjectsActives objactive in objactives)
                {
                    if (objactive.StartDate <= DateTime.Now && objactive.EndDate >= DateTime.Now)
                    {
                        string UserKey = "UserId";
                        decimal ProfitMoney = objactive.ProfitNumber;  //获得数
                        decimal FinishNumber = objactive.FinishNumber; //完成数
                        string CheckKey = CheckObject + "-" + objactive.Id;
                        ProfitObjectsActiveCheck check = dbnew.ProfitObjectsActiveCheck.FirstOrDefault(m => m.CheckData == CheckKey);
                        if (ProfitMoney > 0 && check == null)
                        {
                            int LimitDateKind = objactive.LimitDateKind; //时间限制类型 日月年/自定义
                            if (LimitDateKind == 4)
                            {
                                DateTime LimitCustomerDate = objactive.LimitCustomerDate.Value; //过期时间
                                if (LimitCustomerDate >= DateTime.Now)
                                {
                                    decimal totalTradeMoney = 0;
                                    OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
                                    string sqlstr = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + LimitCustomerDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
                                    DataTable dt = OtherMySqlConn.dtable(sqlstr);
                                    if (dt.Rows.Count > 0)
                                    {
                                        totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
                                    }
                                    // OtherMySqlConn.connstr = ;
                                    if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal)  //达到完成数，发放奖励
                                    {
                                        result.Add(new ProfitResult()
                                        {
                                            UserId = Users[UserKey].UserId,
                                            UserNav = Users[UserKey].UserNav,
                                            Money = ProfitMoney,
                                        });
                                        dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
                                        {
                                            CheckData = CheckKey
                                        });
                                        dbnew.SaveChanges();
                                    }
                                }
                            }
                            else
                            {
                                int LimitDateVal = objactive.LimitDateVal; //时间限制值 日月年
                                DateTime checkDate = Start;
                                if (LimitDateKind == 1)
                                {
                                    checkDate = checkDate.AddDays(LimitDateVal);
                                }
                                else if (LimitDateKind == 2)
                                {
                                    checkDate = checkDate.AddMonths(LimitDateVal);
                                }
                                else if (LimitDateKind == 3)
                                {
                                    checkDate = checkDate.AddYears(LimitDateVal);
                                }
                                if (checkDate >= DateTime.Now)
                                {
                                    decimal totalTradeMoney = 0;
                                    OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
                                    string sql = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + checkDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
                                    DataTable dt = OtherMySqlConn.dtable(sql);
                                    if (dt.Rows.Count > 0)
                                    {
                                        totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
                                    }
                                    // OtherMySqlConn.connstr = ;
                                    if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal)  //达到完成数，发放奖励
                                    {
                                        result.Add(new ProfitResult()
                                        {
                                            UserId = Users[UserKey].UserId,
                                            UserNav = Users[UserKey].UserNav,
                                            Money = ProfitMoney,
                                        });
                                        dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
                                        {
                                            CheckData = CheckKey
                                        });
                                        dbnew.SaveChanges();
                                    }
                                }
                            }
                        }
                    }
                }
            }
            return result;
        }
        #endregion

        #region 激活奖励算法
        public ProfitResult ActivationProft(PosMachinesTwo machine, ProfitUsers User)
        {
            int BrandId = machine.BrandId;
            DateTime Start = machine.ActivationTime.Value;
            ProfitResult result = new ProfitResult();
            if (machine.PosSnType == 1 && machine.UserId != machine.BuyUserId) //循环机具，划拨给其他人，没有激活返现没有循环
            { 
                return result;
            }
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                ProfitObjectActivations objact = RedisDbconn.Instance.Get<ProfitObjectActivations>("pobjacti" + BrandId);
                if (objact.StartDate <= DateTime.Now && objact.EndDate >= DateTime.Now)
                {
                    int LimitDateKind = objact.LimitDateKind; //时间限制类型 日月年/自定义
                    int LimitDateVal = objact.LimitDateVal; //时间限制值 日月年
                    decimal ProfitMoney = objact.ProfitNumber;
                    int MachineCount = objact.MachineCount;
                    DateTime checkDate = Start;
                    if (LimitDateKind == 1)
                    {
                        checkDate = checkDate.AddDays(LimitDateVal);
                    }
                    else if (LimitDateKind == 2)
                    {
                        checkDate = checkDate.AddMonths(LimitDateVal);
                    }
                    else if (LimitDateKind == 3)
                    {
                        checkDate = checkDate.AddYears(LimitDateVal);
                    }
                    else if (LimitDateKind == 4)
                    {
                        checkDate = objact.LimitCustomerDate.Value;
                    }
                    // if (DateTime.Now > checkDate && ProfitMoney > objact.ExpiredNumber)
                    // {
                    //     ProfitMoney = objact.ExpiredNumber;
                    // }
                    if (ProfitMoney >= obj.MinProfitVal)
                    {
                        result = new ProfitResult()
                        {
                            UserId = User.UserId,
                            UserNav = User.UserNav,
                            Money = ProfitMoney,
                            MachineCount = MachineCount,
                        };
                    }
                }
            }
            return result;
        }
        #endregion

        #region 获取分润规则Id

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

        #endregion








        #region POS统计交易额
        public void StartListenTradeDo(int tradeId, bool profit = true)
        {
            try
            {
                WebCMSEntities dbnew = new WebCMSEntities();
                TradeRecord trade_record = dbnew.TradeRecord.FirstOrDefault(m => m.Id == tradeId);
                if (trade_record != null)
                {
                    int BrandId = trade_record.BrandId;
                    decimal TradeAmt = trade_record.TradeAmount;
                    int BankCardTypeNum = trade_record.BankCardType; //1-贷记卡，0-借记卡，2-准贷记卡

                    DateTime TradeDateTime = trade_record.CreateDate.Value;
                    string monthString = TradeDateTime.ToString("yyyyMM");
                    string dayString = TradeDateTime.ToString("yyyyMMdd");
                    string NaturalMonthString = RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:NaturalMonth");
                    int NaturalMonth = int.Parse(NaturalMonthString); //自然月

                    MachineForSnNo machinefor = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == trade_record.SnNo) ?? new MachineForSnNo();
                    PosMachinesTwo machine = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == machinefor.SnId) ?? new PosMachinesTwo();
                    Users user = dbnew.Users.FirstOrDefault(m => m.Id == machine.UserId) ?? new Users();
                    int TopUserId = 0;
                    if (!string.IsNullOrEmpty(user.ParentNav))
                    {
                        string[] navList = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                        if (navList.Length > 1)
                        {
                            TopUserId = int.Parse(navList[1]);
                        }
                        else
                        { 
                            TopUserId = int.Parse(navList[0]);
                        }
                    }
                    PosMerchantInfo merchant = dbnew.PosMerchantInfo.FirstOrDefault(m => m.Id == machine.BindMerchantId) ?? new PosMerchantInfo();
                    List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();

                    using (var tran = dbnew.Database.BeginTransaction())
                    {
                        try
                        {
                            ulong DirectFlag = merchant.UserId == machine.UserId ? 1u : 0u; //是否直营
                            ulong MerHelpFlag = 1; //扶持期、稳定期
                            if (merchant.CreateDate.Value < DateTime.Now.AddMonths(-NaturalMonth))
                            {
                                MerHelpFlag = 0;
                            }
                            int HelpMonthCount = DateTime.Now.Month - merchant.CreateDate.Value.Month; //扶持期第几月
                            if (HelpMonthCount < 0)
                            {
                                HelpMonthCount = 12 + DateTime.Now.Month - merchant.CreateDate.Value.Month;
                            }
                            int QrPayFlag = trade_record.QrPayFlag;
                            decimal CreditTradeAmt = 0;
                            decimal DebitNotCapTradeAmt = 0;
                            decimal DebitCapTradeAmt = 0;
                            int DebitCapTradeNum = 0;
                            if (BankCardTypeNum == 1)
                            {
                                CreditTradeAmt = TradeAmt;
                            }
                            else if (BankCardTypeNum == 0)
                            {
                                //累计借记卡封顶或非封顶交易 // TODO:需优化，判断不太科学
                                // decimal profitrate = 0;
                                // if (user.CreateDate.Value.AddMonths(NaturalMonth) >= DateTime.Now)
                                // {
                                //     UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 1) ?? new UserProfitSet(); //获取创客分润规则-扶持期
                                //     profitrate = profitSet.ProfitRate;
                                // }
                                // else
                                // {
                                //     UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 0) ?? new UserProfitSet(); //获取创客分润规则-非扶持期
                                //     profitrate = profitSet.ProfitRate;
                                // }
                                // profitrate = profitrate / 100;
                                // int UserLevel = user.UserLevel; //当前会员等级
                                // decimal utrade = RedisDbconn.Instance.Get<decimal>("TeamTradeStat:" + user.Id + ":" + BrandId + ":" + DateTime.Now.ToString("yyMM"));
                                // UserLevelSet checklevel = levels.Where(m => m.UpLevelIntegral < utrade).OrderBy(m => m.Id).FirstOrDefault();
                                // if (checklevel != null)
                                // {
                                //     UserLevel = checklevel.Id + 1;
                                // }
                                // ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + GetLevelKindId(BrandId) + ":" + UserLevel); //获取当前等级参数
                                // decimal getLevelProfit = TradeAmt * objlevel.Percents * profitrate;
                                // if (getLevelProfit < 1)
                                // {
                                //     DebitNotCapTradeAmt = TradeAmt;
                                // }
                                // else
                                // {
                                //     DebitCapTradeAmt = TradeAmt;
                                //     DebitCapTradeNum = 1;
                                //     trade_record.CapFlag = 1;
                                //     dbnew.SaveChanges();
                                // }
                                DebitNotCapTradeAmt = TradeAmt;
                            }
                            UserTradeMonthSummary editsummary = dbnew.UserTradeMonthSummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeMonth == monthString && m.BrandId == BrandId && m.StatType == 0);
                            if (editsummary == null)
                            {
                                dbnew.UserTradeMonthSummary.Add(new UserTradeMonthSummary()
                                {
                                    CreateDate = DateTime.Now,
                                    UserId = user.Id, //创客
                                    TradeMonth = monthString, //交易月
                                    BrandId = BrandId, //品牌
                                    StatType = 0, //交易统计类型
                                    TradeAmt = TradeAmt, //商户交易总额
                                    CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
                                    DebitNotCapTradeAmt = DebitNotCapTradeAmt, //商户非封顶借记卡交易总金额
                                    DebitCapTradeAmt = DebitCapTradeAmt, //商户借记卡封顶交易总额
                                    DebitCapTradeNum = DebitCapTradeNum, //商户借记卡封顶交易总笔数
                                    MallPosOrderStatus = machine.PosSnType == 1 ? 0 : 1, //商城兑换机具状态
                                    ActiveBuddyMerStatus = user.RealName == merchant.MerchantName ? 0 : 1, //激活创客同名商户
                                });
                            }
                            else
                            {
                                editsummary.TradeAmt += TradeAmt;
                                editsummary.CreditTradeAmt += CreditTradeAmt;
                                editsummary.DebitNotCapTradeAmt += DebitNotCapTradeAmt;
                                editsummary.DebitCapTradeAmt += DebitCapTradeAmt;
                                editsummary.DebitCapTradeNum += DebitCapTradeNum;
                            }
                            TradeDaySummary editdaysum = dbnew.TradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
                            if (editdaysum == null)
                            {
                                editdaysum = dbnew.TradeDaySummary.Add(new TradeDaySummary()
                                {
                                    CreateDate = DateTime.Now,
                                    UserId = user.Id, //创客
                                    TradeDate = dayString, //交易日
                                    TradeMonth = monthString, //交易月
                                    BrandId = BrandId, //品牌
                                    TopUserId = TopUserId, //顶级创客
                                }).Entity;
                                dbnew.SaveChanges();
                            }
                            //分类统计交易额
                            if (MerHelpFlag == 0)
                            {
                                if (DirectFlag == 1)
                                {
                                    editdaysum.NotHelpDirectTradeAmt = TradeAmt; //直营商户交易总额(非扶持期)
                                    if (BankCardTypeNum == 1)
                                    {
                                        editdaysum.NotHelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(非扶持期)
                                        if (QrPayFlag == 1)
                                        {
                                            editdaysum.NotHelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(非扶持期)
                                        }
                                        else
                                        {
                                            editdaysum.NotHelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(非扶持期)
                                        }
                                    }
                                    else
                                    {
                                        editdaysum.NotHelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(非扶持期)
                                        if (DebitCapTradeNum > 0)
                                        {
                                            editdaysum.NotHelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(非扶持期)
                                            editdaysum.NotHelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(非扶持期)
                                        }
                                        else
                                        {
                                            if (QrPayFlag == 1)
                                            {
                                                editdaysum.NotHelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(非扶持期)
                                            }
                                            else
                                            {
                                                editdaysum.NotHelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(非扶持期)
                                            }
                                        }
                                    }
                                }
                                else
                                {
                                    editdaysum.NotHelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(非扶持期)
                                    if (BankCardTypeNum == 1)
                                    {
                                        editdaysum.NotHelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(非扶持期)
                                        if (QrPayFlag == 1)
                                        {
                                            editdaysum.NotHelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(非扶持期)
                                        }
                                        else
                                        {
                                            editdaysum.NotHelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(非扶持期)
                                        }
                                    }
                                    else
                                    {
                                        editdaysum.NotHelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(非扶持期)
                                        if (DebitCapTradeNum > 0)
                                        {
                                            editdaysum.NotHelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(非扶持期)
                                            editdaysum.NotHelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(非扶持期)
                                        }
                                        else
                                        {
                                            if (QrPayFlag == 1)
                                            {
                                                editdaysum.NotHelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(非扶持期)
                                            }
                                            else
                                            {
                                                editdaysum.NotHelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(非扶持期)
                                            }
                                        }
                                    }
                                }
                            }
                            else
                            {
                                if (DirectFlag == 1)
                                {
                                    editdaysum.HelpDirectTradeAmt += TradeAmt; //直营商户交易总额(扶持期)
                                    if (BankCardTypeNum == 1)
                                    {
                                        editdaysum.HelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(扶持期)
                                        if (QrPayFlag == 1)
                                        {
                                            editdaysum.HelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(扶持期)
                                        }
                                        else
                                        {
                                            editdaysum.HelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(扶持期)
                                        }
                                    }
                                    else
                                    {
                                        editdaysum.HelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(扶持期)
                                        if (DebitCapTradeNum > 0)
                                        {
                                            editdaysum.HelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(扶持期)
                                            editdaysum.HelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(扶持期)
                                        }
                                        else
                                        {
                                            if (QrPayFlag == 1)
                                            {
                                                editdaysum.HelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(扶持期)
                                            }
                                            else
                                            {
                                                editdaysum.HelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(扶持期)
                                            }
                                        }
                                    }
                                }
                                else
                                {
                                    editdaysum.HelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(扶持期)
                                    if (BankCardTypeNum == 1)
                                    {
                                        editdaysum.HelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(扶持期)
                                        if (QrPayFlag == 1)
                                        {
                                            editdaysum.HelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(扶持期)
                                        }
                                        else
                                        {
                                            editdaysum.HelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(扶持期)
                                        }
                                    }
                                    else
                                    {
                                        editdaysum.HelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(扶持期)
                                        if (DebitCapTradeNum > 0)
                                        {
                                            editdaysum.HelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(扶持期)
                                            editdaysum.HelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(扶持期)
                                        }
                                        else
                                        {
                                            if (QrPayFlag == 1)
                                            {
                                                editdaysum.HelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(扶持期)
                                            }
                                            else
                                            {
                                                editdaysum.HelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(扶持期)
                                            }
                                        }
                                    }
                                }
                            }
                            UserTradeDaySummary userdaysum = dbnew.UserTradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
                            if (userdaysum == null)
                            {
                                userdaysum = dbnew.UserTradeDaySummary.Add(new UserTradeDaySummary()
                                {
                                    CreateDate = DateTime.Now,
                                    UserId = user.Id, //创客
                                    TradeDate = dayString, //交易日
                                    TradeMonth = monthString, //交易月
                                    BrandId = BrandId, //品牌
                                }).Entity;
                                dbnew.SaveChanges();
                            }
                            if (DirectFlag == 1)
                            {
                                userdaysum.DirectTradeAmt += TradeAmt; //直营商户交易总额
                                if (BankCardTypeNum == 0)
                                {
                                    userdaysum.DirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额
                                }
                            }
                            else
                            {
                                userdaysum.NonDirectTradeAmt += TradeAmt; //非直营商户交易总额
                                if (BankCardTypeNum == 0)
                                {
                                    userdaysum.NonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额
                                }
                            }
                            dbnew.SaveChanges();
                            if (profit)
                            {
                                DoProfitForPos(dbnew, trade_record);
                            }
                            tran.Commit();
                        }
                        catch (Exception ex)
                        {
                            LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
                            tran.Rollback();
                        }
                    }
                }
                dbnew.Dispose();
            }
            catch (Exception ex)
            {
                LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
            }
        }

        public void DoProfitForPos(WebCMSEntities dbnew, TradeRecord trade_record)
        { 
            List<ProfitUsers> users = new List<ProfitUsers>();
            int TopUserId = 0; //顶级创客Id
            Users us = dbnew.Users.FirstOrDefault(a => a.Id == trade_record.UserId);
            if (us != null)
            {
                string uidstring = us.Id.ToString();
                string[] uidlist = { };
                if (!string.IsNullOrEmpty(us.ParentNav))
                {
                    uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
                    uidlist = uidstring.Split(',');
                    if (uidlist.Length > 1)
                    {
                        TopUserId = int.Parse(function.CheckInt(uidlist[1]));
                    }
                    else
                    { 
                        TopUserId = int.Parse(function.CheckInt(uidlist[0]));
                    }
                }
                Array.Reverse(uidlist);
                foreach (string uidstr in uidlist)
                {
                    int puid = int.Parse(function.CheckInt(uidstr));
                    Users pus = dbnew.Users.FirstOrDefault(a => a.Id == puid);
                    if (pus != null)
                    {
                        users.Add(new ProfitUsers()
                        {
                            UserId = pus.Id,
                            UserNav = pus.ParentNav,
                            UserLevel = pus.UserLevel,
                            CreateDate = pus.CreateDate.Value,
                        });
                    }
                }
            }
            string TradeMonth = trade_record.TradeDate.Value.ToString("yyyyMM");
            List<ProfitResult> list = new List<ProfitResult>();
            list = StartProftForPos(dbnew, trade_record, users);
            using (var tran = dbnew.Database.BeginTransaction())
            {
                try
                {
                    foreach (ProfitResult sub in list)
                    {
                        if (sub.Message == "分红奖励")
                        { 
                            UserAccountRecord accountRecord = dbnew.UserAccountRecord.Add(new UserAccountRecord()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = sub.UserId, //创客
                                ChangeType = 11, //变动类型
                                ProductType = trade_record.BrandId, //产品类型
                                ChangeAmount = sub.Money, //变更金额
                                Status = -1,
                            }).Entity;
                            dbnew.SaveChanges();
                        }
                        else
                        {
                            int ProfitType = sub.UserId == trade_record.UserId ? 0 : 1;
                            ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.MerchantId == trade_record.MerchantId && m.BrandId == trade_record.BrandId && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
                            if (editprofitrecord == null)
                            {
                                editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
                                {
                                    CreateDate = DateTime.Now,
                                    UserId = sub.UserId, //创客
                                    MerchantId = trade_record.MerchantId, //商户
                                    BrandId = trade_record.BrandId, //品牌
                                    ProfitType = ProfitType, //创客分润类型
                                    TradeMonth = TradeMonth, //交易月
                                    TopUserId = TopUserId, //顶级创客
                                }).Entity;
                                dbnew.SaveChanges();
                                string RecordNo = "KPM";
                                int RecordId = editprofitrecord.Id;
                                string RecordIdString = RecordId.ToString();
                                for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
                                {
                                    RecordIdString = "0" + RecordIdString;
                                }
                                RecordNo += RecordIdString;
                                editprofitrecord.RecordNo = RecordNo;
                                dbnew.SaveChanges();
                            }
                            // editprofitrecord.OtherTradeAmt = 0; //其他产品交易总金额
                            // editprofitrecord.OtherCreditTradeAmt = 0; //其他产品贷记卡交易总金额
                            // editprofitrecord.OtherDebitNotCapTradeAmt = 0; //其他产品借记卡非封顶交易总金额
                            decimal TradeAmount = trade_record.TradeAmount;
                            editprofitrecord.TradeAmt += TradeAmount; //商户交易总额
                            if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeAmt += TradeAmount; //贷记卡交易总金额
                            if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeAmt += TradeAmount; //(云闪付)贷记卡交易总金额
                            if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeAmt += TradeAmount; //(非云闪付)贷记卡交易总金额
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeAmt += TradeAmount; //(非扶持期)(非云闪付)贷记卡交易总金额
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeAmt += TradeAmount; //(扶持期)(非云闪付)贷记卡交易总金额
                            if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonCapTradeAmt += TradeAmount; //商户非封顶借记卡交易总额
                            if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNotCapTradeAmt += TradeAmount; //(云闪付)商户非封顶借记卡交易总额
                            if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNotCapTradeAmt += TradeAmount; //(非云闪付)商户非封顶借记卡交易总额
                            if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonCapTradeAmt += TradeAmount; //(非扶持期)(非云闪付)借记卡非封顶交易总金额
                            if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonCapTradeAmt += TradeAmount; //(扶持期)(非云闪付)借记卡非封顶交易总金额
                            if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapTradeAmt = TradeAmount; //商户借记卡封顶交易总额
                            editprofitrecord.DebitCapTradeNum += 1; //商户借记卡封顶交易总笔数

                            decimal ProfitMoney = sub.Money;
                            ulong DirectFlag = trade_record.DirectFlag;
                            editprofitrecord.TradeProfit += ProfitMoney; //交易分润
                            if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeProfit += ProfitMoney; //贷记卡分润总金额
                            if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeProfit += ProfitMoney; //(云闪付)贷记卡交易分润
                            if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeProfit += ProfitMoney; //(非云闪付)贷记卡交易分润
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeProfit += ProfitMoney; //(非扶持期)(非云闪付)贷记卡分润总金额
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeProfit += ProfitMoney; //(扶持期)(非云闪付)贷记卡分润总金额
                            if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonTradeCapProfit += ProfitMoney; //借记卡非封顶交易分润总金额
                            if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNonTradeCapProfit += ProfitMoney; //(云闪付)借记卡非封顶交易分润总金额
                            if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNonTradeCapProfit += ProfitMoney; //(非云闪付)借记卡非封顶交易分润总金额
                            if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonTradeCapProfit += ProfitMoney; //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
                            if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonTradeCapProfit += ProfitMoney; //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
                            if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitTradeCapProfit += ProfitMoney; //借记卡封顶交易分润总金额
                            if (sub.Money < 1 && DirectFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapSingleReward += ProfitMoney; //借记卡合伙人直营封顶交易奖励金额

                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)贷记卡标准分润比例
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)贷记卡成本或增或减比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)贷记卡-标准分润比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)贷记卡成本或增或减比例
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)借记卡标准分润比例
                            if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)借记卡成本或增或减比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)借记卡商户交易对应分润比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)借记卡-标准分润比例
                            if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)借记卡成本或增或减比例
                            if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitRate = sub.ProfitRate; //(云闪付)贷记卡交易分润比例
                            if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitStandardRate = sub.ProfitRateBase; //(云闪付)贷记卡分润基准
                            editprofitrecord.QrCreditAddOrSubRate = sub.AddOrSubRate; //(云闪付)贷记卡分润比例或增或减
                            if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitRate = sub.ProfitRate; //(云闪付)借记卡非封顶交易分润比例
                            if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitStandardRate = sub.ProfitRateBase; //(云闪付)借记卡非封顶交易分润基准
                            if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitAddOrSubRate = sub.AddOrSubRate; //(云闪付)借记卡非封顶交易分润比例或增或减
                            dbnew.SaveChanges();

                            dbnew.ProfitRecord.Add(new ProfitRecord()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = sub.UserId, //创客
                                MerchantId = trade_record.MerchantId, //商户
                                MerNo = trade_record.MerNo, //渠道商户编号
                                MerHelpFlag = trade_record.MerHelpFlag, //是否属于扶持周期内商户
                                HelpMonthCount = trade_record.HelpMonthCount, //扶持第几个月
                                MerBuddyType = trade_record.MerBuddyType, //商户创客类型
                                SnNo = trade_record.SnNo, //SN号
                                TradeDate = trade_record.TradeDate, //交易日期
                                ProfitAmount = sub.Money, //分润金额
                                QrPayFlag = trade_record.QrPayFlag, //云闪付标识
                                CapFlag = trade_record.CapFlag, //借记卡封顶交易标志
                                DirectFlag = trade_record.DirectFlag, //是否直营
                                BrandId = trade_record.BrandId, //品牌
                                ParentNav = us.ParentNav, //上级创客集
                                TradeId = trade_record.Id, //交易记录Id
                            });
                            dbnew.SaveChanges();

                            // Users user = dbnew.Users.FirstOrDefault(m => m.Id == sub.UserId);
                            // if (user != null)
                            // {
                                // if (!string.IsNullOrEmpty(user.CloudPushDeviceId))
                                // {
                                //     new AliyunPushOld().Push("鑫创客通知", "您有一笔分润收益：" + sub.Money.ToString("f2"), "30", "NOTICE", user.DeviceType, user.CloudPushDeviceId, "1");
                                // }
                                // TODO:发送阿里云推送消息
                            // }
                        }
                    }
                    dbnew.SaveChanges();
                    tran.Commit();
                }
                catch (Exception ex)
                { 
                    tran.Rollback();
                    LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "POS分润异常");
                }
            }
        }

        #endregion
        
        #region POS分润算法
        public List<ProfitResult> StartProftForPos(WebCMSEntities dbnew, TradeRecord trade, List<ProfitUsers> users)
        {
            // 级差
            /*   
                
                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分润

            */


            List<ProfitResult> result = new List<ProfitResult>();
            int BrandId = trade.BrandId;
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                decimal TradeMoney = trade.TradeAmount;
                int BankCardType = trade.BankCardType; //银行卡类型：贷记卡-1，借记卡-0
                int MerHelpFlag = (int)trade.MerHelpFlag; //扶持期-1，稳定期=0
                List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
                int IncludeCurrentMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:IncludeCurrentMonth")); //是否包含当前月
                int NaturalMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:NaturalMonth")); //自然月
                if(IncludeCurrentMonth == 1) NaturalMonth -= 1;
                if (BankCardType == 0)
                {
                    Users user = dbnew.Users.FirstOrDefault(m => m.Id == trade.UserId) ?? new Users();
                    // UserProfitSet profitSet = profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
                    // profitrate = profitSet.ProfitRate;
                    // profitrate = profitrate / 100;
                    int UserLevel = user.UserLevel; //当前会员等级
                    int HelpTime = 0;
                    if (user.CreateDate.Value.AddMonths(NaturalMonth) > DateTime.Now)
                    {
                        HelpTime = 1;
                    }
                    int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
                    ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                    decimal getLevelProfit = TradeMoney * objlevel.Percents;
                    if(getLevelProfit > 1) getLevelProfit = 1;
                    result.Add(new ProfitResult()
                    {
                        UserId = user.Id,
                        UserNav = user.ParentNav,
                        Money = getLevelProfit,
                        ProfitRate = objlevel.Percents,
                        // ProfitPercent = profitSet.ProfitPercent,
                        // AddOrSubRate = profitSet.AddOrSubRate,
                        // ProfitRateBase = profitSet.ProfitRateBase,
                    });
                    return result;
                }
                int maxLevel = obj.MaxLevel; //最大等级
                int maxFloor = obj.MaxFloor; //最大层级
                int maxContinueFloor = RedisDbconn.Instance.Get<int>("pobjconc" + BrandId); //最大继续分润层级
                decimal diffLevelProfit = 0;  //等级级差
                decimal diffDiviProfit = 0; //分红级差
                // decimal diffFloorProfit = 0;  //层级级差
                // int continueFloor = 0; //继续分润层级
                int curLevel = 0; //当前层级的会员等级
                for (int curFloor = 1; curFloor <= users.Count; curFloor++)
                {
                    ProfitUsers user = new ProfitUsers();
                    if (curFloor <= users.Count)
                    {
                        user = users[curFloor - 1];
                    }
                    int UserLevel = user.UserLevel; //当前会员等级
                    //判断当前创客是否有直推的激活机具，并且在活动时间内
                    if (UserLevel == maxLevel && UserLevel == curLevel)
                    {
                        break;
                    }
                    if (UserLevel <= maxLevel && UserLevel > curLevel)
                    {
                        int HelpTime = 0;
                        if (user.CreateDate.AddMonths(NaturalMonth) > DateTime.Now)
                        {
                            HelpTime = 1;
                        }
                        int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
                        ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                        if (objlevel != null)
                        {
                            decimal getLevelProfit = 0;  //等级分润
                            // UserProfitSet profitSet = new UserProfitSet();
                            if (objlevel.Percents > 0)
                            {
                                //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                decimal profitrate = objlevel.Percents;
                                // profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.UserId && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
                                // profitrate = profitSet.ProfitRate;
                                // profitrate = profitrate / 100;
                                getLevelProfit += TradeMoney * objlevel.Percents * profitrate;
                            }
                            if (objlevel.AddProfitVal > 0)
                            {
                                //分红奖励:一个3000万，3000万以下市场总和大于1200万
                                bool bigMarket = false;
                                decimal smallMarket = 0;
                                List<Users> directs = dbnew.Users.Where(m => m.ParentUserId == user.UserId).ToList();
                                decimal BigMarketTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:BigMarketTradeAmt")); //大市场交易额
                                decimal PassTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:PassTradeAmt")); //小市场交易超越额
                                decimal UnitPrize = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:UnitPrize")); //单位奖励基数
                                foreach (Users direct in directs)
                                {
                                    UserData userData = dbnew.UserData.FirstOrDefault(m => m.UserId == direct.Id) ?? new UserData();
                                    if (userData.TotalOrderMoney >= BigMarketTradeAmt)
                                    {
                                        bigMarket = true;
                                    }
                                    else
                                    {
                                        smallMarket += userData.TotalOrderMoney;
                                    }
                                }
                                if (bigMarket && smallMarket >= PassTradeAmt)
                                { 
                                    decimal DiviPrize = objlevel.AddProfitVal * TradeMoney / UnitPrize;
                                    decimal checkmoney = DiviPrize;
                                    DiviPrize -= diffDiviProfit;
                                    if (objlevel.LevelDiff == 1)  //判断是否有级差
                                    {
                                        diffDiviProfit = checkmoney;
                                    }
                                    if (DiviPrize >= obj.MinProfitVal)
                                    {
                                        result.Add(new ProfitResult()
                                        {
                                            UserId = user.UserId,
                                            UserNav = user.UserNav,
                                            Money = DiviPrize,
                                            Message = "分红奖励",
                                        });
                                    }
                                }
                            }
                            decimal money = getLevelProfit;
                            getLevelProfit -= diffLevelProfit;
                            if (objlevel.LevelDiff == 1)  //判断是否有级差
                            {
                                diffLevelProfit = money;
                            }
                            if (getLevelProfit >= obj.MinProfitVal)
                            {
                                result.Add(new ProfitResult()
                                {
                                    UserId = user.UserId,
                                    UserNav = user.UserNav,
                                    Money = getLevelProfit,
                                    ProfitRate = objlevel.Percents,
                                    // ProfitPercent = profitSet.ProfitPercent,
                                    // AddOrSubRate = profitSet.AddOrSubRate,
                                    // ProfitRateBase = profitSet.ProfitRateBase,
                                });
                            }
                        }
                    }
                    curLevel = UserLevel;
                }
            }
            return result;
        }
        public void StatProfit()
        {
            Thread th = new Thread(StatProfitDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StatProfitDo()
        {
            string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            string check = function.ReadInstance("/ProfitStat/" + Month + ".txt");
            if (!string.IsNullOrEmpty(check))
            {
                return;
            }
            function.WritePage("/ProfitStat/", Month + ".txt", DateTime.Now.ToString());
            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)
                    {
                        List<ProfitResult> result = StartProftForPosByMonth(i, j, Month, PageNum);
                        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, //交易月份
                                        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();
                            PageNum += 1;
                        }
                        else
                        {
                            op = false;
                        }
                    }
                }
            }
            db.Dispose();

            HelpProfitHelper.Instance.StatProfitEveryDay(DateTime.Now.AddMonths(-1).ToString("yyyyMM")); //助利宝分润
            ProfitCheckHelper.Instance.Start();
        }
        public List<ProfitResult> StartProftForPosByMonth(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,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 where TradeMonth='202208' 
                    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 and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00'

                    // 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;
            }
            LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
            LogHelper.Instance.WriteLog(BankCardType.ToString(), "老规则分润日志");
            LogHelper.Instance.WriteLog(BrandId.ToString(), "老规则分润日志");
            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                string start = Month.Substring(0, 4) + "-" + Month.Substring(4, 2) + "-01 00:00:00";
                string end = DateTime.Parse(start).AddMonths(1).ToString("yyyy-MM-dd HH:mm:ss");
                DataTable dt = new DataTable();
                if (BankCardType == 1)
                {
                    dt = ProfitHelperV2.Instance.GetDataTable("select SnNo,UserId,QrPayFlag,MerHelpFlag,TradeAmount,Version from TradeRecord" + Month + " where MerHelpFlag=1 and Version=0 and BrandId=" + BrandId + LimitString);
                }
                LogHelper.Instance.WriteLog("记录页数：" + PageNum.ToString(), "老规则分润日志");
                LogHelper.Instance.WriteLog("记录条数：" + dt.Rows.Count.ToString(), "老规则分润日志");
                foreach (DataRow dr in dt.Rows)
                {
                    WebCMSEntities dbnew = new WebCMSEntities();
                    try
                    {
                        string SnNo = dr["SnNo"].ToString();
                        int UserId = int.Parse(dr["UserId"].ToString());
                        int HelpTime = int.Parse(dr["Version"].ToString()) == 1 ? 2 : int.Parse(dr["MerHelpFlag"].ToString());
                        LogHelper.Instance.WriteLog("SnNo:" + SnNo, "老规则分润日志");
                        LogHelper.Instance.WriteLog("UserId:" + UserId, "老规则分润日志");
                        LogHelper.Instance.WriteLog("HelpTime:" + HelpTime, "老规则分润日志");
                        MachineForSnNo forSnNo = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == SnNo) ?? new MachineForSnNo();
                        PosMachinesTwo pos = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
                        decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
                        if (pos.BindingState == 1)
                        {
                            LogHelper.Instance.WriteLog("BindingState:" + pos.BindingState, "老规则分润日志");
                            int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString());
                            decimal TradeAmt = decimal.Parse(dr[4].ToString());
                            List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
                            SubUser selfUser = ProfitHelperV2.Instance.GetUser(UserId, Month) ?? new SubUser();
                            int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
                            if (BankCardType == 0)
                            {
                            }
                            else
                            {
                                int maxLevel = obj.MaxLevel; //最大等级
                                decimal diffLevelProfit = 0;  //等级级差
                                int curLevel = 0; //当前层级的会员等级
                                string ParentNav = selfUser.ParentNav;
                                if (string.IsNullOrEmpty(ParentNav) && pos.BuyUserId == 1 && pos.UserId == 1)
                                {
                                    ParentNav = ",0,";
                                }
                                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");
                                    foreach (string UserIdString in ParentNavList)
                                    {
                                        level += 1;
                                        int uid = int.Parse(UserIdString);
                                        SubUser user = ProfitHelperV2.Instance.GetUser(uid, Month) ?? new SubUser();
                                        int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
                                        if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                        {
                                            break;
                                        }
                                        if (UserLevel <= maxLevel && UserLevel > curLevel)
                                        {
                                            LogHelper.Instance.WriteLog("UserLevel:" + UserLevel, "老规则分润日志");
                                            LogHelper.Instance.WriteLog("curLevel:" + curLevel, "老规则分润日志");
                                            int LevelKindId = GetLevelKindId(BrandId, HelpTime, 1);
                                            ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                            if (objlevel != null)
                                            {
                                                decimal getLevelProfit = 0;  //等级分润
                                                if (objlevel.Percents > 0)
                                                {
                                                    //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                                    getLevelProfit += TradeAmt * objlevel.Percents;
                                                }
                                                if (objlevel.AddProfitVal > 0)
                                                {
                                                    getLevelProfit += objlevel.AddProfitVal;
                                                }
                                                decimal money = getLevelProfit;
                                                getLevelProfit -= diffLevelProfit;
                                                if (objlevel.LevelDiff == 1)  //判断是否有级差
                                                {
                                                    diffLevelProfit = money;
                                                }

                                                // 分润补贴
                                                if (HelpTime == 1 && level == 1)
                                                {
                                                    LogHelper.Instance.WriteLog("ok", "老规则分润日志");
                                                    int SubsidyUserId = pos.BuyUserId;
                                                    SubUser subuser = ProfitHelperV2.Instance.GetUser(SubsidyUserId, Month) ?? new SubUser();
                                                    int subUserLevel = subuser.PreUserLevel > subuser.UserLevel ? subuser.PreUserLevel : subuser.UserLevel;
                                                    LogHelper.Instance.WriteLog("subUserLevel:" + subUserLevel, "老规则分润日志");
                                                    if(subUserLevel < 5)
                                                    {
                                                        LogHelper.Instance.WriteLog("sub:ok:", "老规则分润日志");
                                                        ProfitObjectLevels sublevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + subUserLevel); //获取当前等级参数
                                                        if (sublevel != null)
                                                        {
                                                            decimal otherPercent = 0.001M - sublevel.Percents;
                                                            decimal otherMoney = TradeAmt * otherPercent;
                                                            LogHelper.Instance.WriteLog("otherPercent:" + otherPercent, "老规则分润日志");
                                                            LogHelper.Instance.WriteLog("otherMoney:" + otherMoney, "老规则分润日志");
                                                            if (otherMoney >= obj.MinProfitVal)
                                                            {
                                                                LogHelper.Instance.WriteLog("finish:" + SnNo, "老规则分润日志");
                                                                result.Add(new ProfitResult()
                                                                {
                                                                    UserId = subuser.Id,
                                                                    UserNav = subuser.ParentNav,
                                                                    Money = PublicFunction.NumberFormat(otherMoney),
                                                                    ProfitRate = otherPercent,
                                                                    Message = "分润补贴",
                                                                    BankCardType = BankCardType,
                                                                    QrPayFlag = QrPayFlag,
                                                                    DirectFlag = 1,
                                                                    BrandId = pos.BrandId,
                                                                    IsSubsidy = 1,
                                                                    MerchantId = pos.BindMerchantId,
                                                                    TradeAmount = TradeAmt,
                                                                    HelpFlag = HelpTime,
                                                                    PosSn = pos.PosSn,
                                                                });
                                                            }
                                                        }
                                                    }
                                                }
                                            }
                                        }
                                        curLevel = UserLevel;
                                    }
                                }
                            }
                        }
                        LogHelper.Instance.WriteLog("\n\n", "老规则分润日志");
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
                    }
                    dbnew.Dispose();
                }
            }
            LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
            LogHelper.Instance.WriteLog("\r\n\r\n", "老规则分润日志");
            return result;
        }
        #endregion







        public void StartSetDivi()
        {
            Thread th = new Thread(StartSetDiviDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartSetDiviDo()
        {
            while (true)
            {
                string content = RedisDbconn.Instance.RPop<string>("ConsumerOrdersSetDivi");
                if (!string.IsNullOrEmpty(content))
                {
                    SetDivi(content);
                }
                else
                {
                    Thread.Sleep(10000);
                }
            }
        }

        public void SetDivi(string content)
        { 
            try
            {
                JsonData jsonObj = JsonMapper.ToObject(content);
                int orderId = int.Parse(function.CheckInt(jsonObj["OrderId"].ToString()));
                decimal diviAmt = decimal.Parse(function.CheckNum(jsonObj["DiviAmt"].ToString()));
                WebCMSEntities db = new WebCMSEntities();
                ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == orderId);
                if(order != null)
                {
                    order.CurDivi = diviAmt;
                    db.SaveChanges();
                }
                db.Dispose();
            }
            catch(Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "设置订单当前返现金额异常");
            }
        }

    }
}