统计交易额的地方统一加上盈利期

AppStart/Helper/Profit/ProfitCheckHelper.cs

@@ -191,8 +191,10 @@ namespace MySystem
                         {
                             decimal HelpTradeAmt = 0;
                             decimal NotHelpTradeAmt = 0;
+                            decimal ProfitTradeAmt = 0;
                             decimal HelpProfit = 0;
                             decimal NotHelpProfit = 0;
+                            decimal ProfitProfit = 0;
                             bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "self" && m.HelpDirectTradeAmt > 0);
                             if(check)
                             {
@@ -205,6 +207,12 @@ namespace MySystem
                                 NotHelpTradeAmt = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "self").Sum(m => m.NotHelpDirectTradeAmt);
                             }
                             LogString += "稳定期交易额：" + NotHelpTradeAmt + "\n";
+                            check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "self" && m.ProfitDirectTradeAmt > 0);
+                            if(check)
+                            {
+                                ProfitTradeAmt = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "self").Sum(m => m.ProfitDirectTradeAmt);
+                            }
+                            LogString += "盈利期交易额：" + ProfitTradeAmt + "\n";
                             if(HelpTradeAmt > 0)
                             {
                                 decimal percent = GetLevelProfit(BrandId, UserLevel, 1);
@@ -217,7 +225,13 @@ namespace MySystem
                                 NotHelpProfit = NotHelpTradeAmt * percent;
                                 LogString += "稳定期分润：" + NotHelpTradeAmt + " * " + percent + " = " + NotHelpProfit + "\n";
                             }
-                            TotalProfit += HelpProfit + NotHelpProfit;
+                            if(ProfitTradeAmt > 0)
+                            {
+                                decimal percent = GetLevelProfit(BrandId, UserLevel, 2);
+                                ProfitProfit = ProfitTradeAmt * percent;
+                                LogString += "盈利期分润：" + ProfitTradeAmt + " * " + percent + " = " + ProfitProfit + "\n";
+                            }
+                            TotalProfit += HelpProfit + NotHelpProfit + ProfitProfit;
                             LogString += "总分润：" + TotalProfit + "\n";
                         }
                         else
@@ -234,8 +248,10 @@ namespace MySystem
                                 {
                                     decimal HelpTradeAmt = 0;
                                     decimal NotHelpTradeAmt = 0;
+                                    decimal ProfitTradeAmt = 0;
                                     decimal HelpProfit = 0;
                                     decimal NotHelpProfit = 0;
+                                    decimal ProfitProfit = 0;
                                     bool check = db.TradeDaySummary.Any(m => m.UserId == subuser.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team" && m.HelpNonDirectTradeAmt > 0);
                                     if(check)
                                     {
@@ -248,6 +264,12 @@ namespace MySystem
                                         NotHelpTradeAmt = db.TradeDaySummary.Where(m => m.UserId == subuser.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team").Sum(m => m.NotHelpNonDirectTradeAmt);
                                     }
                                     LogString += "稳定期交易额：" + NotHelpTradeAmt + "\n";
+                                    check = db.TradeDaySummary.Any(m => m.UserId == subuser.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team" && m.ProfitNonDirectTradeAmt > 0);
+                                    if(check)
+                                    {
+                                        ProfitTradeAmt = db.TradeDaySummary.Where(m => m.UserId == subuser.Id && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team").Sum(m => m.ProfitNonDirectTradeAmt);
+                                    }
+                                    LogString += "盈利期交易额：" + ProfitTradeAmt + "\n";
 
                                     string UserIdString = "," + subuser.Id + ",";
                                     List<Users> busers = db.Users.Where(m => m.ParentNav.Contains(UserIdString) && m.AuthFlag == 1).ToList();
@@ -273,6 +295,7 @@ namespace MySystem
                                     }
                                     string LogHelpTradeAmt = HelpTradeAmt.ToString();
                                     string LogNotHelpTradeAmt = NotHelpTradeAmt.ToString();
+                                    string LogProfitTradeAmt = ProfitTradeAmt.ToString();
                                     if(busernavs.Count > 0)
                                     {
                                         LogString += "团队中等级超过K" + UserLevel + "：\n";
@@ -295,6 +318,7 @@ namespace MySystem
                                                 bool OtherCheck = db.TradeDaySummary.Any(m => m.UserId == busernav.UserId && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team" && m.HelpNonDirectTradeAmt > 0);
                                                 decimal OtherHelpTradeAmt = 0;
                                                 decimal OtherNotHelpTradeAmt = 0;
+                                                decimal OtherProfitTradeAmt = 0;
                                                 if(OtherCheck)
                                                 {
                                                     OtherHelpTradeAmt = db.TradeDaySummary.Where(m => m.UserId == busernav.UserId && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt);
@@ -304,12 +328,19 @@ namespace MySystem
                                                 {
                                                     OtherNotHelpTradeAmt = db.TradeDaySummary.Where(m => m.UserId == busernav.UserId && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team").Sum(m => m.NotHelpNonDirectTradeAmt);
                                                 }
+                                                OtherCheck = db.TradeDaySummary.Any(m => m.UserId == busernav.UserId && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team" && m.ProfitNonDirectTradeAmt > 0);
+                                                if(OtherCheck)
+                                                {
+                                                    OtherProfitTradeAmt = db.TradeDaySummary.Where(m => m.UserId == busernav.UserId && m.TradeMonth == Month && m.BrandId == BrandId && m.SeoTitle == "team").Sum(m => m.ProfitNonDirectTradeAmt);
+                                                }
                                                 HelpTradeAmt -= OtherHelpTradeAmt;
                                                 NotHelpTradeAmt -= OtherNotHelpTradeAmt;
+                                                ProfitTradeAmt -= OtherProfitTradeAmt;
                                                 LogString += "\n----创客编号：" + busernav.MakerCode + "，创客名称：" + busernav.RealName + "\n";
                                                 LogString += "----创客职级：" + busernav.UserLevel + "\n";
                                                 LogString += "----扶持期交易额：" + OtherHelpTradeAmt + "\n";
                                                 LogString += "----稳定期交易额：" + OtherNotHelpTradeAmt + "\n";
+                                                LogString += "----盈利期交易额：" + OtherProfitTradeAmt + "\n";
                                                 if(OtherHelpTradeAmt > 0)
                                                 {
                                                     LogHelpTradeAmt += " - " + OtherHelpTradeAmt;
@@ -318,6 +349,10 @@ namespace MySystem
                                                 {
                                                     LogNotHelpTradeAmt += " - " + OtherNotHelpTradeAmt;
                                                 }
+                                                if(OtherProfitTradeAmt > 0)
+                                                {
+                                                    LogProfitTradeAmt += " - " + OtherProfitTradeAmt;
+                                                }
                                             }
                                             ParentNavs.Add(ParentNav);
                                         }
@@ -344,7 +379,18 @@ namespace MySystem
                                         NotHelpProfit = NotHelpTradeAmt * (parentpercent - percent);
                                         LogString += "稳定期分润：" + LogNotHelpTradeAmt + " * (" + parentpercent + " - " + percent + ") = " + NotHelpProfit + "\n";
                                     }
-                                    decimal SubTotalProfit = HelpProfit + NotHelpProfit;
+                                    if(ProfitTradeAmt > 0)
+                                    {
+                                        decimal parentpercent = GetLevelProfit(BrandId, UserLevel, 2);
+                                        decimal percent = GetLevelProfit(BrandId, sUserLevel, 2);
+                                        if(LogProfitTradeAmt.Contains("-"))
+                                        {
+                                            LogProfitTradeAmt = "(" + LogProfitTradeAmt + ")";
+                                        }
+                                        ProfitProfit = ProfitTradeAmt * (parentpercent - percent);
+                                        LogString += "盈利期分润：" + LogProfitTradeAmt + " * (" + parentpercent + " - " + percent + ") = " + ProfitProfit + "\n";
+                                    }
+                                    decimal SubTotalProfit = HelpProfit + NotHelpProfit + ProfitProfit;
                                     TotalProfit += SubTotalProfit;
                                     LogString += "总分润：" + SubTotalProfit + "\n";
                                 }

AppStart/Helper/Profit/ProfitHelper.cs

@@ -1012,37 +1012,6 @@ namespace MySystem
 
 
 
-        #region POS重置交易额
-
-        public void resetTradeAmount()
-        {
-            Thread th = new Thread(resetTradeAmountDo);
-            th.IsBackground = true;
-            th.Start();
-        }
-        public void resetTradeAmountDo()
-        {
-            string PosSn = RedisDbconn.Instance.Get<string>("ResetTradeAmountList");
-            if (!string.IsNullOrEmpty(PosSn))
-            {
-                DateTime start = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
-                if (DateTime.Now.Day == 1)
-                { 
-                    start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
-                }
-                DateTime end = DateTime.Parse(DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + " 00:00:00");;
-                WebCMSEntities db = new WebCMSEntities();
-                var list = db.TradeRecord.Select(m => new { m.Id, m.CreateDate }).Where(m => m.CreateDate >= start && m.CreateDate < end).ToList();
-                foreach (var sub in list)
-                {
-                    StartListenTradeDo(sub.Id, false);
-                }
-                db.Dispose();
-            }
-        }
-
-        #endregion
-
         #region POS统计交易额
         public void StartListenTradeDo(int tradeId, bool profit = true)
         {

AppStart/Helper/StatService.cs

@@ -1428,204 +1428,9 @@ namespace MySystem
 
 
 
-        // 统计交易额V2
-        public void StartEverDayV2()
-        {
-            Thread th = new Thread(StartEverDayV2Do);
-            th.IsBackground = true;
-            th.Start();
-        }
-        public void StartEverDayV2Do()
-        {
-            while (true)
-            {
-                if(DateTime.Now.Hour >= 2)
-                {
-                    StatTradeAmountEverDayV2();
-                }
-                Thread.Sleep(100);
-            }
-        }
-        public void StatTradeAmountEverDayV2()
-        {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行交易额V2日志");
-            WebCMSEntities db = new WebCMSEntities();
-            using (var tran = db.Database.BeginTransaction())
-            {
-                try
-                {
-                    string startId = function.ReadInstance("/TradeRecord/Id.txt");
-                    if(string.IsNullOrEmpty(startId))
-                    {
-                        startId = "718574";
-                    }
-                    DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
-                    if(idsDt.Rows.Count > 0)
-                    {
-                        string ids = "";
-                        foreach (DataRow idsDr in idsDt.Rows)
-                        {
-                            ids += idsDr["Id"].ToString() + ",";
-                            startId = idsDr["Id"].ToString();
-                        }
-                        DataTable selfDt = OtherMySqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d')");
-                        if (selfDt.Rows.Count > 0)
-                        {
-                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时交易额V2日志");
-                            foreach (DataRow selfDr in selfDt.Rows)
-                            {
-                                int UserId = int.Parse(selfDr["UserId"].ToString());
-                                Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-                                string ParentNav = user.ParentNav; //selfDr["ParentNav"].ToString();
-                                int BrandId = int.Parse(selfDr["BrandId"].ToString());
-                                int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
-                                int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
-                                int MerHelpFlag = int.Parse(selfDr["MerHelpFlag"].ToString());
-                                int CapFlag = int.Parse(selfDr["CapFlag"].ToString());
-                                int VipFlag = int.Parse(selfDr["VipFlag"].ToString());
-                                int PayType = int.Parse(selfDr["PayType"].ToString());
-                                string TradeDate = selfDr[9].ToString();
-                                decimal TradeAmount = decimal.Parse(selfDr[10].ToString());
-                                int TradeCount = int.Parse(selfDr[11].ToString());
-                                string TradeMonth = TradeDate.Substring(0, 6);
-                                TradeDaySummary selfStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "self");
-                                if (selfStat == null)
-                                {
-                                    selfStat = db.TradeDaySummary.Add(new TradeDaySummary()
-                                    {
-                                        UserId = UserId,
-                                        TradeMonth = TradeMonth,
-                                        TradeDate = TradeDate,
-                                        BrandId = BrandId,
-                                        QueryCount = QrPayFlag,
-                                        VipFlag = VipFlag,
-                                        PayType = PayType,
-                                        SeoTitle = "self",
-                                    }).Entity;
-                                    db.SaveChanges();
-                                }
-                                if (BankCardType == 0)
-                                {
-                                    if (MerHelpFlag == 1)
-                                    {
-                                        selfStat.HelpDirectDebitTradeAmt += TradeAmount;
-                                        if (CapFlag == 1)
-                                        {
-                                            selfStat.HelpDirectDebitCapTradeAmt += TradeAmount;
-                                            selfStat.HelpDirectDebitCapNum += TradeCount;
-                                        }
-                                    }
-                                    else
-                                    {
-                                        selfStat.NotHelpDirectDebitTradeAmt += TradeAmount;
-                                        if (CapFlag == 1)
-                                        {
-                                            selfStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
-                                            selfStat.NotHelpDirectDebitCapNum += TradeCount;
-                                        }
-                                    }
-                                }
-                                else if (BankCardType != 0)
-                                {
-                                    if (MerHelpFlag == 1)
-                                    {
-                                        selfStat.HelpDirectTradeAmt += TradeAmount;
-                                    }
-                                    else
-                                    {
-                                        selfStat.NotHelpDirectTradeAmt += TradeAmount;
-                                    }
-                                }
-                                ParentNav += "," + UserId + ",";
-                                if (!string.IsNullOrEmpty(ParentNav))
-                                {
-                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-                                    foreach (string NavUserIdString in ParentNavList)
-                                    {
-                                        int NavUserId = int.Parse(NavUserIdString);
-                                        TradeDaySummary teamStat = db.TradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.VipFlag == VipFlag && m.PayType == PayType && m.SeoTitle == "team");
-                                        if (teamStat == null)
-                                        {
-                                            teamStat = db.TradeDaySummary.Add(new TradeDaySummary()
-                                            {
-                                                UserId = NavUserId,
-                                                TradeMonth = TradeMonth,
-                                                TradeDate = TradeDate,
-                                                BrandId = BrandId,
-                                                QueryCount = QrPayFlag,
-                                                VipFlag = VipFlag,
-                                                PayType = PayType,
-                                                SeoTitle = "team",
-                                            }).Entity;
-                                            db.SaveChanges();
-                                        }
-                                        if (BankCardType == 0)
-                                        {
-                                            if (MerHelpFlag == 1)
-                                            {
-                                                teamStat.HelpNonDirectDebitTradeAmt += TradeAmount;
-                                                if (CapFlag == 1)
-                                                {
-                                                    teamStat.HelpDirectDebitCapTradeAmt += TradeAmount;
-                                                    teamStat.HelpDirectDebitCapNum += TradeCount;
-                                                }
-                                            }
-                                            else
-                                            {
-                                                teamStat.NotHelpNonDirectDebitTradeAmt += TradeAmount;
-                                                if (CapFlag == 1)
-                                                {
-                                                    teamStat.NotHelpDirectDebitCapTradeAmt += TradeAmount;
-                                                    teamStat.NotHelpDirectDebitCapNum += TradeCount;
-                                                }
-                                            }
-                                        }
-                                        else if (BankCardType != 0)
-                                        {
-                                            if (MerHelpFlag == 1)
-                                            {
-                                                teamStat.HelpNonDirectTradeAmt += TradeAmount;
-                                            }
-                                            else
-                                            {
-                                                teamStat.NotHelpNonDirectTradeAmt += TradeAmount;
-                                            }
-                                        }
-                                    }
-                                }
-                            }
-                            OtherMySqlConn.op("update TradeRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
-                            function.WritePage("/TradeRecord/", "Id.txt", startId);
-                        }
-                        db.SaveChanges();
-                    }
-                    tran.Commit();
-                }
-                catch (Exception ex)
-                {
-                    tran.Rollback();
-                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天交易额V2异常");
-                }
-            }
-            db.Dispose();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行交易额V2日志");
-        }
-
-
         // 每天统计头一天的交易额
         public void StartEverDay(string date)
         {
-            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            // DateTime end = DateTime.Parse("2022-04-19 00:00:00");
-            // DateTime check = DateTime.Parse("2022-03-11");
-            // while (check <= end)
-            // {
-            //     Thread th = new Thread(StatTradeAmountEverDay);
-            //     th.IsBackground = true;
-            //     th.Start(check.ToString("yyyy-MM-dd"));
-            //     check = check.AddDays(1);
-            // }
             string TradeMonth = DateTime.Now.ToString("yyyyMM");
             if(DateTime.Now.Day == 1)
             {
@@ -2027,55 +1832,6 @@ namespace MySystem
             RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1");
         }
 
-        public void StatUserLevelStartTest()
-        {
-            Thread th = new Thread(StatUserLevelStartTestDo);
-            th.IsBackground = true;
-            th.Start();
-        }
-        public void StatUserLevelStartTestDo()
-        {
-            WebCMSEntities db = new WebCMSEntities();
-            try
-            {
-                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
-                DateTime start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
-                DateTime end = start.AddDays(1);
-                string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
-                List<UserLevelSet> sets = db.UserLevelSet.ToList();
-                List<int> uids = new List<int>();
-                uids.Add(6341);
-                foreach (int uid in uids)
-                {
-                    Users user = db.Users.FirstOrDefault(m => m.Id == uid);
-                    if (user != null)
-                    {
-                        int BeforeLevel = user.UserLevel;
-                        int AfterLevel = 0;
-                        decimal TradeAmount = 0;
-                        bool check = db.TradeDaySummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team");
-                        if (check)
-                        {
-                            TradeAmount = db.TradeDaySummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
-                        }
-                        function.WriteLog(user.Id.ToString() + "----" + TradeAmount, "创客升级业绩");
-                        UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount);
-                        if (set != null)
-                        {
-                            AfterLevel = set.Id;
-                        }
-                        function.WriteLog("update Users set UserLevel=" + AfterLevel + " where Id=" + user.Id.ToString() + ";", "创客升级日志");
-                    }
-                }
-                function.WriteLog(DateTime.Now.ToString(), "创客升级日志");
-            }
-            catch (Exception ex)
-            {
-                function.WriteLog(ex.ToString(), "创客升级异常");
-            }
-            db.Dispose();
-        }
-
 
         // 统计创客激活数
         public void StartPosActNum()
@@ -2691,48 +2447,6 @@ namespace MySystem
 
 
 
-        // 实时统计我的创客交易额
-        public void StatMyUserThisTrade()
-        {
-            Thread th = new Thread(StatMyUserThisTradeDo);
-            th.IsBackground = true;
-            th.Start();
-        }
-        public void StatMyUserThisTradeDo()
-        {
-            while (true)
-            {
-                if(DateTime.Now.Hour > 3)
-                {
-                    StatMyUserThisTradeListen();
-                }
-                int timespan = 1000 * 3600 * 3;
-                Thread.Sleep(timespan);
-            }
-        }
-        public void StatMyUserThisTradeListen()
-        {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            string TradeMonth = DateTime.Now.ToString("yyyyMM");
-            // if(DateTime.Now.Day == 1)
-            // {
-            //     TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
-            // }
-            DataTable list = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt) from (select UserId,HelpNonDirectTradeAmt,NotHelpNonDirectTradeAmt from TradeDaySummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId");
-            string sql = "";
-            foreach (DataRow dr in list.Rows)
-            {
-                string UserId = dr["UserId"].ToString();
-                string ThisMonthTrade = dr[1].ToString();
-                sql += "update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId + ";";
-            }
-            if(!string.IsNullOrEmpty(sql))
-            {
-                OtherMySqlConn.op(sql);
-            }
-        }
-
-
 
 
         #region 判断品牌互斥条件，根据身份证号

AppStart/Helper/TestService.cs

@@ -15,555 +15,5 @@ namespace MySystem
         private TestService()
         { }
 
-        public void Start()
-        {
-            Thread th = new Thread(ReduceMoreSubsidy);
-            th.IsBackground = true;
-            th.Start();
-        }
-
-        public void ResetTradeRecordUserId()
-        {
-            WebCMSEntities db = new WebCMSEntities();
-            List<int> posids = new List<int>();
-            posids.Add(13312);
-            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            foreach (int posid in posids)
-            {
-                PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posid);
-                if (pos != null)
-                {
-                    // OtherMySqlConn.op("update TradeRecord set UserId=" + pos.UserId + " where SnNo='" + pos.PosSn + "'");
-                    // function.WriteLog(DateTime.Now.ToString() + ":" + pos.UserId + "-" + pos.PosSn, "重置非商户型创客交易记录Id");
-                    RedisDbconn.Instance.AddList("TmpResetUserTradeQueue", pos.UserId + "#cut#2022-04-01 00:00:00#cut#2022-05-11 00:00:00#cut#" + pos.BrandId);
-                }
-            }
-            // // OtherMySqlConn.connstr = ;
-            db.Dispose();
-        }
-
-        public void StartReset()
-        {
-            Thread th = new Thread(doSomething);
-            th.IsBackground = true;
-            th.Start();
-        }
-
-        public void doSomething()
-        { 
-            while (true)
-            {
-                string content = RedisDbconn.Instance.RPop<string>("TmpResetUserTradeQueue");
-                if (!string.IsNullOrEmpty(content))
-                {
-                    try
-                    {
-                        OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-                        WebCMSEntities db = new WebCMSEntities();
-                        string[] datalist = content.Split(new string[] { "#cut#" }, StringSplitOptions.None);
-                        int UserId = int.Parse(datalist[0]);
-                        DateTime sdate = DateTime.Parse(datalist[1]);
-                        DateTime edate = DateTime.Parse(datalist[2]);
-                        int BrandId = int.Parse(datalist[3]);
-                        function.WriteLog(DateTime.Now.ToString(), "重置创客交易额");
-                        List<string> uids = new List<string>();
-                        DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id=" + UserId);
-                        if (userDt.Rows.Count > 0)
-                        {
-                            while (sdate <= edate)
-                            {
-                                string date = sdate.ToString("yyyy-MM-dd");
-                                string TradeDate = date.Replace("-", "");
-                                string TradeMonth = TradeDate.Substring(0, 6);
-                                string start = date + " 00:00:00";
-                                string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00";
-                                string startId = "0", endId = "9999999999";
-                                DataTable startDt = OtherMySqlConn.dtable("select min(Id) from TradeRecord where CreateDate>='" + start + "'");
-                                if (startDt.Rows.Count > 0)
-                                {
-                                    startId = startDt.Rows[0][0].ToString();
-                                }
-                                DataRow userDr = userDt.Rows[0];
-                                string ParentNav = userDr["ParentNav"].ToString();
-                                function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
-                                OtherMySqlConn.op("delete from UserTradeDaySummary where UserId=" + UserId + " and BrandId=" + BrandId + " and TradeMonth='" + TradeMonth + "' and TradeDate='" + TradeDate + "' and SeoTitle='self'");
-                                DataTable selfdt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " and BrandId=" + BrandId + " group by BrandId,BankCardType,QrPayFlag");
-                                function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
-                                foreach (DataRow selfDr in selfdt.Rows)
-                                {
-                                    int BankCardType = int.Parse(selfDr["BankCardType"].ToString());
-                                    int QrPayFlag = int.Parse(selfDr["QrPayFlag"].ToString());
-                                    decimal TradeAmount = decimal.Parse(selfDr[3].ToString());
-                                    UserTradeDaySummary selfStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "self");
-                                    if (selfStat == null)
-                                    {
-                                        selfStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
-                                        {
-                                            UserId = UserId,
-                                            TradeMonth = TradeMonth,
-                                            TradeDate = TradeDate,
-                                            BrandId = BrandId,
-                                            QueryCount = QrPayFlag,
-                                            SeoTitle = "self",
-                                        }).Entity;
-                                        db.SaveChanges();
-                                    }
-                                    if (BankCardType == 0)
-                                    {
-                                        selfStat.DirectDebitTradeAmt += TradeAmount;
-                                    }
-                                    else if (BankCardType != 0)
-                                    {
-                                        selfStat.DirectTradeAmt += TradeAmount;
-                                    }
-                                    db.SaveChanges();
-                                }
-                                if (!string.IsNullOrEmpty(ParentNav))
-                                {
-                                    ParentNav += "," + UserId + ",";
-                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-                                    foreach (string NavUserIdString in ParentNavList)
-                                    {
-                                        if (!uids.Contains(NavUserIdString + start))
-                                        {
-                                            uids.Add(NavUserIdString + start);
-                                            int NavUserId = int.Parse(NavUserIdString);
-                                            function.WriteLog(NavUserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
-                                            OtherMySqlConn.op("delete from UserTradeDaySummary where UserId=" + NavUserId + " and BrandId=" + BrandId + " and TradeMonth='" + TradeMonth + "' and TradeDate='" + TradeDate + "' and SeoTitle='team'");
-                                            DataTable teamDt = OtherMySqlConn.dtable("select BrandId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") and BrandId=" + BrandId + " group by BrandId,BankCardType,QrPayFlag");
-                                            function.WriteLog(NavUserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志");
-                                            foreach (DataRow teamDr in teamDt.Rows)
-                                            {
-                                                int BankCardType = int.Parse(teamDr["BankCardType"].ToString());
-                                                int QrPayFlag = int.Parse(teamDr["QrPayFlag"].ToString());
-                                                decimal TradeAmount = decimal.Parse(teamDr[3].ToString());
-                                                UserTradeDaySummary teamStat = db.UserTradeDaySummary.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId && m.QueryCount == QrPayFlag && m.SeoTitle == "team");
-                                                if (teamStat == null)
-                                                {
-                                                    teamStat = db.UserTradeDaySummary.Add(new UserTradeDaySummary()
-                                                    {
-                                                        UserId = NavUserId,
-                                                        TradeMonth = TradeMonth,
-                                                        TradeDate = TradeDate,
-                                                        BrandId = BrandId,
-                                                        QueryCount = QrPayFlag,
-                                                        SeoTitle = "team",
-                                                    }).Entity;
-                                                    db.SaveChanges();
-                                                }
-                                                if (BankCardType == 0)
-                                                {
-                                                    teamStat.NonDirectDebitTradeAmt += TradeAmount;
-                                                }
-                                                else if (BankCardType != 0)
-                                                {
-                                                    teamStat.NonDirectTradeAmt += TradeAmount;
-                                                }
-                                                db.SaveChanges();
-                                            }
-                                        }
-                                    }
-                                }
-                                sdate = sdate.AddDays(1);
-                                Thread.Sleep(200);
-                            }
-                        }
-                        db.Dispose();
-                        function.WriteLog(DateTime.Now.ToString() + "\r\n\r\n", "重置创客交易额");
-                    }
-                    catch (Exception ex)
-                    {
-                        function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "重置创客交易额异常");
-                    }
-                }
-                else
-                {
-                    Thread.Sleep(5000);
-                }
-            }
-        }
-
-
-
-        public void statTrade()
-        {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            WebCMSEntities db = new WebCMSEntities();
-            DataTable dt = OtherMySqlConn.dtable("select UserId,BrandId,MerchantId,QrPayFlag,PayType,VipFlag,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount) from TradeRecord where Id>=574439 and UserId>0 and MerchantId in (5962,32731,14396,14,855,2586,2911,1839,6368,2598,79,47,21884,3243,3259,11637,5082,9767,5381,7091,4652,16159,24752,6183,18417,5285,17980,20862,3678,6567,11,21529,2647,10799,9024,24367,17045,14977,17249,847,3901,35077,21982,4496,5121,1383,153,12051,13036,20036,24984,21155,4720,15512,26592,4073,15241,7981,7079,9853,23689,24284,23731,4103,5959,85,31,24936,23781,9566,5658,10898,4929,26997,248,15916,9444,4760,7022,8697,9754,3482,255,793,14351,14149,3049,13390,3796,9209,27862,656,2413,9017,1649,282,8,14112,16313,15545,5639,2809,3733,16717,11541,9774,18000,20341,20273,10047,16151,28510,20193,4650,2498,2597,23242,11325,34592,12362,29281,15165,208,2196,3709,2715,6494,16034,3368,17283,4513,3309,2979,2854,6497,251,17906,7598,2327,6856,2347,2675,4,10991,138,784,350,7961,3385,29349,23533,31893,5036,15382,6934,3778,5922,24357,6222,6755,8887) and CreateDate>='2022-06-01 00:00:00' and MerHelpFlag=1 and BankCardType!=0 and CreateDate<'2022-07-01 00:00:00' group by UserId,BrandId,MerchantId,QrPayFlag,PayType,VipFlag,DATE_FORMAT(CreateDate,'%Y%m%d') order by DATE_FORMAT(CreateDate,'%Y%m%d')");
-            List<string> IdBrands = new List<string>();
-            if(dt.Rows.Count > 0)
-            {
-                foreach(DataRow dr in dt.Rows)
-                {
-                    int UserId = int.Parse(dr["UserId"].ToString());
-                    int MerchantId = int.Parse(dr["MerchantId"].ToString());
-                    int BrandId = int.Parse(dr["BrandId"].ToString());
-                    int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString());
-                    int PayType = int.Parse(dr["PayType"].ToString());
-                    int VipFlag = int.Parse(dr["VipFlag"].ToString());
-                    string TradeDate = dr[6].ToString();
-                    decimal HelpDirectTradeAmt = decimal.Parse(dr[7].ToString());
-                    function.WriteLog("update TradeDaySummary set HelpDirectTradeAmt=HelpDirectTradeAmt-" + HelpDirectTradeAmt + ",NotHelpDirectTradeAmt=NotHelpDirectTradeAmt+" + HelpDirectTradeAmt + " where UserId=" + UserId + " and BrandId=" + BrandId + " and TradeDate='" + TradeDate + "' and QueryCount=" + QrPayFlag + " and PayType=" + PayType + " and VipFlag=" + VipFlag + " and SeoTitle='self';\n", "多余机器分润");
-                    Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-                    string ParentNav = user.ParentNav;
-                    ParentNav += "," + UserId + ",";
-                    if (!string.IsNullOrEmpty(ParentNav))
-                    {
-                        string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-                        foreach (string NavUserIdString in ParentNavList)
-                        {
-                            function.WriteLog("update TradeDaySummary set HelpNonDirectTradeAmt=HelpNonDirectTradeAmt-" + HelpDirectTradeAmt + ",NotHelpNonDirectTradeAmt=NotHelpNonDirectTradeAmt+" + HelpDirectTradeAmt + " where UserId=" + NavUserIdString + " and BrandId=" + BrandId + " and TradeDate='" + TradeDate + "' and QueryCount=" + QrPayFlag + " and PayType=" + PayType + " and VipFlag=" + VipFlag + " and SeoTitle='team';\n", "多余机器分润");
-                        }
-                    }
-
-                    List<ProfitResult> results = StartProftForPosByDate(BrandId, UserId, HelpDirectTradeAmt);
-                    foreach(ProfitResult result in results)
-                    {
-                        int DirectFlag = result.DirectFlag;
-                        function.WriteLog("update ProfitRecord set ProfitAmount=ProfitAmount-" + result.Money + " where UserId=" + result.UserId + " and SeoTitle='202206' and DirectFlag=" + DirectFlag + " and BrandId=" + BrandId + ";\n", "多余机器分润");
-                        function.WriteLog("update UserMachineData set TradeProfit=TradeProfit-" + result.Money + " where IdBrand='" + UserId + "_" + BrandId + "';\n", "多余机器分润");
-                    }
-                    if(!IdBrands.Contains(UserId+"-"+MerchantId))
-                    {
-                        IdBrands.Add(UserId + "-" + MerchantId);
-                        DataTable sub = OtherMySqlConn.dtable("select SubsidyProfit from ProfitSubsidyDetail where TradeMonth='202206' and SubsidyUserId=" + UserId + " and MerchantId=" + MerchantId + "");
-                        if(sub.Rows.Count > 0)
-                        {
-                            string SubsidyProfit = sub.Rows[0][0].ToString();
-                            function.WriteLog("delete from ProfitSubsidyDetail where TradeMonth='202206' and SubsidyUserId=" + UserId + " and MerchantId=" + MerchantId + ";\n", "多余机器分润");                    
-                            function.WriteLog("update UserMachineData set OtherProfit=OtherProfit-" + SubsidyProfit + " where IdBrand='" + UserId + "_" + BrandId + "';\n", "多余机器分润");
-                        }
-                    }
-                }
-            }
-            db.Dispose();
-        }
-
-        public List<ProfitResult> StartProftForPosByDate(int BrandId, int UserId, decimal HelpDirectTradeAmt)
-        {
-            List<ProfitResult> result = new List<ProfitResult>();
-            // ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
-            // if (obj.Status == 1) //判断分润是否开启
-            // {
-            //     WebCMSEntities dbnew = new WebCMSEntities();
-            //     try
-            //     {
-            //         List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
-            //         Users selfUser = dbnew.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-            //         int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
-            //         int maxLevel = obj.MaxLevel; //最大等级
-            //         decimal diffLevelProfit = 0;  //等级级差
-            //         int curLevel = 0; //当前层级的会员等级
-            //         string ParentNav = selfUser.ParentNav;
-            //         if (string.IsNullOrEmpty(ParentNav))
-            //         {
-            //             ParentNav = ",0,";
-            //         }
-            //         if (!string.IsNullOrEmpty(ParentNav))
-            //         {
-            //             ParentNav += "," + UserId + ",";
-            //             string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-            //             Array.Reverse(ParentNavList); //反转顺序
-            //             int level = 0;
-            //             DateTime now = DateTime.Now;
-            //             if (HelpDirectTradeAmt > 0)
-            //             {
-            //                 foreach (string UserIdString in ParentNavList)
-            //                 {
-            //                     level += 1;
-            //                     int uid = int.Parse(UserIdString);
-            //                     Users user = dbnew.Users.FirstOrDefault(m => m.Id == uid) ?? new Users();
-            //                     int UserLevel = user.UserLevel; //当前会员等级
-            //                     UserRankWhite rank = dbnew.UserRankWhite.FirstOrDefault(m => m.Id == user.Id && m.UpdateDate > now);
-            //                     if (rank != null)
-            //                     {
-            //                         if (rank.Rank > UserLevel)
-            //                         {
-            //                             UserLevel = rank.Rank;
-            //                         }
-            //                     }
-            //                     if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
-            //                     {
-            //                         break;
-            //                     }
-            //                     if (UserLevel <= maxLevel && UserLevel > curLevel)
-            //                     {
-            //                         int LevelKindId = ProfitHelperV2.Instance.GetLevelKindId(BrandId, 1, 1);
-            //                         ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
-            //                         int LevelKindId2 = ProfitHelperV2.Instance.GetLevelKindId(BrandId, 0, 1);
-            //                         ProfitObjectLevels objlevel2 = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId2 + ":" + UserLevel); //获取当前等级参数
-            //                         if (objlevel != null && objlevel2 != null)
-            //                         {
-            //                             decimal getLevelProfit = 0;  //等级分润
-            //                             if (objlevel.Percents > 0 && objlevel2.Percents > 0)
-            //                             {
-            //                                 //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
-            //                                 getLevelProfit += HelpDirectTradeAmt * (objlevel.Percents - objlevel2.Percents);
-            //                             }
-            //                             decimal money = getLevelProfit;
-            //                             getLevelProfit -= diffLevelProfit;
-            //                             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 = 1,
-            //                                     DirectFlag = selfUser.Id == user.Id ? 1 : 0,
-            //                                     BrandId = BrandId,
-            //                                     IsSubsidy = 0,
-            //                                     TradeAmount = HelpDirectTradeAmt,
-            //                                     HelpFlag = 1,
-            //                                 });
-            //                             }
-            //                         }
-            //                     }
-            //                     curLevel = UserLevel;
-            //                 }
-            //             }
-            //         }
-            //     }
-            //     catch (Exception ex)
-            //     {
-            //         function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
-            //     }
-            //     dbnew.Dispose();
-            // }
-            return result;
-        }
-    
-    
-        public void helpprofit()
-        {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            DataTable dt = OtherMySqlConn.dtable("select Id,KqMerNo from PosMerchantInfo where Id in (select MerchantId from HelpProfitMerchantForUser) and BrandId!=1");
-            foreach(DataRow dr in dt.Rows)
-            {
-                int MerchantId = int.Parse(dr["Id"].ToString());
-                string KqMerNo = dr["KqMerNo"].ToString();
-                int Id = RedisDbconn.Instance.RPop<int>("HelpProfitMerchantIds");
-                if(Id > 0)
-                {
-                    OtherMySqlConn.op("update HelpProfitMerIds set MerchantId=" + Id + " where MerchantId=" + MerchantId + "");
-                    OtherMySqlConn.op("update PosMerchantInfo set SeoKeyword='' where Id=" + MerchantId);
-                    OtherMySqlConn.op("update PosMerchantInfo set SeoKeyword='已被申领为商机' where Id=" + Id);
-                    OtherMySqlConn.op("update PosCoupons set HelpProfitMerchantId=" + Id + " where HelpProfitMerchantId=" + MerchantId + "");
-                    OtherMySqlConn.op("update HelpProfitMerchantForUser set MerchantId=" + Id + ",Sort=1,MerNo='" + KqMerNo + "' where MerchantId=" + MerchantId + "");
-                }
-            }
-        }
-
-
-        #region 每月交易额统计
-        public void tradeAmt()
-        {
-            while(true)
-            {
-                if(DateTime.Now.Hour > 4)
-                {
-                    tradeAmtDo();
-                }
-                Thread.Sleep(60000);
-            }
-        }
-        public void tradeAmtDo()
-        {
-            function.WriteLog("start:" + DateTime.Now.ToString(), "每月交易额统计");
-            string month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
-            string html = "<table>";
-            html += "<tr>";
-            html += "<td>创客编号</td>";
-            html += "<td>创客名称</td>";
-            html += "<td>创客身份证号</td>";
-            html += "<td>创客手机号</td>";
-            html += "<td>顶级创客编号</td>";
-            html += "<td>顶级创客名称</td>";
-            html += "<td>交易额</td>";
-            html += "<td>最大市场交易额</td>";
-            html += "</tr>";
-            WebCMSEntities db = new WebCMSEntities();
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where Id>=2194025 and TradeMonth='" + month + "' and SeoTitle='team' group by UserId having sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt)>=3000000 and sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt)<10000000");
-            function.WriteLog("总数:" + dt.Rows.Count, "每月交易额统计");
-            foreach(DataRow dr in dt.Rows)
-            {
-                int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
-                decimal TradeAmt = decimal.Parse(function.CheckNum(dr[1].ToString()));
-                decimal MaxTradeAmt = 0;
-                List<decimal> subTradeAmtList = new List<decimal>();
-                DataTable subdt = OtherMySqlConn.dtable("select Id from Users where ParentUserId=" + UserId + " and AuthFlag=1");
-                foreach(DataRow subdr in subdt.Rows)
-                {
-                    int SubUserId = int.Parse(function.CheckInt(subdr["Id"].ToString()));
-                    decimal subTradeAmt = 0;
-                    DataTable subuserdt = OtherMySqlConn.dtable("select sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectCreditTradeAmt+NotHelpNonDirectCreditTradeAmt) from TradeDaySummary where Id>=2194025 and TradeMonth='" + month + "' and SeoTitle='team' and UserId=" + SubUserId);
-                    if(subuserdt.Rows.Count > 0)
-                    {
-                        subTradeAmt = decimal.Parse(function.CheckNum(subuserdt.Rows[0][0].ToString()));
-                    }
-                    subTradeAmtList.Add(subTradeAmt);
-                }
-                if(subTradeAmtList.Count > 0)
-                {
-                    MaxTradeAmt = subTradeAmtList.Max(m => m);
-                }
-                Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-                int TopUserId = 0;
-                string ParentNav = user.ParentNav;
-                if (!string.IsNullOrEmpty(ParentNav))
-                {
-                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-                    if (ParentNavList.Length > 1)
-                    {
-                        TopUserId = int.Parse(ParentNavList[1]);
-                    }
-                    else if (ParentNavList.Length == 1)
-                    {
-                        TopUserId = int.Parse(ParentNavList[0]);
-                    }
-                }
-                Users tuser = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
-                html += "<tr>";
-                html += "<td>" + user.MakerCode + "</td>";
-                html += "<td>" + user.RealName + "</td>";
-                html += "<td>" + user.CertId + "</td>";
-                html += "<td>" + user.Mobile + "</td>";
-                html += "<td>" + tuser.MakerCode + "</td>";
-                html += "<td>" + tuser.RealName + "</td>";
-                html += "<td>" + TradeAmt + "</td>";
-                html += "<td>" + MaxTradeAmt + "</td>";
-                html += "</tr>";
-                function.WriteLog(DateTime.Now.ToString(), "每月交易额统计");
-                function.WriteLog(UserId.ToString(), "每月交易额统计");
-            }
-            html += "</table>";
-            db.SaveChanges();
-            function.WritePage("/htmlfile/", month + ".html", html);
-            function.WriteLog("end:" + DateTime.Now.ToString(), "每月交易额统计");
-        }
-        #endregion
-
-        #region 查找8月多余补贴
-
-        // public void Subsidy()
-        // {
-        //     while(true)
-        //     {
-        //         if(DateTime.Now.Hour > 4)
-        //         {
-        //             SubsidyDo();
-        //         }
-        //         Thread.Sleep(60000);
-        //     }
-        // }
-        public void SubsidyDo()
-        {
-            WebCMSEntities db = new WebCMSEntities();
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            DataTable dt = OtherMySqlConn.dtable("select UserId,ProductType,ChangeAmount from UserAccountRecord where ChangeType=111 and CreateDate>='2022-09-01 00:00:00' and CreateDate<'2022-10-01 00:00:00' order by Id");
-            function.WriteLog("总数:" + dt.Rows.Count, "查找8月多余补贴");
-            foreach(DataRow dr in dt.Rows)
-            {
-                int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
-                int ProductType = int.Parse(function.CheckInt(dr["ProductType"].ToString()));
-                decimal ChangeAmount = decimal.Parse(function.CheckNum(dr["ChangeAmount"].ToString()));
-                decimal CheckAmount = 0;
-                DataTable checkdt = OtherMySqlConn.dtable("select sum(SubsidyProfit) from ProfitSubsidyExport2 where MakerCode=(select MakerCode from Users where Id=" + UserId + ") and BrandName=(select Name from KqProducts where Id=" + ProductType + ")");
-                if(checkdt.Rows.Count > 0)
-                {
-                    CheckAmount = decimal.Parse(function.CheckNum(checkdt.Rows[0][0].ToString()));
-                    if(ChangeAmount - CheckAmount > 1 && CheckAmount > 0)
-                    {
-                        decimal LastAmount = ChangeAmount - CheckAmount;
-                        function.WriteLog("差异分润:UserId:" + UserId + ";ProductType:" + ProductType + ";ChangeAmount:" + ChangeAmount + ";CheckAmount:" + CheckAmount + ";LastAmount:" + LastAmount + ";", "查找8月多余补贴");
-                    }
-                    else
-                    {
-                        function.WriteLog("多余分润:UserId:" + UserId + ";ProductType:" + ProductType + ";ChangeAmount:" + ChangeAmount + ";", "查找8月多余补贴");
-                    }
-                }
-                else
-                {
-                    function.WriteLog("多余分润:UserId:" + UserId + ";ProductType:" + ProductType + ";ChangeAmount:" + ChangeAmount + ";", "查找8月多余补贴");
-                }
-            }
-            db.Dispose();
-        }
-
-        #endregion
-
-        #region 重置开机奖励流量分佣
-
-        public void resetOpenPrize()
-        {
-            string doDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
-            string flag = function.ReadInstance("/Stat/" + doDate + ".txt");
-            if (string.IsNullOrEmpty(flag))
-            {
-                function.WritePage("/Stat/", doDate + ".txt", DateTime.Now.ToString("HH:mm:ss"));
-                OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-                // StatService.Instance.StartEverDay(doDate);
-                // StatService.Instance.StatMerchantTrade(doDate);
-                // StatService.Instance.dosomething4(doDate);
-                // StatService.Instance.ListenFluxRecord(doDate);
-            }
-        }
-
-        #endregion
-    
-
-        #region 扣8月多余补贴
-
-        public void ReduceMoreSubsidy()
-        {
-            WebCMSEntities db = new WebCMSEntities();
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-            DataTable dt = OtherMySqlConn.dtable("select UserId,sum(MoreMoney) from SubsidyCheck where Status=0 group by UserId");
-            foreach(DataRow dr in dt.Rows)
-            {
-                int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
-                decimal MoreMoney = decimal.Parse(function.CheckNum(dr[1].ToString()));
-                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
-                if (account != null)
-                {
-                    if(account.BalanceAmount >= MoreMoney)
-                    {
-                        decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-                        decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-                        decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-                        account.BalanceAmount -= MoreMoney;
-                        decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-                        decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-                        decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-                        db.SaveChanges();
-                        UserAccountRecord accountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
-                        {
-                            CreateDate = DateTime.Now,
-                            UpdateDate = DateTime.Now,
-                            UserId = UserId, //创客
-                            ChangeType = 63, //变动类型
-                            ChangeAmount = MoreMoney, //变更金额
-                            BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
-                            AfterTotalAmount = AfterTotalAmount, //变更后总金额
-                            BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
-                            AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
-                            BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
-                            AfterBalanceAmount = AfterBalanceAmount, //变更后余额
-                            Remark = "9月多发补贴扣减",
-                        }).Entity;
-                        db.SaveChanges();
-                        OtherMySqlConn.op("update SubsidyCheck set Status=1 where UserId=" + UserId);
-                    }
-                }
-            }
-            db.Dispose();
-        }
-
-        #endregion
-
     }
 }

AppStart/Timer/TestHelper.cs

@@ -72,182 +72,4 @@ public class TestHelper
         function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志");
     }
 
-    //统计团队交易额（小市场）
-    public void teamTrade()
-    {
-        Dictionary<int, decimal> userdic = new Dictionary<int, decimal>();
-        WebCMSEntities db = new WebCMSEntities();
-        OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-        function.WriteLog("start:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "团队交易额名单");
-        DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectDebitTradeAmt) from TradeDaySummary where TradeMonth='202208' and SeoTitle='team' group by UserId");
-        function.WriteLog("ready:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "团队交易额名单");
-        foreach(DataRow dr in dt.Rows)
-        {
-            int UserId = int.Parse(function.CheckInt(dr["UserId"].ToString()));
-            decimal TradeAmount = decimal.Parse(function.CheckNum(dr[1].ToString()));
-            userdic.Add(UserId, TradeAmount);
-        }
-        function.WriteLog("1:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "团队交易额名单");
-        Dictionary<int, decimal> userdic1 = userdic.Where(m => m.Value >= 3000000 && m.Value <= 10000000).ToDictionary(m => m.Key, m => m.Value);
-        function.WriteLog("3000000:" + userdic1.Count(), "团队交易额名单");
-        foreach(int UserId in userdic1.Keys)
-        {
-            decimal curTotal = userdic1[UserId];
-            List<int> ids = new List<int>();
-            Users self = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-            int TopUserId = 0;
-            if (!string.IsNullOrEmpty(self.ParentNav))
-            {
-                string uidstring = self.ParentNav.Trim(',').Replace(",,", ",");
-                string[] uidlist = uidstring.Split(',');
-                if (uidlist.Length > 1)
-                {
-                    TopUserId = int.Parse(function.CheckInt(uidlist[1]));
-                }
-                else
-                { 
-                    TopUserId = int.Parse(function.CheckInt(uidlist[0]));
-                }
-            }
-            Users top = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
-            var users = db.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == UserId).ToList();
-            foreach(var user in users)
-            {
-                ids.Add(user.Id);
-            }
-            int index = 0;
-            decimal totalAmt = 0;
-            decimal maxAmt = 0;
-            Dictionary<int, decimal> dic = userdic.Where(m => ids.Contains(m.Key)).OrderByDescending(m => m.Value).ToDictionary(m => m.Key, m => m.Value);
-            foreach(int key in dic.Keys)
-            {
-                index += 1;
-                if(index > 1)
-                {
-                    totalAmt += dic[key];
-                }
-                else
-                {
-                    maxAmt = dic[key];
-                }
-            }
-            if(totalAmt >= 1200000)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额300万-1000万且小市场大于120万的名单");
-            }
-            if(totalAmt >= curTotal * 0.4M)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额300万-1000万且小市场大于40%的名单");
-            }
-            function.WriteLog(UserId.ToString(), "团队交易额名单");
-        }
-        Dictionary<int, decimal> userdic2 = userdic.Where(m => m.Value >= 10000000 && m.Value <= 100000000).ToDictionary(m => m.Key, m => m.Value);
-        function.WriteLog("10000000:" + userdic2.Count(), "团队交易额名单");
-        foreach(int UserId in userdic2.Keys)
-        {
-            decimal curTotal = userdic2[UserId];
-            List<int> ids = new List<int>();
-            Users self = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-            int TopUserId = 0;
-            if (!string.IsNullOrEmpty(self.ParentNav))
-            {
-                string uidstring = self.ParentNav.Trim(',').Replace(",,", ",");
-                string[] uidlist = uidstring.Split(',');
-                if (uidlist.Length > 1)
-                {
-                    TopUserId = int.Parse(function.CheckInt(uidlist[1]));
-                }
-                else
-                { 
-                    TopUserId = int.Parse(function.CheckInt(uidlist[0]));
-                }
-            }
-            Users top = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
-            var users = db.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == UserId).ToList();
-            foreach(var user in users)
-            {
-                ids.Add(user.Id);
-            }
-            int index = 0;
-            decimal totalAmt = 0;
-            decimal maxAmt = 0;
-            Dictionary<int, decimal> dic = userdic.Where(m => ids.Contains(m.Key)).OrderByDescending(m => m.Value).ToDictionary(m => m.Key, m => m.Value);
-            foreach(int key in dic.Keys)
-            {
-                index += 1;
-                if(index > 1)
-                {
-                    totalAmt += dic[key];
-                }
-                else
-                {
-                    maxAmt = dic[key];
-                }
-            }
-            if(totalAmt >= 4000000)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额1000万-1亿且小市场大于400万的名单");
-            }
-            if(totalAmt >= curTotal * 0.4M)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额1000万-1亿且小市场大于40%的名单");
-            }
-            function.WriteLog(UserId.ToString(), "团队交易额名单");
-        }
-        Dictionary<int, decimal> userdic3 = userdic.Where(m => m.Value >= 100000000).ToDictionary(m => m.Key, m => m.Value);
-        function.WriteLog("100000000:" + userdic3.Count(), "团队交易额名单");
-        foreach(int UserId in userdic3.Keys)
-        {
-            decimal curTotal = userdic3[UserId];
-            List<int> ids = new List<int>();
-            Users self = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-            int TopUserId = 0;
-            if (!string.IsNullOrEmpty(self.ParentNav))
-            {
-                string uidstring = self.ParentNav.Trim(',').Replace(",,", ",");
-                string[] uidlist = uidstring.Split(',');
-                if (uidlist.Length > 1)
-                {
-                    TopUserId = int.Parse(function.CheckInt(uidlist[1]));
-                }
-                else
-                { 
-                    TopUserId = int.Parse(function.CheckInt(uidlist[0]));
-                }
-            }
-            Users top = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
-            var users = db.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == UserId).ToList();
-            foreach(var user in users)
-            {
-                ids.Add(user.Id);
-            }
-            int index = 0;
-            decimal totalAmt = 0;
-            decimal maxAmt = 0;
-            Dictionary<int, decimal> dic = userdic.Where(m => ids.Contains(m.Key)).OrderByDescending(m => m.Value).ToDictionary(m => m.Key, m => m.Value);
-            foreach(int key in dic.Keys)
-            {
-                index += 1;
-                if(index > 1)
-                {
-                    totalAmt += dic[key];
-                }
-                else
-                {
-                    maxAmt = dic[key];
-                }
-            }
-            if(totalAmt >= 40000000)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额1亿以上且小市场大于4000万的名单");
-            }
-            if(totalAmt >= curTotal * 0.4M)
-            {
-                function.WriteLog(self.MakerCode + "--" + self.RealName + "--" + self.Mobile + "--" + top.MakerCode + "--" + top.RealName + "--" + top.Mobile + "--" + curTotal + "--" + maxAmt + "--" + totalAmt, "团队交易额1亿以上且小市场大于40%的名单");
-            }
-            function.WriteLog(UserId.ToString(), "团队交易额名单");
-        }
-        db.Dispose();
-        function.WriteLog("end:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "团队交易额名单");
-    }
 }

Controllers/HomeController.cs

@@ -753,128 +753,6 @@ namespace MySystem.Controllers
             return result;
         }
 
-        // 翻倍奖888
-        public string prize888v2()
-        {
-            WebCMSEntities maindb = new WebCMSEntities();
-            List<int> userIdList = new List<int>();
-            string html = "<table>";
-            DateTime StartDate = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
-            DateTime EndDate = StartDate.AddMonths(1);
-            var orders = maindb.Orders.Select(m => new { m.UserId, m.TotalPrice, m.Status, m.PayDate }).Where(m => m.PayDate >= StartDate && m.PayDate < EndDate && m.TotalPrice == 88 && m.Status > 0).ToList();
-            foreach (var order in orders)
-            {
-                userIdList.Add(order.UserId);
-            }
-            foreach (int UserId in userIdList)
-            {
-                Users myuser = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
-                var lastmonth = DateTime.Now.AddMonths(-2).ToString("yyyyMM");
-                var thismonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
-                DateTime start = DateTime.Now.AddDays(1 - DateTime.Now.Day).Date;
-                DateTime end = DateTime.Now.AddDays(1 - DateTime.Now.Day).Date.AddMonths(1).AddSeconds(-1);
-                string UserIdString = "," + UserId + ",";
-                List<Users> users = maindb.Users.Where(m => m.ParentNav.Contains(UserIdString) || m.Id == UserId).ToList();
-                List<int> uids = new List<int>();
-                List<int> uids2 = new List<int>();
-                foreach (var user in users)
-                {
-                    uids.Add(user.Id);
-                }
-                var suborders = orders.Where(m => uids.Contains(m.UserId)).ToList();
-                foreach (var suborder in suborders)
-                {
-                    uids2.Add(suborder.UserId);
-                }
-                users = users.Where(m => uids2.Contains(m.Id)).ToList();
-                List<ProgressUserList> list = new List<ProgressUserList>();
-                foreach (Users user in users)
-                {
-                    int IsOk = 0;//是否达标(0-否 1-是)
-                    decimal lastMonthAmt = maindb.TradeDaySummary.Where(m => m.TradeMonth == lastmonth && m.SeoTitle == "team" && m.UserId == user.Id).Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
-                    decimal thisMonthAmt = maindb.TradeDaySummary.Where(m => m.TradeMonth == thismonth && m.SeoTitle == "team" && m.UserId == user.Id).Sum(m => m.HelpNonDirectTradeAmt + m.NotHelpNonDirectTradeAmt);
-                    if (thisMonthAmt >= lastMonthAmt * 2 && thisMonthAmt >= 2000000)
-                    {
-                        IsOk = 1;
-                    }
-                    ProgressUserList item = new ProgressUserList()
-                    {
-                        LastMonth = lastMonthAmt,
-                        ThisMonth = thisMonthAmt,
-                        UserId = user.Id,
-                        ParentNav = user.ParentNav,
-                        IsOk = IsOk,
-                    };
-                    list.Add(item);
-                }
-                list = list.OrderBy(m => m.ParentNav).ToList();
-                int index = 0;
-                decimal selfTrade = 0; // 自己的本月交易额
-                decimal lastTrade = 0; // 自己的上月交易额
-                decimal totalTrade = 0; // 自己的本月目标交易额
-                string selfNav = ""; // 自己的ParentNav
-                List<string> ParentNavs = new List<string>();
-                if (list.Count > 0)
-                {
-                    foreach (ProgressUserList sub in list)
-                    {
-                        index += 1;
-                        if (index == 1)
-                        {
-                            selfTrade = sub.ThisMonth;
-                            lastTrade = sub.LastMonth;
-                            totalTrade = lastTrade * 2;
-                            selfNav = sub.ParentNav + "," + sub.UserId + ",";
-                        }
-                        else
-                        {
-                            bool op = true; //是否满足条件
-                            string ParentNav = sub.ParentNav + "," + sub.UserId + ",";
-                            foreach (string subNav in ParentNavs)
-                            {
-                                if (ParentNavs.Contains(ParentNav) && ParentNav != subNav)
-                                {
-                                    op = false;
-                                }
-                            }
-                            if (op)
-                            {
-                                if (sub.IsOk == 1)
-                                {
-                                    selfTrade -= sub.ThisMonth;
-                                    totalTrade -= sub.ThisMonth;
-                                }
-                            }
-                            ParentNavs.Add(ParentNav);
-                        }
-                    }
-                }
-                if (lastTrade * 2 < 2000000 || selfTrade == 0 || totalTrade < 2000000)
-                {
-                    totalTrade = 2000000;
-                }
-                html += "<tr>";
-                html += "<td>" + myuser.MakerCode + "</td>";
-                html += "<td>" + myuser.RealName + "</td>";
-                html += "<td>" + selfTrade + "</td>";
-                html += "<td>" + lastTrade + "</td>";
-                html += "<td>" + totalTrade + "</td>";
-                if (selfTrade >= totalTrade)
-                {
-                    html += "<td>满足条件</td>";
-                }
-                else
-                {
-                    html += "<td>未满足条件</td>";
-                }
-                html += "</tr>";
-            }
-            html += "</table>";
-            maindb.Dispose();
-            return html;
-        }
-
-
         // 大盟主标记扫描
         public string leaderflag()
         {