|
|
@@ -0,0 +1,1565 @@
|
|
|
+using System;
|
|
|
+using System.Collections.Generic;
|
|
|
+using System.Linq;
|
|
|
+using System.Data;
|
|
|
+using MySystem.Models;
|
|
|
+using Library;
|
|
|
+using LitJson;
|
|
|
+using System.Threading;
|
|
|
+using Microsoft.Extensions.Hosting;
|
|
|
+using System.Threading.Tasks;
|
|
|
+
|
|
|
+namespace MySystem
|
|
|
+{
|
|
|
+ public class ProfitAfterHelper
|
|
|
+ {
|
|
|
+ public readonly static ProfitAfterHelper Instance = new ProfitAfterHelper();
|
|
|
+ private ProfitAfterHelper()
|
|
|
+ {
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public void StartListenProfit()
|
|
|
+ {
|
|
|
+ Thread th = new Thread(StartListenProfitDo);
|
|
|
+ th.IsBackground = true;
|
|
|
+ th.Start();
|
|
|
+ }
|
|
|
+
|
|
|
+ public void StartListenProfitDo()
|
|
|
+ {
|
|
|
+ while(true)
|
|
|
+ {
|
|
|
+ if(DateTime.Now.Day < 10 && DateTime.Now.Hour > 2 && DateTime.Now.Hour < 23)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ DoProfit();
|
|
|
+ }
|
|
|
+ catch(Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "来客吧分润异常");
|
|
|
+ }
|
|
|
+ Thread.Sleep(600000);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Thread.Sleep(3600000);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //分润算法
|
|
|
+ public void DoProfit()
|
|
|
+ {
|
|
|
+ string TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
|
+ string check = function.ReadInstance("/ProfitFlag/" + TradeMonth + "-after.txt");
|
|
|
+ if(!string.IsNullOrEmpty(check))
|
|
|
+ {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ function.WritePage("/ProfitFlag/", TradeMonth + "-after.txt", DateTime.Now.ToString());
|
|
|
+ KxsMainModels.WebCMSEntities kxsdb = new KxsMainModels.WebCMSEntities();
|
|
|
+ WebCMSEntities dbnew = new WebCMSEntities();
|
|
|
+ DataTable dt = CustomerSqlConn.dtable("select IsAct,UserId,sum(TotalAmount) from UserAmountSummaryAfter where TradeMonth='" + TradeMonth + "' and SeoTitle='self' group by IsAct,UserId", MysqlConn.SqlConnStr);
|
|
|
+ foreach(DataRow dr in dt.Rows)
|
|
|
+ {
|
|
|
+ int UserId = int.Parse(dr["UserId"].ToString());
|
|
|
+ bool IsActive = dr["IsAct"].ToString() == "1";
|
|
|
+ decimal TotalAmount = decimal.Parse(dr[2].ToString());
|
|
|
+ List<ProfitUsers> users = new List<ProfitUsers>();
|
|
|
+ int TopUserId = 0; //顶级创客Id
|
|
|
+ KxsMainModels.Users us = kxsdb.Users.FirstOrDefault(a => a.Id == UserId);
|
|
|
+ if (us != null)
|
|
|
+ {
|
|
|
+ string uidstring = us.Id.ToString();
|
|
|
+ if (!string.IsNullOrEmpty(us.ParentNav))
|
|
|
+ {
|
|
|
+ uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
|
|
|
+ string[] parents = us.ParentNav.Trim(',').Replace(",,", ",").Split(',');
|
|
|
+ if(parents.Length > 1)
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(function.CheckInt(parents[1]));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(function.CheckInt(parents[0]));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ string[] uidlist = uidstring.Split(',');
|
|
|
+ Array.Reverse(uidlist);
|
|
|
+ foreach (string uidstr in uidlist)
|
|
|
+ {
|
|
|
+ int puid = int.Parse(function.CheckInt(uidstr));
|
|
|
+ KxsMainModels.Users pus = kxsdb.Users.FirstOrDefault(a => a.Id == puid);
|
|
|
+ if (pus != null)
|
|
|
+ {
|
|
|
+ users.Add(new ProfitUsers()
|
|
|
+ {
|
|
|
+ UserId = pus.Id,
|
|
|
+ MakerCode = pus.MakerCode,
|
|
|
+ RealName = pus.RealName,
|
|
|
+ UserNav = pus.ParentNav,
|
|
|
+ UserLevel = pus.UserLevel,
|
|
|
+ CreateDate = pus.CreateDate.Value,
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ KxsMainModels.Users topUser = kxsdb.Users.FirstOrDefault(a => a.Id == TopUserId) ?? new KxsMainModels.Users();
|
|
|
+ List<ProfitResult> list = new List<ProfitResult>();
|
|
|
+ list = StartProft(TotalAmount, 1, users, IsActive);
|
|
|
+ try
|
|
|
+ {
|
|
|
+ foreach (ProfitResult sub in list)
|
|
|
+ {
|
|
|
+ int ProfitType = sub.UserId == UserId ? 0 : 1;
|
|
|
+ ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.BrandId == 1 && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
|
|
|
+ if (editprofitrecord == null)
|
|
|
+ {
|
|
|
+ editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UserId = sub.UserId, //创客
|
|
|
+ BrandId = 1, //品牌
|
|
|
+ ProfitType = ProfitType, //创客分润类型
|
|
|
+ TradeMonth = TradeMonth, //交易月
|
|
|
+ TopUserId = TopUserId, //顶级创客
|
|
|
+ CreateMan = sub.MakerCode, //创客编号
|
|
|
+ UpdateMan = topUser.MakerCode, //顶级编号
|
|
|
+ SeoTitle = sub.RealName, //创客姓名
|
|
|
+ SeoKeyword = topUser.RealName, //创客姓名
|
|
|
+ }).Entity;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ string RecordNo = "KPM";
|
|
|
+ int RecordId = editprofitrecord.Id;
|
|
|
+ string RecordIdString = RecordId.ToString();
|
|
|
+ for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
|
|
|
+ {
|
|
|
+ RecordIdString = "0" + RecordIdString;
|
|
|
+ }
|
|
|
+ RecordNo += RecordIdString;
|
|
|
+ editprofitrecord.RecordNo = RecordNo;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ if(IsActive)
|
|
|
+ {
|
|
|
+ editprofitrecord.CreditTradeAmt += TotalAmount;
|
|
|
+ editprofitrecord.CreditTradeProfit += sub.Money;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editprofitrecord.TradeAmt += TotalAmount;
|
|
|
+ editprofitrecord.TradeProfit += sub.Money;
|
|
|
+ }
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog(ex.ToString(), "分润异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dbnew.Dispose();
|
|
|
+ kxsdb.Dispose();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ #region 分润算法
|
|
|
+ public List<ProfitResult> StartProft(decimal TotalAmount, int LevelKindId, List<ProfitUsers> users, bool IsActive = true)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("\n\nTotalAmount：" + TotalAmount + "；", "来客吧分润日志");
|
|
|
+ string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
|
+ WebCMSEntities db = new WebCMSEntities();
|
|
|
+ List<UserLevelSet> levels = db.UserLevelSet.ToList();
|
|
|
+ List<ProfitResult> result = new List<ProfitResult>();
|
|
|
+ ProfitObjects obj = db.ProfitObjects.FirstOrDefault();
|
|
|
+ if (obj.Status == 1) //判断分润是否开启
|
|
|
+ {
|
|
|
+ int maxLevel = obj.MaxLevel; //最大等级
|
|
|
+ int maxFloor = obj.MaxFloor; //最大层级
|
|
|
+ decimal diffLevelProfit = 0; //等级级差
|
|
|
+ ProfitObjectLevels maxlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == 9) ?? new ProfitObjectLevels(); //获取最高等级参数
|
|
|
+ decimal maxPercent = IsActive ? maxlevel.DebitPercents : maxlevel.Percents;
|
|
|
+ LogHelper.Instance.WriteLog("maxPercent：" + maxPercent + "；", "来客吧分润日志");
|
|
|
+ decimal maxLevelProfit = TotalAmount * maxPercent;
|
|
|
+ LogHelper.Instance.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
|
|
|
+ maxLevelProfit = PublicFunction.NumberFormat(maxLevelProfit);
|
|
|
+ LogHelper.Instance.WriteLog("maxLevelProfit：" + maxLevelProfit + "；", "来客吧分润日志");
|
|
|
+ // decimal diffDiviProfit = 0; //分红级差
|
|
|
+ int curLevel = 0; //当前层级的会员等级
|
|
|
+ for (int curFloor = 1; curFloor <= users.Count; curFloor++)
|
|
|
+ {
|
|
|
+ ProfitUsers user = new ProfitUsers();
|
|
|
+ if (curFloor <= users.Count)
|
|
|
+ {
|
|
|
+ user = users[curFloor - 1];
|
|
|
+ }
|
|
|
+ SubUser selfUser = GetUser(user.UserId, Month) ?? new SubUser();
|
|
|
+ int UserLevel = GetUserLevel(selfUser); //当前会员等级
|
|
|
+ //判断当前创客是否有直推的激活机具，并且在活动时间内
|
|
|
+ if (curLevel == maxLevel)
|
|
|
+ {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if (UserLevel <= maxLevel && UserLevel >= curLevel)
|
|
|
+ {
|
|
|
+ ProfitObjectLevels objlevel = db.ProfitObjectLevels.FirstOrDefault(m => m.Id == UserLevel); //获取当前等级参数
|
|
|
+ if (objlevel != null)
|
|
|
+ {
|
|
|
+ decimal getLevelProfit = 0; //等级分润
|
|
|
+ UserProfitSet profitSet = new UserProfitSet();
|
|
|
+ decimal profitPercent = IsActive ? objlevel.DebitPercents : objlevel.Percents;
|
|
|
+ LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + profitPercent + "；", "来客吧分润日志");
|
|
|
+ if (profitPercent > 0)
|
|
|
+ {
|
|
|
+ decimal profitTmp = TotalAmount * profitPercent;
|
|
|
+ getLevelProfit += profitTmp;
|
|
|
+ LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + profitTmp + "；", "来客吧分润日志");
|
|
|
+ }
|
|
|
+ decimal money = getLevelProfit;
|
|
|
+ getLevelProfit -= diffLevelProfit;
|
|
|
+ if (objlevel.LevelDiff == 1) //判断是否有级差
|
|
|
+ {
|
|
|
+ diffLevelProfit = money;
|
|
|
+ }
|
|
|
+ if (getLevelProfit >= obj.MinProfitVal)
|
|
|
+ {
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = user.UserId,
|
|
|
+ MakerCode = user.MakerCode,
|
|
|
+ RealName = user.RealName,
|
|
|
+ UserNav = user.UserNav,
|
|
|
+ Money = PublicFunction.NumberFormat(getLevelProfit),
|
|
|
+ ProfitRate = profitSet.ProfitRate,
|
|
|
+ ProfitPercent = profitSet.ProfitPercent,
|
|
|
+ AddOrSubRate = profitSet.AddOrSubRate,
|
|
|
+ ProfitRateBase = profitSet.ProfitRateBase,
|
|
|
+ });
|
|
|
+ LogHelper.Instance.WriteLog("money：" + UserLevel + "：" + PublicFunction.NumberFormat(getLevelProfit) + "；", "来客吧分润日志");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(curLevel < UserLevel)
|
|
|
+ {
|
|
|
+ curLevel = UserLevel;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ db.Dispose();
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ public SubUser GetUser(int UserId, string Month)
|
|
|
+ {
|
|
|
+ SubUser user = new SubUser();
|
|
|
+ DataTable dt = GetDataTable("select * from Users" + Month + " where Id=" + UserId);
|
|
|
+ if(dt.Rows.Count > 0)
|
|
|
+ {
|
|
|
+ user.Id = int.Parse(dt.Rows[0]["Id"].ToString());
|
|
|
+ user.ParentUserId = int.Parse(dt.Rows[0]["ParentUserId"].ToString());
|
|
|
+ user.ParentNav = dt.Rows[0]["ParentNav"].ToString();
|
|
|
+ user.UserLevel = int.Parse(dt.Rows[0]["UserLevel"].ToString());
|
|
|
+ user.PreUserLevel = int.Parse(dt.Rows[0]["PreUserLevel"].ToString());
|
|
|
+ user.PreLeaderLevel = int.Parse(dt.Rows[0]["PreLeaderLevel"].ToString());
|
|
|
+ user.PreOpLevel = int.Parse(dt.Rows[0]["PreOpLevel"].ToString());
|
|
|
+ }
|
|
|
+ return user;
|
|
|
+ }
|
|
|
+
|
|
|
+ public int GetUserLevel(SubUser user)
|
|
|
+ {
|
|
|
+ int level = user.UserLevel;
|
|
|
+ if(user.PreUserLevel > level) level = user.PreUserLevel;
|
|
|
+ if(user.PreLeaderLevel > level) level = user.PreLeaderLevel;
|
|
|
+ if(user.PreOpLevel > level) level = user.PreOpLevel;
|
|
|
+ return level;
|
|
|
+ }
|
|
|
+
|
|
|
+ public DataTable GetDataTable(string sqlstr)
|
|
|
+ {
|
|
|
+ DataTable dt = CustomerSqlConn.dtable(sqlstr, Library.ConfigurationManager.AppSettings["KxsStatSqlConnStr"].ToString());
|
|
|
+ return dt;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 活动奖励算法
|
|
|
+ public List<ProfitResult> StartActiveProft(WebCMSEntities dbnew, PosMachinesTwo machine, string CheckObject, int ObjectId, Dictionary<string, ProfitUsers> Users, ActiveCheckData StatParam)
|
|
|
+ {
|
|
|
+ DateTime Start = machine.ActivationTime.Value;
|
|
|
+ List<ProfitResult> result = new List<ProfitResult>();
|
|
|
+ ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + ObjectId);
|
|
|
+ if (obj.Status == 1) //判断分润是否开启
|
|
|
+ {
|
|
|
+ List<ProfitObjectsActives> objactives = RedisDbconn.Instance.GetList<ProfitObjectsActives>("pobjact" + ObjectId);
|
|
|
+ foreach (ProfitObjectsActives objactive in objactives)
|
|
|
+ {
|
|
|
+ if (objactive.StartDate <= DateTime.Now && objactive.EndDate >= DateTime.Now)
|
|
|
+ {
|
|
|
+ string UserKey = "UserId";
|
|
|
+ decimal ProfitMoney = objactive.ProfitNumber; //获得数
|
|
|
+ decimal FinishNumber = objactive.FinishNumber; //完成数
|
|
|
+ string CheckKey = CheckObject + "-" + objactive.Id;
|
|
|
+ ProfitObjectsActiveCheck check = dbnew.ProfitObjectsActiveCheck.FirstOrDefault(m => m.CheckData == CheckKey);
|
|
|
+ if (ProfitMoney > 0 && check == null)
|
|
|
+ {
|
|
|
+ int LimitDateKind = objactive.LimitDateKind; //时间限制类型 日月年/自定义
|
|
|
+ if (LimitDateKind == 4)
|
|
|
+ {
|
|
|
+ DateTime LimitCustomerDate = objactive.LimitCustomerDate.Value; //过期时间
|
|
|
+ if (LimitCustomerDate >= DateTime.Now)
|
|
|
+ {
|
|
|
+ decimal totalTradeMoney = 0;
|
|
|
+ OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
|
|
|
+ string sqlstr = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + LimitCustomerDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
|
|
|
+ DataTable dt = OtherMySqlConn.dtable(sqlstr);
|
|
|
+ if (dt.Rows.Count > 0)
|
|
|
+ {
|
|
|
+ totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
|
|
|
+ }
|
|
|
+ // OtherMySqlConn.connstr = ;
|
|
|
+ if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal) //达到完成数，发放奖励
|
|
|
+ {
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = Users[UserKey].UserId,
|
|
|
+ UserNav = Users[UserKey].UserNav,
|
|
|
+ Money = ProfitMoney,
|
|
|
+ });
|
|
|
+ dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
|
|
|
+ {
|
|
|
+ CheckData = CheckKey
|
|
|
+ });
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ int LimitDateVal = objactive.LimitDateVal; //时间限制值 日月年
|
|
|
+ DateTime checkDate = Start;
|
|
|
+ if (LimitDateKind == 1)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddDays(LimitDateVal);
|
|
|
+ }
|
|
|
+ else if (LimitDateKind == 2)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddMonths(LimitDateVal);
|
|
|
+ }
|
|
|
+ else if (LimitDateKind == 3)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddYears(LimitDateVal);
|
|
|
+ }
|
|
|
+ if (checkDate >= DateTime.Now)
|
|
|
+ {
|
|
|
+ decimal totalTradeMoney = 0;
|
|
|
+ OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OldSqlConnStr"].ToString();
|
|
|
+ string sql = "select sum(" + StatParam.StatField + ") from " + StatParam.TableName + " where Id>=" + StatParam.StartId + " and " + StatParam.CheckField + "='" + CheckObject + "'" + StatParam.OtherCondition + " and CreateDate>='" + Start.ToString("yyyy-MM-dd HH:mm:ss") + "' and CreateDate<='" + checkDate.ToString("yyyy-MM-dd HH:mm:ss") + "'";
|
|
|
+ DataTable dt = OtherMySqlConn.dtable(sql);
|
|
|
+ if (dt.Rows.Count > 0)
|
|
|
+ {
|
|
|
+ totalTradeMoney = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
|
|
|
+ }
|
|
|
+ // OtherMySqlConn.connstr = ;
|
|
|
+ if (totalTradeMoney >= FinishNumber && ProfitMoney >= obj.MinProfitVal) //达到完成数，发放奖励
|
|
|
+ {
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = Users[UserKey].UserId,
|
|
|
+ UserNav = Users[UserKey].UserNav,
|
|
|
+ Money = ProfitMoney,
|
|
|
+ });
|
|
|
+ dbnew.ProfitObjectsActiveCheck.Add(new ProfitObjectsActiveCheck()
|
|
|
+ {
|
|
|
+ CheckData = CheckKey
|
|
|
+ });
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 激活奖励算法
|
|
|
+ public ProfitResult ActivationProft(PosMachinesTwo machine, ProfitUsers User)
|
|
|
+ {
|
|
|
+ int BrandId = machine.BrandId;
|
|
|
+ DateTime Start = machine.ActivationTime.Value;
|
|
|
+ ProfitResult result = new ProfitResult();
|
|
|
+ if (machine.PosSnType == 1 && machine.UserId != machine.BuyUserId) //循环机具，划拨给其他人，没有激活返现没有循环
|
|
|
+ {
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
|
|
|
+ if (obj.Status == 1) //判断分润是否开启
|
|
|
+ {
|
|
|
+ ProfitObjectActivations objact = RedisDbconn.Instance.Get<ProfitObjectActivations>("pobjacti" + BrandId);
|
|
|
+ if (objact.StartDate <= DateTime.Now && objact.EndDate >= DateTime.Now)
|
|
|
+ {
|
|
|
+ int LimitDateKind = objact.LimitDateKind; //时间限制类型 日月年/自定义
|
|
|
+ int LimitDateVal = objact.LimitDateVal; //时间限制值 日月年
|
|
|
+ decimal ProfitMoney = objact.ProfitNumber;
|
|
|
+ int MachineCount = objact.MachineCount;
|
|
|
+ DateTime checkDate = Start;
|
|
|
+ if (LimitDateKind == 1)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddDays(LimitDateVal);
|
|
|
+ }
|
|
|
+ else if (LimitDateKind == 2)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddMonths(LimitDateVal);
|
|
|
+ }
|
|
|
+ else if (LimitDateKind == 3)
|
|
|
+ {
|
|
|
+ checkDate = checkDate.AddYears(LimitDateVal);
|
|
|
+ }
|
|
|
+ else if (LimitDateKind == 4)
|
|
|
+ {
|
|
|
+ checkDate = objact.LimitCustomerDate.Value;
|
|
|
+ }
|
|
|
+ // if (DateTime.Now > checkDate && ProfitMoney > objact.ExpiredNumber)
|
|
|
+ // {
|
|
|
+ // ProfitMoney = objact.ExpiredNumber;
|
|
|
+ // }
|
|
|
+ if (ProfitMoney >= obj.MinProfitVal)
|
|
|
+ {
|
|
|
+ result = new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = User.UserId,
|
|
|
+ UserNav = User.UserNav,
|
|
|
+ Money = ProfitMoney,
|
|
|
+ MachineCount = MachineCount,
|
|
|
+ };
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 获取分润规则Id
|
|
|
+
|
|
|
+ private int GetLevelKindId(int BrandId, int Help, int BankCardType)
|
|
|
+ {
|
|
|
+ return RedisDbconn.Instance.Get<int>("pobjlv:kid:" + BrandId + ":" + Help + ":" + BankCardType);
|
|
|
+ }
|
|
|
+
|
|
|
+ #endregion
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ #region POS统计交易额
|
|
|
+ public void StartListenTradeDo(int tradeId, bool profit = true)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ WebCMSEntities dbnew = new WebCMSEntities();
|
|
|
+ TradeRecord trade_record = dbnew.TradeRecord.FirstOrDefault(m => m.Id == tradeId);
|
|
|
+ if (trade_record != null)
|
|
|
+ {
|
|
|
+ int BrandId = trade_record.BrandId;
|
|
|
+ decimal TradeAmt = trade_record.TradeAmount;
|
|
|
+ int BankCardTypeNum = trade_record.BankCardType; //1-贷记卡，0-借记卡，2-准贷记卡
|
|
|
+
|
|
|
+ DateTime TradeDateTime = trade_record.CreateDate.Value;
|
|
|
+ string monthString = TradeDateTime.ToString("yyyyMM");
|
|
|
+ string dayString = TradeDateTime.ToString("yyyyMMdd");
|
|
|
+ string NaturalMonthString = RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:NaturalMonth");
|
|
|
+ int NaturalMonth = int.Parse(NaturalMonthString); //自然月
|
|
|
+
|
|
|
+ MachineForSnNo machinefor = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == trade_record.SnNo) ?? new MachineForSnNo();
|
|
|
+ PosMachinesTwo machine = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == machinefor.SnId) ?? new PosMachinesTwo();
|
|
|
+ Users user = dbnew.Users.FirstOrDefault(m => m.Id == machine.UserId) ?? new Users();
|
|
|
+ int TopUserId = 0;
|
|
|
+ if (!string.IsNullOrEmpty(user.ParentNav))
|
|
|
+ {
|
|
|
+ string[] navList = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
|
|
|
+ if (navList.Length > 1)
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(navList[1]);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(navList[0]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ PosMerchantInfo merchant = dbnew.PosMerchantInfo.FirstOrDefault(m => m.Id == machine.BindMerchantId) ?? new PosMerchantInfo();
|
|
|
+ List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
|
|
|
+
|
|
|
+ using (var tran = dbnew.Database.BeginTransaction())
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ ulong DirectFlag = merchant.UserId == machine.UserId ? 1u : 0u; //是否直营
|
|
|
+ ulong MerHelpFlag = 1; //扶持期、稳定期
|
|
|
+ if (merchant.CreateDate.Value < DateTime.Now.AddMonths(-NaturalMonth))
|
|
|
+ {
|
|
|
+ MerHelpFlag = 0;
|
|
|
+ }
|
|
|
+ int HelpMonthCount = DateTime.Now.Month - merchant.CreateDate.Value.Month; //扶持期第几月
|
|
|
+ if (HelpMonthCount < 0)
|
|
|
+ {
|
|
|
+ HelpMonthCount = 12 + DateTime.Now.Month - merchant.CreateDate.Value.Month;
|
|
|
+ }
|
|
|
+ int QrPayFlag = trade_record.QrPayFlag;
|
|
|
+ decimal CreditTradeAmt = 0;
|
|
|
+ decimal DebitNotCapTradeAmt = 0;
|
|
|
+ decimal DebitCapTradeAmt = 0;
|
|
|
+ int DebitCapTradeNum = 0;
|
|
|
+ if (BankCardTypeNum == 1)
|
|
|
+ {
|
|
|
+ CreditTradeAmt = TradeAmt;
|
|
|
+ }
|
|
|
+ else if (BankCardTypeNum == 0)
|
|
|
+ {
|
|
|
+ //累计借记卡封顶或非封顶交易 // TODO:需优化，判断不太科学
|
|
|
+ // decimal profitrate = 0;
|
|
|
+ // if (user.CreateDate.Value.AddMonths(NaturalMonth) >= DateTime.Now)
|
|
|
+ // {
|
|
|
+ // UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 1) ?? new UserProfitSet(); //获取创客分润规则-扶持期
|
|
|
+ // profitrate = profitSet.ProfitRate;
|
|
|
+ // }
|
|
|
+ // else
|
|
|
+ // {
|
|
|
+ // UserProfitSet profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardTypeNum && m.HelpFlag == 0) ?? new UserProfitSet(); //获取创客分润规则-非扶持期
|
|
|
+ // profitrate = profitSet.ProfitRate;
|
|
|
+ // }
|
|
|
+ // profitrate = profitrate / 100;
|
|
|
+ // int UserLevel = user.UserLevel; //当前会员等级
|
|
|
+ // decimal utrade = RedisDbconn.Instance.Get<decimal>("TeamTradeStat:" + user.Id + ":" + BrandId + ":" + DateTime.Now.ToString("yyMM"));
|
|
|
+ // UserLevelSet checklevel = levels.Where(m => m.UpLevelIntegral < utrade).OrderBy(m => m.Id).FirstOrDefault();
|
|
|
+ // if (checklevel != null)
|
|
|
+ // {
|
|
|
+ // UserLevel = checklevel.Id + 1;
|
|
|
+ // }
|
|
|
+ // ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + GetLevelKindId(BrandId) + ":" + UserLevel); //获取当前等级参数
|
|
|
+ // decimal getLevelProfit = TradeAmt * objlevel.Percents * profitrate;
|
|
|
+ // if (getLevelProfit < 1)
|
|
|
+ // {
|
|
|
+ // DebitNotCapTradeAmt = TradeAmt;
|
|
|
+ // }
|
|
|
+ // else
|
|
|
+ // {
|
|
|
+ // DebitCapTradeAmt = TradeAmt;
|
|
|
+ // DebitCapTradeNum = 1;
|
|
|
+ // trade_record.CapFlag = 1;
|
|
|
+ // dbnew.SaveChanges();
|
|
|
+ // }
|
|
|
+ DebitNotCapTradeAmt = TradeAmt;
|
|
|
+ }
|
|
|
+ UserTradeMonthSummary editsummary = dbnew.UserTradeMonthSummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeMonth == monthString && m.BrandId == BrandId && m.StatType == 0);
|
|
|
+ if (editsummary == null)
|
|
|
+ {
|
|
|
+ dbnew.UserTradeMonthSummary.Add(new UserTradeMonthSummary()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UserId = user.Id, //创客
|
|
|
+ TradeMonth = monthString, //交易月
|
|
|
+ BrandId = BrandId, //品牌
|
|
|
+ StatType = 0, //交易统计类型
|
|
|
+ TradeAmt = TradeAmt, //商户交易总额
|
|
|
+ CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
|
|
|
+ DebitNotCapTradeAmt = DebitNotCapTradeAmt, //商户非封顶借记卡交易总金额
|
|
|
+ DebitCapTradeAmt = DebitCapTradeAmt, //商户借记卡封顶交易总额
|
|
|
+ DebitCapTradeNum = DebitCapTradeNum, //商户借记卡封顶交易总笔数
|
|
|
+ MallPosOrderStatus = machine.PosSnType == 1 ? 0 : 1, //商城兑换机具状态
|
|
|
+ ActiveBuddyMerStatus = user.RealName == merchant.MerchantName ? 0 : 1, //激活创客同名商户
|
|
|
+ });
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editsummary.TradeAmt += TradeAmt;
|
|
|
+ editsummary.CreditTradeAmt += CreditTradeAmt;
|
|
|
+ editsummary.DebitNotCapTradeAmt += DebitNotCapTradeAmt;
|
|
|
+ editsummary.DebitCapTradeAmt += DebitCapTradeAmt;
|
|
|
+ editsummary.DebitCapTradeNum += DebitCapTradeNum;
|
|
|
+ }
|
|
|
+ TradeDaySummary editdaysum = dbnew.TradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
|
|
|
+ if (editdaysum == null)
|
|
|
+ {
|
|
|
+ editdaysum = dbnew.TradeDaySummary.Add(new TradeDaySummary()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UserId = user.Id, //创客
|
|
|
+ TradeDate = dayString, //交易日
|
|
|
+ TradeMonth = monthString, //交易月
|
|
|
+ BrandId = BrandId, //品牌
|
|
|
+ TopUserId = TopUserId, //顶级创客
|
|
|
+ }).Entity;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ //分类统计交易额
|
|
|
+ if (MerHelpFlag == 0)
|
|
|
+ {
|
|
|
+ if (DirectFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectTradeAmt = TradeAmt; //直营商户交易总额(非扶持期)
|
|
|
+ if (BankCardTypeNum == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(非扶持期)
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(非扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(非扶持期)
|
|
|
+ if (DebitCapTradeNum > 0)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(非扶持期)
|
|
|
+ editdaysum.NotHelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(非扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(非扶持期)
|
|
|
+ if (BankCardTypeNum == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(非扶持期)
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(非扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(非扶持期)
|
|
|
+ if (DebitCapTradeNum > 0)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(非扶持期)
|
|
|
+ editdaysum.NotHelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(非扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.NotHelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(非扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (DirectFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectTradeAmt += TradeAmt; //直营商户交易总额(扶持期)
|
|
|
+ if (BankCardTypeNum == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectCreditTradeAmt += TradeAmt; //直营贷记卡交易总额(扶持期)
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectQrCreditTradeAmt += TradeAmt; //直营云闪付贷记卡交易额(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectNonQrCreditTradeAmt += TradeAmt; //直营非云闪付贷记卡交易额(扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额(扶持期)
|
|
|
+ if (DebitCapTradeNum > 0)
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectDebitCapTradeAmt += TradeAmt; //直营商户借记卡封顶交易总金额(扶持期)
|
|
|
+ editdaysum.HelpDirectDebitCapNum += 1; //直营商户借记卡封顶交易总数(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectQrDebitTradeAmt += TradeAmt; //直营云闪付非封顶借记卡(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpDirectNonQrDebitTradeAmt += TradeAmt; //直营非云闪付非封顶借记卡(扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectTradeAmt += TradeAmt; //非直营商户交易总额(扶持期)
|
|
|
+ if (BankCardTypeNum == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectCreditTradeAmt += TradeAmt; //非直营贷记卡交易总额(扶持期)
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectQrCreditTradeAmt += TradeAmt; //非直营云闪付贷记卡交易额(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectNonQrCreditTradeAmt += TradeAmt; //非直营非云闪付贷记卡交易额(扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额(扶持期)
|
|
|
+ if (DebitCapTradeNum > 0)
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectDebitCapTradeAmt += TradeAmt; //非直营商户借记卡封顶交易总金额(扶持期)
|
|
|
+ editdaysum.HelpNonDirectDebitCapNum += 1; //非直营商户借记卡封顶交易总数(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectQrDebitTradeAmt += TradeAmt; //非直营云闪付非封顶借记卡(扶持期)
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ editdaysum.HelpNonDirectNonQrDebitTradeAmt += TradeAmt; //非直营非云闪付非封顶借记卡(扶持期)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ UserTradeDaySummary userdaysum = dbnew.UserTradeDaySummary.FirstOrDefault(m => m.UserId == user.Id && m.TradeDate == dayString && m.BrandId == BrandId);
|
|
|
+ if (userdaysum == null)
|
|
|
+ {
|
|
|
+ userdaysum = dbnew.UserTradeDaySummary.Add(new UserTradeDaySummary()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UserId = user.Id, //创客
|
|
|
+ TradeDate = dayString, //交易日
|
|
|
+ TradeMonth = monthString, //交易月
|
|
|
+ BrandId = BrandId, //品牌
|
|
|
+ }).Entity;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ if (DirectFlag == 1)
|
|
|
+ {
|
|
|
+ userdaysum.DirectTradeAmt += TradeAmt; //直营商户交易总额
|
|
|
+ if (BankCardTypeNum == 0)
|
|
|
+ {
|
|
|
+ userdaysum.DirectDebitTradeAmt += TradeAmt; //直营商户借记卡交易总额
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ userdaysum.NonDirectTradeAmt += TradeAmt; //非直营商户交易总额
|
|
|
+ if (BankCardTypeNum == 0)
|
|
|
+ {
|
|
|
+ userdaysum.NonDirectDebitTradeAmt += TradeAmt; //非直营商户借记卡交易总额
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ if (profit)
|
|
|
+ {
|
|
|
+ DoProfitForPos(dbnew, trade_record);
|
|
|
+ }
|
|
|
+ tran.Commit();
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
|
|
|
+ tran.Rollback();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dbnew.Dispose();
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + ":" + ex.ToString(), "自定义分润程序监听队列异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public void DoProfitForPos(WebCMSEntities dbnew, TradeRecord trade_record)
|
|
|
+ {
|
|
|
+ List<ProfitUsers> users = new List<ProfitUsers>();
|
|
|
+ int TopUserId = 0; //顶级创客Id
|
|
|
+ Users us = dbnew.Users.FirstOrDefault(a => a.Id == trade_record.UserId);
|
|
|
+ if (us != null)
|
|
|
+ {
|
|
|
+ string uidstring = us.Id.ToString();
|
|
|
+ string[] uidlist = { };
|
|
|
+ if (!string.IsNullOrEmpty(us.ParentNav))
|
|
|
+ {
|
|
|
+ uidstring = us.ParentNav.Trim(',').Replace(",,", ",") + "," + uidstring;
|
|
|
+ uidlist = uidstring.Split(',');
|
|
|
+ if (uidlist.Length > 1)
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(function.CheckInt(uidlist[1]));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(function.CheckInt(uidlist[0]));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Array.Reverse(uidlist);
|
|
|
+ foreach (string uidstr in uidlist)
|
|
|
+ {
|
|
|
+ int puid = int.Parse(function.CheckInt(uidstr));
|
|
|
+ Users pus = dbnew.Users.FirstOrDefault(a => a.Id == puid);
|
|
|
+ if (pus != null)
|
|
|
+ {
|
|
|
+ users.Add(new ProfitUsers()
|
|
|
+ {
|
|
|
+ UserId = pus.Id,
|
|
|
+ UserNav = pus.ParentNav,
|
|
|
+ UserLevel = pus.UserLevel,
|
|
|
+ CreateDate = pus.CreateDate.Value,
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ string TradeMonth = trade_record.TradeDate.Value.ToString("yyyyMM");
|
|
|
+ List<ProfitResult> list = new List<ProfitResult>();
|
|
|
+ list = StartProftForPos(dbnew, trade_record, users);
|
|
|
+ using (var tran = dbnew.Database.BeginTransaction())
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ foreach (ProfitResult sub in list)
|
|
|
+ {
|
|
|
+ if (sub.Message == "分红奖励")
|
|
|
+ {
|
|
|
+ UserAccountRecord accountRecord = dbnew.UserAccountRecord.Add(new UserAccountRecord()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UpdateDate = DateTime.Now,
|
|
|
+ UserId = sub.UserId, //创客
|
|
|
+ ChangeType = 11, //变动类型
|
|
|
+ ProductType = trade_record.BrandId, //产品类型
|
|
|
+ ChangeAmount = sub.Money, //变更金额
|
|
|
+ Status = -1,
|
|
|
+ }).Entity;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ int ProfitType = sub.UserId == trade_record.UserId ? 0 : 1;
|
|
|
+ ProfitRewardRecord editprofitrecord = dbnew.ProfitRewardRecord.FirstOrDefault(m => m.UserId == sub.UserId && m.MerchantId == trade_record.MerchantId && m.BrandId == trade_record.BrandId && m.ProfitType == ProfitType && m.TradeMonth == TradeMonth);
|
|
|
+ if (editprofitrecord == null)
|
|
|
+ {
|
|
|
+ editprofitrecord = dbnew.ProfitRewardRecord.Add(new ProfitRewardRecord()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UserId = sub.UserId, //创客
|
|
|
+ MerchantId = trade_record.MerchantId, //商户
|
|
|
+ BrandId = trade_record.BrandId, //品牌
|
|
|
+ ProfitType = ProfitType, //创客分润类型
|
|
|
+ TradeMonth = TradeMonth, //交易月
|
|
|
+ TopUserId = TopUserId, //顶级创客
|
|
|
+ }).Entity;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ string RecordNo = "KPM";
|
|
|
+ int RecordId = editprofitrecord.Id;
|
|
|
+ string RecordIdString = RecordId.ToString();
|
|
|
+ for (int i = 0; i < 14 - RecordId.ToString().Length; i++)
|
|
|
+ {
|
|
|
+ RecordIdString = "0" + RecordIdString;
|
|
|
+ }
|
|
|
+ RecordNo += RecordIdString;
|
|
|
+ editprofitrecord.RecordNo = RecordNo;
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ }
|
|
|
+ // editprofitrecord.OtherTradeAmt = 0; //其他产品交易总金额
|
|
|
+ // editprofitrecord.OtherCreditTradeAmt = 0; //其他产品贷记卡交易总金额
|
|
|
+ // editprofitrecord.OtherDebitNotCapTradeAmt = 0; //其他产品借记卡非封顶交易总金额
|
|
|
+ decimal TradeAmount = trade_record.TradeAmount;
|
|
|
+ editprofitrecord.TradeAmt += TradeAmount; //商户交易总额
|
|
|
+ if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeAmt += TradeAmount; //贷记卡交易总金额
|
|
|
+ if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeAmt += TradeAmount; //(云闪付)贷记卡交易总金额
|
|
|
+ if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeAmt += TradeAmount; //(非云闪付)贷记卡交易总金额
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeAmt += TradeAmount; //(非扶持期)(非云闪付)贷记卡交易总金额
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeAmt += TradeAmount; //(扶持期)(非云闪付)贷记卡交易总金额
|
|
|
+ if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonCapTradeAmt += TradeAmount; //商户非封顶借记卡交易总额
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNotCapTradeAmt += TradeAmount; //(云闪付)商户非封顶借记卡交易总额
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNotCapTradeAmt += TradeAmount; //(非云闪付)商户非封顶借记卡交易总额
|
|
|
+ if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonCapTradeAmt += TradeAmount; //(非扶持期)(非云闪付)借记卡非封顶交易总金额
|
|
|
+ if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonCapTradeAmt += TradeAmount; //(扶持期)(非云闪付)借记卡非封顶交易总金额
|
|
|
+ if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapTradeAmt = TradeAmount; //商户借记卡封顶交易总额
|
|
|
+ editprofitrecord.DebitCapTradeNum += 1; //商户借记卡封顶交易总笔数
|
|
|
+
|
|
|
+ decimal ProfitMoney = sub.Money;
|
|
|
+ ulong DirectFlag = trade_record.DirectFlag;
|
|
|
+ editprofitrecord.TradeProfit += ProfitMoney; //交易分润
|
|
|
+ if (trade_record.BankCardType == 0) editprofitrecord.CreditTradeProfit += ProfitMoney; //贷记卡分润总金额
|
|
|
+ if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditTradeProfit += ProfitMoney; //(云闪付)贷记卡交易分润
|
|
|
+ if (trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NonQrCreditTradeProfit += ProfitMoney; //(非云闪付)贷记卡交易分润
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditTradeProfit += ProfitMoney; //(非扶持期)(非云闪付)贷记卡分润总金额
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditTradeProfit += ProfitMoney; //(扶持期)(非云闪付)贷记卡分润总金额
|
|
|
+ if (sub.Money < 1 && trade_record.BankCardType == 1) editprofitrecord.DebitNonTradeCapProfit += ProfitMoney; //借记卡非封顶交易分润总金额
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitNonTradeCapProfit += ProfitMoney; //(云闪付)借记卡非封顶交易分润总金额
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NonQrDebitNonTradeCapProfit += ProfitMoney; //(非云闪付)借记卡非封顶交易分润总金额
|
|
|
+ if (sub.Money < 1 && trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitNonTradeCapProfit += ProfitMoney; //(非扶持期)(非云闪付)借记卡非封顶交易分润总金额
|
|
|
+ if (sub.Money < 1 && trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitNonTradeCapProfit += ProfitMoney; //(扶持期)(非云闪付)借记卡非封顶交易分润总金额
|
|
|
+ if (sub.Money == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitTradeCapProfit += ProfitMoney; //借记卡封顶交易分润总金额
|
|
|
+ if (sub.Money < 1 && DirectFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.DebitCapSingleReward += ProfitMoney; //借记卡合伙人直营封顶交易奖励金额
|
|
|
+
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)贷记卡商户交易对应分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)贷记卡标准分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.NotHelpCreditAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)贷记卡成本或增或减比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)贷记卡商户交易对应分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)贷记卡-标准分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 0) editprofitrecord.HelpCreditAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)贷记卡成本或增或减比例
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitRate = sub.ProfitRate; //(非扶持期)(非云闪付)借记卡商户交易对应分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitProfitStandardRate = sub.ProfitPercent; //(非扶持期)(非云闪付)借记卡标准分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 0 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.NotHelpDebitAddOrSubRate = sub.AddOrSubRate; //(非扶持期)(非云闪付)借记卡成本或增或减比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitRate = sub.ProfitRate; //(扶持期)(非云闪付)借记卡商户交易对应分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitProfitStandardRate = sub.ProfitPercent; //(扶持期)(非云闪付)借记卡-标准分润比例
|
|
|
+ if (trade_record.MerHelpFlag == 1 && trade_record.QrPayFlag == 0 && trade_record.BankCardType == 1) editprofitrecord.HelpDebitAddOrSubRate = sub.AddOrSubRate; //(扶持期)(非云闪付)借记卡成本或增或减比例
|
|
|
+ if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitRate = sub.ProfitRate; //(云闪付)贷记卡交易分润比例
|
|
|
+ if (trade_record.QrPayFlag == 1 && trade_record.BankCardType == 0) editprofitrecord.QrCreditProfitStandardRate = sub.ProfitRateBase; //(云闪付)贷记卡分润基准
|
|
|
+ editprofitrecord.QrCreditAddOrSubRate = sub.AddOrSubRate; //(云闪付)贷记卡分润比例或增或减
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitRate = sub.ProfitRate; //(云闪付)借记卡非封顶交易分润比例
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitProfitStandardRate = sub.ProfitRateBase; //(云闪付)借记卡非封顶交易分润基准
|
|
|
+ if (sub.Money < 1 && trade_record.QrPayFlag == 1 && trade_record.BankCardType == 1) editprofitrecord.QrDebitAddOrSubRate = sub.AddOrSubRate; //(云闪付)借记卡非封顶交易分润比例或增或减
|
|
|
+ dbnew.SaveChanges();
|
|
|
+
|
|
|
+ dbnew.ProfitRecord.Add(new ProfitRecord()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UpdateDate = DateTime.Now,
|
|
|
+ UserId = sub.UserId, //创客
|
|
|
+ MerchantId = trade_record.MerchantId, //商户
|
|
|
+ MerNo = trade_record.MerNo, //渠道商户编号
|
|
|
+ MerHelpFlag = trade_record.MerHelpFlag, //是否属于扶持周期内商户
|
|
|
+ HelpMonthCount = trade_record.HelpMonthCount, //扶持第几个月
|
|
|
+ MerBuddyType = trade_record.MerBuddyType, //商户创客类型
|
|
|
+ SnNo = trade_record.SnNo, //SN号
|
|
|
+ TradeDate = trade_record.TradeDate, //交易日期
|
|
|
+ ProfitAmount = sub.Money, //分润金额
|
|
|
+ QrPayFlag = trade_record.QrPayFlag, //云闪付标识
|
|
|
+ CapFlag = trade_record.CapFlag, //借记卡封顶交易标志
|
|
|
+ DirectFlag = trade_record.DirectFlag, //是否直营
|
|
|
+ BrandId = trade_record.BrandId, //品牌
|
|
|
+ ParentNav = us.ParentNav, //上级创客集
|
|
|
+ TradeId = trade_record.Id, //交易记录Id
|
|
|
+ });
|
|
|
+ dbnew.SaveChanges();
|
|
|
+
|
|
|
+ // Users user = dbnew.Users.FirstOrDefault(m => m.Id == sub.UserId);
|
|
|
+ // if (user != null)
|
|
|
+ // {
|
|
|
+ // if (!string.IsNullOrEmpty(user.CloudPushDeviceId))
|
|
|
+ // {
|
|
|
+ // new AliyunPushOld().Push("鑫创客通知", "您有一笔分润收益：" + sub.Money.ToString("f2"), "30", "NOTICE", user.DeviceType, user.CloudPushDeviceId, "1");
|
|
|
+ // }
|
|
|
+ // TODO:发送阿里云推送消息
|
|
|
+ // }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ dbnew.SaveChanges();
|
|
|
+ tran.Commit();
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ tran.Rollback();
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "POS分润异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region POS分润算法
|
|
|
+ public List<ProfitResult> StartProftForPos(WebCMSEntities dbnew, TradeRecord trade, List<ProfitUsers> users)
|
|
|
+ {
|
|
|
+ // 级差
|
|
|
+ /*
|
|
|
+
|
|
|
+ K1 - K5：无大小市场要求，无押机分润比例为有押金机的70%，如K1的有押金机分润比例为万6，则无押机的分润比例为万4.2
|
|
|
+ 机具激活大于90天，分润比例为原比例的70%
|
|
|
+
|
|
|
+ if(is0y){
|
|
|
+ 分润比例为原比例的70%
|
|
|
+ }
|
|
|
+ if(ActivityDate > now - 90){
|
|
|
+ 分润比例为原比例的70%
|
|
|
+ }
|
|
|
+ K6 - K9：
|
|
|
+ K6：至少有1个直推大于3000万，且总交易额减去3000万大于1200万，则获得分红奖（月月红）直接级差
|
|
|
+ K7：总交易额减去最大交易额的直推，大于4000万，则获得分红奖（月月红）直接级差
|
|
|
+ K8：总交易额减去最大交易额的直推，大于12000万，则获得分红奖（月月红）直接级差
|
|
|
+ K9：总交易额减去最大交易额的直推，大于32000万，则获得分红奖（月月红）直接级差
|
|
|
+
|
|
|
+ 补贴：
|
|
|
+ 0押金无补贴
|
|
|
+ 机具激活90天内，机具所属创客获得万10置顶
|
|
|
+ 若创客为商户型创客，则机具UserId的创客获得万4分润
|
|
|
+
|
|
|
+ */
|
|
|
+
|
|
|
+
|
|
|
+ List<ProfitResult> result = new List<ProfitResult>();
|
|
|
+ int BrandId = trade.BrandId;
|
|
|
+ ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
|
|
|
+ if (obj.Status == 1) //判断分润是否开启
|
|
|
+ {
|
|
|
+ decimal TradeMoney = trade.TradeAmount;
|
|
|
+ int BankCardType = trade.BankCardType; //银行卡类型：贷记卡-1，借记卡-0
|
|
|
+ int MerHelpFlag = (int)trade.MerHelpFlag; //扶持期-1，稳定期=0
|
|
|
+ List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
|
|
|
+ int IncludeCurrentMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:IncludeCurrentMonth")); //是否包含当前月
|
|
|
+ int NaturalMonth = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":HelpPolicy:NaturalMonth")); //自然月
|
|
|
+ if(IncludeCurrentMonth == 1) NaturalMonth -= 1;
|
|
|
+ if (BankCardType == 0)
|
|
|
+ {
|
|
|
+ Users user = dbnew.Users.FirstOrDefault(m => m.Id == trade.UserId) ?? new Users();
|
|
|
+ // UserProfitSet profitSet = profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.Id && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
|
|
|
+ // profitrate = profitSet.ProfitRate;
|
|
|
+ // profitrate = profitrate / 100;
|
|
|
+ int UserLevel = user.UserLevel; //当前会员等级
|
|
|
+ int HelpTime = 0;
|
|
|
+ if (user.CreateDate.Value.AddMonths(NaturalMonth) > DateTime.Now)
|
|
|
+ {
|
|
|
+ HelpTime = 1;
|
|
|
+ }
|
|
|
+ int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
|
|
|
+ ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
|
|
|
+ decimal getLevelProfit = TradeMoney * objlevel.Percents;
|
|
|
+ if(getLevelProfit > 1) getLevelProfit = 1;
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = user.Id,
|
|
|
+ UserNav = user.ParentNav,
|
|
|
+ Money = getLevelProfit,
|
|
|
+ ProfitRate = objlevel.Percents,
|
|
|
+ // ProfitPercent = profitSet.ProfitPercent,
|
|
|
+ // AddOrSubRate = profitSet.AddOrSubRate,
|
|
|
+ // ProfitRateBase = profitSet.ProfitRateBase,
|
|
|
+ });
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ int maxLevel = obj.MaxLevel; //最大等级
|
|
|
+ int maxFloor = obj.MaxFloor; //最大层级
|
|
|
+ int maxContinueFloor = RedisDbconn.Instance.Get<int>("pobjconc" + BrandId); //最大继续分润层级
|
|
|
+ decimal diffLevelProfit = 0; //等级级差
|
|
|
+ decimal diffDiviProfit = 0; //分红级差
|
|
|
+ // decimal diffFloorProfit = 0; //层级级差
|
|
|
+ // int continueFloor = 0; //继续分润层级
|
|
|
+ int curLevel = 0; //当前层级的会员等级
|
|
|
+ for (int curFloor = 1; curFloor <= users.Count; curFloor++)
|
|
|
+ {
|
|
|
+ ProfitUsers user = new ProfitUsers();
|
|
|
+ if (curFloor <= users.Count)
|
|
|
+ {
|
|
|
+ user = users[curFloor - 1];
|
|
|
+ }
|
|
|
+ int UserLevel = user.UserLevel; //当前会员等级
|
|
|
+ //判断当前创客是否有直推的激活机具，并且在活动时间内
|
|
|
+ if (UserLevel == maxLevel && UserLevel == curLevel)
|
|
|
+ {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if (UserLevel <= maxLevel && UserLevel > curLevel)
|
|
|
+ {
|
|
|
+ int HelpTime = 0;
|
|
|
+ if (user.CreateDate.AddMonths(NaturalMonth) > DateTime.Now)
|
|
|
+ {
|
|
|
+ HelpTime = 1;
|
|
|
+ }
|
|
|
+ int LevelKindId = GetLevelKindId(trade.BrandId, HelpTime, BankCardType);
|
|
|
+ ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
|
|
|
+ if (objlevel != null)
|
|
|
+ {
|
|
|
+ decimal getLevelProfit = 0; //等级分润
|
|
|
+ // UserProfitSet profitSet = new UserProfitSet();
|
|
|
+ if (objlevel.Percents > 0)
|
|
|
+ {
|
|
|
+ //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
|
|
|
+ decimal profitrate = objlevel.Percents;
|
|
|
+ // profitSet = dbnew.UserProfitSet.FirstOrDefault(m => m.UserId == user.UserId && m.BrandId == BrandId && m.CardType == BankCardType && m.HelpFlag == MerHelpFlag) ?? new UserProfitSet(); //获取创客分润规则-扶持期
|
|
|
+ // profitrate = profitSet.ProfitRate;
|
|
|
+ // profitrate = profitrate / 100;
|
|
|
+ getLevelProfit += TradeMoney * objlevel.Percents * profitrate;
|
|
|
+ }
|
|
|
+ if (objlevel.AddProfitVal > 0)
|
|
|
+ {
|
|
|
+ //分红奖励:一个3000万，3000万以下市场总和大于1200万
|
|
|
+ bool bigMarket = false;
|
|
|
+ decimal smallMarket = 0;
|
|
|
+ List<Users> directs = dbnew.Users.Where(m => m.ParentUserId == user.UserId).ToList();
|
|
|
+ decimal BigMarketTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:BigMarketTradeAmt")); //大市场交易额
|
|
|
+ decimal PassTradeAmt = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:PassTradeAmt")); //小市场交易超越额
|
|
|
+ decimal UnitPrize = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + trade.BrandId + ":Dividends:UnitPrize")); //单位奖励基数
|
|
|
+ foreach (Users direct in directs)
|
|
|
+ {
|
|
|
+ UserData userData = dbnew.UserData.FirstOrDefault(m => m.UserId == direct.Id) ?? new UserData();
|
|
|
+ if (userData.TotalOrderMoney >= BigMarketTradeAmt)
|
|
|
+ {
|
|
|
+ bigMarket = true;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ smallMarket += userData.TotalOrderMoney;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (bigMarket && smallMarket >= PassTradeAmt)
|
|
|
+ {
|
|
|
+ decimal DiviPrize = objlevel.AddProfitVal * TradeMoney / UnitPrize;
|
|
|
+ decimal checkmoney = DiviPrize;
|
|
|
+ DiviPrize -= diffDiviProfit;
|
|
|
+ if (objlevel.LevelDiff == 1) //判断是否有级差
|
|
|
+ {
|
|
|
+ diffDiviProfit = checkmoney;
|
|
|
+ }
|
|
|
+ if (DiviPrize >= obj.MinProfitVal)
|
|
|
+ {
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = user.UserId,
|
|
|
+ UserNav = user.UserNav,
|
|
|
+ Money = DiviPrize,
|
|
|
+ Message = "分红奖励",
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ decimal money = getLevelProfit;
|
|
|
+ getLevelProfit -= diffLevelProfit;
|
|
|
+ if (objlevel.LevelDiff == 1) //判断是否有级差
|
|
|
+ {
|
|
|
+ diffLevelProfit = money;
|
|
|
+ }
|
|
|
+ if (getLevelProfit >= obj.MinProfitVal)
|
|
|
+ {
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = user.UserId,
|
|
|
+ UserNav = user.UserNav,
|
|
|
+ Money = getLevelProfit,
|
|
|
+ ProfitRate = objlevel.Percents,
|
|
|
+ // ProfitPercent = profitSet.ProfitPercent,
|
|
|
+ // AddOrSubRate = profitSet.AddOrSubRate,
|
|
|
+ // ProfitRateBase = profitSet.ProfitRateBase,
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ curLevel = UserLevel;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ public void StatProfit()
|
|
|
+ {
|
|
|
+ Thread th = new Thread(StatProfitDo);
|
|
|
+ th.IsBackground = true;
|
|
|
+ th.Start();
|
|
|
+ }
|
|
|
+ public void StatProfitDo()
|
|
|
+ {
|
|
|
+ string Month = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
|
|
|
+ string check = function.ReadInstance("/ProfitStat/" + Month + ".txt");
|
|
|
+ if (!string.IsNullOrEmpty(check))
|
|
|
+ {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ function.WritePage("/ProfitStat/", Month + ".txt", DateTime.Now.ToString());
|
|
|
+ WebCMSEntities db = new WebCMSEntities();
|
|
|
+ for (int i = 1; i <= 9; i++) //品牌
|
|
|
+ {
|
|
|
+ for (int j = 0; j <= 1; j++) //卡类型
|
|
|
+ {
|
|
|
+ int PageNum = 1;
|
|
|
+ bool op = true;
|
|
|
+ while(op)
|
|
|
+ {
|
|
|
+ List<ProfitResult> result = StartProftForPosByMonth(i, j, Month, PageNum);
|
|
|
+ if(result.Count > 0)
|
|
|
+ {
|
|
|
+ foreach (ProfitResult sub in result)
|
|
|
+ {
|
|
|
+ int TopUserId = 0;
|
|
|
+ if (!string.IsNullOrEmpty(sub.UserNav))
|
|
|
+ {
|
|
|
+ string[] UserNavList = sub.UserNav.Trim(',').Replace(",,", ",").Split(',');
|
|
|
+ if (UserNavList.Length > 1)
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(UserNavList[1]);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ TopUserId = int.Parse(UserNavList[0]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ string RecordNo = "P" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
|
|
|
+ decimal ProfitAmt = sub.Money;
|
|
|
+ decimal TradeAmt = sub.TradeAmount;
|
|
|
+ decimal ProfitRate = sub.ProfitRate;
|
|
|
+ if (sub.IsSubsidy == 1 && j == 1)
|
|
|
+ {
|
|
|
+ decimal CreditTradeAmt = TradeAmt; //商户贷记卡交易总金额
|
|
|
+ decimal QrCreditTradeAmt = 0; //商户(云闪付)贷记卡交易总金额
|
|
|
+ decimal NonQrCreditTradeAmt = 0; //商户(非云闪付)贷记卡交易总金额
|
|
|
+ decimal CreditProfitRate = 0; //(非云闪付)贷记卡交易分润比例
|
|
|
+ decimal SubsidyProfit = 0; //商户(非云闪付)贷记卡交易分润补贴金额
|
|
|
+ if (sub.QrPayFlag == 1)
|
|
|
+ {
|
|
|
+ QrCreditTradeAmt = TradeAmt; //商户(云闪付)贷记卡交易总金额
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ NonQrCreditTradeAmt = TradeAmt; //商户(非云闪付)贷记卡交易总金额
|
|
|
+ CreditProfitRate = ProfitRate; //(非云闪付)贷记卡交易分润比例
|
|
|
+ SubsidyProfit = ProfitAmt; //商户(非云闪付)贷记卡交易分润补贴金额
|
|
|
+ }
|
|
|
+ MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == sub.PosSn) ?? new MachineForSnNo();
|
|
|
+ PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
|
|
|
+ PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.MerchantId) ?? new PosMerchantInfo();
|
|
|
+ db.ProfitSubsidyDetail.Add(new ProfitSubsidyDetail()
|
|
|
+ {
|
|
|
+ CreateDate = DateTime.Now,
|
|
|
+ UpdateDate = DateTime.Now,
|
|
|
+ RecordNo = RecordNo, //流水号
|
|
|
+ BrandId = sub.BrandId, //品牌
|
|
|
+ ProductName = RelationClass.GetKqProductBrandInfo(sub.BrandId), //产品名称
|
|
|
+ TradeMonth = Month, //交易月份
|
|
|
+ MerchantId = sub.MerchantId, //商户
|
|
|
+ MerNo = merchant.KqMerNo, //渠道商户编号
|
|
|
+ SnNo = sub.PosSn, //渠道SN号
|
|
|
+ MerRegTime = pos.BindingTime, //渠道注册时间
|
|
|
+ MerStandardDate = merchant.MerStandardDate, //商户激活时间
|
|
|
+ BelongUserId = merchant.UserId, //商户归属人
|
|
|
+ MerHelpFlag = sub.HelpFlag == 1 ? 1u : 0u, //是否属于扶持周期内商户
|
|
|
+ SubsidyUserId = sub.UserId, //补贴人
|
|
|
+ SubsidyType = sub.DirectFlag, //分润补贴类型
|
|
|
+ SubsidyProfitRate = sub.Money, //创客活动期内直营商户分润万分之十
|
|
|
+ CreditTradeAmt = CreditTradeAmt, //商户贷记卡交易总金额
|
|
|
+ QrCreditTradeAmt = QrCreditTradeAmt, //商户(云闪付)贷记卡交易总金额
|
|
|
+ NonQrCreditTradeAmt = NonQrCreditTradeAmt, //商户(非云闪付)贷记卡交易总金额
|
|
|
+ CreditProfitRate = CreditProfitRate, //(非云闪付)贷记卡交易分润比例
|
|
|
+ SubsidyProfit = SubsidyProfit, //商户(非云闪付)贷记卡交易分润补贴金额
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ db.SaveChanges();
|
|
|
+ PageNum += 1;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ op = false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ db.Dispose();
|
|
|
+
|
|
|
+ HelpProfitHelper.Instance.StatProfitEveryDay(DateTime.Now.AddMonths(-1).ToString("yyyyMM")); //助利宝分润
|
|
|
+ ProfitCheckHelper.Instance.Start();
|
|
|
+ }
|
|
|
+ public List<ProfitResult> StartProftForPosByMonth(int BrandId, int BankCardType, string Month, int PageNum = 1)
|
|
|
+ {
|
|
|
+ // 级差
|
|
|
+ /*
|
|
|
+
|
|
|
+ K1 - K5：无大小市场要求，无押机分润比例为有押金机的70%，如K1的有押金机分润比例为万6，则无押机的分润比例为万4.2
|
|
|
+ 机具激活大于90天，分润比例为原比例的70%
|
|
|
+
|
|
|
+ if(is0y){
|
|
|
+ 分润比例为原比例的70%
|
|
|
+ }
|
|
|
+ if(ActivityDate > now - 90){
|
|
|
+ 分润比例为原比例的70%
|
|
|
+ }
|
|
|
+ K6 - K9：
|
|
|
+ K6：至少有1个直推大于3000万，且总交易额减去3000万大于1200万，则获得分红奖（月月红）直接级差
|
|
|
+ K7：总交易额减去最大交易额的直推，大于4000万，则获得分红奖（月月红）直接级差
|
|
|
+ K8：总交易额减去最大交易额的直推，大于12000万，则获得分红奖（月月红）直接级差
|
|
|
+ K9：总交易额减去最大交易额的直推，大于32000万，则获得分红奖（月月红）直接级差
|
|
|
+
|
|
|
+ 补贴：
|
|
|
+ 0押金无补贴
|
|
|
+ 机具激活90天内，机具所属创客获得万10置顶
|
|
|
+ 若创客为商户型创客，则机具UserId的创客获得万4分润
|
|
|
+
|
|
|
+ //查分润
|
|
|
+ select u.MakerCode,u.RealName,u.UserLevel,r.Rank,pos.SeoKeyword,p.KqSnNo,(case when ProfitType=1 then '直营' else '团队' end) as DirectFlag,
|
|
|
+ k.Name,CreditTradeAmt,CreditTradeProfit,DebitTradeAmt,DebitTradeProfit,QrCreditTradeAmt,QrCreditTradeProfit from (
|
|
|
+ select UserId,ProfitType,BrandId,MerchantId,
|
|
|
+ sum(CreditTradeAmt) as CreditTradeAmt,
|
|
|
+ sum(CreditTradeProfit) as CreditTradeProfit,
|
|
|
+ sum(DebitNonCapTradeAmt+DebitCapTradeAmt) as DebitTradeAmt,
|
|
|
+ sum(DebitNonTradeCapProfit+DebitTradeCapProfit) as DebitTradeProfit,
|
|
|
+ sum(QrCreditTradeAmt) as QrCreditTradeAmt,
|
|
|
+ sum(QrCreditTradeProfit) as QrCreditTradeProfit
|
|
|
+ from ProfitRewardRecord where MerchantId>0
|
|
|
+ GROUP BY UserId,ProfitType,BrandId,MerchantId
|
|
|
+ ) tb
|
|
|
+ left join Users u on tb.UserId=u.Id
|
|
|
+ LEFT JOIN KqProducts k ON k.Id=tb.BrandId
|
|
|
+ left join PosMerchantInfo p on tb.MerchantId=p.Id
|
|
|
+ left join MachineForSnNo fp on fp.SnNo=p.KqSnNo
|
|
|
+ left join PosMachinesTwo pos on pos.Id=fp.SnId
|
|
|
+ left join UserRankWhite r on u.Id=r.Id
|
|
|
+ ORDER BY p.KqSnNo,u.MakerCode
|
|
|
+
|
|
|
+ //查补贴
|
|
|
+ select u.MakerCode,u.RealName,u.UserLevel,r.Rank,m.KqSnNo,m.MerchantName,(case when SubsidyType=1 then '直营' else '团队' end) as DirectFlag,
|
|
|
+ k.Name,CreditTradeAmt,SubsidyProfit from (
|
|
|
+ select SubsidyUserId,MerchantId,BrandId,SubsidyType,
|
|
|
+ sum(CreditTradeAmt) as CreditTradeAmt,
|
|
|
+ sum(SubsidyProfitRate) as SubsidyProfit
|
|
|
+ from ProfitSubsidyDetail where TradeMonth='202208'
|
|
|
+ GROUP BY SubsidyUserId,MerchantId,BrandId,SubsidyType
|
|
|
+ ) tb
|
|
|
+ left join Users u on tb.SubsidyUserId=u.Id
|
|
|
+ LEFT JOIN KqProducts k ON k.Id=tb.BrandId
|
|
|
+ left join PosMerchantInfo m on tb.MerchantId=m.Id
|
|
|
+ left join UserRankWhite r on u.Id=r.Id and r.CreateDate<'2022-09-01 00:00:00' and r.UpdateDate>'2022-09-01 00:00:00'
|
|
|
+
|
|
|
+ // TODO:做到后台查询，换绑机器遗漏交易额补差
|
|
|
+ select UserId,sum(TradeAmount) from TradeRecord where SnNo in (
|
|
|
+ select PosSn from PosMachinesTwo where UserId=0 and BuyUserId=0 and CreditTrade>0
|
|
|
+ ) and CreateDate>='2022-04-01 00:00:00' and CreateDate<'2022-05-01 00:00:00' and UserId>0 group by UserId
|
|
|
+
|
|
|
+ */
|
|
|
+
|
|
|
+ int PageSize = 200;
|
|
|
+ int SkipNum = (PageNum - 1) * PageSize;
|
|
|
+ string LimitString = " limit " + PageSize;
|
|
|
+ if(PageNum > 1)
|
|
|
+ {
|
|
|
+ LimitString = " limit " + SkipNum + "," + PageSize;
|
|
|
+ }
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog(BankCardType.ToString(), "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog(BrandId.ToString(), "老规则分润日志");
|
|
|
+ List<ProfitResult> result = new List<ProfitResult>();
|
|
|
+ ProfitObjects obj = RedisDbconn.Instance.Get<ProfitObjects>("pobj" + BrandId);
|
|
|
+ if (obj.Status == 1) //判断分润是否开启
|
|
|
+ {
|
|
|
+ string start = Month.Substring(0, 4) + "-" + Month.Substring(4, 2) + "-01 00:00:00";
|
|
|
+ string end = DateTime.Parse(start).AddMonths(1).ToString("yyyy-MM-dd HH:mm:ss");
|
|
|
+ DataTable dt = new DataTable();
|
|
|
+ if (BankCardType == 1)
|
|
|
+ {
|
|
|
+ dt = ProfitHelperV2.Instance.GetDataTable("select SnNo,UserId,QrPayFlag,MerHelpFlag,TradeAmount,Version from TradeRecord" + Month + " where MerHelpFlag=1 and Version=0 and BrandId=" + BrandId + LimitString);
|
|
|
+ }
|
|
|
+ LogHelper.Instance.WriteLog("记录页数：" + PageNum.ToString(), "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("记录条数：" + dt.Rows.Count.ToString(), "老规则分润日志");
|
|
|
+ foreach (DataRow dr in dt.Rows)
|
|
|
+ {
|
|
|
+ WebCMSEntities dbnew = new WebCMSEntities();
|
|
|
+ try
|
|
|
+ {
|
|
|
+ string SnNo = dr["SnNo"].ToString();
|
|
|
+ int UserId = int.Parse(dr["UserId"].ToString());
|
|
|
+ int HelpTime = int.Parse(dr["Version"].ToString()) == 1 ? 2 : int.Parse(dr["MerHelpFlag"].ToString());
|
|
|
+ LogHelper.Instance.WriteLog("SnNo:" + SnNo, "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("UserId:" + UserId, "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("HelpTime:" + HelpTime, "老规则分润日志");
|
|
|
+ MachineForSnNo forSnNo = dbnew.MachineForSnNo.FirstOrDefault(m => m.SnNo == SnNo) ?? new MachineForSnNo();
|
|
|
+ PosMachinesTwo pos = dbnew.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
|
|
|
+ decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
|
|
|
+ if (pos.BindingState == 1)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("BindingState:" + pos.BindingState, "老规则分润日志");
|
|
|
+ int QrPayFlag = int.Parse(dr["QrPayFlag"].ToString());
|
|
|
+ decimal TradeAmt = decimal.Parse(dr[4].ToString());
|
|
|
+ List<UserLevelSet> levels = dbnew.UserLevelSet.ToList();
|
|
|
+ SubUser selfUser = ProfitHelperV2.Instance.GetUser(UserId, Month) ?? new SubUser();
|
|
|
+ int Days = int.Parse(RedisDbconn.Instance.Get<string>("pobjrule:" + BrandId + ":HelpPolicy:Days")); //天数
|
|
|
+ if (BankCardType == 0)
|
|
|
+ {
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ int maxLevel = obj.MaxLevel; //最大等级
|
|
|
+ decimal diffLevelProfit = 0; //等级级差
|
|
|
+ int curLevel = 0; //当前层级的会员等级
|
|
|
+ string ParentNav = selfUser.ParentNav;
|
|
|
+ if (string.IsNullOrEmpty(ParentNav) && pos.BuyUserId == 1 && pos.UserId == 1)
|
|
|
+ {
|
|
|
+ ParentNav = ",0,";
|
|
|
+ }
|
|
|
+ if (!string.IsNullOrEmpty(ParentNav))
|
|
|
+ {
|
|
|
+ ParentNav += "," + UserId + ",";
|
|
|
+ string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
|
|
|
+ Array.Reverse(ParentNavList); //反转顺序
|
|
|
+ int level = 0;
|
|
|
+ DateTime now = DateTime.Now;
|
|
|
+ DateTime ThisMonth = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
|
|
|
+ foreach (string UserIdString in ParentNavList)
|
|
|
+ {
|
|
|
+ level += 1;
|
|
|
+ int uid = int.Parse(UserIdString);
|
|
|
+ SubUser user = ProfitHelperV2.Instance.GetUser(uid, Month) ?? new SubUser();
|
|
|
+ int UserLevel = user.PreUserLevel > user.UserLevel ? user.PreUserLevel : user.UserLevel; //当前会员等级
|
|
|
+ if (curLevel == maxLevel) //判断当前创客是否有直推的激活机具，并且在活动时间内
|
|
|
+ {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if (UserLevel <= maxLevel && UserLevel > curLevel)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("UserLevel:" + UserLevel, "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("curLevel:" + curLevel, "老规则分润日志");
|
|
|
+ int LevelKindId = GetLevelKindId(BrandId, HelpTime, 1);
|
|
|
+ ProfitObjectLevels objlevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + UserLevel); //获取当前等级参数
|
|
|
+ if (objlevel != null)
|
|
|
+ {
|
|
|
+ decimal getLevelProfit = 0; //等级分润
|
|
|
+ if (objlevel.Percents > 0)
|
|
|
+ {
|
|
|
+ //获取创客分润规则，注册日开始算起，3个自然月内算扶持期
|
|
|
+ getLevelProfit += TradeAmt * objlevel.Percents;
|
|
|
+ }
|
|
|
+ if (objlevel.AddProfitVal > 0)
|
|
|
+ {
|
|
|
+ getLevelProfit += objlevel.AddProfitVal;
|
|
|
+ }
|
|
|
+ decimal money = getLevelProfit;
|
|
|
+ getLevelProfit -= diffLevelProfit;
|
|
|
+ if (objlevel.LevelDiff == 1) //判断是否有级差
|
|
|
+ {
|
|
|
+ diffLevelProfit = money;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 分润补贴
|
|
|
+ if (HelpTime == 1 && level == 1)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("ok", "老规则分润日志");
|
|
|
+ int SubsidyUserId = pos.BuyUserId;
|
|
|
+ SubUser subuser = ProfitHelperV2.Instance.GetUser(SubsidyUserId, Month) ?? new SubUser();
|
|
|
+ int subUserLevel = subuser.PreUserLevel > subuser.UserLevel ? subuser.PreUserLevel : subuser.UserLevel;
|
|
|
+ LogHelper.Instance.WriteLog("subUserLevel:" + subUserLevel, "老规则分润日志");
|
|
|
+ if(subUserLevel < 5)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("sub:ok:", "老规则分润日志");
|
|
|
+ ProfitObjectLevels sublevel = RedisDbconn.Instance.Get<ProfitObjectLevels>("pobjlv" + LevelKindId + ":" + subUserLevel); //获取当前等级参数
|
|
|
+ if (sublevel != null)
|
|
|
+ {
|
|
|
+ decimal otherPercent = 0.001M - sublevel.Percents;
|
|
|
+ decimal otherMoney = TradeAmt * otherPercent;
|
|
|
+ LogHelper.Instance.WriteLog("otherPercent:" + otherPercent, "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("otherMoney:" + otherMoney, "老规则分润日志");
|
|
|
+ if (otherMoney >= obj.MinProfitVal)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog("finish:" + SnNo, "老规则分润日志");
|
|
|
+ result.Add(new ProfitResult()
|
|
|
+ {
|
|
|
+ UserId = subuser.Id,
|
|
|
+ UserNav = subuser.ParentNav,
|
|
|
+ Money = PublicFunction.NumberFormat(otherMoney),
|
|
|
+ ProfitRate = otherPercent,
|
|
|
+ Message = "分润补贴",
|
|
|
+ BankCardType = BankCardType,
|
|
|
+ QrPayFlag = QrPayFlag,
|
|
|
+ DirectFlag = 1,
|
|
|
+ BrandId = pos.BrandId,
|
|
|
+ IsSubsidy = 1,
|
|
|
+ MerchantId = pos.BindMerchantId,
|
|
|
+ TradeAmount = TradeAmt,
|
|
|
+ HelpFlag = HelpTime,
|
|
|
+ PosSn = pos.PosSn,
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ curLevel = UserLevel;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ LogHelper.Instance.WriteLog("\n\n", "老规则分润日志");
|
|
|
+ }
|
|
|
+ catch (Exception ex)
|
|
|
+ {
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "每月统计分润异常");
|
|
|
+ }
|
|
|
+ dbnew.Dispose();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ LogHelper.Instance.WriteLog(DateTime.Now.ToString(), "老规则分润日志");
|
|
|
+ LogHelper.Instance.WriteLog("\r\n\r\n", "老规则分润日志");
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ public void StartSetDivi()
|
|
|
+ {
|
|
|
+ Thread th = new Thread(StartSetDiviDo);
|
|
|
+ th.IsBackground = true;
|
|
|
+ th.Start();
|
|
|
+ }
|
|
|
+ public void StartSetDiviDo()
|
|
|
+ {
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+ string content = RedisDbconn.Instance.RPop<string>("ConsumerOrdersSetDivi");
|
|
|
+ if (!string.IsNullOrEmpty(content))
|
|
|
+ {
|
|
|
+ SetDivi(content);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Thread.Sleep(10000);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public void SetDivi(string content)
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
+ JsonData jsonObj = JsonMapper.ToObject(content);
|
|
|
+ int orderId = int.Parse(function.CheckInt(jsonObj["OrderId"].ToString()));
|
|
|
+ decimal diviAmt = decimal.Parse(function.CheckNum(jsonObj["DiviAmt"].ToString()));
|
|
|
+ WebCMSEntities db = new WebCMSEntities();
|
|
|
+ ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == orderId);
|
|
|
+ if(order != null)
|
|
|
+ {
|
|
|
+ order.CurDivi = diviAmt;
|
|
|
+ db.SaveChanges();
|
|
|
+ }
|
|
|
+ db.Dispose();
|
|
|
+ }
|
|
|
+ catch(Exception ex)
|
|
|
+ {
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "设置订单当前返现金额异常");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+}
|
