baifenbaishop.git

			@@ -1,7 +1,7 @@
			/***********************************************************************
			* Project: CoreCms
			* Project: baifenBinfa
			* ProjectName: 百分兵法管理系统
			* Web: hhtp://chuanyin.com
			* Web: http://chuanyin.com
			* Author:
			* Email:
			* CreateTime: 202403/02
			@@ -19,6 +19,7 @@
			using CoreCms.Net.IServices;
			using CoreCms.Net.Loging;
			using CoreCms.Net.Model.Entities;
			using CoreCms.Net.Model.Entities.Distribution;
			using CoreCms.Net.Model.ViewModels.Basics;
			using CoreCms.Net.Model.ViewModels.DTO.Distribution;
			using CoreCms.Net.Model.ViewModels.UI;
			@@ -27,13 +28,15 @@
			using Newtonsoft.Json;
			using Newtonsoft.Json.Linq;
			using NPOI.SS.Formula.Functions;
			using Org.BouncyCastle.Asn1.Cmp;
			using SqlSugar;
			using static CoreCms.Net.Configuration.GlobalEnumVars;


			namespace CoreCms.Net.Services
			{
			/// <summary>
			/// 分销商表接口实现
			/// 经销商表接口实现
			/// </summary>
			public class CoreCmsDistributionServices : BaseServices<CoreCmsDistribution>, ICoreCmsDistributionServices
			{
			@@ -48,7 +51,9 @@
			private readonly ICoreCmsOrderRepository _orderRepository;
			private readonly ICoreCmsSettingServices _settingServices;
			private readonly IUnitOfWork _unitOfWork;
			public CoreCmsDistributionServices(IUnitOfWork unitOfWork, ICoreCmsDistributionRepository dal, ICoreCmsDistributionOrderRepository distributionOrderRepository, ICoreCmsUserRepository userRepository, ICoreCmsGoodsRepository goodsRepository, ICoreCmsUserGradeRepository userGradeRepository, ICoreCmsSettingServices settingServices, ICoreCmsOrderRepository orderRepository, ICoreCmsDistributionGradeRepository distributionGradeRepository, ICoreCmsDistributionResultRepository distributionResultRepository, ICoreCmsDistributionConditionServices coreCmsDistributionConditionServices)
			private readonly ICoreCmsUserBalanceServices _userBalanceServices;

			public CoreCmsDistributionServices(IUnitOfWork unitOfWork, ICoreCmsDistributionRepository dal, ICoreCmsDistributionOrderRepository distributionOrderRepository, ICoreCmsUserRepository userRepository, ICoreCmsGoodsRepository goodsRepository, ICoreCmsUserGradeRepository userGradeRepository, ICoreCmsSettingServices settingServices, ICoreCmsOrderRepository orderRepository, ICoreCmsDistributionGradeRepository distributionGradeRepository, ICoreCmsDistributionResultRepository distributionResultRepository, ICoreCmsDistributionConditionServices coreCmsDistributionConditionServices, ICoreCmsUserBalanceServices userBalanceServices)
			{
			this._dal = dal;
			_distributionOrderRepository = distributionOrderRepository;
			@@ -62,11 +67,14 @@
			_coreCmsDistributionConditionServices = coreCmsDistributionConditionServices;
			base.BaseDal = dal;
			_unitOfWork = unitOfWork;
			_userBalanceServices = userBalanceServices;


			}

			#region 获取分销商信息
			#region 获取经销商信息
			/// <summary>
			/// 获取分销商信息
			/// 获取经销商信息
			/// </summary>
			/// <param name="userId">用户id</param>
			/// <param name="checkStatus">是否检查满足条件</param>
			@@ -262,14 +270,14 @@
			}
			#endregion

			#region 检查是否可以成为分销商
			//检查是否可以成为分销商
			#region 检查是否可以成为经销商
			//检查是否可以成为经销商
			public async Task CheckCondition(Dictionary<string, DictionaryKeyValues> allConfigs, CoreCmsDistribution info, int userId = 0)
			{
			//判断消费
			info.ConditionStatus = false;//条件状态
			info.ConditionProgress = 0;
			//获取成为分销商条件
			//获取成为经销商条件
			//var DistributionType = CommonHelper.GetConfigDictionary(allConfigs, GlobalSettingConstVars.DistributionType).ObjectToInt(0);
			var distributionMoney = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionMoney).ObjectToInt(0);
			//支付金额
			@@ -305,7 +313,7 @@
			}
			else
			{
			info.ConditionMsg = "您的条件未满足，请任意购买一件商品即可成为分销商。";
			info.ConditionMsg = "您的条件未满足，请任意购买一件商品即可成为经销商。";
			}
			}
			else if (distributionGoods is > 0 and 3) //购买指定商品
			@@ -324,11 +332,11 @@
			var goodsInfo = await _goodsRepository.QueryByIdAsync(distributionGoodsId);
			if (goodsInfo != null)
			{
			info.ConditionMsg = "您的条件未满足，请购买指定的【" + goodsInfo.name + "】商品即可成为分销商。";
			info.ConditionMsg = "您的条件未满足，请购买指定的【" + goodsInfo.name + "】商品即可成为经销商。";
			}
			else
			{
			info.ConditionMsg = "您的条件未满足，请购买指定的商品即可成为分销商。";
			info.ConditionMsg = "您的条件未满足，请购买指定的商品即可成为经销商。";

			}
			}
			@@ -409,7 +417,7 @@
			var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
			if (info == null)
			{
			jm.msg = "不是分销商的，不返利";
			jm.msg = "不是经销商的，不返利";
			return jm;
			}
			var allConfigs = await _settingServices.GetConfigDictionaries();
			@@ -477,7 +485,7 @@
			var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
			if (info is { gradeId: > 0 })
			{
			//找下有没有可以升级的分销商等级（一次只升一级）
			//找下有没有可以升级的经销商等级（一次只升一级）
			var grade = await _distributionGradeRepository.QueryByClauseAsync(p => p.sortId > info.gradeId && p.isAutoUpGrade == true, p => p.sortId, OrderByType.Asc, true);
			if (grade == null) return jm;
			{
			@@ -624,8 +632,110 @@
			{
			return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize, blUseNoLock);
			}


			#endregion

			public async Task<(decimal,DateTime?, DateTime?)> AchievementTotal(int UserId)
			{
			var StartTime= await _unitOfWork.GetDbClient()
			.Queryable<DistributionAchievement>()
			.Where(x=>x.userID == UserId&&x.isdelete==false)
			.Select(x=>x.endTime)
			.OrderByDescending(x=>x)
			.FirstAsync();
			if (StartTime == null)
			///最多统计两年内的业绩
			StartTime = DateTime.Now.AddYears(-2);
			else
			StartTime= StartTime.Value.AddSeconds(1);
			var endTime = DateTime.Now;
			//payStatus = (int)GlobalEnumVars.OrderPayStatus.Refunded,
			// status = (int)GlobalEnumVars.OrderStatus.Complete
			//var result = await _balanceServices.Change(item.userId, (int)GlobalEnumVars.UserBalanceSourceTypes.Distribution,
			// item.amount, item.orderId);
			var total= await _unitOfWork.GetDbClient().Queryable<CoreCmsOrder>().Where(x => x.status == (int)GlobalEnumVars.OrderStatus.Complete
			&& (x.payStatus != (int)GlobalEnumVars.OrderPayStatus.No \|\| x.payStatus != (int)GlobalEnumVars.OrderPayStatus.Refunded)
			&& x.isdel == false
			&& x.updateTime > StartTime
			&& x.updateTime < endTime
			).SumAsync(x => x.orderAmount);

			var orderToler= await _unitOfWork.GetDbClient().Queryable<DistributionAchievementOrder>().Where(x => x.userID == UserId
			&& x.createTime > StartTime
			&& x.createTime < endTime).SumAsync(x => x.achievementTotal);
			total = total + orderToler;
			if (total==0)
			return (total,null, null);
			else
			return (total, StartTime, endTime);
			}

			public async Task<decimal> AchievementBonus(decimal AttributeTotal)
			{

			var allConfigs = await _settingServices.GetConfigDictionaries();
			var key = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DictionaryAchievementSet).ObjectToInt(0);
			return AttributeTotal *(decimal)key / 100;
			}

			public async Task<bool> SettledAchievement(int UserId)
			{
			//非供应商，停止
			var da = await _dal.GetCountAsync(x => x.userId == UserId && x.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes, isDataCache: true, cacheTimes: 1);
			if (da == 0)
			return true;
			var att = await AchievementTotal(UserId);
			if(att.Item1>0)
			{
			DistributionAchievement oder = new DistributionAchievement
			{
			achievementTotals = att.Item1,
			achievementBonus = await AchievementBonus(att.Item1),
			createBy="系统结算",
			createTime=DateTime.Now,
			startTime=att.Item2,
			endTime = att.Item3,
			userID = UserId

			};
			//建立结算单
			var id= await _unitOfWork.GetDbClient().Insertable(oder).ExecuteCommandIdentityIntoEntityAsync();
			var a= await _userBalanceServices.Change(UserId, (int )UserBalanceSourceTypes.DistributionAchievement,
			oder.achievementBonus,id.ToString());
			if(a.code!=0)
			{
			NLogUtil.WriteAll(NLog.LogLevel.Fatal, LogType.DataBase, "经销商业绩提成写入余额失败", a.msg);
			return false;
			}
			return true;
			}
			return true;
			}


			public async Task<bool> CreateDistributionAchievementOrder(CreateDAOrderInParam Parma)
			{
			//非供应商，停止
			var da= await _dal.GetCountAsync(x=>x.userId== Parma.UserID && x.verifyStatus== (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes,isDataCache:true,cacheTimes:1);
			if (da == 0)
			return true;
			var oder = new DistributionAchievementOrder
			{
			achievementTotal = Parma.Money,
			createBy = "经销商业绩写入",
			createTime = DateTime.Now,
			orderId = Parma.OderId,
			userID = Parma.UserID,
			orderType=(int ) Parma.SourceTypes




			};

			return await _unitOfWork.GetDbClient().Updateable(oder).ExecuteCommandAsync()>0;

			}
			}
			}