using System; using System.Collections.Generic; using Library; using LitJson; using System.Linq; using System.Data; using System.Threading; using MySystem.PxcModels; namespace MySystem { public class StatService { public readonly static StatService Instance = new StatService(); private StatService() { } public void Start() { Thread th = new Thread(StartDo); th.IsBackground = true; th.Start(); } public void StartDo() { while(true) { try { if(DateTime.Now.Hour > 0) { 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")); StartEverDay(doDate); StatMerchantTrade(doDate); } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "每天重置交易额异常"); } Thread.Sleep(3600000); } } public void StartActiveReward() { Thread th = new Thread(ActiveReward); th.IsBackground = true; th.Start(); } public void ActiveReward() { while(true) { try { function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理激活奖励"); dosomething3(); function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理激活奖励"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理激活奖励异常"); } Thread.Sleep(30000); } } public void StartActiveReward1() { Thread th = new Thread(ActiveReward1); th.IsBackground = true; th.Start(); } public void ActiveReward1() { while(true) { try { function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理0押激活奖励"); activePrizeWithoutDeposit(); // activePrizeWithoutDeposit6(); function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理0押激活奖励"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理0押激活奖励异常"); } Thread.Sleep(30000); } } public void StartActiveReward2() { Thread th = new Thread(ActiveReward2); th.IsBackground = true; th.Start(); } public void ActiveReward2() { while(true) { try { function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理盒易付0押激活奖励"); activePrizeWithoutDeposit12(); // activePrizeWithoutDeposit122(); function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理盒易付0押激活奖励"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理盒易付0押激活奖励异常"); } Thread.Sleep(30000); } } //广电卡激活奖励 public void StartSimActive() { Thread th = new Thread(StartSimActiveListen); th.IsBackground = true; th.Start(); } public void StartSimActiveListen() { while(true) { try { function.WriteLog(DateTime.Now.ToString() + ":start", "实时处理广电卡激活奖励"); StartSimActiveDo(); function.WriteLog(DateTime.Now.ToString() + ":end\n\n", "实时处理广电卡激活奖励"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "实时处理广电卡激活奖励异常"); } Thread.Sleep(29000); } } public void StartSimActiveDo(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-30); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.BrandId == 14 && m.Detail != "1"); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday); } foreach (PosMachinesTwo pos in posList.ToList()) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } decimal Amount = 19 * 1.5M; doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, Amount); PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(item != null) { item.Detail = "1"; db.SaveChanges(); } } } } db.Dispose(); } public void clear() { RedisDbconn.Instance.Clear("TotalAmount*"); RedisDbconn.Instance.Clear("TotalCloudPayAmount*"); RedisDbconn.Instance.Clear("TotalPosAmount*"); RedisDbconn.Instance.Clear("TeamTotalAmount*"); RedisDbconn.Instance.Clear("TeamTotalCloudPayAmount*"); RedisDbconn.Instance.Clear("TeamTotalPosAmount*"); // RedisDbconn.Instance.Clear("TotalUser*"); // RedisDbconn.Instance.Clear("TeamTotalUser*"); // RedisDbconn.Instance.Clear("AddUser*"); // RedisDbconn.Instance.Clear("TeamAddUser*"); // RedisDbconn.Instance.Clear("TotalPosMerchant*"); // RedisDbconn.Instance.Clear("TeamTotalPosMerchant*"); RedisDbconn.Instance.Clear("MerTotalAmount*"); } // 1. 前一天的绑定记录和创客信息匹配，设置商户型创客 public void dosomething1(string date) { // TODO: 每天扫描非商户型创客的持有机具数量 SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities(); WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Parse(date + " 00:00:00"); DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"); List binds = spdb.BindRecord.Where(m => m.CreateTime >= yesterday && m.CreateTime < today).ToList(); foreach (SpModels.BindRecord bind in binds) { string Mobile = bind.MerNewSnNo; string MerNo = bind.MerNo; string BeforeNum = ""; string AfterNum = ""; if (Mobile.Contains("****") && Mobile.Length == 11) { BeforeNum = Mobile.Substring(0, 3); AfterNum = Mobile.Substring(7); } string Name = bind.MerName; if (bind.ProductType == "2") { if (Name.Contains("-")) { Name = Name.Split('-')[1]; } else if (Name.Contains("_")) { Name = Name.Split('_')[1]; } } else if (bind.ProductType == "4") { Name = bind.SeoTitle; } PxcModels.Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0); if (user != null) { bool checkPos = db.PosMachinesTwo.Any(m => m.UserId == user.Id); if (!checkPos) { PxcModels.MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == bind.MerSnNo) ?? new PxcModels.MachineForSnNo(); PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId && m.UserId != user.Id); if (pos != null) { pos.UserId = user.Id; user.MerchantType = 1; PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PxcModels.PosMerchantInfo(); merchant.UserId = user.Id; merchant.MerUserType = 1; pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id db.SaveChanges(); } } } } spdb.Dispose(); db.Dispose(); } // 1. 前一天的商户型创客，判断名下是否3台激活机器，是则变为非商户型创客 public void dosomething11(string date) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Parse(date + " 00:00:00"); DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"); var users = db.Users.Select(m => new { m.Id, m.MerchantType }).Where(m => m.MerchantType == 1).ToList(); foreach (var user in users) { int machineCount = db.PosMachinesTwo.Count(m => m.UserId == user.Id && m.PosSnType == 0); int couponCount = db.PosCoupons.Count(m => m.UserId == user.Id && m.IsUse == 0); //判断是否拥有3张券 if (machineCount + couponCount >= 3) { Users edit = db.Users.FirstOrDefault(m => m.Id == user.Id); if (edit != null) { edit.MerchantType = 0; db.SaveChanges(); } } } db.Dispose(); } public void testStatTrade(string date) { string yesterday = date + " 00:00:00"; string today = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; string TradeMonth = DateTime.Parse(date).ToString("yyyyMM"); string TradeDate = DateTime.Parse(date).ToString("yyyyMMdd"); DataTable dt = dbconn.dtable("select UserId,BrandId,MerchantId,BankCardType,QrPayFlag,sum(TradeAmount) from TradeRecord where CreateDate>='" + yesterday + "' and CreateDate<'" + today + "' group by UserId,BrandId,MerchantId,BankCardType,QrPayFlag"); foreach (DataRow dr in dt.Rows) { int UserId = int.Parse(dr["UserId"].ToString()); //创客ID int BrandId = int.Parse(dr["BrandId"].ToString()); //品牌 int MerchantId = int.Parse(dr["MerchantId"].ToString()); //商户Id int BankCardType = int.Parse(dr["BankCardType"].ToString()); //卡类型 int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString()); //云闪付 decimal TradeAmount = decimal.Parse(dr[5].ToString()); //当日交易额 string content = "{"; content += "\"DateString\":\"" + date + "\","; content += "\"UserId\":\"" + UserId + "\","; content += "\"BrandId\":\"" + BrandId + "\","; content += "\"MerchantId\":\"" + MerchantId + "\","; content += "\"BankCardType\":\"" + BankCardType + "\","; content += "\"QrPayFlag\":\"" + QrPayFlag + "\","; content += "\"TradeAmount\":\"" + TradeAmount + "\""; content += "}"; RedisDbconn.Instance.AddList("TradeStatQueueTest", content); } } // 3. 前一天的激活记录，根据创客类型，如果是商户型创客，则激活奖励的起始人从此人上级计算。如果不是，则从此人开始计算 public void dosomething3(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-1); DateTime today = DateTime.Now.AddMinutes(-10); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword) && m.Detail != "1" && m.BrandId != 14); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today); } foreach (PosMachinesTwo pos in posList.ToList()) { // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo)); // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1); PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null && pos.ActivationTime.Value <= pos.BindingTime.Value.AddDays(30)) { // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0); // if (otherInfo != null) // { // otherInfo.PrizeFlag1 = 1; // db.SaveChanges(); string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword)); if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9) { ActPrize = ActPrize / 100; } if (ActPrize > 0) { if (ActPrize == 99) { ActPrize = 100; } else if (ActPrize == 199) { ActPrize = 200; } else if (ActPrize == 299) { ActPrize = 300; } else if (ActPrize == 249) { ActPrize = 260; } if (GetUserId > 0) { doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize); } } else if(ActPrize == 0) { if(pos.BrandId == 6) { doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50); } } PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(edit != null) { edit.Detail = "1"; db.SaveChanges(); } } // } } } db.Dispose(); } //金控活动机返奖励 private void doJk30(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, int GetUserId, string ParentNav, int TopUserId) { // DateTime start = DateTime.Parse("2022-04-06 00:00:00"); // DateTime end = DateTime.Parse("2022-07-05 00:00:00"); // if((pos.BrandId == 1 || pos.BrandId == 3) && pos.CreateDate >= start && pos.CreateDate < end) // { // decimal amt = 0; // if(DateTime.Now < DateTime.Parse("2023-05-01 00:00:00")) // { // amt = 10; // } // if(amt > 0) // { // doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, amt, 0, 1); // } // } } //无押金激活奖励 public void activePrizeWithoutDeposit(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-1); DateTime today = DateTime.Now.AddMinutes(-10); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && string.IsNullOrEmpty(m.SeoKeyword) && m.BrandId != 12 && m.BrandId != 13 && m.BrandId != 6 && m.BrandId != 14 && m.Detail != "1"); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today); } foreach (PosMachinesTwo pos in posList.ToList()) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } if((pos.BrandId == 10 || pos.BrandId == 11) && DateTime.Now < DateTime.Parse("2023-05-01 00:00:00") && pos.IsFirst == 1) //首台无押金机返50 { doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50); } PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(edit != null) { edit.Detail = "1"; db.SaveChanges(); } } } } db.Dispose(); } public void activePrizeWithoutDeposit6(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-30); DateTime today = DateTime.Now.AddMinutes(-10); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && m.BrandId == 6 && m.Detail != "1"); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today); } foreach (PosMachinesTwo pos in posList.ToList()) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } // 立刷30天内刷满5000，无服务费机具，返50 if (pos.BrandId == 6 && pos.BindingTime > DateTime.Now.AddDays(-30)) { doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50); } PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(edit != null) { edit.Detail = "1"; db.SaveChanges(); } } } } db.Dispose(); } public void activePrizeWithoutDeposit12(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-30); DateTime today = DateTime.Now.AddMinutes(-10); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.IsFirst == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 12 || m.BrandId == 13) && m.Detail != "1"); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today); } foreach (PosMachinesTwo pos in posList.ToList()) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } //首台无押金机返50 doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50); PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(item != null) { item.Detail = "1"; db.SaveChanges(); } } } } db.Dispose(); } public void activePrizeWithoutDeposit122(int posid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddDays(-30); DateTime today = DateTime.Now.AddMinutes(-5); DateTime checkTime = DateTime.Parse("2023-08-01 00:00:00"); IQueryable posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.IsFirst == 0 && m.CreditTrade >= 1000 && m.ActivationTime < checkTime && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 12 || m.BrandId == 13) && m.Detail != "1"); if (posid > 0) { posList = posList.Where(m => m.Id == posid); } else { posList = posList.Where(m => m.ActivationTime >= yesterday && m.ActivationTime < today); } foreach (PosMachinesTwo pos in posList.ToList()) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } string IdCard = merchant.MerIdcardNo; string IdCardStart = IdCard.Substring(0, 6); string IdCardEnd = IdCard.Substring(IdCard.Length - 4); string MerName = merchant.MerchantName; List BrandIds = new List(); BrandIds.Add(4); BrandIds.Add(5); BrandIds.Add(8); BrandIds.Add(9); PosMerchantInfo other = db.PosMerchantInfo.FirstOrDefault(m => m.MerIdcardNo.StartsWith(IdCardStart) && m.MerIdcardNo.EndsWith(IdCardEnd) && m.MerchantName.Contains(MerName) && BrandIds.Contains(m.BrandId)); if(other != null) { PosMachinesTwo checkpos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == other.KqSnNo && m.IsFirst == 1); if(checkpos != null) { doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, 50); PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(edit != null) { edit.SeoKeyword = checkpos.SeoKeyword; edit.UpFeeFlag = checkpos.UpFeeFlag; edit.DownFeeFlag = checkpos.DownFeeFlag; edit.UpFeeDate = checkpos.UpFeeDate; edit.DownFeeDate = checkpos.DownFeeDate; edit.BindingTime = checkpos.BindingTime; edit.IsFirst = checkpos.IsFirst; db.SaveChanges(); if(edit.UpFeeFlag == 1 && edit.DownFeeFlag == 0) { string info = "{\"RecordId\":\"\",\"PosId\":\"" + edit.Id + "\",\"Fee\": \"0.63\",\"Kind\": \"1\",\"OpMan\": \"系统\"}"; RedisDbconn.Instance.AddList("SetDepositPostQueue", info); } } } } PosMachinesTwo item = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id); if(item != null) { item.Detail = "1"; db.SaveChanges(); } } } } db.Dispose(); } public void doActiveReward(WebCMSEntities db, PosMerchantInfo merchant, PosMachinesTwo pos, int GetUserId, string ParentNav, int TopUserId, decimal ActPrize, int ChangeType = 0, int ActType = 0) { bool check = db.ActiveReward.Any(m => m.KqMerNo == merchant.KqMerNo && m.RewardAmount == ActPrize); bool check1 = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn && m.RewardAmount == ActPrize); if (!check && !check1) { function.WriteLog(DateTime.Now.ToString() + ":" + pos.PosSn, "实时处理激活奖励"); Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); db.ActiveReward.Add(new ActiveReward() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 MerchantId = pos.BindMerchantId, //商户 StandardDate = pos.ActivationTime, //达标日期 RewardAmount = ActPrize, //奖励金额 BrandId = pos.BrandId, //品牌 UserNav = ParentNav, //创客父级 DirectBuddyNo = merchant.UserId, //商户直属创客 KqMerNo = merchant.KqMerNo, //渠道商户编号 KqSnNo = pos.PosSn, //渠道SN号 SnType = pos.PosSnType, //机具类型 SnApplyUserId = pos.BuyUserId, //机具申请创客 ActType = ActType, //激活类型 SnStoreId = pos.StoreId, //SN仓库 RewardTips = "激活奖励", //奖励描述 Remark = "激活奖励", //备注 ActDate = pos.ActivationTime, //激活时间 TopUserId = TopUserId, //顶级创客 SeoTitle = machineUser.RealName, }); db.SaveChanges(); string IdBrand = GetUserId + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.ActProfit += ActPrize; db.SaveChanges(); UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = GetUserId, UserId = GetUserId, }).Entity; db.SaveChanges(); } decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += ActPrize; account.TotalAmount += ActPrize; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 ChangeType = ChangeType, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = ActPrize, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd"); string monthString = pos.ActivationTime.Value.ToString("yyyyMM"); // 激活奖励列表 List dates = RedisDbconn.Instance.GetList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId); if (!dates.Contains(dateString)) { RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize); List months = RedisDbconn.Instance.GetList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId); if (!months.Contains(monthString)) { RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize); // 激活奖励详情 List actPrizeList = RedisDbconn.Instance.GetList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString); if (!actPrizeList.Contains(pos.BindMerchantId)) { RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize); //收支明细 RedisDbconn.Instance.Clear("UserAccount:Income:" + GetUserId + ":" + monthString); } } //根据商户信息发放激活奖励 public void dosomething32(int merid = 0) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Now.AddHours(-3); DateTime today = DateTime.Now; IQueryable merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && !string.IsNullOrEmpty(m.SeoKeyword)); if (merid > 0) { merList = merList.Where(m => m.Id == merid); } else { merList = merList.Where(m => m.MerStandardDate >= yesterday && m.MerStandardDate < today); } foreach (PosMerchantInfo merchant in merList.ToList()) { // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo)); // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0); // if (otherInfo != null) // { // otherInfo.PrizeFlag1 = 1; // db.SaveChanges(); MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo(); PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo(); string ParentNav = ""; Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { int GetUserId = user.Id; ParentNav = user.ParentNav; int TopUserId = 0; if (!string.IsNullOrEmpty(ParentNav)) { TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword)); if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9) { ActPrize = ActPrize / 100; } if (ActPrize > 0) { bool check = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn); if (!check) { if (ActPrize == 99) { ActPrize = 100; } else if (ActPrize == 199) { ActPrize = 200; } else if (ActPrize == 299) { ActPrize = 300; } Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); db.ActiveReward.Add(new ActiveReward() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 MerchantId = pos.BindMerchantId, //商户 StandardDate = pos.ActivationTime, //达标日期 RewardAmount = ActPrize, //奖励金额 BrandId = pos.BrandId, //品牌 UserNav = ParentNav, //创客父级 DirectBuddyNo = merchant.UserId, //商户直属创客 KqMerNo = merchant.KqMerNo, //渠道商户编号 KqSnNo = pos.PosSn, //渠道SN号 SnType = pos.PosSnType, //机具类型 SnApplyUserId = pos.BuyUserId, //机具申请创客 ActType = 0, //激活类型 SnStoreId = pos.StoreId, //SN仓库 RewardTips = "激活奖励", //奖励描述 Remark = "激活奖励", //备注 ActDate = pos.ActivationTime, //激活时间 TopUserId = TopUserId, //顶级创客 SeoTitle = machineUser.RealName, }); db.SaveChanges(); string IdBrand = GetUserId + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.ActProfit += ActPrize; db.SaveChanges(); UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = GetUserId, UserId = GetUserId, }).Entity; db.SaveChanges(); } decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += ActPrize; account.TotalAmount += ActPrize; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 ChangeType = 0, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = ActPrize, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd"); string monthString = pos.ActivationTime.Value.ToString("yyyyMM"); // 激活奖励列表 List dates = RedisDbconn.Instance.GetList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId); if (!dates.Contains(dateString)) { RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, ActPrize); List months = RedisDbconn.Instance.GetList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId); if (!months.Contains(monthString)) { RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, ActPrize); // 激活奖励详情 List actPrizeList = RedisDbconn.Instance.GetList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString); if (!actPrizeList.Contains(pos.BindMerchantId)) { RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId); } RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, ActPrize); } } } // } } db.Dispose(); } //3. 前一天的激活记录，根据创客类型，如果是商户型创客，则开机奖励的起始人从此人上级计算。如果不是，则从此人开始计算 public void dosomething4(string date) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Parse(date + " 00:00:00"); DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"); List posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.ActivationTime >= yesterday && m.ActivationTime < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000).ToList(); foreach (PosMachinesTwo pos in posList) { if (pos.BindingTime > DateTime.Now.AddDays(-30)) { decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword)); if (ActPrize > 0) { // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo)); // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1); PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0); // if (otherInfo != null) // { // otherInfo.PrizeFlag2 = 1; // db.SaveChanges(); // 从机具所属人上级开始分开机奖励 Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { if (!string.IsNullOrEmpty(user.ParentNav)) { decimal Prize = 20; string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(','); for (int i = ParentNavs.Length - 1; i >= 0; i--) { int UserId = int.Parse(ParentNavs[i]); Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1); if (puser != null && Prize > 0) { int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机 int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送） int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券 // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机 // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机（不限购买或赠送） if (machineCount + ActiveCount + couponCount >= 3) { int pTopUserId = 0; if (!string.IsNullOrEmpty(puser.ParentNav)) { pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = yesterday.ToString("yyyyMM"), //交易月 TradeDate = yesterday, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称 MerchantId = pos.BindMerchantId, //商户 DirectUserId = merchant.UserId, //商户直属人 SnNo = pos.PosSn, //SN号 MerNo = merchant.KqMerNo, //渠道商户号 SnType = pos.PosSnType, //机具类型 StandardDate = pos.ActivationTime, //商户的激活日期 SnStoreId = pos.StoreId, //SN仓库 MerBuddyType = puser.MerchantType, //商户创客类型 RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励 RewardTips = "开机奖励", //奖励描述 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 SeoTitle = machineUser.RealName, }).Entity; db.OpenReward.Add(new OpenReward() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = yesterday.ToString("yyyyMM"), //交易月 TradeDate = DateTime.Now, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 RewardType = 2, //奖励类型 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 }); string IdBrand = puser.Id + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.OpenProfit += Prize; db.SaveChanges(); //账户入库 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = puser.Id, UserId = puser.Id, }).Entity; db.SaveChanges(); } //收支明细入库 decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += Prize; account.TotalAmount += Prize; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = puser.Id, //创客 ChangeType = 50, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = Prize, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); string dateString = yesterday.ToString("yyyyMMdd"); string monthString = yesterday.ToString("yyyyMM"); // 开机奖励列表 List dates = RedisDbconn.Instance.GetList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId); if (!dates.Contains(dateString)) { RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize); List months = RedisDbconn.Instance.GetList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId); if (!months.Contains(monthString)) { RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize); // 开机奖励详情 RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail); Prize = 0; } } } } } // } } } } } db.Dispose(); } //实时获取开机奖励 public void StartOpenReward() { Thread th = new Thread(StartOpenRewardDo); th.IsBackground = true; th.Start(); } public void StartOpenRewardDo() { while(true) { string content = RedisDbconn.Instance.RPop("OpenRewardQueue"); if(!string.IsNullOrEmpty(content)) { try { function.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "开机奖励发放日志"); int PosId = int.Parse(content); Thread.Sleep(1000); WebCMSEntities db = new WebCMSEntities(); PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && ((!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000) || m.BrandId == 14)); if (pos != null) { function.WriteLog("sn:" + pos.PosSn, "开机奖励发放日志"); if (pos.BindingTime > DateTime.Now.AddDays(-30)) { decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword)); function.WriteLog("押金:" + pos.SeoKeyword, "开机奖励发放日志"); if (ActPrize > 0 || pos.BrandId == 14) { PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { function.WriteLog("商户:" + merchant.KqMerNo, "开机奖励发放日志"); Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { function.WriteLog("所属人:" + user.MakerCode, "开机奖励发放日志"); string ParentNav = function.CheckNull(user.ParentNav) + "," + user.Id + ","; if (!string.IsNullOrEmpty(ParentNav)) { decimal Prize = 20; if(pos.BrandId == 14) { Prize = 19 * 0.3M; } string[] ParentNavs = ParentNav.Trim(',').Replace(",,", ",").Split(','); for (int i = ParentNavs.Length - 1; i >= 0; i--) { int UserId = int.Parse(ParentNavs[i]); Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1); if (puser != null && Prize > 0) { function.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志"); // int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机 // int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送） // int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券 // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机 // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机（不限购买或赠送） // function.WriteLog("条件:machineCount:" + machineCount + ",ActiveCount:" + ActiveCount + ",couponCount:" + couponCount + "", "开机奖励发放日志"); // if (machineCount + ActiveCount + couponCount >= 3) function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志"); if(puser.LeaderLevel > 0 || puser.UserType == 1) { bool leaderOp = true; if(puser.LeaderLevel > 0 && puser.UserType == 0) { DateTime now = DateTime.Now; leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now); function.WriteLog("条件:leaderOp:" + leaderOp, "开机奖励发放日志"); } if(leaderOp) { function.WriteLog("满足条件", "开机奖励发放日志"); int pTopUserId = 0; if (!string.IsNullOrEmpty(puser.ParentNav)) { pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月 TradeDate = DateTime.Now, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称 MerchantId = pos.BindMerchantId, //商户 DirectUserId = merchant.UserId, //商户直属人 SnNo = pos.PosSn, //SN号 MerNo = merchant.KqMerNo, //渠道商户号 SnType = pos.PosSnType, //机具类型 StandardDate = pos.ActivationTime, //商户的激活日期 SnStoreId = pos.StoreId, //SN仓库 MerBuddyType = puser.MerchantType, //商户创客类型 RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励 RewardTips = "开机奖励", //奖励描述 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 SeoTitle = machineUser.RealName, }).Entity; db.OpenReward.Add(new OpenReward() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月 TradeDate = DateTime.Now, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 RewardType = 2, //奖励类型 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 }); string IdBrand = puser.Id + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.OpenProfit += Prize; db.SaveChanges(); //账户入库 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = puser.Id, UserId = puser.Id, }).Entity; db.SaveChanges(); } //收支明细入库 decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += Prize; account.TotalAmount += Prize; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = puser.Id, //创客 ChangeType = 50, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = Prize, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); string dateString = DateTime.Now.ToString("yyyyMMdd"); string monthString = DateTime.Now.ToString("yyyyMM"); // 开机奖励列表 List dates = RedisDbconn.Instance.GetList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId); if (!dates.Contains(dateString)) { RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize); List months = RedisDbconn.Instance.GetList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId); if (!months.Contains(monthString)) { RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize); // 开机奖励详情 RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail); Prize = 0; } } } } } } // } } } } } db.Dispose(); } catch(Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常"); } } else { Thread.Sleep(5000); } } } public void dosomething42(string date) { WebCMSEntities db = new WebCMSEntities(); DateTime yesterday = DateTime.Parse(date + " 00:00:00"); DateTime today = DateTime.Parse(DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"); List merList = db.PosMerchantInfo.Where(m => m.ActiveStatus == 1 && m.MerStandardDate >= yesterday && m.MerStandardDate < today && !string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0").ToList(); foreach (PosMerchantInfo merchant in merList) { MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.MerchantNo) ?? new MachineForMerNo(); PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forMerNo.SnId) ?? new PosMachinesTwo(); if (pos.ActivationTime > DateTime.Now.AddDays(-20) && pos.CreditTrade >= 1000) { decimal ActPrize = decimal.Parse(function.CheckNum(merchant.SeoKeyword)); if (ActPrize > 0) { // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo)); // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag2 == 0); // if (otherInfo != null) // { // otherInfo.PrizeFlag2 = 1; // db.SaveChanges(); // 从机具所属人上级开始分开机奖励 Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId); if (user != null) { if (!string.IsNullOrEmpty(user.ParentNav)) { decimal Prize = 20; string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(','); for (int i = ParentNavs.Length - 1; i >= 0; i--) { int UserId = int.Parse(ParentNavs[i]); Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1); if (puser != null && Prize > 0) { int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0 && m.ActivationState == 0); //判断是否拥有3台兑换机 int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送） int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券 // int BigCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.BrandId == 3); //判断是否拥有2台大机 // int BigActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1 && m.BrandId == 3); //判断是否拥有2台激活大机（不限购买或赠送） if (machineCount + ActiveCount + couponCount >= 3) { int pTopUserId = 0; if (!string.IsNullOrEmpty(puser.ParentNav)) { pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = yesterday.ToString("yyyyMM"), //交易月 TradeDate = yesterday, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称 MerchantId = pos.BindMerchantId, //商户 DirectUserId = merchant.UserId, //商户直属人 SnNo = pos.PosSn, //SN号 MerNo = merchant.KqMerNo, //渠道商户号 SnType = pos.PosSnType, //机具类型 StandardDate = pos.ActivationTime, //商户的激活日期 SnStoreId = pos.StoreId, //SN仓库 MerBuddyType = puser.MerchantType, //商户创客类型 RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励 RewardTips = "开机奖励", //奖励描述 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 SeoTitle = machineUser.RealName, }).Entity; db.OpenReward.Add(new OpenReward() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, TradeMonth = yesterday.ToString("yyyyMM"), //交易月 TradeDate = DateTime.Now, //达标日期 UserId = puser.Id, //创客 BrandId = pos.BrandId, //品牌 RewardType = 2, //奖励类型 CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额 DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额 CreditRewardAmount = Prize, //贷记卡交易奖励金额 RewardDesc = "开机奖励", //奖励描述 TopUserId = pTopUserId, //顶级创客 }); string IdBrand = puser.Id + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.OpenProfit += Prize; db.SaveChanges(); //账户入库 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = puser.Id, UserId = puser.Id, }).Entity; db.SaveChanges(); } //收支明细入库 decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += Prize; account.TotalAmount += Prize; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = puser.Id, //创客 ChangeType = 50, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = Prize, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); string dateString = yesterday.ToString("yyyyMMdd"); string monthString = yesterday.ToString("yyyyMM"); // 开机奖励列表 List dates = RedisDbconn.Instance.GetList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId); if (!dates.Contains(dateString)) { RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize); List months = RedisDbconn.Instance.GetList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId); if (!months.Contains(monthString)) { RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString); } RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize); // 开机奖励详情 RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail); Prize -= 10; } } } } } // } } } } db.Dispose(); } // 4. 前一天的流量卡记录和匹配 public void ListenFluxRecord() { Thread th = new Thread(ListenFluxRecordD0); th.IsBackground = true; th.Start(); } public void ListenFluxRecordD0() { while(true) { if(DateTime.Now.Hour > 0) { CheckFluxForTrade(); } Thread.Sleep(600000); } } public void doFluxRecord() { function.WriteLog(DateTime.Now.ToString(), "执行流量费返佣"); SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities(); WebCMSEntities db = new WebCMSEntities(); DateTime start = DateTime.Now.AddDays(-20); List trades = spdb.TradeFluxRecord.Where(m => m.CreateDate >= start && m.Status == 1).ToList(); foreach (SpModels.TradeFluxRecord trade in trades) { try { string OrderNo = trade.TradeSerialNo; //单号 DateTime TradeDate = trade.CreateDate.Value; string TradeMonth = TradeDate.ToString("yyyyMM"); decimal FeeAmount = trade.FeeAmount; //流量费 if (trade.ProductType == "1" || trade.ProductType == "4" || trade.ProductType == "6" || trade.ProductType == "8" || trade.ProductType == "9") { FeeAmount = FeeAmount / 100; } string TradeSnNo = trade.TradeSnNo; //机具SN decimal FluxProfit = 0; if (trade.ProductType == "1" && FeeAmount == 60) { FluxProfit = 24; } else if (trade.ProductType == "7" && FeeAmount == 46) { FluxProfit = 10; } else if (trade.ProductType != "1" && FeeAmount == 48) { FluxProfit = 12; } else if (trade.ProductType != "1" && FeeAmount == 60) { FluxProfit = 24; } if (FluxProfit > 0) { MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == TradeSnNo) ?? new MachineForSnNo(); PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo(); // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1); PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null && pos.BrandId != 6) { bool checkExist = db.FluxProfitDetail.Any(m => m.MerNo == merchant.KqMerNo); if (!checkExist && decimal.Parse(function.CheckNum(pos.SeoKeyword)) > 0) { Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users(); int GetUserId = user.Id; 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]); } } FluxProfitSummary fluxProfit = db.FluxProfitSummary.FirstOrDefault(m => m.UserId == GetUserId && m.BrandId == pos.BrandId && m.TradeMonth == TradeMonth); if (fluxProfit == null) { fluxProfit = db.FluxProfitSummary.Add(new FluxProfitSummary() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 BrandId = pos.BrandId, TopUserId = TopUserId, //顶级创客 TradeMonth = TradeMonth, //交易月 MerUserType = user.MerchantType, //商户创客类型 Remark = "流量卡分佣", //备注 }).Entity; db.SaveChanges(); } fluxProfit.FluxProfitAmt += FluxProfit; //流量分润总金额 db.FluxProfitDetail.Add(new FluxProfitDetail() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, RecordNo = OrderNo, //单号 TradeDate = TradeDate.ToString("yyyyMMdd"), //交易日期 TradeTime = TradeDate.ToString("HHmmss"), //交易时间 TradeMonth = TradeMonth, //交易月 UserId = GetUserId, //创客 MerchantId = pos.BindMerchantId, //商户 MerchantUserId = pos.UserId, //商户直属人 MerNo = merchant.KqMerNo, //渠道商户编号 SnNo = pos.PosSn, //渠道SN号 FluxOrderNo = OrderNo, //流量扣费单号 TradeOrderNo = OrderNo, //交易流水号 TradeAmt = trade.TradeAmount, //商户交易额 FluxFeeAmt = FeeAmount, //流量费 FluxProfitAmt = FluxProfit, //流量分润总金额 PosType = pos.PosSnType.ToString(), //POS类型 Remark = "流量卡分佣", //备注 BrandId = pos.BrandId, //品牌 TopUserId = TopUserId, //顶级创客 MerUserType = user.MerchantType, //商户创客类型 }); string IdBrand = user.Id + "_" + pos.BrandId; UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand); if (userData == null) { userData = db.UserMachineData.Add(new UserMachineData() { IdBrand = IdBrand, }).Entity; db.SaveChanges(); } userData.FluxProfit += FluxProfit; db.SaveChanges(); UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId); if (account == null) { account = db.UserAccount.Add(new UserAccount() { Id = GetUserId, UserId = GetUserId, }).Entity; db.SaveChanges(); } decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额 decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额 decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额 account.BalanceAmount += FluxProfit; account.TotalAmount += FluxProfit; decimal AfterTotalAmount = account.TotalAmount; //变更后总金额 decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额 decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额 UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = GetUserId, //创客 ChangeType = 60, //变动类型 ProductType = pos.BrandId, //产品类型 ChangeAmount = FluxProfit, //变更金额 BeforeTotalAmount = BeforeTotalAmount, //变更前总金额 AfterTotalAmount = AfterTotalAmount, //变更后总金额 BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额 AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额 BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额 AfterBalanceAmount = AfterBalanceAmount, //变更后余额 }).Entity; db.SaveChanges(); } SpModels.TradeFluxRecord edit = spdb.TradeFluxRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; spdb.SaveChanges(); } } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常"); } } spdb.Dispose(); db.Dispose(); function.WriteLog(DateTime.Now.ToString() + "\n", "执行流量费返佣"); } public void CheckFluxForTrade() { function.WriteLog(DateTime.Now.ToString(), "扫描交易记录中的流量费"); SpModels.WebCMSEntities spdb = new SpModels.WebCMSEntities(); DateTime start = DateTime.Now.AddDays(-20); int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/TradeRecordId.txt"))); List BrandIds = new List(); BrandIds.Add("1"); BrandIds.Add("10"); BrandIds.Add("12"); var list = spdb.TradeRecord.Select(m => new { m.Id, m.CreateDate, m.ProductType, m.Status }).Where(m => m.Id >= StartId && m.Status == 2 && m.CreateDate > start && BrandIds.Contains(m.ProductType)).OrderBy(m => m.CreateDate); foreach (var sub in list.ToList()) { try { SpModels.TradeRecord trade = spdb.TradeRecord.FirstOrDefault(m => m.Id == sub.Id); if (trade != null) { if(trade.ProductType == "1") //金控 { string content = trade.SeoDescription; if (!string.IsNullOrEmpty(content)) { content = System.Web.HttpUtility.UrlDecode(content); JsonData jsonObj = JsonMapper.ToObject(content); decimal terminalDataFlowFee = decimal.Parse(function.CheckNum(jsonObj["terminalDataFlowFee"].ToString())); if (terminalDataFlowFee > 0) { spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord() { SeoDescription = trade.TradeSerialNo, FeeAmount = terminalDataFlowFee, TradeSerialNo = function.MD5_16(trade.TradeSerialNo), CreateDate = trade.CreateDate, TradeSnNo = trade.TradeSnNo, ProductType = trade.ProductType, Status = 1, }); spdb.SaveChanges(); } } } else if(trade.ProductType == "10" || trade.ProductType == "12") //10联动、12盒易付 { if (trade.DigAmt > 0) { spdb.TradeFluxRecord.Add(new SpModels.TradeFluxRecord() { SeoDescription = trade.TradeSerialNo, FeeAmount = trade.DigAmt, TradeSerialNo = function.MD5_16(trade.TradeSerialNo), CreateDate = trade.CreateDate, TradeSnNo = trade.TradeSnNo, ProductType = trade.ProductType, Status = 1, }); spdb.SaveChanges(); } } trade.Status = 3; spdb.SaveChanges(); } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n$" + sub.Id + "$\n" + ex.ToString(), "扫描交易记录中的流量费异常"); } } spdb.Dispose(); function.WriteLog(DateTime.Now.ToString() + "\n", "扫描交易记录中的流量费"); doFluxRecord(); } // 每天统计头一天的交易额 public void StartEverDay(string date) { string TradeMonth = DateTime.Now.ToString("yyyyMM"); if(DateTime.Now.Day == 1) { TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM"); } else if(DateTime.Now.Day == 2) { CustomerSqlConn.op("update Users set ThisMonthTrade=0 where ThisMonthTrade>0", MysqlConn.SqlConnStr); } DataTable list = CustomerSqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectTradeAmt+ProfitNonDirectDebitTradeAmt) from (select UserId,HelpNonDirectTradeAmt,HelpNonDirectDebitTradeAmt,NotHelpNonDirectTradeAmt,NotHelpNonDirectDebitTradeAmt,ProfitNonDirectTradeAmt,ProfitNonDirectDebitTradeAmt from TradeDaySummary where Id>=9790000 and TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0) tb group by UserId", MysqlConn.SqlConnStr); foreach (DataRow dr in list.Rows) { string UserId = dr["UserId"].ToString(); string ThisMonthTrade = dr[1].ToString(); CustomerSqlConn.op("update Users set ThisMonthTrade=" + ThisMonthTrade + " where Id=" + UserId, MysqlConn.SqlConnStr); } // Thread th = new Thread(StatTradeAmountEverDay); // th.IsBackground = true; // th.Start(date); } public void StatTradeAmountEverDay(object sender) { string date = sender.ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天交易额日志"); WebCMSEntities db = new WebCMSEntities(); try { 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"; List uids = new List(); DataTable startDt = OtherMySqlConn.dtable("select min(Id) from TradeRecord where CreateDate>='" + start + "'"); if (startDt.Rows.Count > 0) { startId = startDt.Rows[0][0].ToString(); } function.WriteLog(startId + "\n\n", "执行昨天交易额日志"); // DataTable endDt = OtherMySqlConn.dtable("select max(Id) from TradeRecord where CreateDate<'" + end + "'"); // if (endDt.Rows.Count > 0) // { // endId = endDt.Rows[0][0].ToString(); // } DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from TradeRecord where Id>=" + startId + " and Id<=" + endId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')"); function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天交易额日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["Id"].ToString()); string ParentNav = userDr["ParentNav"].ToString(); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志"); 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 + " 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 BrandId = int.Parse(selfDr["BrandId"].ToString()); 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 + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志"); 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 + ") group by BrandId,BankCardType,QrPayFlag"); function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志"); foreach (DataRow teamDr in teamDt.Rows) { int BrandId = int.Parse(teamDr["BrandId"].ToString()); 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(); } } } } } if (DateTime.Now.Day >= 2) { Thread.Sleep(5000); DataTable list = OtherMySqlConn.dtable("select UserId,sum(NonDirectTradeAmt) from UserTradeDaySummary where TradeDate='" + TradeDate + "' GROUP BY UserId"); foreach (DataRow dr in list.Rows) { string UserId = dr["UserId"].ToString(); string ThisMonthTrade = dr[1].ToString(); OtherMySqlConn.op("update Users set ThisMonthTrade=ThisMonthTrade+" + ThisMonthTrade + " where Id=" + UserId); } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天的交易额异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天交易额日志"); StatMerchantTrade(date); } //统计商户交易额 private void StatMerchantTrade(string date) { function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行商户交易额日志"); // WebCMSEntities db = new WebCMSEntities(); try { string start = date + " 00:00:00"; string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; CustomerSqlConn.op("insert into PosMerchantTradeSummay (MerchantId,BrandId,TradeDate,TradeMonth,TradeAmount,CreateDate) select *,now() from (select MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d') as TradeDate,DATE_FORMAT(CreateDate,'%Y%m') as TradeMonth,sum(TradeAmount) as TradeAmount from TradeRecord where Id>=13000000 and CreateDate>='" + start + "' and CreateDate<'" + end + "' and ActStatus=1 group by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d'),TradeDate,DATE_FORMAT(CreateDate,'%Y%m') order by MerchantId,BrandId,DATE_FORMAT(CreateDate,'%Y%m%d')) tb", MysqlConn.SqlConnStr); RedisDbconn.Instance.Clear("PosMerchantAmount:*"); RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "").Substring(0, 6)); //商户当月交易 RedisDbconn.Instance.Clear("PosMerchantAmount:*:" + date.Replace("-", "")); //商户当日交易 // foreach (DataRow selfDr in selfdt.Rows) // { // int BrandId = int.Parse(selfDr["BrandId"].ToString()); // int MerchantId = int.Parse(selfDr["MerchantId"].ToString()); // string TradeDate = selfDr["TradeDate"].ToString(); // TradeDate = TradeDate.Replace("-", ""); // string TradeMonth = TradeDate.Substring(0, 6); // decimal TradeAmount = decimal.Parse(selfDr["TradeAmount"].ToString()); // PosMerchantTradeSummay merStat = db.PosMerchantTradeSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId); // if (merStat == null) // { // merStat = db.PosMerchantTradeSummay.Add(new PosMerchantTradeSummay() // { // MerchantId = MerchantId, // TradeMonth = TradeMonth, // TradeDate = TradeDate, // BrandId = BrandId, // }).Entity; // db.SaveChanges(); // } // merStat.TradeAmount += TradeAmount; // db.SaveChanges(); // } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计商户的交易额"); } // db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行商户交易额日志"); } // 5. 创客升级 public void StatUserLevel() { Thread th = new Thread(StatUserLevelDo); th.IsBackground = true; th.Start(); } public void StatUserLevelDo() { while (true) { if(DateTime.Now.Day < 15 && DateTime.Now.Hour >= 0) { string Month = DateTime.Now.AddDays(-1).ToString("yyyy-MM"); string flag = function.ReadInstance("/ProfitFlag/" + Month + ".txt"); if (string.IsNullOrEmpty(flag)) { function.WritePage("/ProfitFlag/", Month + ".txt", DateTime.Now.ToString("HH:mm:ss")); LogoutUserHelper.Instance.DoWorks(); //每月一号归档注销创客,把伞下创客归到注销创客的上级 StatUserLevelStartNew(); } } Thread.Sleep(600000); } } public void StatUserLevelStart() { WebCMSEntities db = new WebCMSEntities(); MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities(); try { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); 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 sets = db.UserLevelSet.ToList(); bool op = true; int startid = 0; while(op) { var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList(); function.WriteLog(users.Count.ToString(), "创客升级日志"); if(users.Count > 0) { foreach (var subuser in users) { Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id); 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.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt); } //助利宝团队交易额 DataTable checkdt = OtherMySqlConn.dtable("SELECT SUM(TradeAmount) TradeAmount FROM HelpProfitMerTradeSummay WHERE (MerchantId IN(SELECT MerchantId FROM HelpProfitMerIds WHERE UserId IN(SELECT Id from Users WHERE ParentNav like '%," + user.Id + ",%' OR Id=" + user.Id + "))) AND TradeMonth=" + TradeMonth + ""); if (checkdt.Rows.Count > 0) { TradeAmount += decimal.Parse(function.CheckNum(checkdt.Rows[0]["TradeAmount"].ToString())); } //码牌团队交易额 check = mpmaindb.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team"); if (check) { TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team").Sum(m => m.TotalAmount); } UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount); if (set != null) { AfterLevel = set.Id; } // K6以上计算小市场是否达标 // 升级逻辑 bool upFlag = true; if(AfterLevel > 5) { DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) from TradeDaySummary where UserId in (select Id from Users where ParentUserId=" + user.Id + ") and TradeMonth='" + TradeMonth + "' and SeoTitle='team' group by UserId order by sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) desc"); int index = 0; decimal TradeAmt = 0; decimal BigTradeAmt = 0; foreach(DataRow dr in dt.Rows) { index += 1; if(index == 1) { BigTradeAmt = decimal.Parse(dr[1].ToString()); } else if(index > 1) { TradeAmt += decimal.Parse(dr[1].ToString()); } } if(TradeAmt < 12000000 || BigTradeAmt < 30000000) { if(AfterLevel > BeforeLevel && BeforeLevel >= 5) //保级，只升不降 { AfterLevel = BeforeLevel; } else if(AfterLevel > BeforeLevel && BeforeLevel < 5) { AfterLevel = 5; } else if(BeforeLevel > 5) { AfterLevel = 5; } else { upFlag = false; } } } if (AfterLevel > BeforeLevel && AfterLevel > 1 && upFlag) { function.WriteLog("升级：" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志"); user.UserLevel = AfterLevel; DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00"); UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id); if(rank == null) { db.UserRank.Add(new UserRank() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = user.Id, //创客 WhiteRank = BeforeLevel, Rank = AfterLevel, //当前等级 StatYear = DateTime.Now.Year, //统计年份 StatMonth = DateTime.Now.Month, //统计月份 TradeAmt = TradeAmount, //团队交易总额 UpgradeFlag = 1, //升级标识 OperateDate = DateTime.Now, //操作时间 Status = 1, }); db.SaveChanges(); } else { rank.TradeAmt = TradeAmount; rank.Rank = AfterLevel; db.SaveChanges(); } } // 降级逻辑 if(!upFlag && AfterLevel > 5) { AfterLevel = 5; } if (AfterLevel < BeforeLevel && BeforeLevel > 1) { function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志"); user.UserLevel = AfterLevel; DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00"); UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id); if(rank == null) { db.UserRank.Add(new UserRank() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = user.Id, //创客 WhiteRank = BeforeLevel, Rank = AfterLevel, //当前等级 StatYear = DateTime.Now.Year, //统计年份 StatMonth = DateTime.Now.Month, //统计月份 TradeAmt = TradeAmount, //团队交易总额 UpgradeFlag = 0, //升级标识 OperateDate = DateTime.Now, //操作时间 Status = 1, }); db.SaveChanges(); } else { rank.TradeAmt = TradeAmount; rank.Rank = AfterLevel; rank.Status = 1; db.SaveChanges(); } } } startid = subuser.Id; } function.WriteLog(startid.ToString(), "创客升级日志"); } else { op = false; } } function.WriteLog(DateTime.Now.ToString(), "创客升级日志"); } catch (Exception ex) { function.WriteLog(ex.ToString(), "创客升级异常"); } db.Dispose(); mpmaindb.Dispose(); RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1"); } public void StatUserLevelStartNew() { WebCMSEntities db = new WebCMSEntities(); MpMainModels.WebCMSEntities mpmaindb = new MpMainModels.WebCMSEntities(); MpMainModels2.WebCMSEntities mpmaindb2 = new MpMainModels2.WebCMSEntities(); try { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); 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 sets = db.UserLevelSet.ToList(); bool op = true; int startid = 138681; while(op) { var users = db.Users.Select(m => new { m.Id, m.AuthFlag }).Where(m => m.Id > startid && m.AuthFlag == 1).OrderBy(m => m.Id).Take(500).ToList(); function.WriteLog(users.Count.ToString(), "创客升级日志"); if(users.Count > 0) { foreach (var subuser in users) { Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id); 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.HelpNonDirectDebitTradeAmt + m.NotHelpNonDirectTradeAmt + m.NotHelpNonDirectDebitTradeAmt + m.ProfitNonDirectTradeAmt + m.ProfitNonDirectDebitTradeAmt); } //助利宝团队交易额 DataTable checkdt = OtherMySqlConn.dtable("SELECT SUM(TradeAmount) TradeAmount FROM HelpProfitMerTradeSummay WHERE (MerchantId IN(SELECT MerchantId FROM HelpProfitMerIds WHERE UserId IN(SELECT Id from Users WHERE ParentNav like '%," + user.Id + ",%' OR Id=" + user.Id + "))) AND TradeMonth=" + TradeMonth + ""); if (checkdt.Rows.Count > 0) { TradeAmount += decimal.Parse(function.CheckNum(checkdt.Rows[0]["TradeAmount"].ToString())); } //码牌团队交易额（直联） check = mpmaindb.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team"); if (check) { TradeAmount += mpmaindb.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4; } //码牌团队交易额（银联） check = mpmaindb2.UserAmountSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team"); if (check) { TradeAmount += mpmaindb2.UserAmountSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.IsAct == 1).Sum(m => m.TotalAmount) * 4; } //广电卡扶持期按1万/张计入职级 check = db.UserTradeMonthSummary.Any(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14); if (check) { TradeAmount += db.UserTradeMonthSummary.Where(m => m.UserId == user.Id && m.TradeMonth == TradeMonth && m.SeoTitle == "team" && m.BrandId == 14).Sum(m => m.ActiveBuddyMerStatus) * 10000; } UserLevelSet set = sets.FirstOrDefault(m => m.UpLevelGrowth <= TradeAmount && m.UpLevelIntegral > TradeAmount); if (set != null) { AfterLevel = set.Id; } // K6以上计算小市场是否达标 // 升级逻辑 bool upFlag = true; if(AfterLevel > 5) { DataTable dt = OtherMySqlConn.dtable("select UserId,sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+NotHelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) from TradeDaySummary where UserId in (select Id from Users where ParentUserId=" + user.Id + ") and TradeMonth='" + TradeMonth + "' and SeoTitle='team' group by UserId order by sum(HelpNonDirectTradeAmt+NotHelpNonDirectTradeAmt+ProfitNonDirectTradeAmt+HelpNonDirectDebitTradeAmt+ProfitNonDirectDebitTradeAmt) desc"); int index = 0; decimal TradeAmt = 0; decimal BigTradeAmt = 0; foreach(DataRow dr in dt.Rows) { index += 1; if(index == 1) { BigTradeAmt = decimal.Parse(dr[1].ToString()); } else if(index > 1) { TradeAmt += decimal.Parse(dr[1].ToString()); } } if(TradeAmt < 12000000 || BigTradeAmt < 30000000) { if(AfterLevel > BeforeLevel && BeforeLevel >= 5) //保级，只升不降 { AfterLevel = BeforeLevel; } else if(AfterLevel > BeforeLevel && BeforeLevel < 5) { AfterLevel = 5; } else if(BeforeLevel > 5) { AfterLevel = 5; } else { upFlag = false; } } } if (AfterLevel > BeforeLevel && AfterLevel > 0 && upFlag) { function.WriteLog("升级：" + user.Id.ToString() + BeforeLevel + "->" + AfterLevel, "创客升级日志"); user.UserLevel = AfterLevel; DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00"); UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id); if(rank == null) { db.UserRank.Add(new UserRank() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = user.Id, //创客 WhiteRank = BeforeLevel, Rank = AfterLevel, //当前等级 StatYear = DateTime.Now.Year, //统计年份 StatMonth = DateTime.Now.Month, //统计月份 TradeAmt = TradeAmount, //团队交易总额 UpgradeFlag = 1, //升级标识 OperateDate = DateTime.Now, //操作时间 Status = 1, }); db.SaveChanges(); } else { rank.TradeAmt = TradeAmount; rank.Rank = AfterLevel; db.SaveChanges(); } UserRankWhite rankWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == user.Id); if(rankWhite != null) { if(Utils.Instance.GetUserLevel(user.Id) >= rankWhite.Rank) { user.Version = 0; db.SaveChanges(); } } } // 降级逻辑 if(!upFlag && AfterLevel > 5) { AfterLevel = 5; } // 如果是达标创客，只能降级到K1 if(AfterLevel == 0 && Utils.Instance.IsStandardUser(user.Id)) { AfterLevel = 1; } if (AfterLevel < BeforeLevel && BeforeLevel > 0) { function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志"); user.UserLevel = AfterLevel; DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00"); UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id); if(rank == null) { db.UserRank.Add(new UserRank() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = user.Id, //创客 WhiteRank = BeforeLevel, Rank = AfterLevel, //当前等级 StatYear = DateTime.Now.Year, //统计年份 StatMonth = DateTime.Now.Month, //统计月份 TradeAmt = TradeAmount, //团队交易总额 UpgradeFlag = 0, //升级标识 OperateDate = DateTime.Now, //操作时间 Status = 1, }); db.SaveChanges(); } else { rank.TradeAmt = TradeAmount; rank.Rank = AfterLevel; rank.Status = 1; db.SaveChanges(); } UserRankWhite rankWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == user.Id); if(rankWhite != null) { if(Utils.Instance.GetUserLevel(user.Id) < rankWhite.Rank) { user.Version = 3; db.SaveChanges(); } } } } startid = subuser.Id; } function.WriteLog(startid.ToString(), "创客升级日志"); } else { op = false; } } //查找K0创客，如果商城下单购买一组机具券，则预设为K1 List productIds = new List(); productIds.Add(10); productIds.Add(11); op = true; startid = 0; while(op) { var users = db.Users.Select(m => new { m.Id, m.AuthFlag, m.UserLevel }).Where(m => m.Id > startid && m.AuthFlag == 1 && m.UserLevel == 0).OrderBy(m => m.Id).Take(50).ToList(); if(users.Count > 0) { foreach (var subuser in users) { bool hasOrder = db.Orders.Any(m => m.UserId == subuser.Id && m.Status > 0 && productIds.Contains(m.ProductId)); if(hasOrder) { Utils.Instance.LeaderPreUserLevel(subuser.Id, 1, DateTime.Parse("2025-01-01 00:00:00")); db.UserRank.Add(new UserRank() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, UserId = subuser.Id, //创客 WhiteRank = 0, Rank = 1, //当前等级 StatYear = DateTime.Now.Year, //统计年份 StatMonth = DateTime.Now.Month, //统计月份 TradeAmt = 0, //团队交易总额 UpgradeFlag = 1, //升级标识 OperateDate = DateTime.Now, //操作时间 Status = 1, }); Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id); if(user != null) { user.Version = 3; } db.SaveChanges(); } } } else { op = false; } } function.WriteLog(DateTime.Now.ToString(), "创客升级日志"); } catch (Exception ex) { function.WriteLog(ex.ToString(), "创客升级异常"); } db.Dispose(); mpmaindb.Dispose(); mpmaindb2.Dispose(); RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1"); } // 统计创客激活数 public void StartPosActNum() { Thread th = new Thread(StartPosActNumFor); th.IsBackground = true; th.Start(); } public void StartPosActNumFor() { // DateTime end = DateTime.Parse("2022-06-15 00:00:00"); // DateTime check = DateTime.Parse("2022-06-14"); // while (check <= end) // { // StartPosActNumDo(check.ToString("yyyy-MM-dd")); // check = check.AddDays(1); // } while (true) { if(DateTime.Now.Hour >= 2) { StartPosActNumEverTime(); } Thread.Sleep(100); } } public void StartPosActNumDo(object sender) { string date = sender.ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行创客激活数日志"); WebCMSEntities db = new WebCMSEntities(); try { 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"; List uids = new List(); DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT BuyUserId from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "')"); function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行创客激活数日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["Id"].ToString()); string ParentNav = userDr["ParentNav"].ToString(); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志"); DataTable selfdt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId=" + UserId + " group by BrandId"); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志"); foreach (DataRow selfDr in selfdt.Rows) { int BrandId = int.Parse(selfDr["BrandId"].ToString()); int QrPayFlag = 0; int ActCount = int.Parse(selfDr[1].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(); } selfStat.DirectDebitCapNum += ActCount; 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 + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志"); DataTable teamDt = OtherMySqlConn.dtable("select BrandId,count(Id) from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "' and BuyUserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by BrandId"); function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志"); foreach (DataRow teamDr in teamDt.Rows) { int BrandId = int.Parse(teamDr["BrandId"].ToString()); int QrPayFlag = 0; int ActCount = int.Parse(teamDr[1].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(); } teamStat.NonDirectDebitCapNum += ActCount; db.SaveChanges(); } } } } } OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where QueryCount=0 and ActivationState=1 and ActivationTime>='" + start + "' and ActivationTime<'" + end + "'"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行创客激活数异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行创客激活数日志"); Thread.Sleep(60000); } public void StartPosActNumEverTime() { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志"); WebCMSEntities db = new WebCMSEntities(); try { DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and BuyUserId>0 limit 50"); if(idsDt.Rows.Count > 0) { string ids = ""; foreach (DataRow idsDr in idsDt.Rows) { ids += idsDr["Id"].ToString() + ","; } DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')"); if (userDt.Rows.Count > 0) { function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["BuyUserId"].ToString()); int BrandId = int.Parse(userDr["BrandId"].ToString()); string TradeDate = userDr[2].ToString(); int ActCount = int.Parse(function.CheckInt(userDr[3].ToString())); int QrPayFlag = 0; string TradeMonth = TradeDate.Substring(0, 6); string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2); string start = date + " 00:00:00"; string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users(); string ParentNav = user.ParentNav; 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(); } selfStat.DirectDebitCapNum += ActCount; ParentNav += "," + UserId + ","; if (!string.IsNullOrEmpty(ParentNav)) { string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(','); foreach (string NavUserIdString in ParentNavList) { int NavUserId = int.Parse(NavUserIdString); 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(); } teamStat.NonDirectDebitCapNum += ActCount; } } } db.SaveChanges(); OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")"); } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行创客激活数异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行创客激活数日志"); } // 统计新增创客数 public void StartNewUserNum() { Thread th = new Thread(StartNewUserNumFor); th.IsBackground = true; th.Start(); } public void StartNewUserNumFor() { // DateTime end = DateTime.Parse("2022-06-15 00:00:00"); // DateTime check = DateTime.Parse("2022-06-14"); // while (check <= end) // { // StartNewUserNumDo(check.ToString("yyyy-MM-dd")); // check = check.AddDays(1); // } while (true) { if(DateTime.Now.Hour >= 2) { StartNewUserNumEverTime(); } Thread.Sleep(120000); } } public void StartNewUserNumDo(object sender) { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); string date = sender.ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志"); WebCMSEntities db = new WebCMSEntities(); try { string StatDate = date.Replace("-", ""); string StatMonth = StatDate.Substring(0, 6); string start = date + " 00:00:00"; string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; List uids = new List(); DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'"); function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "执行新增创客数日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["Id"].ToString()); string ParentNav = userDr["ParentNav"].ToString(); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志"); DataTable selfdt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentUserId=" + UserId + ""); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志"); foreach (DataRow selfDr in selfdt.Rows) { int AddCount = int.Parse(selfDr[0].ToString()); PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self"); if (selfStat == null) { selfStat = db.PullnewSummary.Add(new PullnewSummary() { UserId = UserId, StatMonth = StatMonth, StatDate = StatDate, SeoTitle = "self", }).Entity; db.SaveChanges(); } selfStat.RecUserAuthNum += AddCount; 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 + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志"); DataTable teamDt = OtherMySqlConn.dtable("select count(Id) from Users where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "' and ParentNav like '%," + NavUserId + ",%'"); function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志"); foreach (DataRow teamDr in teamDt.Rows) { int AddCount = int.Parse(teamDr[0].ToString()); PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team"); if (teamStat == null) { teamStat = db.PullnewSummary.Add(new PullnewSummary() { UserId = NavUserId, StatMonth = StatMonth, StatDate = StatDate, SeoTitle = "team", }).Entity; db.SaveChanges(); } teamStat.RecUserAuthNum += AddCount; db.SaveChanges(); } } } } } OtherMySqlConn.op("update Users set QueryCount=1 where QueryCount=0 and AuthFlag=1 and AuthDate>='" + start + "' and AuthDate<'" + end + "'"); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "执行新增创客数异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行新增创客数日志"); Thread.Sleep(60000); } public void StartNewUserNumEverTime() { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志"); WebCMSEntities db = new WebCMSEntities(); try { DataTable idsDt = OtherMySqlConn.dtable("select Id from Users where QueryCount=0 and AuthFlag=1 and AuthDate is not null limit 50"); if(idsDt.Rows.Count > 0) { string ids = ""; foreach (DataRow idsDr in idsDt.Rows) { ids += idsDr["Id"].ToString() + ","; } DataTable userDt = OtherMySqlConn.dtable("select ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d'),count(Id) from Users where Id in (" + ids.TrimEnd(',') + ") group by ParentUserId,DATE_FORMAT(AuthDate, '%Y%m%d')"); if(userDt.Rows.Count > 0) { function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行新增创客数日志"); foreach (DataRow userDr in userDt.Rows) { string StatDate = userDr[1].ToString(); int UserId = int.Parse(userDr["ParentUserId"].ToString()); string StatMonth = StatDate.Substring(0, 6); string date = StatDate.Substring(0, 4) + "-" + StatDate.Substring(4, 2) + "-" + StatDate.Substring(6, 2); string start = date + " 00:00:00"; string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; int AddCount = int.Parse(userDr[2].ToString()); Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users(); string ParentNav = user.ParentNav; PullnewSummary selfStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == UserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "self"); if (selfStat == null) { selfStat = db.PullnewSummary.Add(new PullnewSummary() { UserId = UserId, StatMonth = StatMonth, StatDate = StatDate, SeoTitle = "self", }).Entity; db.SaveChanges(); } selfStat.RecUserAuthNum += AddCount; ParentNav += "," + UserId + ","; if (!string.IsNullOrEmpty(ParentNav)) { string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(','); foreach (string NavUserIdString in ParentNavList) { int NavUserId = int.Parse(NavUserIdString); PullnewSummary teamStat = db.PullnewSummary.FirstOrDefault(m => m.UserId == NavUserId && m.StatMonth == StatMonth && m.StatDate == StatDate && m.SeoTitle == "team"); if (teamStat == null) { teamStat = db.PullnewSummary.Add(new PullnewSummary() { UserId = NavUserId, StatMonth = StatMonth, StatDate = StatDate, SeoTitle = "team", }).Entity; db.SaveChanges(); } teamStat.RecUserAuthNum += AddCount; } } } db.SaveChanges(); OtherMySqlConn.op("update Users set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")"); } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时执行新增创客数异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行新增创客数日志"); } // 每天统计头一天的收益 public void StatProfit() { Thread th = new Thread(StatProfitDo); th.IsBackground = true; th.Start(); } public void StatProfitDo() { // DateTime end = DateTime.Parse("2022-06-16 00:00:00"); // DateTime check = DateTime.Parse("2022-06-16"); // while (check <= end) // { // StatProfitEverDay(check.ToString("yyyy-MM-dd")); // Thread.Sleep(1000); // check = check.AddDays(1); // } while (true) { if(DateTime.Now.Hour >= 2) { StatProfitEverDayEverTime(); } Thread.Sleep(120000); } } public void StatProfitEverDay(object sender) { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); string date = sender.ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志"); WebCMSEntities db = new WebCMSEntities(); try { 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"; List uids = new List(); DataTable startDt = OtherMySqlConn.dtable("select min(Id) from UserAccountRecord where CreateDate>='" + start + "'"); if (startDt.Rows.Count > 0) { startId = startDt.Rows[0][0].ToString(); } function.WriteLog(startId + "\n\n", "执行昨天收益日志"); DataTable userDt = OtherMySqlConn.dtable("select Id,ParentNav from Users where Id in (select DISTINCT UserId from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "')"); function.WriteLog("交易人数:" + userDt.Rows.Count + "\n\n", "执行昨天收益日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["Id"].ToString()); string ParentNav = userDr["ParentNav"].ToString(); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志"); DataTable selfdt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId=" + UserId + " group by ChangeType,ProductType"); function.WriteLog(UserId + ":" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志"); foreach (DataRow selfDr in selfdt.Rows) { int ChangeType = int.Parse(selfDr["ChangeType"].ToString()); int ProductType = int.Parse(selfDr["ProductType"].ToString()); decimal ProfitAmount = decimal.Parse(selfDr[2].ToString()); UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self"); if (selfStat == null) { selfStat = db.UserRebateDetail.Add(new UserRebateDetail() { UserId = UserId, TradeMonth = TradeMonth, TradeDate = TradeDate, RebateType = ChangeType, ProductType = ProductType, SeoTitle = "self", }).Entity; db.SaveChanges(); } selfStat.CreditRewardAmount += ProfitAmount; 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 + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志"); DataTable teamDt = OtherMySqlConn.dtable("select ChangeType,ProductType,sum(ChangeAmount) from UserAccountRecord where Id>=" + startId + " and CreateDate>='" + start + "' and CreateDate<'" + end + "' and UserId in (select Id from Users where ParentNav like '%," + NavUserId + ",%' or Id=" + NavUserId + ") group by ChangeType,ProductType"); function.WriteLog(NavUserId + ":team:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志"); foreach (DataRow teamDr in teamDt.Rows) { int ChangeType = int.Parse(teamDr["ChangeType"].ToString()); int ProductType = int.Parse(teamDr["ProductType"].ToString()); decimal ProfitAmount = decimal.Parse(teamDr[2].ToString()); UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team"); if (teamStat == null) { teamStat = db.UserRebateDetail.Add(new UserRebateDetail() { UserId = NavUserId, TradeMonth = TradeMonth, TradeDate = TradeDate, RebateType = ChangeType, ProductType = ProductType, SeoTitle = "team", }).Entity; db.SaveChanges(); } teamStat.CreditRewardAmount += ProfitAmount; db.SaveChanges(); } } } } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天收益异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "执行昨天收益日志"); } public void StatProfitEverDayEverTime() { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志"); WebCMSEntities db = new WebCMSEntities(); try { string startId = function.ReadInstance("/UserAccountRecord/Id.txt"); if(string.IsNullOrEmpty(startId)) { startId = "160653"; } DataTable idsDt = OtherMySqlConn.dtable("select Id from UserAccountRecord 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 userDt = OtherMySqlConn.dtable("select UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d'),sum(ChangeAmount) from UserAccountRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ChangeType,ProductType,DATE_FORMAT(CreateDate, '%Y%m%d')"); if (userDt.Rows.Count > 0) { function.WriteLog("收益人数:" + userDt.Rows.Count + "\n\n", "实时统计收益日志"); foreach (DataRow userDr in userDt.Rows) { int UserId = int.Parse(userDr["UserId"].ToString()); int ChangeType = int.Parse(userDr["ChangeType"].ToString()); int ProductType = int.Parse(userDr["ProductType"].ToString()); string TradeDate = userDr[3].ToString(); decimal ProfitAmount = decimal.Parse(userDr[4].ToString()); string TradeMonth = TradeDate.Substring(0, 6); string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2); string start = date + " 00:00:00"; string end = DateTime.Parse(date).AddDays(1).ToString("yyyy-MM-dd") + " 00:00:00"; Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users(); string ParentNav = user.ParentNav; UserRebateDetail selfStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == UserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "self"); if (selfStat == null) { selfStat = db.UserRebateDetail.Add(new UserRebateDetail() { UserId = UserId, TradeMonth = TradeMonth, TradeDate = TradeDate, RebateType = ChangeType, ProductType = ProductType, SeoTitle = "self", }).Entity; db.SaveChanges(); } selfStat.CreditRewardAmount += ProfitAmount; ParentNav += "," + UserId + ","; if (!string.IsNullOrEmpty(ParentNav)) { string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(','); foreach (string NavUserIdString in ParentNavList) { int NavUserId = int.Parse(NavUserIdString); UserRebateDetail teamStat = db.UserRebateDetail.FirstOrDefault(m => m.UserId == NavUserId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.RebateType == ChangeType && m.ProductType == ProductType && m.SeoTitle == "team"); if (teamStat == null) { teamStat = db.UserRebateDetail.Add(new UserRebateDetail() { UserId = NavUserId, TradeMonth = TradeMonth, TradeDate = TradeDate, RebateType = ChangeType, ProductType = ProductType, SeoTitle = "team", }).Entity; db.SaveChanges(); } teamStat.CreditRewardAmount += ProfitAmount; } } } db.SaveChanges(); OtherMySqlConn.op("update UserAccountRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")"); function.WritePage("/UserAccountRecord/", "Id.txt", startId); } } } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "实时统计收益异常"); } db.Dispose(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时统计收益日志"); } #region 判断品牌互斥条件，根据身份证号 public bool CheckRepeatByBrand(WebCMSEntities db, int MerchantId) { int check = db.PosMachinesTwo.Count(m => m.Status > -1 && m.BindMerchantId == MerchantId); return false; } #endregion } }