using System; using System.Threading; using System.Linq; using System.Data; using Library; using LitJson; using System.Collections.Generic; using MySystem.PxcModels; namespace MySystem { public class LeaderCompPrizeHelper { public readonly static LeaderCompPrizeHelper Instance = new LeaderCompPrizeHelper(); private LeaderCompPrizeHelper() { } public void Start()//启动 { Thread thread = new Thread(Listen); thread.IsBackground = true; thread.Start(); } public void Listen()//启动 { while(true) { if(DateTime.Now.Hour > 0 && DateTime.Now.Hour < 3) { if(DateTime.Now.Month == 1) { CustomerSqlConn.op("insert into LeaderCompTradeStatBak select * from LeaderCompTradeStat;insert into LeaderCompTmpBak select * from LeaderCompTmp;insert into LeaderCompPrizeBak select * from LeaderCompPrize;", MysqlConn.SqlConnStr); } Ready(DateTime.Now.ToString("yyyy-MM")); } Thread.Sleep(60000); } // doSomething("202306", "202305"); // doSomething("202306", "202206"); // doSomething("202305", "202206"); // SendPrize("202306", "202305"); // SendPrize("202306", "202206"); // SendPrize("202305", "202206"); } public void Ready(string curMonth) { CustomerSqlConn.op("delete from LeaderCompTradeStat;delete from LeaderCompTmp;delete from LeaderCompPrize;", MysqlConn.SqlConnStr); Thread.Sleep(10000); DateTime Start = DateTime.Parse("2023-06-01 00:00:00"); DateTime now = DateTime.Parse(curMonth + "-01 00:00:00"); while(now > Start) { string month = now.ToString("yyyyMM"); string checkMonth = Start.ToString("yyyyMM"); doSomething(month, checkMonth); now = now.AddMonths(-1); } now = DateTime.Parse(curMonth + "-01 00:00:00"); while(now > Start) { string month = now.ToString("yyyyMM"); string checkMonth = Start.ToString("yyyyMM"); SendPrize(month, checkMonth); now = now.AddMonths(-1); } } public void doSomething(string month, string checkMonth) { try { WebCMSEntities db = new WebCMSEntities(); OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities(); string MonthString = month + "-" + checkMonth; //统计交易增量 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); DataTable dt = CustomerSqlConn.dtable("select CONCAT('insert into LeaderCompTradeStat (CreateDate,UserId,StatMonth,TradeAmount,SelfTradeAmount,CheckTradeAmount,CheckSelfTradeAmount) values (now(),', UserId,',\\\'" + month + "-" + checkMonth + "\\\',', amt" + month + ",',', samt" + month + ",',', amt" + checkMonth + ",',', samt" + checkMonth + ",');') from (select UserId,(case when amt" + month + " is null then 0 else amt" + month + " end) amt" + month + ",(case when samt" + month + " is null then 0 else samt" + month + " end) samt" + month + ",(case when amt" + checkMonth + " is null then 0 else amt" + checkMonth + " end) amt" + checkMonth + ",(case when samt" + checkMonth + " is null then 0 else samt" + checkMonth + " end) samt" + checkMonth + " from (select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) amt" + month + ",(select sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='team' and UserId=main.UserId) amt" + checkMonth + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + month + " where SeoTitle='self' and UserId=main.UserId) samt" + month + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='self' and UserId=main.UserId) samt" + checkMonth + " from TradeDaySummary" + month + " main where SeoTitle='team' and UserId>0 group by UserId) tb) tb2", MysqlConn.RdsStatSqlConnStr); string sql = ""; int num = 0; foreach(DataRow dr in dt.Rows) { sql += dr[0].ToString(); num += 1; if(num >= 200) { CustomerSqlConn.op(sql, MysqlConn.SqlConnStr); sql = ""; num = 0; } } if(!string.IsNullOrEmpty(sql)) { CustomerSqlConn.op(sql, MysqlConn.SqlConnStr); } CustomerSqlConn.op("update LeaderCompTradeStat leader set ParentUserId=case when (select ParentUserId from Users where Id=leader.UserId) is null then 0 else (select ParentUserId from Users where Id=leader.UserId) end,ParentNav=(select ParentNav from Users where Id=leader.UserId) where StatMonth='" + month + "-" + checkMonth + "' and UserId>1", MysqlConn.SqlConnStr); function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); //计算创客名下的达标人数，直推和间接 function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志"); List stats = db.LeaderCompTradeStat.Where(m => m.StatMonth == MonthString).ToList(); function.WriteLog(stats.Count.ToString(), "领导人达标奖励日志"); foreach(LeaderCompTradeStat stat in stats) { decimal totalAmount = stat.SelfTradeAmount - stat.CheckSelfTradeAmount; //当月交易 List directs = stats.Where(m => m.ParentUserId == stat.UserId).ToList(); foreach(LeaderCompTradeStat direct in directs) { decimal parentTotalAmount = direct.TradeAmount - direct.CheckTradeAmount; if(parentTotalAmount < 30000000) { totalAmount += parentTotalAmount; } } function.WriteLog("UserId:" + stat.UserId, "领导人达标奖励日志"); function.WriteLog("totalAmount:" + totalAmount, "领导人达标奖励日志"); if(totalAmount >= 30000000 && !string.IsNullOrEmpty(stat.ParentNav)) { LeaderCompTradeStat statEdit = db.LeaderCompTradeStat.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString); if(statEdit != null) { statEdit.ResultTradeAmount = totalAmount; db.SaveChanges(); } LeaderCompTmp tmp = db.LeaderCompTmp.FirstOrDefault(m => m.Id == stat.UserId); if(tmp == null) { tmp = db.LeaderCompTmp.Add(new LeaderCompTmp() { Id = stat.UserId, ParentUserId = stat.ParentUserId, ParentNav = stat.ParentNav }).Entity; db.SaveChanges(); } Dictionary EveryMonthData = new Dictionary(); if(!string.IsNullOrEmpty(tmp.EveryMonthData)) { EveryMonthData = Newtonsoft.Json.JsonConvert.DeserializeObject>(tmp.EveryMonthData); } if(!EveryMonthData.ContainsKey(MonthString)) { EveryMonthData.Add(MonthString, 1); } else { EveryMonthData[MonthString] = 1; } tmp.EveryMonthData = Newtonsoft.Json.JsonConvert.SerializeObject(EveryMonthData); db.SaveChanges(); string[] parents = stat.ParentNav.Trim(',').Replace(",,", ",").Split(','); Array.Reverse(parents); int index = 0; foreach(string parent in parents) { index += 1; int ParentUserId = int.Parse(function.CheckInt(parent)); LeaderCompPrize prize = db.LeaderCompPrize.FirstOrDefault(m => m.UserId == ParentUserId && m.StatMonth == MonthString); if(prize == null) { Users user = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users(); prize = db.LeaderCompPrize.Add(new LeaderCompPrize() { CreateDate = DateTime.Now, UserId = ParentUserId, ParentUserId = user.ParentUserId, ParentNav = user.ParentNav, StatMonth = MonthString, }).Entity; db.SaveChanges(); } if(index == 1) { prize.DirectCount += 1; } else { prize.NotDirectCount += 1; } db.SaveChanges(); } } function.WriteLog(DateTime.Now.ToString() + "------" + stat.UserId, "领导人达标奖励日志"); } function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); db.Dispose(); } catch(Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "领导达标人奖励异常"); } } private void SendPrize(string month, string checkDate) { string MonthFlag = month + "-" + checkDate; WebCMSEntities db = new WebCMSEntities(); OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities(); //计算运营中心或大盟主达标奖励 List leaderPrizes = db.LeaderCompPrize.Where(m => m.StatMonth == MonthFlag).ToList(); function.WriteLog(leaderPrizes.Count.ToString(), "领导人达标奖励日志"); foreach(LeaderCompPrize leaderPrize in leaderPrizes) { Users user = db.Users.FirstOrDefault(m => m.Id == leaderPrize.UserId) ?? new Users(); // if(user.UserType == 1) // { // OpModels.SysAdmin opSys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == user.Id); // if(opSys != null) // { // // checkDate = opSys.CreateDate.Value.AddMonths(-1).ToString("yyyyMM"); // } // } // else if(user.LeaderLevel == 2) // { // Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == user.Id); // if(leader != null) // { // // checkDate = leader.LastBuyDate.Value.AddMonths(-1).ToString("yyyyMM"); // } // } string CheckJson = "\"" + MonthFlag + "\":1"; string NavUserId = "," + user.Id + ","; int person = 0; int directPerson = 0; int totalPerson = db.LeaderCompTmp.Count(m => (m.ParentNav.Contains(NavUserId)) && m.EveryMonthData.Contains(CheckJson)); var subusers = db.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == user.Id).ToList(); foreach(var subuser in subusers) { string subNavUserId = "," + subuser.Id + ","; if(db.LeaderCompTmp.Count(m => (m.ParentNav.Contains(subNavUserId) || m.Id == subuser.Id) && m.EveryMonthData.Contains(CheckJson)) > 0) { person += 1; } if(db.LeaderCompTmp.Any(m => m.Id == subuser.Id && m.EveryMonthData.Contains(CheckJson))) { directPerson += 1; } } // List list = db.LeaderCompPrize.Where(m => m.StatMonth == MonthFlag && m.ParentUserId == user.Id).ToList(); // foreach(LeaderCompPrize sub in list) // { // if(sub.DirectCount + sub.NotDirectCount > 0) // { // person += 1; // } // totalPerson += sub.DirectCount + sub.NotDirectCount; // } int maxPerson = person * person; decimal CompPrize = 0; if(totalPerson >= maxPerson) { CompPrize = GetPrize(maxPerson - person, person); } else { CompPrize = GetPrize(totalPerson - person, person); } LeaderCompPrize edit = db.LeaderCompPrize.FirstOrDefault(m => m.StatMonth == MonthFlag && m.UserId == leaderPrize.UserId); if(edit != null) { edit.DirectCount = directPerson; edit.NotDirectCount = totalPerson - person; edit.SecDirectCount = person; edit.CompPrize = CompPrize; } db.SaveChanges(); } function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); db.Dispose(); opdb.Dispose(); } private decimal GetPrize(int count, int direct) { decimal prize = 0; if (count + direct >= 30) { prize = 3000 * (count + direct * 2); } else if (count + direct >= 25) { prize = 2500 * (count + direct * 2); } else if (count + direct >= 20) { prize = 2000 * (count + direct * 2); } else if (count + direct >= 15) { prize = 1500 * (count + direct * 2); } else if (count + direct >= 10) { prize = 1000 * (count + direct * 2); } else if (count + direct >= 5) { prize = 500 * (count + direct * 2); } return prize; } public void doEverday(string month, string checkMonth) { try { WebCMSEntities db = new WebCMSEntities(); OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities(); string MonthString = month + "-" + checkMonth; //统计交易增量 function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); DataTable dt = CustomerSqlConn.dtable("select CONCAT('insert into LeaderCompTradeStatBak (CreateDate,UserId,StatMonth,TradeAmount,SelfTradeAmount,CheckTradeAmount,CheckSelfTradeAmount) values (now(),', UserId,',\\\'" + month + "-" + checkMonth + "\\\',', amt" + month + ",',', samt" + month + ",',', amt" + checkMonth + ",',', samt" + checkMonth + ",');') from (select UserId,(case when amt" + month + " is null then 0 else amt" + month + " end) amt" + month + ",(case when samt" + month + " is null then 0 else samt" + month + " end) samt" + month + ",(case when amt" + checkMonth + " is null then 0 else amt" + checkMonth + " end) amt" + checkMonth + ",(case when samt" + checkMonth + " is null then 0 else samt" + checkMonth + " end) samt" + checkMonth + " from (select UserId,sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) amt" + month + ",(select sum(HelpNonDirectTradeAmt + NotHelpNonDirectTradeAmt + ProfitNonDirectTradeAmt + HelpNonDirectDebitTradeAmt + NotHelpNonDirectDebitTradeAmt + ProfitNonDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='team' and UserId=main.UserId) amt" + checkMonth + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + month + " where SeoTitle='self' and UserId=main.UserId) samt" + month + ",(select sum(HelpDirectTradeAmt + NotHelpDirectTradeAmt + ProfitDirectTradeAmt + HelpDirectDebitTradeAmt + NotHelpDirectDebitTradeAmt + ProfitDirectDebitTradeAmt) from TradeDaySummary" + checkMonth + " where SeoTitle='self' and UserId=main.UserId) samt" + checkMonth + " from TradeDaySummary" + month + " main where SeoTitle='team' and UserId>0 group by UserId) tb) tb2", MysqlConn.RdsStatSqlConnStr); string sql = ""; int num = 0; foreach(DataRow dr in dt.Rows) { sql += dr[0].ToString(); num += 1; if(num >= 200) { CustomerSqlConn.op(sql, MysqlConn.SqlConnStr); sql = ""; num = 0; } } if(!string.IsNullOrEmpty(sql)) { CustomerSqlConn.op(sql, MysqlConn.SqlConnStr); } CustomerSqlConn.op("update LeaderCompTradeStatBak leader set ParentUserId=case when (select ParentUserId from Users where Id=leader.UserId) is null then 0 else (select ParentUserId from Users where Id=leader.UserId) end,ParentNav=(select ParentNav from Users where Id=leader.UserId) where StatMonth='" + month + "-" + checkMonth + "' and UserId>1", MysqlConn.SqlConnStr); function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); //计算创客名下的达标人数，直推和间接 function.WriteLog("MonthString:" + MonthString, "领导人达标奖励日志"); List stats = db.LeaderCompTradeStatBak.Where(m => m.StatMonth == MonthString).ToList(); function.WriteLog(stats.Count.ToString(), "领导人达标奖励日志"); foreach(LeaderCompTradeStatBak stat in stats) { decimal totalAmount = stat.SelfTradeAmount - stat.CheckSelfTradeAmount; //当月交易 List directs = stats.Where(m => m.ParentUserId == stat.UserId).ToList(); foreach(LeaderCompTradeStatBak direct in directs) { decimal parentTotalAmount = direct.TradeAmount - direct.CheckTradeAmount; if(parentTotalAmount < 30000000) { totalAmount += parentTotalAmount; } } function.WriteLog("UserId:" + stat.UserId, "领导人达标奖励日志"); function.WriteLog("totalAmount:" + totalAmount, "领导人达标奖励日志"); if(totalAmount >= 30000000 && !string.IsNullOrEmpty(stat.ParentNav)) { LeaderCompTradeStatBak statEdit = db.LeaderCompTradeStatBak.FirstOrDefault(m => m.UserId == stat.UserId && m.StatMonth == MonthString); if(statEdit != null) { statEdit.ResultTradeAmount = totalAmount; db.SaveChanges(); } LeaderCompTmpBak tmp = db.LeaderCompTmpBak.FirstOrDefault(m => m.Id == stat.UserId); if(tmp == null) { tmp = db.LeaderCompTmpBak.Add(new LeaderCompTmpBak() { Id = stat.UserId, ParentUserId = stat.ParentUserId, ParentNav = stat.ParentNav }).Entity; db.SaveChanges(); } Dictionary EveryMonthData = new Dictionary(); if(!string.IsNullOrEmpty(tmp.EveryMonthData)) { EveryMonthData = Newtonsoft.Json.JsonConvert.DeserializeObject>(tmp.EveryMonthData); } if(!EveryMonthData.ContainsKey(MonthString)) { EveryMonthData.Add(MonthString, 1); } else { EveryMonthData[MonthString] = 1; } tmp.EveryMonthData = Newtonsoft.Json.JsonConvert.SerializeObject(EveryMonthData); db.SaveChanges(); string[] parents = stat.ParentNav.Trim(',').Replace(",,", ",").Split(','); Array.Reverse(parents); int index = 0; foreach(string parent in parents) { index += 1; int ParentUserId = int.Parse(function.CheckInt(parent)); LeaderCompPrizeBak prize = db.LeaderCompPrizeBak.FirstOrDefault(m => m.UserId == ParentUserId && m.StatMonth == MonthString); if(prize == null) { Users user = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users(); prize = db.LeaderCompPrizeBak.Add(new LeaderCompPrizeBak() { CreateDate = DateTime.Now, UserId = ParentUserId, ParentUserId = user.ParentUserId, ParentNav = user.ParentNav, StatMonth = MonthString, }).Entity; db.SaveChanges(); } if(index == 1) { prize.DirectCount += 1; } else { prize.NotDirectCount += 1; } db.SaveChanges(); } } function.WriteLog(DateTime.Now.ToString() + "------" + stat.UserId, "领导人达标奖励日志"); } function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); db.Dispose(); } catch(Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "领导达标人奖励异常"); } } private void SendPrizeEveryDay(string month, string checkDate) { string MonthFlag = month + "-" + checkDate; WebCMSEntities db = new WebCMSEntities(); OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities(); //计算运营中心或大盟主达标奖励 List leaderPrizes = db.LeaderCompPrizeBak.Where(m => m.StatMonth == MonthFlag).ToList(); function.WriteLog(leaderPrizes.Count.ToString(), "领导人达标奖励日志"); foreach(LeaderCompPrizeBak leaderPrize in leaderPrizes) { Users user = db.Users.FirstOrDefault(m => m.Id == leaderPrize.UserId) ?? new Users(); string CheckJson = "\"" + MonthFlag + "\":1"; string NavUserId = "," + user.Id + ","; int person = 0; int directPerson = 0; int totalPerson = db.LeaderCompTmpBak.Count(m => (m.ParentNav.Contains(NavUserId)) && m.EveryMonthData.Contains(CheckJson)); var subusers = db.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == user.Id).ToList(); foreach(var subuser in subusers) { string subNavUserId = "," + subuser.Id + ","; if(db.LeaderCompTmpBak.Count(m => (m.ParentNav.Contains(subNavUserId) || m.Id == subuser.Id) && m.EveryMonthData.Contains(CheckJson)) > 0) { person += 1; } if(db.LeaderCompTmpBak.Any(m => m.Id == subuser.Id && m.EveryMonthData.Contains(CheckJson))) { directPerson += 1; } } int maxPerson = person * person; decimal CompPrize = 0; if(totalPerson >= maxPerson) { CompPrize = GetPrize(maxPerson - person, person); } else { CompPrize = GetPrize(totalPerson - person, person); } LeaderCompPrizeBak edit = db.LeaderCompPrizeBak.FirstOrDefault(m => m.StatMonth == MonthFlag && m.UserId == leaderPrize.UserId); if(edit != null) { edit.DirectCount = directPerson; edit.NotDirectCount = totalPerson - person; edit.SecDirectCount = person; edit.CompPrize = CompPrize; } db.SaveChanges(); } function.WriteLog(DateTime.Now.ToString(), "领导人达标奖励日志"); db.Dispose(); opdb.Dispose(); } } }