/***********************************************************************
|
* Project: CoreCms
|
* ProjectName: 百分兵法管理系统
|
* Web: hhtp://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Loging;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.Basics;
|
using CoreCms.Net.Model.ViewModels.DTO.Distribution;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using CoreCms.Net.Utility.Helper;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using NPOI.SS.Formula.Functions;
|
using SqlSugar;
|
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 经销商表 接口实现
|
/// </summary>
|
public class CoreCmsDistributionServices : BaseServices<CoreCmsDistribution>, ICoreCmsDistributionServices
|
{
|
private readonly ICoreCmsDistributionRepository _dal;
|
private readonly ICoreCmsDistributionOrderRepository _distributionOrderRepository;
|
private readonly ICoreCmsDistributionGradeRepository _distributionGradeRepository;
|
private readonly ICoreCmsDistributionResultRepository _distributionResultRepository;
|
private readonly ICoreCmsDistributionConditionServices _coreCmsDistributionConditionServices;
|
private readonly ICoreCmsUserRepository _userRepository;
|
private readonly ICoreCmsGoodsRepository _goodsRepository;
|
private readonly ICoreCmsUserGradeRepository _userGradeRepository;
|
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)
|
{
|
this._dal = dal;
|
_distributionOrderRepository = distributionOrderRepository;
|
_userRepository = userRepository;
|
_goodsRepository = goodsRepository;
|
_userGradeRepository = userGradeRepository;
|
_settingServices = settingServices;
|
_orderRepository = orderRepository;
|
_distributionGradeRepository = distributionGradeRepository;
|
_distributionResultRepository = distributionResultRepository;
|
_coreCmsDistributionConditionServices = coreCmsDistributionConditionServices;
|
base.BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
}
|
|
#region 获取经销商信息
|
/// <summary>
|
/// 获取经销商信息
|
/// </summary>
|
/// <param name="userId">用户id</param>
|
/// <param name="checkStatus">是否检查满足条件</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetInfo(int userId, bool checkStatus = false)
|
{
|
var jm = new WebApiCallBack();
|
|
var allConfigs = await _settingServices.GetConfigDictionaries();
|
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info != null && info.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes)
|
{
|
//总金额
|
info.TotalSettlementAmount = await _distributionOrderRepository.GetSumAsync(
|
p => p.isSettlement != (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementCancel && p.userId == userId,
|
p => p.amount);
|
//已结算金额
|
info.SettlementAmount = await _distributionOrderRepository.GetSumAsync(
|
p => p.isSettlement == (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementYes && p.userId == userId,
|
p => p.amount);
|
//冻结金额
|
info.FreezeAmount = await _distributionOrderRepository.GetSumAsync(
|
p => p.isSettlement == (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementNo && p.userId == userId,
|
p => p.amount);
|
var dt = DateTime.Now;
|
//本月第一天时间
|
DateTime dtFirst = dt.AddDays(1 - (dt.Day));
|
dtFirst = new DateTime(dtFirst.Year, dtFirst.Month, dtFirst.Day, 0, 0, 0);
|
|
//获得某年某月的天数
|
int year = dt.Year;
|
int month = dt.Month;
|
int dayCount = DateTime.DaysInMonth(year, month);
|
DateTime dtLast = dtFirst.AddDays(dayCount - 1);
|
//本月订单数
|
info.CurrentMonthOrder = await _distributionOrderRepository.GetCountAsync(p =>
|
p.createTime >= dtFirst && p.createTime < dtLast && p.userId == userId);
|
|
info.Store = UserHelper.GetShareCodeByUserId(userId).ToString();
|
|
//本日开始结束时间
|
var day = dt.Day;
|
var dayStart = new DateTime(year, month, day, 0, 0, 0);
|
var datEnd = new DateTime(year, month, day, 23, 59, 59);
|
//今日收益
|
info.TodayFreezeAmount = await _distributionOrderRepository.GetSumAsync(
|
p => p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId,
|
p => p.amount);
|
//今日订单
|
info.TodayOrder = await _distributionOrderRepository.GetCountAsync(
|
p => p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId);
|
//今日会员
|
info.TodayUser = await _userRepository.GetCountAsync(p =>
|
p.parentId == userId && p.createTime > dayStart && p.createTime <= datEnd);
|
}
|
else if (info == null)
|
{
|
info = new CoreCmsDistribution();
|
}
|
info.TotalGoods = await _goodsRepository.GetCountAsync(p => p.isMarketable == true);
|
if (info.gradeId > 0)
|
{
|
var userGrade = await _userGradeRepository.QueryByIdAsync(info.gradeId);
|
if (userGrade != null)
|
{
|
info.GradeName = userGrade.title;
|
}
|
}
|
//检查是否满足条件
|
if ((checkStatus == true && info.id == 0) || info.verifyStatus != (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes)
|
{
|
info.NeedApply = true; //是否需要申请
|
info.ConditionMsg = "您的条件已满足。（点击申请）";
|
|
//无需审核,但是需要满足条件
|
var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
|
if (distributionType > 0 && distributionType == 3)
|
{
|
info.NeedApply = false;
|
info.ConditionStatus = false;//条件状态
|
info.ConditionProgress = 0;
|
|
//满足条件，直接成为会员
|
await CheckCondition(allConfigs, info, userId);
|
if (info.ConditionStatus == true && info.ConditionProgress == 100)
|
{
|
//添加用户
|
var userModel = await _userRepository.QueryByIdAsync(userId);
|
if (userModel != null)
|
{
|
var iData = new CoreCmsDistribution();
|
iData.name = !string.IsNullOrEmpty(userModel.nickName)
|
? userModel.nickName
|
: userModel.mobile;
|
iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes;
|
iData.verifyTime = DateTime.Now;
|
|
await AddData(iData, userId);
|
info.ConditionProgress = 100;
|
info.ConditionStatus = true;//条件状态
|
}
|
}
|
}
|
else
|
{
|
//无条件，但是需要审核
|
if (distributionType > 0 && distributionType == 1)
|
{
|
info.NeedApply = true;
|
info.ConditionProgress = 100;
|
info.ConditionStatus = true;//条件状态
|
info.ConditionMsg = "您的条件已满足。（前往申请）";
|
}
|
else if (distributionType > 0 && distributionType == 2)
|
{
|
await CheckCondition(allConfigs, info, userId);
|
}
|
}
|
}
|
|
jm.msg = "获取成功";
|
jm.status = true;
|
jm.data = info;
|
|
return jm;
|
}
|
#endregion
|
|
#region 添加用户信息
|
/// <summary>
|
/// 添加用户信息
|
/// </summary>
|
/// <param name="iData"></param>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> AddData(CoreCmsDistribution iData, int userId)
|
{
|
var jm = new WebApiCallBack();
|
if (string.IsNullOrEmpty(iData.mobile))
|
{
|
jm.msg = "请填写手机号";
|
return jm;
|
}
|
if (CommonHelper.IsMobile(iData.mobile) == false)
|
{
|
jm.msg = "请填写正确的手机号";
|
return jm;
|
}
|
if (string.IsNullOrEmpty(iData.name))
|
{
|
jm.msg = "请填写您的姓名";
|
return jm;
|
}
|
iData.userId = userId;
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info != null)
|
{
|
jm.status = false;
|
jm.msg = "您已申请，请勿重复提交";
|
return jm;
|
}
|
//默认等级处理
|
if (iData.gradeId == 0)
|
{
|
var disGradeModel = await _distributionGradeRepository.QueryByClauseAsync(p => p.isDefault == true);
|
if (disGradeModel != null)
|
{
|
iData.gradeId = disGradeModel.id;
|
}
|
}
|
|
var allConfigs = await _settingServices.GetConfigDictionaries();
|
var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
|
if (distributionType == (int)GlobalEnumVars.DistributionConditionType.NoReview)
|
{
|
iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes;
|
}
|
else
|
{
|
iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyWait;
|
}
|
|
iData.isDelete = false;
|
iData.createTime = DateTime.Now;
|
|
//判断是否存在
|
var bl = await _dal.InsertAsync(iData) > 0;
|
jm.status = bl;
|
jm.msg = bl ? "申请成功" : "申请失败";
|
|
return jm;
|
}
|
#endregion
|
|
#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);
|
//支付金额
|
var payed = await _orderRepository.GetSumAsync(
|
p => p.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes && p.userId == userId, p => p.payedAmount);
|
if (payed < distributionMoney && distributionMoney > 0)
|
{
|
info.ConditionMsg = "您的消费额度未满足" + distributionMoney + "元无法申请，快去下单吧~";
|
}
|
else
|
{
|
info.ConditionProgress = 50;
|
//判断是否需要购买商品
|
var distributionGoods = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionGoods).ObjectToInt(0);
|
if (distributionGoods is > 0 and 1)
|
{
|
info.ConditionProgress += 50;
|
info.ConditionStatus = true;//条件状态
|
info.ConditionMsg = "您的条件已满足，马上申请。";
|
}
|
else
|
{
|
//任意商品
|
if (distributionGoods is > 0 and 2)
|
{
|
var orderCount = await _orderRepository.GetCountAsync(p =>
|
p.userId == userId && p.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes);
|
if (orderCount >= 1)
|
{
|
info.ConditionProgress += 50;
|
info.ConditionStatus = true;//条件状态
|
info.ConditionMsg = "您的条件已满足，马上申请。";
|
}
|
else
|
{
|
info.ConditionMsg = "您的条件未满足，请任意购买一件商品即可成为经销商。";
|
}
|
}
|
else if (distributionGoods is > 0 and 3) //购买指定商品
|
{
|
//判断是否购买指定商品
|
var distributionGoodsId = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionGoodsId).ObjectToInt(0);
|
var orderNum = _orderRepository.GetOrderNum(userId, distributionGoodsId);
|
if (orderNum >= 1)
|
{
|
info.ConditionProgress += 50;
|
info.ConditionStatus = true;//条件状态
|
info.ConditionMsg = "您的条件已满足，马上申请。";
|
}
|
else
|
{
|
var goodsInfo = await _goodsRepository.QueryByIdAsync(distributionGoodsId);
|
if (goodsInfo != null)
|
{
|
info.ConditionMsg = "您的条件未满足，请购买指定的【" + goodsInfo.name + "】商品即可成为经销商。";
|
}
|
else
|
{
|
info.ConditionMsg = "您的条件未满足，请购买指定的商品即可成为经销商。";
|
|
}
|
}
|
|
}
|
|
}
|
}
|
}
|
|
#endregion
|
|
#region 获取我的推广订单
|
|
/// <summary>
|
/// 获取我的推广订单
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <param name="page"></param>
|
/// <param name="limit"></param>
|
/// <param name="typeId">类型</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetMyOrderList(int userId, int page, int limit = 10, int typeId = 0)
|
{
|
var jm = new WebApiCallBack();
|
|
jm.status = true;
|
jm.msg = "获取成功";
|
var pageList = await _dal.QueryOrderPageAsync(userId, page, limit, typeId);
|
jm.data = pageList;
|
jm.code = pageList.TotalCount;
|
|
return jm;
|
}
|
#endregion
|
|
#region 获取店铺信息
|
/// <summary>
|
/// 获取店铺信息
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetStore(int userId)
|
{
|
var jm = new WebApiCallBack();
|
|
jm.status = true;
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info != null)
|
{
|
info.TotalGoods = await _goodsRepository.GetCountAsync(p => p.isMarketable == true && p.isDel == false);
|
jm.data = new
|
{
|
info.createTime,
|
info.name,
|
info.storeBanner,
|
info.storeDesc,
|
info.storeLogo,
|
info.storeName,
|
info.TotalGoods
|
};
|
}
|
|
return jm;
|
}
|
#endregion
|
|
#region 获取当前用户返佣设置
|
/// <summary>
|
/// 获取当前用户返佣设置
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetGradeAndCommission(int userId)
|
{
|
var jm = new WebApiCallBack();
|
|
var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
|
if (info == null)
|
{
|
jm.msg = "不是经销商的，不返利";
|
return jm;
|
}
|
var allConfigs = await _settingServices.GetConfigDictionaries();
|
var dto = new DistributionDto();
|
if (info.gradeId > 0)
|
{
|
var res = await _distributionResultRepository.QueryListByClauseAsync(p => p.gradeId == info.gradeId, p => p.id, OrderByType.Asc, true, true);
|
if (res != null && res.Any())
|
{
|
dto.grade_id = info.gradeId;
|
res.ForEach(p =>
|
{
|
var obj = JObject.Parse(p.parameters);
|
switch (p.code)
|
{
|
case "COMMISSION_1":
|
dto.commission_1 = new Commission()
|
{
|
type = obj["commissionType"].ObjectToInt(0),
|
discount = obj["discount"].ObjectToDecimal(0)
|
};
|
break;
|
case "COMMISSION_2":
|
dto.commission_2 = new Commission()
|
{
|
type = obj["commissionType"].ObjectToInt(0),
|
discount = obj["discount"].ObjectToDecimal(0)
|
};
|
break;
|
case "COMMISSION_3":
|
dto.commission_3 = new Commission()
|
{
|
type = obj["commissionType"].ObjectToInt(0),
|
discount = obj["discount"].ObjectToDecimal(0)
|
};
|
break;
|
}
|
});
|
}
|
else
|
{
|
jm.msg = "未获取到佣金设置，不返利";
|
return jm;
|
}
|
}
|
jm.status = true;
|
jm.data = dto;
|
jm.msg = "获取成功";
|
|
return jm;
|
}
|
#endregion
|
|
#region 检查当前用户是否可以升级
|
|
/// <summary>
|
/// 检查当前用户是否可以升级
|
/// </summary>
|
/// <param name="userId"></param>
|
/// <returns></returns>
|
public async Task<AdminUiCallBack> CheckUpdate(int userId)
|
{
|
var jm = new AdminUiCallBack();
|
|
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;
|
{
|
var condition = true;//默认满足升级
|
var conditionList = await _coreCmsDistributionConditionServices.QueryListByClauseAsync(p => p.gradeId == grade.id);
|
if (!conditionList.Any())
|
{
|
jm.msg = "未设置条件，无法升级";
|
return jm;
|
}
|
//循环所有条件，判断是否可以升级
|
foreach (var item in conditionList)
|
{
|
var parameters = (JObject)JsonConvert.DeserializeObject(item.parameters);
|
if (parameters == null)
|
{
|
condition = false;
|
break;
|
}
|
|
//只要购买了商品并且订单完结。
|
if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.GOODS_ALL.ToString(), StringComparison.CurrentCultureIgnoreCase))
|
{
|
if (!parameters.ContainsKey("num"))
|
{
|
condition = false;
|
break;
|
}
|
var num = parameters["num"].ObjectToInt(0);
|
var getCount = await _orderRepository.GetCountAsync(p =>
|
p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED);
|
condition = getCount > num;
|
if (condition == false)
|
{
|
break;
|
}
|
}
|
//购买了指定的商品
|
if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.GOODS_IDS.ToString(), StringComparison.CurrentCultureIgnoreCase))
|
{
|
//goodsId
|
if (!parameters.ContainsKey("goodsId"))
|
{
|
condition = false;
|
break;
|
}
|
var goodsId = parameters["goodsId"].ObjectToInt(0);
|
var getCount = _orderRepository.GetOrderNum(userId, goodsId, (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED);
|
condition = getCount > 0;
|
if (condition == false)
|
{
|
break;
|
}
|
}
|
//个人消费总额(已完成的订单)
|
if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.USER_ORDERS.ToString(), StringComparison.CurrentCultureIgnoreCase))
|
{
|
if (!parameters.ContainsKey("money") || !parameters.ContainsKey("limit_day"))
|
{
|
condition = false;
|
break;
|
}
|
var money = parameters["money"].ObjectToInt(0);
|
var limitDay = parameters["limit_day"].ObjectToInt(0);
|
|
var startTime = DateTime.Now.AddDays(-limitDay);
|
var endTime = DateTime.Now;
|
|
var getAmount = await _orderRepository.GetSumAsync(p => p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED && p.paymentTime > startTime && p.paymentTime < endTime, p => p.orderAmount);
|
|
condition = getAmount > money;
|
|
if (condition == false)
|
{
|
break;
|
}
|
}
|
//个人订单数量(已完成的订单)
|
if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.USER_ORDERSNUM.ToString(), StringComparison.CurrentCultureIgnoreCase))
|
{
|
|
if (!parameters.ContainsKey("num") || !parameters.ContainsKey("limit_day"))
|
{
|
condition = false;
|
break;
|
}
|
var num = parameters["num"].ObjectToInt(0);
|
var limitDay = parameters["limit_day"].ObjectToInt(0);
|
|
var startTime = DateTime.Now.AddDays(-limitDay);
|
var endTime = DateTime.Now;
|
|
var getCount = await _orderRepository.GetCountAsync(p => p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED && p.paymentTime > startTime && p.paymentTime < endTime);
|
|
condition = getCount > num;
|
if (condition == false)
|
{
|
break;
|
}
|
}
|
}
|
if (condition)
|
{
|
await _dal.UpdateAsync(p => new CoreCmsDistribution() { gradeId = grade.id }, p => p.userId == userId);
|
jm.msg = "升级成功";
|
}
|
else
|
{
|
jm.msg = "条件暂不满足，无法升级";
|
}
|
}
|
}
|
return jm;
|
}
|
#endregion
|
|
|
/// <summary>
|
/// 获取代理商排行
|
/// </summary>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <returns></returns>
|
public async Task<IPageList<DistributionRankingDTO>> QueryRankingPageAsync(int pageIndex = 1, int pageSize = 20)
|
{
|
return await _dal.QueryRankingPageAsync(pageIndex, pageSize);
|
}
|
|
|
#region 重写根据条件查询分页数据
|
/// <summary>
|
/// 重写根据条件查询分页数据
|
/// </summary>
|
/// <param name="predicate">判断集合</param>
|
/// <param name="orderByType">排序方式</param>
|
/// <param name="pageIndex">当前页面索引</param>
|
/// <param name="pageSize">分布大小</param>
|
/// <param name="orderByExpression"></param>
|
/// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
|
/// <returns></returns>
|
public async Task<IPageList<CoreCmsDistribution>> QueryPageAsync(Expression<Func<CoreCmsDistribution, bool>> predicate,
|
Expression<Func<CoreCmsDistribution, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
|
int pageSize = 20, bool blUseNoLock = false)
|
{
|
return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize, blUseNoLock);
|
}
|
#endregion
|
|
|
}
|
}
|
