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

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

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

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

        #endregion
        

        public void StatSimProfiting()
        {
            string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
            string check = function.ReadInstance("/ProfitStat/" + Month + "-1-sim-before.txt");
            if (!string.IsNullOrEmpty(check))
            {
                return;
            }
            function.WritePage("/ProfitStat/", Month + "-1-sim-before.txt", DateTime.Now.ToString());
            try
            {
                WebCMSEntities db = new WebCMSEntities();
                ReadModels.WebCMSEntities rdb = new ReadModels.WebCMSEntities();
                int PageNum = 1;
                bool op = true;
                while(op)
                {
                    function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + "BrandId:14,BankCardType:1,Month:" + Month + ",PageNum:" + PageNum, "分润监控日志");
                    List<ProfitResult> result = StartProftForSimByDate(Month, 14, PageNum);
                    function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + "result:" + result.Count, "分润监控日志");
                    function.WriteLog("\r\n", "分润监控日志");
                    if(result.Count > 0)
                    {
                        foreach (ProfitResult sub in result)
                        {
                            int TopUserId = 0;
                            if (!string.IsNullOrEmpty(sub.UserNav))
                            {
                                string[] UserNavList = sub.UserNav.Trim(',').Replace(",,", ",").Split(',');
                                if (UserNavList.Length > 1)
                                {
                                    TopUserId = int.Parse(UserNavList[1]);
                                }
                                else
                                {
                                    TopUserId = int.Parse(UserNavList[0]);
                                }
                            }
                            string RecordNo = "P" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
                            decimal ProfitAmt = sub.Money;
                            decimal TradeAmt = sub.TradeAmount;
                            decimal ProfitRate = sub.ProfitRate;
                            
                            decimal CreditTradeAmt = 0;
                            decimal CreditTradeProfit = 0;
                            decimal QrCreditTradeAmt = 0;
                            decimal QrCreditProfitRate = 0;
                            decimal QrCreditProfitStandardRate = 0;
                            decimal QrCreditAddOrSubRate = 0;
                            decimal QrCreditTradeProfit = 0;
                            decimal NonQrCreditTradeAmt = 0;
                            decimal NotHelpCreditTradeAmt = 0;
                            decimal NotHelpCreditTradeProfit = 0;
                            decimal NotHelpCreditProfitRate = 0;
                            decimal NotHelpCreditProfitStandardRate = 0;
                            decimal NotHelpCreditAddOrSubRate = 0;
                            decimal HelpCreditTradeAmt = 0;
                            decimal NonQrCreditTradeProfit = 0;
                            decimal HelpCreditTradeProfit = 0;
                            decimal HelpCreditProfitRate = 0;
                            decimal HelpCreditProfitStandardRate = 0;
                            decimal HelpCreditAddOrSubRate = 0;
                            decimal DebitNonCapTradeAmt = 0;
                            decimal DebitCapTradeAmt = 0;
                            decimal QrDebitNotCapTradeAmt = 0;
                            decimal NonQrDebitNotCapTradeAmt = 0;
                            decimal NotHelpDebitNonCapTradeAmt = 0;
                            decimal HelpDebitNonCapTradeAmt = 0;
                            decimal DebitNonTradeCapProfit = 0;
                            decimal QrDebitNonTradeCapProfit = 0;
                            decimal NonQrDebitNonTradeCapProfit = 0;
                            decimal NotHelpDebitNonTradeCapProfit = 0;
                            decimal HelpDebitNonTradeCapProfit = 0;
                            decimal DebitTradeCapProfit = 0;
                            decimal NotHelpDebitProfitRate = 0;
                            decimal NotHelpDebitProfitStandardRate = 0;
                            decimal NotHelpDebitAddOrSubRate = 0;
                            decimal HelpDebitProfitRate = 0;
                            decimal HelpDebitProfitStandardRate = 0;
                            decimal HelpDebitAddOrSubRate = 0;
                            decimal DebitCapSingleReward = 0;
                            decimal QrDebitProfitRate = 0;
                            decimal QrDebitProfitStandardRate = 0;
                            decimal QrDebitAddOrSubRate = 0;
                            decimal ProfitCreditTradeProfit = 0;
                            decimal ProfitCreditProfitRate = 0;
                            decimal ProfitCreditTradeAmt = 0;
                            decimal ProfitCreditTradeProfit2 = 0;
                            decimal ProfitCreditProfitRate2 = 0;
                            decimal ProfitCreditTradeAmt2 = 0;
                            decimal ProfitDebitNonCapTradeAmt = 0;
                            decimal ProfitDebitNonTradeCapProfit = 0;
                            decimal ProfitDebitProfitRate = 0;
                            
                            CreditTradeAmt = TradeAmt; //贷记卡交易总金额
                            CreditTradeProfit = ProfitAmt; //贷记卡分润总金额
                            if (sub.QrPayFlag == 1)
                            {
                                QrCreditTradeAmt = TradeAmt; //(云闪付)贷记卡交易总金额
                                QrCreditProfitRate = ProfitRate; //(云闪付)贷记卡交易分润比例
                                QrCreditTradeProfit = ProfitAmt; //(云闪付)贷记卡交易分润
                            }
                            else
                            {
                                NonQrCreditTradeAmt = TradeAmt; //(非云闪付)贷记卡交易总金额
                                NonQrCreditTradeProfit = ProfitAmt; //(非云闪付)贷记卡交易分润
                                if(sub.HelpFlag == 1)
                                {
                                    HelpCreditTradeProfit = ProfitAmt; //(扶持期)(非云闪付)贷记卡分润总金额
                                    HelpCreditProfitRate = ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                    HelpCreditTradeAmt = TradeAmt; //(扶持期)(非云闪付)贷记卡交易总金额
                                }
                                else if(sub.HelpFlag == 2)
                                {
                                    ProfitCreditTradeProfit = ProfitAmt; //(盈利期)(非云闪付)贷记卡分润总金额
                                    ProfitCreditProfitRate = ProfitRate; //(盈利期)(非云闪付)贷记卡商户交易对应分润比例
                                    ProfitCreditTradeAmt = TradeAmt; //(盈利期)(非云闪付)贷记卡交易总金额
                                }
                                else if(sub.HelpFlag == 3)
                                {
                                    ProfitCreditTradeProfit2 = ProfitAmt; //(盈利期)(非云闪付)贷记卡分润总金额
                                    ProfitCreditProfitRate2 = ProfitRate; //(盈利期)(非云闪付)贷记卡商户交易对应分润比例
                                    ProfitCreditTradeAmt2 = TradeAmt; //(盈利期)(非云闪付)贷记卡交易总金额
                                }
                                else
                                {
                                    NotHelpCreditTradeAmt = TradeAmt; //(非扶持期)(非云闪付)贷记卡交易总金额
                                    NotHelpCreditTradeProfit = ProfitAmt; //(非扶持期)(非云闪付)贷记卡分润总金额
                                    NotHelpCreditProfitRate = ProfitRate; //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                }
                            }
                                
                            db.ProfitRewardRecord.Add(new ProfitRewardRecord()
                            {
                                Version = 1,
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = sub.UserId, //创客
                                MerchantId = sub.MerchantId, //商户
                                BrandId = sub.BrandId, //品牌
                                ProfitType = sub.DirectFlag, //创客分润类型
                                TradeAmt = sub.TradeAmount, //商户交易总额
                                TradeProfit = sub.Money, //交易分润
                                TradeMonth = Month, //交易月
                                RecordNo = RecordNo, //记录单号
                                TopUserId = TopUserId, //顶级创客
                                CreditTradeAmt = CreditTradeAmt, //贷记卡交易总金额
                                QrCreditTradeAmt = QrCreditTradeAmt, //(云闪付)贷记卡交易总金额
                                NonQrCreditTradeAmt = NonQrCreditTradeAmt, //(非云闪付)贷记卡交易总金额
                                NotHelpCreditTradeAmt = NotHelpCreditTradeAmt, //(非扶持期)(非云闪付)贷记卡交易总金额
                                HelpCreditTradeAmt = HelpCreditTradeAmt, //(扶持期)(非云闪付)贷记卡交易总金额
                                DebitNonCapTradeAmt = DebitNonCapTradeAmt, //商户非封顶借记卡交易总额
                                QrDebitNotCapTradeAmt = QrDebitNotCapTradeAmt, //(云闪付)商户非封顶借记卡交易总额
                                NonQrDebitNotCapTradeAmt = NonQrDebitNotCapTradeAmt, //(非云闪付)商户非封顶借记卡交易总额
                                NotHelpDebitNonCapTradeAmt = NotHelpDebitNonCapTradeAmt, //(非扶持期)(非云闪付)借记卡非封顶交易总金额
                                HelpDebitNonCapTradeAmt = HelpDebitNonCapTradeAmt, //(扶持期)(非云闪付)借记卡非封顶交易总金额
                                DebitCapTradeAmt = DebitCapTradeAmt, //商户借记卡封顶交易总额
                                CreditTradeProfit = CreditTradeProfit, //贷记卡分润总金额
                                QrCreditTradeProfit = QrCreditTradeProfit, //(云闪付)贷记卡交易分润
                                NonQrCreditTradeProfit = NonQrCreditTradeProfit, //(非云闪付)贷记卡交易分润
                                NotHelpCreditTradeProfit = NotHelpCreditTradeProfit, //(非扶持期)(非云闪付)贷记卡分润总金额
                                HelpCreditTradeProfit = HelpCreditTradeProfit, //(扶持期)(非云闪付)贷记卡分润总金额
                                DebitNonTradeCapProfit = DebitNonTradeCapProfit, //借记卡非封顶交易分润总金额
                                QrDebitNonTradeCapProfit = QrDebitNonTradeCapProfit, //(云闪付)借记卡非封顶交易分润总金额
                                NonQrDebitNonTradeCapProfit = NonQrDebitNonTradeCapProfit, //(非云闪付)借记卡非封顶交易分润总金额
                                NotHelpDebitNonTradeCapProfit = NotHelpDebitNonTradeCapProfit, //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                HelpDebitNonTradeCapProfit = HelpDebitNonTradeCapProfit, //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
                                DebitTradeCapProfit = DebitTradeCapProfit, //借记卡封顶交易分润总金额
                                NotHelpCreditProfitRate = NotHelpCreditProfitRate, //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                NotHelpCreditProfitStandardRate = NotHelpCreditProfitStandardRate, //(非扶持期)(非云闪付)贷记卡标准分润比例
                                NotHelpCreditAddOrSubRate = NotHelpCreditAddOrSubRate, //(非扶持期)(非云闪付)贷记卡成本或增或减比例
                                HelpCreditProfitRate = HelpCreditProfitRate, //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
                                HelpCreditProfitStandardRate = HelpCreditProfitStandardRate, //(扶持期)(非云闪付)贷记卡-标准分润比例
                                HelpCreditAddOrSubRate = HelpCreditAddOrSubRate, //(扶持期)(非云闪付)贷记卡成本或增或减比例
                                NotHelpDebitProfitRate = NotHelpDebitProfitRate, //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
                                NotHelpDebitProfitStandardRate = NotHelpDebitProfitStandardRate, //(非扶持期)(非云闪付)借记卡标准分润比例
                                NotHelpDebitAddOrSubRate = NotHelpDebitAddOrSubRate, //(非扶持期)(非云闪付)借记卡成本或增或减比例
                                HelpDebitProfitRate = HelpDebitProfitRate, //(扶持期)(非云闪付)借记卡商户交易对应分润比例
                                HelpDebitProfitStandardRate = HelpDebitProfitStandardRate, //(扶持期)(非云闪付)借记卡-标准分润比例
                                HelpDebitAddOrSubRate = HelpDebitAddOrSubRate, //(扶持期)(非云闪付)借记卡成本或增或减比例
                                DebitCapSingleReward = DebitCapSingleReward, //借记卡合伙人直营封顶交易奖励金额
                                QrCreditProfitRate = QrCreditProfitRate, //(云闪付)贷记卡交易分润比例
                                QrCreditProfitStandardRate = QrCreditProfitStandardRate, //(云闪付)贷记卡分润基准
                                QrCreditAddOrSubRate = QrCreditAddOrSubRate, //(云闪付)贷记卡分润比例或增或减
                                QrDebitProfitRate = QrDebitProfitRate, //(云闪付)借记卡非封顶交易分润比例
                                QrDebitProfitStandardRate = QrDebitProfitStandardRate, //(云闪付)借记卡非封顶交易分润基准
                                QrDebitAddOrSubRate = QrDebitAddOrSubRate, //(云闪付)借记卡非封顶交易分润比例或增或减
                                ProfitCreditTradeProfit = ProfitCreditTradeProfit,  //(盈利期)(非云闪付)贷记卡分润总金额
                                ProfitCreditProfitRate = ProfitCreditProfitRate, //(盈利期)(非云闪付)贷记卡商户交易对应分润比例
                                ProfitCreditTradeAmt = ProfitCreditTradeAmt, //(盈利期)(非云闪付)贷记卡交易总金额
                                ProfitCreditTradeProfit2 = ProfitCreditTradeProfit2,  //(盈利期)(非云闪付)贷记卡分润总金额
                                ProfitCreditProfitRate2 = ProfitCreditProfitRate2, //(盈利期)(非云闪付)贷记卡商户交易对应分润比例
                                ProfitCreditTradeAmt2 = ProfitCreditTradeAmt2, //(盈利期)(非云闪付)贷记卡交易总金额
                                ProfitDebitNonCapTradeAmt = ProfitDebitNonCapTradeAmt, //(盈利期)(非云闪付)借记卡非封顶交易总金额
                                ProfitDebitNonTradeCapProfit = ProfitDebitNonTradeCapProfit, //(盈利期)(非云闪付)借记卡非封顶交易分润总金额
                                ProfitDebitProfitRate = ProfitDebitProfitRate, //(盈利期)(非云闪付)借记卡商户交易对应分润比例
                            });
                        }
                        db.SaveChanges();
                        PageNum += 1;
                    }
                    else
                    {
                        op = false;
                    }
                }
                db.Dispose();
                rdb.Dispose();
            }
            catch(Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "分润监控异常");
            }
        }

        public List<ProfitResult> StartProftForSimByDate(string Month, int BrandId = 14, int PageNum = 1)
        {
            int PageSize = 200;
            int SkipNum = (PageNum - 1) * PageSize;
            string LimitString = " limit " + PageSize;
            if(PageNum > 1)
            {
                LimitString = " limit " + SkipNum + "," + PageSize;
            }
            List<ProfitResult> result = new List<ProfitResult>();
            ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
            if (obj.Status == 1) //判断分润是否开启
            {
                string sqlstr = "select UserId,sum(HelpDirectTradeAmt),sum(NotHelpDirectTradeAmt) from TradeDaySummaryBefore where TradeMonth='" + Month + "' and BrandId=14 and SeoTitle='self' group by UserId" + LimitString;
                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + sqlstr, "广电卡分润监控日志");
                DataTable dt = GetMainTable(sqlstr);
                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + dt.Rows.Count.ToString(), "广电卡分润监控日志");
                if(dt.Rows.Count > 0)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        WebCMSEntities dbnew = new WebCMSEntities();
                        try
                        {
                            int UserId = int.Parse(dr["UserId"].ToString());
                            List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
                            SubUser selfUser = GetUser(UserId, Month) ?? new SubUser();
                            int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
                            
                            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "", "广电卡分润监控日志");
                            decimal HelpDirectTradeAmt = decimal.Parse(dr[1].ToString()); //扶持期交易额
                            decimal NotHelpDirectTradeAmt = decimal.Parse(dr[2].ToString()); //稳定期交易额
                            int maxLevel = obj.MaxLevel; //最大等级
                            decimal diffLevelProfit = 0;  //等级级差
                            int curLevel = 0; //当前层级的会员等级
                            string ParentNav = selfUser.ParentNav;
                            if (string.IsNullOrEmpty(ParentNav))
                            {
                                ParentNav = ",0,";
                            }
                            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":" + ParentNav, "广电卡分润监控日志");
                            if (!string.IsNullOrEmpty(ParentNav))
                            {
                                ParentNav += "," + UserId + ",";
                                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                Array.Reverse(ParentNavList); //反转顺序
                                int level = 0;
                                DateTime now = DateTime.Now;
                                DateTime ThisMonth = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
                                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":扶持期:" + HelpDirectTradeAmt, "广电卡分润监控日志");
                                if (HelpDirectTradeAmt > 0)
                                {
                                    level = 0;
                                    curLevel = 0;
                                    diffLevelProfit = 0;  //等级级差
                                    decimal curProfit = 0;
                                    foreach (string UserIdString in ParentNavList)
                                    {
                                        level += 1;
                                        int uid = int.Parse(UserIdString);
                                        SubUser user = GetUser(uid, Month) ?? new SubUser();
                                        int UserLevel = GetUserLevel(user); //当前会员等级
                                        if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                        {
                                            break;
                                        }
                                        if (UserLevel <= maxLevel && UserLevel >= curLevel)
                                        {
                                            int LevelKindId = GetLevelKindId(BrandId, 1, 1);
                                            ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                            if (objlevel != null)
                                            {
                                                decimal getLevelProfit = 0;  //等级分润
                                                if (objlevel.Percents > 0)
                                                {
                                                    //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                                    getLevelProfit += HelpDirectTradeAmt * objlevel.Percents;
                                                }
                                                if (objlevel.AddProfitVal > 0)
                                                {
                                                    getLevelProfit += objlevel.AddProfitVal;
                                                }
                                                decimal money = getLevelProfit;
                                                getLevelProfit -= diffLevelProfit;
                                                if (objlevel.LevelDiff == 1)  //判断是否有级差
                                                {
                                                    diffLevelProfit = money;
                                                }
                                                if (getLevelProfit >= obj.MinProfitVal)
                                                {
                                                    int DirectFlag = selfUser.Id == user.Id ? 1 : 0;
                                                    result.Add(new ProfitResult()
                                                    {
                                                        UserId = user.Id,
                                                        UserNav = user.ParentNav,
                                                        Money = PublicFunction.NumberFormat(getLevelProfit),
                                                        ProfitRate = objlevel.Percents,
                                                        Message = "交易分润",
                                                        BankCardType = 0,
                                                        QrPayFlag = 0,
                                                        DirectFlag = DirectFlag,
                                                        BrandId = BrandId,
                                                        IsSubsidy = 0,
                                                        TradeAmount = HelpDirectTradeAmt,
                                                        HelpFlag = 1,
                                                    });
                                                    curProfit += getLevelProfit;
                                                    function.WriteLog(user.Id + "-" + UserLevel + "-" + HelpDirectTradeAmt + "-" + DirectFlag + "-扶持期分润:" + getLevelProfit, "广电卡分润监控日志");
                                                }
                                            }
                                        }
                                        if(curLevel < UserLevel)
                                        {
                                            curLevel = UserLevel;
                                        }
                                    }
                                }
                                function.WriteLog("------------------------", "广电卡分润监控日志");
                                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":稳定期:" + NotHelpDirectTradeAmt, "广电卡分润监控日志");
                                if (NotHelpDirectTradeAmt > 0)
                                {
                                    level = 0;
                                    curLevel = 0;
                                    diffLevelProfit = 0;  //等级级差
                                    foreach (string UserIdString in ParentNavList)
                                    {
                                        level += 1;
                                        int uid = int.Parse(UserIdString);
                                        SubUser user = GetUser(uid, Month) ?? new SubUser();
                                        int UserLevel = GetUserLevel(user); //当前会员等级
                                        if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
                                        {
                                            break;
                                        }
                                        if (UserLevel <= maxLevel && UserLevel > curLevel)
                                        {
                                            int LevelKindId = GetLevelKindId(BrandId, 0, 1);
                                            ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
                                            if (objlevel != null)
                                            {
                                                decimal getLevelProfit = 0;  //等级分润
                                                if (objlevel.Percents > 0)
                                                {
                                                    //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
                                                    getLevelProfit += NotHelpDirectTradeAmt * objlevel.Percents;
                                                }
                                                if (objlevel.AddProfitVal > 0)
                                                {
                                                    getLevelProfit += objlevel.AddProfitVal;
                                                }
                                                decimal money = getLevelProfit;
                                                getLevelProfit -= diffLevelProfit;
                                                if (objlevel.LevelDiff == 1)  //判断是否有级差
                                                {
                                                    diffLevelProfit = money;
                                                }
                                                if (getLevelProfit >= obj.MinProfitVal)
                                                {
                                                    result.Add(new ProfitResult()
                                                    {
                                                        UserId = user.Id,
                                                        UserNav = user.ParentNav,
                                                        Money = PublicFunction.NumberFormat(getLevelProfit),
                                                        ProfitRate = objlevel.Percents,
                                                        Message = "交易分润",
                                                        BankCardType = 0,
                                                        QrPayFlag = 0,
                                                        BrandId = BrandId,
                                                        DirectFlag = selfUser.Id == user.Id ? 1 : 0,
                                                        IsSubsidy = 0,
                                                        TradeAmount = NotHelpDirectTradeAmt,
                                                        HelpFlag = 0,
                                                    });
                                                }
                                            }
                                        }
                                        if(curLevel < UserLevel)
                                        {
                                            curLevel = UserLevel;
                                        }
                                    }
                                }
                                function.WriteLog("------------------------", "广电卡分润监控日志");
                            }
                            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + ":over", "广电卡分润监控日志");
                        }
                        catch (Exception ex)
                        {
                            function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "广电卡分润异常");
                        }
                        dbnew.Dispose();
                    }
                }
            }
            return result;
        }


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

        public int GetUserLevel(SubUser user)
        {
            int level = user.UserLevel;
            if(user.PreUserLevelBefore > level) level = user.PreUserLevelBefore;
            return level;
        }

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

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